Message batch contiguous-prefix plan
Inspect up to 256 supplied message envelopes against stream checkpoints, explicit duplicate rules and sequence-slot identity. Propose a contiguous ordered prefix per stream, stopping at gaps and withholding every plan on structural conflicts. No messages are delivered or consumed.
workflow-assurance · Operation ID: message-batch-plan
Choose this operation when
- Order an agent message batch without skipping missing sequence numbers
- Deduplicate identical message envelopes under an explicit policy
Outside this profile
- Live negotiation, message delivery, queue consumption, remote pagination, artifact fetching or migration execution
- Authentication, signed provenance, authorization, schema compatibility proofs, or exactly-once guarantees
- Inferring absent versions, server state, missing history, semantic equivalence, or market uniqueness
Exact release references
Static JSON contract · Markdown reference · Fixed example response
Complete input schema
{
"$schema": "https://json-schema.org/draft/2020-12/schema",
"type": "object",
"properties": {
"streams": {
"minItems": 1,
"maxItems": 32,
"type": "array",
"items": {
"type": "object",
"properties": {
"id": {
"type": "string",
"minLength": 1,
"maxLength": 100
},
"nextSequence": {
"type": "integer",
"minimum": 0,
"maximum": 9007199254740991
}
},
"required": [
"id",
"nextSequence"
],
"additionalProperties": false
}
},
"messages": {
"maxItems": 256,
"type": "array",
"items": {
"type": "object",
"properties": {
"id": {
"type": "string",
"minLength": 1,
"maxLength": 100
},
"stream": {
"type": "string",
"minLength": 1,
"maxLength": 100
},
"sequence": {
"type": "integer",
"minimum": 0,
"maximum": 9007199254740990
},
"contentSha256": {
"type": "string",
"pattern": "^[a-f0-9]{64}$"
}
},
"required": [
"id",
"stream",
"sequence",
"contentSha256"
],
"additionalProperties": false
}
},
"duplicatePolicy": {
"type": "string",
"enum": [
"keep-first-identical",
"reject"
]
}
},
"required": [
"streams",
"messages",
"duplicatePolicy"
],
"additionalProperties": false
}
Complete output-envelope schema
{
"type": "object",
"required": [
"operation",
"version",
"result",
"provenance"
],
"properties": {
"operation": {
"const": "message-batch-plan",
"type": "string"
},
"version": {
"const": "0.29.0",
"type": "string"
},
"result": {
"$schema": "https://json-schema.org/draft/2020-12/schema",
"type": "object",
"properties": {
"profile": {
"type": "string",
"const": "message-batch-contiguous-prefix-v1"
},
"consistent": {
"type": "boolean"
},
"allRemainingMessagesSelected": {
"type": "boolean"
},
"plans": {
"maxItems": 32,
"type": "array",
"items": {
"type": "object",
"properties": {
"stream": {
"type": "string",
"minLength": 1,
"maxLength": 100
},
"messageIds": {
"maxItems": 256,
"type": "array",
"items": {
"type": "string",
"minLength": 1,
"maxLength": 100
}
},
"inputIndices": {
"maxItems": 256,
"type": "array",
"items": {
"type": "integer",
"minimum": 0,
"maximum": 9007199254740991
}
},
"nextSequence": {
"type": "integer",
"minimum": 0,
"maximum": 9007199254740991
},
"gapAt": {
"anyOf": [
{
"type": "integer",
"minimum": 0,
"maximum": 9007199254740991
},
{
"type": "null"
}
]
}
},
"required": [
"stream",
"messageIds",
"inputIndices",
"nextSequence",
"gapAt"
],
"additionalProperties": false
}
},
"dispositions": {
"maxItems": 256,
"type": "array",
"items": {
"type": "object",
"properties": {
"inputIndex": {
"type": "integer",
"minimum": 0,
"maximum": 9007199254740991
},
"messageId": {
"type": "string",
"minLength": 1,
"maxLength": 100
},
"disposition": {
"type": "string",
"enum": [
"selected",
"exact_duplicate",
"before_checkpoint",
"blocked_gap",
"conflict",
"unknown_stream",
"held_invalid_batch"
]
}
},
"required": [
"inputIndex",
"messageId",
"disposition"
],
"additionalProperties": false
}
},
"orderingPolicy": {
"type": "string",
"const": "input-stream-order-then-ascending-sequence"
},
"findings": {
"maxItems": 200,
"type": "array",
"items": {
"type": "object",
"properties": {
"code": {
"type": "string"
},
"severity": {
"type": "string",
"enum": [
"error",
"warning"
]
},
"path": {
"type": "string"
},
"message": {
"type": "string"
},
"relatedIds": {
"maxItems": 8,
"type": "array",
"items": {
"type": "string",
"minLength": 1,
"maxLength": 100
}
}
},
"required": [
"code",
"severity",
"path",
"message",
"relatedIds"
],
"additionalProperties": false
}
},
"findingCount": {
"type": "integer",
"minimum": 0,
"maximum": 9007199254740991
},
"errorCount": {
"type": "integer",
"minimum": 0,
"maximum": 9007199254740991
},
"truncated": {
"type": "boolean"
},
"advisoryOnly": {
"type": "boolean",
"const": true
},
"execution": {
"type": "boolean",
"const": false
},
"authorizationGranted": {
"type": "boolean",
"const": false
}
},
"required": [
"profile",
"consistent",
"allRemainingMessagesSelected",
"plans",
"dispositions",
"orderingPolicy",
"findings",
"findingCount",
"errorCount",
"truncated",
"advisoryOnly",
"execution",
"authorizationGranted"
],
"additionalProperties": false
},
"provenance": {
"type": "object",
"required": [
"inputSha256",
"outputSha256",
"deterministic",
"externalRequests"
],
"properties": {
"inputSha256": {
"type": "string",
"pattern": "^[a-f0-9]{64}$"
},
"outputSha256": {
"type": "string",
"pattern": "^[a-f0-9]{64}$"
},
"deterministic": {
"const": true
},
"externalRequests": {
"const": 0
}
}
}
},
"additionalProperties": false
}
Fixed example
One accepted fixed example, not a custom-input trial. No operation runs when this static page is requested.
Example input
{
"streams": [
{
"id": "jobs",
"nextSequence": 4
}
],
"duplicatePolicy": "keep-first-identical",
"messages": [
{
"id": "m5",
"stream": "jobs",
"sequence": 5,
"contentSha256": "bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb"
},
{
"id": "m4",
"stream": "jobs",
"sequence": 4,
"contentSha256": "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
}
]
}
Example response
{
"operation": "message-batch-plan",
"version": "0.29.0",
"result": {
"profile": "message-batch-contiguous-prefix-v1",
"consistent": true,
"allRemainingMessagesSelected": true,
"plans": [
{
"stream": "jobs",
"messageIds": [
"m4",
"m5"
],
"inputIndices": [
1,
0
],
"nextSequence": 6,
"gapAt": null
}
],
"dispositions": [
{
"inputIndex": 0,
"messageId": "m5",
"disposition": "selected"
},
{
"inputIndex": 1,
"messageId": "m4",
"disposition": "selected"
}
],
"orderingPolicy": "input-stream-order-then-ascending-sequence",
"findings": [],
"findingCount": 0,
"errorCount": 0,
"truncated": false,
"advisoryOnly": true,
"execution": false,
"authorizationGranted": false
},
"provenance": {
"inputSha256": "476b2632476a1d18051d6e887e497daa163a23f2f23b75c700f3244df1b9ce5e",
"outputSha256": "d148b30c422eb8c1f665e97e9aa41814ac5be288467d671637bfa33cea57eedf",
"deterministic": true,
"externalRequests": 0
}
}
Bounds and precision
JavaScript IEEE-754 numbers; use strings for large integer IDs/exact decimals where the schema accepts strings. No lossless numeric parsing.
{
"global": {
"requestBytes": 131072,
"responseBytes": 524288,
"jsonDepth": 32,
"jsonNodes": 20000,
"requestsPerMinute": 60,
"paidAttemptsPerMinute": 20,
"idempotencyHours": 24
},
"operation": {
"inputBytes": 100000,
"outputBytes": 400000,
"jsonNodes": 12000,
"depth": 20,
"findings": 200,
"streams": 32,
"messages": 256
}
}
Complete schemas, descriptions and cross-field validation may impose additional limits.
Proposed price and protocol definitions
{
"unit": "one successful operation call",
"proposedNominalUsd": "0.005",
"sixDecimalTokenBaseUnits": "5000",
"subscription": false,
"includesPayerWalletOrNetworkFees": false,
"liveQuoteVerified": false,
"condition": "Actual SDK challenge is authoritative only within the caller's explicit authorization; configured six-decimal token peg is an operator assertion, not a conversion guarantee."
}
Protocol definitions: x402, mpp. MPP uses Tempo charge. Paid MCP execution is unsupported. All runtime readiness is not evaluated in this build.
API path templates, not endpoints on this documentation host
{
"x402": "/v1/x402/message-batch-plan",
"mpp": "/v1/mpp/message-batch-plan"
}
Required headers
{
"Content-Type": "application/json",
"Idempotency-Key": "random 16–128 character operation identifier"
}
Actual SDK challenge amount, asset, network, recipient and wallet costs must pass independent authorization. Preserve identical key, body, protocol and credential on retries; on PAYMENT_UNCERTAIN stop and reconcile.
Execution profile and provider conditions
{
"deterministic": true,
"externalRequests": 0,
"maxExternalRequests": 0,
"resultSnapshotPersisted": false,
"fixedExampleIsIllustrativeSnapshot": false,
"requiresPayment": true,
"supportsMcpExecution": false
}
Deterministic supplied-input operation with no external requests or stored request/result bodies. Payment infrastructure retains payment metadata and hashes.
Failure handling
- HTTP 400: Malformed JSON, missing/invalid idempotency key, or payment identifier mismatch Correct the request before payment
- HTTP 402: Payment challenge or rejected payment Use official protocol SDK; inspect payment outcome before another payment
- HTTP 409: Idempotency conflict, duplicate proof, or PAYMENT_UNCERTAIN Keep original key, body, and proof; reconcile uncertainty with operator; never blindly repay
- HTTP 413: Input or generated output too large Reduce input; no payment attempted for validation failure
- HTTP 415: Unsupported media type or compression Send uncompressed application/json
- HTTP 422: Schema or service-specific semantic validation failure Correct input using returned error code; no payment attempted
- HTTP 429: Request/payment-attempt rate exceeded Wait for rate limit window; preserve existing payment identity
- HTTP 503: Payment configuration/provider/state unavailable, or live DNS preparation failed before settlement Check readiness; DNS preparation failures may retry the identical key/body/credential only; uncertainty requires reconciliation
Declared requirements
Before any paid call, refresh the live operation contract and POST the complete bounded budgeted plan to the separate API's /preflight. Unknown requirements block selection; compatible preflight is not permission to spend.