Update app.py

app.py

@@ -54,6 +54,8 @@ else:
 # checks payload of webhook and runs the main code if webhook was triggered by specified stream + one of the branches
 listendStreams = [STREAM_ID]
 listendBranchNames = [BRANCH_NAME_LAND_USES,BRANCH_NAME_DISTANCE_MATRIX,BRANCH_NAME_METRIC_DIST_MATRIX]
+print("branchnames", listendBranchNames)
+print("stream", listendStreams)
 
 @webhook_endpoint
 async def update_streams(request: Request):
@@ -71,10 +73,10 @@ async def update_streams(request: Request):
     if "event" in payload and "data" in payload["event"]:
         event_data = payload["event"]["data"]
 
-        # Check if the event type is "commit_create"
-        if "type" in event_data and event_data["type"] in  ["commit_create", "commit_delete"]:
+        # Check if the event type is one of the specified types
+        if "event_name" in payload["event"] and payload["event"]["event_name"] in ["commit_create", "commit_delete", "commit_update"]:
             # Check if the stream name matches the specified list
-            if "stream" in event_data and event_data["stream"] in listendStreams:
+            if "stream" in payload and payload["stream"]["name"] in listendStreams:
                 # Check if the branch name matches the specified list
                 if "commit" in event_data and "branchName" in event_data["commit"]:
                     if event_data["commit"]["branchName"] in listendBranchNames:
@@ -84,7 +86,7 @@ async def update_streams(request: Request):
             else:
                 print("Stream name not found or not in the specified list.")
         else:
-            print("Event type is not 'commit_create'.")
+            print("Event type is not one of the specified types.")
     else:
         print("Payload structure does not match the expected format.")
 
@@ -96,7 +98,7 @@ async def update_streams(request: Request):
         print("Flag is False. Skipping further execution.")
 
     return "Webhook processing complete."
-   
+    
     
 
 def runAll():