Adding generation of followers

Author: mahomedalid

src/ActivityPubDotNet.Core/Storage/FollowersGenerator.cs

@@ -0,0 +1,89 @@
+using System.Security.Cryptography;
+using System.Text;
+using System.Text.Json;
+using Azure.Data.Tables;
+using Azure.Storage.Blobs;
+using Azure.Storage.Blobs.Models;
+
+namespace ActivityPubDotNet.Core.Storage
+{
+    public class FollowersGenerator(TableServiceClient tableServiceClient, BlobServiceClient blobServiceClient)
+    {
+        internal class ContextNamePolicy : JsonNamingPolicy
+        {
+            public override string ConvertName(string name)
+            {
+                if (name.Equals("_context"))
+                {
+                    return "@context";
+                }
+
+                return name;
+            }
+        }
+
+        private readonly TableServiceClient tableServiceClient = tableServiceClient;
+
+        private readonly BlobServiceClient blobServiceClient = blobServiceClient;
+
+        private const string FollowersTable = "followers";
+
+        public string Domain { get; set; } = default!;
+
+        public async Task Generate()
+        {
+            var table = tableServiceClient.GetTableClient(FollowersTable);
+
+            var query = table.QueryAsync<Reply>();
+
+            var items = new List<string>();
+
+            await foreach (var item in query)
+            {
+                items.Add(item.Id);
+            }
+
+            var repliesPage = new
+            {
+                _context = "https://www.w3.org/ns/activitystreams",
+                // generate Id 
+                id = $"{Domain!}/socialweb/followers",
+                type = "CollectionPage",
+                items
+            };
+
+            //Store into a blob in the container $web, and path "/socialweb/replies/{noteId}"
+
+            var containerClient = blobServiceClient.GetBlobContainerClient("$web");
+
+            // Serialize the repliesPage object to JSON
+            string jsonContent = JsonSerializer.Serialize(repliesPage, new JsonSerializerOptions
+            {
+                PropertyNamingPolicy = new ContextNamePolicy(),
+                WriteIndented = true
+            });
+
+            // Generate blob name using MD5 hash of the noteUrl
+            string blobName = $"socialweb/followers";
+
+            // Get a reference to the blob
+            var blobClient = containerClient.GetBlobClient(blobName);
+
+            var blobHttpHeaders = new BlobHttpHeaders
+            {
+                ContentType = "application/activity+json" // Set your custom content type here
+            };
+
+            // Upload the JSON content to the blob
+            using (var stream = new MemoryStream(Encoding.UTF8.GetBytes(jsonContent)))
+            {
+                await blobClient.UploadAsync(stream,
+                    new BlobUploadOptions
+                    {
+                        HttpHeaders = blobHttpHeaders,
+                        Conditions = default
+                    });
+            }
+        }
+    }
+}

src/ActivityPubFunctions/FollowService.cs

@@ -6,8 +6,16 @@
 
 namespace ActivityPubDotNet
 {
-    public class FollowService(TableServiceClient tableServiceClient, ActorHelper actorHelper)
+    public class FollowService(TableServiceClient tableServiceClient, ActorHelper actorHelper, FollowersGenerator followersGenerator)
     {
+        private readonly FollowersGenerator _followersGenerator = followersGenerator;
+
+        public string Domain { get; set; } = default!;
+
+        public string FollowersUrl => $"{Domain}/socialweb/followers";
+
+        public string FollowersPath => $"/socialweb/followers";
+    
         public ILogger? Logger { get; set; }
 
         private readonly string FollowersTable = "followers";
@@ -56,6 +64,11 @@ public async Task CreateFollower(InboxMessage message)
             }
         }
 
+        public async Task UpdateFollowersCollection()
+        {
+            await _followersGenerator.Generate();
+        }
+
         public async Task DeleteFollower(InboxMessage message)
         {
             await _tableServiceClient.CreateTableIfNotExistsAsync(FollowersTable);
@@ -111,7 +124,7 @@ public async Task<AcceptRequest> SendAcceptedFollowRequest(InboxMessage message)
                 PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
             };
 
-            await _actorHelper.SendSignedRequest(JsonSerializer.Serialize(acceptRequest, options), new Uri(actor.Inbox));
+            await _actorHelper.SendPostSignedRequest(JsonSerializer.Serialize(acceptRequest, options), new Uri(actor.Inbox));
 
             return acceptRequest;
         }

src/ActivityPubFunctions/Inbox.cs

@@ -60,6 +60,8 @@ public async Task<HttpResponseData> Run([HttpTrigger(AuthorizationLevel.Anonymou
                 if (message?.IsFollow() ?? false)
                 {
                     await _followService.Follow(message);
+
+                    await _followService.UpdateFollowersCollection();
                 }
                 else if (message?.IsUndoFollow() ?? false)
                 {
@@ -85,6 +87,8 @@ public async Task<HttpResponseData> Run([HttpTrigger(AuthorizationLevel.Anonymou
                     _logger?.LogInformation($"Sending accept request to {actor.Inbox} - {document}");
 
                     await _actorHelper.SendPostSignedRequest(document, new Uri(actor.Inbox));
+
+                    await _followService.UpdateFollowersCollection();
                 }
                 else if (message?.IsCreateActivity() ?? false)
                 {

src/ActivityPubFunctions/Program.cs

@@ -40,6 +40,14 @@
                 provider.GetRequiredService<RepliesGenerator>(),
                 domain);
         }).AddSingleton(provider =>
+        {
+            return new FollowersGenerator(
+                provider.GetRequiredService<TableServiceClient>(),
+                provider.GetRequiredService<BlobServiceClient>())
+            {
+                Domain = hostContext.Configuration.GetSection("BaseDomain").Value!
+            };
+        }).AddSingleton(provider =>
         {
             var privatePem = hostContext.Configuration.GetSection("ActorPrivatePEMKey").Value;
             var keyId = hostContext.Configuration.GetSection("ActorKeyId").Value;
@@ -49,7 +57,8 @@
         {
             return new FollowService(
                 provider.GetRequiredService<TableServiceClient>(),
-                provider.GetRequiredService<ActorHelper>());
+                provider.GetRequiredService<ActorHelper>(),
+                provider.GetRequiredService<FollowersGenerator>());
         }).AddSingleton(provider =>
         {
             return new ServerConfig()