Merge marketplace listings

omni products scan-duplicates --json '{}'
omni products get-duplicate-scan --format json
omni products list --status duplicates --duplicate-type sku --detail full --format json

omni products preview-duplicate-merge --json '{"productIds":["product-a","product-b"]}' --format json

omni products preview-duplicate-merge --json '{"productIds":["product-a","product-b"],"masterProductIds":["product-b"]}' --format json

omni products merge-duplicates --json '{"productIds":["product-a","product-b"],"masterProductIds":["product-b"],"expectedGroups":[{"productIds":["product-b","product-a"],"sku":"REVIEWED-SKU"}],"dryRun":true}' --format json

omni products merge-duplicates --json '{"productIds":["product-a","product-b"],"masterProductIds":["product-b"],"expectedGroups":[{"productIds":["product-b","product-a"],"sku":"REVIEWED-SKU"}]}' --format json

// Refresh once with scanDuplicates({}) if needed, then wait for completion.
const scan = await client.products.getDuplicateScan();
if (scan.data.status !== "completed")
  throw new Error("Wait for a successful duplicate scan");

const page = await client.products.list({
  status: "duplicates",
  duplicateType: "sku",
  detail: "full",
});
// Page all results and select the root + exact_sku peer IDs to review.
const productIds = ["product-a", "product-b"];
const inspected = await client.products.previewDuplicateMerge({ productIds });
if (inspected.data.groups.length !== 1)
  throw new Error("Review one master per group");
const allowed =
  inspected.data.groups[0].masterSelections?.filter((x) => x.allowed) ?? [];
// If several are allowed, obtain the seller's choice instead of guessing.
if (allowed.length !== 1)
  throw new Error("Choose an eligible master before continuing");
const masterProductIds = [allowed[0].productId];
const reviewed = await client.products.previewDuplicateMerge({
  productIds,
  masterProductIds,
});
if (!reviewed.data.success) throw new Error(reviewed.data.error);
const expectedGroups = reviewed.data.groups.map((group) => {
  if (!group.success || !group.sku) throw new Error("A group is not ready");
  return { productIds: group.productIds, sku: group.sku };
});
// Test the actual merge transaction without saving:
const simulation = await client.products.mergeDuplicates({
  productIds,
  masterProductIds,
  expectedGroups,
  dryRun: true,
});
console.log(simulation.data.success, simulation.data.wouldMergeProductIds);
// A real merge is separate, after the seller approves these concrete targets:
const result = await client.products.mergeDuplicates({
  productIds,
  masterProductIds,
  expectedGroups,
});
console.log(result.data.success, result.data.items);

# Refresh once with scan_duplicates() if needed, then wait for completion.
scan = client.products.get_duplicate_scan()  # wait for data.status == completed
if scan["data"]["status"] != "completed":
    raise ValueError("Wait for a successful duplicate scan")
page = client.products.list(status="duplicates", duplicate_type="sku", detail="full")
product_ids = ["product-a", "product-b"]  # selected root and exact-SKU peers
inspected = client.products.preview_duplicate_merge(product_ids=product_ids)
if len(inspected["data"]["groups"]) != 1:
    raise ValueError("Review one master per group")
allowed = [x for x in inspected["data"]["groups"][0].get("masterSelections", []) if x["allowed"]]
if len(allowed) != 1:
    raise ValueError("Choose an eligible master before continuing")
masters = [allowed[0]["productId"]]
reviewed = client.products.preview_duplicate_merge(product_ids=product_ids, master_product_ids=masters)
if not reviewed["data"]["success"]:
    raise ValueError(reviewed["data"].get("error", "Merge blocked"))
groups = reviewed["data"]["groups"]
expected = [{"productIds": g["productIds"], "sku": g["sku"]} for g in groups]
# Test the transaction without saving any changes:
simulation = client.products.merge_duplicates(product_ids=product_ids, master_product_ids=masters, expected_groups=expected, dry_run=True)
print(simulation["data"]["success"], simulation["data"]["wouldMergeProductIds"])
# A real merge is separate, after reviewing and approving all targets:
result = client.products.merge_duplicates(product_ids=product_ids, master_product_ids=masters, expected_groups=expected)
print(result["data"]["success"], result["data"]["items"])