# encoding: utf-8
module Ayadn
  class Action

    ##
    # This class is the main initializer + dispatcher

    def initialize
      @api = API.new
      @view = View.new
      @workers = Workers.new
      @stream = Stream.new(@api, @view, @workers)
      @search = Search.new(@api, @view, @workers)
      Settings.load_config
      Settings.get_token
      Settings.init_config
      Logs.create_logger
      Databases.open_databases
      at_exit { Databases.close_all }
    end

    def method_missing(meth, options)
      case meth.to_s
      when 'unified', 'checkins', 'global', 'trending', 'photos', 'conversations', 'interactions'
        begin
          @stream.send(meth.to_sym, options)
        rescue => e
          Errors.global_error({error: e, caller: caller, data: [meth, options]})
        end
      else
        super
      end
    end

    def mentions(username, options)
      begin
        @stream.mentions(username, options)
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [username, options]})
      end
    end

    def posts(username, options)
      begin
        @stream.posts(username, options)
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [username, options]})
      end
    end

    def whatstarred(username, options)
      begin
        @stream.whatstarred(username, options)
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [username, options]})
      end
    end

    def whoreposted(post_id, options)
      begin
        @stream.whoreposted(post_id, options)
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [post_id, options]})
      end
    end

    def whostarred(post_id, options)
      begin
        @stream.whostarred(post_id, options)
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [post_id, options]})
      end
    end

    def convo(post_id, options)
      begin
        @stream.convo(post_id, options)
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [post_id, options]})
      end
    end

    def delete(post_ids)
      begin
        ids = post_ids.select { |post_id| post_id.is_integer? }
        abort(Status.error_missing_post_id) if ids.empty?
        ids.each do |post_id|
          print Status.deleting_post(post_id)
          resp = @api.delete_post(post_id)
          Check.has_been_deleted(post_id, resp)
          sleep 1 unless ids.length == 1
        end
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [post_id]})
      end
    end

    def delete_m(args)
      begin
        abort(Status.error_missing_message_id) unless args.length >= 2
        channel = args[0]
        args.shift
        ids = args.select {|message_id| message_id.is_integer?}
        abort(Status.error_missing_message_id) if ids.empty?
        channel_id = @workers.get_channel_id_from_alias(channel)
        ids.each do |message_id|
          print Status.deleting_message(message_id)
          resp = @api.delete_message(channel_id, message_id)
          Check.message_has_been_deleted(message_id, resp)
          sleep 1 unless ids.length == 1
        end
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [message_id]})
      end
    end

    def unfollow(usernames)
      begin
        Check.no_username(usernames)
        users = @workers.all_but_me(usernames)
        puts Status.unfollowing(users.join(','))
        users.each do |user|
          resp = @api.unfollow(user)
          Check.has_been_unfollowed(user, resp)
          sleep 1 unless users.length == 1
        end
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [usernames]})
      end
    end

    def follow(usernames)
      begin
        Check.no_username(usernames)
        users = @workers.all_but_me(usernames)
        puts Status.following(users.join(','))
        users.each do |user|
          resp = @api.follow(user)
          Check.has_been_followed(user, resp)
          sleep 1 unless users.length == 1
        end
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [usernames]})
      end
    end

    def unmute(usernames)
      begin
        Check.no_username(usernames)
        users = @workers.all_but_me(usernames)
        puts Status.unmuting(users.join(','))
        users.each do |user|
          resp = @api.unmute(user)
          Check.has_been_unmuted(user, resp)
          sleep 1 unless users.length == 1
        end
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [usernames]})
      end
    end

    def mute(usernames)
      begin
        Check.no_username(usernames)
        users = @workers.all_but_me(usernames)
        puts Status.muting(users.join(','))
        users.each do |user|
          resp = @api.mute(user)
          Check.has_been_muted(user, resp)
          sleep 1 unless users.length == 1
        end
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [usernames]})
      end
    end

    def unblock(usernames)
      begin
        Check.no_username(usernames)
        users = @workers.all_but_me(usernames)
        puts Status.unblocking(users.join(','))
        users.each do |user|
          resp = @api.unblock(user)
          Check.has_been_unblocked(user, resp)
          sleep 1 unless users.length == 1
        end
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [usernames]})
      end
    end

    def block(usernames)
      begin
        Check.no_username(usernames)
        users = @workers.all_but_me(usernames)
        puts Status.blocking(users.join(','))
        users.each do |user|
          resp = @api.block(user)
          Check.has_been_blocked(user, resp)
          sleep 1 unless users.length == 1
        end
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [usernames]})
      end
    end

    def repost(post_id)
      begin
        Check.bad_post_id(post_id)
        puts Status.reposting(post_id)
        resp = @api.get_details(post_id)
        Check.already_reposted(resp)
        id = @workers.get_original_id(post_id, resp)
        Check.has_been_reposted(id, @api.repost(id))
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [post_id, id]})
      end
    end

    def unrepost(post_id)
      begin
        Check.bad_post_id(post_id)
        puts Status.unreposting(post_id)
        if @api.get_details(post_id)['data']['you_reposted']
          Check.has_been_unreposted(post_id, @api.unrepost(post_id))
        else
          puts Status.not_your_repost
        end
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [post_id]})
      end
    end

    def unstar(post_id)
      begin
        Check.bad_post_id(post_id)
        puts Status.unstarring(post_id)
        resp = @api.get_details(post_id)
        id = @workers.get_original_id(post_id, resp)
        resp = @api.get_details(id)
        if resp['data']['you_starred']
          Check.has_been_unstarred(id, @api.unstar(id))
        else
          puts Status.not_your_starred
        end
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [post_id]})
      end
    end

    def star(post_id)
      begin
        Check.bad_post_id(post_id)
        puts Status.starring(post_id)
        resp = @api.get_details(post_id)
        Check.already_starred(resp)
        id = @workers.get_original_id(post_id, resp)
        Check.has_been_starred(id, @api.star(id))
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [post_id]})
      end
    end

    def hashtag(hashtag, options)
      begin
        @search.hashtag(hashtag, options)
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [hashtag, options]})
      end
    end

    def search(words, options)
      begin
        @search.find(words, options)
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [words, options]})
      end
    end

    def followings(username, options)
      begin
        @stream.followings(username, options)
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [username, options]})
      end
    end

    def followers(username, options)
      begin
        @stream.followers(username, options)
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [username, options]})
      end
    end

    def muted(options)
      begin
        @stream.muted(options)
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [options]})
      end
    end

    def blocked(options)
      begin
        @stream.blocked(options)
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [options]})
      end
    end

    def view_settings(options)
      begin
        options[:raw] ? (puts Settings.options.to_json) : @view.show_settings
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [options]})
      end
    end

    def userinfo(username, options)
      begin
        Check.no_username(username)
        username = @workers.add_arobase(username)
        @view.downloading(options)
        if options[:raw]
          resp = @api.get_user(username)
          @view.show_raw(resp, options)
          exit
        end
        stream = @api.get_user(username)
        Check.no_user(stream, username)
        Check.same_username(stream) ? token = @api.get_token_info['data'] : token = nil
        @view.infos(stream['data'], token)
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [username, options]})
      end
    end

    def postinfo(post_id, options)
      begin
        Settings.options[:force] = true if options[:force]
        Check.bad_post_id(post_id)
        @view.downloading(options)
        if options[:raw]
          details = @api.get_details(post_id, options)
          @view.show_raw(details, options)
          exit
        end
        @view.clear_screen
        response = @api.get_details(post_id, options)
        Check.no_post(response, post_id)
        resp = response['data']
        response = @api.get_user("@#{resp['user']['username']}")
        Check.no_user(response, response['data']['username'])
        stream = response['data']
        puts "POST:\n".inverse
        @view.show_simple_post([resp], options)
        if resp['repost_of']
          puts "REPOST OF:\n".inverse
          Errors.repost(post_id, resp['repost_of']['id'])
          @view.show_simple_post([resp['repost_of']], options)
        end
        puts "AUTHOR:\n".inverse
        if response['data']['username'] == Settings.config[:identity][:username]
          @view.show_userinfos(stream, @api.get_token_info['data'], true)
        else
          @view.show_userinfos(stream, nil, true)
        end
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [post_id, options]})
      end
    end

    def files(options)
      begin
        @view.downloading(options)
        if options[:raw]
          @view.show_raw(@api.get_files_list(options), options)
          exit
        end
        list = @api.get_files_list(options)
        @view.clear_screen
        list.empty? ? Errors.no_data('files') : @view.show_files_list(list)
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [options]})
      end
    end

    def download(file_id)
      begin
        file = @api.get_file(file_id)['data']
        FileOps.download_url(file['name'], file['url'])
        puts Status.downloaded(file['name'])
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [file_id, file['url']]})
      end
    end

    def channels
      begin
        @view.downloading
        resp = @api.get_channels
        @view.clear_screen
        @view.show_channels(resp)
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [resp['meta']]})
      end
    end

    def messages(channel_id, options)
      begin
        @stream.messages(channel_id, options)
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [channel_id, options]})
      end
    end

    def pin(post_id, usertags)
      require 'pinboard'
      require 'base64'
      begin
        Check.bad_post_id(post_id)
        @view.downloading
        resp = @api.get_details(post_id)['data']
        @view.clear_screen
        links = @workers.extract_links(resp)
        resp['text'].nil? ? text = "" : text = resp['text']
        usertags << "ADN"
        handle = "@" + resp['user']['username']
        post_text = "From: #{handle} -- Text: #{text} -- Links: #{links.join(" ")}"
        pinner = Ayadn::PinBoard.new
        unless pinner.has_credentials_file?
          puts Status.no_pin_creds
          pinner.ask_credentials
          puts Status.pin_creds_saved
        end
        credentials = pinner.load_credentials
        maker = Struct.new(:username, :password, :url, :tags, :text, :description)
        bookmark = maker.new(credentials[0], credentials[1], resp['canonical_url'], usertags.join(","), post_text, links[0])
        puts Status.saving_pin
        pinner.pin(bookmark)
        puts Status.done
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [post_id, usertags]})
      end
    end

    def auto(options)
      begin
        @view.clear_screen
        puts Status.auto
        Post.new.auto_readline
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [options]})
      end
    end

    def post(args, options)
      begin
        writer = Post.new
        @view.clear_screen
        puts Status.posting
        if options[:poster] # Returns the same options hash + poster embed
          settings = options.dup
          options = NowWatching.new.get_poster(settings[:poster], settings)
        end
        resp = writer.post({options: options, text: args.join(" ")})
        save_and_view(resp)
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [args, options]})
      end
    end

    def write(options)
      begin
        writer = Post.new
        puts Status.writing
        puts Status.post
        lines_array = writer.compose
        writer.check_post_length(lines_array)
        text = lines_array.join("\n")
        @view.clear_screen
        puts Status.posting
        if options[:poster]
          settings = options.dup
          options = NowWatching.new.get_poster(settings[:poster], settings)
        end
        resp = writer.post({options: options, text: text})
        save_and_view(resp)
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [text, options]})
      end
    end

    def pmess(username, options = {})
    	begin
        Check.no_username(username)
        username = [@workers.add_arobase(username)]
    		writer = Post.new
        puts Status.message_from(username)
    		puts Status.message
    		lines_array = writer.compose
    		writer.check_message_length(lines_array)
        text = lines_array.join("\n")
    		@view.clear_screen
        puts Status.posting
        if options[:poster]
          settings = options.dup
          options = NowWatching.new.get_poster(settings[:poster], settings)
        end
        resp = writer.pm({options: options, text: text, username: username})
        FileOps.save_message(resp) if Settings.options[:backup][:auto_save_sent_messages]
    		@view.clear_screen
    		puts Status.yourmessage(username[0])
    		@view.show_posted(resp)
    	rescue => e
        Errors.global_error({error: e, caller: caller, data: [username, options]})
    	end
    end

    def reply(post_id, options = {})
      begin
        post_id = @workers.get_real_post_id(post_id)
      	puts Status.replying_to(post_id)
      	replied_to = @api.get_details(post_id)
        Check.no_post(replied_to, post_id)
        post_id = @workers.get_original_id(post_id, replied_to)
        if replied_to['data']['repost_of']
          if post_id == replied_to['data']['repost_of']['id']
            replied_to = @api.get_details(post_id)
            Check.no_post(replied_to, post_id)
          end
        end
        # ----
        writer = Post.new
        puts Status.writing
        puts Status.reply
        lines_array = writer.compose
        writer.check_post_length(lines_array)
        @view.clear_screen
        text = lines_array.join("\n")
        replied_to = @workers.build_posts([replied_to['data']])
        if options[:poster]
          settings = options.dup
          options = NowWatching.new.get_poster(settings[:poster], settings)
        end
        resp = writer.reply({options: options, text: text, id: post_id, reply_to: replied_to})
        # ----
        options = options.dup
        unless resp['data']['reply_to'].nil?
          options[:reply_to] = resp['data']['reply_to'].to_i
        end
        options[:post_id] = resp['data']['id'].to_i
        @view.render(@api.get_convo(post_id), options)
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [post_id, options]})
      end
    end

    def send_to_channel(channel_id)
      begin
        channel_id = @workers.get_channel_id_from_alias(channel_id)
        writer = Post.new
        puts Status.writing
        puts Status.post
        lines_array = writer.compose
        writer.check_message_length(lines_array)
        @view.clear_screen
        puts Status.posting
        resp = writer.message({id: channel_id, text: lines_array.join("\n")})
        save_and_view(resp)
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [channel_id]})
      end
    end

    def nowplaying(options = {})
      np = NowPlaying.new(@api, @view, @workers)
      options['lastfm'] ? np.lastfm(options) : np.itunes(options)
    end

    def nowwatching(args, options = {})
      begin
        abort(Status.error_missing_title) if args.empty?
        nw = NowWatching.new(@view)
        nw.post(args, options)
      rescue ArgumentError => e
        puts Status.no_movie
      rescue => e
        puts Status.wtf
        Errors.global_error({error: e, caller: caller, data: [args, options]})
      end
    end

    def tvshow(args, options = {})
      begin
        abort(Status.error_missing_title) if args.empty?
        client = TvShow.new
        if options['alt']
          show_obj = client.find_alt(args.join(' '))
        else
          show_obj = client.find(args.join(' '))
        end
        candidate = client.create_details(show_obj)
        candidate.ok ? candidate.post(options) : candidate.cancel
      rescue => e
        puts Status.wtf
        Errors.global_error({error: e, caller: caller, data: [args, options]})
      end
    end

    def random_posts(options)
      begin
        @stream.random_posts(options)
      rescue => e
        Errors.global_error({error: e, caller: caller, data: [@max_id, @random_post_id, @resp, options]})
      end
    end

    def version
      begin
        puts "\nAYADN\n".color(:red)
        puts "Version:\t".color(:cyan) + "#{VERSION}\n".color(:green)
        puts "Changelog:\t".color(:cyan) + "https://github.com/ericdke/na/blob/master/CHANGELOG.md\n".color(Settings.options[:colors][:link])
        puts "Docs:\t\t".color(:cyan) + "https://github.com/ericdke/na/tree/master/doc".color(Settings.options[:colors][:link])
        puts "\n"
      rescue => e
        Errors.global_error({error: e, caller: caller, data: []})
      end
    end

    private

    def save_and_view(resp)
      FileOps.save_post(resp) if Settings.options[:backup][:auto_save_sent_posts]
      @view.clear_screen
      puts Status.yourpost
      @view.show_posted(resp)
    end

  end
end