user.js 3.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166
  1. const UserModel = require('../model/user');
  2. const fs = require('fs').promises;
  3. const path = require('path');
  4. const Jimp = require('jimp');
  5. const jwt = require('jsonwebtoken');
  6. const createFolderIsExist = require('../helpers/create-directory');
  7. require('dotenv').config();
  8. const client = require('../helpers/twilio');
  9. const phoneToken = require('generate-sms-verification-code');
  10. const SECRET_KEY = process.env.JWT_SECRET;
  11. const saveAvatarForStatic = async (req, res, next) => {
  12. try {
  13. const userId = req.user.id;
  14. const DIR_IMAGES = process.env.DIR_IMAGES;
  15. const pathToFile = req.file.path;
  16. const newNameAvatar = req.file.originalname;
  17. const img = await Jimp.read(pathToFile);
  18. await img
  19. .autocrop()
  20. .cover(
  21. 250,
  22. 250,
  23. Jimp.HORIZONTAL_ALIGN_CENTER | Jimp.VERTICAL_ALIGN_MIDDLE
  24. )
  25. .writeAsync(pathToFile);
  26. await createFolderIsExist(path.join(DIR_IMAGES, userId));
  27. await fs.rename(pathToFile, path.join(DIR_IMAGES, userId, newNameAvatar));
  28. const newUrlAvatar = path.normalize(path.join(userId, newNameAvatar));
  29. const newUrl = `http://localhost:3000/${userId}/${newNameAvatar}`;
  30. await UserModel.updateAvatar(userId, newUrlAvatar);
  31. return res.status(200).json({
  32. status: 'success',
  33. code: 200,
  34. data: {
  35. newUrl,
  36. },
  37. });
  38. } catch (e) {
  39. next(e);
  40. }
  41. };
  42. const createNewUser = async (req, res, next) => {
  43. try {
  44. const code = phoneToken(8, { type: 'number' });
  45. const number = req.body.number;
  46. const isExist = await UserModel.findByNumber(number);
  47. if (isExist) {
  48. const id = isExist._id;
  49. await UserModel.updateCode(id, code);
  50. } else {
  51. await UserModel.createUser({ number, code });
  52. }
  53. client.messages.create({
  54. body: `${code}`,
  55. to: `${number}`,
  56. from: '+18305875860',
  57. });
  58. return res.status(201).json({
  59. status: 'success',
  60. code: 201,
  61. data: code,
  62. });
  63. } catch (e) {
  64. next(e);
  65. }
  66. };
  67. const logIn = async (req, res, next) => {
  68. try {
  69. const { number, code } = req.body;
  70. const user = await UserModel.findByNumber(number);
  71. if (!user || user.code !== code)
  72. return res.status(401).json({
  73. status: 'error',
  74. code: 401,
  75. data: 'UNAUTHORIZED',
  76. message: 'Invalid credentials',
  77. });
  78. const id = user._id;
  79. const payload = { id };
  80. const token = jwt.sign(payload, SECRET_KEY, { expiresIn: '24h' });
  81. const { name, lastName, avatarUrl } = user;
  82. await UserModel.updateToken(id, token);
  83. await UserModel.updateCode(id, '');
  84. return res.status(200).json({
  85. status: 'success',
  86. code: 200,
  87. data: {
  88. token,
  89. number,
  90. name,
  91. lastName,
  92. avatarUrl,
  93. },
  94. });
  95. } catch (e) {
  96. next(e);
  97. }
  98. };
  99. const logOut = async (req, res, next) => {
  100. try {
  101. const id = req.user.id;
  102. const user = await UserModel.findById(id);
  103. if (!user)
  104. return res.status(401).json({
  105. status: 'error',
  106. code: 401,
  107. data: 'UNAUTHORIZED',
  108. message: 'Invalid credentials',
  109. });
  110. await UserModel.updateToken(id, null);
  111. return res.status(204).json({});
  112. } catch (e) {
  113. next(e);
  114. }
  115. };
  116. const getCurrent = async (req, res, next) => {
  117. try {
  118. const user = req.user;
  119. if (!user)
  120. return res.status(401).json({
  121. status: 'error',
  122. code: 401,
  123. data: 'UNAUTHORIZED',
  124. message: 'Invalid credentials',
  125. });
  126. return res.status(200).json({
  127. status: 'success',
  128. code: 200,
  129. data: {
  130. user,
  131. },
  132. });
  133. } catch (e) {
  134. next(e);
  135. }
  136. };
  137. const updateName = async (req, res, next) => {
  138. try {
  139. const id = req.user.id;
  140. const user = await UserModel.updateName(id, req.body.name);
  141. return res.status(200).json({
  142. data: user,
  143. });
  144. } catch (e) {
  145. next(e);
  146. }
  147. };
  148. module.exports = {
  149. saveAvatarForStatic,
  150. createNewUser,
  151. logIn,
  152. logOut,
  153. getCurrent,
  154. updateName,
  155. };