This repository has been archived by the owner on Sep 19, 2024. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 61
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'development' into html-comments
- Loading branch information
Showing
11 changed files
with
302 additions
and
79 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1 +1,2 @@ | ||
| export * from "./client"; | ||
| export * from "./log"; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,193 @@ | ||
| import { getAdapters, getBotContext, Logger } from "../../../bindings"; | ||
| import { Payload } from "../../../types"; | ||
| import { getNumericLevel } from "../../../utils/helpers"; | ||
| import { getOrgAndRepoFromPath } from "../../../utils/private"; | ||
| interface Log { | ||
| repo: string | null; | ||
| org: string | null; | ||
| commentId: number | undefined; | ||
| issueNumber: number | undefined; | ||
| logMessage: string; | ||
| level: Level; | ||
| timestamp: string; | ||
| } | ||
|
|
||
| export enum Level { | ||
| ERROR = "error", | ||
| WARN = "warn", | ||
| INFO = "info", | ||
| HTTP = "http", | ||
| VERBOSE = "verbose", | ||
| DEBUG = "debug", | ||
| SILLY = "silly", | ||
| } | ||
|
|
||
| export class GitHubLogger implements Logger { | ||
| private supabase; | ||
| private maxLevel; | ||
| private app; | ||
| private logEnvironment; | ||
| private logQueue: Log[] = []; // Your log queue | ||
| private maxConcurrency = 6; // Maximum concurrent requests | ||
| private retryDelay = 1000; // Delay between retries in milliseconds | ||
| private throttleCount = 0; | ||
| private retryLimit = 0; // Retries disabled by default | ||
|
|
||
| constructor(app: string, logEnvironment: string, maxLevel: Level, retryLimit: number) { | ||
| this.app = app; | ||
| this.logEnvironment = logEnvironment; | ||
| this.maxLevel = getNumericLevel(maxLevel); | ||
| this.retryLimit = retryLimit; | ||
| this.supabase = getAdapters().supabase; | ||
| } | ||
|
|
||
| async sendLogsToSupabase({ repo, org, commentId, issueNumber, logMessage, level, timestamp }: Log) { | ||
| const { error } = await this.supabase.from("logs").insert([ | ||
| { | ||
| repo_name: repo, | ||
| level: getNumericLevel(level), | ||
| org_name: org, | ||
| comment_id: commentId, | ||
| log_message: logMessage, | ||
| issue_number: issueNumber, | ||
| timestamp, | ||
| }, | ||
| ]); | ||
|
|
||
| if (error) { | ||
| console.error("Error logging to Supabase:", error.message); | ||
| return; | ||
| } | ||
| } | ||
|
|
||
| async processLogs(log: Log) { | ||
| try { | ||
| await this.sendLogsToSupabase(log); | ||
| } catch (error) { | ||
| console.error("Error sending log, retrying:", error); | ||
| return this.retryLimit > 0 ? await this.retryLog(log) : null; | ||
| } | ||
| } | ||
|
|
||
| async retryLog(log: Log, retryCount = 0) { | ||
| if (retryCount >= this.retryLimit) { | ||
| console.error("Max retry limit reached for log:", log); | ||
| return; | ||
| } | ||
|
|
||
| await new Promise((resolve) => setTimeout(resolve, this.retryDelay)); | ||
|
|
||
| try { | ||
| await this.sendLogsToSupabase(log); | ||
| } catch (error) { | ||
| console.error("Error sending log (after retry):", error); | ||
| await this.retryLog(log, retryCount + 1); | ||
| } | ||
| } | ||
|
|
||
| async processLogQueue() { | ||
| while (this.logQueue.length > 0) { | ||
| const log = this.logQueue.shift(); | ||
| if (!log) { | ||
| continue; | ||
| } | ||
| await this.processLogs(log); | ||
| } | ||
| } | ||
|
|
||
| async throttle() { | ||
| if (this.throttleCount >= this.maxConcurrency) { | ||
| return; | ||
| } | ||
|
|
||
| this.throttleCount++; | ||
| try { | ||
| await this.processLogQueue(); | ||
| } finally { | ||
| this.throttleCount--; | ||
| if (this.logQueue.length > 0) { | ||
| await this.throttle(); | ||
| } | ||
| } | ||
| } | ||
|
|
||
| async addToQueue(log: Log) { | ||
| this.logQueue.push(log); | ||
| if (this.throttleCount < this.maxConcurrency) { | ||
| await this.throttle(); | ||
| } | ||
| } | ||
|
|
||
| private save(logMessage: string | object, level: Level, errorPayload?: string | object) { | ||
| if (getNumericLevel(level) > this.maxLevel) return; // only return errors lower than max level | ||
|
|
||
| const context = getBotContext(); | ||
| const payload = context.payload as Payload; | ||
| const timestamp = new Date().toUTCString(); | ||
|
|
||
| const { comment, issue, repository } = payload; | ||
| const commentId = comment?.id; | ||
| const issueNumber = issue?.number; | ||
| const repoFullName = repository?.full_name; | ||
|
|
||
| const { org, repo } = getOrgAndRepoFromPath(repoFullName); | ||
|
|
||
| if (!logMessage) return; | ||
|
|
||
| if (typeof logMessage === "object") { | ||
| // pass log as json stringified | ||
| logMessage = JSON.stringify(logMessage); | ||
| } | ||
|
|
||
| this.addToQueue({ repo, org, commentId, issueNumber, logMessage, level, timestamp }) | ||
| .then(() => { | ||
| return; | ||
| }) | ||
| .catch(() => { | ||
| console.log("Error adding logs to queue"); | ||
| }); | ||
|
|
||
| if (this.logEnvironment === "development") { | ||
| console.log(this.app, logMessage, errorPayload, level, repo, org, commentId, issueNumber); | ||
| } | ||
| } | ||
|
|
||
| info(message: string | object, errorPayload?: string | object) { | ||
| this.save(message, Level.INFO, errorPayload); | ||
| } | ||
|
|
||
| warn(message: string | object, errorPayload?: string | object) { | ||
| this.save(message, Level.WARN, errorPayload); | ||
| } | ||
|
|
||
| debug(message: string | object, errorPayload?: string | object) { | ||
| this.save(message, Level.DEBUG, errorPayload); | ||
| } | ||
|
|
||
| error(message: string | object, errorPayload?: string | object) { | ||
| this.save(message, Level.ERROR, errorPayload); | ||
| } | ||
|
|
||
| async get() { | ||
| try { | ||
| const { data, error } = await this.supabase.from("logs").select("*"); | ||
|
|
||
| if (error) { | ||
| console.error("Error retrieving logs from Supabase:", error.message); | ||
| return []; | ||
| } | ||
|
|
||
| return data; | ||
| } catch (error) { | ||
| if (error instanceof Error) { | ||
| // 👉️ err is type Error here | ||
| console.error("An error occurred:", error.message); | ||
|
|
||
| return; | ||
| } | ||
|
|
||
| console.log("Unexpected error", error); | ||
| return []; | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.