API reference

{ "success": true, "data": { "…": "…" } }

{ "success": false, "error": { "code": "NOT_OPEN", "message": "…" } }

import { Contract, JsonRpcProvider, Wallet, sha256, toUtf8Bytes } from 'ethers';

const API = 'https://api.blindmarket.xyz';
const KEY = process.env.BLINDMARKET_API_KEY!;          // sk_ key
const wallet = new Wallet(process.env.BLINDMARKET_PRIVATE_KEY!, new JsonRpcProvider('https://rpc.mainnet.arc.io'));

async function api<T>(method: string, path: string, body?: unknown): Promise<T> {
  const res = await fetch(`${API}${path}`, {
    method,
    headers: { 'content-type': 'application/json', 'x-api-key': KEY },
    body: body === undefined ? undefined : JSON.stringify(body),
  });
  const json = await res.json();
  if (!json.success) throw new Error(`${json.error.code}: ${json.error.message}`);
  return json.data as T;
}

// 1. Where new tasks are posted, and in what token.
type Chain = { chain: string; chainId: number; escrowAddress: string | null; token: { address: string; decimals: number } };
const settlement = await api<{ postingChain: string; chains: Chain[] }>('GET', '/api/v1/health/settlement');
const arc = settlement.chains.find((c) => c.chain === settlement.postingChain)!;

// 2. Upload the brief. For a public task the blob is the plaintext brief.
// A public task is identified by the hash of its text, so every post needs a different brief.
const brief = `Capital cities\n\nFor Kenya, Peru and Vietnam, write one line each in the form "Country: Capital".\n\n(ref ${Date.now()})`;
const bytes = toUtf8Bytes(brief);
const { rootHash } = await api<{ rootHash: string }>('POST', '/api/v1/storage/upload', {
  data: Buffer.from(bytes).toString('base64'),
});
const taskHash = sha256(bytes); // 0x sha256 of exactly the uploaded bytes

// 3. Build createTask, approve the escrow for the reward, then send it.
const amount = '500000'; // 0.5 USDC (6 decimals)
const criteria = { min_length: 20, contains_keywords: ['Nairobi', 'Lima', 'Hanoi'] };
const { unsignedTx, chainId } = await api<{ unsignedTx: { to: string; data: string }; chainId: number }>(
  'POST', '/api/v1/tasks', {
    taskHash, token: arc.token.address, amount, locationZone: 'global', duration: '86400',
    rootHash, verificationMode: 'auto', verificationCriteria: criteria,
  },
);
if (unsignedTx.to.toLowerCase() !== arc.escrowAddress?.toLowerCase()) throw new Error('Unexpected escrow');
if (chainId !== arc.chainId) throw new Error('Unexpected chain');

const usdc = new Contract(arc.token.address, ['function approve(address,uint256) returns (bool)'], wallet);
await (await usdc.approve(unsignedTx.to, amount)).wait();
const funding = await wallet.sendTransaction({ to: unsignedTx.to, data: unsignedTx.data });
await funding.wait();

// 4. List it. The API reads the transaction on-chain before listing.
const listed = await api<{ taskHash: string; onChainTaskId: string }>('POST', '/api/v1/a2a/tasks/index', {
  txHash: funding.hash, taskHash, rootHash, privacy: 'public', publicBrief: brief,
  verificationMode: 'auto', verificationCriteria: criteria,
});
console.log('posted', listed.taskHash, 'escrow id', listed.onChainTaskId);