Merge branch 'feat/contributor-incentives-total-scoring-duplicate-fix…

…' into refactor/type-locations

package.json

@@ -61,7 +61,8 @@
     "prettier": "^2.7.1",
     "probot": "^12.2.4",
     "tsx": "^3.12.7",
-    "yaml": "^2.2.2"
+    "yaml": "^2.2.2",
+    "zlib": "^1.0.5"
   },
   "devDependencies": {
     "@types/dotenv": "^8.2.0",

src/bindings/event.ts

@@ -1,12 +1,15 @@
 import OpenAI from "openai";
 import { Context as ProbotContext } from "probot";
+import zlib from "zlib";
 import { createAdapters, supabaseClient } from "../adapters/adapters";
 import { LogMessage, LogReturn, Logs } from "../adapters/supabase/helpers/tables/logs";
 import { processors, wildcardProcessors } from "../handlers/processors";
 import { validateConfigChange } from "../handlers/push/push";
 import structuredMetadata from "../handlers/shared/structured-metadata";
 import { BotConfig } from "../types/configuration-types";
 
+import { addCommentToIssue } from "../helpers/issue";
+import { shouldSkip } from "../helpers/shared";
 import { Context } from "../types/context";
 import {
   HandlerReturnValuesNoVoid,
@@ -20,8 +23,6 @@ import { ajv } from "../utils/ajv";
 import { generateConfiguration } from "../utils/generate-configuration";
 import Runtime from "./bot-runtime";
 import { env } from "./env";
-import { shouldSkip } from "../helpers/shared";
-import { addCommentToIssue } from "../helpers/issue";
 
 const allowedEvents = Object.values(GitHubEvent) as string[];
 
@@ -46,7 +47,7 @@ export async function bindEvents(eventContext: ProbotContext) {
 
   logger.info("Event received", { id: eventContext.id, name: eventName });
 
-  if (!allowedEvents.includes(eventName)) {
+  if (!allowedEvents.includes(eventName) && eventContext.name !== "repository_dispatch") {
     // just check if its on the watch list
     return logger.info(`Skipping the event. reason: not configured`);
   }
@@ -93,6 +94,22 @@ export async function bindEvents(eventContext: ProbotContext) {
     throw new Error("Failed to create logger");
   }
 
+  if (eventContext.name === GitHubEvent.REPOSITORY_DISPATCH) {
+    const dispatchPayload = payload as any;
+    if (payload.action === "issueClosed") {
+      //This is response for issueClosed request
+      const response = dispatchPayload.client_payload.result;
+      if (response.comment as Comment) {
+        const uncompressedComment = zlib.gunzipSync(Buffer.from(response.comment));
+        await addCommentToIssue(
+          context,
+          uncompressedComment.toString(),
+          parseInt(dispatchPayload.client_payload.issueNumber)
+        );
+      }
+    }
+  }
+
   // Get the handlers for the action
   const handlers = processors[eventName];
 

src/handlers/comment/handlers/issue/issue-closed.ts

@@ -1,12 +1,11 @@
 import Runtime from "../../../../bindings/bot-runtime";
+import { env } from "../../../../bindings/env";
 import { checkUserPermissionForRepoAndOrg, getAllIssueComments } from "../../../../helpers/issue";
 import { Context } from "../../../../types/context";
-
 import { Comment, Issue, Payload, StateReason } from "../../../../types/payload";
 import structuredMetadata from "../../../shared/structured-metadata";
-import { generatePermits } from "./generate-permits";
-import { aggregateAndScoreContributions } from "./scoreSources";
-import { sumTotalScores } from "./sumTotalScoresPerContributor";
+import { getCollaboratorsForRepo } from "./get-collaborator-ids-for-repo";
+import { getPullRequestComments } from "./getPullRequestComments";
 
 export async function issueClosed(context: Context) {
   // TODO: delegate permit calculation to GitHub Action
@@ -19,21 +18,44 @@ export async function issueClosed(context: Context) {
 
   // === Calculate Permit === //
 
-  // 1. score sources will credit every contributor for every one of their contributions
-  const sourceScores = await aggregateAndScoreContributions({
-    context,
-    issue,
-    issueComments,
+  const pullRequestComments = await getPullRequestComments(context, owner, repository, issueNumber);
+  const repoCollaborators = await getCollaboratorsForRepo(context);
+
+  await dispatchWorkflow(owner, "ubiquibot-config", "compute.yml", {
+    eventName: "issueClosed",
+    secretToken: process.env.GITHUB_TOKEN,
     owner,
-    repository,
-    issueNumber,
+    repo: repository,
+    issueNumber: `${issueNumber}`,
+    payload: JSON.stringify({
+      issue,
+      issueComments,
+      openAiKey: context.config.keys.openAi,
+      pullRequestComments,
+      botConfig: context.config,
+      repoCollaborators,
+      X25519_PRIVATE_KEY: env.X25519_PRIVATE_KEY,
+      supabaseUrl: env.SUPABASE_URL,
+      supabaseKey: env.SUPABASE_KEY,
+    }),
   });
-  // 2. sum total scores will sum the scores of every contribution, and organize them by contributor
-  const contributorTotalScores = sumTotalScores(sourceScores);
-  // 3. generate permits will generate a payment for every contributor
-  const permitComment = await generatePermits(context, contributorTotalScores);
-  // 4. return the permit comment
-  return permitComment;
+
+  return "Please wait until we get the result.";
+}
+
+export async function dispatchWorkflow(owner: string, repo: string, workflowId: string, inputs: any) {
+  const res = await fetch(`https://api.github.com/repos/${owner}/${repo}/actions/workflows/${workflowId}/dispatches`, {
+    method: "POST",
+    headers: {
+      Authorization: `Bearer ${process.env.GITHUB_TOKEN}`,
+      Accept: "application/vnd.github.v3+json",
+    },
+    body: JSON.stringify({ ref: "master", inputs }),
+  });
+  if (res.status !== 204) {
+    const errorMessage = await res.text();
+    console.error(errorMessage);
+  }
 }
 
 async function getEssentials(context: Context) {

src/types/payload.ts

@@ -28,6 +28,8 @@ export enum GitHubEvent {
 
   // label
   LABEL_EDITED = "label.edited",
+
+  REPOSITORY_DISPATCH = "repository_dispatch",
 }
 
 export enum UserType {