54 lines
2.0 KiB
JavaScript
54 lines
2.0 KiB
JavaScript
|
'use strict';
|
||
|
|
const httpStatus = require('http-status');
|
||
|
|
const Sequelize = require('sequelize');
|
||
|
|
const generateControllers = require('../../core/controllers');
|
||
|
|
const { buildContext } = require('../../core/controllers');
|
||
|
|
const pushService = require('./push.service');
|
||
|
|
const { extractParamsFromRequest, handleErrorResponse, handleResultResponse } = require('../../helpers/controller.helper');
|
||
|
|
|
||
|
|
// Module Name
|
||
|
|
const MODULE_NAME = '[push.controller]';
|
||
|
|
const controllerOptions = { MODULE_NAME };
|
||
|
|
|
||
|
|
const extraControllers = {
|
||
|
|
createOrUpdate: (config) => {
|
||
|
|
return async (req, res, next) => {
|
||
|
|
try {
|
||
|
|
const context = buildContext(req, config);
|
||
|
|
var data = {
|
||
|
|
token: req.body.token,
|
||
|
|
valid: 1,
|
||
|
|
userId: context.user.id
|
||
|
|
};
|
||
|
|
|
||
|
|
let params = extractParamsFromRequest(req, res, {
|
||
|
|
includeAll: false,
|
||
|
|
paginate: { limit: 1, page: 1 },
|
||
|
|
params: {
|
||
|
|
userId: context.user.id,
|
||
|
|
token: data.token,
|
||
|
|
}
|
||
|
|
});
|
||
|
|
|
||
|
|
// Buscamos el token y el usuario
|
||
|
|
let result = await pushService.fetchOne(params, context);
|
||
|
|
if (!result) {
|
||
|
|
// Dar de alta el token
|
||
|
|
console.log('>> Dar de alta el token');
|
||
|
|
result = await pushService.create(data, context);
|
||
|
|
} else {
|
||
|
|
// Actualizar el token
|
||
|
|
console.log('>> Actualizar el token');
|
||
|
|
result = await pushService.update(params.params, data, context);
|
||
|
|
}
|
||
|
|
} catch(error) {
|
||
|
|
console.error(error);
|
||
|
|
} finally {
|
||
|
|
// En todo caso devolver OK al cliente
|
||
|
|
return handleResultResponse('OK', null, null, res, httpStatus.OK);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
},
|
||
|
|
};
|
||
|
|
|
||
|
|
module.exports = generateControllers(pushService, extraControllers, controllerOptions);
|