endpoint: ProducerHandler returns Promisable

Author: yoursunny

pkg/endpoint/package.json

@@ -30,7 +30,8 @@
     "@ndn/packet": "workspace:*",
     "@ndn/util": "workspace:*",
     "streaming-iterables": "^8.0.1",
-    "tslib": "^2.8.1"
+    "tslib": "^2.8.1",
+    "type-fest": "^5.7.0"
   },
   "devDependencies": {
     "@ndn/keychain": "workspace:*",

pkg/endpoint/src/producer.ts

@@ -1,6 +1,7 @@
 import { Forwarder, type FwFace, FwPacket } from "@ndn/fw";
 import { Data, Interest, Name, type NameLike, Signer } from "@ndn/packet";
 import { flatTransform } from "streaming-iterables";
+import type { Promisable } from "type-fest";
 
 import { type CommonOptions, exactOptions } from "./common";
 import type { DataBuffer } from "./data-buffer";
@@ -19,7 +20,7 @@ import type { DataBuffer } from "./data-buffer";
  *   - {@link ProducerOptions.dataBuffer} is unset: cause a timeout.
  *   - {@link ProducerOptions.dataBuffer} is provided: query the DataBuffer.
  */
-export type ProducerHandler = (interest: Interest, producer: Producer) => Promise<Data | undefined>;
+export type ProducerHandler = (interest: Interest, producer: Producer) => Promisable<Data | undefined>;
 
 /** {@link produce} options. */
 export interface ProducerOptions extends CommonOptions {
@@ -29,7 +30,7 @@ export interface ProducerOptions extends CommonOptions {
    * @defaultValue `true`
    *
    * @remarks
-   * If all nexthops of a FIB entry are set to non-capture, FIB lookup may continue onto nexthops
+   * If all next-hops of a FIB entry are set to non-capture, FIB lookup may continue onto next-hops
    * on FIB entries with shorter prefixes. One use case is in dataset synchronization protocols,
    * where both local and remote sync participants want to receive each other's Interests.
    */

pkg/ndncert/src/server/server.ts

@@ -122,7 +122,7 @@ export class Server {
     }
   }
 
-  private readonly handleInfoInterest: ProducerHandler = async () => this.profile.data;
+  private readonly handleInfoInterest: ProducerHandler = () => this.profile.data;
 
   private readonly handleProbeInterest: ProducerHandler = async (interest) => {
     let request: ProbeRequest;

pkg/psync/src/partial-publisher.ts

@@ -115,7 +115,7 @@ export class PartialPublisher extends TypedEventTarget<EventMap> implements Sync
     return this.c.add(prefix);
   }
 
-  private readonly handleHelloInterest: ProducerHandler = async (interest) => {
+  private readonly handleHelloInterest: ProducerHandler = (interest) => {
     if (interest.name.length !== this.syncPrefix.length + 1) {
       // segment Interest should be satisfied by StateProducerBuffer
       return undefined;

pkg/segmented-object/src/serve/data-producer.ts

@@ -41,7 +41,7 @@ export abstract class DataProducer {
     }
   }
 
-  public readonly processInterest: ProducerHandler = (interest: Interest): Promise<Data | undefined> => {
+  public readonly processInterest: ProducerHandler = (interest) => {
     const segmentNum = this.parseInterest(interest);
     return this.getData(segmentNum);
   };

pkg/svs/src/publisher.ts

@@ -126,7 +126,7 @@ export class SvPublisher {
     return seqNum;
   }
 
-  private readonly handleOuter: ProducerHandler = async (interest) => {
+  private readonly handleOuter: ProducerHandler = (interest) => {
     if (!interest.name.get(this.nodeSyncPrefix.length)?.is(GenericNumber)) {
       return undefined;
     }