module AcquiaToolbelt
  class CLI
    class Databases < AcquiaToolbelt::Thor
      no_tasks do
        # Internal: Build the database output.
        #
        # Output the database information exposing all the available fields and
        # data to the end user.
        #
        # database - The name of the database you wish to fetch the information
        #            about.
        #
        # Returns the row of data for the database.
        def database_details(database)
          row_data = []
          row_data << database['name']
          row_data << database['username']
          row_data << database['password']
          row_data << database['host']
          row_data << database['db_cluster']
          row_data << database['instance_name']

          row_data
        end
      end

      # Public: Add a database to the subscription.
      #
      # Returns a status message.
      desc 'add', 'Add a database.'
      method_option :database, :type => :string, :aliases => %w(-d),
        :required => true, :desc => 'Name of the database to create.'
      def add
        if options[:subscription]
          subscription = options[:subscription]
        else
          subscription = AcquiaToolbelt::CLI::API.default_subscription
        end

        database     = options[:database]
        add_database = AcquiaToolbelt::CLI::API.request "sites/#{subscription}/dbs", 'POST', :db => "#{database}"

        if add_database['id']
          ui.success "Database '#{database}' has been successfully created."
        else
          ui.fail AcquiaToolbelt::CLI::API.display_error(add_database)
        end
      end

      # Public: Copy a database from one environment to another.
      #
      # Returns a status message.
      desc 'copy', 'Copy a database from one environment to another.'
      method_option :database, :type => :string, :aliases => %w(-d), :required => true,
        :desc => 'Name of the database to copy.'
      method_option :origin, :type => :string, :aliases => %w(-o), :required => true,
        :desc => 'Origin of the database to copy.'
      method_option :target, :type => :string, :aliases => %w(-t), :required => true,
        :desc => 'Target of where to copy the database.'
      def copy
        if options[:subscription]
          subscription = options[:subscription]
        else
          subscription = AcquiaToolbelt::CLI::API.default_subscription
        end

        database      = options[:database]
        origin        = options[:origin]
        target        = options[:target]
        copy_database = AcquiaToolbelt::CLI::API.request "sites/#{subscription}/dbs/#{database}/db-copy/#{origin}/#{target}", 'POST'

        if copy_database["id"]
          ui.success "Database '#{database}' has been copied from #{origin} to #{target}."
        else
          ui.fail AcquiaToolbelt::CLI::API.display_error(copy_database)
        end
      end

      # Public: Delete a database from a subscription.
      #
      # NB: This will delete all instances of the database across all
      # environments.
      #
      # Returns a status message.
      desc 'delete', 'Delete a database.'
      method_option :database, :type => :string, :aliases => %w(-d),
        :required => true, :desc => 'Name of the database to delete.'
      def delete
        if options[:subscription]
          subscription = options[:subscription]
        else
          subscription = AcquiaToolbelt::CLI::API.default_subscription
        end

        database  = options[:database]
        delete_db = AcquiaToolbelt::CLI::API.request "sites/#{subscription}/dbs/#{database}", 'DELETE'

        if delete_db['id']
          ui.success "Database '#{database}' has been successfully deleted."
        else
          ui.fail AcquiaToolbelt::CLI::API.display_error(delete_database)
        end
      end

      # Public: List all databases available within a subscription.
      #
      # Returns a database listing.
      desc 'list', 'List all databases.'
      method_option :database, :type => :string, :aliases => %w(-d),
        :desc => 'Name of the database to view.'
      def list
        if options[:subscription]
          subscription = options[:subscription]
        else
          subscription = AcquiaToolbelt::CLI::API.default_subscription
        end

        ui.say

        database    = options[:database]
        environment = options[:environment]
        rows        = []
        headings    = [
          'Name',
          'Username',
          'Password',
          'Host',
          'DB cluster',
          'Instance name'
        ]

        # Output a single database where the name and environment are specified.
        if database && environment
          database = AcquiaToolbelt::CLI::API.request "sites/#{subscription}/envs/#{environment}/dbs/#{database}"
          rows << database_details(database)

        # Only an environment was set so get all expanded data for the requested
        # environment.
        elsif environment
          databases = AcquiaToolbelt::CLI::API.request "sites/#{subscription}/envs/#{environment}/dbs"
          databases.each do |db|
            rows << database_details(db)
          end

        # If no name or environment is passed, just throw back all the database
        # names - no in depth details.
        else
          # Only set the 'name' header as we don't need the rest of the headers.
          headings = ['Name']
          databases = AcquiaToolbelt::CLI::API.request "sites/#{subscription}/dbs"
          databases.each do |db|
            rows << [db['name']]
          end
        end

        ui.output_table('', headings, rows)
      end

      # Public: Create a database instance backup.
      #
      # Returns a status message.
      desc 'backup', 'Create a new backup for a database.'
      method_option :database, :type => :string, :aliases => %w(-d),
        :required => true, :desc => 'Name of the database to backup.'
      def backup
        if options[:subscription]
          subscription = options[:subscription]
        else
          subscription = AcquiaToolbelt::CLI::API.default_subscription
        end

        database      = options[:database]
        environment   = options[:environment]
        create_backup = AcquiaToolbelt::CLI::API.request "sites/#{subscription}/envs/#{environment}/dbs/#{database}/backups", 'POST'
        if create_backup["id"]
          ui.success "The backup for '#{database}' in #{environment} has been started."
        else
          ui.fail AcquiaToolbelt::CLI::API.display_error(create_backup)
        end
      end

      # Public: List available database backups.
      #
      # Returns all database backups.
      desc 'list-backups', 'List all database backups.'
      method_option :database, :type => :string, :aliases => %w(-d),
        :required => true, :desc => 'Name of the database to get the backup for.'
      def list_backups
        # Ensure we have an environment defined.
        if options[:environment].nil?
          ui.say "No value provided for required options '--environment'"
          return
        end

        if options[:subscription]
          subscription = options[:subscription]
        else
          subscription = AcquiaToolbelt::CLI::API.default_subscription
        end

        database    = options[:database]
        environment = options[:environment]
        backups     = AcquiaToolbelt::CLI::API.request "sites/#{subscription}/envs/#{environment}/dbs/#{database}/backups"

        ui.say

        rows = []
        headings = [
          'ID',
          'Checksum',
          'Type',
          'Path',
          'Start',
          'Completed'
        ]

        backups.each do |backup|
          row_data = []
          row_data << backup['id']
          row_data << backup['checksum']
          row_data << backup['type']
          row_data << backup['path']
          row_data << Time.at(backup['started'].to_i)
          row_data << Time.at(backup['completed'].to_i)
          rows << row_data
        end

        ui.output_table('', headings, rows)
      end

      # Public: Restore a database backup.
      #
      # Returns a status message.
      desc 'restore', 'Restore a database from a backup.'
      method_option :id, :type => :string, :aliases => %w(-i),
        :desc => 'Backup ID to restore.'
       method_option :database, :type => :string, :aliases => %w(-d),
        :desc => 'Name of the database to restore.'
      def restore
        # Ensure we have an environment defined.
        if options[:environment].nil?
          ui.say "No value provided for required options '--environment'"
          return
        end

        if options[:subscription]
          subscription = options[:subscription]
        else
          subscription = AcquiaToolbelt::CLI::API.default_subscription
        end

        database    = options[:database]
        environment = options[:environment]
        database    = options[:database]
        backup_id   = options[:id]
        restore_db  = AcquiaToolbelt::CLI::API.request "sites/#{subscription}/envs/#{environment}/dbs/#{database}/backups/#{backup_id}/restore", 'POST'

        if restore_db['id']
          ui.success "Database backup #{backup_id} has been restored to '#{database}' in #{environment}."
        else
          ui.fail AcquiaToolbelt::CLI::API.display_error(restore_db)
        end
      end
    end
  end
end