Add option to disable unknown offer id error

CHANGELOG.md

@@ -1,5 +1,7 @@
 # Next version
 
+- Add option to disable unknown offer id.
+
 # 2.0.5-50
 
 - Change gas estimation for kandel populate transaction.

src/market.ts

@@ -348,6 +348,11 @@ namespace Market {
      *
      * Defaults to `Semibook.DEFAULT_CHUNK_SIZE`. */
     chunkSize?: number;
+
+    /**
+     * Whether to allow unknown offer IDs in the cache.
+     */
+    allowUnknownId?: boolean;
   };
 
   /**
@@ -684,20 +689,24 @@ class Market {
         return {
           desiredVolume: semibookDesiredVolume,
           chunkSize: opts.chunkSize,
+          allowUnknownId: opts.allowUnknownId,
         };
       } else if ("desiredPrice" in opts) {
         return {
           desiredPrice: opts.desiredPrice,
           chunkSize: opts.chunkSize,
+          allowUnknownId: opts.allowUnknownId,
         };
       } else if ("targetNumberOfTicks" in opts) {
         return {
           targetNumberOfTicks: opts.targetNumberOfTicks,
           chunkSize: opts.chunkSize,
+          allowUnknownId: opts.allowUnknownId,
         };
       } else {
         return {
           chunkSize: opts.chunkSize,
+          allowUnknownId: opts.allowUnknownId,
         };
       }
     };

src/semibook.ts

@@ -98,6 +98,11 @@ namespace Semibook {
      *
      * Defaults to `Semibook.DEFAULT_CHUNK_SIZE`. */
     chunkSize?: number;
+
+    /**
+     * Whether to allow unknown offer IDs in the cache.
+     */
+    allowUnknownId?: boolean;
   };
 
   /**
@@ -224,8 +229,7 @@ class Semibook
   readonly market: Market;
   readonly tickPriceHelper: TickPriceHelper;
   readonly options: Semibook.ResolvedOptions; // complete and validated
-  readonly #cacheOperations: SemibookCacheOperations =
-    new SemibookCacheOperations();
+  readonly #cacheOperations: SemibookCacheOperations;
 
   #eventListeners: Map<Semibook.EventListener, boolean> = new Map();
 
@@ -868,6 +872,8 @@ class Semibook
     this.olKey = market.getOLKey(ba);
 
     this.#eventListeners.set(eventListener, true);
+
+    this.#cacheOperations = new SemibookCacheOperations(options.allowUnknownId);
   }
 
   async stateInitialize(
@@ -1556,6 +1562,12 @@ class CacheIterator implements Semibook.CacheIterator {
 // Only used internally, exposed for testing.
 // All modifications of the cache must be called in a context where #cacheLock is acquired.
 export class SemibookCacheOperations {
+  private allowUnknownId: boolean;
+
+  constructor(allowUnknownId = false) {
+    this.allowUnknownId = allowUnknownId;
+  }
+
   // Marks an incomplete cache as known to be complete.
   markComplete(state: Semibook.State): void {
     if (state.isComplete) {
@@ -1645,7 +1657,7 @@ export class SemibookCacheOperations {
   removeOfferDueToEvent(
     state: Semibook.State,
     id: number,
-    allowUnknownId = false,
+    allowUnknownId = this.allowUnknownId,
   ): Market.Offer | undefined {
     const offer = state.offerCache.get(id);
     if (offer === undefined) {