chore: Small tidy ups of API folder structure

api.planx.uk/inviteToPay/createPaymentSendEvents.test.ts

@@ -1,10 +1,10 @@
 import supertest from "supertest";
 import app from "../server";
-import { createScheduledEvent } from "../hasura/metadata";
+import { createScheduledEvent } from "../lib/hasura/metadata";
 import { queryMock } from "../tests/graphqlQueryMock";
 import { flowWithInviteToPay } from "../tests/mocks/inviteToPayData";
 
-jest.mock("../hasura/metadata");
+jest.mock("../lib/hasura/metadata");
 const mockedCreateScheduledEvent = createScheduledEvent as jest.MockedFunction<
   typeof createScheduledEvent
 >;

api.planx.uk/inviteToPay/createPaymentSendEvents.ts

@@ -5,7 +5,7 @@ import { $api, $public } from "../client";
 import {
   ScheduledEventResponse,
   createScheduledEvent,
-} from "../hasura/metadata";
+} from "../lib/hasura/metadata";
 import { getMostRecentPublishedFlow } from "../helpers";
 import { Flow, Node, Team } from "../types";
 

api.planx.uk/modules/webhooks/service/lowcalSessionEvents/index.test.ts

@@ -1,10 +1,10 @@
 import supertest from "supertest";
 import app from "../../../../server";
-import { createScheduledEvent } from "../../../../hasura/metadata";
+import { createScheduledEvent } from "../../../../lib/hasura/metadata";
 
 const { post } = supertest(app);
 
-jest.mock("../../../../hasura/metadata");
+jest.mock("../../../../lib/hasura/metadata");
 const mockedCreateScheduledEvent = createScheduledEvent as jest.MockedFunction<
   typeof createScheduledEvent
 >;

api.planx.uk/modules/webhooks/service/lowcalSessionEvents/index.ts

@@ -1,6 +1,6 @@
 import { addDays } from "date-fns";
 
-import { createScheduledEvent } from "../../../../hasura/metadata";
+import { createScheduledEvent } from "../../../../lib/hasura/metadata";
 import {
   DAYS_UNTIL_EXPIRY,
   REMINDER_DAYS_FROM_EXPIRY,

api.planx.uk/modules/webhooks/service/lowcalSessionEvents/schema.ts

@@ -1,6 +1,6 @@
 import { z } from "zod";
 import { ValidatedRequestHandler } from "../../../../shared/middleware/validate";
-import { ScheduledEventResponse } from "../../../../hasura/metadata";
+import { ScheduledEventResponse } from "../../../../lib/hasura/metadata";
 
 export const createSessionEventSchema = z.object({
   body: z.object({

api.planx.uk/modules/webhooks/service/paymentRequestEvents/index.test.ts

@@ -1,11 +1,11 @@
 import supertest from "supertest";
 import app from "../../../../server";
-import { createScheduledEvent } from "../../../../hasura/metadata";
+import { createScheduledEvent } from "../../../../lib/hasura/metadata";
 import { CreatePaymentEvent } from "./schema";
 
 const { post } = supertest(app);
 
-jest.mock("../../../../hasura/metadata");
+jest.mock("../../../../lib/hasura/metadata");
 const mockedCreateScheduledEvent = createScheduledEvent as jest.MockedFunction<
   typeof createScheduledEvent
 >;

api.planx.uk/modules/webhooks/service/paymentRequestEvents/index.ts

@@ -1,6 +1,6 @@
 import { addDays } from "date-fns";
 
-import { createScheduledEvent } from "../../../../hasura/metadata";
+import { createScheduledEvent } from "../../../../lib/hasura/metadata";
 import {
   DAYS_UNTIL_EXPIRY,
   REMINDER_DAYS_FROM_EXPIRY,

api.planx.uk/modules/webhooks/service/paymentRequestEvents/schema.ts

@@ -1,6 +1,6 @@
 import { z } from "zod";
 import { ValidatedRequestHandler } from "../../../../shared/middleware/validate";
-import { ScheduledEventResponse } from "../../../../hasura/metadata";
+import { ScheduledEventResponse } from "../../../../lib/hasura/metadata";
 
 export const createPaymentEventSchema = z.object({
   body: z.object({

api.planx.uk/modules/webhooks/service/sanitiseApplicationData/operations.test.ts

@@ -1,4 +1,4 @@
-import { runSQL } from "../../../../hasura/schema";
+import { runSQL } from "../../../../lib/hasura/schema";
 import { queryMock } from "../../../../tests/graphqlQueryMock";
 import {
   mockIds,
@@ -25,7 +25,7 @@ import {
   deleteHasuraScheduledEventsForSubmittedSessions,
 } from "./operations";
 
-jest.mock("../../../../hasura/schema");
+jest.mock("../../../../lib/hasura/schema");
 const mockRunSQL = runSQL as jest.MockedFunction<typeof runSQL>;
 
 const mockFindSession = jest.fn();

api.planx.uk/modules/webhooks/service/sanitiseApplicationData/operations.ts

@@ -2,10 +2,10 @@ import { gql } from "graphql-request";
 import { subMonths } from "date-fns";
 
 import { Operation, OperationResult, QueryResult } from "./types";
-import { runSQL } from "../../../../hasura/schema";
-import { getFilesForSession } from "../../../../session/files";
+import { runSQL } from "../../../../lib/hasura/schema";
 import { deleteFilesByURL } from "../../../../s3/deleteFile";
 import { $api } from "../../../../client";
+import { Passport } from "@opensystemslab/planx-core";
 
 const RETENTION_PERIOD_MONTHS = 6;
 export const getRetentionPeriod = () =>
@@ -97,7 +97,11 @@ export const deleteApplicationFiles: Operation = async () => {
 
   const sessionIds = await getExpiredSessionIds();
   for (const sessionId of sessionIds) {
-    const files = await getFilesForSession(sessionId);
+    const session = await $api.session.find(sessionId);
+    if (!session) {
+      throw Error(`Unable to find session matching id ${sessionId}`);
+    }
+    const files = new Passport(session.data.passport).files();
     if (files.length) {
       const deleted = await deleteFilesByURL(files);
       deletedFiles.push(...deleted);

api.planx.uk/send/createSendEvents.ts

@@ -2,7 +2,7 @@ import { NextFunction, Request, Response } from "express";
 import {
   ScheduledEventResponse,
   createScheduledEvent,
-} from "../hasura/metadata";
+} from "../lib/hasura/metadata";
 
 interface CombinedResponse {
   bops?: ScheduledEventResponse;