multiple-values.js

const chai = require('chai')
chai.Should()
chai.use(require('chai-things'))
chai.use(require('@signalk/signalk-schema').chaiModule)
const freeport = require('freeport-promise')
const startServerP = require('./servertestutilities').startServerP

const rp = require('request-promise')

const uuid = 'urn:mrn:signalk:uuid:c0d79334-4e25-4245-8892-54e8ccc8021d'

const delta = {
  context: 'vessels.' + uuid,
  updates: [
    {
      source: {
        pgn: 128275,
        label: '/dev/actisense',
        src: '115'
      },
      values: [
        { path: 'navigation.trip.log', value: 43374 },
        { path: 'navigation.log', value: 17404540 }
      ]
    },
    {
      source: {
        label: '/dev/actisense',
        src: '115',
        pgn: 128267
      },
      values: [
        { path: 'navigation.courseOverGroundTrue', value: 172.9 },
        { path: 'navigation.speedOverGround', value: 3.85 }
      ]
    }
  ]
}

describe('Server', function () {
  let server, port

  before(async function () {
    port = await freeport()
    server = await startServerP(port)
  })

  after(async function () {
    await server.stop()
  })

  it('handles two deltas with signalk path', function () {
    const host = 'http://localhost:' + port
    const deltaUrl = host + '/signalk/v1/api/_test/delta'
    const restUrl = host + '/signalk/v1/api/'

    return rp({ url: deltaUrl, method: 'POST', json: delta })
      .then(function (body) {
        return rp({ url: restUrl, method: 'GET' })
      })
      .then(function (body) {
        const treeAfterFirstDelta = JSON.parse(body)
        treeAfterFirstDelta.vessels[uuid].should.have.nested.property(
          'navigation.trip.log.value',
          43374
        )
        treeAfterFirstDelta.vessels[uuid].should.have.nested.property(
          'navigation.trip.log.$source',
          'deltaFromHttp.115'
        )
        treeAfterFirstDelta.should.be.validSignalK

        delta.updates[0].values[0].value = 1
        return rp({ url: deltaUrl, method: 'POST', json: delta })
      })
      .then(function (body) {
        return rp({ url: restUrl, method: 'GET' })
      })
      .then(function (body) {
        const treeAfterSecondDelta = JSON.parse(body)
        treeAfterSecondDelta.vessels[uuid].should.have.nested.property(
          'navigation.trip.log.value',
          1
        )
        treeAfterSecondDelta.vessels[uuid].should.have.nested.property(
          'navigation.trip.log.$source',
          'deltaFromHttp.115'
        )
        treeAfterSecondDelta.should.be.validSignalK

        delta.updates[0].values[0].value = 2
        delta.updates[0].source.src = '116'
        return rp({ url: deltaUrl, method: 'POST', json: delta })
      })
      .then(function (body) {
        return rp({ url: restUrl, method: 'GET' })
      })
      .then(function (body) {
        const treeAfterOtherSourceDelta = JSON.parse(body)
        treeAfterOtherSourceDelta.vessels[uuid].should.have.nested.property(
          'navigation.trip.log.value',
          2
        )
        treeAfterOtherSourceDelta.vessels[uuid].should.have.nested.property(
          'navigation.trip.log.$source',
          'deltaFromHttp.116'
        )
        treeAfterOtherSourceDelta.vessels[uuid].navigation.trip.log.values[
          'deltaFromHttp.115'
        ].value.should.equal(1)
        treeAfterOtherSourceDelta.vessels[uuid].navigation.trip.log.values[
          'deltaFromHttp.116'
        ].value.should.equal(2)
        treeAfterOtherSourceDelta.should.be.validSignalK
      })
  }).timeout(4000)
})