modified reaction provider

ruokun-niu · Jan 7, 2025 · 3c4d4b2 · 3c4d4b2
1 parent fe53b6a
commit 3c4d4b2
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 9 deletions.
diff --git a/cli/service/resources/default-reaction-providers.yaml b/cli/service/resources/default-reaction-providers.yaml
@@ -72,6 +72,12 @@ spec:
           - "CloudEvents"
           - "EventGrid"
         default: "CloudEvents"
+      format:
+        type: string
+        enum:
+          - "packed"
+          - "unpacked"
+        default: "packed"
     required:
       - eventGridUri
 ---

diff --git a/reactions/azure/eventgrid-reaction/Services/ChangeHandler.cs b/reactions/azure/eventgrid-reaction/Services/ChangeHandler.cs
@@ -42,10 +42,6 @@ public ChangeHandler(EventGridPublisherClient publisherClient,IConfiguration con
         _formatter = formatter;
         _logger = logger;
         _eventGridSchema = config.GetValue<string>("eventGridSchema").ToLower();
-        if (_eventGridSchema != "eventgrid" && _eventGridSchema != "cloudevents")
-        {
-            throw new ArgumentException("Invalid event grid schema. Supported schemas are 'EventGrid' and 'CloudEvents'.");
-        }
     }
 
     public async Task HandleChange(ChangeEvent evt, object? queryConfig)

diff --git a/reactions/azure/eventgrid-reaction/Services/ControlSignalHandler.cs b/reactions/azure/eventgrid-reaction/Services/ControlSignalHandler.cs
@@ -39,11 +39,6 @@ public ControlSignalHandler(EventGridPublisherClient publisherClient, IConfigura
         _format = Enum.Parse<OutputFormat>(config.GetValue("format", "packed") ?? "packed", true);
         _logger = logger;
         _eventGridSchema = config.GetValue<string>("eventGridSchema").ToLower();
-        if (_eventGridSchema != "eventgrid" && _eventGridSchema != "cloudevents")
-        {
-            throw new ArgumentException("Invalid event grid schema. Supported schemas are 'EventGrid' and 'CloudEvents'.");
-        }
-        Console.WriteLine("schema: " + _eventGridSchema);
     }
 
     public async Task HandleControlSignal(ControlEvent evt, object? queryConfig)