# frozen_string_literal: true

require "net/http"
require "json"
require "active_support/time"

module DevOrbit
  class Orbit
    def initialize(type:, data:, workspace_id:, api_key:, historical_import: false, last_orbit_member_timestamp: nil)
      @type = type
      @data = data
      @workspace_id = workspace_id
      @api_key = api_key
      @historical_import = historical_import
      @last_orbit_activity_timestamp = last_orbit_activity_timestamp(type)
      @last_orbit_member_timestamp = last_orbit_member_timestamp
    end
    
    def call
      if @type == "comments"
        times = 0
        
        @data[:comments].each do |comment|
          unless @historical_import && @last_orbit_activity_timestamp
            next if (comment["created_at"] || comment[:created_at]) < @last_orbit_activity_timestamp unless @last_orbit_activity_timestamp.nil? 
          end

          if @last_orbit_activity_timestamp && @historical_import == false
            next if (comment["created_at"] || comment[:created_at]) < @last_orbit_activity_timestamp
          end

          times += 1

          DevOrbit::Interactions::Comment.new(
            article_title: @data.transform_keys(&:to_sym)[:title],
            comment: comment.transform_keys(&:to_sym),
            url: @data[:url],
            workspace_id: @workspace_id,
            api_key: @api_key
          )
        end

        output = "Sent #{times} new DEV comments to your Orbit workspace"
        
        puts output
        return output
      end

      if @type == "followers"
        counter = 0
        @data[:followers].each do |follower|
          next if follower.nil? || follower.empty?

          unless @historical_import && @last_orbit_member_timestamp
            next if follower["created_at"] < @last_orbit_member_timestamp unless @last_orbit_member_timestamp.nil?
          end
  
          if @last_orbit_member_timestamp && @historical_import == false
            next if follower["created_at"] < @last_orbit_member_timestamp
          end

          sleep(20) if counter % 100 == 0 && counter != 0 # API rate limiting

          DevOrbit::Interactions::Follower.new(
            id: follower["id"],
            name: follower["name"],
            username: follower["username"],
            url: follower["path"],
            workspace_id: @workspace_id,
            api_key: @api_key
          )
          counter += 1
        end
        output = "Sent #{counter} new followers to Orbit"

        puts output
        return output
      end
    end

    private

    def last_orbit_activity_timestamp(type)
      @last_orbit_activity_timestamp ||= begin
        if type == "comments"
          activity_type = "custom:dev:comment"
        end

        if type == "followers"
          return nil
        end

        OrbitActivities::Request.new(
          api_key: @api_key,
          workspace_id: @workspace_id,
          user_agent: "community-ruby-dev-orbit/#{DevOrbit::VERSION}",
          action: "latest_activity_timestamp",
          filters: { activity_type: activity_type }
        ).response
      end
    end
  end
end