Function get

packages/rpc/src/sync-driver.test.ts:66–85

(target, prop, receiver)

  let disposeCount = 0;
  const wrapped = new Proxy(rpc as object, {
    get(target, prop, receiver) {
      if (prop === "fetchChanges") {
        return async (...args: Parameters<SyncRPC["fetchChanges"]>) => {
          const real = await Reflect.get(target, prop, receiver).call(target, ...args);
          return {
            ...real,
            ...(opts.appliedPushCursor !== undefined
              ? { appliedPushCursor: opts.appliedPushCursor }
              : {}),
            [Symbol.dispose]() {
              disposeCount += 1;
            },
          };
        };
      }
      if (prop === "hasObjects" && opts.failHasObjects) {
        return async () => [];
      }
      return Reflect.get(target, prop, receiver);
    },
  }) as SyncRPC;
  return { rpc: wrapped, disposeCount: () => disposeCount };
}