Analytics

package.json

@@ -4,7 +4,7 @@
   "type": "module",
   "private": true,
   "scripts": {
-    "gen": "cd proto && bunx buf generate && bunx grpc_tools_node_protoc --js_out=import_style=commonjs,binary:../src/gen auth/v1/auth.proto event/v1/event.proto payment/v1/payment.proto",
+    "gen": "cd proto && bunx buf generate && bunx grpc_tools_node_protoc --js_out=import_style=commonjs,binary:../src/gen auth/v1/auth.proto event/v1/event.proto payment/v1/payment.proto query/v1/query.proto",
     "dev:backend": "bun --watch src/server.ts",
     "test": "vitest",
     "test:ui": "vitest --ui",
@@ -51,4 +51,4 @@
     "postgres": "^3.4.7",
     "zod": "^4.1.12"
   }
-}
+}

src/gen/query/v1/query_grpc_pb.js

@@ -0,0 +1,44 @@
+// GENERATED CODE -- DO NOT EDIT!
+
+'use strict';
+var grpc = require('@grpc/grpc-js');
+var query_v1_query_pb = require('../../query/v1/query_pb.js');
+
+function serialize_query_v1_QueryEventsRequest(arg) {
+  if (!(arg instanceof query_v1_query_pb.QueryEventsRequest)) {
+    throw new Error('Expected argument of type query.v1.QueryEventsRequest');
+  }
+  return Buffer.from(arg.serializeBinary());
+}
+
+function deserialize_query_v1_QueryEventsRequest(buffer_arg) {
+  return query_v1_query_pb.QueryEventsRequest.deserializeBinary(new Uint8Array(buffer_arg));
+}
+
+function serialize_query_v1_QueryEventsResponse(arg) {
+  if (!(arg instanceof query_v1_query_pb.QueryEventsResponse)) {
+    throw new Error('Expected argument of type query.v1.QueryEventsResponse');
+  }
+  return Buffer.from(arg.serializeBinary());
+}
+
+function deserialize_query_v1_QueryEventsResponse(buffer_arg) {
+  return query_v1_query_pb.QueryEventsResponse.deserializeBinary(new Uint8Array(buffer_arg));
+}
+
+
+var QueryServiceService = exports.QueryServiceService = {
+  queryEvents: {
+    path: '/query.v1.QueryService/QueryEvents',
+    requestStream: false,
+    responseStream: false,
+    requestType: query_v1_query_pb.QueryEventsRequest,
+    responseType: query_v1_query_pb.QueryEventsResponse,
+    requestSerialize: serialize_query_v1_QueryEventsRequest,
+    requestDeserialize: deserialize_query_v1_QueryEventsRequest,
+    responseSerialize: serialize_query_v1_QueryEventsResponse,
+    responseDeserialize: deserialize_query_v1_QueryEventsResponse,
+  },
+};
+
+exports.QueryServiceClient = grpc.makeGenericClientConstructor(QueryServiceService, 'QueryService');

src/gen/query/v1/query_pb.d.ts

@@ -0,0 +1,315 @@
+// package: query.v1
+// file: query/v1/query.proto
+
+import * as jspb from "google-protobuf";
+
+export class FilterCondition extends jspb.Message {
+  getField(): string;
+  setField(value: string): void;
+
+  getOperator(): OperatorMap[keyof OperatorMap];
+  setOperator(value: OperatorMap[keyof OperatorMap]): void;
+
+  getValue(): string;
+  setValue(value: string): void;
+
+  serializeBinary(): Uint8Array;
+  toObject(includeInstance?: boolean): FilterCondition.AsObject;
+  static toObject(includeInstance: boolean, msg: FilterCondition): FilterCondition.AsObject;
+  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+  static serializeBinaryToWriter(message: FilterCondition, writer: jspb.BinaryWriter): void;
+  static deserializeBinary(bytes: Uint8Array): FilterCondition;
+  static deserializeBinaryFromReader(message: FilterCondition, reader: jspb.BinaryReader): FilterCondition;
+}
+
+export namespace FilterCondition {
+  export type AsObject = {
+    field: string,
+    operator: OperatorMap[keyof OperatorMap],
+    value: string,
+  }
+}
+
+export class FilterGroup extends jspb.Message {
+  getLogical(): LogicalOperatorMap[keyof LogicalOperatorMap];
+  setLogical(value: LogicalOperatorMap[keyof LogicalOperatorMap]): void;
+
+  clearConditionsList(): void;
+  getConditionsList(): Array<FilterCondition>;
+  setConditionsList(value: Array<FilterCondition>): void;
+  addConditions(value?: FilterCondition, index?: number): FilterCondition;
+
+  clearGroupsList(): void;
+  getGroupsList(): Array<FilterGroup>;
+  setGroupsList(value: Array<FilterGroup>): void;
+  addGroups(value?: FilterGroup, index?: number): FilterGroup;
+
+  serializeBinary(): Uint8Array;
+  toObject(includeInstance?: boolean): FilterGroup.AsObject;
+  static toObject(includeInstance: boolean, msg: FilterGroup): FilterGroup.AsObject;
+  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+  static serializeBinaryToWriter(message: FilterGroup, writer: jspb.BinaryWriter): void;
+  static deserializeBinary(bytes: Uint8Array): FilterGroup;
+  static deserializeBinaryFromReader(message: FilterGroup, reader: jspb.BinaryReader): FilterGroup;
+}
+
+export namespace FilterGroup {
+  export type AsObject = {
+    logical: LogicalOperatorMap[keyof LogicalOperatorMap],
+    conditionsList: Array<FilterCondition.AsObject>,
+    groupsList: Array<FilterGroup.AsObject>,
+  }
+}
+
+export class Aggregation extends jspb.Message {
+  getType(): AggregationTypeMap[keyof AggregationTypeMap];
+  setType(value: AggregationTypeMap[keyof AggregationTypeMap]): void;
+
+  getField(): string;
+  setField(value: string): void;
+
+  serializeBinary(): Uint8Array;
+  toObject(includeInstance?: boolean): Aggregation.AsObject;
+  static toObject(includeInstance: boolean, msg: Aggregation): Aggregation.AsObject;
+  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+  static serializeBinaryToWriter(message: Aggregation, writer: jspb.BinaryWriter): void;
+  static deserializeBinary(bytes: Uint8Array): Aggregation;
+  static deserializeBinaryFromReader(message: Aggregation, reader: jspb.BinaryReader): Aggregation;
+}
+
+export namespace Aggregation {
+  export type AsObject = {
+    type: AggregationTypeMap[keyof AggregationTypeMap],
+    field: string,
+  }
+}
+
+export class GroupBy extends jspb.Message {
+  getField(): string;
+  setField(value: string): void;
+
+  serializeBinary(): Uint8Array;
+  toObject(includeInstance?: boolean): GroupBy.AsObject;
+  static toObject(includeInstance: boolean, msg: GroupBy): GroupBy.AsObject;
+  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+  static serializeBinaryToWriter(message: GroupBy, writer: jspb.BinaryWriter): void;
+  static deserializeBinary(bytes: Uint8Array): GroupBy;
+  static deserializeBinaryFromReader(message: GroupBy, reader: jspb.BinaryReader): GroupBy;
+}
+
+export namespace GroupBy {
+  export type AsObject = {
+    field: string,
+  }
+}
+
+export class QueryEventsRequest extends jspb.Message {
+  hasWhere(): boolean;
+  clearWhere(): void;
+  getWhere(): FilterGroup | undefined;
+  setWhere(value?: FilterGroup): void;
+
+  hasAggregation(): boolean;
+  clearAggregation(): void;
+  getAggregation(): Aggregation | undefined;
+  setAggregation(value?: Aggregation): void;
+
+  hasGroupBy(): boolean;
+  clearGroupBy(): void;
+  getGroupBy(): GroupBy | undefined;
+  setGroupBy(value?: GroupBy): void;
+
+  getLimit(): number;
+  setLimit(value: number): void;
+
+  getOffset(): number;
+  setOffset(value: number): void;
+
+  serializeBinary(): Uint8Array;
+  toObject(includeInstance?: boolean): QueryEventsRequest.AsObject;
+  static toObject(includeInstance: boolean, msg: QueryEventsRequest): QueryEventsRequest.AsObject;
+  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+  static serializeBinaryToWriter(message: QueryEventsRequest, writer: jspb.BinaryWriter): void;
+  static deserializeBinary(bytes: Uint8Array): QueryEventsRequest;
+  static deserializeBinaryFromReader(message: QueryEventsRequest, reader: jspb.BinaryReader): QueryEventsRequest;
+}
+
+export namespace QueryEventsRequest {
+  export type AsObject = {
+    where?: FilterGroup.AsObject,
+    aggregation?: Aggregation.AsObject,
+    groupBy?: GroupBy.AsObject,
+    limit: number,
+    offset: number,
+  }
+}
+
+export class EventRow extends jspb.Message {
+  getEventId(): string;
+  setEventId(value: string): void;
+
+  getEventType(): string;
+  setEventType(value: string): void;
+
+  getUserId(): string;
+  setUserId(value: string): void;
+
+  getReportedTimestamp(): string;
+  setReportedTimestamp(value: string): void;
+
+  getIngestedTimestamp(): string;
+  setIngestedTimestamp(value: string): void;
+
+  hasSdkCallType(): boolean;
+  clearSdkCallType(): void;
+  getSdkCallType(): string;
+  setSdkCallType(value: string): void;
+
+  hasDebitAmount(): boolean;
+  clearDebitAmount(): void;
+  getDebitAmount(): number;
+  setDebitAmount(value: number): void;
+
+  hasModel(): boolean;
+  clearModel(): void;
+  getModel(): string;
+  setModel(value: string): void;
+
+  hasInputTokens(): boolean;
+  clearInputTokens(): void;
+  getInputTokens(): number;
+  setInputTokens(value: number): void;
+
+  hasOutputTokens(): boolean;
+  clearOutputTokens(): void;
+  getOutputTokens(): number;
+  setOutputTokens(value: number): void;
+
+  hasInputDebitAmount(): boolean;
+  clearInputDebitAmount(): void;
+  getInputDebitAmount(): number;
+  setInputDebitAmount(value: number): void;
+
+  hasOutputDebitAmount(): boolean;
+  clearOutputDebitAmount(): void;
+  getOutputDebitAmount(): number;
+  setOutputDebitAmount(value: number): void;
+
+  serializeBinary(): Uint8Array;
+  toObject(includeInstance?: boolean): EventRow.AsObject;
+  static toObject(includeInstance: boolean, msg: EventRow): EventRow.AsObject;
+  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+  static serializeBinaryToWriter(message: EventRow, writer: jspb.BinaryWriter): void;
+  static deserializeBinary(bytes: Uint8Array): EventRow;
+  static deserializeBinaryFromReader(message: EventRow, reader: jspb.BinaryReader): EventRow;
+}
+
+export namespace EventRow {
+  export type AsObject = {
+    eventId: string,
+    eventType: string,
+    userId: string,
+    reportedTimestamp: string,
+    ingestedTimestamp: string,
+    sdkCallType: string,
+    debitAmount: number,
+    model: string,
+    inputTokens: number,
+    outputTokens: number,
+    inputDebitAmount: number,
+    outputDebitAmount: number,
+  }
+}
+
+export class AggregationRow extends jspb.Message {
+  hasGroupValue(): boolean;
+  clearGroupValue(): void;
+  getGroupValue(): string;
+  setGroupValue(value: string): void;
+
+  getAggValue(): string;
+  setAggValue(value: string): void;
+
+  serializeBinary(): Uint8Array;
+  toObject(includeInstance?: boolean): AggregationRow.AsObject;
+  static toObject(includeInstance: boolean, msg: AggregationRow): AggregationRow.AsObject;
+  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+  static serializeBinaryToWriter(message: AggregationRow, writer: jspb.BinaryWriter): void;
+  static deserializeBinary(bytes: Uint8Array): AggregationRow;
+  static deserializeBinaryFromReader(message: AggregationRow, reader: jspb.BinaryReader): AggregationRow;
+}
+
+export namespace AggregationRow {
+  export type AsObject = {
+    groupValue: string,
+    aggValue: string,
+  }
+}
+
+export class QueryEventsResponse extends jspb.Message {
+  clearRowsList(): void;
+  getRowsList(): Array<EventRow>;
+  setRowsList(value: Array<EventRow>): void;
+  addRows(value?: EventRow, index?: number): EventRow;
+
+  clearAggRowsList(): void;
+  getAggRowsList(): Array<AggregationRow>;
+  setAggRowsList(value: Array<AggregationRow>): void;
+  addAggRows(value?: AggregationRow, index?: number): AggregationRow;
+
+  getTotal(): number;
+  setTotal(value: number): void;
+
+  serializeBinary(): Uint8Array;
+  toObject(includeInstance?: boolean): QueryEventsResponse.AsObject;
+  static toObject(includeInstance: boolean, msg: QueryEventsResponse): QueryEventsResponse.AsObject;
+  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+  static serializeBinaryToWriter(message: QueryEventsResponse, writer: jspb.BinaryWriter): void;
+  static deserializeBinary(bytes: Uint8Array): QueryEventsResponse;
+  static deserializeBinaryFromReader(message: QueryEventsResponse, reader: jspb.BinaryReader): QueryEventsResponse;
+}
+
+export namespace QueryEventsResponse {
+  export type AsObject = {
+    rowsList: Array<EventRow.AsObject>,
+    aggRowsList: Array<AggregationRow.AsObject>,
+    total: number,
+  }
+}
+
+export interface OperatorMap {
+  OPERATOR_UNSPECIFIED: 0;
+  EQ: 1;
+  GT: 2;
+  GTE: 3;
+  LT: 4;
+  LTE: 5;
+  NEQ: 6;
+}
+
+export const Operator: OperatorMap;
+
+export interface AggregationTypeMap {
+  AGGREGATION_TYPE_UNSPECIFIED: 0;
+  SUM: 1;
+  COUNT: 2;
+}
+
+export const AggregationType: AggregationTypeMap;
+
+export interface LogicalOperatorMap {
+  LOGICAL_OPERATOR_UNSPECIFIED: 0;
+  AND: 1;
+  OR: 2;
+}
+
+export const LogicalOperator: LogicalOperatorMap;
+