Migration Operations
Normalize contact rows and quarantine bad mappings — Notion review blocks
Map operator-supplied column keys to normalized contact drafts and return row-indexed quarantine reasons. No import or CRM write occurs. Prepare a Notion review blocks.
Experimental native example · local preview · revision 1
WORKFLOW PREVIEW
See how it works
Use + and − to zoom, F to fit. Press Enter on a node to inspect it.
Private preview. These tested drafts are available for inspection. Adding them to a Vora workspace is still being tested.
What you need
- Authorized supplied job facts matching the original closed input contract.
- Explicit review metadata and target destination fields; no implicit team, channel, list or project selection.
Follow the workflow step by step
Supplied agency job and review metadata
Receive the explicitly supplied manual input packet.
Normalize contact rows and quarantine bad mappings
Map operator-supplied column keys to normalized contact drafts and return row-indexed quarantine reasons. No import or CRM write occurs.
- default: Notion review blocks
Notion review blocks
Map operator-supplied column keys to normalized contact drafts and return row-indexed quarantine reasons. No import or CRM write occurs.
Setup and review
- Download the workflow JSON and inspect its jobInput and deliveryMetadata contracts.
- Supply the original agency job input plus explicit review metadata and destination.
- Run in an isolated test and inspect the complete jobResult, target status, holds and escape report before taking an external action.
Inspect every node
Expand a node to inspect its complete settings. Review the runtime and adoption evidence before installing it.
Supplied agency job and review metadata · wfManualTrigger
{
"label": "Supplied agency job and review metadata"
}Normalize contact rows and quarantine bad mappings · code
{
"label": "Normalize contact rows and quarantine bad mappings",
"code": "return (function(context){\n\nfunction obj(value, keys, required = keys) {\n if (!value || typeof value !== 'object' || Array.isArray(value)) throw new Error('Expected object');\n if (Object.keys(value).some(key => !keys.includes(key))) throw new Error('Unknown input field');\n if (required.some(key => !Object.hasOwn(value, key))) throw new Error('Missing required input field');\n return value;\n}\nfunction text(value, name, max = 200, allowEmpty = false) {\n if (typeof value !== 'string' || value.length > max || (!allowEmpty && !value.trim())) throw new Error('Invalid ' + name);\n return value.trim();\n}\nfunction list(value, name, max = 500) {\n if (!Array.isArray(value) || value.length > max) throw new Error('Invalid ' + name);\n return value;\n}\nfunction int(value, name, min = 0, max = Number.MAX_SAFE_INTEGER) {\n if (!Number.isSafeInteger(value) || value < min || value > max) throw new Error('Invalid ' + name);\n return value;\n}\nfunction amount(value, name) {\n if (!Number.isFinite(value) || value < 0 || value > 1000000000) throw new Error('Invalid ' + name);\n return value;\n}\nfunction email(value) { return /^[^\\s@]+@[^\\s@]+\\.[^\\s@]+$/.test(value); }\nfunction day(value) {\n if (typeof value !== 'string' || !/^\\d{4}-\\d{2}-\\d{2}$/.test(value)) throw new Error('Invalid calendar date');\n const ms = Date.parse(value + 'T00:00:00Z');\n if (!Number.isFinite(ms) || new Date(ms).toISOString().slice(0, 10) !== value) throw new Error('Invalid calendar date');\n return ms;\n}\nfunction instant(value) {\n if (typeof value !== 'string' || !/^\\d{4}-\\d{2}-\\d{2}T\\d{2}:\\d{2}:\\d{2}(\\.\\d{3})?Z$/.test(value)) throw new Error('Invalid UTC timestamp');\n const ms = Date.parse(value);\n const normalized = value.includes('.') ? value : value.replace('Z', '.000Z');\n if (!Number.isFinite(ms) || new Date(ms).toISOString() !== normalized) throw new Error('Invalid UTC timestamp');\n return ms;\n}\nfunction uniqueIds(items) {\n const ids = items.map(item => text(item.id, 'item ID', 120));\n if (new Set(ids).size !== ids.length) throw new Error('Duplicate item ID');\n return ids;\n}\nfunction ratioBps(numerator, denominator) {\n const n = BigInt(numerator) * 10000n;\n const d = BigInt(denominator);\n const quotient = n / d;\n const floor = n < 0n && n % d !== 0n ? quotient - 1n : quotient;\n const result = Number(floor);\n if (!Number.isSafeInteger(result)) throw new Error('Unsafe calculated ratio');\n return result;\n}\n\n\nconst x = obj(context.input, ['importId','mapping','rows']);\nconst importId = text(x.importId, 'import ID', 120), mapping = obj(x.mapping, ['externalId','name','email']);\nconst keys = ['externalId','name','email'];\nconst columns = keys.map(key => text(mapping[key], 'mapping column', 120));\nif (new Set(columns).size !== columns.length) throw new Error('Overlapping mapping keys');\nconst rows = list(x.rows, 'rows');\nconst parsed = rows.map((row,index) => {\n obj(row, ['cells']);\n const cells = list(row.cells, 'cells', 50), values = new Map(), reasons = [];\n cells.forEach(cell => {\n obj(cell, ['column','value']);\n const column = text(cell.column, 'column', 120), value = text(cell.value, 'cell value', 4000, true);\n if (!columns.includes(column)) return;\n if (values.has(column)) { if (!reasons.includes('ambiguous_mapped_column')) reasons.push('ambiguous_mapped_column'); }\n else values.set(column, value);\n });\n const externalId = values.get(columns[0]) || '', name = values.get(columns[1]) || '', address = (values.get(columns[2]) || '').toLowerCase();\n if (!externalId || externalId.length > 120) reasons.push('invalid_external_id');\n if (!name || name.length > 200) reasons.push('invalid_name');\n if (!email(address) || address.length > 320) reasons.push('invalid_email');\n return {row:index + 1, externalId, name, address, reasons};\n});\nconst counts = new Map();\nparsed.forEach(row => { if (row.externalId) counts.set(row.externalId, (counts.get(row.externalId) || 0) + 1); });\nconst drafts = [], quarantine = [];\nparsed.forEach(row => {\n if (counts.get(row.externalId) > 1) row.reasons.push('duplicate_external_id');\n if (row.reasons.length) quarantine.push({row:row.row, reasons:row.reasons});\n else drafts.push({externalId:row.externalId, name:row.name, email:row.address});\n});\nreturn {importId, drafts, quarantine};\n\n})({input:context.input.jobInput});\n",
"outputVar": "jobResult",
"timeout": 3000,
"memoryLimit": 64
}Notion review blocks · code
{
"label": "Notion review blocks",
"code": "const jobResult=context.jobResult;\nconst delivery=(function(context){\nreturn ((function(originalResult,metadata,destination){\nfunction stableResult(value,depth=0){\n if(depth>64)throw new Error('Result nesting exceeds 64');\n if(value===null||typeof value==='string'||typeof value==='boolean')return JSON.stringify(value);\n if(typeof value==='number'&&Number.isFinite(value))return JSON.stringify(value);\n if(Array.isArray(value)){\n if(Object.keys(value).length!==value.length||Array.from({length:value.length},(_,i)=>i).some(i=>!Object.hasOwn(value,i)))throw new Error('Result contains sparse data');\n return '['+value.map(item=>stableResult(item,depth+1)).join(',')+']';\n }\n if(value&&typeof value==='object')return '{'+Object.keys(value).sort().map(key=>JSON.stringify(key)+':'+stableResult(value[key],depth+1)).join(',')+'}';\n throw new Error('Result is not JSON data');\n}\nfunction utf8Length(text){\n let bytes=0;\n for(let i=0;i<text.length;i++){\n const code=text.charCodeAt(i);\n if(code<128)bytes++;else if(code<2048)bytes+=2;\n else if(code>=55296&&code<=56319&&i+1<text.length&&text.charCodeAt(i+1)>=56320&&text.charCodeAt(i+1)<=57343){bytes+=4;i++;}\n else bytes+=3;\n }\n return bytes;\n}\nfunction chunkText(text,maximum){\n const chunks=[];\n for(let start=0;start<text.length;){let end=Math.min(start+maximum,text.length);const last=text.charCodeAt(end-1),next=text.charCodeAt(end);if(end<text.length&&last>=55296&&last<=56319&&next>=56320&&next<=57343)end--;chunks.push(text.slice(start,end));start=end;}\n return chunks;\n}\nfunction deliveryState(rendererId,originalResult,metadata,destination,destinationKeys){\n const output={rendererId,status:'HELD',originalResult,drafts:[],holds:[],escapeReport:[]};\n const hold=(code,message)=>{output.holds.push({code,message});return {output,json:''};};\n const object=value=>value&&typeof value==='object'&&!Array.isArray(value);\n const exact=(value,keys)=>object(value)&&Object.keys(value).length===keys.length&&keys.every(key=>Object.hasOwn(value,key));\n const keys=['workflowId','canonicalIntentId','title','reviewUrl'],maxima=[128,200,200,1000];\n if(!exact(metadata,keys)||keys.some((key,i)=>typeof metadata[key]!=='string'||!metadata[key].length||metadata[key].length>maxima[i]||/[\\u0000-\\u001f\\u007f]/.test(metadata[key]))||!/^https?:\\/\\/[^\\s<>\"']+$/.test(metadata.reviewUrl))return hold('INVALID_METADATA','Metadata must provide bounded workflowId, canonicalIntentId, title and an HTTP(S) reviewUrl.');\n if(!exact(destination,destinationKeys)||destinationKeys.some(key=>typeof destination[key]!=='string'||!destination[key].length||destination[key].length>200||destination[key]!==destination[key].trim()||/[\\u0000-\\u001f\\u007f]/.test(destination[key])))return hold('INVALID_DESTINATION','Destination fields must be exactly: '+destinationKeys.join(', ')+'.');\n let json;\n try{if(!object(originalResult))throw new Error('Primary result must be a JSON object');json=stableResult(originalResult);}catch(error){return hold('INVALID_RESULT',error.message);}\n if(json.length>32768||utf8Length(json)>65536)return hold('RESULT_BOUND_EXCEEDED','Original result exceeds this renderer profile; full original result is retained.');\n return {output,json};\n}\nfunction escapeHtml(text){return text.replace(/&/g,'&').replace(/</g,'<').replace(/>/g,'>').replace(/\"/g,'"').replace(/'/g,''');}\nfunction escapeMarkdown(text){return text.replace(/&/g,'&').replace(/[\\\\`*{}\\[\\]()#+\\-.!_|>~<]/g,'\\\\$&');}\nfunction markdownReviewText(metadata,json){\n const runs=json.match(/`+/g)||[],fence='`'.repeat(Math.max(3,...runs.map(run=>run.length+1)));\n return '# '+escapeMarkdown(metadata.title)+'\\n\\nWorkflow: '+escapeMarkdown(metadata.workflowId)+'\\nCanonical job: '+escapeMarkdown(metadata.canonicalIntentId)+'\\nReview: <'+metadata.reviewUrl.replace(/&/g,'&')+'>\\n\\n'+fence+'json\\n'+json+'\\n'+fence+'\\n';\n}\nfunction plainReviewText(metadata,json){return metadata.title+'\\nWorkflow: '+metadata.workflowId+'\\nCanonical job: '+metadata.canonicalIntentId+'\\nReview: '+metadata.reviewUrl+'\\n\\n'+json;}\nfunction finishDraft(state,draft,texts=[],textMaximum=32768,byteMaximum=131072){\n if(texts.some(text=>text.length>textMaximum)||utf8Length(JSON.stringify(draft))>byteMaximum){state.output.holds.push({code:'TARGET_BOUND_EXCEEDED',message:'Draft exceeds the target or Vora profile bound; no draft is emitted and the full original result is retained.'});return state.output;}\n state.output.status='PREPARED';state.output.drafts=[draft];return state.output;\n}\nreturn (function notionBlocksReview(originalResult,metadata,destination){\n const state=deliveryState('notion-blocks-review',originalResult,metadata,destination,['blockId']);if(state.output.holds.length)return state.output;\n const texts=[metadata.title,'Workflow: '+metadata.workflowId+'\\nCanonical job: '+metadata.canonicalIntentId,'Review: '+metadata.reviewUrl,...chunkText(state.json,2000)];\n const children=texts.map(content=>({object:'block',type:'paragraph',paragraph:{rich_text:[{type:'text',text:{content}}]}}));\n if(children.length>100){state.output.holds.push({code:'TARGET_BOUND_EXCEEDED',message:'Notion draft exceeds the documented block-array limit; no draft is emitted.'});return state.output;}\n return finishDraft(state,{blockId:destination.blockId,body:{children}},texts,2000);\n})(originalResult,metadata,destination);\n}))(context.input.jobResult,context.input.deliveryMetadata.metadata,context.input.deliveryMetadata.destination);\n\n})({input:{jobResult,deliveryMetadata:context.input.deliveryMetadata}});\nreturn {jobResult,delivery};\n",
"outputVar": "result",
"timeout": 3000,
"memoryLimit": 64
}Input and output contracts
Input
{
"type": "object",
"properties": {
"jobInput": {
"additionalProperties": false,
"properties": {
"importId": {
"maxLength": 120,
"type": "string"
},
"mapping": {
"additionalProperties": false,
"properties": {
"email": {
"maxLength": 120,
"type": "string"
},
"externalId": {
"maxLength": 120,
"type": "string"
},
"name": {
"maxLength": 120,
"type": "string"
}
},
"required": [
"externalId",
"name",
"email"
],
"type": "object"
},
"rows": {
"items": {
"additionalProperties": false,
"properties": {
"cells": {
"items": {
"additionalProperties": false,
"properties": {
"column": {
"maxLength": 120,
"type": "string"
},
"value": {
"maxLength": 4000,
"type": "string"
}
},
"required": [
"column",
"value"
],
"type": "object"
},
"maxItems": 50,
"type": "array"
}
},
"required": [
"cells"
],
"type": "object"
},
"maxItems": 500,
"type": "array"
}
},
"required": [
"importId",
"mapping",
"rows"
],
"type": "object"
},
"deliveryMetadata": {
"type": "object",
"properties": {
"metadata": {
"type": "object",
"properties": {
"workflowId": {
"type": "string",
"maxLength": 128
},
"canonicalIntentId": {
"type": "string",
"maxLength": 200
},
"title": {
"type": "string",
"maxLength": 200
},
"reviewUrl": {
"type": "string",
"maxLength": 1000
}
},
"required": [
"workflowId",
"canonicalIntentId",
"title",
"reviewUrl"
],
"additionalProperties": false
},
"destination": {
"type": "object",
"properties": {
"blockId": {
"type": "string",
"maxLength": 200
}
},
"required": [
"blockId"
],
"additionalProperties": false
}
},
"required": [
"metadata",
"destination"
],
"additionalProperties": false
}
},
"required": [
"jobInput",
"deliveryMetadata"
],
"additionalProperties": false
}Output
{
"type": "object",
"properties": {
"jobResult": {
"additionalProperties": false,
"properties": {
"drafts": {
"items": {
"additionalProperties": false,
"properties": {
"email": {
"maxLength": 320,
"type": "string"
},
"externalId": {
"maxLength": 120,
"type": "string"
},
"name": {
"maxLength": 200,
"type": "string"
}
},
"required": [
"externalId",
"name",
"email"
],
"type": "object"
},
"maxItems": 500,
"type": "array"
},
"importId": {
"maxLength": 120,
"type": "string"
},
"quarantine": {
"items": {
"additionalProperties": false,
"properties": {
"reasons": {
"items": {
"maxLength": 200,
"type": "string"
},
"maxItems": 6,
"type": "array"
},
"row": {
"maximum": 500,
"minimum": 1,
"type": "integer"
}
},
"required": [
"row",
"reasons"
],
"type": "object"
},
"maxItems": 500,
"type": "array"
}
},
"required": [
"importId",
"drafts",
"quarantine"
],
"type": "object"
},
"delivery": {
"type": "object",
"properties": {
"rendererId": {
"type": "string",
"maxLength": 128,
"enum": [
"notion-blocks-review"
]
},
"status": {
"type": "string",
"maxLength": 16,
"enum": [
"PREPARED",
"HELD"
]
},
"originalResult": {
"additionalProperties": false,
"properties": {
"drafts": {
"items": {
"additionalProperties": false,
"properties": {
"email": {
"maxLength": 320,
"type": "string"
},
"externalId": {
"maxLength": 120,
"type": "string"
},
"name": {
"maxLength": 200,
"type": "string"
}
},
"required": [
"externalId",
"name",
"email"
],
"type": "object"
},
"maxItems": 500,
"type": "array"
},
"importId": {
"maxLength": 120,
"type": "string"
},
"quarantine": {
"items": {
"additionalProperties": false,
"properties": {
"reasons": {
"items": {
"maxLength": 200,
"type": "string"
},
"maxItems": 6,
"type": "array"
},
"row": {
"maximum": 500,
"minimum": 1,
"type": "integer"
}
},
"required": [
"row",
"reasons"
],
"type": "object"
},
"maxItems": 500,
"type": "array"
}
},
"required": [
"importId",
"drafts",
"quarantine"
],
"type": "object"
},
"drafts": {
"type": "array",
"items": {
"type": "object",
"properties": {
"blockId": {
"type": "string",
"maxLength": 200
},
"body": {
"type": "object",
"properties": {
"children": {
"type": "array",
"items": {
"type": "object",
"properties": {
"object": {
"type": "string",
"maxLength": 16,
"enum": [
"block"
]
},
"type": {
"type": "string",
"maxLength": 16,
"enum": [
"paragraph"
]
},
"paragraph": {
"type": "object",
"properties": {
"rich_text": {
"type": "array",
"items": {
"type": "object",
"properties": {
"type": {
"type": "string",
"maxLength": 16,
"enum": [
"text"
]
},
"text": {
"type": "object",
"properties": {
"content": {
"type": "string",
"maxLength": 2000
}
},
"required": [
"content"
],
"additionalProperties": false
}
},
"required": [
"type",
"text"
],
"additionalProperties": false
},
"maxItems": 1,
"minItems": 1
}
},
"required": [
"rich_text"
],
"additionalProperties": false
}
},
"required": [
"object",
"type",
"paragraph"
],
"additionalProperties": false
},
"maxItems": 100,
"minItems": 4
}
},
"required": [
"children"
],
"additionalProperties": false
}
},
"required": [
"blockId",
"body"
],
"additionalProperties": false
},
"maxItems": 1,
"minItems": 0
},
"holds": {
"type": "array",
"items": {
"type": "object",
"properties": {
"code": {
"type": "string",
"maxLength": 128
},
"message": {
"type": "string",
"maxLength": 2000
}
},
"required": [
"code",
"message"
],
"additionalProperties": false
},
"maxItems": 10,
"minItems": 0
},
"escapeReport": {
"type": "array",
"items": {
"type": "object",
"properties": {
"field": {
"type": "string",
"maxLength": 256
},
"method": {
"type": "string",
"maxLength": 80
},
"originalValue": {
"type": "string",
"maxLength": 32768
},
"escapedValue": {
"type": "string",
"maxLength": 32768
}
},
"required": [
"field",
"method",
"originalValue",
"escapedValue"
],
"additionalProperties": false
},
"maxItems": 1000,
"minItems": 0
}
},
"required": [
"rendererId",
"status",
"originalResult",
"drafts",
"holds",
"escapeReport"
],
"additionalProperties": false
}
},
"required": [
"jobResult",
"delivery"
],
"additionalProperties": false
}Related implementations
Compare implementations for this job · Primary business workflow
Caller supplies blockId; children are literal paragraph blocks using rich_text text.content, without Markdown parsing. First three paragraphs contain metadata; subsequent paragraphs contain the complete stable JSON split at 2000 UTF-16 units without dividing a surrogate pair. Joining all result paragraphs in order recovers the entire stable JSON. Original result, including original reasons/holds, is preserved without mutation. Missing/extra destination fields or invalid metadata hold the draft. No truncation: overflow returns HELD with an empty drafts array and full original result.
Supplied input: vora-agency-contact-import-quarantine · 1. Draft/result: notion-blocks-review · Notion REST append-block-children / paragraph review profile v1.
Mapping and loss rules
- Caller supplies blockId; children are literal paragraph blocks using rich_text text.content, without Markdown parsing.
- First three paragraphs contain metadata; subsequent paragraphs contain the complete stable JSON split at 2000 UTF-16 units without dividing a surrogate pair.
- Joining all result paragraphs in order recovers the entire stable JSON.
- Original result, including original reasons/holds, is preserved without mutation.
- Missing/extra destination fields or invalid metadata hold the draft.
- No truncation: overflow returns HELD with an empty drafts array and full original result.
This binding consumes supplied data. It does not establish an authenticated connector or a provider write.
Example input and result
These examples use synthetic data.
Input
{
"jobInput": {
"importId": "import-01",
"mapping": {
"externalId": "Contact ID",
"name": "Full Name",
"email": "Work Email"
},
"rows": [
{
"cells": [
{
"column": "Contact ID",
"value": " 001 "
},
{
"column": "Full Name",
"value": " Ada Agency "
},
{
"column": "Work Email",
"value": " ADA@Example.test "
},
{
"column": "Unneeded",
"value": "drop"
}
]
}
]
},
"deliveryMetadata": {
"metadata": {
"workflowId": "agency-contact-import-quarantine",
"canonicalIntentId": "migration.validate-contact-row-mapping",
"title": "Normalize contact rows and quarantine bad mappings",
"reviewUrl": "https://example.test/workflows/contact-import-quarantine/"
},
"destination": {
"blockId": "00000000-0000-4000-8000-000000000001"
}
}
}Expected result
{
"jobResult": {
"importId": "import-01",
"drafts": [
{
"externalId": "001",
"name": "Ada Agency",
"email": "ada@example.test"
}
],
"quarantine": []
},
"delivery": {
"rendererId": "notion-blocks-review",
"status": "PREPARED",
"originalResult": {
"importId": "import-01",
"drafts": [
{
"externalId": "001",
"name": "Ada Agency",
"email": "ada@example.test"
}
],
"quarantine": []
},
"drafts": [
{
"blockId": "00000000-0000-4000-8000-000000000001",
"body": {
"children": [
{
"object": "block",
"type": "paragraph",
"paragraph": {
"rich_text": [
{
"type": "text",
"text": {
"content": "Normalize contact rows and quarantine bad mappings"
}
}
]
}
},
{
"object": "block",
"type": "paragraph",
"paragraph": {
"rich_text": [
{
"type": "text",
"text": {
"content": "Workflow: agency-contact-import-quarantine\nCanonical job: migration.validate-contact-row-mapping"
}
}
]
}
},
{
"object": "block",
"type": "paragraph",
"paragraph": {
"rich_text": [
{
"type": "text",
"text": {
"content": "Review: https://example.test/workflows/contact-import-quarantine/"
}
}
]
}
},
{
"object": "block",
"type": "paragraph",
"paragraph": {
"rich_text": [
{
"type": "text",
"text": {
"content": "{\"drafts\":[{\"email\":\"ada@example.test\",\"externalId\":\"001\",\"name\":\"Ada Agency\"}],\"importId\":\"import-01\",\"quarantine\":[]}"
}
}
]
}
}
]
}
}
],
"holds": [],
"escapeReport": []
}
}Success means: Map operator-supplied column keys to normalized contact drafts and return row-indexed quarantine reasons. No import or CRM write occurs.
When something goes wrong
- Review original business holds and target holds separately. Correct the relevant supplied input and rerun without discarding the original job result.
Limits and costs
- This prepares a target-specific review draft from the original agency decision. The complete original job result and business holds remain visible. A held target produces no draft. No provider request, send, import, issue creation or publication occurs.
- No paid model calls or metered third-party operations are declared in this pure graph. Vora plan availability, compute and quotas still apply; pricing has not been verified by this batch.