Function pushObjects

packages/dofs/src/sync/push.ts:13–27

(
  db: Database,
  hashes: Uint8Array[],
)

// fetchObjects on one side and pushObjects on the other. Both names
// resolve to the same SQL.
export async function* pushObjects(
  db: Database,
  hashes: Uint8Array[],
): AsyncIterable<{ hash: Uint8Array; bytes: Uint8Array }> {
  for (const hash of hashes) {
    const row = db.one<{ bytes: Uint8Array }>(
      "SELECT bytes FROM vfs_blob_bytes WHERE hash = ?",
      hash,
    );
    if (row === undefined) {
      throw createWorkspaceError("EUNKNOWN_HASH", "pushObjects: missing blob for requested hash");
    }
    yield { hash, bytes: row.bytes };
  }
}