Merge pull request #96 from qminer/frozen

Frozen

built/db_updater.d.ts

@@ -1,3 +1,4 @@
+import * as qtopology from "qtopology";
 /**
  * Simple callback.
  */
@@ -10,6 +11,18 @@ export interface SimpleResultCallback<T> {
 export interface Connection {
     query(script: string, callback: SimpleResultCallback<any[]>): any;
 }
+/**
+ * Simple callback.
+ */
+export interface Glob {
+    sync(path: string): string[];
+}
+/**
+ * Simple callback.
+ */
+export interface Fs {
+    readFileSync(name: string, encoding: string): string;
+}
 /**
  * Options for automatic DB upgrade
  */
@@ -18,6 +31,13 @@ export interface DbUpgraderOptions {
     conn: Connection;
     settings_table: string;
     version_record_key: string;
+    log_prefix?: string;
+    glob?: Glob;
+    fs?: Fs;
+    use_init_script?: boolean;
+    init_script_name?: string;
+    sql_template_get?: string;
+    sql_template_update?: string;
 }
 /**
  * This class handles automatic upgrades of underlaying database.
@@ -27,10 +47,25 @@ export declare class DbUpgrader {
     private conn;
     private settings_table;
     private version_record_key;
+    private inner_glob;
+    private inner_fs;
+    private log_prefix;
+    private init_script_name;
+    private use_init_script;
+    private sql_template_update;
+    private sql_template_get;
+    private curr_version;
+    private files;
     /** Simple constructor */
     constructor(options: DbUpgraderOptions);
     /** Internal logging utility method */
     private log(s);
+    /** This method just checks if database version is in sync with code version. */
+    check(callback: qtopology.SimpleCallback): void;
     /** Sequentially executes upgrade files. */
-    run(callback: any): void;
+    run(callback: qtopology.SimpleCallback): void;
+    private runInitScript(callback);
+    private getCurrentVersionFromDb(callback);
+    private checkFilesInScriptsDir(xcallback);
+    private updateVersionInDb(ver, callback);
 }