Skip to content

Commit

Permalink
Updated modelFunctions & fx signatures to include server as arg 0
Browse files Browse the repository at this point in the history
  • Loading branch information
4umfreak committed Sep 8, 2020
1 parent 8e7ffd4 commit cf4299b
Show file tree
Hide file tree
Showing 2 changed files with 17 additions and 17 deletions.
18 changes: 9 additions & 9 deletions lib/modelFunctions.js
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ module.exports = function ModelFunctions(options) {
collations
});

function modelFind(entity, req) {
function modelFind(server, entity, req) {
const model = entity.model;
return new Promise(function (resolve, reject) {
const query = handlerUtils.buildQuery(model.find(), req, entity);
Expand Down Expand Up @@ -69,7 +69,7 @@ module.exports = function ModelFunctions(options) {
});
}

function modelFindById(entity, req) {
function modelFindById(server, entity, req) {
const model = entity.model;
return new Promise(function (resolve, reject) {
let id;
Expand Down Expand Up @@ -154,7 +154,7 @@ module.exports = function ModelFunctions(options) {
});
}

function modelFindBinary(entity, req) {
function modelFindBinary(server, entity, req) {
const model = entity.model;
return new Promise(function (resolve, reject) {
const pathOpts = model.schema.path(req.params.__attribute).options;
Expand Down Expand Up @@ -196,7 +196,7 @@ module.exports = function ModelFunctions(options) {
});
}

function modelCount(entity, req) {
function modelCount(server, entity, req) {
const model = entity.model;
return new Promise(function (resolve, reject) {

Expand All @@ -217,7 +217,7 @@ module.exports = function ModelFunctions(options) {
});
}

function modelInsert(entity, req) {
function modelInsert(server, entity, req) {
const model = entity.model;
return new Promise(function (resolve, reject) {
const values = Object.assign({}, req.body, req.files);
Expand Down Expand Up @@ -271,7 +271,7 @@ module.exports = function ModelFunctions(options) {
});
}

function modelDelete(entity, req) {
function modelDelete(server, entity, req) {
const model = entity.model;
return new Promise(function (resolve, reject) {

Expand Down Expand Up @@ -302,7 +302,7 @@ module.exports = function ModelFunctions(options) {
});
}

function modelDeleteById(entity, req) {
function modelDeleteById(server, entity, req) {
const model = entity.model;
return new Promise(function (resolve, reject) {
let id;
Expand Down Expand Up @@ -340,7 +340,7 @@ module.exports = function ModelFunctions(options) {
});
}

function modelDeleteBatch(entity, req) {
function modelDeleteBatch(server, entity, req) {
const model = entity.model;
var p = new Promise(function (resolve, reject) {
const deleteIdList = (req.body || {}).id;
Expand Down Expand Up @@ -387,7 +387,7 @@ module.exports = function ModelFunctions(options) {
});
}

function modelUpdateById(entity, req) {
function modelUpdateById(server, entity, req) {
const model = entity.model;
return new Promise(function (resolve, reject) {
let id;
Expand Down
16 changes: 8 additions & 8 deletions lib/modelHandler.js
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ module.exports = function ModelHandler(options) {
debug(`HandleFind on ${entity.modelName}`);

const modelFx = entity.fx || modelFunctions.modelFind;
modelFx(entity, req)
modelFx(server, entity, req)
.then((data) => {
const responder = entity.responder || jsonArrayResponder;
return responder(server, entity, req, res, data);
Expand All @@ -106,7 +106,7 @@ module.exports = function ModelHandler(options) {
const entity = getEntity(req, "findById");
debug(`HandleFindById on ${entity.modelName}`);
const modelFx = entity.fx || modelFunctions.modelFindById;
modelFx(entity, req)
modelFx(server, entity, req)
.then((data) => {
const responder = entity.responder || jsonResponder;
return responder(server, entity, req, res, {item: data});
Expand All @@ -125,7 +125,7 @@ module.exports = function ModelHandler(options) {
const entity = getEntity(req, "findBinary");
debug(`HandleFindBinary on ${entity.modelName}`);
const modelFx = entity.fx || modelFunctions.modelFindBinary;
modelFx(entity, req)
modelFx(server, entity, req)
.then((data) => {
const responder = entity.responder || binaryResponder;
return responder(server, entity, req, res, data);
Expand All @@ -141,7 +141,7 @@ module.exports = function ModelHandler(options) {
const entity = getEntity(req, "findCount");
debug(`HandleCount on ${entity.modelName}`);
const modelFx = entity.fx || modelFunctions.modelCount;
modelFx(entity, req)
modelFx(server, entity, req)
.then((data) => {
const responder = entity.responder || jsonResponder;
return responder(server, entity, req, res, {item: data});
Expand All @@ -157,7 +157,7 @@ module.exports = function ModelHandler(options) {
const entity = getEntity(req, "insert");
debug(`HandleInsert on ${entity.modelName}`);
const modelFx = entity.fx || modelFunctions.modelInsert;
modelFx(entity, req)
modelFx(server, entity, req)
.then((data) => {
const responder = entity.responder || jsonResponder;
return responder(server, entity, req, res, data);
Expand Down Expand Up @@ -189,7 +189,7 @@ module.exports = function ModelHandler(options) {
const entity = getEntity(req, "deleteById");
debug(`HandleDeleteById on ${entity.modelName}`);
const modelFx = entity.fx || modelFunctions.modelDeleteById;
modelFx(entity, req)
modelFx(server, entity, req)
.then((data) => {
const responder = entity.responder || jsonResponder;
return responder(server, entity, req, res, {item: data});
Expand All @@ -205,7 +205,7 @@ module.exports = function ModelHandler(options) {
const entity = getEntity(req, "deleteBatch");
debug(`HandleDeleteBatch on ${entity.modelName}`);
const modelFx = entity.fx || modelFunctions.handleDeleteBatch;
modelFx(entity, req)
modelFx(server, entity, req)
.then((data) => {
const responder = entity.responder || jsonResponder;
return responder(server, entity, req, res, {item: data});
Expand All @@ -221,7 +221,7 @@ module.exports = function ModelHandler(options) {
const entity = getEntity(req, "updateById");
debug(`HandleUpdateById on ${entity.modelName}`);
const modelFx = entity.fx || modelFunctions.modelUpdateById;
modelFx(entity, req)
modelFx(server, entity, req)
.then((data) => {
const responder = entity.responder || jsonResponder;
return responder(server, entity, req, res, data);
Expand Down

0 comments on commit cf4299b

Please sign in to comment.