Migration Operations
Normalize contact rows and quarantine bad mappings — Slack plain text review draft
Map operator-supplied column keys to normalized contact drafts and return row-indexed quarantine reasons. No import or CRM write occurs. Prepare a Slack plain text review draft.
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: Slack plain text review draft
Slack plain text review draft
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
}Slack plain text review draft · code
{
"label": "Slack plain text review draft",
"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}\nreturn (function slackBlockKitReview(originalResult,metadata,destination){\n const state=deliveryState('slack-block-kit-review',originalResult,metadata,destination,['channelId']);\n if(state.output.holds.length)return state.output;\n const section=text=>({type:'section',text:{type:'plain_text',text}});\n const blocks=[section(metadata.title),section('Workflow: '+metadata.workflowId+'\\nCanonical job: '+metadata.canonicalIntentId),section('Review: '+metadata.reviewUrl),...chunkText(state.json,3000).map(section)];\n const draft={channel:destination.channelId,blocks};\n if(blocks.length>50||blocks.some(block=>!block.text.text.length||block.text.text.length>3000)||utf8Length(JSON.stringify(draft))>131072){state.output.holds.push({code:'TARGET_BOUND_EXCEEDED',message:'Slack draft exceeds the block/text or Vora payload profile bound; no draft is emitted.'});return state.output;}\n state.output.status='PREPARED';state.output.drafts=[draft];return state.output;\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": {
"channelId": {
"type": "string",
"maxLength": 200
}
},
"required": [
"channelId"
],
"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": [
"slack-block-kit-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": {
"channel": {
"type": "string",
"maxLength": 200
},
"blocks": {
"type": "array",
"items": {
"type": "object",
"properties": {
"type": {
"type": "string",
"maxLength": 16,
"enum": [
"section"
]
},
"text": {
"type": "object",
"properties": {
"type": {
"type": "string",
"maxLength": 16,
"enum": [
"plain_text"
]
},
"text": {
"type": "string",
"maxLength": 3000,
"minLength": 1
}
},
"required": [
"type",
"text"
],
"additionalProperties": false
}
},
"required": [
"type",
"text"
],
"additionalProperties": false
},
"maxItems": 50,
"minItems": 4
}
},
"required": [
"channel",
"blocks"
],
"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-supplied channelId becomes channel; metadata and complete stable result JSON use plain_text sections. Result text is split at at most 3000 UTF-16 units without splitting a surrogate pair; joining result sections recovers complete JSON. No top-level text is supplied; the documented supported-block fallback remains available. 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: slack-block-kit-review · Slack Web API / Block Kit, reviewed 2026-10-08.
Mapping and loss rules
- Caller-supplied channelId becomes channel; metadata and complete stable result JSON use plain_text sections.
- Result text is split at at most 3000 UTF-16 units without splitting a surrogate pair; joining result sections recovers complete JSON.
- No top-level text is supplied; the documented supported-block fallback remains available.
- 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": {
"channelId": "C-review"
}
}
}Expected result
{
"jobResult": {
"importId": "import-01",
"drafts": [
{
"externalId": "001",
"name": "Ada Agency",
"email": "ada@example.test"
}
],
"quarantine": []
},
"delivery": {
"rendererId": "slack-block-kit-review",
"status": "PREPARED",
"originalResult": {
"importId": "import-01",
"drafts": [
{
"externalId": "001",
"name": "Ada Agency",
"email": "ada@example.test"
}
],
"quarantine": []
},
"drafts": [
{
"channel": "C-review",
"blocks": [
{
"type": "section",
"text": {
"type": "plain_text",
"text": "Normalize contact rows and quarantine bad mappings"
}
},
{
"type": "section",
"text": {
"type": "plain_text",
"text": "Workflow: agency-contact-import-quarantine\nCanonical job: migration.validate-contact-row-mapping"
}
},
{
"type": "section",
"text": {
"type": "plain_text",
"text": "Review: https://example.test/workflows/contact-import-quarantine/"
}
},
{
"type": "section",
"text": {
"type": "plain_text",
"text": "{\"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.