ye

Author: kamilkisiela

package.json

@@ -28,7 +28,7 @@
     "docker:override-up": "docker compose -f ./docker/docker-compose.override.yml up -d --remove-orphans",
     "env:sync": "tsx scripts/sync-env-files.ts",
     "generate": "pnpm --filter @hive/storage db:generate && pnpm graphql:generate",
-    "graphql:generate": "graphql-codegen --config codegen.mts",
+    "graphql:generate": "VERBOSE=1 graphql-codegen --config codegen.mts",
     "integration:prepare": "cd integration-tests && ./local.sh",
     "lint": "eslint --cache --ignore-path .gitignore \"{packages,cypress}/**/*.{ts,tsx,graphql}\"",
     "lint:env-template": "tsx scripts/check-env-template.ts",

packages/services/api/src/modules/operations/module.graphql.mappers.ts

@@ -1,6 +1,9 @@
+import type Dataloader from 'dataloader';
 import type { ClientStatsValues, OperationStatsValues, PageInfo } from '../../__generated__/types';
 import type { DateRange } from '../../shared/entities';
 
+// import { SqlValue } from './providers/sql';
+
 type Connection<TNode> = {
   pageInfo: PageInfo;
   edges: Array<{ node: TNode; cursor: string }>;
@@ -41,3 +44,17 @@ export interface DurationValuesMapper {
   p95: number | null;
   p99: number | null;
 }
+
+export type TracesFilterOptionsMapper = {
+  // ANDs: readonly SqlValue[];
+  loader: Dataloader<
+    {
+      key: string;
+      columnExpression: string;
+      limit: number | null;
+      arrayJoinColumn: string | null;
+    },
+    { value: string; count: number }[],
+    string
+  >;
+};

packages/services/api/src/modules/operations/module.graphql.ts

@@ -259,13 +259,82 @@ export default gql`
     body: String! @tag(name: "public")
   }
 
+  type TraceConnection {
+    edges: [TraceEdge!]!
+    pageInfo: PageInfo!
+  }
+
+  type TraceEdge {
+    node: Trace!
+    cursor: String!
+  }
+
+  type Trace {
+    id: ID!
+    timestamp: DateTime!
+    operationName: String!
+    operationType: GraphQLOperationType!
+    duration: Int!
+    subgraphs: [String!]!
+    success: Boolean!
+    clientName: String
+    clientVersion: String
+    httpStatusCode: Int
+    httpMethod: String
+    httpHost: String
+    httpRoute: String
+    httpUrl: String
+  }
+
+  input TracesFilterInput {
+    id: [ID!]
+    operationName: [String!]
+    operationType: [GraphQLOperationType!]
+    success: [Boolean!]
+    httpStatusCode: [Int!]
+    httpMethod: [String!]
+    httpHost: [String!]
+    httpRoute: [String!]
+    httpUrl: [String!]
+    subgraphs: [String!]
+  }
+
+  type TracesFilterOptions {
+    success: [FilterBooleanOption!]!
+    operationType: [FilterStringOption!]!
+    operationName(top: Int): [FilterStringOption!]!
+    httpStatusCode(top: Int): [FilterIntOption!]!
+    httpMethod(top: Int): [FilterStringOption!]!
+    httpHost(top: Int): [FilterStringOption!]!
+    httpRoute(top: Int): [FilterStringOption!]!
+    httpUrl(top: Int): [FilterStringOption!]!
+    subgraphs(top: Int): [FilterStringOption!]!
+  }
+
+  type FilterStringOption {
+    value: String!
+    count: Int!
+  }
+
+  type FilterBooleanOption {
+    value: Boolean!
+    count: Int!
+  }
+
+  type FilterIntOption {
+    value: Int!
+    count: Int!
+  }
+
   extend type Target {
     requestsOverTime(resolution: Int!, period: DateRangeInput!): [RequestsOverTime!]!
     totalRequests(period: DateRangeInput!): SafeInt!
     """
     Retrieve an operation via it's hash.
     """
     operation(hash: ID! @tag(name: "public")): Operation @tag(name: "public")
+    traces(first: Int, after: String, filter: TracesFilterInput): TraceConnection!
+    tracesFilterOptions(filter: TracesFilterInput): TracesFilterOptions!
   }
 
   extend type Project {