chor: sdk update

src/ChatClient.cs

@@ -64,7 +64,7 @@
         }
 
         // Delete campaign
         public async Task<StreamResponse<DeleteCampaignResponse>> DeleteCampaignAsync(string id, object request = null,
             CancellationToken cancellationToken = default)
         {
             var pathParams = new Dictionary<string, string>
@@ -80,7 +80,7 @@
         }
 
         // Get campaign by ID.
         public async Task<StreamResponse<GetCampaignResponse>> GetCampaignAsync(string id, object request = null,
             CancellationToken cancellationToken = default)
         {
             var pathParams = new Dictionary<string, string>
@@ -260,7 +260,7 @@
 
         // Sends events:
         // - channel.deleted
         public async Task<StreamResponse<DeleteChannelResponse>> DeleteChannelAsync(string type, string id, object request = null,
             CancellationToken cancellationToken = default)
         {
             var pathParams = new Dictionary<string, string>
@@ -278,7 +278,7 @@
         }
 
         // Returns a channel by its CID without creating it. Responds with 404 when the channel does not exist, so it doubles as an existence check. Pass state=true to also load messages, read state and watchers.
         public async Task<StreamResponse<ChannelStateResponse>> GetChannelAsync(string type, string id, object request = null,
             CancellationToken cancellationToken = default)
         {
             var pathParams = new Dictionary<string, string>
@@ -343,7 +343,7 @@
 
         // Sends events:
         // - draft.deleted
         public async Task<StreamResponse<Response>> DeleteDraftAsync(string type, string id, object request = null,
             CancellationToken cancellationToken = default)
         {
             var pathParams = new Dictionary<string, string>
@@ -361,7 +361,7 @@
         }
 
         // Get a draft
         public async Task<StreamResponse<GetDraftResponse>> GetDraftAsync(string type, string id, object request = null,
             CancellationToken cancellationToken = default)
         {
             var pathParams = new Dictionary<string, string>
@@ -396,7 +396,7 @@
         }
 
         // Deletes previously uploaded file
         public async Task<StreamResponse<Response>> DeleteChannelFileAsync(string type, string id, object request = null,
             CancellationToken cancellationToken = default)
         {
             var pathParams = new Dictionary<string, string>
@@ -451,7 +451,7 @@
         }
 
         // Deletes previously uploaded image
         public async Task<StreamResponse<Response>> DeleteChannelImageAsync(string type, string id, object request = null,
             CancellationToken cancellationToken = default)
         {
             var pathParams = new Dictionary<string, string>
@@ -506,6 +506,7 @@
         // Sends new message to the specified channel
 
         // Sends events:
+        // - channel.visible
         // - message.new
         // - message.updated
         public async Task<StreamResponse<SendMessageResponse>> SendMessageAsync(string type, string id, SendMessageRequest request,

src/CommonClient.cs

@@ -104,6 +104,21 @@ public async Task<StreamResponse<CreateBlockListResponse>> CreateBlockListAsync(
 
             return result;
         }
+        public async Task<StreamResponse<ImportBlockListResponse>> ImportBlockListAsync(string id, ImportBlockListRequest request,
+            CancellationToken cancellationToken = default)
+        {
+            var pathParams = new Dictionary<string, string>
+            {
+                ["id"] = id,
+            };
+
+            var result = await MakeRequestAsync<ImportBlockListRequest, ImportBlockListResponse>(
+                "POST",
+                "/api/v2/blocklists/{id}/import", null, request, pathParams,
+                cancellationToken);
+
+            return result;
+        }
         public async Task<StreamResponse<Response>> DeleteBlockListAsync(string name, object request = null,
             CancellationToken cancellationToken = default)
         {
@@ -642,11 +657,10 @@ public async Task<StreamResponse<PollOptionResponse>> GetPollOptionAsync(string
                 ["poll_id"] = pollID,
                 ["option_id"] = optionID,
             };
-            var queryParams = ExtractQueryParams(request);
 
             var result = await MakeRequestAsync<object, PollOptionResponse>(
                 "GET",
-                "/api/v2/polls/{poll_id}/options/{option_id}", queryParams, null, pathParams,
+                "/api/v2/polls/{poll_id}/options/{option_id}", null, null, pathParams,
                 cancellationToken);
 
             return result;

src/ModerationClient.cs

@@ -403,25 +403,33 @@ public async Task<StreamResponse<UpsertModerationRuleResponse>> UpsertModeration
 
             return result;
         }
-        public async Task<StreamResponse<DeleteModerationRuleResponse>> DeleteModerationRuleAsync(object request = null,
+        public async Task<StreamResponse<DeleteModerationRuleResponse>> DeleteModerationRuleAsync(string id, object request = null,
             CancellationToken cancellationToken = default)
         {
+            var pathParams = new Dictionary<string, string>
+            {
+                ["id"] = id,
+            };
             var queryParams = ExtractQueryParams(request);
 
             var result = await _client.MakeRequestAsync<object, DeleteModerationRuleResponse>(
                 "DELETE",
-                "/api/v2/moderation/moderation_rule/{id}", queryParams, null, null,
+                "/api/v2/moderation/moderation_rule/{id}", queryParams, null, pathParams,
                 cancellationToken);
 
             return result;
         }
-        public async Task<StreamResponse<GetModerationRuleResponse>> GetModerationRuleAsync(object request = null,
+        public async Task<StreamResponse<GetModerationRuleResponse>> GetModerationRuleAsync(string id, object request = null,
             CancellationToken cancellationToken = default)
         {
+            var pathParams = new Dictionary<string, string>
+            {
+                ["id"] = id,
+            };
 
             var result = await _client.MakeRequestAsync<object, GetModerationRuleResponse>(
                 "GET",
-                "/api/v2/moderation/moderation_rule/{id}", null, null, null,
+                "/api/v2/moderation/moderation_rule/{id}", null, null, pathParams,
                 cancellationToken);
 
             return result;
@@ -448,13 +456,96 @@ public async Task<StreamResponse<MuteResponse>> MuteAsync(MuteRequest request,
 
             return result;
         }
+        public async Task<StreamResponse<PolicyTestRunResponse>> GetPolicyTestRunAsync(string id, object request = null,
+            CancellationToken cancellationToken = default)
+        {
+            var pathParams = new Dictionary<string, string>
+            {
+                ["id"] = id,
+            };
+
+            var result = await _client.MakeRequestAsync<object, PolicyTestRunResponse>(
+                "GET",
+                "/api/v2/moderation/policy_tests/runs/{id}", null, null, pathParams,
+                cancellationToken);
+
+            return result;
+        }
+        public async Task<StreamResponse<PolicyTestSetListResponse>> ListPolicyTestSetsAsync(object request = null,
+            CancellationToken cancellationToken = default)
+        {
+
+            var result = await _client.MakeRequestAsync<object, PolicyTestSetListResponse>(
+                "GET",
+                "/api/v2/moderation/policy_tests/sets", null, null, null,
+                cancellationToken);
+
+            return result;
+        }
+        public async Task<StreamResponse<PolicyTestSetResponse>> CreatePolicyTestSetAsync(CreatePolicyTestSetRequest request,
+            CancellationToken cancellationToken = default)
+        {
+
+            var result = await _client.MakeRequestAsync<CreatePolicyTestSetRequest, PolicyTestSetResponse>(
+                "POST",
+                "/api/v2/moderation/policy_tests/sets", null, request, null,
+                cancellationToken);
+
+            return result;
+        }
+        public async Task<StreamResponse<Response>> DeletePolicyTestSetAsync(string id, object request = null,
+            CancellationToken cancellationToken = default)
+        {
+            var pathParams = new Dictionary<string, string>
+            {
+                ["id"] = id,
+            };
+
+            var result = await _client.MakeRequestAsync<object, Response>(
+                "DELETE",
+                "/api/v2/moderation/policy_tests/sets/{id}", null, null, pathParams,
+                cancellationToken);
+
+            return result;
+        }
+        public async Task<StreamResponse<PolicyTestSetResponse>> GetPolicyTestSetAsync(string id, object request = null,
+            CancellationToken cancellationToken = default)
+        {
+            var pathParams = new Dictionary<string, string>
+            {
+                ["id"] = id,
+            };
+
+            var result = await _client.MakeRequestAsync<object, PolicyTestSetResponse>(
+                "GET",
+                "/api/v2/moderation/policy_tests/sets/{id}", null, null, pathParams,
+                cancellationToken);
+
+            return result;
+        }
+        public async Task<StreamResponse<PolicyTestRunResponse>> StartPolicyTestRunAsync(string id, object request = null,
+            CancellationToken cancellationToken = default)
+        {
+            var pathParams = new Dictionary<string, string>
+            {
+                ["id"] = id,
+            };
+
+            var result = await _client.MakeRequestAsync<object, PolicyTestRunResponse>(
+                "POST",
+                "/api/v2/moderation/policy_tests/sets/{id}/runs", null, null, pathParams,
+                cancellationToken);
+
+            return result;
+        }
         public async Task<StreamResponse<ListQueuesResponse>> ListQueuesAsync(object request = null,
             CancellationToken cancellationToken = default)
         {
+            var queryParams = ExtractQueryParams(request);
 
             var result = await _client.MakeRequestAsync<object, ListQueuesResponse>(
                 "GET",
-                "/api/v2/moderation/queues", null, null, null,
+                "/api/v2/moderation/queues", queryParams, null, null,
                 cancellationToken);
 
             return result;

src/Webhook.cs

@@ -152,6 +152,7 @@ public static class WebhookEventType
         public const string MessageUnblocked = "message.unblocked";
         public const string MessageUndeleted = "message.undeleted";
         public const string MessageUpdated = "message.updated";
+        public const string ModerationAnalysisFailed = "moderation.analysis.failed";
         public const string ModerationCustomAction = "moderation.custom_action";
         public const string ModerationFlagged = "moderation.flagged";
         public const string ModerationImageAnalysisComplete = "moderation.image_analysis.complete";
@@ -415,6 +416,7 @@ private static Type GetEventTypeClass(string eventType)
                 "message.unblocked" => typeof(MessageUnblockedEvent),
                 "message.undeleted" => typeof(MessageUndeletedEvent),
                 "message.updated" => typeof(MessageUpdatedEvent),
+                "moderation.analysis.failed" => typeof(ModerationAnalysisFailedEvent),
                 "moderation.custom_action" => typeof(ModerationCustomActionEvent),
                 "moderation.flagged" => typeof(ModerationFlaggedEvent),
                 "moderation.image_analysis.complete" => typeof(ModerationImageAnalysisCompleteEvent),