/*
    * 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.cli.transfer;
  
  import java.util.Locale;
  
  import org.apache.maven.cli.transfer.AbstractMavenTransferListener.FileSizeFormat;
  import org.eclipse.aether.transfer.AbstractTransferListener;
  import org.eclipse.aether.transfer.TransferCancelledException;
  import org.eclipse.aether.transfer.TransferEvent;
  import org.eclipse.aether.transfer.TransferResource;
  import org.slf4j.Logger;
  import org.slf4j.LoggerFactory;
  
  /**
   * Slf4jMavenTransferListener
   */
  public class Slf4jMavenTransferListener extends AbstractTransferListener {
  
      protected final Logger out;
  
      public Slf4jMavenTransferListener() {
          this.out = LoggerFactory.getLogger(Slf4jMavenTransferListener.class);
      }
  
      // TODO should we deprecate?
      public Slf4jMavenTransferListener(Logger out) {
          this.out = out;
      }
  
      @Override
      public void transferInitiated(TransferEvent event) {
          String action = event.getRequestType() == TransferEvent.RequestType.PUT ? "Uploading" : "Downloading";
          String direction = event.getRequestType() == TransferEvent.RequestType.PUT ? "to" : "from";
  
          TransferResource resource = event.getResource();
          StringBuilder message = new StringBuilder();
          message.append(action).append(' ').append(direction).append(' ').append(resource.getRepositoryId());
          message.append(": ");
          message.append(resource.getRepositoryUrl()).append(resource.getResourceName());
  
          out.info(message.toString());
      }
  
      @Override
      public void transferCorrupted(TransferEvent event) throws TransferCancelledException {
          TransferResource resource = event.getResource();
          out.warn(
                  "{} from {} for {}{}",
                  event.getException().getMessage(),
                  resource.getRepositoryId(),
                  resource.getRepositoryUrl(),
                  resource.getResourceName());
      }
  
      @Override
      public void transferSucceeded(TransferEvent event) {
          String action = (event.getRequestType() == TransferEvent.RequestType.PUT ? "Uploaded" : "Downloaded");
          String direction = event.getRequestType() == TransferEvent.RequestType.PUT ? "to" : "from";
  
          TransferResource resource = event.getResource();
          long contentLength = event.getTransferredBytes();
          FileSizeFormat format = new FileSizeFormat(Locale.ENGLISH);
  
          StringBuilder message = new StringBuilder();
          message.append(action).append(' ').append(direction).append(' ').append(resource.getRepositoryId());
          message.append(": ");
          message.append(resource.getRepositoryUrl()).append(resource.getResourceName());
          message.append(" (").append(format.format(contentLength));
  
          long duration = System.currentTimeMillis() - resource.getTransferStartTime();
          if (duration > 0L) {
              double bytesPerSecond = contentLength / (duration / 1000.0);
              message.append(" at ").append(format.format((long) bytesPerSecond)).append("/s");
          }
  
          message.append(')');
          out.info(message.toString());
      }
  }