chore: Drop adminClient (1/2)

api.planx.uk/gis/digitalLand.ts

@@ -5,9 +5,9 @@ import type {
 } from "@opensystemslab/planx-core/types";
 import { gql } from "graphql-request";
 import fetch from "isomorphic-fetch";
-import { adminGraphQLClient as adminClient } from "../hasura";
 import { addDesignatedVariable, omitGeometry } from "./helpers";
 import { baseSchema } from "./local_authorities/metadata/base";
+import { $api } from "../client";
 
 export interface LocalAuthorityMetadata {
   planningConstraints: {
@@ -73,7 +73,7 @@ async function go(
 
   // if analytics are "on", store an audit record of the raw response
   if (extras?.analytics !== "false") {
-    const _auditRecord = await adminClient.request(
+    const _auditRecord = await $api.client.request(
       gql`
         mutation CreatePlanningConstraintsRequest(
           $destination_url: String = ""

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

@@ -52,7 +52,7 @@ describe("Create payment send events webhook", () => {
       name: "GetTeamSlugByFlowId",
       matchOnVariables: false,
       data: {
-        flows_by_pk: {
+        flows: {
           team: {
             slug: "southwark",
           },

api.planx.uk/inviteToPay/createPaymentSendEvents.ts

@@ -1,8 +1,7 @@
 import { ComponentType } from "@opensystemslab/planx-core/types";
 import { NextFunction, Request, Response } from "express";
 import { gql } from "graphql-request";
-import { $api } from "../client";
-import { adminGraphQLClient as adminClient } from "../hasura";
+import { $api, $public } from "../client";
 import {
   ScheduledEventResponse,
   createScheduledEvent,
@@ -121,11 +120,19 @@ const createPaymentSendEvents = async (
   }
 };
 
+interface GetTeamSlugByFlowId {
+  flows: {
+    team: {
+      slug: string;
+    };
+  };
+}
+
 const getTeamSlugByFlowId = async (id: Flow["id"]): Promise<Team["slug"]> => {
-  const data = await adminClient.request(
+  const data = await $public.client.request<GetTeamSlugByFlowId>(
     gql`
       query GetTeamSlugByFlowId($id: uuid!) {
-        flows_by_pk(id: $id) {
+        flows: flows_by_pk(id: $id) {
           team {
             slug
           }
@@ -135,7 +142,7 @@ const getTeamSlugByFlowId = async (id: Flow["id"]): Promise<Team["slug"]> => {
     { id },
   );
 
-  return data.flows_by_pk.team.slug;
+  return data.flows.team.slug;
 };
 
 export { createPaymentSendEvents };

api.planx.uk/notify/routeSendEmailRequest.test.ts

@@ -217,9 +217,7 @@ describe("Send Email endpoint", () => {
       const softDeleteSessionMock = queryMock
         .getCalls()
         .find((mock) => mock.id === "SoftDeleteLowcalSession");
-      expect(
-        softDeleteSessionMock?.response.data.update_lowcal_sessions_by_pk.id,
-      ).toEqual("123");
+      expect(softDeleteSessionMock?.response.data.session.id).toEqual("123");
     });
   });
 });

api.planx.uk/saveAndReturn/resumeApplication.test.ts

@@ -4,31 +4,33 @@ import app from "../server";
 import { queryMock } from "../tests/graphqlQueryMock";
 import { mockLowcalSession, mockTeam } from "../tests/mocks/saveAndReturnMocks";
 import { buildContentFromSessions } from "./resumeApplication";
+import { PartialDeep } from "type-fest";
 
 const ENDPOINT = "/resume-application";
 const TEST_EMAIL = "[email protected]";
 
-type DeepPartial<T> = T extends object
-  ? {
-      [P in keyof T]?: DeepPartial<T[P]>;
-    }
-  : T;
-
 const mockFormatRawProjectTypes = jest
   .fn()
   .mockResolvedValue(["New office premises"]);
 
 jest.mock("@opensystemslab/planx-core", () => {
+  const actualCoreDomainClient = jest.requireActual(
+    "@opensystemslab/planx-core",
+  ).CoreDomainClient;
+
   return {
-    CoreDomainClient: jest.fn().mockImplementation(() => ({
-      formatRawProjectTypes: () => mockFormatRawProjectTypes(),
-    })),
+    CoreDomainClient: class extends actualCoreDomainClient {
+      constructor() {
+        super();
+        this.formatRawProjectTypes = () => mockFormatRawProjectTypes();
+      }
+    },
   };
 });
 
 describe("buildContentFromSessions function", () => {
   it("should return correctly formatted content for a single session", async () => {
-    const sessions: DeepPartial<LowCalSession>[] = [
+    const sessions: PartialDeep<LowCalSession>[] = [
       {
         data: {
           passport: {
@@ -62,7 +64,7 @@ describe("buildContentFromSessions function", () => {
   });
 
   it("should return correctly formatted content for multiple session", async () => {
-    const sessions: DeepPartial<LowCalSession>[] = [
+    const sessions: PartialDeep<LowCalSession>[] = [
       {
         data: {
           passport: {
@@ -137,7 +139,7 @@ describe("buildContentFromSessions function", () => {
   });
 
   it("should handle an empty address field", async () => {
-    const sessions: DeepPartial<LowCalSession>[] = [
+    const sessions: PartialDeep<LowCalSession>[] = [
       {
         data: {
           passport: {
@@ -170,7 +172,7 @@ describe("buildContentFromSessions function", () => {
 
   it("should handle an empty project type field", async () => {
     mockFormatRawProjectTypes.mockResolvedValueOnce("");
-    const sessions: DeepPartial<LowCalSession>[] = [
+    const sessions: PartialDeep<LowCalSession>[] = [
       {
         data: {
           passport: {
@@ -227,7 +229,7 @@ describe("Resume Application endpoint", () => {
 
     queryMock.mockQuery({
       name: "ValidateRequest",
-      data: { teams: null, lowcal_sessions: null },
+      data: { teams: null, sessions: null },
       variables: body.payload,
     });
 
@@ -249,7 +251,7 @@ describe("Resume Application endpoint", () => {
     queryMock.mockQuery({
       name: "ValidateRequest",
       data: {
-        lowcal_sessions: [mockLowcalSession],
+        sessions: [mockLowcalSession],
         teams: [mockTeam],
       },
       variables: body.payload,
@@ -269,7 +271,7 @@ describe("Resume Application endpoint", () => {
 
     queryMock.mockQuery({
       name: "ValidateRequest",
-      data: { teams: [mockTeam], lowcal_sessions: [] },
+      data: { teams: [mockTeam], sessions: [] },
       variables: body.payload,
     });
 

api.planx.uk/saveAndReturn/resumeApplication.ts

@@ -1,11 +1,10 @@
 import { NextFunction, Request, Response } from "express";
 import { gql } from "graphql-request";
-import { adminGraphQLClient as adminClient } from "../hasura";
 import { LowCalSession, Team } from "../types";
 import { convertSlugToName, getResumeLink, calculateExpiryDate } from "./utils";
 import { sendEmail } from "../notify";
 import type { SiteAddress } from "@opensystemslab/planx-core/types";
-import { $public } from "../client";
+import { $api, $public } from "../client";
 
 /**
  * Send a "Resume" email to an applicant which list all open applications for a given council (team)
@@ -42,6 +41,11 @@ const resumeApplication = async (
   }
 };
 
+interface ValidateRequest {
+  teams: Team[];
+  sessions: LowCalSession[] | null;
+}
+
 /**
  * Validate that there are sessions matching the request
  * XXX: Admin role is required here as we are relying on the combination of email
@@ -57,7 +61,7 @@ const validateRequest = async (
   try {
     const query = gql`
       query ValidateRequest($email: String, $teamSlug: String) {
-        lowcal_sessions(
+        sessions(
           where: {
             email: { _eq: $email }
             deleted_at: { _is_null: true }
@@ -81,16 +85,19 @@ const validateRequest = async (
         }
       }
     `;
-    const { lowcal_sessions, teams } = await adminClient.request(query, {
-      teamSlug,
-      email: email.toLowerCase(),
-    });
+    const { sessions, teams } = await $api.client.request<ValidateRequest>(
+      query,
+      {
+        teamSlug,
+        email: email.toLowerCase(),
+      },
+    );
 
     if (!teams?.length) throw Error;
 
     return {
       team: teams[0],
-      sessions: lowcal_sessions,
+      sessions: sessions || [],
     };
   } catch (error) {
     throw Error("Unable to validate request");

api.planx.uk/saveAndReturn/utils.ts

@@ -1,10 +1,9 @@
 import { SiteAddress } from "@opensystemslab/planx-core/types";
 import { format, addDays } from "date-fns";
 import { gql } from "graphql-request";
-import { adminGraphQLClient as adminClient } from "../hasura";
 import { LowCalSession, Team } from "../types";
 import { Template, getClientForTemplate, sendEmail } from "../notify";
-import { $public } from "../client";
+import { $api, $public } from "../client";
 
 const DAYS_UNTIL_EXPIRY = 28;
 const REMINDER_DAYS_FROM_EXPIRY = [7, 1];
@@ -201,7 +200,7 @@ const softDeleteSession = async (sessionId: string) => {
         }
       }
     `;
-    await adminClient.request(mutation, { sessionId });
+    await $api.client.request(mutation, { sessionId });
   } catch (error) {
     throw new Error(`Error deleting session ${sessionId}`);
   }
@@ -223,7 +222,7 @@ const markSessionAsSubmitted = async (sessionId: string) => {
         }
       }
     `;
-    await adminClient.request(mutation, { sessionId });
+    await $api.client.request(mutation, { sessionId });
   } catch (error) {
     throw new Error(`Error marking session ${sessionId} as submitted`);
   }
@@ -238,25 +237,31 @@ const getSaveAndReturnPublicHeaders = (sessionId: string, email: string) => ({
   "x-hasura-lowcal-email": email.toLowerCase(),
 });
 
+interface SetupEmailNotifications {
+  session: { hasUserSaved: boolean };
+}
+
 // Update lowcal_sessions.has_user_saved column to kick-off the setup_lowcal_expiry_events &
 // setup_lowcal_reminder_events event triggers in Hasura
 // Should only run once on initial save of a session
 const setupEmailEventTriggers = async (sessionId: string) => {
   try {
     const mutation = gql`
       mutation SetupEmailNotifications($sessionId: uuid!) {
-        update_lowcal_sessions_by_pk(
+        session: update_lowcal_sessions_by_pk(
           pk_columns: { id: $sessionId }
           _set: { has_user_saved: true }
         ) {
           id
-          has_user_saved
+          hasUserSaved: has_user_saved
         }
       }
     `;
     const {
-      update_lowcal_sessions_by_pk: { has_user_saved: hasUserSaved },
-    } = await adminClient.request(mutation, { sessionId });
+      session: { hasUserSaved },
+    } = await $api.client.request<SetupEmailNotifications>(mutation, {
+      sessionId,
+    });
     return hasUserSaved;
   } catch (error) {
     throw new Error(

api.planx.uk/saveAndReturn/validateSession.test.ts

@@ -13,12 +13,24 @@ import {
   stubUpdateLowcalSessionData,
 } from "../tests/mocks/saveAndReturnMocks";
 import type { Node, Flow, Breadcrumb } from "../types";
+import { userContext } from "../modules/auth/middleware";
+import { getJWT } from "../tests/mockJWT";
 
 const validateSessionPath = "/validate-session";
+const getStoreMock = jest.spyOn(userContext, "getStore");
 
 describe("Validate Session endpoint", () => {
   const reconciledData = omit(mockLowcalSession.data, "passport");
 
+  beforeEach(() => {
+    getStoreMock.mockReturnValue({
+      user: {
+        sub: "123",
+        jwt: getJWT({ role: "teamEditor" }),
+      },
+    });
+  });
+
   afterEach(() => {
     queryMock.reset();
   });