Class McpTask

java.lang.Object

com.soklet.McpTask

@ThreadSafe
public final class McpTask
extends Object

Immutable authoritative snapshot of one MCP task.

The configured McpTaskManager returns this value after atomically authorizing the current request. The origin is application-persisted framework data and is never rendered on the wire. Task status determines the one permitted status-specific payload: outstanding input requests for McpTaskStatus.INPUT_REQUIRED, a complete result for McpTaskStatus.COMPLETED, or a JSON-RPC failure for McpTaskStatus.FAILED. A tool result whose isError value is true is still a completed task.

This value does not contain task ownership or an authorization decision. A manager must independently bind the task to the admitted principal, tenant, endpoint, and other application authorization context, and must not return a snapshot to an unauthorized request.

Construction validates the status-specific payload shape, not whether that payload can be delivered under the origin tool's contract. Soklet checks outstanding input declarations and completed output during delivery, using the current server's access policy and result sanitizer. A failed delivery does not change this authoritative snapshot or synthesize a McpTaskStatus.FAILED state.

Author:

Mark Allen

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	McpTask.Builder	Mutable builder for an immutable task snapshot.

Method Summary

Modifier and Type	Method	Description
boolean	equals(@Nullable Object other)
@NonNull Optional<@NonNull McpCompleteResult>	getCompletedResult()	Returns the operation result of a completed task.
@NonNull Instant	getCreatedAt()
@NonNull Optional<@NonNull McpJsonRpcError>	getFailure()	Returns the JSON-RPC error that failed task execution.
@NonNull Map<@NonNull String, @NonNull McpInputRequest>	getInputRequests()	Returns outstanding task input requests in insertion order.
@NonNull Instant	getLastUpdatedAt()
@NonNull McpJsonObject	getMetadata()
@NonNull Optional<@NonNull Duration>	getPollInterval()
@NonNull String	getTaskId()
@NonNull McpTaskOrigin	getTaskOrigin()	Returns the non-wire origin persisted with this task.
@NonNull McpTaskStatus	getTaskStatus()
@NonNull Optional<@NonNull String>	getTaskStatusMessage()
@NonNull Optional<@NonNull Duration>	getTimeToLive()	Returns the duration after creation for which the task may be retained.
int	hashCode()
@NonNull String	toString()
static @NonNull McpTask.Builder	withTaskId(@NonNull String taskId, @NonNull McpTaskOrigin taskOrigin, @NonNull McpTaskStatus taskStatus, @NonNull Instant createdAt, @NonNull Instant lastUpdatedAt)	Vends a builder primed with every required task property.

Methods inherited from class Object

getClass, notify, notifyAll, wait, wait, wait

Method Details

withTaskId

public static @NonNull McpTask.Builder withTaskId(@NonNull String taskId,
 @NonNull McpTaskOrigin taskOrigin,
 @NonNull McpTaskStatus taskStatus,
 @NonNull Instant createdAt,
 @NonNull Instant lastUpdatedAt)

Vends a builder primed with every required task property.

Parameters:

taskId - nonblank task identifier without carriage-return or newline characters

taskOrigin - persisted framework origin

taskStatus - current task status

createdAt - task creation time

lastUpdatedAt - most recent state-update time, not before creation

Returns:

task builder

Throws:

NullPointerException - if an argument is null

IllegalArgumentException - if the task ID or timestamps are invalid

getTaskId

public @NonNull String getTaskId()

Returns:

nonblank durable task identifier

getTaskOrigin

public @NonNull McpTaskOrigin getTaskOrigin()

Returns the non-wire origin persisted with this task.

Returns:

framework-derived task origin

getTaskStatus

public @NonNull McpTaskStatus getTaskStatus()

Returns:

current task status

getTaskStatusMessage

public @NonNull Optional<@NonNull String> getTaskStatusMessage()

Returns:

client-visible status message, if supplied

getCreatedAt

public @NonNull Instant getCreatedAt()

Returns:

task creation time

getLastUpdatedAt

public @NonNull Instant getLastUpdatedAt()

Returns:

most recent task state-update time

getTimeToLive

public @NonNull Optional<@NonNull Duration> getTimeToLive()

Returns the duration after creation for which the task may be retained.

Returns:

positive whole-millisecond duration, or empty for unlimited

getPollInterval

public @NonNull Optional<@NonNull Duration> getPollInterval()

Returns:

positive whole-millisecond suggested polling interval, if any

getInputRequests

public @NonNull Map<@NonNull String, @NonNull McpInputRequest> getInputRequests()

Returns outstanding task input requests in insertion order.

Returns:

immutable input-request map; nonempty only for McpTaskStatus.INPUT_REQUIRED

getCompletedResult

public @NonNull Optional<@NonNull McpCompleteResult> getCompletedResult()

Returns the operation result of a completed task.

Returns:

complete result only for McpTaskStatus.COMPLETED

getFailure

public @NonNull Optional<@NonNull McpJsonRpcError> getFailure()

Returns the JSON-RPC error that failed task execution.

Returns:

failure only for McpTaskStatus.FAILED

getMetadata

public @NonNull McpJsonObject getMetadata()

Returns:

immutable task-result protocol extension metadata

equals

public boolean equals(@Nullable Object other)

Overrides:

equals in class Object

Returns:

whether every persisted task property is structurally equal

hashCode

public int hashCode()

Overrides:

hashCode in class Object

Returns:

structural persisted-task hash code

toString

public @NonNull String toString()

Overrides:

toString in class Object

Returns:

a diagnostic rendering that redacts task and application data