discord.ts 2.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869
  1. import { Request as ExpressRequest, Response as ExpressResponse } from "express";
  2. import { DiscordAPI } from "src/utils/util";
  3. import { Option, tryDo } from "@shared/common/async_utils";
  4. import { eventLogger, logger } from "src/utils/logging";
  5. import { rpcClient } from "src/utils/rpc";
  6. import { ENV } from "src/utils/environment";
  7. export const get = async (req: ExpressRequest, res: ExpressResponse): Promise<void> => {
  8. res.redirect(DiscordAPI.getAuthUrl({
  9. client_id: ENV.BOT_CLIENT_ID,
  10. redirect_url: ENV.WEB_AUTH_URI,
  11. response_type: "code",
  12. scope: "identify",
  13. }));
  14. };
  15. type AuthResult = Option<unknown, {error: string}>;
  16. export const post = async (req: ExpressRequest, res: ExpressResponse):
  17. Promise<ExpressResponse<AuthResult>> => {
  18. if (!req.session) {
  19. logger.warn("WEB: req.session is not set up correctly!");
  20. return res.json({
  21. ok: false,
  22. error: "No session is set up. This is a server error!",
  23. });
  24. }
  25. if (!req.session.authTokenCode) {
  26. logger.warn("WEB: attempted to join with no authTokenCode set!");
  27. eventLogger.warn("IP %s attempted to join with no authTokenCode set", req.ip);
  28. return res.json({
  29. ok: false,
  30. error: "Authentication token is missing. Please try logging in again.",
  31. });
  32. }
  33. const tokenResult = await DiscordAPI.getToken({
  34. client_id: ENV.BOT_CLIENT_ID,
  35. client_secret: ENV.BOT_CLIENT_SECRET,
  36. grant_type: "authorization_code",
  37. code: req.session.authTokenCode,
  38. scope: "identify",
  39. redirect_uri: ENV.WEB_AUTH_URI,
  40. });
  41. if (!tokenResult.ok) {
  42. return res.json(tokenResult);
  43. }
  44. const userResult = await DiscordAPI.getCurrentUser(tokenResult.access_token);
  45. if (!userResult.ok) {
  46. return res.json(userResult);
  47. }
  48. const userInServerResult = await tryDo(rpcClient.userInServer({ userId: userResult.id }));
  49. if (!userInServerResult.ok) {
  50. logger.error("WEB: failed to auth user %s: %s", userResult.id, userInServerResult.error);
  51. return res.json({ ok: false, error: "Couldn't determine if user joined the server, please try again later" });
  52. }
  53. eventLogger.info("%s#%s authed from %s", userResult.username, userResult.discriminator, req.ip);
  54. logger.verbose("Logged in as %s#%s (%s); user in server: (%s)", userResult.username, userResult.discriminator, userResult.id, userInServerResult.result.exists);
  55. if (!userInServerResult.result.exists) {
  56. return res.json({ ok: false, error: "You haven't joined any servers NoctBot manages! Please join first and try again!" });
  57. }
  58. req.session.authTokenCode = undefined;
  59. req.session.userId = userResult.id;
  60. req.session.avatarId = userResult.avatar;
  61. req.session.username = `${userResult.username}#${userResult.discriminator}`;
  62. req.sessionOptions.maxAge = tokenResult.expires_in;
  63. return res.json({
  64. ok: true,
  65. });
  66. };