WIP - call out to Octopus Imaging API from database-bridge-lambda i…

…n `createItem` mutation if the `type` is `imaging-request`

database-bridge-lambda/package.json

@@ -12,9 +12,11 @@
   "devDependencies": {
     "@types/aws-lambda": "^8.10.102",
     "aws-sdk": "^2.840.0",
-    "ts-node-dev": "^1.0.0"
+    "ts-node-dev": "^1.0.0",
+    "@types/node-fetch": "2"
   },
   "dependencies": {
-    "postgres": "^3.2.4"
+    "postgres": "^3.2.4",
+    "node-fetch": "2"
   }
 }

database-bridge-lambda/run.ts

@@ -4,6 +4,7 @@ import { createDatabaseTunnel } from "../shared/database/local/databaseTunnel";
 import prompts from "prompts";
 import { DatabaseOperation } from "../shared/graphql/operations";
 import { getYourEmail } from "../shared/local/yourEmail";
+import { performImagingRequest } from "./src/imagingRequestCallout";
 
 (async () => {
   const baseInput = {
@@ -29,16 +30,30 @@ import { getYourEmail } from "../shared/local/yourEmail";
       type: "select",
       name: "inputPayload",
       message: "Operation?",
-      choices: Object.entries(sampleInputs).map(([operation, sampleInput]) => ({
-        title: operation,
-        value: {
-          ...baseInput,
-          arguments: sampleInput,
-          info: { fieldName: operation },
-        } as AppSyncResolverEvent<unknown, unknown>,
-      })),
+      choices: [
+        { title: "SAMPLE IMAGING ORDER", value: "imaging-request" },
+        ...Object.entries(sampleInputs).map(([operation, sampleInput]) => ({
+          title: operation,
+          value: {
+            ...baseInput,
+            arguments: sampleInput,
+            info: { fieldName: operation },
+          } as AppSyncResolverEvent<unknown, unknown>,
+        })),
+      ],
     });
 
-    console.log(JSON.stringify(await handler(inputPayload), null, 2));
+    console.log(
+      JSON.stringify(
+        inputPayload === "imaging-request"
+          ? await performImagingRequest({
+              item: {} as any,
+              existingPayload: {},
+            })
+          : await handler(inputPayload),
+        null,
+        2
+      )
+    );
   }
 })();

database-bridge-lambda/src/imagingRequestCallout.ts

@@ -0,0 +1,27 @@
+import fetch from "node-fetch";
+import { Item } from "../../shared/graphql/graphql";
+import { pinboardConfigPromiseGetter } from "../../shared/awsIntegration";
+
+export const performImagingRequest = async ({
+  //TODO don't pass the whole item, just the fields we need
+  item,
+  existingPayload,
+}: {
+  item: Item;
+  existingPayload: any;
+}) => {
+  console.log("performImagingRequest", item, existingPayload);
+  const response = await fetch(
+    await pinboardConfigPromiseGetter("octopus/imaging/orderURL"),
+    {
+      method: "POST",
+      headers: {
+        "Content-Type": "application/json",
+      },
+      body: JSON.stringify({ bob: "hope", frank: " sinatra" }),
+      //TODO auth??
+    }
+  );
+  const responseJSON = (await response.json()) as { bob: string };
+  return responseJSON.bob;
+};

database-bridge-lambda/src/sql/Item.ts

@@ -4,6 +4,8 @@ import {
   PinboardIdWithClaimCounts,
 } from "../../../shared/graphql/graphql";
 import { Sql } from "../../../shared/database/types";
+import { performImagingRequest } from "../imagingRequestCallout";
+import { IMAGING_REQUEST_ITEM_TYPE } from "../../../shared/octopusImaging";
 
 const fragmentIndividualMentionsToMentionHandles = (
   sql: Sql,
@@ -57,10 +59,34 @@ export const createItem = async (
   args: { input: CreateItemInput },
   userEmail: string
 ) =>
-  sql`
+  sql.begin(async (sql) => {
+    const insertResult = (await sql`
         INSERT INTO "Item" ${sql({ userEmail, ...args.input })}
             RETURNING ${fragmentItemFields(sql, userEmail)}
-    `.then((rows) => rows[0]);
+    `.then((rows) => rows[0])) as Item;
+    if (
+      insertResult.type === IMAGING_REQUEST_ITEM_TYPE &&
+      insertResult.payload
+    ) {
+      const existingPayload = JSON.parse(insertResult.payload);
+      // if this throws, the SQL transaction should be rolled back
+      const octopusImagingOrderId = await performImagingRequest({
+        item: insertResult,
+        existingPayload,
+      });
+      return sql`
+        UPDATE "Item" 
+        SET "payload" = ${{
+          ...existingPayload,
+          octopusImagingOrderId,
+        }}}
+        WHERE "id" = ${insertResult.id} 
+        RETURNING ${fragmentItemFields(sql, userEmail)}`.then(
+        (rows) => rows[0]
+      );
+    }
+    return insertResult;
+  });
 
 export const listItems = (
   sql: Sql,

shared/octopusImaging.ts

@@ -0,0 +1 @@
+export const IMAGING_REQUEST_ITEM_TYPE = "imaging-request";