Merge branch 'main' into feat/issue-152-pr

Author: scarface-dev1

backend/src/routes/donations.js

@@ -239,6 +239,8 @@ async function recordDonation(req, res, next) {
     await client.query("COMMIT");
     inTransaction = false;
 
+    // Fire-and-forget: enqueue profile update + donation matching.
+    // Neither failure should roll back the donation itself.
     enqueueProfileUpdate(donorAddress).catch((err) => {
       logger.error(
         { event: "profile_update_enqueue_failed", err, donorAddress },

backend/src/routes/donations.socket.test.js

@@ -9,7 +9,7 @@ jest.mock("../services/stellar", () => ({
 }));
 
 jest.mock("../services/matchQueue", () => ({
-  enqueueDonationMatching: jest.fn().mockResolvedValue("job-id"),
+  enqueueMatchDonation: jest.fn().mockResolvedValue(undefined),
 }));
 
 const http = require("http");
@@ -528,15 +528,17 @@ describe("POST /api/donations → broadcast hardening", () => {
     }
   }, 3000);
 
-  test("emits a single primary event when donation is recorded (matching is now async)", async () => {
+  test("emits only one event per donation (matching is now async via matchQueue)", async () => {
     const donorAddress = makePublicKey("K");
     const transactionHash = makeTxHash("f");
+    // Matching is handled asynchronously by matchQueue, so recordDonation
+    // no longer queries donation_matches or inserts match donations inline.
+    // Only 6 queries remain: SELECT project, dedup, BEGIN, INSERT, UPDATE, COMMIT.
     createMockClient(
       queryResult([{ id: "project-match" }]), // SELECT project
       queryResult([]), // dedup check
       queryResult(), // BEGIN
       queryResult([
-        // INSERT primary donation
         {
           id: "match-primary",
           project_id: "project-match",
@@ -548,7 +550,7 @@ describe("POST /api/donations → broadcast hardening", () => {
           transaction_hash: transactionHash,
           created_at: new Date().toISOString(),
         },
-      ]),
+      ]), // INSERT donation
       queryResult(), // UPDATE projects
       queryResult(), // COMMIT
     );

backend/src/routes/donations.test.js

@@ -597,7 +597,7 @@ describe("profile upsert on first donation", () => {
       queryResult([]),
       queryResult(),
       queryResult([donationRow]),
-      // no donation_matches query for non-XLM
+      // no donation_matches query for non-XLM — matching is now async via matchQueue
       queryResult(), // UPDATE projects (raises_xlm += 0)
       queryResult(), // COMMIT
     );

backend/src/server.js

@@ -451,6 +451,7 @@ async function startServer() {
   await runMigrations();
   await startSummaryQueue(io);
   await startProfileQueue(io);
+  await startMatchQueue();
   await startWebhookQueue();
   await startPushQueue();
   await startIdempotencyCleanup();
@@ -620,6 +621,7 @@ async function startServer() {
   for (const queue of [
     "./services/summaryQueue",
     "./services/profileQueue",
+    "./services/matchQueue",
     "./services/digestQueue",
     "./services/webhookQueue",
     "./services/pushQueue",