# frozen_string_literal: true
module LinkedinOrbit
  class Linkedin
    def initialize(params = {})
      @linkedin_organization = params.fetch(:linkedin_organization)
      @linkedin_token = params.fetch(:linkedin_token)
      @orbit_api_key = params.fetch(:orbit_api_key)
      @orbit_workspace = params.fetch(:orbit_workspace)
      @historical_import = params.fetch(:historical_import, false)
    end

    def process_comments
      posts = get_posts

      return posts unless posts.is_a?(Array)

      orbit_timestamp = last_orbit_activity_timestamp

      times = 0
      posts.each do |post|
    
        comments = get_post_comments(post["id"])

        next if comments.nil? || comments.empty?

        # Indicates that the member does not want their information shared
        # Member viewing access if forbidden for profile memberId
        comments.reject! do |comment| 
          if comment.has_key? "actor!"
              true if comment["actor!"]["status"] == 403
          end
        end

        # Indicates that the member does not want their information shared
        comments.reject! do |comment|
          if comment.has_key? "actor~"
            true if comment["actor~"]["id"] == "private"
          end
        end

        comments.each do |comment|
          unless @historical_import && orbit_timestamp
            next if Time.at(comment["created"]["time"] / 1000).utc.to_s < orbit_timestamp unless orbit_timestamp.nil?
          end

          if orbit_timestamp && @historical_import == false
            next if Time.at(comment["created"]["time"] / 1000).utc.to_s < orbit_timestamp
          end

          times += 1

          LinkedinOrbit::Orbit.call(
            type: "comments",
            data: {
              comment: comment,
              title: post["message_highlight"]
            },
            orbit_workspace: @orbit_workspace,
            orbit_api_key: @orbit_api_key
          )
        end
      end
      
      output = "Sent #{times} new comments to your Orbit workspace"

      puts output
      return output
    end

    def get_posts
      posts = []
      page = 0
      count = 100
      total = 0

      while page * count <= total
        url = URI("https://api.linkedin.com/v2/ugcPosts?q=authors&authors=List(#{CGI.escape(@linkedin_organization)})&sortBy=LAST_MODIFIED&start=#{page*count}&count=#{count}")
        https = Net::HTTP.new(url.host, url.port)
        https.use_ssl = true

        request = Net::HTTP::Get.new(url)
        request["Accept"] = "application/json"
        request["X-Restli-Protocol-Version"] = "2.0.0"
        request["Content-Type"] = "application/json"
        request["Authorization"] = "Bearer #{@linkedin_token}"

        response = https.request(request)

        response = JSON.parse(response.body)

        total = response["paging"]["total"] if page == 0

        return response["message"] if response["serviceErrorCode"]

        if response["elements"].nil? || response["elements"].empty?
          return <<~HEREDOC
            No new posts to process from your LinkedIn organization.
            If you suspect this is incorrect, verify your LinkedIn organization schema is correct in your credentials.
          HEREDOC
        end

        response["elements"].each do |element|
          next if element["id"].nil?
          posts << {
            "id" => element["id"],
            "message_highlight" => element["specificContent"]["com.linkedin.ugc.ShareContent"]["shareCommentary"]["text"][0, 40]
          }
        end
        page += 1
      end

      posts
    end

    def get_post_comments(id)
      url = URI("https://api.linkedin.com/v2/socialActions/#{id}/comments?projection=(elements(*(*,actor~(*,profilePicture(displayImage~:playableStreams)))))")
      https = Net::HTTP.new(url.host, url.port)
      https.use_ssl = true

      request = Net::HTTP::Get.new(url)
      request["Accept"] = "application/json"
      request["Content-Type"] = "application/json"
      request["Authorization"] = "Bearer #{@linkedin_token}"

      response = https.request(request)

      response = JSON.parse(response.body)

      response["elements"]
    end

    def last_orbit_activity_timestamp
      @last_orbit_activity_timestamp ||= begin
        OrbitActivities::Request.new(
          api_key: @orbit_api_key,
          workspace_id: @orbit_workspace,
          user_agent: "community-ruby-linkedin-orbit/#{LinkedinOrbit::VERSION}",
          action: "latest_activity_timestamp",
          filters: { activity_type: "custom:linkedin:comment" }
        ).response
      end
    end
  end
end