tyleryasaka
commented
5 years ago @subhasisbanik I know what the cause of this issue is (I ran into the same thing myself). db.load() resolves only after the database has finished loading from storage into memory. It does not wait for the database to be replicated from peers. The replication happens in the background, and is likely completing a split second after db.get('test') is run. That's why when you run the code a second time, you get the expected value.
If you want to wait for the replication to finish, you can listen for the replicated event. E.g.
await Promise.resolve(resolve => {
db.events.on('replicated', resolve)
})Beware, though; if no replication occurs, the above code will hang indefinitely. (For example, if the peers are already fully in sync.) This is a major problem; I don't know of a good solution off the top of my head, though I am looking into options. I'll report back if I find anything.
subhasisbanik
aphelionz
I have prepared a cluster of 2 nodes in IPFS with IPFS Daemon and swarm key. I am running orbitdb and connecting to the IPFS node with "ipfs-api" in HTTP protocol. I am able to post data through orbitdb (feed, keyvalue) from one node and am able to fetch it back in another orbitdb instance connected to the other node. The issue is that when I am calling a "put" in one instance and trying to "get" it from another instance, its not able to "get" it the first time. But if the same "get" is being called from the same node the second time, its showing the data.
I am not sure how orbitdb sync works but below is the code that I am running.
Node 1----------- const OrbitDB = require('orbit-db'); const IpfsApi = require('ipfs-api'); const ipfs = IpfsApi('localhost', '5002', {protocol: 'http'}) const orbitdb = new OrbitDB(ipfs); const writePermissions = [orbitdb.key.getPublic('hex'),];
const kv = await orbitdb.kvstore('new-db',{write:writePermissions});
await kv.load();
await kv.put('test', 80);
Node 2------------ const OrbitDB = require('orbit-db'); const IpfsApi = require('ipfs-api'); const ipfs = IpfsApi('localhost', '5002', {protocol: 'http'}) const orbitdb = new OrbitDB(ipfs); const db = await orbitdb.open('/orbitdb/QmPJ4QXJDfBjPKB6JKZcqmrDfDxbubC85BMQvxDcR2Gunb/new-db'); await db.load(); db.get('test');
Please help!!!