Skip to content

Instantly share code, notes, and snippets.

@ayoisaiah
Created December 26, 2020 11:00
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 2 You must be signed in to fork a gist
  • Save ayoisaiah/1e921f0934f5973b9f83e4060caf865a to your computer and use it in GitHub Desktop.
Save ayoisaiah/1e921f0934f5973b9f83e4060caf865a to your computer and use it in GitHub Desktop.
Multipart requests in Go (feat Google Drive API)
package main
import (
"bytes"
"fmt"
"io"
"io/ioutil"
"mime/multipart"
"net/http"
"net/textproto"
"time"
)
func upload() error {
// Metadata content.
metadata := `{"name": "photo-sample.jpeg"}`
// New empty buffer
body := &bytes.Buffer{}
// Creates a new multipart Writer with a random boundary, writing to the empty
// buffer
writer := multipart.NewWriter(body)
// Metadata part
metadataHeader := textproto.MIMEHeader{}
// Set the Content-Type header
metadataHeader.Set("Content-Type", "application/json; charset=UTF-8")
// Create new multipart part
part, err := writer.CreatePart(metadataHeader)
if err != nil {
return err
}
// Write the part body
part.Write([]byte(metadata))
// Media part
// Read the file to memory
mediaData, err := ioutil.ReadFile("file.jpeg")
if err != nil {
return err
}
mediaHeader := textproto.MIMEHeader{}
mediaHeader.Set("Content-Type", "image/jpeg")
mediaPart, err := writer.CreatePart(mediaHeader)
if err != nil {
return err
}
io.Copy(mediaPart, bytes.NewReader(mediaData))
// Finish the multipart message
writer.Close()
accessToken := "<google drive access token>"
endpoint := "https://www.googleapis.com/upload/drive/v3/files?uploadType=multipart"
req, err := http.NewRequest("POST", endpoint, bytes.NewReader(body.Bytes()))
if err != nil {
return err
}
// Request Content-Type with boundary parameter.
contentType := fmt.Sprintf("multipart/related; boundary=%s", writer.Boundary())
req.Header.Set("Content-Type", contentType)
// Content-Length must be the total number of bytes in the request body.
req.Header.Set("Content-Length", fmt.Sprintf("%d", body.Len()))
req.Header.Set("Authorization", fmt.Sprintf("Bearer %s", accessToken))
client := &http.Client{Timeout: 120 * time.Second}
resp, err := client.Do(req)
if err != nil {
return err
}
defer resp.Body.Close()
// Do what you want with the response
return nil
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment