# frozen_string_literal: true

module DiscourseSubscriptionClient
  class Resources
    attr_accessor :suppliers,
                  :resources

    def initialize
      @suppliers = []
      @resources = []
    end

    def self.find_all
      RailsMultisite::ConnectionManagement.each_connection do
        new.find_all
      end
    end

    def find_all
      return unless DiscourseSubscriptionClient.database_exists?

      setup_resources
      find_resources

      return unless @resources.any?

      ActiveRecord::Base.transaction do
        find_suppliers
        save_resources
      end
    end

    def setup_resources
      setup_plugins
    end

    def find_resources
      find_plugins
    end

    def find_suppliers
      supplier_urls = @resources.map { |resource| resource[:supplier_url] }.uniq.compact

      supplier_urls.each do |url|
        supplier = SubscriptionClientSupplier.find_by(url: url)

        if supplier&.name
          @suppliers << supplier
        else
          supplier ||= SubscriptionClientSupplier.create!(url: url)
          request = DiscourseSubscriptionClient::Request.new(:supplier, supplier.id)
          data = request.perform("#{url}/subscription-server")

          if data
            supplier.update(name: data[:supplier])
            @suppliers << supplier
          else
            supplier.destroy!
          end
        end
      end
    end

    def save_resources
      @resources.each do |resource|
        supplier = @suppliers.select { |s| s.url === resource[:supplier_url] }.first

        next unless supplier.present?

        attrs = {
          supplier_id: supplier.id,
          name: resource[:name]
        }
        SubscriptionClientResource.create!(attrs) unless SubscriptionClientResource.exists?(attrs)
      end
    end

    def setup_plugins
      Plugin::Metadata::FIELDS << :subscription_url unless Plugin::Metadata::FIELDS.include?(:subscription_url)
      Plugin::Metadata.attr_accessor(:subscription_url)
    end

    def find_plugins
      Dir["#{DiscourseSubscriptionClient.root}/plugins/*/plugin.rb"].sort.each do |path|
        source = File.read(path)
        metadata = Plugin::Metadata.parse(source)

        next unless metadata.subscription_url.present?

        @resources << {
          name: metadata.name,
          supplier_url: metadata.subscription_url
        }
      end
    end
  end
end