#65 add get project donors route

apps/backend/db/.env.dev

@@ -1 +1 @@
-DATABASE_URL=postgresql://branch_dev:password@localhost:5433/branch_db
+DATABASE_URL=postgresql://branch_dev:password@localhost:5432/branch_db

apps/backend/db/db_setup.sql

@@ -75,7 +75,8 @@ INSERT INTO users (name, email, is_admin) VALUES
 INSERT INTO projects (name, description, total_budget, start_date, end_date, currency) VALUES
 ('Clinician Communication Study', 'Study of clinician-patient communication patterns', 500000, '2025-01-01', '2026-01-01', 'USD'),
 ('Health Education Initiative', 'Community health education and outreach', 300000, '2025-03-01', '2026-03-01', 'USD'),
-('Policy Advocacy Program', 'Advocacy and policy change efforts', 200000, '2025-06-01', '2026-06-01', 'USD');
+('Policy Advocacy Program', 'Advocacy and policy change efforts', 200000, '2025-06-01', '2026-06-01', 'USD'),
+('Proj B', '', 2500.50, NULL, NULL, 'USD');
 
 INSERT INTO donors (organization, contact_name, contact_email) VALUES
 ('NIH', 'Dr. Sarah Lee', 'sarah@nih.gov'),

apps/backend/lambdas/projects/README.md

@@ -11,6 +11,7 @@ Lambda for managing projects.
 | GET | /health | Health check |
 | GET | /projects/{id}/members |  |
 | GET | /projects |  |
+| GET | /projects/{id}/donors |  |
 | GET | /projects/{id} |  |
 | PUT | /projects/{id} |  |
 

apps/backend/lambdas/projects/handler.ts

@@ -42,6 +42,44 @@ export const handler = async (event: any): Promise<APIGatewayProxyResult> => {
       const projects = await db.selectFrom("branch.projects").selectAll().execute();
       return json(200, projects);
     }
+
+    // GET /projects/{id}/donors
+      const parts = normalizedPath.split('/');
+      if (parts.length === 3 && parts[2] === 'donors' && method === 'GET') {
+        const id = parts[1];
+
+
+      if (!id) return json(400, { message: 'id is required' });
+      if (isNaN(Number(id))) {
+        return json(400, { message: 'Project id must be a valid number' });
+      }
+      const queryString = event.rawQueryString || event.queryStringParameters;
+
+      if (queryString && (typeof queryString === 'string' ? queryString.length > 0 : Object.keys(queryString).length > 0)) {
+        return json(400, { message: 'Bad Request: Query parameters are not allowed' });
+      }
+
+      const project = await db
+        .selectFrom("branch.projects as p")
+        .where("p.project_id", "=", Number(id))
+        .selectAll()
+        .executeTakeFirst();
+
+      if (!project) {
+        return json(404, { message: 'Project not found' });
+      }
+
+      const donors = await db.selectFrom("branch.projects as p").where("p.project_id", "=", Number(id)).innerJoin(
+        "branch.project_donations as bpd",
+        "bpd.project_id",
+        "p.project_id"
+      ).innerJoin(
+        "branch.donors as bd",
+        "bd.donor_id",
+        "bpd.donor_id"
+      ).selectAll().execute();
+        return json(200, { donors });
+    }
 
     // GET /projects/{id}
     if (rawPath.startsWith('/') && rawPath.split('/').length === 2 && method === 'GET') {

apps/backend/lambdas/projects/openapi.yaml

@@ -29,6 +29,11 @@ paths:
           schema:
             type: string
   /projects:
+    get:
+      summary: GET /projects
+      responses:
+        '200':
+          description: OK
     post:
       summary: POST /projects
       requestBody:
@@ -37,7 +42,7 @@ paths:
           application/json:
             schema:
               type: object
-              required: 
+              required:
                 - name
               properties:
                 name:
@@ -50,6 +55,29 @@ paths:
         '200':
           description: OK
 
+  /projects/{id}:
+    get:
+      summary: GET /projects/{id}
+      parameters:
+        - in: path
+          name: id
+          required: true
+          schema:
+            type: string
+      responses:
+        '200':
+          description: OK
+    put:
+      summary: PUT /projects/{id}
+      parameters:
+        - in: path
+          name: id
+          required: true
+          schema:
+            type: string
+      responses:
+        '200':
+          description: OK
   /projects/{id}/expenditures:
     get:
       summary: GET /projects/{id}/expenditures
@@ -68,3 +96,17 @@ paths:
                 type: array
                 items:
                   type: object
+
+  /projects/{id}/donors:
+    get:
+      summary: GET /projects/{id}/donors
+      parameters:
+        - in: path
+          name: id
+          required: true
+          schema:
+            type: string
+      responses:
+        '200':
+          description: OK
+

apps/backend/lambdas/projects/test/example.test.ts

@@ -0,0 +1,61 @@
+
+test("health test 🌞", async () => {
+  let res = await fetch("http://localhost:3000/projects/health")
+  expect(res.status).toBe(200);
+});
+
+
+test("get projects no donors test 🌞", async () => { 
+  const res = await fetch("http://localhost:3000/projects/4/donors");  
+  expect(res.status).toBe(200);
+  let body = await res.json();
+  console.log(body);
+  expect(body.donors).toBeDefined();
+  expect(Array.isArray(body.donors)).toBe(true);
+});
+
+test("get projects yes donors test 🌞", async () => { 
+  const res = await fetch("http://localhost:3000/projects/1/donors");  
+  expect(res.status).toBe(200);
+  let body = await res.json();
+  console.log(body);
+  expect(body.donors).toBeDefined();
+  expect(Array.isArray(body.donors)).toBe(true);
+  if (body.donors.length > 0) {
+    const donor = body.donors[0];
+    expect(donor.project_id).toBeDefined();
+    expect(donor.name).toBeDefined();
+    expect(donor.total_budget).toBeDefined();
+    expect(donor.start_date).toBeDefined();
+    expect(donor.end_date).toBeDefined();
+    expect(donor.currency).toBeDefined();
+    expect(donor.created_at).toBeDefined();
+    expect(donor.donation_id).toBeDefined();
+    expect(donor.donor_id).toBeDefined();
+    expect(donor.amount).toBeDefined();
+    expect(donor.donated_at).toBeDefined();
+    expect(donor.organization).toBeDefined();
+    expect(donor.contact_name).toBeDefined();
+    expect(donor.contact_email).toBeDefined();
+  }
+});
+
+
+test("404 when invalid project id 🌞", async () => { 
+  const res = await fetch("http://localhost:3000/projects/1000/donors");  
+  expect(res.status).toBe(404);
+});
+
+test("400 when project id is not a number 🌞", async () => {
+  const res = await fetch("http://localhost:3000/projects/abc/donors");
+  expect(res.status).toBe(400);
+  const body = await res.json();
+  expect(body.message).toContain("must be a valid number");
+});
+
+test("400 when request has both body and query params 🌞", async () => {
+  const res = await fetch("http://localhost:3000/projects/1/donors?sort=desc");
+  expect(res.status).toBe(400);
+  const body = await res.json();
+  expect(body.message).toContain("Bad Request");
+});