better logs

WIP, logging a message by a trusted author

src/gradio_space_ci/webhook.py

@@ -245,6 +245,20 @@ async def trigger_ci_on_pr(payload: WebhookPayload, task_queue: BackgroundTasks)
     space_id = payload.repo.name
 
     has_task = False
+
+    pr_num = payload.discussion.num
+    details = get_discussion_details(repo_id=space_id, repo_type="space", discussion_num=pr_num)
+    event_author = details.events[-1]._event["author"]["name"] # username of that event
+    if (
+        # Means comment by a trusted author
+        payload.event.scope == "discussion.comment"
+        and payload.event.action == "create"
+        and payload.discussion.isPullRequest
+        and payload.discussion.status == "open"
+        and event_author in EPHEMERAL_SPACES_CONFIG["trusted_authors"]
+    ):
+        print("Comment detected with content:\n", payload.comment.content)
+    
     if (
         # Means "a new PR has been opened"
         payload.event.scope.startswith("discussion")
@@ -253,9 +267,9 @@ async def trigger_ci_on_pr(payload: WebhookPayload, task_queue: BackgroundTasks)
         and payload.discussion.isPullRequest
         and payload.discussion.status == "open"
     ):
-        if not is_pr_synced(space_id=space_id, pr_num=payload.discussion.num):
+        if not is_pr_synced(space_id=space_id, pr_num=pr_num):
             # New PR! Sync task scheduled
-            task_queue.add_task(sync_ci_space, space_id=space_id, pr_num=payload.discussion.num)
+            task_queue.add_task(sync_ci_space, space_id=space_id, pr_num=pr_num)
             has_task = True
     elif (
         # Means "a PR has been merged or closed"
@@ -268,7 +282,7 @@ async def trigger_ci_on_pr(payload: WebhookPayload, task_queue: BackgroundTasks)
         task_queue.add_task(
             delete_ci_space,
             space_id=space_id,
-            pr_num=payload.discussion.num,
+            pr_num=pr_num,
         )
         has_task = True
     elif (
@@ -290,11 +304,11 @@ async def trigger_ci_on_pr(payload: WebhookPayload, task_queue: BackgroundTasks)
         and payload.discussion.isPullRequest
         and payload.discussion.status == "open"
         # TODO:
-        # this limited to owner only
+        # this is limited to the owner only
         # check if it works with organizations
         and payload.discussion.author.id == payload.repo.owner
     ):
-        print(payload.comment.content)
+        print("Payload by owner detected with content:\n ", payload.comment.content)
 
     if has_task:
         return Response("Task scheduled to sync/delete Space", status_code=status.HTTP_202_ACCEPTED)