Method push

packages/computer/src/workspace.ts:557–581

(id?: string)

  // span on the configured observer, tagged with the resolved
  // backend id and the entry count.
  push(id?: string): Promise<number> {
    return this.#serialize(id, (resolvedId) =>
      withSpan(
        this.#observer,
        "workspace.sync.push",
        { "workspace.sync.backend": resolvedId },
        async () => {
          if (resolvedId === undefined || this.#moduleBackendsById.has(resolvedId)) return 0;
          const handle = await this.#handleFor(resolvedId);
          // A backend that reuses the host store as its sole
          // source of truth has nothing to ship and no remote to
          // ship to. Short-circuit so the shell exec bracket can
          // keep calling push() unconditionally without paying
          // for it.
          if (handle.sync === "none") return 0;
          return this.#runWithInvalidation(resolvedId, handle, () =>
            pushOnce(this.#db, handle.rpc.sync, resolvedId),
          );
        },
        (span, outcome) => {
          if (outcome.ok) span.setAttribute("workspace.sync.pushed", outcome.value);
        },
      ),
    );
  }

  pull(id?: string): Promise<ApplyResult> {
    return this.#serialize(id, (resolvedId) => this.#pullResolved(resolvedId));