const PowergateIO = require('orbit-db-powergate-io')

const host = 'http://0.0.0.0:6002' // This is the default value
PowergateIO.create(host)
  .then((powergateio) => {
    console.log(powergateio.wallet) // Will be {} until funded
  })

const IPFS = require('ipfs')
const OrbitDB = require('orbit-db')
const PowergateIO = require('orbit-db-powergate-io')

;(async () => {
  const ipfs = await IPFS.create()
  const orbitdb = await OrbitDB.createInstance(ipfs)
  powergateio = await PowergateIO.create('https://my.hosted.powergate.node')

  const addresses = (await powergateio.ipfs.id()).addresses
  await ipfs.swarm.connect(addresses[0].toString())

  const db = await orbitdb.eventlog('powergate-test')
  for (let i = 0; i < 10; i++) {
    await db.add(`entry${i}`)
  }

  jobStatus = await powergateio.storeSnapshot(db.address.toString())
  console.log(jobStatus)

  // Wait until wallet is funded
  // Can take up to 2 minute on testnet
  console.log(powergateio.wallet)

  await powergateio.stop()
  await orbitdb.disconnect()
  await ipfs.stop()
})()

const IPFS = require('ipfs')
const OrbitDB = require('orbit-db')
const PowergateIO = require('orbit-db-powergate-io')

;(async () => {
  const ipfs = await IPFS.create()
  const orbitdb = await OrbitDB.createInstance(ipfs)
  const powergateio = await PowergateIO.create('https://my.hosted.powergate.node')

  const addresses = (await powergateio.ipfs.id()).addresses
  await ipfs.swarm.connect(addresses[0].toString())

  const dbAddr = '/orbitdb/zdpuAxkdoDum8Nk2VCxKkHZk8TzqAYPm86mVgoy7wagu2UcZB/powergate-test'
  const db2 = await orbitdb.open(dbAddr, { create: true })
  const snapshot = await powergateio.retrieveSnapshot(dbAddr)

  await db2._oplog.join(snapshots[0].log)
  await db2._updateIndex()
})()