package io.freefair.spring.okhttp.autoconfigure;

import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.context.properties.NestedConfigurationProperty;
import org.springframework.util.unit.DataSize;
import java.io.File;
import java.time.Duration;

/**
 * @author Lars Grefer
 */
@ConfigurationProperties(prefix = "okhttp")
public class OkHttpProperties {
    /**
     * The default connect timeout for new connections.
     */
    private Duration connectTimeout = Duration.ofSeconds(10);
    /**
     * The default read timeout for new connections.
     */
    private Duration readTimeout = Duration.ofSeconds(10);
    /**
     * The default write timeout for new connections.
     */
    private Duration writeTimeout = Duration.ofSeconds(10);
    /**
     * The interval between web socket pings initiated by this client. Use this to
     * automatically send web socket ping frames until either the web socket fails or it is closed.
     * This keeps the connection alive and may detect connectivity failures early. No timeouts are
     * enforced on the acknowledging pongs.
     *
     * <p>The default value of 0 disables client-initiated pings.
     */
    private Duration pingInterval = Duration.ZERO;
    @NestedConfigurationProperty
    private CacheProperties cache = new CacheProperties();
    /**
     * Whether to follow redirects from HTTPS to HTTP and from HTTP to HTTPS.
     */
    private boolean followSslRedirects = true;
    /**
     * Whether to follow redirects.
     */
    private boolean followRedirects = true;
    /**
     * Whether to retry or not when a connectivity problem is encountered.
     */
    private boolean retryOnConnectionFailure = true;
    @NestedConfigurationProperty
    private final ConnectionPoolProperties connectionPool = new ConnectionPoolProperties();


    /**
     * @author Lars Grefer
     * @see okhttp3.Cache
     */
    public static class CacheProperties {
        private boolean enabled;
        /**
         * The maximum number of bytes this cache should use to store.
         */
        private DataSize maxSize = DataSize.ofMegabytes(10);
        /**
         * The path of the directory where the cache should be stored.
         */
        private File directory;

        public CacheProperties() {
        }

        public boolean isEnabled() {
            return this.enabled;
        }

        /**
         * The maximum number of bytes this cache should use to store.
         */
        public DataSize getMaxSize() {
            return this.maxSize;
        }

        /**
         * The path of the directory where the cache should be stored.
         */
        public File getDirectory() {
            return this.directory;
        }

        public void setEnabled(final boolean enabled) {
            this.enabled = enabled;
        }

        /**
         * The maximum number of bytes this cache should use to store.
         */
        public void setMaxSize(final DataSize maxSize) {
            this.maxSize = maxSize;
        }

        /**
         * The path of the directory where the cache should be stored.
         */
        public void setDirectory(final File directory) {
            this.directory = directory;
        }

        @Override
        public boolean equals(final Object o) {
            if (o == this) return true;
            if (!(o instanceof OkHttpProperties.CacheProperties)) return false;
            final OkHttpProperties.CacheProperties other = (OkHttpProperties.CacheProperties) o;
            if (!other.canEqual((Object) this)) return false;
            if (this.isEnabled() != other.isEnabled()) return false;
            final Object this$maxSize = this.getMaxSize();
            final Object other$maxSize = other.getMaxSize();
            if (this$maxSize == null ? other$maxSize != null : !this$maxSize.equals(other$maxSize)) return false;
            final Object this$directory = this.getDirectory();
            final Object other$directory = other.getDirectory();
            if (this$directory == null ? other$directory != null : !this$directory.equals(other$directory)) return false;
            return true;
        }

        protected boolean canEqual(final Object other) {
            return other instanceof OkHttpProperties.CacheProperties;
        }

        @Override
        public int hashCode() {
            final int PRIME = 59;
            int result = 1;
            result = result * PRIME + (this.isEnabled() ? 79 : 97);
            final Object $maxSize = this.getMaxSize();
            result = result * PRIME + ($maxSize == null ? 43 : $maxSize.hashCode());
            final Object $directory = this.getDirectory();
            result = result * PRIME + ($directory == null ? 43 : $directory.hashCode());
            return result;
        }

        @Override
        public String toString() {
            return "OkHttpProperties.CacheProperties(enabled=" + this.isEnabled() + ", maxSize=" + this.getMaxSize() + ", directory=" + this.getDirectory() + ")";
        }
    }


    /**
     * @see okhttp3.ConnectionPool
     */
    public static class ConnectionPoolProperties {
        /**
         * The maximum number of idle connections for each address.
         */
        private int maxIdleConnections = 5;
        private Duration keepAliveDuration = Duration.ofMinutes(5);

        public ConnectionPoolProperties() {
        }

        /**
         * The maximum number of idle connections for each address.
         */
        public int getMaxIdleConnections() {
            return this.maxIdleConnections;
        }

        public Duration getKeepAliveDuration() {
            return this.keepAliveDuration;
        }

        /**
         * The maximum number of idle connections for each address.
         */
        public void setMaxIdleConnections(final int maxIdleConnections) {
            this.maxIdleConnections = maxIdleConnections;
        }

        public void setKeepAliveDuration(final Duration keepAliveDuration) {
            this.keepAliveDuration = keepAliveDuration;
        }

        @Override
        public boolean equals(final Object o) {
            if (o == this) return true;
            if (!(o instanceof OkHttpProperties.ConnectionPoolProperties)) return false;
            final OkHttpProperties.ConnectionPoolProperties other = (OkHttpProperties.ConnectionPoolProperties) o;
            if (!other.canEqual((Object) this)) return false;
            if (this.getMaxIdleConnections() != other.getMaxIdleConnections()) return false;
            final Object this$keepAliveDuration = this.getKeepAliveDuration();
            final Object other$keepAliveDuration = other.getKeepAliveDuration();
            if (this$keepAliveDuration == null ? other$keepAliveDuration != null : !this$keepAliveDuration.equals(other$keepAliveDuration)) return false;
            return true;
        }

        protected boolean canEqual(final Object other) {
            return other instanceof OkHttpProperties.ConnectionPoolProperties;
        }

        @Override
        public int hashCode() {
            final int PRIME = 59;
            int result = 1;
            result = result * PRIME + this.getMaxIdleConnections();
            final Object $keepAliveDuration = this.getKeepAliveDuration();
            result = result * PRIME + ($keepAliveDuration == null ? 43 : $keepAliveDuration.hashCode());
            return result;
        }

        @Override
        public String toString() {
            return "OkHttpProperties.ConnectionPoolProperties(maxIdleConnections=" + this.getMaxIdleConnections() + ", keepAliveDuration=" + this.getKeepAliveDuration() + ")";
        }
    }

    public OkHttpProperties() {
    }

    /**
     * The default connect timeout for new connections.
     */
    public Duration getConnectTimeout() {
        return this.connectTimeout;
    }

    /**
     * The default read timeout for new connections.
     */
    public Duration getReadTimeout() {
        return this.readTimeout;
    }

    /**
     * The default write timeout for new connections.
     */
    public Duration getWriteTimeout() {
        return this.writeTimeout;
    }

    /**
     * The interval between web socket pings initiated by this client. Use this to
     * automatically send web socket ping frames until either the web socket fails or it is closed.
     * This keeps the connection alive and may detect connectivity failures early. No timeouts are
     * enforced on the acknowledging pongs.
     *
     * <p>The default value of 0 disables client-initiated pings.
     */
    public Duration getPingInterval() {
        return this.pingInterval;
    }

    public CacheProperties getCache() {
        return this.cache;
    }

    /**
     * Whether to follow redirects from HTTPS to HTTP and from HTTP to HTTPS.
     */
    public boolean isFollowSslRedirects() {
        return this.followSslRedirects;
    }

    /**
     * Whether to follow redirects.
     */
    public boolean isFollowRedirects() {
        return this.followRedirects;
    }

    /**
     * Whether to retry or not when a connectivity problem is encountered.
     */
    public boolean isRetryOnConnectionFailure() {
        return this.retryOnConnectionFailure;
    }

    public ConnectionPoolProperties getConnectionPool() {
        return this.connectionPool;
    }

    /**
     * The default connect timeout for new connections.
     */
    public void setConnectTimeout(final Duration connectTimeout) {
        this.connectTimeout = connectTimeout;
    }

    /**
     * The default read timeout for new connections.
     */
    public void setReadTimeout(final Duration readTimeout) {
        this.readTimeout = readTimeout;
    }

    /**
     * The default write timeout for new connections.
     */
    public void setWriteTimeout(final Duration writeTimeout) {
        this.writeTimeout = writeTimeout;
    }

    /**
     * The interval between web socket pings initiated by this client. Use this to
     * automatically send web socket ping frames until either the web socket fails or it is closed.
     * This keeps the connection alive and may detect connectivity failures early. No timeouts are
     * enforced on the acknowledging pongs.
     *
     * <p>The default value of 0 disables client-initiated pings.
     */
    public void setPingInterval(final Duration pingInterval) {
        this.pingInterval = pingInterval;
    }

    public void setCache(final CacheProperties cache) {
        this.cache = cache;
    }

    /**
     * Whether to follow redirects from HTTPS to HTTP and from HTTP to HTTPS.
     */
    public void setFollowSslRedirects(final boolean followSslRedirects) {
        this.followSslRedirects = followSslRedirects;
    }

    /**
     * Whether to follow redirects.
     */
    public void setFollowRedirects(final boolean followRedirects) {
        this.followRedirects = followRedirects;
    }

    /**
     * Whether to retry or not when a connectivity problem is encountered.
     */
    public void setRetryOnConnectionFailure(final boolean retryOnConnectionFailure) {
        this.retryOnConnectionFailure = retryOnConnectionFailure;
    }

    @Override
    public boolean equals(final Object o) {
        if (o == this) return true;
        if (!(o instanceof OkHttpProperties)) return false;
        final OkHttpProperties other = (OkHttpProperties) o;
        if (!other.canEqual((Object) this)) return false;
        if (this.isFollowSslRedirects() != other.isFollowSslRedirects()) return false;
        if (this.isFollowRedirects() != other.isFollowRedirects()) return false;
        if (this.isRetryOnConnectionFailure() != other.isRetryOnConnectionFailure()) return false;
        final Object this$connectTimeout = this.getConnectTimeout();
        final Object other$connectTimeout = other.getConnectTimeout();
        if (this$connectTimeout == null ? other$connectTimeout != null : !this$connectTimeout.equals(other$connectTimeout)) return false;
        final Object this$readTimeout = this.getReadTimeout();
        final Object other$readTimeout = other.getReadTimeout();
        if (this$readTimeout == null ? other$readTimeout != null : !this$readTimeout.equals(other$readTimeout)) return false;
        final Object this$writeTimeout = this.getWriteTimeout();
        final Object other$writeTimeout = other.getWriteTimeout();
        if (this$writeTimeout == null ? other$writeTimeout != null : !this$writeTimeout.equals(other$writeTimeout)) return false;
        final Object this$pingInterval = this.getPingInterval();
        final Object other$pingInterval = other.getPingInterval();
        if (this$pingInterval == null ? other$pingInterval != null : !this$pingInterval.equals(other$pingInterval)) return false;
        final Object this$cache = this.getCache();
        final Object other$cache = other.getCache();
        if (this$cache == null ? other$cache != null : !this$cache.equals(other$cache)) return false;
        final Object this$connectionPool = this.getConnectionPool();
        final Object other$connectionPool = other.getConnectionPool();
        if (this$connectionPool == null ? other$connectionPool != null : !this$connectionPool.equals(other$connectionPool)) return false;
        return true;
    }

    protected boolean canEqual(final Object other) {
        return other instanceof OkHttpProperties;
    }

    @Override
    public int hashCode() {
        final int PRIME = 59;
        int result = 1;
        result = result * PRIME + (this.isFollowSslRedirects() ? 79 : 97);
        result = result * PRIME + (this.isFollowRedirects() ? 79 : 97);
        result = result * PRIME + (this.isRetryOnConnectionFailure() ? 79 : 97);
        final Object $connectTimeout = this.getConnectTimeout();
        result = result * PRIME + ($connectTimeout == null ? 43 : $connectTimeout.hashCode());
        final Object $readTimeout = this.getReadTimeout();
        result = result * PRIME + ($readTimeout == null ? 43 : $readTimeout.hashCode());
        final Object $writeTimeout = this.getWriteTimeout();
        result = result * PRIME + ($writeTimeout == null ? 43 : $writeTimeout.hashCode());
        final Object $pingInterval = this.getPingInterval();
        result = result * PRIME + ($pingInterval == null ? 43 : $pingInterval.hashCode());
        final Object $cache = this.getCache();
        result = result * PRIME + ($cache == null ? 43 : $cache.hashCode());
        final Object $connectionPool = this.getConnectionPool();
        result = result * PRIME + ($connectionPool == null ? 43 : $connectionPool.hashCode());
        return result;
    }

    @Override
    public String toString() {
        return "OkHttpProperties(connectTimeout=" + this.getConnectTimeout() + ", readTimeout=" + this.getReadTimeout() + ", writeTimeout=" + this.getWriteTimeout() + ", pingInterval=" + this.getPingInterval() + ", cache=" + this.getCache() + ", followSslRedirects=" + this.isFollowSslRedirects() + ", followRedirects=" + this.isFollowRedirects() + ", retryOnConnectionFailure=" + this.isRetryOnConnectionFailure() + ", connectionPool=" + this.getConnectionPool() + ")";
    }
}