package org.oxerr.vividseats.client.rescu.impl;
   
   import java.util.function.Supplier;
   
   import org.apache.commons.lang3.ArrayUtils;
   import org.oxerr.rescu.ext.singleton.RestProxyFactorySingletonImpl;
   import org.oxerr.vividseats.client.VividSeatsClient;
   import org.oxerr.vividseats.client.inventory.ListingService;
   import org.oxerr.vividseats.client.rescu.impl.inventory.ListingServiceImpl;
  import org.oxerr.vividseats.client.rescu.resource.inventory.ListingResource;
  
  import com.fasterxml.jackson.annotation.JsonInclude.Include;
  import com.fasterxml.jackson.databind.DeserializationFeature;
  import com.fasterxml.jackson.databind.ObjectMapper;
  import com.fasterxml.jackson.databind.SerializationFeature;
  import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
  
  import io.github.poshjosh.ratelimiter.store.BandwidthsStore;
  import jakarta.ws.rs.HeaderParam;
  import si.mazi.rescu.ClientConfig;
  import si.mazi.rescu.IRestProxyFactory;
  import si.mazi.rescu.Interceptor;
  import si.mazi.rescu.RestProxyFactoryImpl;
  import si.mazi.rescu.serialization.jackson.DefaultJacksonObjectMapperFactory;
  import si.mazi.rescu.serialization.jackson.JacksonObjectMapperFactory;
  
  public class ResCUVividSeatsClient implements VividSeatsClient {
  
  	private static final String DEFAULT_BASE_URL = "https://brokers.vividseats.com/webservices";
  
  	private final String baseUrl;
  
  	private final IRestProxyFactory restProxyFactory;
  
  	private final ListingService listingService;
  
  	/**
  	 * Constructs a client with the specified token.
  	 *
  	 * @param token the token to access the API.
  	 * @param interceptors the interceptors to intercept the requests.
  	 */
  	public ResCUVividSeatsClient(String token, Interceptor... interceptors) {
  		this(DEFAULT_BASE_URL, token, interceptors);
  	}
  
  	/**
  	 * Constructs a client with the specified token.
  	 *
  	 * @param token the token to access the API.
  	 * @param bandwidthsStore the bandwidths store to store the bandwidth.
  	 * @param interceptors the interceptors to intercept the requests.
  	 */
  	public ResCUVividSeatsClient(String token, BandwidthsStore<String> bandwidthsStore, Interceptor... interceptors) {
  		this(DEFAULT_BASE_URL, token, bandwidthsStore, interceptors);
  	}
  
  	/**
  	 * Constructs a client with the specified token.
  	 *
  	 * @param tokenSupplier the token supplier to access the API.
  	 * @param interceptors the interceptors to intercept the requests.
  	 */
  	public ResCUVividSeatsClient(Supplier<String> tokenSupplier, Interceptor... interceptors) {
  		this(DEFAULT_BASE_URL, tokenSupplier, interceptors);
  	}
  
  	/**
  	 * Constructs a client with the specified token.
  	 *
  	 * @param tokenSupplier the token supplier to access the API.
  	 * @param bandwidthsStore the bandwidths store to store the bandwidth.
  	 * @param interceptors the interceptors to intercept the requests.
  	 */
  	public ResCUVividSeatsClient(Supplier<String> tokenSupplier, BandwidthsStore<String> bandwidthsStore, Interceptor... interceptors) {
  		this(DEFAULT_BASE_URL, tokenSupplier, bandwidthsStore, interceptors);
  	}
  
  	/**
  	 * Constructs a client with the specified base URL and token.
  	 *
  	 * @param baseUrl the base URL of the API.
  	 * @param token the token to access the API.
  	 * @param interceptors the interceptors to intercept the requests.
  	 */
  	public ResCUVividSeatsClient(String baseUrl, String token, Interceptor... interceptors) {
  		this(baseUrl, () -> token, interceptors);
  	}
  
  	/**
  	 * Constructs a client with the specified base URL and token.
  	 *
  	 * @param baseUrl the base URL of the API.
  	 * @param tokenSupplier the token supplier to access the API.
  	 * @param interceptors the interceptors to intercept the requests.
  	 */
  	public ResCUVividSeatsClient(String baseUrl, Supplier<String> tokenSupplier, Interceptor... interceptors) {
  		this(baseUrl, tokenSupplier, BandwidthsStore.ofDefaults(), interceptors);
  	}
 
 	/**
 	 * Constructs a client with the specified base URL, token and bandwidths store.
 	 *
 	 * @param baseUrl the base URL of the API.
 	 * @param token the token to access the API.
 	 * @param bandwidthsStore the bandwidths store to store the bandwidth.
 	 * @param interceptors the interceptors to intercept the requests.
 	 */
 	public ResCUVividSeatsClient(String baseUrl, String token, BandwidthsStore<String> bandwidthsStore, Interceptor... interceptors) {
 		this(baseUrl, () -> token, bandwidthsStore, interceptors);
 	}
 
 	/**
 	 * Constructs a client with the specified base URL, token supplier, bandwidths store and interceptors.
 	 *
 	 * @param baseUrl the base URL of the API.
 	 * @param tokenSupplier the token supplier to access the API.
 	 * @param bandwidthsStore the bandwidths store to store the bandwidth.
 	 * @param interceptors the interceptors to intercept the requests.
 	 */
 	public ResCUVividSeatsClient(String baseUrl, Supplier<String> tokenSupplier, BandwidthsStore<String> bandwidthsStore, Interceptor... interceptors) {
 		this.baseUrl = baseUrl;
 		JacksonObjectMapperFactory jacksonObjectMapperFactory = createJacksonObjectMapperFactory();
 		var clientConfigV1 = createClientConfigV1(jacksonObjectMapperFactory);
 		var clientConfig = createClientConfig(jacksonObjectMapperFactory, tokenSupplier);
 		this.restProxyFactory = new RestProxyFactorySingletonImpl(new RestProxyFactoryImpl());
 		this.listingService = new ListingServiceImpl(
 			tokenSupplier,
 			this.restProxyFactory.createProxy(org.oxerr.vividseats.client.rescu.resource.v1.inventory.ListingResource.class, baseUrl, clientConfigV1, interceptors),
 			createProxy(ListingResource.class, clientConfig, bandwidthsStore, interceptors)
 		);
 	}
 
 	@Override
 	public ListingService getListingService() {
 		return this.listingService;
 	}
 
 	protected <I> I createProxy(Class<I> restInterface, ClientConfig clientConfig, BandwidthsStore<String> bandwidthsStore, Interceptor... interceptors) {
 		var rateLimiterInterceptor = new RateLimiterInterceptor(bandwidthsStore);
 		return createProxy(restInterface, clientConfig, ArrayUtils.add(interceptors, rateLimiterInterceptor));
 	}
 
 	protected <I> I createProxy(Class<I> restInterface, ClientConfig clientConfig, Interceptor... interceptors) {
 		return this.restProxyFactory.createProxy(restInterface, baseUrl, clientConfig, interceptors);
 	}
 
 	protected ClientConfig createClientConfigV1(JacksonObjectMapperFactory jacksonObjectMapperFactory) {
 		var clientConfig = new ClientConfig();
 		clientConfig.setJacksonObjectMapperFactory(jacksonObjectMapperFactory);
 		return clientConfig;
 	}
 
 	protected ClientConfig createClientConfig(JacksonObjectMapperFactory jacksonObjectMapperFactory, Supplier<String> tokenSupplier) {
 		var clientConfig = new ClientConfig();
 		clientConfig.addDefaultParam(HeaderParam.class, "Api-token", new Object() {
 
 			@Override
 			public String toString() {
 				return tokenSupplier.get();
 			}
 
 		});
 		clientConfig.setJacksonObjectMapperFactory(jacksonObjectMapperFactory);
 		return clientConfig;
 	}
 
 	protected JacksonObjectMapperFactory createJacksonObjectMapperFactory() {
 		return new DefaultJacksonObjectMapperFactory() {
 
 			@Override
 			public void configureObjectMapper(ObjectMapper objectMapper) {
 				super.configureObjectMapper(objectMapper);
 				objectMapper.registerModule(new JavaTimeModule());
 				objectMapper.setSerializationInclusion(Include.NON_ABSENT);
 				objectMapper.configure(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS, false);
 				objectMapper.configure(DeserializationFeature.READ_DATE_TIMESTAMPS_AS_NANOSECONDS, false);
 				objectMapper.configure(DeserializationFeature.ADJUST_DATES_TO_CONTEXT_TIME_ZONE, false);
 			}
 
 		};
 	}
 
 }