Operating Context¶

// Get current context information (throws if not in Temporal context)
var workflowId = XiansContext.WorkflowId;     // Current workflow ID
var tenantId = XiansContext.TenantId;         // Current tenant ID

// Check execution context
if (XiansContext.InWorkflow) { }              // In workflow?
if (XiansContext.InActivity) { }              // In activity?
if (XiansContext.InWorkflowOrActivity) { }    // In either?

// Use for logging - returns null if not in context
_logger.LogInfo("Workflow: {0}", XiansContext.SafeWorkflowId ?? "N/A");
_logger.LogInfo("Agent: {0}", XiansContext.SafeAgentName ?? "N/A");

var userId = XiansContext.GetParticipantId();  // Get user ID from context
var idPostfix = XiansContext.GetIdPostfix();   // Get ID postfix
var taskQueue = XiansContext.GetTaskQueue();   // Get current task queue

var agent = XiansContext.CurrentAgent;

// Access agent resources
var knowledge = await agent.Knowledge.GetAsync("config-key");
var documents = await agent.Documents.QueryAsync(new DocumentQuery());

var workflow = XiansContext.CurrentWorkflow;

// Access workflow resources
var schedule = await workflow.Schedules.GetAsync("my-schedule");
var workflowType = workflow.WorkflowType;

// Start workflow
await XiansContext.Workflows.StartAsync<MyWorkflow>(args, uniqueKey);

// Execute and wait for result
var result = await XiansContext.Workflows.ExecuteAsync<MyWorkflow, string>(args, uniqueKey);

// Get workflow handle for signaling/querying
var handle = await XiansContext.Workflows.GetWorkflowHandleAsync<MyWorkflow>(idPostfix);
await handle.SignalAsync(wf => wf.ProcessSignal, data);
var status = await handle.QueryAsync(wf => wf.GetStatus);

// Send chat message to user
await XiansContext.Messaging.SendChatAsync("userId123", "Your order shipped!");

// Send data message
await XiansContext.Messaging.SendDataAsync("userId123", "Order data", orderObject);

// Send message to built-in workflow
var response = await XiansContext.A2A.SendChatToBuiltInAsync(
    "WebWorkflow", 
    new A2AMessage { Text = "Fetch data" }
);

// Send simple text
var response = await XiansContext.A2A.SendTextAsync("WebWorkflow", "Hello");

// Send data
var response = await XiansContext.A2A.SendDataToBuiltInAsync("DataWorkflow", 
    new A2AMessage { Data = myData });

// Get agent (throws if not found)
var agent = XiansContext.GetAgent("MyAgent");

// Try get agent (returns bool)
if (XiansContext.TryGetAgent("MyAgent", out var agent))
{
    // Use agent
}

// Get all agents
var allAgents = XiansContext.GetAllAgents();

// Get workflow by type (throws if not found)
var workflow = XiansContext.GetWorkflow("MyAgent:CustomWorkflow");

// Get built-in workflow (auto-constructs type from current agent)
var webWorkflow = XiansContext.GetBuiltInWorkflow("WebWorkflow");

// Try methods (return bool)
if (XiansContext.TryGetWorkflow("MyAgent:CustomWorkflow", out var wf)) { }
if (XiansContext.TryGetBuiltInWorkflow("WebWorkflow", out var wf)) { }

// Get all workflows
var allWorkflows = XiansContext.GetAllWorkflows();

// Build workflow type: "MyAgent:WebWorkflow"
var workflowType = XiansContext.BuildBuiltInWorkflowType("MyAgent", "WebWorkflow");

// Build workflow ID: "tenant123:MyAgent:WebWorkflow"
var workflowId = XiansContext.BuildBuiltInWorkflowId("MyAgent", "WebWorkflow");

// Get workflow type from class
var workflowType = XiansContext.GetWorkflowTypeFor(typeof(MyCustomWorkflow));

public void LogState()
{
    if (XiansContext.InWorkflowOrActivity)
    {
        _logger.LogInfo("Workflow: {0}", XiansContext.WorkflowId);
    }
    else
    {
        _logger.LogInfo("Outside Temporal context");
    }
}

// Agent-scoped operations
var config = await XiansContext.CurrentAgent.Knowledge.GetAsync("config");

// Workflow-scoped operations
var schedule = await XiansContext.CurrentWorkflow.Schedules.GetAsync("daily-task");

if (XiansContext.TryGetAgent("OptionalAgent", out var agent))
{
    // Agent exists
}
else
{
    // Handle missing agent
}

// Start and signal pattern
await XiansContext.Workflows.StartAsync<MyWorkflow>(args);
var handle = await XiansContext.Workflows.GetWorkflowHandleAsync<MyWorkflow>(idPostfix);
await handle.SignalAsync(wf => wf.Process, data);

// Send to sub-workflow and wait for response
var response = await XiansContext.A2A.SendChatToBuiltInAsync(
    "WebWorkflow",
    new A2AMessage { Text = "Fetch data from example.com" }
);

// Will throw if not in context
var workflowId = XiansContext.WorkflowId;

// Safe alternative
var workflowId = XiansContext.SafeWorkflowId;
if (workflowId != null)
{
    // In Temporal context
}

// Or check first
if (XiansContext.InWorkflowOrActivity)
{
    var workflowId = XiansContext.WorkflowId;
}