Mirroristas/orbitdb
2
0
Fork 0
mirror of https://github.com/orbitdb/orbitdb.git synced 2025-10-07 22:57:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: Put entry and index before setting heads to avoid retrieving a head not in the database.

Browse Source
This commit is contained in:
Hayden Young 2025-05-17 01:22:58 +02:00
parent dc150b9cc2
commit 6f72fdddfe
3 changed files with 1118 additions and 2789 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3901
package-lock.json generated
View File

File diff suppressed because it is too large Load Diff

2
package.json
View File

@ -35,7 +35,7 @@
"c8": "^8.0.1", "c8": "^8.0.1",
"cross-env": "^7.0.3", "cross-env": "^7.0.3",
"fs-extra": "^11.2.0", "fs-extra": "^11.2.0",
"helia": "^5.2.1", "helia": "^5.3.0",
"it-all": "^3.0.4", "it-all": "^3.0.4",
"jsdoc": "^4.0.2", "jsdoc": "^4.0.2",
"mocha": "^10.2.0", "mocha": "^10.2.0",

4
src/oplog/oplog-store.js
View File

@ -48,12 +48,12 @@ const OplogStore = async ({ logHeads, entryStorage, headsStorage, indexStorage,
const setHead = async (entry) => { const setHead = async (entry) => {
const { hash, bytes } = await Entry.encode(entry, encryptEntryFn, encryptPayloadFn) const { hash, bytes } = await Entry.encode(entry, encryptEntryFn, encryptPayloadFn)
// The appended entry is now the latest head
await _heads.set([{ hash, next: entry.next }])
// Add entry to the entry storage // Add entry to the entry storage
await _entries.put(hash, bytes) await _entries.put(hash, bytes)
// Add entry to the entry index // Add entry to the entry index
await _index.put(hash, true) await _index.put(hash, true)
// The appended entry is now the latest head
await _heads.set([{ hash, next: entry.next }])
return hash return hash
} }