using System;
using System.Collections.Generic;
using System.IO;
using System.Threading;
using System.Threading.Tasks;
using Minio;
namespace MinioClientTest
{
    class Program
    {
        static async Task Main()
        {
            var minIoClient = new MinioClient().WithEndpoint("localhost:9000").WithCredentials("LocalaccessKey", "localSecretKey").Build();
            var amazonClient = new MinioClient().WithEndpoint("s3.amazonaws.com").WithCredentials("s3AccessKey", "s3AccessSecret").WithSSL().WithRegion("eu-west-2").Build();
            
            var minIoSourceBucket = "default";
            var minIoSourceFilePath = "SomeLogFile.txt";

            var amazonSinkBucket = "SomeBucket";
            var amazonSinkFilePath = "SomeLogFile.txt";


            var getArgs = new GetObjectArgs().WithBucket(minIoSourceBucket)
                .WithObject(minIoSourceFilePath)
                .WithCallbackStream(async stream =>
                {
                    var memoryStream = new MemoryStream();
                    stream.CopyTo(memoryStream);
                    memoryStream.Seek(0, SeekOrigin.Begin);
                    await PutObjectAsync(amazonClient, amazonSinkBucket, amazonSinkFilePath,
                        memoryStream, memoryStream.Length, "application/octet-stream");
                
                });
            var getResult = await minIoClient.GetObjectAsync(getArgs);
        
            Console.ReadKey();
        }
        public static async Task PutObjectAsync(MinioClient mediaClient, string bucketName, string objectName, Stream data, long size, string contentType = null,
            Dictionary<string, string> metaData = null, CancellationToken cancellationToken = new CancellationToken())
        {
            var obj = new PutObjectArgs()
                .WithBucket(bucketName)
                .WithObject(objectName)
                .WithStreamData(data)
                .WithObjectSize(size);
            if (!string.IsNullOrWhiteSpace(contentType))
            {
                obj.WithContentType(contentType);
            }
            if (!(metaData is null))
            {
                obj.WithHeaders(metaData);
            }
            await mediaClient.PutObjectAsync(obj, cancellationToken);
        }
    }
}