chore: move webhook function to new module

This commit is contained in:
shiftinv 2022-09-03 20:11:04 +02:00
parent f214d4af1c
commit 31b66eb01a
2 changed files with 44 additions and 41 deletions

View File

@ -1,9 +1,9 @@
import { http, log } from "../deps.ts";
import config from "./config.ts";
import { http } from "../deps.ts";
import { verify } from "./crypto.ts";
import filterWebhook from "./filter.ts";
import { UrlConfig } from "./types.d.ts";
import * as util from "./util.ts";
import { sendWebhook } from "./webhook.ts";
export default async function handle(req: Request): Promise<Response> {
if (req.method !== "POST") {
@ -58,42 +58,3 @@ function getUrlConfig(params: URLSearchParams): UrlConfig {
}
return config;
}
async function sendWebhook(
id: string,
token: string,
headers: HeadersInit,
body: string,
): Promise<Response> {
const url = `https://discord.com/api/webhooks/${id}/${token}/github?wait=1`;
let res: Response;
let retries = 0;
do {
const req = new Request(url, {
method: "POST",
headers: headers,
body: body,
});
log.info(`sending webhook request to ${url}`);
res = await fetch(req);
// return response if everything's fine
if (res.status !== 429) break;
const reset = res.headers.get("retry-after");
// should always exist, even for cf bans, but checking anyway
if (reset === null) break;
const resetms = parseFloat(reset);
// if we'd wait longer than the configured limit, just return the 429
if (resetms > config.maxWebhookRetryMs) break;
// wait and try again
log.warning(`retrying after ${resetms}ms`);
await util.sleep(resetms);
retries++;
} while (retries <= config.maxWebhookRetries);
return res;
}

42
lib/webhook.ts Normal file
View File

@ -0,0 +1,42 @@
import { log } from "../deps.ts";
import config from "./config.ts";
import * as util from "./util.ts";
export async function sendWebhook(
id: string,
token: string,
headers: HeadersInit,
body: string,
): Promise<Response> {
const url = `https://discord.com/api/webhooks/${id}/${token}/github?wait=1`;
let res: Response;
let retries = 0;
do {
const req = new Request(url, {
method: "POST",
headers: headers,
body: body,
});
log.info(`sending webhook request to ${url}`);
res = await fetch(req);
// return response if everything's fine
if (res.status !== 429) break;
const reset = res.headers.get("retry-after");
// should always exist, even for cf bans, but checking anyway
if (reset === null) break;
const resetms = parseFloat(reset);
// if we'd wait longer than the configured limit, just return the 429
if (resetms > config.maxWebhookRetryMs) break;
// wait and try again
log.warning(`retrying after ${resetms}ms`);
await util.sleep(resetms);
retries++;
} while (retries <= config.maxWebhookRetries);
return res;
}