level-model/test.js

var test = require('tape')
var levelup = require('levelup')
var through = require('through2')
var inherits = require('util').inherits

var model = require('./index')

var db = levelup('test', { 
  db: require('memdown'),
  valueEncoding: 'json'
})

function Example (db, opts) {
  model.call(this, db, opts)
}

inherits(Example, model)

var example = new Example(db, {
  modelName: 'example',
  properties: {
    key: { type: 'string' },
    test: { type: 'string' },
    ok: { type: 'integer' }
  },
  indexKeys: ['test', 'ok'],
  required: ['test']
})

test('model exists', function (t) {
  t.ok(example, 'example model exists')
  t.ok(example.schema, 'schema of example model exists')
  t.end()
})

test('create a model', function (t) {
  var data = {
    test: 'first instance!',
    ok: 1
  }

  example.create(data, function (err, instance) {
    t.ifError(err, 'no error')
    t.ok(instance, 'instance of model exists')
    t.ok(instance.key, 'has a key')
    t.end()
  })
})

test('get a model', function (t) {
  var data = {
    test: 'second instance!',
    ok: 2
  }

  example.create(data, function (err, instance) {
    example.get(instance.key, function (err, retrieved) {
      t.ifError(err, 'no error')
      t.ok(retrieved, 'instance of model exists')
      t.ok(retrieved.key, 'has a key')
      t.end()
    })
  })
})

test('update a model', function (t) {
  var data = {
    test: 'third instance!',
    ok: 3
  }

  example.create(data, function (err, instance) {
    instance.ok = 2

    example.update(instance, function (err, updated) {
      t.ifError(err, 'no error')
      t.equals(updated.ok, 2)
      t.end()
    })
  })
})

test('reject model creation if it doesnt fit the schema' , function (t) {
  var data = {
    test: 'huh',
    ok: 'oops' // should be an integer
  }

  example.create(data, function (err, instance) {
    t.ok(err, 'error saying the object does not match the schema')
    t.notOk(instance, 'instance of model not created')
    t.end()
  })
})

test('list models', function (t) {
  var count = 0

  function iterator (item, enc, next) {
    count++
    next()
  }

  function end () {
    t.equals(count, 3)
    t.end()
  }

  example.createReadStream().pipe(through.obj(iterator, end))
})

test('find models by indexed key', function (t) {
  var count = 0

  function iterator (item, enc, next) {
    count++
    next()
  }

  function end (a, b, c) {
    t.end()
  }

  example.find('ok', 2).pipe(through.obj(iterator, end))
})

test('create, update, delete events', function (t) {
  var data = {
    test: 'fourth instance!',
    ok: 4
  }
  
  example.on('create', function (model) {
    t.ok(model)
  })
  
  example.on('update', function (model) {
    t.ok('model')
  })
  
  example.on('delete', function () {
    t.ok(true)
  })

  example.create(data, function (err, instance) {
    instance.ok = 2

    example.update(instance, function (err, updated) {
      t.ifError(err, 'no error')
      t.equals(updated.ok, 2)
      t.end()
    })
  })
})

test('delete models', function (t) {
  example.createReadStream()
    .on('data', function (data) {
      example.delete(data.key, function (err) {
        t.ifError(err, 'no error')
      })
    })
    .on('end', function () {
      t.end()
    })
})