module KineticSdk
  class Task

    # Find the database configuration
    #
    # @param params [Hash] Query parameters that are added to the URL, such as +include+
    # @param headers [Hash] hash of headers to send, default is basic authentication
    # @return [KineticSdk::Utils::KineticHttpResponse] object, with +code+, +message+, +content_string+, and +content+ properties
    def find_db(params={}, headers=header_basic_auth)
      @logger.info("Finding the database configuration")
      get("#{@api_url}/config/db", params, headers)
    end


    # Find the session configuration properties
    #
    # @param params [Hash] Query parameters that are added to the URL, such as +include+
    # @param headers [Hash] hash of headers to send, default is basic authentication
    # @return [KineticSdk::Utils::KineticHttpResponse] object, with +code+, +message+, +content_string+, and +content+ properties
    def find_session_configuration(params={}, headers=header_basic_auth)
      @logger.info("Finding the session timeout")
      get("#{@api_url}/config/session", params, headers)
    end


    # Find the engine configuration properties
    #
    # @param params [Hash] Query parameters that are added to the URL, such as +include+
    # @param headers [Hash] hash of headers to send, default is basic authentication
    # @return [KineticSdk::Utils::KineticHttpResponse] object, with +code+, +message+, +content_string+, and +content+ properties
    def find_engine_configuration(params={}, headers=header_basic_auth)
      @logger.info("Finding the engine configuration")
      get("#{@api_url}/config/engine", params, headers)
    end


    # Update the authentication settings
    #
    # @param settings [Hash] Settings for the authenticator
    # @param headers [Hash] hash of headers to send, default is basic authentication and accept JSON content type
    # @return [KineticSdk::Utils::KineticHttpResponse] object, with +code+, +message+, +content_string+, and +content+ properties
    #
    # Example
    #
    #     update_authentication({
    #       "authenticator" => "com.kineticdata.core.v1.authenticators.ProxyAuthenticator",
    #       "authenticationJsp" => "/WEB-INF/app/login.jsp",
    #       "properties" => {
    #         "Authentication Strategy" => "Http Header",
    #         "Header Name" => "X-Login",
    #         "Guest Access Enabled" => "No"
    #       }
    #     })
    #
    def update_authentication(settings, headers=default_headers)
      @logger.info("Updating the authentication properties")
      put("#{@api_url}/config/auth", settings, headers)
    end


    # Update the database configuration
    #
    # This assumes the database has already been created on the dbms.
    #
    # @param settings [Hash] Setting sfor the selected type of dbms
    # @param headers [Hash] hash of headers to send, default is basic authentication and accept JSON content type
    # @return [KineticSdk::Utils::KineticHttpResponse] object, with +code+, +message+, +content_string+, and +content+ properties
    #
    # Example
    #
    #     update_db({
    #       "hibernate.connection.driver_class" => "org.postgresql.Driver",
    #       "hibernate.connection.url" => "jdbc:postgresql://192.168.0.1:5432",
    #       "hibernate.connection.username" => "my-db-user",
    #       "hibernate.connection.password" => "my-db-password",
    #       "hibernate.dialect" => "com.kineticdata.task.adapters.dbms.KineticPostgreSQLDialect"
    #     })
    #
    def update_db(settings, headers=default_headers)
      @logger.info("Updating the database properties")
      put("#{@api_url}/config/db", settings, headers)
    end


    # Update the engine settings
    #
    # @param settings [Hash] Settings for the selected type of dbms
    # @param headers [Hash] hash of headers to send, default is basic authentication and accept JSON content type
    # @return [KineticSdk::Utils::KineticHttpResponse] object, with +code+, +message+, +content_string+, and +content+ properties
    #
    # Example
    #
    #     update_engine({
    #       "Max Threads" => "1",
    #       "Sleep Delay" => "10",
    #       "Trigger Query" => "'Selection Criterion'=null"
    #     })
    #
    def update_engine(settings, headers=default_headers)
      @logger.info("Updating the engine properties")
      put("#{@api_url}/config/engine", settings, headers)

      # start the task engine?
      if !settings['Sleep Delay'].nil? && settings['Sleep Delay'].to_i > 0
        @logger.info("Starting the engine")
        start_engine
      end
    end


    # Update the identity store settings
    #
    # @param settings [Hash] Settings for the identity store
    # @param headers [Hash] hash of headers to send, default is basic authentication and accept JSON content type
    # @return [KineticSdk::Utils::KineticHttpResponse] object, with +code+, +message+, +content_string+, and +content+ properties
    #
    # Example
    #
    #     update_identity_store({
    #       "Identity Store" => "com.kineticdata.authentication.kineticcore.KineticCoreIdentityStore",
    #       "properties" => {
    #         "Kinetic Core Space Url" => "http://server:port/kinetic/space",
    #         "Group Attribute Name" => "Group",
    #         "Proxy Username" => "admin",
    #         "Proxy Password" => "admin"
    #       }
    #     })
    #
    def update_identity_store(settings, headers=default_headers)
      @logger.info("Updating the identity store properties")
      put("#{@api_url}/config/identityStore", settings, headers)
    end


    # Update the web server and default configuration user settings
    #
    # @param settings [Hash] Settings for the web server and configurator user
    # @param headers [Hash] hash of headers to send, default is basic authentication and accept JSON content type
    # @return [KineticSdk::Utils::KineticHttpResponse] object, with +code+, +message+, +content_string+, and +content+ properties
    #
    # Example
    #
    #     update_properties({
    #       "Configurator Username" => "my-admin-user",
    #       "Configurator Password" => "my-admin-pass",
    #       "Log Level" => "DEBUG",
    #       "Log Size (MB)" => "20"
    #     })
    #
    # Example
    #
    #     update_properties({
    #       "Configurator Username" => "my-admin-user",
    #       "Configurator Password" => "my-admin-pass"
    #     })
    #
    def update_properties(settings, headers=default_headers)
      @logger.info("Updating the web server properties")
      put("#{@api_url}/config/server", settings, headers)

      # reset the configuration user
      @config_user = {
        username: settings["Configurator Username"],
        password: settings["Configurator Password"]
      }
    end


    # Update the session configuration settings
    #
    # @param settings [Hash] Settings for the session configuration
    # @param headers [Hash] hash of headers to send, default is basic authentication and accept JSON content type
    # @return [KineticSdk::Utils::KineticHttpResponse] object, with +code+, +message+, +content_string+, and +content+ properties
    #
    # Example
    #
    #     update_session_configuration({
    #       "timeout" => "30"
    #     })
    #
    def update_session_configuration(settings, headers=default_headers)
      @logger.info("Updating the session configuration settings")
      put("#{@api_url}/config/session", settings, headers)
    end

    # Find the system policy rule
    #
    # @param params [Hash] Query parameters that are added to the URL, such as +include+
    # @param headers [Hash] hash of headers to send, default is basic authentication
    # @return [KineticSdk::Utils::KineticHttpResponse] object, with +code+, +message+, +content_string+, and +content+ properties
    def find_system_policy_rule(params={}, headers=header_basic_auth)
      @logger.info("Finding the system policy rule")
      get("#{@api_url}/config/systemPolicyRule", params, headers)
    end

    # Update the system policy rule
    #
    # @param policy_rule_name [String] name of the policy rule to use
    # @param headers [Hash] hash of headers to send, default is basic authentication and accept JSON content type
    # @return [KineticSdk::Utils::KineticHttpResponse] object, with +code+, +message+, +content_string+, and +content+ properties
    #
    # Example
    #
    #     update_system_policy_rule("Allow All")
    #
    def update_system_policy_rule(policy_rule_name, headers=default_headers)
      @logger.info("Updating the system policy rule")
      payload = { "name" => policy_rule_name }
      put("#{@api_url}/config/systemPolicyRule", payload, headers)
    end

  end
end