main.go

package main

import (
	"context"
	"fmt"
	"github.com/gin-gonic/gin"
	"github.com/google/uuid"
	"github.com/minio/minio-go/v7"
	"github.com/minio/minio-go/v7/pkg/credentials"
	"log"
	"net/http"
	"path/filepath"
)

func main() {
	minioClient, err := minio.New("localhost:9000", &minio.Options{
		Creds:  credentials.NewStaticV4("admin", "admin123", ""),
		Secure: false,
	})
	if err != nil {
		log.Fatal(err)
	}

	// ایجاد bucket در صورت نیاز
	bucketName := "my-fat-bucket"
	err = minioClient.MakeBucket(context.Background(), bucketName, minio.MakeBucketOptions{})
	if err != nil {
		exists, bucketErr := minioClient.BucketExists(context.Background(), bucketName)
		if bucketErr == nil && exists {
			log.Println("bucket already exist")
		} else {
			log.Fatal("bucket check error :", bucketErr)
		}
	} else {
		log.Println("bucket successfully created")
	}

	r := gin.Default()
	r.LoadHTMLFiles("upload.html")

	r.GET("/upload", func(c *gin.Context) {
		c.HTML(200, "upload.html", nil)
	})

	r.POST("/upload", func(c *gin.Context) {

		// store single file
		//info, done := singleFileStore(c, minioClient, bucketName)
		//if done {
		//	return
		//}

		// multi store file
		files, err := c.MultipartForm()
		if err != nil {
			c.JSON(200, gin.H{
				"err": err,
			})
			return
		}

		if files == nil || len(files.File["files"]) == 0 {
			c.JSON(200, gin.H{
				"msg": "no files uploaded",
			})
			return
		}

		var uploadedFiles []map[string]interface{}
		for _, file := range files.File["files"] {
			// باز کردن فایل
			fileToUpload, err := file.Open()
			if err != nil {
				c.JSON(http.StatusBadRequest, gin.H{"error": "Unable to open file"})
				return
			}
			defer fileToUpload.Close()

			// استفاده از UUID برای نامگذاری فایل
			objectName := uuid.New().String()

			// آپلود فایل به MinIO
			info, err := minioClient.PutObject(
				c.Request.Context(),
				bucketName,
				"products/"+objectName+filepath.Ext(file.Filename),
				fileToUpload,
				file.Size,
				minio.PutObjectOptions{},
			)
			if err != nil {
				c.JSON(http.StatusInternalServerError, gin.H{"error": "Error uploading file"})
				return
			}

			uploadedFiles = append(uploadedFiles, map[string]interface{}{
				"info_file": info,
			})
		}

		c.JSON(200, gin.H{
			"info": uploadedFiles,
			"msg":  "files uploaded successfully",
		})
		return

	})

	fmt.Println("http://localhost:8081")
	log.Fatal(r.Run(":8081"))
}

func singleFileStore(c *gin.Context, minioClient *minio.Client, bucketName string) (minio.UploadInfo, bool) {
	file, _ := c.FormFile("files")
	if file == nil {
		c.JSON(200, gin.H{
			"msg": "file is nil",
		})
		return minio.UploadInfo{}, true
	}
	// باز کردن فایل
	fileToUpload, err := file.Open()
	if err != nil {
		c.JSON(http.StatusBadRequest, gin.H{"error": "Unable to open file"})
		return minio.UploadInfo{}, true
	}
	defer fileToUpload.Close()

	objectName := uuid.New()
	//http://localhost:9000/my-fat-bucket/products/1c13b62b-5f0d-42e7-8eec-e1955ad3b45c.jpg
	info, err := minioClient.PutObject(
		c.Request.Context(),
		bucketName,
		"products/"+objectName.String()+filepath.Ext(file.Filename),
		fileToUpload,
		file.Size,
		minio.PutObjectOptions{},
	)

	if err != nil {
		c.JSON(http.StatusInternalServerError, gin.H{"error": "Error uploading file"})
		return minio.UploadInfo{}, true
	}
	return info, false
}