rack_attack.rb 3.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106
  1. # frozen_string_literal: true
  2. require 'doorkeeper/grape/authorization_decorator'
  3. class Rack::Attack
  4. class Request
  5. def authenticated_token
  6. return @token if defined?(@token)
  7. @token = Doorkeeper::OAuth::Token.authenticate(
  8. Doorkeeper::Grape::AuthorizationDecorator.new(self),
  9. *Doorkeeper.configuration.access_token_methods
  10. )
  11. end
  12. def remote_ip
  13. @remote_ip ||= (@env["action_dispatch.remote_ip"] || ip).to_s
  14. end
  15. def authenticated_user_id
  16. authenticated_token&.resource_owner_id
  17. end
  18. def unauthenticated?
  19. !authenticated_user_id
  20. end
  21. def api_request?
  22. path.start_with?('/api')
  23. end
  24. def web_request?
  25. !api_request?
  26. end
  27. def paging_request?
  28. params['page'].present? || params['min_id'].present? || params['max_id'].present? || params['since_id'].present?
  29. end
  30. end
  31. PROTECTED_PATHS = %w(
  32. /auth/sign_in
  33. /auth
  34. /auth/password
  35. /auth/confirmation
  36. ).freeze
  37. PROTECTED_PATHS_REGEX = Regexp.union(PROTECTED_PATHS.map { |path| /\A#{Regexp.escape(path)}/ })
  38. Rack::Attack.safelist('allow from localhost') do |req|
  39. req.remote_ip == '127.0.0.1' || req.remote_ip == '::1'
  40. end
  41. throttle('throttle_authenticated_api', limit: 300, period: 5.minutes) do |req|
  42. req.authenticated_user_id if req.api_request?
  43. end
  44. throttle('throttle_unauthenticated_api', limit: 300, period: 5.minutes) do |req|
  45. req.remote_ip if req.api_request? && req.unauthenticated?
  46. end
  47. throttle('throttle_api_media', limit: 30, period: 30.minutes) do |req|
  48. req.authenticated_user_id if req.post? && req.path.start_with?('/api/v1/media')
  49. end
  50. throttle('throttle_media_proxy', limit: 30, period: 10.minutes) do |req|
  51. req.remote_ip if req.path.start_with?('/media_proxy')
  52. end
  53. throttle('throttle_api_sign_up', limit: 5, period: 30.minutes) do |req|
  54. req.remote_ip if req.post? && req.path == '/api/v1/accounts'
  55. end
  56. throttle('throttle_authenticated_paging', limit: 300, period: 15.minutes) do |req|
  57. req.authenticated_user_id if req.paging_request?
  58. end
  59. throttle('throttle_unauthenticated_paging', limit: 300, period: 15.minutes) do |req|
  60. req.remote_ip if req.paging_request? && req.unauthenticated?
  61. end
  62. API_DELETE_REBLOG_REGEX = /\A\/api\/v1\/statuses\/[\d]+\/unreblog/.freeze
  63. API_DELETE_STATUS_REGEX = /\A\/api\/v1\/statuses\/[\d]+/.freeze
  64. throttle('throttle_api_delete', limit: 30, period: 30.minutes) do |req|
  65. req.authenticated_user_id if (req.post? && req.path =~ API_DELETE_REBLOG_REGEX) || (req.delete? && req.path =~ API_DELETE_STATUS_REGEX)
  66. end
  67. throttle('protected_paths', limit: 25, period: 5.minutes) do |req|
  68. req.remote_ip if req.post? && req.path =~ PROTECTED_PATHS_REGEX
  69. end
  70. self.throttled_response = lambda do |env|
  71. now = Time.now.utc
  72. match_data = env['rack.attack.match_data']
  73. headers = {
  74. 'Content-Type' => 'application/json',
  75. 'X-RateLimit-Limit' => match_data[:limit].to_s,
  76. 'X-RateLimit-Remaining' => '0',
  77. 'X-RateLimit-Reset' => (now + (match_data[:period] - now.to_i % match_data[:period])).iso8601(6),
  78. }
  79. [429, headers, [{ error: I18n.t('errors.429') }.to_json]]
  80. end
  81. end