feat(errors): write-errors (#16)

* feat(errors): write-errors

lib/model/model.js

@@ -2,6 +2,7 @@ const debug = require('debug')('requelize:model')
 
 const Joi = require('joi')
 const Query = require('./query')
+const RequelizeError = require('../error')
 const validateSchema = require('./util/validateSchema')
 const bindSchemaToModel = require('./util/bindSchemaToModel')
 const bindVirtuals = require('./util/bindVirtuals')
@@ -254,6 +255,11 @@ function createModel (requelize) {
           .then(() => takeEvents('saving', Model, this))
           .then(() => Model.parse(false).insert(this._data, { conflict: 'update' }).run())
           .then((res) => {
+            // istanbul ignore if
+            if (res.errors.length > 0) {
+              return Promise.reject(new RequelizeError('WriteError', res.errors))
+            }
+
             if (res.generated_keys) {
               debug(`adding ${Model._name}:${Model._options.primaryKey} = ${res.generated_keys[0]}`)
               this[Model._options.primaryKey] = res.generated_keys[0]
@@ -288,7 +294,12 @@ function createModel (requelize) {
             .delete()
             .run()
           )
-          .then(() => {
+          .then((res) => {
+            // istanbul ignore if
+            if (res.errors.length > 0) {
+              return Promise.reject(new RequelizeError('WriteError', res.errors))
+            }
+
             this[options.primaryKey] = null
 
             return takeEvents('deleted', Model, this)

package.json

@@ -1,6 +1,6 @@
 {
   "name": "requelize",
-  "version": "0.6.2",
+  "version": "0.6.3",
   "description": "RethinkDB ORM",
   "main": "index.js",
   "repository": "https://github.com/buckless/requelize.git",