hummingbird-me/kitsu-server

module ListSync
  class MyAnimeList
    attr_reader :linked_account, :agent

    def initialize(linked_account)
      @linked_account = linked_account
      @agent = Mechanize.new do |a|
        a.user_agent_alias = 'Windows Chrome'
      end
      load_session!
    end

    def logged_in?
      track_session do
        ListSync::MyAnimeList::Login.new(agent, username, password).success?
      end
    end

    def sync!(kind)
      # Import first so that we have all their MAL data
      import!(kind)
      # Export back to MAL, just to make sure any merged data takes effect
      export!(kind)
    end

    def import!(kind)
      track_session do
        import = ListImport::MyAnimeListXML.new(
          input_file: their_xml_for(kind),
          user: linked_account.user,
          strategy: :greater,
          status: :running
        )
        import.save!
        import.apply!
      end
    end

    def export!(kind)
      track_session do
        xml = library_xml_for(kind)
        ListSync::MyAnimeList::XMLUploader.new(agent, xml).run!
      end
    end

    def update!(library_entry)
      track_session do
        ListSync::MyAnimeList::LibraryUpdater.new(agent, library_entry).run!
      end
    end

    def destroy!(media)
      track_session do
        ListSync::MyAnimeList::LibraryRemover.new(agent, media).run!
      end
    end

    def save_session!
      session = cookie_jar.dump
      if linked_account.persisted?
        linked_account.update_column(:session_data, session)
      else
        linked_account.session_data = session
      end
    end

    private

    def library_xml_for(kind)
      ListSync::MyAnimeList::XMLGenerator.new(linked_account.user, kind).to_xml
    end

    def their_xml_for(kind)
      ListSync::MyAnimeList::XMLDownloader.new(agent, kind).file
    end

    def username
      linked_account.external_user_id
    end

    def password
      linked_account.token
    end

    def track_session
      yield.tap { save_session! }
    end

    def load_session!
      return unless linked_account.session_data.present?
      cookie_jar.load(linked_account.session_data)
    end

    def cookie_jar
      ListSync::MyAnimeList::CookieJar.new(@agent.cookie_jar)
    end
  end
end