feat(vdp): expose run-on-event endpoints (#221)

Because - We are introducing the functionality for a pipeline to be run on events. This commit - Exposes run-on-event endpoints.
instill-ai · Jul 29, 2024 · 55d8cab · 55d8cab
1 parent 48ba2f5
commit 55d8cab
Show file tree

Hide file tree

Showing 3 changed files with 57 additions and 0 deletions.
diff --git a/config/settings-env/endpoints.json b/config/settings-env/endpoints.json
@@ -1166,6 +1166,22 @@
         "input_query_strings": []
       }
     ],
+    "webhook":[
+      {
+        "endpoint": "/v1beta/namespaces/{namespace_id}/pipelines/{pipeline_id}/events",
+        "url_pattern": "/v1beta/namespaces/{namespace_id}/pipelines/{pipeline_id}/events",
+        "method": "POST",
+        "timeout": "600s",
+        "input_query_strings": ["event", "code"]
+      },
+      {
+        "endpoint": "/v1beta/namespaces/{namespace_id}/pipelines/{pipeline_id}/releases/{release_id}/events",
+        "url_pattern": "/v1beta/namespaces/{namespace_id}/pipelines/{pipeline_id}/releases/{release_id}/events",
+        "method": "POST",
+        "timeout": "600s",
+        "input_query_strings": ["event", "code"]
+      }
+    ],
     "grpc_auth": [
       {
         "endpoint": "/vdp.pipeline.v1beta.PipelinePublicService/CheckName",

diff --git a/config/share/settings-env/input_headers.json b/config/share/settings-env/input_headers.json
@@ -31,6 +31,9 @@
     "Instill-Share-Code",
     "Instill-Use-SSE"
   ],
+  "webhook": [
+    "*"
+  ],
   "no_auth": [
     "Content-Type",
     "Content-Length",

diff --git a/config/share/templates/pipeline.tmpl b/config/share/templates/pipeline.tmpl
@@ -150,6 +150,44 @@
 }
 {{- end}}
 ,
+{{- range $idx, $endpoint := $endpoints.webhook }}
+{{- if $idx -}},{{ end }}
+{
+  "endpoint": "{{ .endpoint }}",
+  "method": "{{ .method }}",
+  {{- if len .input_query_strings -}}
+  "input_query_strings":
+  [
+    {{- range $qidx, $qstring := .input_query_strings }}
+    {{- if $qidx -}},{{ end }}
+    "{{ $qstring }}"
+    {{- end}}
+  ],
+  {{- end}}
+  "timeout": "{{ .timeout }}",
+  "output_encoding": "no-op",
+  "input_headers": {{ marshal $input_headers.webhook }},
+  "backend": [
+    {
+      "url_pattern": "{{ .url_pattern }}",
+      "host": {{ marshal $host }},
+      "sd": "static",
+      "method": "{{ .method }}",
+      "disable_host_sanitize": false,
+      "extra_config": {
+        "github.com/devopsfaith/krakend-martian": {
+          "header.Modifier": {
+            "scope": ["response"],
+            "name": "Backend",
+            "value": "pipeline"
+          }
+        }
+      }
+    }
+  ]
+}
+{{- end }}
+,
 {{- range $idx, $endpoint := $endpoints.grpc_auth }}
 {{- if $idx -}},{{ end }}
 {