/*
    * 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.apache.maven.repository;
  
  import java.io.File;
  import java.io.IOException;
  import java.net.MalformedURLException;
  import java.net.URL;
  import java.nio.file.Files;
  import java.nio.file.Path;
  import java.util.Collection;
  
  import org.eclipse.aether.artifact.Artifact;
  import org.eclipse.aether.metadata.Metadata;
  import org.eclipse.aether.repository.RemoteRepository;
  import org.eclipse.aether.spi.connector.ArtifactDownload;
  import org.eclipse.aether.spi.connector.ArtifactUpload;
  import org.eclipse.aether.spi.connector.MetadataDownload;
  import org.eclipse.aether.spi.connector.MetadataUpload;
  import org.eclipse.aether.spi.connector.RepositoryConnector;
  import org.eclipse.aether.transfer.ArtifactNotFoundException;
  import org.eclipse.aether.transfer.ArtifactTransferException;
  import org.eclipse.aether.transfer.MetadataNotFoundException;
  import org.eclipse.aether.transfer.MetadataTransferException;
  
  /**
   * @author Benjamin Bentmann
   */
  public class TestRepositoryConnector implements RepositoryConnector {
  
      private RemoteRepository repository;
  
      private File basedir;
  
      public TestRepositoryConnector(RemoteRepository repository) {
          this.repository = repository;
          String repositoryUrl = repository.getUrl();
          if (repositoryUrl.contains("${")) {
              // the repository url contains unresolved properties and getting the basedir is not possible
              // in JDK 20+ 'new URL(string)' will fail if the string contains a curly brace
              this.basedir = null;
          } else {
              try {
                  URL url = new URL(repository.getUrl());
                  if ("file".equals(url.getProtocol())) {
                      basedir = new File(url.getPath());
                  }
              } catch (MalformedURLException e) {
                  throw new IllegalStateException(e);
              }
          }
      }
  
      public void close() {}
  
      public void get(
              Collection<? extends ArtifactDownload> artifactDownloads,
              Collection<? extends MetadataDownload> metadataDownloads) {
          if (artifactDownloads != null) {
              for (ArtifactDownload download : artifactDownloads) {
                  File remoteFile = new File(basedir, path(download.getArtifact()));
                  try {
                      Path dest = download.getFile().toPath();
                      Files.createDirectories(dest.getParent());
                      Files.copy(remoteFile.toPath(), dest);
                  } catch (IOException e) {
                      if (!remoteFile.exists()) {
                          download.setException(new ArtifactNotFoundException(download.getArtifact(), repository));
                      } else {
                          download.setException(new ArtifactTransferException(download.getArtifact(), repository, e));
                      }
                  }
              }
          }
          if (metadataDownloads != null) {
              for (final MetadataDownload download : metadataDownloads) {
                  File remoteFile = new File(basedir, path(download.getMetadata()));
                  try {
                      Path dest = download.getFile().toPath();
                      Files.createDirectories(dest.getParent());
                      Files.copy(remoteFile.toPath(), dest);
                  } catch (IOException e) {
                      if (!remoteFile.exists()) {
                         download.setException(new MetadataNotFoundException(download.getMetadata(), repository));
                     } else {
                         download.setException(new MetadataTransferException(download.getMetadata(), repository, e));
                     }
                 }
             }
         }
     }
 
     private String path(Artifact artifact) {
         StringBuilder path = new StringBuilder(128);
 
         path.append(artifact.getGroupId().replace('.', '/')).append('/');
 
         path.append(artifact.getArtifactId()).append('/');
 
         path.append(artifact.getBaseVersion()).append('/');
 
         path.append(artifact.getArtifactId()).append('-').append(artifact.getVersion());
 
         if (artifact.getClassifier().length() > 0) {
             path.append('-').append(artifact.getClassifier());
         }
 
         path.append('.').append(artifact.getExtension());
 
         return path.toString();
     }
 
     private String path(Metadata metadata) {
         StringBuilder path = new StringBuilder(128);
 
         path.append(metadata.getGroupId().replace('.', '/')).append('/');
 
         path.append(metadata.getArtifactId()).append('/');
 
         path.append("maven-metadata.xml");
 
         return path.toString();
     }
 
     public void put(
             Collection<? extends ArtifactUpload> artifactUploads,
             Collection<? extends MetadataUpload> metadataUploads) {
         // TODO Auto-generated method stub
 
     }
 }