Merge pull request #116 from pinax-network/fix/createDatabase

fix create database before ping

index.ts

@@ -17,9 +17,9 @@ import * as buffer from "./src/buffer.js"
 if (config.verbose) logger.enable();
 
 // initizalize before starting the server
+await init();
 await show_tables();
 await show_databases();
-await init();
 await buffer.flush(true);
 
 const app = Bun.serve({

src/clickhouse/createClient.ts

@@ -1,11 +1,11 @@
 import * as clickhouse from "@clickhouse/client-web";
 import { APP_NAME, config } from "../config.js";
 
-function createClient(readonly = false) {
+function createClient(readonly = false, database = "default") {
     return clickhouse.createClient({
         host: config.host,
         password: config.password,
-        database: config.database,
+        database,
         clickhouse_settings: {
             // wait_for_async_insert: 0, // 0
             async_insert: 0, // 1
@@ -15,5 +15,6 @@ function createClient(readonly = false) {
     })
 }
 
-export const client = createClient(false);
-export const readOnlyClient = createClient(true);
+export const client = createClient(false, config.database);
+export const defaultClient = createClient(false, "default");
+export const readOnlyClient = createClient(true, config.database);

src/clickhouse/createDatabase.ts

@@ -1,13 +1,8 @@
 import { logger } from "../logger.js";
-import { client } from "./createClient.js";
-import { databases } from "./stores.js";
+import { defaultClient } from "./createClient.js";
 
 export async function createDatabase(database: string) {
-  // if (!database) {
-  //   throw new Error("[database] is required")
-  // }
-  // if ( databases?.has(database) ) return {};
   const query = `CREATE DATABASE IF NOT EXISTS "${database}"`;
   logger.info('[clickhouse::createDatabase]\t', `CREATE DATABASE [${database}]`);
-  return {query, ...await client.exec({ query })};
+  return {query, ...await defaultClient.exec({ query })};
 }

src/fetch/init.ts

@@ -6,8 +6,8 @@ import { toJSON } from "./cors.js";
 
 export default async function init() {
   return toJSON({
-    ping: await ping(),
     createDatabase: await createDatabase(config.database),
+    ping: await ping(),
     initializeDefaultTables: await initializeDefaultTables(),
   });
 }