feat(Transfer): adds 'next' export for Stream Access Points (#764)

Author: jbottigliero

src/services/transfer/__tests__/__snapshots__/stream-access-point.spec.ts.snap

@@ -1,4 +1,4 @@
-// Jest Snapshot v1, https://jestjs.io/docs/snapshot-testing
+// Jest Snapshot v1, https://goo.gl/fbAQLP
 
 exports[`streamAccessPoint get 1`] = `
 {
@@ -27,3 +27,31 @@ exports[`streamAccessPoint getAll 1`] = `
   "url": "https://transfer.api.globus.org/v2/stream_access_points?filter%5Bendpoint_admin%5D=true&filter%5Bfulltext%5D=example",
 }
 `;
+
+exports[`streamAccessPoint next get 1`] = `
+{
+  "headers": {
+    "accept": "*/*",
+    "accept-encoding": "gzip,deflate",
+    "connection": "close",
+    "host": "transfer.api.globus.org",
+    "user-agent": "node-fetch/1.0 (+https://github.com/bitinn/node-fetch)",
+  },
+  "method": "GET",
+  "url": "https://transfer.api.globus.org/v2/stream_access_points/example-stream-access-point-id",
+}
+`;
+
+exports[`streamAccessPoint next getAll 1`] = `
+{
+  "headers": {
+    "accept": "*/*",
+    "accept-encoding": "gzip,deflate",
+    "connection": "close",
+    "host": "transfer.api.globus.org",
+    "user-agent": "node-fetch/1.0 (+https://github.com/bitinn/node-fetch)",
+  },
+  "method": "GET",
+  "url": "https://transfer.api.globus.org/v2/stream_access_points?filter%5Bendpoint_admin%5D=true&filter%5Bfulltext%5D=example",
+}
+`;

src/services/transfer/__tests__/stream-access-point.spec.ts

@@ -27,4 +27,38 @@ describe('streamAccessPoint', () => {
       headers,
     }).toMatchSnapshot();
   });
+
+  describe('next', () => {
+    test('getAll', async () => {
+      const {
+        req: { url, method, headers },
+      } = await mirror(
+        await streamAccessPoint.next.getAll({
+          request: {
+            query: { 'filter[endpoint_admin]': true, 'filter[fulltext]': 'example' },
+          },
+        }),
+      );
+      expect({
+        url,
+        method,
+        headers,
+      }).toMatchSnapshot();
+    });
+
+    test('get', async () => {
+      const {
+        req: { url, method, headers },
+      } = await mirror(
+        await streamAccessPoint.next.get({
+          stream_access_point_uuid: 'example-stream-access-point-id',
+        }),
+      );
+      expect({
+        url,
+        method,
+        headers,
+      }).toMatchSnapshot();
+    });
+  });
 });

src/services/transfer/service/stream-access-point.ts

@@ -1,6 +1,7 @@
 import { serviceRequest } from '../../shared.js';
 import { ID as service } from '../config.js';
 import { RESOURCE_SERVERS } from '../../auth/config.js';
+import { createServiceMethodFactory } from '../../factory.js';
 
 import type {
   ServiceMethodDynamicSegments,
@@ -60,3 +61,35 @@ export const get = function (
     payload?: GetOperation['requestBody'];
   }
 >;
+
+/**
+ * @private
+ */
+export const next = {
+  getAll: createServiceMethodFactory({
+    service,
+    resource_server: RESOURCE_SERVERS.TRANSFER,
+    path: `/v2/stream_access_points`,
+  }).generate<
+    {
+      request?: {
+        query?: GetAllOperation['parameters']['query'];
+        data?: GetAllOperation['requestBody'];
+      };
+    },
+    JSONFetchResponse<GetAllOperation['responses']['200']['content']['application/json']>
+  >(),
+  get: createServiceMethodFactory({
+    service,
+    resource_server: RESOURCE_SERVERS.TRANSFER,
+    path: `/v2/stream_access_points/{stream_access_point_uuid}`,
+  }).generate<
+    {
+      request?: {
+        query?: GetOperation['parameters']['query'];
+        data?: GetOperation['requestBody'];
+      };
+    },
+    JSONFetchResponse<GetOperation['responses']['200']['content']['application/json']>
+  >(),
+};