package test

import (
	"context"
	"github.com/minio/minio-go/v7/pkg/credentials"
	"log"
	"testing"
	"github.com/minio/minio-go/v7"
)

/**
@author 王世彪
	个人博客: https://sofineday.com?from=apiproject
	微信: 645102170
	QQ: 645102170
*/

/**
测试MinIO对象存储服务的sdk
 */
func TestMinIO(t *testing.T) {
	ctx := context.Background()
	endpoint := "172.18.100.177:9000"
	accessKeyID := "minioadmin"
	secretAccessKey := "minioadmin"
	useSSL := false

	// Initialize minio client object.
	minioClient, err := minio.New(endpoint, &minio.Options{
		Creds:  credentials.NewStaticV4(accessKeyID, secretAccessKey, ""),
		Secure: useSSL,
	})
	if err != nil {
		log.Fatalln(err)
	}

	// Make a new bucket called mymusic.
	bucketName := "mymusic"
	location := "us-east-1"

	err = minioClient.MakeBucket(ctx, bucketName, minio.MakeBucketOptions{Region: location})
	if err != nil {
		// Check to see if we already own this bucket (which happens if you run this twice)
		exists, errBucketExists := minioClient.BucketExists(ctx, bucketName)
		if errBucketExists == nil && exists {
			log.Printf("We already own %sn", bucketName)
		} else {
			log.Fatalln(err)
		}
	} else {
		log.Printf("Successfully created %sn", bucketName)
	}

	// Upload the zip file
	objectName := "百事可乐的视频1"
	filePath := "/home/wangshibiao/test/百事可乐创意广告恶搞伦敦路人.mp4"
	contentType := "video/mpeg4"

	// Upload the zip file with FPutObject
	n, err := minioClient.FPutObject(ctx, bucketName, objectName, filePath, minio.PutObjectOptions{ContentType: contentType})
	if err != nil {
		log.Fatalln(err)
	}
	log.Println(n)

	log.Printf("Successfully uploaded %sn", objectName)
}

/ # mc ls minio/mymusic
[2020-10-30 02:23:28 UTC]  14MiB 百事可乐的视频1
/ #