You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

mod_auth_token.lua 3.8KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130
  1. -- Token authentication
  2. -- Copyright (C) 2015 Atlassian
  3. local formdecode = require "util.http".formdecode;
  4. local generate_uuid = require "util.uuid".generate;
  5. local new_sasl = require "util.sasl".new;
  6. local sasl = require "util.sasl";
  7. local token_util = module:require "token/util".new(module);
  8. local sessions = prosody.full_sessions;
  9. -- no token configuration
  10. if token_util == nil then
  11. return;
  12. end
  13. -- define auth provider
  14. local provider = {};
  15. local host = module.host;
  16. -- Extract 'token' param from URL when session is created
  17. function init_session(event)
  18. local session, request = event.session, event.request;
  19. local query = request.url.query;
  20. if query ~= nil then
  21. local params = formdecode(query);
  22. -- The following fields are filled in the session, by extracting them
  23. -- from the query and no validation is beeing done.
  24. -- After validating auth_token will be cleaned in case of error and few
  25. -- other fields will be extracted from the token and set in the session
  26. session.auth_token = query and params.token or nil;
  27. -- previd is used together with https://modules.prosody.im/mod_smacks.html
  28. -- the param is used to find resumed session and re-use anonymous(random) user id
  29. -- (see get_username_from_token)
  30. session.previd = query and params.previd or nil;
  31. -- The room name and optional prefix from the web query
  32. session.jitsi_web_query_room = params.room;
  33. session.jitsi_web_query_prefix = params.prefix or "";
  34. -- Deprecated, you should use jitsi_web_query_room and jitsi_web_query_prefix
  35. session.jitsi_bosh_query_room = session.jitsi_web_query_room;
  36. session.jitsi_bosh_query_prefix = session.jitsi_web_query_prefix;
  37. end
  38. end
  39. module:hook_global("bosh-session", init_session);
  40. module:hook_global("websocket-session", init_session);
  41. function provider.test_password(username, password)
  42. return nil, "Password based auth not supported";
  43. end
  44. function provider.get_password(username)
  45. return nil;
  46. end
  47. function provider.set_password(username, password)
  48. return nil, "Set password not supported";
  49. end
  50. function provider.user_exists(username)
  51. return nil;
  52. end
  53. function provider.create_user(username, password)
  54. return nil;
  55. end
  56. function provider.delete_user(username)
  57. return nil;
  58. end
  59. function provider.get_sasl_handler(session)
  60. local function get_username_from_token(self, message)
  61. local res, error, reason = token_util:process_and_verify_token(session);
  62. if (res == false) then
  63. log("warn",
  64. "Error verifying token err:%s, reason:%s", error, reason);
  65. session.auth_token = nil;
  66. return res, error, reason;
  67. end
  68. local customUsername
  69. = prosody.events.fire_event("pre-jitsi-authentication", session);
  70. if (customUsername) then
  71. self.username = customUsername;
  72. elseif (session.previd ~= nil) then
  73. for _, session1 in pairs(sessions) do
  74. if (session1.resumption_token == session.previd) then
  75. self.username = session1.username;
  76. break;
  77. end
  78. end
  79. else
  80. self.username = message;
  81. end
  82. return res;
  83. end
  84. return new_sasl(host, { anonymous = get_username_from_token });
  85. end
  86. module:provides("auth", provider);
  87. local function anonymous(self, message)
  88. local username = generate_uuid();
  89. -- This calls the handler created in 'provider.get_sasl_handler(session)'
  90. local result, err, msg = self.profile.anonymous(self, username, self.realm);
  91. if result == true then
  92. if (self.username == nil) then
  93. self.username = username;
  94. end
  95. return "success";
  96. else
  97. return "failure", err, msg;
  98. end
  99. end
  100. sasl.registerMechanism("ANONYMOUS", {"anonymous"}, anonymous);