<commit_before># frozen_string_literal: true

class Pubsubhubbub::ConfirmationWorker
  include Sidekiq::Worker
  include RoutingHelper

  sidekiq_options queue: 'push', retry: false

  attr_reader :subscription, :mode, :secret, :lease_seconds

  def perform(subscription_id, mode, secret = nil, lease_seconds = nil)
    @subscription = Subscription.find(subscription_id)
    @mode = mode
    @secret = secret
    @lease_seconds = lease_seconds
    process_confirmation
  end

  private

  def process_confirmation
    prepare_subscription

    confirm_callback
    logger.debug "Confirming PuSH subscription for #{subscription.callback_url} with challenge #{challenge}: #{callback_response_body}"

<<<<<<< HEAD
    logger.debug "Confirming PuSH subscription for #{subscription.callback_url} with challenge #{challenge}: #{body}"
=======
    update_subscription
  end
>>>>>>> 8963f8c3c2630bfcc377a5ca0513eef5a6b2a4bc

  def update_subscription
    if successful_subscribe?
      subscription.save!
    elsif successful_unsubscribe?
      subscription.destroy!
    end
  end

  def successful_subscribe?
    subscribing? && response_matches_challenge?
  end

  def successful_unsubscribe?
    (unsubscribing? && response_matches_challenge?) || !subscription.confirmed?
  end

  def response_matches_challenge?
    callback_response_body == challenge
  end

  def subscribing?
    mode == 'subscribe'
  end

  def unsubscribing?
    mode == 'unsubscribe'
  end

  def confirm_callback
    @_confirm_callback ||= callback_get_with_params
  end

  def callback_get_with_params
    HTTP.headers(user_agent: 'Mastodon/PubSubHubbub')
        .timeout(:per_operation, write: 20, connect: 20, read: 50)
        .get(subscription.callback_url, params: callback_params)
  end

  def callback_response_body
    confirm_callback.body.to_s
  end

  def callback_params
    {
      'hub.topic' => account_url(subscription.account, format: :atom),
      'hub.mode' => mode,
      'hub.challenge' => challenge,
      'hub.lease_seconds' => subscription.lease_seconds,
    }
  end

  def prepare_subscription
    subscription.secret = secret
    subscription.lease_seconds = lease_seconds
    subscription.confirmed = true
  end

  def challenge
    @_challenge ||= SecureRandom.hex
  end
end
<commit_msg>Resolve a merged conflict - app/workers/pubsubhubbub/confirmation_worker.rb<commit_after># frozen_string_literal: true

class Pubsubhubbub::ConfirmationWorker
  include Sidekiq::Worker
  include RoutingHelper

  sidekiq_options queue: 'push', retry: false

  attr_reader :subscription, :mode, :secret, :lease_seconds

  def perform(subscription_id, mode, secret = nil, lease_seconds = nil)
    @subscription = Subscription.find(subscription_id)
    @mode = mode
    @secret = secret
    @lease_seconds = lease_seconds
    process_confirmation
  end

  private

  def process_confirmation
    prepare_subscription

    confirm_callback
    logger.debug "Confirming PuSH subscription for #{subscription.callback_url} with challenge #{challenge}: #{callback_response_body}"

    update_subscription
  end

  def update_subscription
    if successful_subscribe?
      subscription.save!
    elsif successful_unsubscribe?
      subscription.destroy!
    end
  end

  def successful_subscribe?
    subscribing? && response_matches_challenge?
  end

  def successful_unsubscribe?
    (unsubscribing? && response_matches_challenge?) || !subscription.confirmed?
  end

  def response_matches_challenge?
    callback_response_body == challenge
  end

  def subscribing?
    mode == 'subscribe'
  end

  def unsubscribing?
    mode == 'unsubscribe'
  end

  def confirm_callback
    @_confirm_callback ||= callback_get_with_params
  end

  def callback_get_with_params
    HTTP.headers(user_agent: 'Mastodon/PubSubHubbub')
        .timeout(:per_operation, write: 20, connect: 20, read: 50)
        .get(subscription.callback_url, params: callback_params)
  end

  def callback_response_body
    confirm_callback.body.to_s
  end

  def callback_params
    {
      'hub.topic' => account_url(subscription.account, format: :atom),
      'hub.mode' => mode,
      'hub.challenge' => challenge,
      'hub.lease_seconds' => subscription.lease_seconds,
    }
  end

  def prepare_subscription
    subscription.secret = secret
    subscription.lease_seconds = lease_seconds
    subscription.confirmed = true
  end

  def challenge
    @_challenge ||= SecureRandom.hex
  end
end

{'fraction_non_alphanumeric': 0.08187134502923976, 'fraction_numerical': 0.007647323436797121, 'mean_word_length': 3.9966292134831463, 'pattern_counts': {'":': 0, '<': 10, '<?xml version=': 0, '>': 18, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '6337475', 'n_tokens_mistral': 1377, 'n_tokens_neox': 1316, 'n_words': 298}