using get_discussion_details to get 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 (
@@ -283,17 +297,6 @@ async def trigger_ci_on_pr(payload: WebhookPayload, task_queue: BackgroundTasks)
                     # Found a PR that is not yet synced
                     task_queue.add_task(sync_ci_space, space_id=space_id, pr_num=discussion.num)
                     has_task = True
-    if (
-        payload.event.scope == "discussion.comment"
-        and payload.event.action == "create"
-        and payload.discussion.isPullRequest
-        and payload.discussion.status == "open"
-        # TODO:
-        # figure out how to get the username from the id
-        # and payload.discussion.author.id in EPHEMERAL_SPACES_CONFIG["trusted_authors"]
-    ):
-        print("Comment detected with content:\n ", payload.comment.content)
-
 
     if has_task:
         return Response("Task scheduled to sync/delete Space", status_code=status.HTTP_202_ACCEPTED)