feat: get subscription

src/sections/subscriptions.ts

@@ -1,4 +1,4 @@
-import { Codec, enumeration, exactly, GetInterface, string } from 'purify-ts'
+import { boolean, Codec, enumeration, exactly, GetInterface, string } from 'purify-ts'
 
 import { ParsingError } from '../error'
 import { HttpClient, RequestMeta, Resource } from '../http'
@@ -15,11 +15,20 @@ export type AttributeKeyValueKeys = 'sqsQueueUrl'
 export type NotificationType =
   | 'AnyOfferChanged'
   | 'FeedProcessingFinished'
-  | 'FeedProcessingFinished'
   | 'FeePromotion'
   | 'FulfillmentOrderStatus'
   | 'ReportProcessingFinished'
 
+enum NotificationTypeEnum {
+  AnyOfferChanged = 'AnyOfferChanged',
+  FeedProcessingFinished = 'FeedProcessingFinished',
+  FeePromotion = 'FeePromotion',
+  FulfillmentOrderStatus = 'FulfillmentOrderStatus',
+  ReportProcessingFinished = 'ReportProcessingFinished',
+}
+
+const NotificationType = enumeration(NotificationTypeEnum)
+
 interface MarketplaceIdAndDestinationOnlyParameters {
   MarketplaceId: string
   Destination: Destination
@@ -112,14 +121,62 @@ const CreateSubscriptionResponse = Codec.interface({
   }),
 })
 
+interface GetSubscriptionParameters {
+  MarketplaceId: string
+  NotificationType: NotificationType
+  Destination: Destination
+}
+
+const Subscription = Codec.interface({
+  NotificationType,
+  Destination,
+  IsEnabled: boolean,
+})
+
+const GetSubscription = Codec.interface({
+  Subscription,
+})
+
+type GetSubscription = GetInterface<typeof GetSubscription>
+
+const GetSubscriptionResponse = Codec.interface({
+  GetSubscriptionResponse: Codec.interface({
+    GetSubscriptionResult: GetSubscription,
+  }),
+})
 export class Subscriptions {
   constructor(private httpClient: HttpClient) {}
 
+  async getSubscription(
+    parameters: GetSubscriptionParameters,
+  ): Promise<[GetSubscription, RequestMeta]> {
+    const [response, meta] = await this.httpClient.request('POST', {
+      resource: Resource.Subscriptions,
+      version: SUBSCRIPTIONS_API_VERSION,
+      action: 'GetSubscription',
+      parameters: {
+        MarketplaceId: parameters.MarketplaceId,
+        NotificationType: parameters.NotificationType,
+        Destination: {
+          DeliveryChannel: parameters.Destination.DeliveryChannel,
+          'AttributeList.member': parameters.Destination.AttributeList,
+        },
+      },
+    })
+
+    return GetSubscriptionResponse.decode(response).caseOf({
+      Right: (x) => [x.GetSubscriptionResponse.GetSubscriptionResult, meta],
+      Left: (error) => {
+        throw new ParsingError(error)
+      },
+    })
+  }
+
   async createSubscription(parameters: CreateSubscriptionParameters): Promise<['', RequestMeta]> {
     const [response, meta] = await this.httpClient.request('POST', {
       resource: Resource.Subscriptions,
       version: SUBSCRIPTIONS_API_VERSION,
-      action: 'SendTestNotificationToDestination',
+      action: 'CreateSubscription',
       parameters: {
         MarketplaceId: parameters.MarketplaceId,
         Subscription: {

test/unit/__snapshots__/subscriptions.test.ts.snap

@@ -1,6 +1,6 @@
 // Jest Snapshot v1, https://goo.gl/fbAQLP
 
-exports[`sellers createSubscription returns the standard response if testing is succesful 1`] = `
+exports[`sellers createSubscription returns the standard response if creation is succesful 1`] = `
 Array [
   "",
   Object {
@@ -42,6 +42,33 @@ Array [
 ]
 `;
 
+exports[`sellers getSubscription returns a subscription if succesful 1`] = `
+Array [
+  Object {
+    "Subscription": Object {
+      "Destination": Object {
+        "AttributeList": Array [
+          Object {
+            "Key": "sqsQueueUrl",
+            "Value": "https://sqs.us-east-1.amazonaws.com/51471EXAMPLE/mws_notifications",
+          },
+        ],
+        "DeliveryChannel": "SQS",
+      },
+      "IsEnabled": true,
+      "NotificationType": "AnyOfferChanged",
+    },
+  },
+  Object {
+    "quotaMax": 1000,
+    "quotaRemaining": 999,
+    "quotaResetOn": 2020-04-06T10:22:23.582Z,
+    "requestId": "0",
+    "timestamp": 2020-05-06T09:22:23.582Z,
+  },
+]
+`;
+
 exports[`sellers listRegisteredDestinations returns a list of destinations if succesful 1`] = `
 Array [
   Object {