Merge branch 'main' of github.com:valmi-io/valmi-app-backend

core/stream_api.py

@@ -165,4 +165,25 @@ def delete_obj(request, workspace_id, type, id):
         except Exception as e:
             raise e
 
-    return response.text
+    return response.text
+
+
+@router.delete("/workspaces/{workspace_id}/config/{type}", response={200: Json, 500: Json})
+def delete_link_obj(request, workspace_id, type, fromId, toId):
+    authObject = ValmiUserIDJitsuApiToken.objects.get(user=request.user)
+    response = requests.delete(
+        f"{config('STREAM_API_URL')}/api/{workspace_id}/config/{type}"
+        f"?workspaceId={workspace_id}&fromId={fromId}&toId={toId}",
+        timeout=SHORT_TIMEOUT,
+        headers=get_bearer_header(authObject.api_token),
+    )
+
+    try:
+        response.raise_for_status()
+    except requests.exceptions.HTTPError:
+        try:
+            return (500, response.text)
+        except Exception as e:
+            raise e
+
+    return response.text