nothinkdb - npm Package Compare versions

Comparing version 0.5.6 to 0.5.7

lib/relations.js

@@ -233,4 +233,2 @@ /* eslint no-shadow: 0 */
   function create(onePk, otherPk) {
-    var _relationTable$create;
-
     var _link2 = _slicedToArray(link, 2);
@@ -242,3 +240,15 @@
     var relationTable = link1.left.table;
-    var relation = relationTable.create((_relationTable$create = {}, _defineProperty(_relationTable$create, link1.left.field, onePk), _defineProperty(_relationTable$create, link2.left.field, otherPk), _relationTable$create));
+
+    var relation = undefined;
+    if (_lodash2['default'].isArray(otherPk)) {
+      relation = otherPk.map(function (otherPk) {
+        var _relationTable$create;
+
+        return relationTable.create((_relationTable$create = {}, _defineProperty(_relationTable$create, link1.left.field, onePk), _defineProperty(_relationTable$create, link2.left.field, otherPk), _relationTable$create));
+      });
+    } else {
+      var _relationTable$create2;
+
+      relation = relationTable.create((_relationTable$create2 = {}, _defineProperty(_relationTable$create2, link1.left.field, onePk), _defineProperty(_relationTable$create2, link2.left.field, otherPk), _relationTable$create2));
+    }
     return relationTable.insert(relation, { conflict: 'replace' });
@@ -254,5 +264,11 @@ }
     var relationTable = link1.left.table;
-    return relationTable.query().getAll(onePk, { index: link1.left.field }).filter(_defineProperty({}, link2.left.field, otherPk))
-    // .getAll(otherPk, { index: link2.left.field })
-    ['delete']();
+    var query = relationTable.query().getAll(onePk, { index: link1.left.field });
+    if (_lodash2['default'].isArray(otherPk)) {
+      query = query.filter(function (row) {
+        return _rethinkdb2['default'].expr(otherPk).contains(row(link2.left.field));
+      });
+    } else {
+      query = query.filter(_defineProperty({}, link2.left.field, otherPk));
+    }
+    return query['delete']();
   }
@@ -259,0 +275,0 @@

lib/Table.js

@@ -267,2 +267,6 @@ /* eslint no-shadow: 0, no-param-reassign: 0 */
 
+      var insertData = _extends({}, data);
+      if (this.hasField('createdAt')) {
+        insertData.createdAt = _rethinkdb2['default'].now();
+      }
       return this.assertIntegrate(data)['do'](function () {
@@ -293,5 +297,6 @@ var _query;
       return this.assertIntegrate(data)['do'](function () {
-        var _query$get;
+        var _query2;
 
-        return (_query$get = _this3.query().get(pk)).update.apply(_query$get, [updateData].concat(options));
+        var selectionQuery = _lodash2['default'].isArray(pk) ? (_query2 = _this3.query()).getAll.apply(_query2, _toConsumableArray(pk)) : _this3.query().get(pk);
+        return selectionQuery.update.apply(selectionQuery, [updateData].concat(options));
       });
@@ -321,3 +326,3 @@ }
     value: function _delete(pk) {
-      var _query$get2;
+      var _query$get;
 
@@ -328,3 +333,3 @@ for (var _len3 = arguments.length, options = Array(_len3 > 1 ? _len3 - 1 : 0), _key3 = 1; _key3 < _len3; _key3++) {
 
-      return (_query$get2 = this.query().get(pk))['delete'].apply(_query$get2, options);
+      return (_query$get = this.query().get(pk))['delete'].apply(_query$get, options);
     }
@@ -331,0 +336,0 @@ }, {

package.json

 {
   "name": "nothinkdb",
-  "version": "0.5.6",
+  "version": "0.5.7",
   "description": "Functional toolkit for rethinkdb",
@@ -5,0 +5,0 @@ "main": "lib/nothinkdb.js",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

35129

increased by2.64%

Lines of code

740

increased by2.64%

No dependency changes