mirror of
https://github.com/michaellindman/discoupload.git
synced 2024-12-18 19:04:29 +00:00
109 lines
2.0 KiB
Go
109 lines
2.0 KiB
Go
package main
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/json"
|
|
"flag"
|
|
"fmt"
|
|
"io/ioutil"
|
|
"log"
|
|
"mime/multipart"
|
|
"net/http"
|
|
"os"
|
|
"path/filepath"
|
|
|
|
"github.com/michaellindman/request"
|
|
"github.com/pkg/errors"
|
|
)
|
|
|
|
func main() {
|
|
if err := run(); err != nil {
|
|
log.Fatalf("%s\n", err)
|
|
}
|
|
}
|
|
|
|
func run() error {
|
|
dir, err := filepath.Abs(filepath.Dir(os.Args[0]))
|
|
if err != nil {
|
|
return errors.Wrap(err, "directory")
|
|
}
|
|
cfg, err := NewConfig(dir + "/config.yml")
|
|
if err != nil {
|
|
return errors.Wrap(err, "config")
|
|
}
|
|
flag.Usage = func() {
|
|
fmt.Printf("Usage of %s:\n", os.Args[0])
|
|
flag.PrintDefaults()
|
|
}
|
|
file := flag.String("file", "", "path for file to be uploaded")
|
|
flag.Parse()
|
|
if *file != "" {
|
|
upload, err := upload(cfg, *file)
|
|
if err != nil {
|
|
return errors.Wrap(err, "upload")
|
|
}
|
|
fmt.Printf("Uploaded %v (%v): %v\n", upload["original_filename"], upload["human_filesize"], upload["url"])
|
|
return nil
|
|
}
|
|
flag.PrintDefaults()
|
|
return nil
|
|
}
|
|
|
|
func upload(cfg *Config, filepath string) (response map[string]interface{}, err error) {
|
|
params := map[string]string{
|
|
"type": "upload",
|
|
"synchronous": "true",
|
|
}
|
|
|
|
file, err := os.Open(filepath)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
contents, err := ioutil.ReadAll(file)
|
|
if err != nil {
|
|
file.Close()
|
|
return nil, err
|
|
}
|
|
stat, err := file.Stat()
|
|
if err != nil {
|
|
file.Close()
|
|
return nil, err
|
|
}
|
|
err = file.Close()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
body := &bytes.Buffer{}
|
|
writer := multipart.NewWriter(body)
|
|
part, err := writer.CreateFormFile("file", stat.Name())
|
|
part.Write(contents)
|
|
|
|
for key, val := range params {
|
|
writer.WriteField(key, val)
|
|
}
|
|
|
|
err = writer.Close()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
headers := map[string]string{
|
|
"Api-Key": cfg.API.Key,
|
|
"Api-Username": cfg.API.Username,
|
|
"Content-Type": writer.FormDataContentType(),
|
|
}
|
|
|
|
resp, err := request.API(http.MethodPost, cfg.API.URL+"/uploads", headers, body)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
err = json.Unmarshal(resp.Body, &response)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return response, nil
|
|
}
|