Mirroristas/orbitdb
2
0
Fork 0
mirror of https://github.com/orbitdb/orbitdb.git synced 2025-05-22 14:56:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add tracking of last write

Browse Source
This commit is contained in:
haad 2016-03-23 13:47:46 +01:00
parent 5baf2600b9
commit b748753b2f
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/OrbitDB.js
View File

@ -15,6 +15,7 @@ class OrbitDB {
this._logs = {}; this._logs = {};
this.events = {}; this.events = {};
this.options = options || {}; this.options = options || {};
this.lastWrite = null;
} }
/* Public methods */ /* Public methods */
@ -29,7 +30,7 @@ class OrbitDB {
sync(channel, hash) { sync(channel, hash) {
// console.log("--> Head:", hash) // console.log("--> Head:", hash)
if(hash && this._logs[channel]) { if(hash && hash !== this.lastWrite && this._logs[channel]) {
this.events[channel].emit('load', 'sync', channel); this.events[channel].emit('load', 'sync', channel);
const oldCount = this._logs[channel].items.length; const oldCount = this._logs[channel].items.length;
const other = await(Log.fromIpfsHash(this._ipfs, hash)); const other = await(Log.fromIpfsHash(this._ipfs, hash));
@ -125,8 +126,9 @@ class OrbitDB {
_write(channel, password, operation, key, value) { _write(channel, password, operation, key, value) {
const hash = await(DBOperation.create(this._ipfs, this._logs[channel], this.user, operation, key, value)); const hash = await(DBOperation.create(this._ipfs, this._logs[channel], this.user, operation, key, value));
const listHash = await(Log.getIpfsHash(this._ipfs, this._logs[channel])); const listHash = await(Log.getIpfsHash(this._ipfs, this._logs[channel]));
this.events[channel].emit('write', channel, listHash); this.lastWrite = listHash;
Cache.set(channel, listHash); Cache.set(channel, listHash);
this.events[channel].emit('write', channel, listHash);
return hash; return hash;
} }