feat(backend): increase test coverage to 80%+

Author: AdEmOnD07

backend/src/api.test.ts

@@ -41,7 +41,11 @@ beforeAll(async () => {
 
 afterAll(() => {
   server.close();
-  fs.rmSync(TEST_DB_PATH, { force: true });
+  try {
+    fs.rmSync(TEST_DB_PATH, { force: true });
+  } catch {
+    // Ignore EPERM locks on Windows
+  }
 });
 
 beforeEach(() => {
@@ -51,8 +55,8 @@ beforeEach(() => {
   db.prepare(`DELETE FROM campaigns`).run();
 });
 
-const CREATOR = `G${'A'.repeat(55)}`;
-const CONTRIBUTOR = `G${'B'.repeat(55)}`;
+const CREATOR = "GAAZI4TCR3TY5OJHCTJC2A4QSY6CJWJH5IAJTGKIN2ER7LBNVKOCCWN7";
+const CONTRIBUTOR = "GBZXN7PIRZGNMHGA7MUUUF4GWPY5AYPV6LY4UV2GL6VJGIQRXFDNMADI";
 
 async function post(apiPath: string, body: unknown) {
   const response = await fetch(`${baseUrl}${apiPath}`, {

backend/src/historyEndpoint.test.ts

@@ -19,8 +19,9 @@ let createCampaign: (typeof import('./services/campaignStore'))['createCampaign'
 let initCampaignStore: (typeof import('./services/campaignStore'))['initCampaignStore'];
 let recordEvent: (typeof import('./services/eventHistory'))['recordEvent'];
 let getDb: (typeof import('./services/db'))['getDb'];
+let resetDbForTests: (typeof import('./services/db'))['resetDbForTests'];
 
-const CREATOR = `G${'A'.repeat(55)}`;
+const CREATOR = "GAAZI4TCR3TY5OJHCTJC2A4QSY6CJWJH5IAJTGKIN2ER7LBNVKOCCWN7";
 
 function nowInSeconds(): number {
   return Math.floor(Date.now() / 1000);
@@ -31,13 +32,14 @@ beforeAll(async () => {
 
   ({ createCampaign, initCampaignStore } = await import('./services/campaignStore'));
   ({ recordEvent } = await import('./services/eventHistory'));
-  ({ getDb } = await import('./services/db'));
+  ({ getDb, resetDbForTests } = await import('./services/db'));
   ({ app } = await import('./index'));
 
   initCampaignStore();
 });
 
 afterAll(() => {
+  resetDbForTests();
   fs.rmSync(TEST_DB_PATH, { force: true });
 });
 

backend/src/index.test.ts

@@ -21,8 +21,8 @@ let calculateProgress: CampaignStoreModule['calculateProgress'];
 let initCampaignStore: CampaignStoreModule['initCampaignStore'];
 let getDb: DbModule['getDb'];
 
-const CREATOR = `G${'A'.repeat(55)}`;
-const CONTRIBUTOR = `G${'B'.repeat(55)}`;
+const CREATOR = "GAAZI4TCR3TY5OJHCTJC2A4QSY6CJWJH5IAJTGKIN2ER7LBNVKOCCWN7";
+const CONTRIBUTOR = "GBZXN7PIRZGNMHGA7MUUUF4GWPY5AYPV6LY4UV2GL6VJGIQRXFDNMADI";
 
 beforeAll(async () => {
   fs.rmSync(TEST_DB_PATH, { force: true });

backend/src/index.ts

@@ -2,6 +2,8 @@ import compression from "compression";
 import cors from "cors";
 import "dotenv/config";
 import express, { Request, Response } from "express";
+import helmet from "helmet";
+import { createServer, Server } from "http";
 
 
 import { validateEnv } from "./validateEnv";
@@ -532,11 +534,12 @@ app.post(
       sendValidationError(parsedId.issues);
     }
 
-
+    const result = reconcileOnChainPledge(parsedId.value, req.body);
     invalidateCampaignCache();
     res.status(result.existing ? 200 : 201).json({
       data: {
-
+        ...result.campaign,
+        progress: calculateProgress(result.campaign),
       },
     });
   },

backend/src/logger.ts

@@ -62,11 +62,19 @@ function withRequestContext(fields: LogFields): LogFields {
   return fields;
 }
 
+let globalConfiguredLevel: LogLevel | null = null;
+export function getGlobalConfiguredLogLevel(): LogLevel {
+  if (!globalConfiguredLevel) {
+    globalConfiguredLevel = normalizeLogLevel(process.env.LOG_LEVEL);
+  }
+  return globalConfiguredLevel;
+}
+
 export function logLine(
   level: LogLevel,
   event: string,
   fields: LogFields,
-  configuredLevel: LogLevel,
+  configuredLevel: LogLevel = getGlobalConfiguredLogLevel(),
 ): void {
   if (!shouldLog(level, configuredLevel)) {
     return;
@@ -75,7 +83,11 @@ export function logLine(
   getConsoleMethod(level)(createLogLine(level, event, withRequestContext(fields)));
 }
 
-export function logInfo(event: string, fields: LogFields, configuredLevel: LogLevel): void {
+export function logInfo(
+  event: string,
+  fields: LogFields = {},
+  configuredLevel: LogLevel = getGlobalConfiguredLogLevel(),
+): void {
   logLine('info', event, fields, configuredLevel);
 }
 
@@ -87,7 +99,7 @@ export function logRequest(
     status: number;
     durationMs: number;
   },
-  configuredLevel: LogLevel,
+  configuredLevel: LogLevel = getGlobalConfiguredLogLevel(),
 ): void {
   const durationMs = Number(request.durationMs.toFixed(2));
 
@@ -115,7 +127,7 @@ export function logError(
     status?: number;
     [key: string]: unknown;
   },
-  configuredLevel: LogLevel,
+  configuredLevel: LogLevel = getGlobalConfiguredLogLevel(),
 ): void {
   const normalizedError =
     error instanceof Error ? error : new Error(typeof error === 'string' ? error : 'Unknown error');

backend/src/pledgesEndpoint.test.ts

@@ -23,9 +23,9 @@ let getPledges: CampaignStoreModule['getPledges'];
 let getDb: DbModule['getDb'];
 let parsePledgeListPaginationQuery: ValidationModule['parsePledgeListPaginationQuery'];
 
-const CREATOR = `G${'A'.repeat(55)}`;
-const CONTRIBUTOR_A = `G${'B'.repeat(55)}`;
-const CONTRIBUTOR_B = `G${'C'.repeat(55)}`;
+const CREATOR = "GAAZI4TCR3TY5OJHCTJC2A4QSY6CJWJH5IAJTGKIN2ER7LBNVKOCCWN7";
+const CONTRIBUTOR_A = "GBZXN7PIRZGNMHGA7MUUUF4GWPY5AYPV6LY4UV2GL6VJGIQRXFDNMADI";
+const CONTRIBUTOR_B = "GBBD47IF6LWK7P7MDEVSCWR7DPUWV3NY3DTQEVFL4NAT4AQH3ZLLFLA5";
 
 function nowInSeconds(): number {
   return Math.floor(Date.now() / 1000);

backend/src/rateLimiter.test.ts

@@ -12,7 +12,7 @@ describe("Rate Limiter Middleware", () => {
     nextCalled = false;
     headers = {};
     mockReq = {
-      ip: "127.0.0.1",
+      ip: `127.0.0.${Math.floor(Math.random() * 253) + 2}`,
       method: "GET",
     };
     mockRes = {
@@ -51,18 +51,18 @@ describe("Rate Limiter Middleware", () => {
     const middleware = applyRateLimit(2); // Set limit to 2 for testing
 
     // First request
-    middleware(mockReq as Request, mockRes as Response, next);
+    middleware({ ...mockReq } as Request, mockRes as Response, next);
     expect(nextCalled).toBe(true);
 
     // Second request
     nextCalled = false;
-    middleware(mockReq as Request, mockRes as Response, next);
+    middleware({ ...mockReq } as Request, mockRes as Response, next);
     expect(nextCalled).toBe(true);
 
     // Third request - should exceed limit
     nextCalled = false;
     expect(() => {
-      middleware(mockReq as Request, mockRes as Response, next);
+      middleware({ ...mockReq } as Request, mockRes as Response, next);
     }).toThrow(/Rate limit exceeded/);
     expect(headers["Retry-After"]).toBeDefined();
   });

backend/src/requestId.test.ts

@@ -26,7 +26,11 @@ beforeAll(async () => {
 });
 
 afterAll(() => {
-  fs.rmSync(TEST_DB_PATH, { force: true });
+  try {
+    fs.rmSync(TEST_DB_PATH, { force: true });
+  } catch {
+    // Ignore EPERM locks on Windows
+  }
 });
 
 describe('request id middleware', () => {

backend/src/security.test.ts

@@ -1,12 +1,33 @@
 import request from 'supertest';
-import { describe, it, expect } from 'vitest';
+import { describe, it, expect, beforeAll, afterAll, vi } from 'vitest';
 
 // Set environment before importing app
 process.env.DB_PATH = ':memory:';
 process.env.NODE_ENV = 'test';
 process.env.CONTRACT_ID = 'CAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA';
 process.env.SOROBAN_RPC_URL = 'http://localhost:8000';
 
+import { initCampaignStore } from './services/campaignStore';
+import { config } from './config';
+
+beforeAll(() => {
+  initCampaignStore();
+  config.contractId = 'CAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA';
+  config.sorobanRpcUrl = 'http://localhost:8000';
+
+  vi.spyOn(global, 'fetch').mockImplementation(() => {
+    return Promise.resolve({
+      ok: true,
+      status: 200,
+      json: () => Promise.resolve({ result: { status: 'healthy' } }),
+    } as Response);
+  });
+});
+
+afterAll(() => {
+  vi.restoreAllMocks();
+});
+
 import { app } from './index';
 
 describe('Security Headers (Helmet)', () => {

backend/src/services/__tests__/eventMetadata.test.ts

@@ -34,7 +34,7 @@ describe('Event Metadata Support', () => {
       )
       .run(
         campaignId,
-        `G${'A'.repeat(55)}`,
+        "GAAZI4TCR3TY5OJHCTJC2A4QSY6CJWJH5IAJTGKIN2ER7LBNVKOCCWN7",
         `Campaign ${campaignId}`,
         'Synthetic campaign record for event metadata tests.',
         JSON.stringify(['USDC']),