Add Integration API parameter to produceOffers

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,19 @@ export interface OfferProducer extends Pluggable {
 
   readonly id: string;
 
-  produceOffers(payload: ListOffersPayload): Promise<OfferSetUpdate>;
+  /**
+   * Produce a diffset of offers that the client should apply to its state.
+   * The response includes a page of the diffs starting at the timestamp passed
+   * in as diffStartTimestampUTC. The returned offers should be in chronological
+   * order.
+   *
+   * @param {ListOffersPayload} payload The request parameters.
+   * @param {IntegrationApi} [integrationApi] API to get server-level data.
+   * Only used for intra-server calls, not for RPC calls.
+   * @return {Promise<OfferSetUpdate>} Returned as a promise to allow for RPCs
+   * and IO.
+   * @memberof OfferProducer
+   */
+  produceOffers(payload: ListOffersPayload, integrationApi: IntegrationApi):
+      Promise<OfferSetUpdate>;
 }

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,8 @@ 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;

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({