mirror of
https://github.com/lasthead0/yandex2mqtt.git
synced 2025-08-08 01:00:31 +03:00
Some refactoring
This commit is contained in:
@@ -3,20 +3,23 @@
|
||||
const passport = require('passport');
|
||||
|
||||
module.exports.info = [
|
||||
passport.authenticate('bearer', {session: true}), (req, res) => {
|
||||
passport.authenticate('bearer', {session: true}),
|
||||
(req, res) => {
|
||||
const {user} = req;
|
||||
res.json({user_id: user.id, name: user.name, scope: req.authInfo.scope});
|
||||
}
|
||||
];
|
||||
|
||||
module.exports.ping = [
|
||||
passport.authenticate('bearer', {session: true}), (req, res) => {
|
||||
passport.authenticate('bearer', {session: true}),
|
||||
(req, res) => {
|
||||
res.status(200).send('OK');
|
||||
}
|
||||
];
|
||||
|
||||
module.exports.devices = [
|
||||
passport.authenticate('bearer', {session: true}), (req, res) => {
|
||||
passport.authenticate('bearer', {session: true}),
|
||||
(req, res) => {
|
||||
const reqId = req.get('X-Request-Id');
|
||||
const r = {
|
||||
request_id: reqId,
|
||||
@@ -35,7 +38,8 @@ module.exports.devices = [
|
||||
];
|
||||
|
||||
module.exports.query = [
|
||||
passport.authenticate('bearer', {session: true}), (req, res) => {
|
||||
passport.authenticate('bearer', {session: true}),
|
||||
(req, res) => {
|
||||
const reqId = req.get('X-Request-Id');
|
||||
const r = {
|
||||
request_id: reqId,
|
||||
@@ -54,7 +58,8 @@ module.exports.query = [
|
||||
];
|
||||
|
||||
module.exports.action = [
|
||||
passport.authenticate('bearer', {session: true}), (req, res) => {
|
||||
passport.authenticate('bearer', {session: true}),
|
||||
(req, res) => {
|
||||
const reqId = req.get('X-Request-Id');
|
||||
const r = {
|
||||
request_id: reqId,
|
||||
@@ -69,8 +74,8 @@ module.exports.action = [
|
||||
const capabilities = [];
|
||||
const ldevice = global.devices.find(device => device.data.id == id);
|
||||
|
||||
for (const payloadCapability of payloadDevice.capabilities) {
|
||||
capabilities.push(ldevice.setCapabilityState(payloadCapability.state.value , payloadCapability.type, payloadCapability.state.instance));
|
||||
for (const pdc of payloadDevice.capabilities) {
|
||||
capabilities.push(ldevice.setCapabilityState(pdc.state.value , pdc.type, pdc.state.instance));
|
||||
}
|
||||
|
||||
r.payload.devices.push({id, capabilities});
|
||||
@@ -81,7 +86,8 @@ module.exports.action = [
|
||||
];
|
||||
|
||||
module.exports.unlink = [
|
||||
passport.authenticate('bearer', {session: true}), (req, res) => {
|
||||
passport.authenticate('bearer', {session: true}),
|
||||
(req, res) => {
|
||||
const reqId = req.get('X-Request-Id');
|
||||
const r = {
|
||||
request_id: reqId,
|
||||
|
Reference in New Issue
Block a user