ingest_record
Ingest a record from any registered source system and automatically match it to a canonical AnchorID.
Instructions
Ingest a single source record into Anchord. The record is matched to an AnchorID automatically. Requires a registered source (system). Wraps POST /ingest/batch with a single-item array.
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| system | Yes | Source system key (e.g. hubspot, salesforce, stripe, or a custom source) | |
| object_type | Yes | Object type within the source (e.g. company, contact, customer) | |
| object_id | Yes | Unique ID of the record in the source system | |
| payload | Yes | Record payload — key/value fields (e.g. name, domain, email) |
Implementation Reference
- src/tools.ts:355-356 (registration)Tool registration of 'ingest_record' on the MCP server via server.tool()
server.tool( "ingest_record", - src/tools.ts:360-367 (schema)Input schema for ingest_record using Zod: requires system, object_type, object_id, and payload fields
{ system: z.string().describe("Source system key (e.g. hubspot, salesforce, stripe, or a custom source)"), object_type: z.string().describe("Object type within the source (e.g. company, contact, customer)"), object_id: z.string().describe("Unique ID of the record in the source system"), payload: z .record(z.unknown()) .describe("Record payload — key/value fields (e.g. name, domain, email)"), }, - src/tools.ts:368-377 (handler)Handler that POSTs the input wrapped in a records array to /ingest/batch, using the ApiClient
async (input) => { try { const data = await api.post("/ingest/batch", { records: [input], }); return jsonContent(data); } catch (e) { return errorContent(e); } }, - src/tools.ts:354-354 (helper)Comment header for the 10th tool: ingest_record
// ─── 10. ingest_record ────────────────────────────────────────── - src/tools.ts:357-359 (helper)Description string explaining the tool wraps POST /ingest/batch with a single-item array
"Ingest a single source record into Anchord. The record is matched to an " + "AnchorID automatically. Requires a registered source (system). " + "Wraps POST /ingest/batch with a single-item array.",