Added API call to fetch usage data

Author: svenefftinge

components/usage-api/go/v1/usage.pb.go

@@ -16,6 +16,7 @@ import * as google_protobuf_timestamp_pb from "google-protobuf/google/protobuf/t
 
 interface IUsageServiceService extends grpc.ServiceDefinition<grpc.UntypedServiceImplementation> {
     listBilledUsage: IUsageServiceService_IListBilledUsage;
+    findUsage: IUsageServiceService_IFindUsage;
     reconcileUsage: IUsageServiceService_IReconcileUsage;
     getCostCenter: IUsageServiceService_IGetCostCenter;
     reconcileUsageWithLedger: IUsageServiceService_IReconcileUsageWithLedger;
@@ -30,6 +31,15 @@ interface IUsageServiceService_IListBilledUsage extends grpc.MethodDefinition<us
     responseSerialize: grpc.serialize<usage_v1_usage_pb.ListBilledUsageResponse>;
     responseDeserialize: grpc.deserialize<usage_v1_usage_pb.ListBilledUsageResponse>;
 }
+interface IUsageServiceService_IFindUsage extends grpc.MethodDefinition<usage_v1_usage_pb.FindUsageRequest, usage_v1_usage_pb.FindUsageResponse> {
+    path: "/usage.v1.UsageService/FindUsage";
+    requestStream: false;
+    responseStream: false;
+    requestSerialize: grpc.serialize<usage_v1_usage_pb.FindUsageRequest>;
+    requestDeserialize: grpc.deserialize<usage_v1_usage_pb.FindUsageRequest>;
+    responseSerialize: grpc.serialize<usage_v1_usage_pb.FindUsageResponse>;
+    responseDeserialize: grpc.deserialize<usage_v1_usage_pb.FindUsageResponse>;
+}
 interface IUsageServiceService_IReconcileUsage extends grpc.MethodDefinition<usage_v1_usage_pb.ReconcileUsageRequest, usage_v1_usage_pb.ReconcileUsageResponse> {
     path: "/usage.v1.UsageService/ReconcileUsage";
     requestStream: false;
@@ -62,6 +72,7 @@ export const UsageServiceService: IUsageServiceService;
 
 export interface IUsageServiceServer extends grpc.UntypedServiceImplementation {
     listBilledUsage: grpc.handleUnaryCall<usage_v1_usage_pb.ListBilledUsageRequest, usage_v1_usage_pb.ListBilledUsageResponse>;
+    findUsage: grpc.handleUnaryCall<usage_v1_usage_pb.FindUsageRequest, usage_v1_usage_pb.FindUsageResponse>;
     reconcileUsage: grpc.handleUnaryCall<usage_v1_usage_pb.ReconcileUsageRequest, usage_v1_usage_pb.ReconcileUsageResponse>;
     getCostCenter: grpc.handleUnaryCall<usage_v1_usage_pb.GetCostCenterRequest, usage_v1_usage_pb.GetCostCenterResponse>;
     reconcileUsageWithLedger: grpc.handleUnaryCall<usage_v1_usage_pb.ReconcileUsageWithLedgerRequest, usage_v1_usage_pb.ReconcileUsageWithLedgerResponse>;
@@ -71,6 +82,9 @@ export interface IUsageServiceClient {
     listBilledUsage(request: usage_v1_usage_pb.ListBilledUsageRequest, callback: (error: grpc.ServiceError | null, response: usage_v1_usage_pb.ListBilledUsageResponse) => void): grpc.ClientUnaryCall;
     listBilledUsage(request: usage_v1_usage_pb.ListBilledUsageRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: usage_v1_usage_pb.ListBilledUsageResponse) => void): grpc.ClientUnaryCall;
     listBilledUsage(request: usage_v1_usage_pb.ListBilledUsageRequest, metadata: grpc.Metadata, options: Partial<grpc.CallOptions>, callback: (error: grpc.ServiceError | null, response: usage_v1_usage_pb.ListBilledUsageResponse) => void): grpc.ClientUnaryCall;
+    findUsage(request: usage_v1_usage_pb.FindUsageRequest, callback: (error: grpc.ServiceError | null, response: usage_v1_usage_pb.FindUsageResponse) => void): grpc.ClientUnaryCall;
+    findUsage(request: usage_v1_usage_pb.FindUsageRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: usage_v1_usage_pb.FindUsageResponse) => void): grpc.ClientUnaryCall;
+    findUsage(request: usage_v1_usage_pb.FindUsageRequest, metadata: grpc.Metadata, options: Partial<grpc.CallOptions>, callback: (error: grpc.ServiceError | null, response: usage_v1_usage_pb.FindUsageResponse) => void): grpc.ClientUnaryCall;
     reconcileUsage(request: usage_v1_usage_pb.ReconcileUsageRequest, callback: (error: grpc.ServiceError | null, response: usage_v1_usage_pb.ReconcileUsageResponse) => void): grpc.ClientUnaryCall;
     reconcileUsage(request: usage_v1_usage_pb.ReconcileUsageRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: usage_v1_usage_pb.ReconcileUsageResponse) => void): grpc.ClientUnaryCall;
     reconcileUsage(request: usage_v1_usage_pb.ReconcileUsageRequest, metadata: grpc.Metadata, options: Partial<grpc.CallOptions>, callback: (error: grpc.ServiceError | null, response: usage_v1_usage_pb.ReconcileUsageResponse) => void): grpc.ClientUnaryCall;
@@ -87,6 +101,9 @@ export class UsageServiceClient extends grpc.Client implements IUsageServiceClie
     public listBilledUsage(request: usage_v1_usage_pb.ListBilledUsageRequest, callback: (error: grpc.ServiceError | null, response: usage_v1_usage_pb.ListBilledUsageResponse) => void): grpc.ClientUnaryCall;
     public listBilledUsage(request: usage_v1_usage_pb.ListBilledUsageRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: usage_v1_usage_pb.ListBilledUsageResponse) => void): grpc.ClientUnaryCall;
     public listBilledUsage(request: usage_v1_usage_pb.ListBilledUsageRequest, metadata: grpc.Metadata, options: Partial<grpc.CallOptions>, callback: (error: grpc.ServiceError | null, response: usage_v1_usage_pb.ListBilledUsageResponse) => void): grpc.ClientUnaryCall;
+    public findUsage(request: usage_v1_usage_pb.FindUsageRequest, callback: (error: grpc.ServiceError | null, response: usage_v1_usage_pb.FindUsageResponse) => void): grpc.ClientUnaryCall;
+    public findUsage(request: usage_v1_usage_pb.FindUsageRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: usage_v1_usage_pb.FindUsageResponse) => void): grpc.ClientUnaryCall;
+    public findUsage(request: usage_v1_usage_pb.FindUsageRequest, metadata: grpc.Metadata, options: Partial<grpc.CallOptions>, callback: (error: grpc.ServiceError | null, response: usage_v1_usage_pb.FindUsageResponse) => void): grpc.ClientUnaryCall;
     public reconcileUsage(request: usage_v1_usage_pb.ReconcileUsageRequest, callback: (error: grpc.ServiceError | null, response: usage_v1_usage_pb.ReconcileUsageResponse) => void): grpc.ClientUnaryCall;
     public reconcileUsage(request: usage_v1_usage_pb.ReconcileUsageRequest, metadata: grpc.Metadata, callback: (error: grpc.ServiceError | null, response: usage_v1_usage_pb.ReconcileUsageResponse) => void): grpc.ClientUnaryCall;
     public reconcileUsage(request: usage_v1_usage_pb.ReconcileUsageRequest, metadata: grpc.Metadata, options: Partial<grpc.CallOptions>, callback: (error: grpc.ServiceError | null, response: usage_v1_usage_pb.ReconcileUsageResponse) => void): grpc.ClientUnaryCall;

components/usage-api/go/v1/usage_grpc.pb.go

@@ -11,6 +11,28 @@ var grpc = require('@grpc/grpc-js');
 var usage_v1_usage_pb = require('../../usage/v1/usage_pb.js');
 var google_protobuf_timestamp_pb = require('google-protobuf/google/protobuf/timestamp_pb.js');
 
+function serialize_usage_v1_FindUsageRequest(arg) {
+  if (!(arg instanceof usage_v1_usage_pb.FindUsageRequest)) {
+    throw new Error('Expected argument of type usage.v1.FindUsageRequest');
+  }
+  return Buffer.from(arg.serializeBinary());
+}
+
+function deserialize_usage_v1_FindUsageRequest(buffer_arg) {
+  return usage_v1_usage_pb.FindUsageRequest.deserializeBinary(new Uint8Array(buffer_arg));
+}
+
+function serialize_usage_v1_FindUsageResponse(arg) {
+  if (!(arg instanceof usage_v1_usage_pb.FindUsageResponse)) {
+    throw new Error('Expected argument of type usage.v1.FindUsageResponse');
+  }
+  return Buffer.from(arg.serializeBinary());
+}
+
+function deserialize_usage_v1_FindUsageResponse(buffer_arg) {
+  return usage_v1_usage_pb.FindUsageResponse.deserializeBinary(new Uint8Array(buffer_arg));
+}
+
 function serialize_usage_v1_GetCostCenterRequest(arg) {
   if (!(arg instanceof usage_v1_usage_pb.GetCostCenterRequest)) {
     throw new Error('Expected argument of type usage.v1.GetCostCenterRequest');
@@ -113,6 +135,18 @@ listBilledUsage: {
     responseSerialize: serialize_usage_v1_ListBilledUsageResponse,
     responseDeserialize: deserialize_usage_v1_ListBilledUsageResponse,
   },
+  // ListBilledUsage retrieves all usage for the specified attributionId
+findUsage: {
+    path: '/usage.v1.UsageService/FindUsage',
+    requestStream: false,
+    responseStream: false,
+    requestType: usage_v1_usage_pb.FindUsageRequest,
+    responseType: usage_v1_usage_pb.FindUsageResponse,
+    requestSerialize: serialize_usage_v1_FindUsageRequest,
+    requestDeserialize: deserialize_usage_v1_FindUsageRequest,
+    responseSerialize: serialize_usage_v1_FindUsageResponse,
+    responseDeserialize: deserialize_usage_v1_FindUsageResponse,
+  },
   // ReconcileUsage collects usage for the specified time period, and stores the usage records in the database, returning the records.
 reconcileUsage: {
     path: '/usage.v1.UsageService/ReconcileUsage',

components/usage-api/typescript/src/usage/v1/usage_grpc_pb.d.ts

@@ -189,6 +189,137 @@ export namespace PaginatedResponse {
     }
 }
 
+export class FindUsageRequest extends jspb.Message {
+    getAttributionId(): string;
+    setAttributionId(value: string): FindUsageRequest;
+
+    hasFrom(): boolean;
+    clearFrom(): void;
+    getFrom(): google_protobuf_timestamp_pb.Timestamp | undefined;
+    setFrom(value?: google_protobuf_timestamp_pb.Timestamp): FindUsageRequest;
+
+    hasTo(): boolean;
+    clearTo(): void;
+    getTo(): google_protobuf_timestamp_pb.Timestamp | undefined;
+    setTo(value?: google_protobuf_timestamp_pb.Timestamp): FindUsageRequest;
+    getOrder(): FindUsageRequest.Ordering;
+    setOrder(value: FindUsageRequest.Ordering): FindUsageRequest;
+
+    hasPagination(): boolean;
+    clearPagination(): void;
+    getPagination(): PaginatedRequest | undefined;
+    setPagination(value?: PaginatedRequest): FindUsageRequest;
+
+    serializeBinary(): Uint8Array;
+    toObject(includeInstance?: boolean): FindUsageRequest.AsObject;
+    static toObject(includeInstance: boolean, msg: FindUsageRequest): FindUsageRequest.AsObject;
+    static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+    static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+    static serializeBinaryToWriter(message: FindUsageRequest, writer: jspb.BinaryWriter): void;
+    static deserializeBinary(bytes: Uint8Array): FindUsageRequest;
+    static deserializeBinaryFromReader(message: FindUsageRequest, reader: jspb.BinaryReader): FindUsageRequest;
+}
+
+export namespace FindUsageRequest {
+    export type AsObject = {
+        attributionId: string,
+        from?: google_protobuf_timestamp_pb.Timestamp.AsObject,
+        to?: google_protobuf_timestamp_pb.Timestamp.AsObject,
+        order: FindUsageRequest.Ordering,
+        pagination?: PaginatedRequest.AsObject,
+    }
+
+    export enum Ordering {
+    ORDERING_DESCENDING = 0,
+    ORDERING_ASCENDING = 1,
+    }
+
+}
+
+export class FindUsageResponse extends jspb.Message {
+    clearSessionsList(): void;
+    getSessionsList(): Array<BilledSession>;
+    setSessionsList(value: Array<BilledSession>): FindUsageResponse;
+    addSessions(value?: BilledSession, index?: number): BilledSession;
+    getTotalCreditsUsed(): number;
+    setTotalCreditsUsed(value: number): FindUsageResponse;
+
+    hasPagination(): boolean;
+    clearPagination(): void;
+    getPagination(): PaginatedResponse | undefined;
+    setPagination(value?: PaginatedResponse): FindUsageResponse;
+
+    serializeBinary(): Uint8Array;
+    toObject(includeInstance?: boolean): FindUsageResponse.AsObject;
+    static toObject(includeInstance: boolean, msg: FindUsageResponse): FindUsageResponse.AsObject;
+    static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+    static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+    static serializeBinaryToWriter(message: FindUsageResponse, writer: jspb.BinaryWriter): void;
+    static deserializeBinary(bytes: Uint8Array): FindUsageResponse;
+    static deserializeBinaryFromReader(message: FindUsageResponse, reader: jspb.BinaryReader): FindUsageResponse;
+}
+
+export namespace FindUsageResponse {
+    export type AsObject = {
+        sessionsList: Array<BilledSession.AsObject>,
+        totalCreditsUsed: number,
+        pagination?: PaginatedResponse.AsObject,
+    }
+}
+
+export class Usage extends jspb.Message {
+    getId(): string;
+    setId(value: string): Usage;
+    getAttributionId(): string;
+    setAttributionId(value: string): Usage;
+    getDescription(): string;
+    setDescription(value: string): Usage;
+    getCredits(): number;
+    setCredits(value: number): Usage;
+
+    hasEffectiveTime(): boolean;
+    clearEffectiveTime(): void;
+    getEffectiveTime(): google_protobuf_timestamp_pb.Timestamp | undefined;
+    setEffectiveTime(value?: google_protobuf_timestamp_pb.Timestamp): Usage;
+    getKind(): Usage.Kind;
+    setKind(value: Usage.Kind): Usage;
+    getWorkspaceInstanceId(): string;
+    setWorkspaceInstanceId(value: string): Usage;
+    getDraft(): boolean;
+    setDraft(value: boolean): Usage;
+    getMetadata(): string;
+    setMetadata(value: string): Usage;
+
+    serializeBinary(): Uint8Array;
+    toObject(includeInstance?: boolean): Usage.AsObject;
+    static toObject(includeInstance: boolean, msg: Usage): Usage.AsObject;
+    static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+    static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+    static serializeBinaryToWriter(message: Usage, writer: jspb.BinaryWriter): void;
+    static deserializeBinary(bytes: Uint8Array): Usage;
+    static deserializeBinaryFromReader(message: Usage, reader: jspb.BinaryReader): Usage;
+}
+
+export namespace Usage {
+    export type AsObject = {
+        id: string,
+        attributionId: string,
+        description: string,
+        credits: number,
+        effectiveTime?: google_protobuf_timestamp_pb.Timestamp.AsObject,
+        kind: Usage.Kind,
+        workspaceInstanceId: string,
+        draft: boolean,
+        metadata: string,
+    }
+
+    export enum Kind {
+    KIND_WORKSPACE_INSTANCE = 0,
+    KIND_INVOICE = 1,
+    }
+
+}
+
 export class BilledSession extends jspb.Message {
     getAttributionId(): string;
     setAttributionId(value: string): BilledSession;