# frozen_string_literal: true

module SplitIoClient
  module SSE
    module Workers
      class SplitsWorker
        def initialize(synchronizer, config, feature_flags_repository)
          @synchronizer = synchronizer
          @config = config
          @feature_flags_repository = feature_flags_repository
          @queue = Queue.new
          @running = Concurrent::AtomicBoolean.new(false)
        end

        def start
          if @running.value
            @config.logger.debug('feature_flags_worker already running.')
            return
          end

          @running.make_true
          perform_thread
        end

        def stop
          unless @running.value
            @config.logger.debug('feature_flags_worker not running.')
            return
          end

          @running.make_false
          SplitIoClient::Helpers::ThreadHelper.stop(:split_update_worker, @config)
        end

        def add_to_queue(notification)
          @config.logger.debug("feature_flags_worker add to queue #{notification.data['changeNumber']}")
          @queue.push(notification)
        end

        private

        def return_split_from_json(notification)
          JSON.parse(
            SplitIoClient::Helpers::DecryptionHelper.get_encoded_definition(
              notification.data['c'],
              notification.data['d']
            ),
            symbolize_names: true
          )
        end

        def check_update(notification)
          @feature_flags_repository.get_change_number == notification.data['pcn'] && !notification.data['d'].nil?
        end

        def update_feature_flag(notification)
          return if @feature_flags_repository.get_change_number.to_i > notification.data['changeNumber']

          if check_update(notification)
            begin
              new_split = return_split_from_json(notification)
              if SplitIoClient::Engine::Models::Split.archived?(new_split)
                @feature_flags_repository.remove_split(new_split)
              else
                @feature_flags_repository.add_split(new_split)
              end
              @feature_flags_repository.set_change_number(notification.data['changeNumber'])
              return
            rescue StandardError => e
              @config.logger.debug("Failed to update Split: #{e.inspect}") if @config.debug_enabled
            end
          end
          @synchronizer.fetch_splits(notification.data['changeNumber'])
        end

        def kill_feature_flag(notification)
          return if @feature_flags_repository.get_change_number.to_i > notification.data['changeNumber']

          @config.logger.debug("feature_flags_worker kill #{notification.data['splitName']}, #{notification.data['changeNumber']}")
          @feature_flags_repository.kill(
            notification.data['changeNumber'],
            notification.data['splitName'],
            notification.data['defaultTreatment']
          )
          @synchronizer.fetch_splits(notification.data['changeNumber'])
        end

        def perform
          while (notification = @queue.pop)
            @config.logger.debug("feature_flags_worker change_number dequeue #{notification.data['changeNumber']}")
            case notification.data['type']
            when SSE::EventSource::EventTypes::SPLIT_UPDATE
              update_feature_flag(notification)
            when SSE::EventSource::EventTypes::SPLIT_KILL
              kill_feature_flag(notification)
            end
          end
        end

        def perform_thread
          @config.threads[:split_update_worker] = Thread.new do
            @config.logger.debug('starting feature_flags_worker ...') if @config.debug_enabled
            perform
          end
        end
      end
    end
  end
end