Support passing target resource id in transfer message.

__tests__/endpoints/transferPost.test.js

@@ -103,3 +103,30 @@ describe("POST /transfer/:resourceId/:targetGroup/:targetSystem", () => {
     */
   })
 })
+
+describe("POST /transfer/:resourceId/:targetGroup/:targetSystem/:targetResourceId", () => {
+  describe("user is in target group", () => {
+    it("returns a 204 after queueing an SQS message with the expected params", async () => {
+      aws.buildAndSendSqsMessage.mockResolvedValue()
+      const res = await request(app)
+        .post("/transfer/foo/stanford/ils/abc123")
+        .set("Authorization", `Bearer ${stanfordJwt}`)
+        .send("")
+
+      const msgBodyJson = {
+        resource: { uri: "https://api.development.sinopia.io/resource/foo" },
+        user: {
+          email: "[email protected]",
+        },
+        group: "stanford",
+        target: "ils",
+        targetResourceId: "abc123",
+      }
+      expect(res.statusCode).toEqual(204)
+      expect(aws.buildAndSendSqsMessage).toHaveBeenCalledWith(
+        "stanford-ils",
+        expect.stringMatching(JSON.stringify(msgBodyJson))
+      )
+    })
+  })
+})

openapi.yml

@@ -569,6 +569,45 @@ paths:
             application/json:
               schema:
                 $ref: "#/components/schemas/Groups"
+  /transfer/{resourceId}/{targetGroup}/{targetSystem}/{targetResourceId}:
+    post:
+      summary: publish a Sinopia resource to the target group's target system (e.g. stanford's ILS) using the provided target resource id
+      responses:
+        "204":
+          description: "OK - a message was queued for the transfer request"
+        "401":
+          description: Unauthorized
+          content:
+            application/json:
+              schema:
+                $ref: "#/components/schemas/Errors"
+      parameters:
+        - name: resourceId
+          in: path
+          description: ID of the resource
+          required: true
+          schema:
+            type: string
+        - name: targetGroup
+          in: path
+          description: name of the group to which the resource should go
+          required: true
+          schema:
+            type: string
+        - name: targetSystem
+          in: path
+          description: system to which the resource should go
+          example: "ils"
+          required: true
+          schema:
+            type: string
+        - name: targetResourceId
+          in: path
+          description: identifier for the resource in the target system
+          example: "13714202"
+          required: true
+          schema:
+            type: string
   /transfer/{resourceId}/{targetGroup}/{targetSystem}:
     post:
       summary: publish a Sinopia resource to the target group's target system (e.g. stanford's ILS)

src/endpoints/transfer.js

@@ -5,30 +5,38 @@ import { resourceUriFor } from "./resourcesHelpers.js"
 
 const transferRouter = express.Router()
 
-transferRouter.post("/:resourceId/:targetGroup/:targetSystem", [
-  canTransfer,
-  (req, res, next) => {
-    const { resourceId, targetGroup, targetSystem } = req.params
-    console.log(
-      `transferRouter Received post to /${resourceId}/${targetGroup}/${targetSystem}`
-    )
+transferRouter.post(
+  [
+    "/:resourceId/:targetGroup/:targetSystem/:targetResourceId",
+    "/:resourceId/:targetGroup/:targetSystem",
+  ],
+  [
+    canTransfer,
+    (req, res, next) => {
+      const { resourceId, targetGroup, targetSystem, targetResourceId } =
+        req.params
+      console.log(
+        `transferRouter Received post to /${resourceId}/${targetGroup}/${targetSystem}`
+      )
 
-    const sqsMessageBody = {
-      resource: { uri: resourceUriFor(req) },
-      user: {
-        email: req.user.email,
-      },
-      group: targetGroup,
-      target: targetSystem,
-    }
+      const sqsMessageBody = {
+        resource: { uri: resourceUriFor(req) },
+        user: {
+          email: req.user.email,
+        },
+        group: targetGroup,
+        target: targetSystem,
+        targetResourceId,
+      }
 
-    const queueName = `${targetGroup}-${targetSystem}`
-    buildAndSendSqsMessage(queueName, JSON.stringify(sqsMessageBody))
-      .then(() => {
-        res.sendStatus(204)
-      })
-      .catch(next)
-  },
-])
+      const queueName = `${targetGroup}-${targetSystem}`
+      buildAndSendSqsMessage(queueName, JSON.stringify(sqsMessageBody))
+        .then(() => {
+          res.sendStatus(204)
+        })
+        .catch(next)
+    },
+  ]
+)
 
 export default transferRouter