package fdfsclient

import (
	"fmt"
	"github.com/tedcy/fdfs_client"
	"sync"
)

var conf = "config/fdfs.conf"
var prifileExtName = "jpg"

func UploadFileByBuffer(bytes []byte, fileExtName string) string {
	client, err := fdfs_client.NewClientWithConfig(conf)
	defer client.Destory()
	if err != nil {
		fmt.Println(err.Error())
		return ""
	}
	if fileExtName == "" {
		fileExtName = prifileExtName
	}
	if fileId, err := client.UploadByBuffer(bytes, fileExtName); err != nil {
		fmt.Println(err.Error())
		return ""
	} else {
		fmt.Println(fileId)
		return fileId
	}
}

func UploadFileByBuffer100(bytess [][]byte, extNameList []string) (fields []string) {
	client, err := fdfs_client.NewClientWithConfig(conf)
	defer client.Destory()
	if err != nil {
		fmt.Println(err.Error())
		return nil
	}
	//var done = make(chan string)
	var wg sync.WaitGroup
	wg.Add(len(bytess))
	 //ch := make(chan string,2)
	for _, bytes := range bytess {
		go func() {
			defer wg.Done()
			if fileld, err := client.UploadByBuffer(bytes,"jpg"); err != nil {
				fmt.Println(err.Error())
				fields = append(fields, "")
			} else {
				//ch <- fileld
				fields = append(fields,fileld)
				fmt.Println(fileld)
			}
		}()
	}
	wg.Wait()
	return fields
}

func downloadToBuffer(field string) (bytes []byte) {
	client, err := fdfs_client.NewClientWithConfig(conf)
	defer client.Destory()
	if err != nil {
		fmt.Println(err.Error())
		return nil
	}
	err1 := client.DownloadToAllocatedBuffer(field, bytes, 0, 0)
	if err1 != nil {
		fmt.Println(err1.Error())
		return nil
	} else {
		return bytes
	}
}