added integration and example config

mia-platform · Jan 6, 2025 · ddd35b0 · ddd35b0
1 parent 83b3883
commit ddd35b0
Show file tree

Hide file tree

Showing 4 changed files with 42 additions and 2 deletions.
diff --git a/internal/config/config.schema.json b/internal/config/config.schema.json
@@ -13,7 +13,8 @@
               "type": {
                 "type": "string",
                 "enum": [
-                  "jira"
+                  "jira",
+                  "vm"
                 ]
               },
               "webhookPath": {
@@ -143,4 +144,4 @@
       }
     }
   }
-}
+}
diff --git a/internal/config/testdata/config-vm.json b/internal/config/testdata/config-vm.json
@@ -0,0 +1,28 @@
+{
+  "integrations": [
+    {
+      "source": {
+        "type": "vm",
+        "webhookPath": "/vm/webhook",
+        "authentication": {
+          "secret": {
+            "fromFile": "testdata/secret"
+          }
+        }
+      },
+      "pipelines": [
+        {
+          "processors": [],
+          "sinks": [
+            {
+              "type": "fake",
+              "url": {
+                "fromEnv": "TEST_LOAD_SERVICE_MONGO_URL"
+              }
+            }
+          ]
+        }
+      ]
+    }
+  ]
+}
diff --git a/internal/server/integrations.go b/internal/server/integrations.go
@@ -28,6 +28,7 @@ import (
 	"github.com/mia-platform/integration-connector-agent/internal/sinks/mongo"
 	"github.com/mia-platform/integration-connector-agent/internal/sources"
 	"github.com/mia-platform/integration-connector-agent/internal/sources/jira"
+	"github.com/mia-platform/integration-connector-agent/internal/sources/vm"
 	"github.com/mia-platform/integration-connector-agent/internal/sources/webhook"
 
 	swagger "github.com/davidebianchi/gswagger"
@@ -76,6 +77,15 @@ func setupPipelines(ctx context.Context, log *logrus.Logger, cfg *config.Configu
 			if err := webhook.SetupService(ctx, oasRouter, &jiraConfig.Configuration, pg); err != nil {
 				return fmt.Errorf("%w: %s", errSetupSource, err)
 			}
+		case "vm":
+			vmConfig, err := config.GetConfig[*vm.Config](cfgIntegration.Source)
+			if err != nil {
+				return err
+			}
+
+			if err := webhook.SetupService(ctx, oasRouter, &vmConfig.Configuration, pg); err != nil {
+				return fmt.Errorf("%w: %s", errSetupSource, err)
+			}
 
 		case "test":
 			// do nothing only for testing

diff --git a/internal/sources/types.go b/internal/sources/types.go
@@ -17,4 +17,5 @@ package sources
 
 const (
 	Jira = "jira"
+	VM   = "vm"
 )
-Original file line number
+Diff line change
@@ Expand Up / @@ -17,4 +17,5 @@ package sources @@
     const (
     	Jira = "jira"
+    	VM   = "vm"
     )