github-starred/acebase
2
0
Fork 0
mirror of https://github.com/appy-one/acebase.git synced 2026-06-30 06:02:02 -06:00
Code Issues 20 Projects Packages Wiki Activity Actions

Merge pull request #214 from appy-one/fix/transaction-logging

Browse source 
Transaction logging fixes
This commit is contained in:
Ewout Stortenbeker 2023-04-11 20:46:27 +02:00 • committed by GitHub
commit d111c7d96e
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 10 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

14
src/storage/binary/index.ts
View file

@ -143,7 +143,7 @@ export class AceBaseStorage extends Storage {
this.type = settings.type;
if (this.type === 'data' && settings.transactions.log === true) {
// Get/create storage for mutations logging
const txSettings = new AceBaseStorageSettings({ type: 'transaction', path: settings.path, removeVoidProperties: true, transactions: settings.transactions });
const txSettings = new AceBaseStorageSettings({ type: 'transaction', path: settings.path, removeVoidProperties: true, transactions: settings.transactions, ipc: settings.ipc });
this.txStorage = new AceBaseStorage(name, txSettings, { logLevel: 'error' });
}
@ -1576,18 +1576,24 @@ export class AceBaseStorage extends Storage {
let count = 0;
const oldestValidCursor = this.oldestValidCursor, expiredTransactions: string[] = [], inspectFurther: string[] = [];
await this.getChildren('history', { tid })
.next(childInfo => {
try {
await this.getChildren('history', { tid }).next(childInfo => {
const txCursor = childInfo.key.slice(0, cursor.length);
if (txCursor < oldestValidCursor) { expiredTransactions.push(childInfo.key); }
if (txCursor < cursor) { return; }
if (txCursor === cursor) {
// cuid timestamp bytes are equal - perform extra check on this mutation later to find out if we have to include it in the results
// cuid timestamp bytes are equal - perform extra check on this mutation later to find out if we have to include it in the results
inspectFurther.push(childInfo.key);
}
count++;
check(childInfo.key);
});
}
catch (err) {
if (!(err instanceof NodeNotFoundError)) {
throw err;
}
}
allEnumerated = true;
if (count > 0) {