const tape = require('tape')
const Hypervisor = require('../hypervisor.js')
const Message = require('primea-message')
const Graph = require('ipld-graph-builder')
const IPFS = require('ipfs')

const ipfs = new IPFS()
const graph = new Graph(ipfs)

ipfs.on('start', async () => {
  tape('send and reciving messages', async t => {
    const root = {}
    try {
      const hypervisor = new Hypervisor(graph, root)
      const path = 'one/two/three'
      await hypervisor.set(path, {
        code: message => {
          t.pass('got message')
          t.end()
          return {}
        }
      })
      hypervisor.send(new Message({
        to: path
      }))
    } catch (e) {
      // console.log(e)
    }
  })

  tape('reverts', async t => {
    const root = {}
    const hypervisor = new Hypervisor(graph, root)
    const path = 'one/two/three'
    const path2 = 'one/two/three/four'
    await hypervisor.set(path, {
      code: async (message, kernel) => {
        await kernel.send(new Message({
          to: 'four'
        }))
        throw new Error('vm exception')
      }
    })

    await hypervisor.set(path2, {
      code: (message, kernel) => {
        kernel.graph.set(kernel.state, 'something', {
          somevalue: 'value'
        })
        return 'done!'
      }
    })

    const message = new Message({
      to: path
    })
    hypervisor.send(message)
    const result = await message.result()
    t.equals(result.exception, true)
    const expectedRoot = '{"one":{"two":{"three":{"/":{"four":{"/":{}}}}}}}'
    t.equals(JSON.stringify(root), expectedRoot, 'should produce correct root')
    t.end()
    process.exit()
  })
})