MCPcopy Create free account
hub / github.com/compozy/agh / sessionEvents

Method sessionEvents

internal/daemon/native_tools.go:2167–2197  ·  view source on GitHub ↗
(
	ctx context.Context,
	scope toolspkg.Scope,
	req toolspkg.CallRequest,
)

Source from the content-addressed store, hash-verified

2165}
2166
2167func (n *daemonNativeTools) sessionEvents(
2168 ctx context.Context,
2169 scope toolspkg.Scope,
2170 req toolspkg.CallRequest,
2171) (toolspkg.ToolResult, error) {
2172 input, query, err := decodeSessionEventQueryInput(req)
2173 if err != nil {
2174 return toolspkg.ToolResult{}, err
2175 }
2176 resolved, err := n.nativeResolvedWorkspace(ctx, req.ToolID, input.WorkspaceID, scope)
2177 if err != nil {
2178 return toolspkg.ToolResult{}, err
2179 }
2180 sessionWorkspaceID, err := nativeResolvedRegistryWorkspaceID(&resolved)
2181 if err != nil {
2182 return toolspkg.ToolResult{}, nativeNetworkInputError(req.ToolID, err)
2183 }
2184 info, err := n.nativeSessionInWorkspace(ctx, req.ToolID, sessionWorkspaceID, input.SessionID)
2185 if err != nil {
2186 return toolspkg.ToolResult{}, err
2187 }
2188 events, err := n.deps.Sessions.Events(ctx, input.SessionID, query)
2189 if err != nil {
2190 return toolspkg.ToolResult{}, err
2191 }
2192 payload := make([]any, 0, len(events))
2193 for _, event := range events {
2194 payload = append(payload, core.SessionEventPayloadFromEvent(event, info))
2195 }
2196 return structuredResult(map[string]any{nativeToolsEventsKey: payload}, fmt.Sprintf("%d events", len(payload)))
2197}
2198
2199func (n *daemonNativeTools) sessionHistory(
2200 ctx context.Context,

Callers

nothing calls this directly

Calls 9

nativeNetworkInputErrorFunction · 0.85
appendFunction · 0.85
structuredResultFunction · 0.85
EventsMethod · 0.65

Tested by

no test coverage detected