Function syncCommand

src/cli/sync.ts:23–112

(urlOrToken: string)

const MAX_SHARE_BYTES = 2 * 1024 * 1024;

export async function syncCommand(urlOrToken: string): Promise<void> {
  const dbPath = ensureInitialized();

  const token = extractToken(urlOrToken);
  const decoded = decodeShareToken(token);
  let txId = decoded.txId;
  let encrypted: Uint8Array | null = null;
  let shareWallet = "";
  let shareSignature = "";
  let resolvedShareId = "";

  if (txId) {
    try {
      const txMeta = await queryTransactionTagsById(txId);
      if (!txMeta) {
        throw new Error(`No transaction metadata found for tx id: ${txId}`);
      }
      const type = txMeta.tags.get("Type") ?? "";
      const tagShareId = txMeta.tags.get("Share-Id") ?? "";
      const wallet = txMeta.tags.get("Wallet") ?? "";
      const signature = txMeta.tags.get("Signature")?.trim() ?? "";
      if (type !== "conversation-share") {
        throw new Error("Transaction is not a conversation share.");
      }
      if (tagShareId !== decoded.shareId) {
        throw new Error("Share token does not match transaction share id.");
      }
      if (!wallet || !signature) {
        throw new Error("Share transaction is missing signer metadata.");
      }
      encrypted = await downloadShard(txId, MAX_SHARE_BYTES);
      shareWallet = wallet;
      shareSignature = signature;
      resolvedShareId = tagShareId;
    } catch {
      // Fall back to Share-Id lookup for eventual consistency or stale tx references.
      encrypted = null;
    }
  }

  if (!encrypted) {
    const shareInfo = await queryConversationShare(decoded.shareId);
    if (!shareInfo) {
      throw new Error(`No share found for id: ${decoded.shareId}`);
    }
    if (!shareInfo.wallet || !shareInfo.signature) {
      throw new Error("Share transaction is missing signer metadata.");
    }
    txId = shareInfo.txId;
    resolvedShareId = shareInfo.shareId;
    shareWallet = shareInfo.wallet;
    shareSignature = shareInfo.signature;
    encrypted = await downloadShard(txId, MAX_SHARE_BYTES);
  }

  const valid = verifySignature(encrypted, shareSignature, shareWallet);
  if (!valid) {
    throw new Error("Share signature verification failed.");