Line data    Source code

       1              : import * as connection from '@ankoh/dashql-jsonschema/connection.js';
       2              : import * as pb from "../../proto.js";
       3              : 
       4              : import { HyperDatabaseChannel, HyperDatabaseClient, HyperDatabaseConnectionContext, HyperQueryResultStream } from "./hyperdb_grpc_client.js";
       5              : import { QueryExecutionResponseStreamMock } from "../query_execution_mock.js";
       6              : 
       7            1 : export class HyperDatabaseChannelMock implements HyperDatabaseChannel {
       8              :     /// Execute Query
       9            1 :     async executeQuery(_param: pb.salesforce_hyperdb_grpc_v1.pb.QueryParam): Promise<HyperQueryResultStream> {
      10            1 :         return new QueryExecutionResponseStreamMock();
      11              : 
      12            1 :     }
      13              :     /// Destroy the connection
      14            1 :     async close(): Promise<void> {
      15              : 
      16            1 :     }
      17            1 : }
      18              : 
      19            1 : export class HyperDatabaseClientMock implements HyperDatabaseClient {
      20              :     /// Create a database connection
      21            1 :     async connect(_args: connection.HyperConnectionParams, _context: HyperDatabaseConnectionContext): Promise<HyperDatabaseChannel> {
      22            1 :         return new HyperDatabaseChannelMock();
      23            1 :     }
      24            1 : }