Copy database in binary mode

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);
 	let written;
 	let outstandingWrites = 0;
 	// we use a single transaction to get a snapshot, also we can't use snapshot: false on dupsort dbs
@@ -187,22 +187,31 @@
 			// we want to directly copy bytes so we don't have the overhead of
 			// encoding and decoding
 			dbiInit.encoding = 'binary';
 			dbiInit.compression = existingCompression;
 			//dbiInit.keyEncoding = 'binary';
 			const sourceDbi = rootStore.openDB(key, dbiInit);
 			sourceDbi.decoder = null;
 			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);
 		}
 		if (sourceAuditStore) {
-			const targetAuditStore = rootStore.openDB(AUDIT_STORE_NAME, AUDIT_STORE_OPTIONS);
+			// Copy audit store in binary mode to avoid encode/decode issues with symbol-keyed metadata entries
+			const auditBinaryOptions: any = {
+				keyEncoder: AUDIT_STORE_OPTIONS.keyEncoder,
+				encoding: 'binary',
+			};
+			const sourceAuditBinary: any = rootStore.openDB(AUDIT_STORE_NAME, auditBinaryOptions);
+			sourceAuditBinary.decoder = null;
+			sourceAuditBinary.decoderCopies = false;
+			const targetAuditStore: any = targetEnv.openDB(AUDIT_STORE_NAME, auditBinaryOptions);
+			targetAuditStore.encoder = null;
 			console.log('copying audit log for', sourceDatabase, 'to', targetDatabasePath);
-			copyDbi(sourceAuditStore, targetAuditStore, false, transaction);
+			await copyDbi(sourceAuditBinary, targetAuditStore, false, transaction);
 		}
 
 		async function copyDbi(sourceDbi, targetDbi, isPrimary, transaction) {
@@ -289,7 +298,7 @@
 	}
 	let db;
 	if (options.dupSort) {
 		db = RocksDatabase.open(new RocksIndexStore(path, options));
 	} else {
 		db = RocksDatabase.open(path, options);
 		db.encoder.name = options.name;