CTC-141 add listing functions

src/fft-api/index.ts

@@ -2,16 +2,17 @@ export * from './auth';
 export * from './common';
 export * from './facility';
 export * from './handover';
+export * from './listing';
 export * from './loadunit';
 export * from './order';
+export * from './packjob';
 export * from './parcel';
 export * from './pickjob';
-export * from './packjob';
 export * from './process';
 export * from './routing-plan';
 export * from './shipment';
+export * from './stock';
 export * from './subscription';
 export * from './tag';
 export * from './types';
-export * from './stock';
 export * from './zone';

src/fft-api/listing/fftListingService.ts

@@ -0,0 +1,118 @@
+import { Logger } from 'tslog';
+import { ResponseError } from 'superagent';
+
+import { FftApiClient } from '../common';
+import { CustomLogger } from '../../common';
+import { Listing, ListingForReplacement, ModifyListingAction, StrippedListings } from '../types';
+
+export class FftListingService {
+  private readonly path = 'listings';
+  private readonly logger: Logger<FftListingService> = new CustomLogger<FftListingService>();
+
+  constructor(private readonly apiClient: FftApiClient) {}
+
+  public async create(facilityId: string, listing: ListingForReplacement): Promise<Listing> {
+    try {
+      const listingsForReplacement = { listings: [listing] };
+      return await this.apiClient.put<Listing>(`facilities/${facilityId}/${this.path}`, {
+        ...listingsForReplacement,
+      });
+    } catch (err) {
+      const httpError = err as ResponseError;
+      this.logger.error(
+        `Could not create listing ${listing.tenantArticleId} for facility ${facilityId}. Failed with status ${
+          httpError.status
+        }, error: ${httpError.response ? JSON.stringify(httpError.response.body) : ''}`
+      );
+
+      throw err;
+    }
+  }
+
+  public async get(facilityId: string, tenantArticleId: string, relaxed = false): Promise<Listing | undefined> {
+    try {
+      return await this.apiClient.get<Listing>(`facilities/${facilityId}/${this.path}/${tenantArticleId}`);
+    } catch (err) {
+      const httpError = err as ResponseError;
+      if (httpError.status === 404 && relaxed) {
+        return undefined;
+      }
+      this.logger.error(
+        `Could not fetch listing ${tenantArticleId} for facility ${facilityId}. Failed with status ${
+          httpError.status
+        }, error: ${httpError.response ? JSON.stringify(httpError.response.body) : ''}`
+      );
+
+      throw err;
+    }
+  }
+
+  public async getAll(facilityId: string, size = 25): Promise<StrippedListings> {
+    try {
+      return await this.apiClient.get<StrippedListings>(`facilities/${facilityId}/${this.path}`, {
+        ...(size && { size: size.toString() }),
+      });
+    } catch (error) {
+      const httpError = error as ResponseError;
+      this.logger.error(
+        `Could not get listings for facility ${facilityId}. Failed with status ${httpError.status}, error: ${
+          httpError.response ? JSON.stringify(httpError.response.body) : ''
+        }`
+      );
+      throw error;
+    }
+  }
+
+  public async update(facilityId: string, tenantArticleId: string, action: ModifyListingAction): Promise<Listing> {
+    try {
+      action.action = ModifyListingAction.ActionEnum.ModifyListing;
+      const listing = await this.get(facilityId, tenantArticleId);
+      const listingPatchActions = {
+        actions: [action],
+        version: listing?.version,
+      };
+      return await this.apiClient.patch<Listing>(`facilities/${facilityId}/${this.path}/${tenantArticleId}`, {
+        ...listingPatchActions,
+      });
+    } catch (err) {
+      const httpError = err as ResponseError;
+      this.logger.error(
+        `Could not update listing ${tenantArticleId} for facility ${facilityId}. Failed with status ${
+          httpError.status
+        }, error: ${httpError.response ? JSON.stringify(httpError.response.body) : ''}`
+      );
+
+      throw err;
+    }
+  }
+
+  public async delete(facilityId: string, tenantArticleId: string): Promise<void> {
+    try {
+      return await this.apiClient.delete<void>(`facilities/${facilityId}/${this.path}/${tenantArticleId}`);
+    } catch (err) {
+      const httpError = err as ResponseError;
+      this.logger.error(
+        `Could not delete listing ${tenantArticleId} for facility ${facilityId}. Failed with status ${
+          httpError.status
+        }, error: ${httpError.response ? JSON.stringify(httpError.response.body) : ''}`
+      );
+
+      throw err;
+    }
+  }
+
+  public async deleteAll(facilityId: string): Promise<void> {
+    try {
+      return await this.apiClient.delete<void>(`facilities/${facilityId}/${this.path}`);
+    } catch (err) {
+      const httpError = err as ResponseError;
+      this.logger.error(
+        `Could not delete listings for facility ${facilityId}. Failed with status ${httpError.status}, error: ${
+          httpError.response ? JSON.stringify(httpError.response.body) : ''
+        }`
+      );
+
+      throw err;
+    }
+  }
+}

src/fft-api/listing/index.ts

@@ -0,0 +1 @@
+export * from './fftListingService';

src/fft-api/types/api-ctl.sh

@@ -4,7 +4,7 @@ SCRIPTDIR="$( cd "$( dirname "${BASH_SOURCE[0]}" )" >/dev/null 2>&1 && pwd )"
 
 TARGET_DIR="${SCRIPTDIR}/typescript-fetch-client"
 apiUrl="https://raw.githubusercontent.com/fulfillmenttools/fulfillmenttools-api-reference/master/api.swagger.yaml"
-openApiVersion="3.0.54"
+openApiVersion="3.0.57"
 swaggerFile="swagger-codegen-cli-${openApiVersion}.jar"
 localSwaggerFile="${SCRIPTDIR}/${swaggerFile}"
 swaggerCodeGenUrl="https://repo1.maven.org/maven2/io/swagger/codegen/v3/swagger-codegen-cli/${openApiVersion}/${swaggerFile}"