Pass IntegrationApi to produceOffers

CaravanStudios#85
blingdahl · Mar 21, 2023 · 5d7eaff · 5d7eaff
1 parent da78d2a
commit 5d7eaff
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 3 deletions.
diff --git a/.DS_Store b/.DS_Store
diff --git a/components/core/src/offerproducer/offerproducer.ts b/components/core/src/offerproducer/offerproducer.ts
@@ -15,6 +15,7 @@
  */
 
 import {ListOffersPayload, Offer, OfferPatch} from 'opr-models';
+import { IntegrationApi } from '../coreapi';
 import {Pluggable} from '../integrations/pluggable';
 
 export interface OfferSetUpdate {
@@ -31,5 +32,5 @@ export interface OfferProducer extends Pluggable {
 
   readonly id: string;
 
-  produceOffers(payload: ListOffersPayload): Promise<OfferSetUpdate>;
+  produceOffers(payload: ListOffersPayload, integrationApi: IntegrationApi): Promise<OfferSetUpdate>;
 }
diff --git a/components/core/src/offerproducer/oprfeedproducer.ts b/components/core/src/offerproducer/oprfeedproducer.ts
@@ -26,6 +26,7 @@ import {OprNetworkClient} from '../net/oprnetworkclient';
 import {Clock} from '../util/clock';
 import {DefaultClock} from '../util/defaultclock';
 import {StatusError} from '../util/statuserror';
+import { IntegrationApi } from '../coreapi';
 
 export class OprFeedProducer implements OfferProducer {
   readonly type = 'offerProducer';
@@ -52,7 +53,7 @@ export class OprFeedProducer implements OfferProducer {
     this.logger = logger;
   }
 
-  async produceOffers(request: ListOffersPayload): Promise<OfferSetUpdate> {
+  async produceOffers(request: ListOffersPayload, integrationApi: IntegrationApi): Promise<OfferSetUpdate> {
     const result = await this.client.list(this.organizationUrl, request);
     let offers: AsyncIterable<Offer> | undefined;
     let patchOps: AsyncIterable<OfferPatch> | undefined;

diff --git a/components/core/src/server/oprtenantnode.ts b/components/core/src/server/oprtenantnode.ts
@@ -291,7 +291,7 @@ export class OprTenantNode {
           requestedResultFormat: 'SNAPSHOT',
         };
       }
-      result = await producer.produceOffers(listPayload);
+      result = await producer.produceOffers(listPayload, this.integrationApi);
       nextRunTimestampUTC = result.earliestNextRequestUTC;
       await this.offerModel.processUpdate(producer.id, result);
       await this.offerModel.writeOfferProducerMetadata({