CodeCow/stack
1
0
Fork 0
mirror of https://github.com/stack-auth/stack.git synced 2026-06-13 21:01:21 +08:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

maximum of 5 retries for webhooks

Browse Source
This commit is contained in:
Zai Shi 2025-07-22 15:40:42 -07:00
parent 3ad1bc74ba
commit fc7850487c
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
apps/e2e/tests/backend/backend-helpers.ts
View File

@ -1320,10 +1320,10 @@ export namespace Webhook {
};
}
export async function findWebhookAttempt(projectId: string, endpointId: string, svixToken: string, fn: (msg: any) => boolean) {
export async function findWebhookAttempt(projectId: string, endpointId: string, svixToken: string, fn: (msg: any) => boolean, retryCount: number = 5) {
// retry many times because Svix sucks and is slow
for (let i = 0; i < 20; i++) {
const attempts = await Webhook.listWebhookAttempts(projectId, endpointId, svixToken, 1);
for (let i = 0; i < retryCount; i++) {
const attempts = await Webhook.listWebhookAttempts(projectId, endpointId, svixToken);
const filtered = attempts.filter(fn);
if (filtered.length === 0) {
await wait(500);
@ -1337,7 +1337,7 @@ export namespace Webhook {
throw new Error(`Webhook attempt not found for project ${projectId}, endpoint ${endpointId}`);
}
export async function listWebhookAttempts(projectId: string, endpointId: string, svixToken: string, retryCount: number = 20) {
export async function listWebhookAttempts(projectId: string, endpointId: string, svixToken: string, retryCount: number = 5) {
// retry many times because Svix sucks and is slow
for (let i = 0; i < retryCount; i++) {
const response = await niceFetch(STACK_SVIX_SERVER_URL + `/api/v1/app/${projectId}/attempt/endpoint/${endpointId}`, {