/*
    * Licensed to the Apache Software Foundation (ASF) under one
    * or more contributor license agreements.  See the NOTICE file
    * distributed with this work for additional information
    * regarding copyright ownership.  The ASF licenses this file
    * to you under the Apache License, Version 2.0 (the
    * "License"); you may not use this file except in compliance
    * with the License.  You may obtain a copy of the License at
    *
   *   http://www.apache.org/licenses/LICENSE-2.0
   *
   * Unless required by applicable law or agreed to in writing,
   * software distributed under the License is distributed on an
   * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
   * KIND, either express or implied.  See the License for the
   * specific language governing permissions and limitations
   * under the License.
   */
  package org.eclipse.aether.util.repository;
  
  import java.io.IOException;
  import java.net.Authenticator;
  import java.net.InetSocketAddress;
  import java.net.PasswordAuthentication;
  import java.net.SocketAddress;
  import java.net.URI;
  import java.net.URL;
  import java.util.Arrays;
  import java.util.Collections;
  import java.util.List;
  import java.util.Objects;
  
  import org.eclipse.aether.internal.test.util.TestUtils;
  import org.eclipse.aether.repository.Authentication;
  import org.eclipse.aether.repository.AuthenticationContext;
  import org.eclipse.aether.repository.Proxy;
  import org.eclipse.aether.repository.ProxySelector;
  import org.eclipse.aether.repository.RemoteRepository;
  import org.junit.jupiter.api.AfterEach;
  import org.junit.jupiter.api.BeforeEach;
  import org.junit.jupiter.api.Test;
  
  import static org.junit.jupiter.api.Assertions.*;
  
  public class JreProxySelectorTest {
  
      private abstract static class AbstractProxySelector extends java.net.ProxySelector {
          @Override
          public void connectFailed(URI uri, SocketAddress sa, IOException ioe) {}
      }
  
      private final ProxySelector selector = new JreProxySelector();
  
      private java.net.ProxySelector original;
  
      @BeforeEach
      void init() {
          original = java.net.ProxySelector.getDefault();
      }
  
      @AfterEach
      void exit() {
          java.net.ProxySelector.setDefault(original);
          Authenticator.setDefault(null);
      }
  
      @Test
      void testGetProxy_InvalidUrl() {
          RemoteRepository repo = new RemoteRepository.Builder("test", "default", "http://host:invalid").build();
          assertNull(selector.getProxy(repo));
      }
  
      @Test
      void testGetProxy_OpaqueUrl() {
          RemoteRepository repo = new RemoteRepository.Builder("test", "default", "classpath:base").build();
          assertNull(selector.getProxy(repo));
      }
  
      @Test
      void testGetProxy_NullSelector() {
          RemoteRepository repo = new RemoteRepository.Builder("test", "default", "http://repo.eclipse.org/").build();
          java.net.ProxySelector.setDefault(null);
          assertNull(selector.getProxy(repo));
      }
  
      @Test
      void testGetProxy_NoProxies() {
          RemoteRepository repo = new RemoteRepository.Builder("test", "default", "http://repo.eclipse.org/").build();
          java.net.ProxySelector.setDefault(new AbstractProxySelector() {
              @Override
              public List<java.net.Proxy> select(URI uri) {
                  return Collections.emptyList();
              }
          });
          assertNull(selector.getProxy(repo));
      }
  
      @Test
      void testGetProxy_DirectProxy() {
         RemoteRepository repo = new RemoteRepository.Builder("test", "default", "http://repo.eclipse.org/").build();
         final InetSocketAddress addr = InetSocketAddress.createUnresolved("proxy", 8080);
         java.net.ProxySelector.setDefault(new AbstractProxySelector() {
             @Override
             public List<java.net.Proxy> select(URI uri) {
                 return Arrays.asList(java.net.Proxy.NO_PROXY, new java.net.Proxy(java.net.Proxy.Type.HTTP, addr));
             }
         });
         assertNull(selector.getProxy(repo));
     }
 
     @Test
     void testGetProxy_HttpProxy() throws Exception {
         final RemoteRepository repo =
                 new RemoteRepository.Builder("test", "default", "http://repo.eclipse.org/").build();
         final URL url = new URI(repo.getUrl()).toURL();
         final InetSocketAddress addr = InetSocketAddress.createUnresolved("proxy", 8080);
         java.net.ProxySelector.setDefault(new AbstractProxySelector() {
             @Override
             public List<java.net.Proxy> select(URI uri) {
                 if (repo.getHost().equalsIgnoreCase(uri.getHost())) {
                     return Collections.singletonList(new java.net.Proxy(java.net.Proxy.Type.HTTP, addr));
                 }
                 return Collections.emptyList();
             }
         });
         Authenticator.setDefault(new Authenticator() {
             @Override
             protected PasswordAuthentication getPasswordAuthentication() {
                 if (Authenticator.RequestorType.PROXY.equals(getRequestorType())
                         && addr.getHostName().equals(getRequestingHost())
                         && addr.getPort() == getRequestingPort()
                         && Objects.equals(url, getRequestingURL())) {
                     return new PasswordAuthentication("proxyuser", "proxypass".toCharArray());
                 }
                 return super.getPasswordAuthentication();
             }
         });
 
         Proxy proxy = selector.getProxy(repo);
         assertNotNull(proxy);
         assertEquals(addr.getHostName(), proxy.getHost());
         assertEquals(addr.getPort(), proxy.getPort());
         assertEquals(Proxy.TYPE_HTTP, proxy.getType());
 
         RemoteRepository repo2 =
                 new RemoteRepository.Builder(repo).setProxy(proxy).build();
         Authentication auth = proxy.getAuthentication();
         assertNotNull(auth);
         try (AuthenticationContext authCtx = AuthenticationContext.forProxy(TestUtils.newSession(), repo2)) {
             assertEquals("proxyuser", authCtx.get(AuthenticationContext.USERNAME));
             assertEquals("proxypass", authCtx.get(AuthenticationContext.PASSWORD));
         }
     }
 }