(id toolspkg.ToolID)
| 4112 | } |
| 4113 | |
| 4114 | func (i logQueryInput) eventSummaryQuery(id toolspkg.ToolID) (store.EventSummaryQuery, error) { |
| 4115 | since, err := parseNativeOptionalRFC3339(id, "since", i.Since) |
| 4116 | if err != nil { |
| 4117 | return store.EventSummaryQuery{}, err |
| 4118 | } |
| 4119 | query := store.EventSummaryQuery{ |
| 4120 | WorkspaceID: strings.TrimSpace(i.WorkspaceID), |
| 4121 | SessionID: strings.TrimSpace(i.SessionID), |
| 4122 | AgentName: strings.TrimSpace(i.AgentName), |
| 4123 | Type: strings.TrimSpace(i.Type), |
| 4124 | RunID: strings.TrimSpace(i.RunID), |
| 4125 | ActorKind: strings.TrimSpace(i.ActorKind), |
| 4126 | ActorID: strings.TrimSpace(i.ActorID), |
| 4127 | Provider: strings.TrimSpace(i.Provider), |
| 4128 | Outcome: strings.TrimSpace(i.Outcome), |
| 4129 | Component: strings.TrimSpace(i.Component), |
| 4130 | ErrorOnly: i.ErrorOnly, |
| 4131 | AfterSequence: i.AfterSequence, |
| 4132 | Since: since, |
| 4133 | Limit: i.Limit, |
| 4134 | } |
| 4135 | if err := query.Validate(); err != nil { |
| 4136 | return store.EventSummaryQuery{}, toolspkg.NewToolError( |
| 4137 | toolspkg.ErrorCodeInvalidInput, |
| 4138 | id, |
| 4139 | "logs query is invalid", |
| 4140 | fmt.Errorf("%w: %w", toolspkg.ErrToolInvalidInput, err), |
| 4141 | toolspkg.ReasonSchemaInvalid, |
| 4142 | ) |
| 4143 | } |
| 4144 | return query, nil |
| 4145 | } |
| 4146 | |
| 4147 | type observeSearchInput struct { |
| 4148 | Query string `json:"query"` |
no test coverage detected