11 "github.com/minio/minio-go/v7"
12 "github.com/minio/minio-go/v7/pkg/credentials"
13 "github.com/stretchr/testify/assert"
16 func TestMake_minio_bucket(t *testing.T) {
18 endpoint := "play.min.io:9000"
19 accessKey := "Q3AM3UQ867SPQQA43P2F"
20 secretKey := "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG"
22 minioClient, err := minio.New(endpoint, &minio.Options{
23 Creds: credentials.NewStaticV4(accessKey, secretKey, ""),
27 log.Fatalf("Error creating Minio client: %v", err)
30 if _, err := minioClient.ListBuckets(context.Background()); err != nil {
31 log.Fatalf("Error connecting to Minio server: %v", err)
34 // Create a test bucket.
35 bucketName := "my-test-bucket"
36 err = create_minio_bucket(minioClient, bucketName)
38 log.Fatalf("Error creating bucket: %v", err)
40 assert.NoError(t, err)
44 func Test_bucket_cannot_empty(t *testing.T) {
46 endpoint := "play.min.io:9000"
47 accessKey := "Q3AM3UQ867SPQQA43P2F"
48 secretKey := "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG"
50 minioClient, err := minio.New(endpoint, &minio.Options{
51 Creds: credentials.NewStaticV4(accessKey, secretKey, ""),
55 log.Fatalf("Error creating Minio client: %v", err)
58 if _, err := minioClient.ListBuckets(context.Background()); err != nil {
59 log.Fatalf("Error connecting to Minio server: %v", err)
62 // Create a test bucket.
64 err = create_minio_bucket(minioClient, bucketName)
68 assert.NoError(t, err)
72 func Test_check_minio_bucket(t *testing.T) {
74 endpoint := "play.min.io:9000"
75 accessKey := "Q3AM3UQ867SPQQA43P2F"
76 secretKey := "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG"
80 minioClient, err := minio.New(endpoint, &minio.Options{
81 Creds: credentials.NewStaticV4(accessKey, secretKey, ""),
85 log.Fatalf("Error creating Minio client: %v", err)
88 if _, err := minioClient.ListBuckets(context.Background()); err != nil {
89 log.Fatalf("Error connecting to Minio server: %v", err)
92 // Create a test bucket.
93 bucketName := "my-test-bucket"
94 found = check_minio_bucket(minioClient, bucketName)
98 assert.False(t, found)
102 func Test_bucket_not_exists(t *testing.T) {
104 endpoint := "play.min.io:9000"
105 accessKey := "Q3AM3UQ867SPQQA43P2F"
106 secretKey := "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG"
110 minioClient, err := minio.New(endpoint, &minio.Options{
111 Creds: credentials.NewStaticV4(accessKey, secretKey, ""),
115 log.Fatalf("Error creating Minio client: %v", err)
118 if _, err := minioClient.ListBuckets(context.Background()); err != nil {
119 log.Fatalf("Error connecting to Minio server: %v", err)
122 // Create a test bucket.
123 bucketName := "my-test-bucket-not-exists"
124 found = check_minio_bucket(minioClient, bucketName)
126 assert.True(t, found)
128 assert.False(t, found)
132 func Test_upload_object(t *testing.T) {
134 endpoint := "play.min.io:9000"
135 accessKey := "Q3AM3UQ867SPQQA43P2F"
136 secretKey := "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG"
138 minioClient, err := minio.New(endpoint, &minio.Options{
139 Creds: credentials.NewStaticV4(accessKey, secretKey, ""),
143 log.Fatalf("Error creating Minio client: %v", err)
146 if _, err := minioClient.ListBuckets(context.Background()); err != nil {
147 log.Fatalf("Error connecting to Minio server: %v", err)
150 json_filename := "minio_upload_test.json"
152 fi, err := os.Open(json_filename)
155 t.Fatalf("File %s - cannot be opened - discarding message, error details: %s", json_filename, err.Error())
161 var buf3 bytes.Buffer
162 _, err2 := io.Copy(&buf3, reader)
164 t.Fatalf("File %s - cannot be read, discarding message, %s", json_filename, err.Error())
167 file_bytes := buf3.Bytes()
169 // Create a test bucket.
170 bucketName := "my-test-bucket"
171 upload_object(minioClient, file_bytes, "minio_upload_test.json", bucketName)
173 assert.NoError(t, err)