updates

Author: oigbokwe73

AzureServiceBusToSQL.csproj

@@ -9,6 +9,7 @@
     <FrameworkReference Include="Microsoft.AspNetCore.App" />
     <PackageReference Include="Microsoft.ApplicationInsights.WorkerService" Version="2.21.0" />
     <PackageReference Include="Microsoft.Azure.Functions.Worker.ApplicationInsights" Version="1.1.0" />
+    <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.EventGrid" Version="3.5.0" />
     <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.Http" Version="3.1.0" />
     <PackageReference Include="Microsoft.Azure.Functions.Worker.Sdk" Version="1.16.2" />
     <PackageReference Include="Microsoft.Azure.Functions.Worker" Version="1.20.0" />

Filedroptrigger.cs

@@ -0,0 +1,53 @@
+// Default URL for triggering event grid function in the local environment.
+// http://localhost:7071/runtime/webhooks/EventGrid?functionName={functionname}
+
+using System;
+using System.IO;
+using System.Text.Json;
+using Azure.Messaging;
+using Azure.Messaging.EventGrid;
+using Azure.Storage.Blobs;
+using Microsoft.Azure.Functions.Worker;
+using Microsoft.Extensions.Logging;
+using Xenhey.BPM.Core.Net8.Implementation;
+using Xenhey.BPM.Core.Net8;
+using Microsoft.Graph.Models;
+using Newtonsoft.Json;
+using System.Collections.Specialized;
+using Microsoft.Azure.Management.Sql.Fluent.Models;
+
+namespace AzureServiceBusToSQL;
+
+public class Filedroptrigger
+{
+    private readonly ILogger<Filedroptrigger> _logger;
+    private NameValueCollection nvc = new NameValueCollection();
+
+    public Filedroptrigger(ILogger<Filedroptrigger> logger)
+    {
+        _logger = logger;
+    }
+
+    [Function(nameof(Filedroptrigger))]
+    public void Run([EventGridTrigger] EventGridEvent eventGridEvent)
+    {
+        string ApiKeyName = "x-api-key";
+        _logger.LogInformation($"Received event: {eventGridEvent.EventType}");
+
+        if (eventGridEvent.EventType != "Microsoft.Storage.BlobCreated")
+        {
+            _logger.LogWarning("Event is not a BlobCreated event. Skipping.");
+            return;
+        }
+        NameValueCollection nvc = new NameValueCollection
+        {
+            { ApiKeyName, "2484F9382E974133A216F8E39BF4C389" }
+        };
+        var input = JsonConvert.SerializeObject(eventGridEvent);
+        IOrchestrationService orchrestatorService = new RemoteOrchrestratorService(nvc);
+        var processFiles = orchrestatorService.Run(input);
+
+        
+
+    }
+}