Eliminate TypeScript Errors and Convert foundational .js files to .ts

bin/copyDb.ts

@@ -161,7 +161,7 @@
 	const sourceDbisDb = rootStore.dbisDb;
 	const sourceAuditStore = rootStore.auditStore;
 	const targetEnv = open(new OpenEnvironmentObject(targetDatabasePath));
-	const targetDbisDb = targetEnv.openDB(INTERNAL_DBIS_NAME);
+	const targetDbisDb = targetEnv.openDB({ name: INTERNAL_DBIS_NAME });
 	let written;
 	let outstandingWrites = 0;
 	// we use a single transaction to get a snapshot, also we can't use snapshot: false on dupsort dbs
@@ -194,8 +194,8 @@
 			sourceDbi.decoderCopies = false;
 			sourceDbi.encoding = 'binary';
 			dbiInit.compression = newCompression;
 			const targetDbi = targetEnv.openDB(key, dbiInit);
 			targetDbi.encoder = null;
 			console.log('copying', key, 'from', sourceDatabase, 'to', targetDatabasePath);
 			await copyDbi(sourceDbi, targetDbi, isPrimary, transaction);
 		}
@@ -289,7 +289,7 @@
 	}
 	let db;
 	if (options.dupSort) {
 		db = RocksDatabase.open(new RocksIndexStore(path, options));
 	} else {
 		db = RocksDatabase.open(path, options);
 		db.encoder.name = options.name;

components/Application.ts

@@ -134,7 +134,7 @@ export async function extractApplication(application: Application) {
 	if (application.payload) {
 		// Given a payload, create a Readable from the Buffer or string
 		tarball = Readable.from(
-			application.payload instanceof Buffer ? application.payload : Buffer.from(application.payload, 'base64')
+			application.payload instanceof Buffer ? application.payload : Buffer.from((application as any).payload, 'base64')
 		);
 	} else {
 		// Given a package, there are a a couple options

components/ComponentV1.ts

@@ -33,7 +33,7 @@ interface ComponentV1Details {
 }
 
 export class ComponentV1 {
-	readonly config: Readonly<ComponentV1Config>;
+	readonly config: ComponentV1Config;
 	readonly name: string;
 	readonly directory: string;
 	readonly module: Readonly<ComponentV1Module>;

components/Scope.ts

@@ -63,7 +63,7 @@ export class Scope extends EventEmitter<ScopeEventsMap> {
 		this.#pluginName = pluginName;
 		this.#directory = directory;
 		this.#configFilePath = configFilePath;
-		this.#logger = logger || loggerWithTag(this.#appName);
+		this.#logger = loggerWithTag(this.#appName);
 
 		this.databaseEvents = databaseEventsEmitter;
 		this.applicationScope = applicationScope;

components/componentLoader.ts

@@ -82,7 +82,7 @@ export function loadComponentDirectories(loadedPluginModules?: Map<any, any>, lo
 	});
 }
 
-export const TRUSTED_RESOURCE_PLUGINS = {
+export const TRUSTED_RESOURCE_PLUGINS: any = {
 	REST, // for backwards compatibility with older configs
 	rest: REST,
 	graphql: graphqlQueryHandler,

dataLayer/harperBridge/BridgeMethods.js

@@ -5,79 +5,98 @@
  */
 
 class BridgeMethods {
-	createSchema() {
+	/** @param {...any} args */
+	createSchema(...args) {
 		throw new Error('createSchema bridge method is not defined');
 	}
 
-	dropSchema() {
+	/** @param {...any} args */
+	dropSchema(...args) {
 		throw new Error('dropSchema bridge method is not defined');
 	}
 
-	createTable() {
+	/** @param {...any} args */
+	createTable(...args) {
 		throw new Error('createTable bridge method is not defined');
 	}
 
-	dropTable() {
+	/** @param {...any} args */
+	dropTable(...args) {
 		throw new Error('dropTable bridge method is not defined');
 	}
 
-	createRecords() {
+	/** @param {...any} args */
+	createRecords(...args) {
 		throw new Error('createRecords bridge method is not defined');
 	}
 
-	updateRecords() {
+	/** @param {...any} args */
+	updateRecords(...args) {
 		throw new Error('updateRecords bridge method is not defined');
 	}
 
-	async upsertRecords() {
+	/** @param {...any} args */
+	async upsertRecords(...args) {
 		throw new Error('upsertRecords bridge method is not defined');
 	}
 
-	deleteRecords() {
+	/** @param {...any} args */
+	deleteRecords(...args) {
 		throw new Error('deleteRecords bridge method is not defined');
 	}
 
-	createAttribute() {
+	/** @param {...any} args */
+	createAttribute(...args) {
 		throw new Error('createAttribute bridge method is not defined');
 	}
 
-	dropAttribute() {
+	/** @param {...any} args */
+	dropAttribute(...args) {
 		throw new Error('dropAttribute bridge method is not defined');
 	}
 
-	searchByConditions() {
+	/** @param {...any} args */
+	searchByConditions(...args) {
 		throw new Error('searchByConditions bridge method is not defined');
 	}
 
-	searchByHash() {
+	/** @param {...any} args */
+	searchByHash(...args) {
 		throw new Error('searchByHash bridge method is not defined');
 	}
 
-	searchByValue() {
+	/** @param {...any} args */
+	searchByValue(...args) {
 		throw new Error('searchByValue bridge method is not defined');
 	}
 
-	getDataByHash() {
+	/** @param {...any} args */
+	getDataByHash(...args) {
 		throw new Error('getDataByHash bridge method is not defined');
 	}
 
-	async getDataByValue(_searchObject, _comparator) {
+	/** @param {...any} args */
+	async getDataByValue(...args) {
 		throw new Error('getDataByValue bridge method is not defined');
 	}
 
-	async deleteRecordsBefore(_deleteObj) {
+	/** @param {...any} args */
+	async deleteRecordsBefore(...args) {
 		throw new Error('deleteRecordsBefore bridge method is not defined');
 	}
 
-	async deleteAuditLogsBefore(_deleteObj) {
+	/** @param {...any} args */
+	async deleteAuditLogsBefore(...args) {
 		throw new Error('deleteAuditLogsBefore bridge method is not defined');
 	}
 
-	async deleteTransactionLogsBefore(_deleteObj) {
+	/** @param {...any} args */
+	async deleteTransactionLogsBefore(...args) {
 		throw new Error('deleteTransactionLogsBefore bridge method is not defined');
 	}
 
-	async readAuditLog(_readAuditLogObj) {
+	/** @param {...any} args */
+	async readAuditLog(...args) {
 		throw new Error('readAuditLog bridge method is not defined');
 	}
 }

dataLayer/harperBridge/ResourceBridge.ts

@@ -83,14 +83,14 @@ export class ResourceBridge extends BridgeMethods {
 			{
 				conditions: searchObject.conditions,
 				//set the operator to always be lowercase for later evaluations
-				operator: searchObject.operator ? searchObject.operator.toLowerCase() : undefined,
+				operator: searchObject.operator ? (searchObject.operator as any).toLowerCase() : undefined,
 				limit: searchObject.limit,
 				offset: searchObject.offset,
 				reverse: searchObject.reverse,
 				select: getSelect(searchObject, table),
 				sort: searchObject.sort,
 				allowFullScan: true, // operations API can do full scans by default, but REST is more cautious about what it allows
-			},
+			} as any,
 			{
 				onlyIfCached: searchObject.onlyIfCached,
 				noCacheStore: searchObject.noCacheStore,
@@ -143,7 +143,7 @@ export class ResourceBridge extends BridgeMethods {
 			{
 				name: createAttributeObj.attribute,
 				indexed: createAttributeObj.indexed ?? true,
-			},
+			} as any,
 		]);
 		return `attribute ${createAttributeObj.schema}.${createAttributeObj.table}.${createAttributeObj.attribute} successfully created.`;
 	}
@@ -198,8 +198,9 @@ export class ResourceBridge extends BridgeMethods {
 		return this.upsertRecords(updateObj);
 	}
 
+	// @ts-expect-error property is not assignable to base type
 	async upsertRecords(upsertObj) {
-		const { attributes } = insertUpdateValidate(upsertObj);
+		const { attributes } = await insertUpdateValidate(upsertObj);
 
 		let new_attributes;
 		const Table = getDatabases()[upsertObj.schema][upsertObj.table];
@@ -266,7 +267,7 @@ export class ResourceBridge extends BridgeMethods {
 				keys.push(record[Table.primaryKey]);
 			}
 			return {
-				txn_time: transaction.timestamp,
+				txn_time: (transaction as any).timestamp,
 				written_hashes: keys,
 				new_attributes,
 				skipped_hashes: skipped,
@@ -288,7 +289,7 @@ export class ResourceBridge extends BridgeMethods {
 				if (await Table.delete(id, context)) deleted.push(id);
 				else skipped.push(id);
 			}
-			return createDeleteResponse(deleted, skipped, transaction.timestamp);
+			return createDeleteResponse(deleted, skipped, (transaction as any).timestamp);
 		});
 	}
 
@@ -303,6 +304,7 @@ export class ResourceBridge extends BridgeMethods {
 	 * }
 	 * @returns {undefined}
 	 */
+	// @ts-expect-error property is not assignable to base type
 	async deleteRecordsBefore(deleteObj) {
 		const Table = getDatabases()[deleteObj.schema][deleteObj.table];
 		if (!Table.createdTimeProperty) {
@@ -319,7 +321,7 @@ export class ResourceBridge extends BridgeMethods {
 					comparator: VALUE_SEARCH_COMPARATORS.LESS,
 				},
 			],
-		});
+		} as any);
 
 		let deleteCalled = false;
 		const deletedIds = [];
@@ -376,7 +378,7 @@ export class ResourceBridge extends BridgeMethods {
 	async getDataByHash(searchObject) {
 		const map = new Map();
 		searchObject._returnKeyValue = true;
-		for await (const { key, value } of getRecords(searchObject, true)) {
+		for await (const { key, value } of getRecords(searchObject, true) as any) {
 			map.set(key, value);
 		}
 		return map;
@@ -386,9 +388,10 @@ export class ResourceBridge extends BridgeMethods {
 		if (comparator && VALUE_SEARCH_COMPARATORS_REVERSE_LOOKUP[comparator] === undefined) {
 			throw new Error(`Value search comparator - ${comparator} - is not valid`);
 		}
-		if (searchObject.select !== undefined) searchObject.get_attributes = searchObject.select;
-		if (searchObject.search_attribute !== undefined) searchObject.attribute = searchObject.search_attribute;
-		if (searchObject.search_value !== undefined) searchObject.value = searchObject.search_value;
+		const obj = searchObject as any;
+		if (obj.select !== undefined) obj.get_attributes = obj.select;
+		if (obj.search_attribute !== undefined) obj.attribute = obj.search_attribute;
+		if (obj.search_value !== undefined) obj.value = obj.search_value;
 
 		const validationError = searchValidator(searchObject, 'value');
 		if (validationError) {
@@ -399,7 +402,7 @@ export class ResourceBridge extends BridgeMethods {
 		if (!table) {
 			throw new ClientError(`Table ${searchObject.table} not found`);
 		}
-		let value = searchObject.value;
+		let value: any = searchObject.value;
 		if (value.includes?.('*')) {
 			if (value.startsWith('*')) {
 				if (value.endsWith('*')) {
@@ -435,18 +438,19 @@ export class ResourceBridge extends BridgeMethods {
 				limit: searchObject.limit,
 				offset: searchObject.offset,
 				reverse: searchObject.reverse,
-				sort: searchObject.sort,
+				sort: (searchObject as any).sort,
 				select: getSelect(searchObject, table),
-			},
+			} as any,
 			{
-				onlyIfCached: searchObject.onlyIfCached,
-				noCacheStore: searchObject.noCacheStore,
-				noCache: searchObject.noCache,
-				replicateFrom: searchObject.replicateFrom,
+				onlyIfCached: (searchObject as any).onlyIfCached,
+				noCacheStore: (searchObject as any).noCacheStore,
+				noCache: (searchObject as any).noCache,
+				replicateFrom: (searchObject as any).replicateFrom,
 			}
 		);
 	}
 
+	// @ts-expect-error property is not assignable to base type
 	async getDataByValue(searchObject: SearchObject, comparator?: string) {
 		const map = new Map();
 		const table = getTable(searchObject);
@@ -469,6 +473,7 @@ export class ResourceBridge extends BridgeMethods {
 	 * @param deleteObj The request body
 	 * @returns
 	 */
+	// @ts-expect-error property is not assignable to base type
 	async deleteTransactionLogsBefore(deleteObj: {
 		schema?: string; // deprecated in favor of `database`
 		database?: string;
@@ -506,6 +511,7 @@ export class ResourceBridge extends BridgeMethods {
 		return totalResults;
 	}
 
+	// @ts-expect-error property is not assignable to base type
 	async readAuditLog(readAuditLogObj) {
 		const table = getTable(readAuditLogObj);
 		const histories = {};
@@ -599,7 +605,7 @@ function getRecords(searchObject, returnKeyValue?) {
 						const id = ids[i++];
 						let record;
 						try {
-							record = await table.get({ id, lazy, select }, context);
+							record = await table.get({ id, lazy, select } as any, context);
 							record = record && collapseData(record);
 						} catch (error) {
 							record = {

errors.txt

@@ -0,0 +1 @@
+server/serverHelpers/serverUtilities.ts(474,1): error TS1128: Declaration or statement expected.