auth.controller.js 2.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107
  1. const handleError = require('../utils/handleError')
  2. const response = require('../utils/responseHandler')
  3. const userModel = require('../model/user.model')
  4. const jwt = require('jsonwebtoken')
  5. const { validate } = require('../utils/validation')
  6. const axios = require('../utils/axios')
  7. const qs = require('qs')
  8. const convertRole = require('../utils/convertRole')
  9. const { roleData } = require('../utils/constanta')
  10. const logModel = require('../model/log.model')
  11. const ip = require('ip')
  12. const osValue = require('../utils/osValue')
  13. exports.login = handleError(async (req, res) => {
  14. const isValid = validate(res, req.body, {
  15. username: 'string',
  16. password: 'string',
  17. })
  18. if (!isValid) return
  19. const { username, password } = req.body
  20. const user = await axios.post(
  21. 'https://api.kemdikbud.go.id:8243/manakses/2.0/auth',
  22. qs.stringify({
  23. username,
  24. password,
  25. }),
  26. {
  27. 'Content-Type': 'application/x-www-form-urlencoded',
  28. }
  29. )
  30. if (user.code === 400) {
  31. return response.error(res, {
  32. code: 400,
  33. message: user.message,
  34. })
  35. }
  36. let cekUser = await userModel.findOne({
  37. user_id: user.id,
  38. })
  39. let role = null
  40. if (process.env.ENV === 'production') {
  41. role = user.peran.filter((e) =>
  42. roleData.includes(convertRole(e.peran.id))
  43. )[0]
  44. role.peran.id = convertRole(role.peran.id)
  45. } else {
  46. role = user.peran.filter((e) => roleData.includes(e.peran.id))[0]
  47. }
  48. let dataRole = {
  49. id: role.peran.id,
  50. nama: role.peran.nama,
  51. menu: role.peran.menu,
  52. }
  53. if (!cekUser) {
  54. cekUser = await userModel.create({
  55. user_id: user.id,
  56. nama: user.nama,
  57. lembaga: role.organisasi,
  58. email: user.username,
  59. no_hp: user.no_hp,
  60. alamat: user.alamat,
  61. role: dataRole,
  62. isPublic: false,
  63. isPrivate: false,
  64. })
  65. } else {
  66. if (process.env.ENV === 'production') {
  67. if (cekUser.role.id !== role.peran.id) {
  68. await userModel.updateOne({ _id: cekUser._id }, { role: dataRole })
  69. }
  70. if (!cekUser.lembaga) {
  71. await userModel.updateOne(
  72. { _id: cekUser._id },
  73. { lembaga: role.organisasi }
  74. )
  75. }
  76. if (cekUser.role.id !== role.peran.id || !cekUser.lembaga) {
  77. cekUser = await userModel.findOne({
  78. user_id: user.id,
  79. })
  80. }
  81. }
  82. }
  83. await logModel.create({
  84. user: cekUser._id,
  85. aktivitas: `Berhasil login`,
  86. os: osValue(),
  87. ipv4: ip.address('public', 'ipv4'),
  88. })
  89. const accessToken = jwt.sign({ _id: cekUser._id }, process.env.SECRET, {
  90. expiresIn: '1d',
  91. })
  92. const data = {
  93. token: `Bearer ${accessToken}`,
  94. user: cekUser,
  95. }
  96. response.success(res, {
  97. message: 'Berhasil Login',
  98. data,
  99. })
  100. })