Method agentHeartbeatStatus

internal/daemon/native_tools.go:2066–2120

(
	ctx context.Context,
	_ toolspkg.Scope,
	req toolspkg.CallRequest,
)

}

func (n *daemonNativeTools) agentHeartbeatStatus(
	ctx context.Context,
	_ toolspkg.Scope,
	req toolspkg.CallRequest,
) (toolspkg.ToolResult, error) {
	var input agentHeartbeatStatusInput
	if err := decodeNativeInput(req, &input); err != nil {
		return toolspkg.ToolResult{}, err
	}
	target, err := n.authoredAgentTarget(ctx, req.ToolID, input.WorkspaceID, input.AgentName)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	sessionID := strings.TrimSpace(input.SessionID)
	if sessionID != "" {
		if _, err := n.nativeSessionInWorkspace(ctx, req.ToolID, target.workspaceID, sessionID); err != nil {
			return toolspkg.ToolResult{}, err
		}
	}
	status, err := n.deps.HeartbeatStatus.Status(ctx, heartbeat.StatusRequest{
		Target:               target.heartbeatAuthoringTarget(),
		SessionID:            sessionID,
		IncludeSessionHealth: input.IncludeSessionHealth,
	})
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	payload, err := contract.HeartbeatStatusResponseFromResult(&status)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	if input.IncludeRecentWakeEvents && n.deps.WakeEvents != nil {
		events, err := n.deps.WakeEvents.ListHeartbeatWakeEvents(ctx, heartbeat.WakeEventListQuery{
			WorkspaceID: target.workspaceID,
			AgentName:   target.agentName,
			SessionID:   sessionID,
			Limit:       defaultNativeWakeEventLimit,
		})
		if err != nil {
			return toolspkg.ToolResult{}, err
		}
		payload.WakeEvents = make([]contract.HeartbeatWakeEventPayload, 0, len(events))
		for _, event := range events {
			converted, convertErr := contract.HeartbeatWakeEventPayloadFromDomain(event)
			if convertErr != nil {
				return toolspkg.ToolResult{}, convertErr
			}
			payload.WakeEvents = append(payload.WakeEvents, converted)
		}
	}
	if err := contract.ValidateAuthoredContextRedacted(payload); err != nil {
		return toolspkg.ToolResult{}, err
	}
	return structuredResult(map[string]any{"heartbeat": payload}, string(payload.ValidationStatus))
}

func (n *daemonNativeTools) agentHeartbeatWake(
	ctx context.Context,