| | |
| | | const fastify = require('fastify')({ |
| | | logger: true |
| | | }) |
| | | const _ = require("lodash") |
| | | const db = require("./lib/db") |
| | | |
| | | const settings = require("./settings") |
| | | |
| | | ///////////////////////////////////////////////////////////////////////// |
| | |
| | | }) |
| | | |
| | | fastify |
| | | .get('/api/users', async function (req, res) { |
| | | .get('/users', async function (req, res) { |
| | | const {offset, limit} = req.query |
| | | const users = await db.getUsers(offset, limit) |
| | | return res.send(users) |
| | | }) |
| | | .get("/api/users/count", async function (req, res) { |
| | | .get("/users/count", async function (req, res) { |
| | | const count = await db.getUserCount() |
| | | return res.send(count) |
| | | }) |
| | | .get("/api/user/login/:login", async function (req, res) { |
| | | .get("/user/login/:login", async function (req, res) { |
| | | const {login} = req.params |
| | | const user = await db.getUserByLogin(login) |
| | | if (user.length) { |
| | |
| | | return res.code(404).send({status: "error", msg: "not found"}) |
| | | } |
| | | }) |
| | | .get("/api/user/userid/:userid", async function (req, res) { |
| | | .get("/user/userid/:userid", async function (req, res) { |
| | | const {userid} = req.params |
| | | const user = await db.getUserByUserId(userid) |
| | | if (user.length) { |
| | | return res.send(user[0]) |
| | | if (user) { |
| | | return res.send(user) |
| | | } |
| | | else { |
| | | return res.code(404).send({status: "error", msg: "not found"}) |
| | | } |
| | | }) |
| | | .get("/ref_id/:ref_id", async function (req, res) { |
| | | const {ref_id} = req.params |
| | | const data = await db.getObjIdFromRefId(ref_id) |
| | | if (data) { |
| | | return res.send(data) |
| | | } |
| | | else { |
| | | return res.code(404).send({status: "error", msg: "not found"}) |
| | | } |
| | | }) |
| | | .get("/obj_id/:obj_id", async function (req, res) { |
| | | const {obj_id} = req.params |
| | | let data = await db.getRefIdFromObjId(obj_id) |
| | | if (data) { |
| | | return res.send(data) |
| | | } |
| | | else { |
| | | return res.code(404).send({status: "error", msg: "not found"}) |
| | |
| | | |
| | | ///////////////////////////////////////////////////////////////////////// |
| | | |
| | | fastify.listen({port: 4101}, function (err, address) { |
| | | fastify.listen({port: settings.port}, function (err, address) { |
| | | if (err) { |
| | | fastify.log.error(err) |
| | | process.exit(1) |
| | |
| | | |
| | | ///////////////////////////////////////////////////////////////////////// |
| | | |
| | | async function promiseDelay(ms) { |
| | | return new Promise(resolve => setTimeout(resolve, ms)) |
| | | async function promiseDelay (ms) { |
| | | return new Promise(resolve => setTimeout(resolve, ms)) |
| | | } |