McpTaskStoreBase - EasyAF SI

Definition

Assembly: CloudNimble.McpEssentials.Core.dll Namespace: CloudNimble.McpEssentials.Core.Tasks Inheritance: System.Object

Syntax

CloudNimble.McpEssentials.Core.Tasks.McpTaskStoreBase

Summary

Base type for authenticated MCP task stores. Wires the current-user callback, fail-closed identity, McpTaskStoreBase.InputResponseReceived, flush pulses, and the mapping from IMcpTaskStore / IMcpTaskStorePlus into per-user core methods.

Remarks

Subclass and implement the Core methods plus CancellationToken) to persist snapshots. Create inserts then pulses a throttled flush; get pulses then reads. Set McpTaskStoreBase.AutoSweep to false and call CancellationToken) from your own job to own the schedule. Override DateTimeOffset) to change keep rules. Do not wrap the SDK InMemoryMcpTaskStore; each provider owns its storage.

Constructors

.ctor Inherited

Inherited from object

Syntax

public Object()

Properties

AutoSweep Virtual

Gets or sets whether the store pulses a throttled flush after create and on get.

Syntax

public virtual bool AutoSweep { get; set; }

Property Value

Type: bool The default is true.

Remarks

Set to false and call CancellationToken) from your own job when you want to own the schedule. The public flush handle always runs a full pass.

DefaultPollIntervalMs Virtual

Gets or sets the default poll interval in milliseconds for new tasks.

Syntax

public virtual long DefaultPollIntervalMs { get; set; }

Property Value

Type: long The default is 1000 milliseconds.

DefaultTimeToLive Virtual

Gets or sets the default time-to-live for new tasks, or null for unlimited.

Syntax

public virtual System.Nullable<System.TimeSpan> DefaultTimeToLive { get; set; }

Property Value

Type: System.Nullable<System.TimeSpan>

Remarks

When set to a positive value, the work window ends at CreatedAt + TimeToLive and the row is discarded at CreatedAt + 2×TimeToLive (stamped as StoredMcpTask.DiscardAfter), or sooner when a terminal GetTaskAsync serves it. A null or non-positive value keeps tasks until a terminal get or until the store discards them.

ServeAndDrop Virtual

Gets or sets whether an owner get of a terminal snapshot serves it and then drops the row.

Syntax

public virtual bool ServeAndDrop { get; set; }

Property Value

Type: bool The default is true.

SweepInterval Virtual

Gets or sets the minimum interval between automatic flush pulses.

Syntax

public virtual System.TimeSpan SweepInterval { get; set; }

Property Value

Type: System.TimeSpan The default is 30 seconds. Zero skips the throttle.

Methods

CreateTaskAsync Virtual

Syntax

public virtual System.Threading.Tasks.Task<ModelContextProtocol.Extensions.Tasks.McpTaskInfo> CreateTaskAsync(System.Threading.CancellationToken cancellationToken = null)

Parameters

Name	Type	Description
`cancellationToken`	`System.Threading.CancellationToken`	-

Returns

Type: System.Threading.Tasks.Task<ModelContextProtocol.Extensions.Tasks.McpTaskInfo>

CreateTaskAsync Virtual

Syntax

public virtual System.Threading.Tasks.Task<ModelContextProtocol.Extensions.Tasks.McpTaskInfo> CreateTaskAsync(System.Security.Claims.ClaimsPrincipal user, System.Threading.CancellationToken cancellationToken = null)

Parameters

Name	Type	Description
`user`	`System.Security.Claims.ClaimsPrincipal`	-
`cancellationToken`	`System.Threading.CancellationToken`	-

Returns

Type: System.Threading.Tasks.Task<ModelContextProtocol.Extensions.Tasks.McpTaskInfo>

Equals Inherited Virtual

Inherited from object

Syntax

public virtual bool Equals(object obj)

Parameters

Name	Type	Description
`obj`	`object?`	-

Returns

Type: bool

Equals Inherited

Inherited from object

Syntax

public static bool Equals(object objA, object objB)

Parameters

Name	Type	Description
`objA`	`object?`	-
`objB`	`object?`	-

Returns

Type: bool

GetHashCode Inherited Virtual

Inherited from object

Syntax

public virtual int GetHashCode()

Returns

Type: int

GetTaskAsync Virtual

Syntax

public virtual System.Threading.Tasks.Task<ModelContextProtocol.Extensions.Tasks.McpTaskInfo> GetTaskAsync(string taskId, System.Threading.CancellationToken cancellationToken = null)

Parameters

Name	Type	Description
`taskId`	`string`	-
`cancellationToken`	`System.Threading.CancellationToken`	-

Returns

Type: System.Threading.Tasks.Task<ModelContextProtocol.Extensions.Tasks.McpTaskInfo?>

GetTaskAsync Virtual

Syntax

public virtual System.Threading.Tasks.Task<ModelContextProtocol.Extensions.Tasks.McpTaskInfo> GetTaskAsync(string taskId, System.Security.Claims.ClaimsPrincipal user, System.Threading.CancellationToken cancellationToken = null)

Parameters

Name	Type	Description
`taskId`	`string`	-
`user`	`System.Security.Claims.ClaimsPrincipal`	-
`cancellationToken`	`System.Threading.CancellationToken`	-

Returns

Type: System.Threading.Tasks.Task<ModelContextProtocol.Extensions.Tasks.McpTaskInfo?>

GetType Inherited

Inherited from object

Syntax

public System.Type GetType()

Returns

Type: System.Type

GetUserId

Resolves a stable user identifier from principal.

Syntax

public static string GetUserId(System.Security.Claims.ClaimsPrincipal principal)

Parameters

Name	Type	Description
`principal`	`System.Security.Claims.ClaimsPrincipal?`	The principal for the current request.

Returns

Type: string? The first non-whitespace claim in SDK session-identity order, or null when the principal is missing or unauthenticated.

Remarks

Claim lookup matches the MCP C# SDK session identity order: NameIdentifier, sub, Upn, Name, then Name. The principal must be authenticated.

MemberwiseClone Inherited

Inherited from object

Syntax

protected internal object MemberwiseClone()

Returns

Type: object

ReferenceEquals Inherited

Inherited from object

Syntax

public static bool ReferenceEquals(object objA, object objB)

Parameters

Name	Type	Description
`objA`	`object?`	-
`objB`	`object?`	-

Returns

Type: bool

ResolveInputRequestsAsync Virtual

Syntax

public virtual System.Threading.Tasks.Task ResolveInputRequestsAsync(string taskId, System.Collections.Generic.IDictionary<string, ModelContextProtocol.Protocol.InputResponse> inputResponses, System.Threading.CancellationToken cancellationToken = null)

Parameters

Name	Type	Description
`taskId`	`string`	-
`inputResponses`	`System.Collections.Generic.IDictionary<string, ModelContextProtocol.Protocol.InputResponse>`	-
`cancellationToken`	`System.Threading.CancellationToken`	-

Returns

Type: System.Threading.Tasks.Task

ResolveInputRequestsAsync Virtual

Syntax

public virtual System.Threading.Tasks.Task ResolveInputRequestsAsync(string taskId, System.Collections.Generic.IDictionary<string, ModelContextProtocol.Protocol.InputResponse> inputResponses, System.Security.Claims.ClaimsPrincipal user, System.Threading.CancellationToken cancellationToken = null)

Parameters

Name	Type	Description
`taskId`	`string`	-
`inputResponses`	`System.Collections.Generic.IDictionary<string, ModelContextProtocol.Protocol.InputResponse>`	-
`user`	`System.Security.Claims.ClaimsPrincipal`	-
`cancellationToken`	`System.Threading.CancellationToken`	-

Returns

Type: System.Threading.Tasks.Task

SetCancelledAsync Virtual

Syntax

public virtual System.Threading.Tasks.Task<bool> SetCancelledAsync(string taskId, System.Threading.CancellationToken cancellationToken = null)

Parameters

Name	Type	Description
`taskId`	`string`	-
`cancellationToken`	`System.Threading.CancellationToken`	-

Returns

Type: System.Threading.Tasks.Task<bool>

SetCancelledAsync Virtual

Syntax

public virtual System.Threading.Tasks.Task<bool> SetCancelledAsync(string taskId, System.Security.Claims.ClaimsPrincipal user, System.Threading.CancellationToken cancellationToken = null)

Parameters

Name	Type	Description
`taskId`	`string`	-
`user`	`System.Security.Claims.ClaimsPrincipal`	-
`cancellationToken`	`System.Threading.CancellationToken`	-

Returns

Type: System.Threading.Tasks.Task<bool>

SetCompletedAsync Virtual

Syntax

public virtual System.Threading.Tasks.Task SetCompletedAsync(string taskId, System.Text.Json.JsonElement result, System.Threading.CancellationToken cancellationToken = null)

Parameters

Name	Type	Description
`taskId`	`string`	-
`result`	`System.Text.Json.JsonElement`	-
`cancellationToken`	`System.Threading.CancellationToken`	-

Returns

Type: System.Threading.Tasks.Task

SetFailedAsync Virtual

Syntax

public virtual System.Threading.Tasks.Task SetFailedAsync(string taskId, System.Text.Json.JsonElement error, System.Threading.CancellationToken cancellationToken = null)

Parameters

Name	Type	Description
`taskId`	`string`	-
`error`	`System.Text.Json.JsonElement`	-
`cancellationToken`	`System.Threading.CancellationToken`	-

Returns

Type: System.Threading.Tasks.Task

SetInputRequestsAsync Virtual

Syntax

public virtual System.Threading.Tasks.Task SetInputRequestsAsync(string taskId, System.Collections.Generic.IDictionary<string, ModelContextProtocol.Protocol.InputRequest> inputRequests, System.Threading.CancellationToken cancellationToken = null)

Parameters

Name	Type	Description
`taskId`	`string`	-
`inputRequests`	`System.Collections.Generic.IDictionary<string, ModelContextProtocol.Protocol.InputRequest>`	-
`cancellationToken`	`System.Threading.CancellationToken`	-

Returns

Type: System.Threading.Tasks.Task

SweepExpiredAsync Virtual

Syntax

public virtual System.Threading.Tasks.Task SweepExpiredAsync(System.Threading.CancellationToken cancellationToken = null)

Parameters

Name	Type	Description
`cancellationToken`	`System.Threading.CancellationToken`	-

Returns

Type: System.Threading.Tasks.Task

ToString Inherited Virtual

Inherited from object

Syntax

public virtual string ToString()

Returns

Type: string?

Events

InputResponseReceived

Syntax

public virtual System.Action<ModelContextProtocol.Extensions.Tasks.InputResponseReceivedEventArgs> InputResponseReceived

CloudNimble.McpEssentials.Core.Tasks.IMcpTaskStorePlus
ModelContextProtocol.Extensions.Tasks.IMcpTaskStore

​Definition

​Syntax

​Summary

​Remarks

​Constructors

​ .ctor Inherited

​Syntax

​Properties

​ AutoSweep Virtual

​Syntax

​Property Value

​Remarks

​ DefaultPollIntervalMs Virtual

​Syntax

​Property Value

​ DefaultTimeToLive Virtual

​Syntax

​Property Value

​Remarks

​ ServeAndDrop Virtual

​Syntax

​Property Value

​ SweepInterval Virtual

​Syntax

​Property Value

​Methods

​ CreateTaskAsync Virtual

​Syntax

​Parameters

​Returns

​ CreateTaskAsync Virtual

​Syntax

​Parameters

​Returns

​ Equals Inherited Virtual

​Syntax

​Parameters

​Returns

​ Equals Inherited

​Syntax

​Parameters

​Returns

​ GetHashCode Inherited Virtual

​Syntax

​Returns

​ GetTaskAsync Virtual

​Syntax

​Parameters

​Returns

​ GetTaskAsync Virtual

​Syntax

​Parameters

​Returns

​ GetType Inherited

​Syntax

​Returns

​ GetUserId

​Syntax

​Parameters

​Returns

​Remarks

​ MemberwiseClone Inherited

​Syntax

​Returns

​ ReferenceEquals Inherited

​Syntax

​Parameters

​Returns

​ ResolveInputRequestsAsync Virtual

​Syntax

​Parameters

​Returns

​ ResolveInputRequestsAsync Virtual

​Syntax

​Parameters

​Returns

​ SetCancelledAsync Virtual

​Syntax

​Parameters

​Returns

Definition

Syntax

Summary

Remarks

Constructors

.ctor Inherited

Syntax

Properties

AutoSweep Virtual

Syntax

Property Value

Remarks

DefaultPollIntervalMs Virtual

Syntax

Property Value

DefaultTimeToLive Virtual

Syntax

Property Value

Remarks

ServeAndDrop Virtual

Syntax

Property Value

SweepInterval Virtual

Syntax

Property Value

Methods

CreateTaskAsync Virtual

Syntax

Parameters

Returns

CreateTaskAsync Virtual

Syntax

Parameters

Returns

Equals Inherited Virtual

Syntax

Parameters

Returns

Equals Inherited

Syntax

Parameters

Returns

GetHashCode Inherited Virtual

Syntax

Returns

GetTaskAsync Virtual

Syntax

Parameters

Returns

GetTaskAsync Virtual

Syntax

Parameters

Returns

GetType Inherited

Syntax

Returns

GetUserId

Syntax

Parameters

Returns

Remarks

MemberwiseClone Inherited

Syntax

Returns

ReferenceEquals Inherited

Syntax

Parameters

Returns

ResolveInputRequestsAsync Virtual

Syntax

Parameters

Returns

ResolveInputRequestsAsync Virtual

Syntax

Parameters

Returns

SetCancelledAsync Virtual

Syntax

Parameters

Returns