@oasisdex/spock-etl
Advanced tools
Comparing version 0.1.0 to 0.1.1
@@ -15,2 +15,5 @@ import pg from 'pg-promise'; | ||
export declare function makeNullUndefined<T>(value: T | null): T | undefined; | ||
export declare function getColumnSets(pg: pg.IMain): {}; | ||
export declare function getColumnSets(pg: pg.IMain): { | ||
block: pg.ColumnSet; | ||
extracted_logs: pg.ColumnSet; | ||
}; |
@@ -51,8 +51,8 @@ "use strict"; | ||
return { | ||
// block: new pg.helpers.ColumnSet(['number', 'hash', 'timestamp'], { | ||
// table: new pg.helpers.TableName('block', 'vulcan2x'), | ||
// }), | ||
// extracted_logs: new pg.helpers.ColumnSet(['block_id', 'tx_id', 'log_index', 'address', 'data', 'topics'], { | ||
// table: new pg.helpers.TableName('logs', 'extracted'), | ||
// }), | ||
block: new pg.helpers.ColumnSet(['number', 'hash', 'timestamp'], { | ||
table: new pg.helpers.TableName({ table: 'block', schema: 'vulcan2x' }), | ||
}), | ||
extracted_logs: new pg.helpers.ColumnSet(['block_id', 'tx_id', 'log_index', 'address', 'data', 'topics'], { | ||
table: new pg.helpers.TableName({ table: 'logs', schema: 'extracted' }), | ||
}), | ||
}; | ||
@@ -59,0 +59,0 @@ } |
@@ -142,9 +142,2 @@ import { Dictionary, DeepPartial } from 'ts-essentials'; | ||
} | undefined; | ||
db: { | ||
database: string; | ||
user: string; | ||
password: string; | ||
host: string; | ||
port: number; | ||
} | Record<string, string>; | ||
startingBlock: number; | ||
@@ -190,2 +183,9 @@ extractors: { | ||
}; | ||
db: { | ||
database: string; | ||
user: string; | ||
password: string; | ||
host: string; | ||
port: number; | ||
} | Record<string, string>; | ||
}, { | ||
@@ -198,9 +198,2 @@ lastBlock?: number | undefined; | ||
} | undefined; | ||
db: { | ||
database: string; | ||
user: string; | ||
password: string; | ||
host: string; | ||
port: number; | ||
} | Record<string, string>; | ||
startingBlock: number; | ||
@@ -246,2 +239,9 @@ extractors: { | ||
}; | ||
db: { | ||
database: string; | ||
user: string; | ||
password: string; | ||
host: string; | ||
port: number; | ||
} | Record<string, string>; | ||
}>; | ||
@@ -248,0 +248,0 @@ export declare type SpockConfig = z.infer<typeof spockConfigSchema>; |
import { Dictionary } from 'ts-essentials'; | ||
import { SpockConfig } from './config'; | ||
export declare function loadConfig(externalConfigPath: string): SpockConfig; | ||
export declare function mergeConfig(externalCfg: any): SpockConfig; | ||
export declare function getRequiredString(env: Env, name: string): string; | ||
export declare function getRequiredNumber(env: Env, name: string): number; | ||
export declare type Env = Dictionary<string | undefined>; |
@@ -9,2 +9,7 @@ "use strict"; | ||
const externalCfg = fixConfigPaths(externalConfigPath, modules_1.loadExternalModule(externalConfigPath)); | ||
const mergedConfig = mergeConfig(externalCfg); | ||
return mergedConfig; | ||
} | ||
exports.loadConfig = loadConfig; | ||
function mergeConfig(externalCfg) { | ||
const defaultCfg = config_1.getDefaultConfig(process.env); | ||
@@ -14,3 +19,3 @@ const finalConfig = lodash_1.merge({}, defaultCfg, externalCfg); | ||
} | ||
exports.loadConfig = loadConfig; | ||
exports.mergeConfig = mergeConfig; | ||
/** | ||
@@ -17,0 +22,0 @@ * Turn any relative paths in the config to absolute ones |
{ | ||
"name": "@oasisdex/spock-etl", | ||
"version": "0.1.0", | ||
"version": "0.1.1", | ||
"license": "AGPL-3.0-or-later", | ||
@@ -9,2 +9,3 @@ "files": [ | ||
"scripts": { | ||
"prepublishOnly": "cd ../.. && yarn build", | ||
"start": "ts-node -T ./src/index.ts", | ||
@@ -11,0 +12,0 @@ "format": "prettier --config ../../.prettierrc --ignore-path ../../.prettierignore --check \"./**/*.ts\"", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
145089
1778