test.js

var core    = require('rijs.core').default
  , data    = require('rijs.data').default
  , db      = require('rijs.db').default
  , update  = require('utilise/update')
  , remove  = require('utilise/remove')
  , falsy   = require('utilise/falsy')
  , keys    = require('utilise/keys')
  , push    = require('utilise/push')
  , pop     = require('utilise/pop')
  , expect  = require('chai').expect
  , mysql   = require('./').default
  , mockery = require('mockery')
  , sql, next

describe('MySQL', function(){

  before(function(){ 
    mockery.enable()
    mockery.registerMock('mysql', { 
      createPool: function(){ 
        return { 
          escape: function(d){ return "'" + d + "'" }
        , query: function(d, fn){ next = fn; console.log('sql', sql = d) }
        }
      }
    })
  })

  beforeEach(function(){
    sql = ''
  })

  after(function(){ 
    mockery.disable()
  })

  // it('should create connection hooks', function(){  
  //   var ripple = db(mysql(data(core())), { db: { mysql: 'mysql://user:password@host:port/database' }})
  //   expect(keys(ripple.connections)).to.be.eql(['mysql'])
  //   expect(ripple.connections.mysql.add).to.be.a('function')
  //   expect(ripple.connections.mysql.update).to.be.a('function')
  //   expect(ripple.connections.mysql.remove).to.be.a('function')
  // })

  // it('should create correct load SQL and behaviour', function(){  
  //   var ripple = db(mysql(data(core())), { db: { mysql: 'mysql://user:password@host:port/database' }})
  //   ripple('foo', [1,2,3])
  //   expect(sql).to.be.eql('SHOW COLUMNS FROM foo')
  //   next(null, [{ Field: 'name' }, { Field: 'id' }])
  //   expect(ripple.resources.foo.headers.mysql.table).to.be.eql('foo')
  //   expect(sql).to.be.eql('SELECT * FROM foo')
  //   next(null, [1,2,3,4])
  //   expect(ripple('foo')).to.be.eql([1,2,3,4])
  //   next = null
  //   ripple('foo', [1,2,3])
  //   expect(next).to.be.not.ok
  // })

  // it('should create correct insert SQL and behaviour', function(){  
  //   var ripple = db(mysql(data(core())), { db: { mysql: 'mysql://user:password@host:port/database' }})
  //     , record = { name: 'foo' }

  //   ripple('foo', [])
  //   next(null, [{ Field: 'name' }, { Field: 'id' }])
  //   next(null, [])
  //   push(record)(ripple('foo'))
  //   expect(sql).to.eql("INSERT INTO foo (`name`) VALUES ('foo');")
  //   next(null, { insertId: 7 })
  //   expect(ripple('foo')).to.eql([ { name: 'foo', id: 7 } ])
  // })

  // it('should create correct update SQL and behaviour', function(){  
  //   var ripple = db(mysql(data(core())), { db: { mysql: 'mysql://user:password@host:port/database' }})
  //     , record = { id: 7 }

  //   ripple('foo', [])
  //   next(null, [{ Field: 'name' }, { Field: 'id' }])
  //   next(null, [record])
  //   update(0, (ripple('foo')[0].name = 'foo', ripple('foo')[0]))(ripple('foo'))
  //   expect(sql).to.eql("UPDATE foo SET `name`='foo' WHERE id = 7;")
  //   next(null, {})
  //   expect(ripple('foo')).to.eql([ { name: 'foo', id: 7 } ])
  // })

  // it('should create correct update SQL and behaviour - deep', function(){  
  //   var ripple = db(mysql(data(core())), { db: { mysql: 'mysql://user:password@host:port/database' }})
  //     , record = { id: 7 }

  //   ripple('foo', [])
  //   next(null, [{ Field: 'name' }, { Field: 'city' }, { Field: 'id' }])
  //   next(null, [record])
  //   update('0.name', 'foo')(ripple('foo'))
  //   expect(sql).to.eql("UPDATE foo SET `name`='foo' WHERE id = 7;")
  //   next(null, {})
  //   update('0.city', 'bar')(ripple('foo'))
  //   expect(sql).to.eql("UPDATE foo SET `city`='bar' WHERE id = 7;")
  //   next(null, {})
  //   expect(ripple('foo')).to.eql([ { name: 'foo', city: 'bar', id: 7 } ])
  // })

  // it('should fail on deep update not in fields', function(){  
  //   var ripple = db(mysql(data(core())), { db: { mysql: 'mysql://user:password@host:port/database' }})
  //     , record = { name: 'foo', id: 7 }

  //   ripple('foo', [])
  //   next(null, [{ Field: 'name' }, { Field: 'id' }])
  //   next(null, [record])
  //   sql = ''
  //   update('0.city', 'bar')(ripple('foo'))
  //   expect(sql).to.eql("")
  //   expect(ripple('foo')).to.eql([ { name: 'foo', city: 'bar', id: 7 } ])
  // })

  // it('should create correct remove SQL and behaviour', function(){  
  //   var ripple = db(mysql(data(core())), { db: { mysql: 'mysql://user:password@host:port/database' }})
  //     , record = { id: 7 }

  //   ripple('foo', [])
  //   next(null, [{ Field: 'name' }, { Field: 'id' }])
  //   next(null, [record])
  //   pop(ripple('foo'))
  //   expect(sql).to.eql("DELETE FROM foo WHERE id = 7;")
  //   next(null, {})
  //   expect(ripple('foo')).to.eql([])
  // })

  // it('should skip if resource not linked to table', function(){  
  //   var ripple = db(mysql(data(core())), { db: { mysql: 'mysql://user:password@host:port/database' }})
  //     , record = { name: 'foo' }

  //   ripple('foo', [])
  //   next({ code: 'ER_NO_SUCH_TABLE' })
  //   expect(ripple.resources.foo.headers.mysql.table === '').to.be.ok
  //   sql = ''

  //   push(record)(ripple('foo'))
  //   expect(sql).to.eql('')
  //   expect(ripple('foo')).to.eql([ { name: 'foo' } ])
  // })

  // it('should not do anything with non-objects', function(){  
  //   var ripple = db(mysql(data(core())), { db: { mysql: 'mysql://user:password@host:port/database' }})
  //     , record = 'foo'

  //   ripple('foo', [])
  //   next(null, [{ Field: 'name' }, { Field: 'id' }])
  //   next(null, [])
  //   sql = ''
  //   push(record)(ripple('foo'))
  //   expect(sql).to.eql('')
  //   expect(ripple('foo')).to.eql(['foo'])
  // })

  // it('should deal with mysql errors (crud)', function(){  
  //   var ripple = db(mysql(data(core())), { db: { mysql: 'mysql://user:password@host:port/database' }})
  //     , record = { name: 'foo' }

  //   ripple('foo', [])
  //   next(null, [{ Field: 'name' }, { Field: 'id' }])
  //   next(null, [])
  //   push(record)(ripple('foo'))
  //   expect(sql).to.eql("INSERT INTO foo (`name`) VALUES ('foo');")
  //   next('err')
  //   expect(ripple('foo')).to.eql([ { name: 'foo' } ])
  // })

  // it('should deal with mysql errors (show table)', function(){  
  //   var ripple = db(mysql(data(core())), { db: { mysql: 'mysql://user:password@host:port/database' }})
  //     , record = { name: 'foo' }

  //   ripple('foo', [])
  //   next('err')
  //   expect(ripple('foo')).to.eql([])
  // })

  // it('should deal with mysql errors (select table)', function(){  
  //   var ripple = db(mysql(data(core())), { db: { mysql: 'mysql://user:password@host:port/database' }})
  //     , record = { name: 'foo' }

  //   ripple('foo', [])
  //   next(null, [{ Field: 'name' }, { Field: 'id' }])
  //   next('err', [])
  //   expect(ripple('foo')).to.eql([])
  // })

  // it('should skip props if not in db', function(){  
  //   var ripple = db(mysql(data(core())), { db: { mysql: 'mysql://user:password@host:port/database' }})
  //     , record = { id: 7 }

  //   ripple('foo', [])
  //   next(null, [{ Field: 'name' }, { Field: 'id' }])
  //   next(null, [record])
  //   sql = ''
  //   update('0', { name: 'foo', baz: 'baz', id: 7 })(ripple('foo'))
  //   expect(sql).to.eql("UPDATE foo SET `name`='foo' WHERE id = 7;")
  //   next(null, {})
  //   expect(ripple('foo')).to.eql([ { name: 'foo', baz: 'baz', id: 7 } ])
  // })

  // it('should skip props if not in db - deep', function(){  
  //   var ripple = db(mysql(data(core())), { db: { mysql: 'mysql://user:password@host:port/database' }})
  //     , record = { id: 7 }

  //   ripple('foo', [])
  //   next(null, [{ Field: 'name' }, { Field: 'id' }])
  //   next(null, [record])
  //   sql = ''
  //   update('0.baz', 'baz')(ripple('foo'))
  //   expect(sql).to.eql('')
  //   expect(ripple('foo')).to.eql([ { baz: 'baz', id: 7 } ])
  // })

  // it('should strip mysql headers before sending', function(){ 
  //   var ripple = db(mysql(data(core())), { db: { mysql: 'mysql://user:password@host:port/database' }})
  //   ripple('foo', [1,2,3])
  //   expect(sql).to.be.eql('SHOW COLUMNS FROM foo')
  //   next(null, [{ Field: 'name' }, { Field: 'id' }])
  //   expect(ripple.resources.foo.headers.mysql.table).to.be.eql('foo')
  //   expect(ripple.resources.foo.headers.mysql.fields).to.be.eql(['name', 'id'])
  //   expect(sql).to.be.eql('SELECT * FROM foo')
  //   next(null, [1,2,3,4])
  //   expect(ripple('foo')).to.be.eql([1,2,3,4])

  //   expect('loaded' in ripple.resources.foo.headers.mysql).to.be.ok
  //   expect('fields' in ripple.resources.foo.headers.mysql).to.be.ok
  //   expect('table'  in ripple.resources.foo.headers.mysql).to.be.ok

  //   var headers = ripple.types['application/data'].to(ripple.resources.foo).headers
  //   expect('mysql' in headers).to.not.be.ok
  // })

  // it('should allow blocking action', function(){  
  //   var ripple = db(mysql(data(core())), { db: { mysql: 'mysql://user:password@host:port/database' }})
  //     , record = { name: 'foo' }

  //   ripple('foo', [], { mysql: { to: falsy }})
  //   next(null, [{ Field: 'name' }, { Field: 'id' }])
  //   next(null, [])
  //   next = null
  //   push(record)(ripple('foo'))
  //   expect(sql).to.be.not.ok
  //   expect(next).to.be.not.ok
  //   expect(ripple('foo')).to.eql([ { name: 'foo' } ])
  // })

})