Add sharepoint_client block

apps/api/lib/buildel/blocks.ex

@@ -41,7 +41,8 @@ defmodule Buildel.Blocks do
     Image,
     ImageOutput,
     Knowledge,
-    CollectAllAudio
+    CollectAllAudio,
+    SharepointClient
   }
 
   @names_to_blocks_map %{
@@ -81,7 +82,8 @@ defmodule Buildel.Blocks do
     "image" => Image,
     "image_output" => ImageOutput,
     "knowledge" => Knowledge,
-    "collect_all_audio" => CollectAllAudio
+    "collect_all_audio" => CollectAllAudio,
+    "sharepoint_client" => SharepointClient
   }
 
   @blocks_to_names_map %{
@@ -121,7 +123,8 @@ defmodule Buildel.Blocks do
     Image => "image",
     ImageOutput => "image_output",
     Knowledge => "knowledge",
-    CollectAllAudio => "collect_all_audio"
+    CollectAllAudio => "collect_all_audio",
+    SharepointClient => "sharepoint_client"
   }
 
   def list_types() do

apps/api/lib/buildel/blocks/sharepoint_client.ex

@@ -0,0 +1,138 @@
+defmodule Buildel.Blocks.SharepointClient do
+  use Buildel.Blocks.Block
+
+  @impl true
+  def options() do
+    %{
+      type: "sharepoint_client",
+      description: "This module is designed to interact with a SharePoint API.",
+      groups: ["text", "inputs / outputs"],
+      inputs: [Block.text_input("list")],
+      outputs: [Block.text_output("list")],
+      ios: [],
+      dynamic_ios: nil,
+      schema: schema()
+    }
+  end
+
+  @impl true
+  def schema() do
+    %{
+      "type" => "object",
+      "required" => ["name", "inputs"],
+      "properties" => %{
+        "name" => name_schema(),
+        "opts" =>
+          options_schema(%{
+            "required" => ["client_secret", "client_id", "tenant_id"],
+            "properties" => %{
+              "client_secret" =>
+                secret_schema(%{
+                  "title" => "Client secret",
+                  "description" => "Azure app client secret"
+                }),
+              "client_id" => %{
+                "type" => "string",
+                "title" => "Client ID",
+                "description" => "Azure app client ID",
+                "default" => "",
+                "minLength" => 1
+              },
+              "tenant_id" => %{
+                "type" => "string",
+                "title" => "Tenant ID",
+                "description" => "Azure app tenant ID",
+                "default" => "",
+                "minLength" => 1
+              },
+              "site_id" => %{
+                "type" => "string",
+                "title" => "Site ID",
+                "description" => "SharePoint site ID",
+                "default" => "",
+                "minLength" => 1
+              },
+              "drive_id" => %{
+                "type" => "string",
+                "title" => "Drive ID",
+                "description" => "SharePoint drive ID",
+                "default" => "",
+                "minLength" => 1
+              }
+            }
+          })
+      }
+    }
+  end
+
+  @scope "https://graph.microsoft.com/.default"
+
+  @impl true
+  def setup(%{opts: opts, context_id: context_id} = state) do
+    secret = block_context().get_secret_from_context(context_id, opts.client_secret)
+
+    {:ok, access_token} =
+      get_access_token(
+        opts.client_id,
+        secret,
+        opts.tenant_id
+      )
+
+    IO.inspect(access_token)
+
+    {:ok,
+     state
+     |> Map.put(:access_token, access_token)
+     |> Map.put(:site_id, opts.site_id)
+     |> Map.put(:drive_id, opts.drive_id)}
+  end
+
+  defp get_access_token(client_id, client_secret, tenant_id) do
+    url = "https://login.microsoftonline.com/#{tenant_id}/oauth2/v2.0/token"
+
+    body = %{
+      "client_id" => client_id,
+      "client_secret" => client_secret,
+      "scope" => @scope,
+      "grant_type" => "client_credentials"
+    }
+
+    headers = [{"Content-Type", "application/x-www-form-urlencoded"}]
+
+    case Req.new(url: url) |> Req.post(form: body, headers: headers) do
+      {:ok, %Req.Response{status: 200, body: body}} ->
+        {:ok, body["access_token"]}
+
+      {:ok, %Req.Response{body: reason}} ->
+        {:error, reason}
+
+      {:error, reason} ->
+        {:error, reason}
+    end
+  end
+
+  @impl true
+  def handle_input("list", {_topic, :text, text, _metadata}, state) do
+    {:ok, documents} = list_documents(state)
+
+    state |> output("list", {:text, Jason.encode!(documents)})
+  end
+
+  defp list_documents(state) do
+    url =
+      "https://graph.microsoft.com/v1.0/sites/#{state.site_id}/drives/#{state.drive_id}/root/children"
+
+    headers = [{"Authorization", "Bearer #{state.access_token}"}]
+
+    case Req.new(url: url) |> Req.get(headers: headers) do
+      {:ok, %Req.Response{status: 200, body: body}} ->
+        {:ok, body}
+
+      {:ok, %Req.Response{body: reason}} ->
+        {:error, reason}
+
+      {:error, reason} ->
+        {:error, reason}
+    end
+  end
+end