Write/Commit a file (#126)

* feat: implement WriteFileBlob

* chore: reformat structs to not mess up the diff

Author: eh-am

bitbucket.go

@@ -158,6 +158,17 @@ type RepositoryBlobOptions struct {
 	Path     string `json:"path"`
 }
 
+// Based on https://developer.atlassian.com/bitbucket/api/2/reference/resource/repositories/%7Bworkspace%7D/%7Brepo_slug%7D/src#post
+type RepositoryBlobWriteOptions struct {
+	Owner    string `json:"owner"`
+	RepoSlug string `json:"repo_slug"`
+	FilePath string `json:"filepath"`
+	FileName string `json:"filename"`
+	Author   string `json:"author"`
+	Message  string `json:"message"`
+	Branch   string `json:"branch"`
+}
+
 type RepositoryBranchOptions struct {
 	Owner      string `json:"owner"`
 	RepoSlug   string `json:"repo_slug"`

client.go

@@ -262,7 +262,7 @@ func (c *Client) execute(method string, urlStr string, text string) (interface{}
 	return result, nil
 }
 
-func (c *Client) executeFileUpload(method string, urlStr string, filePath string, fileName string) (interface{}, error) {
+func (c *Client) executeFileUpload(method string, urlStr string, filePath string, fileName string, fieldname string, params map[string]string) (interface{}, error) {
 	fileReader, err := os.Open(filePath)
 	if err != nil {
 		return nil, err
@@ -274,14 +274,21 @@ func (c *Client) executeFileUpload(method string, urlStr string, filePath string
 	w := multipart.NewWriter(&b)
 
 	var fw io.Writer
-	if fw, err = w.CreateFormFile("files", fileName); err != nil {
+	if fw, err = w.CreateFormFile(fieldname, fileName); err != nil {
 		return nil, err
 	}
 
 	if _, err = io.Copy(fw, fileReader); err != nil {
 		return nil, err
 	}
 
+	for key, value := range params {
+		err = w.WriteField(key, value)
+		if err != nil {
+			return nil, err
+		}
+	}
+
 	// Don't forget to close the multipart writer.
 	// If you don't close it, your request will be missing the terminating boundary.
 	w.Close()

downloads.go

@@ -6,7 +6,7 @@ type Downloads struct {
 
 func (dl *Downloads) Create(do *DownloadsOptions) (interface{}, error) {
 	urlStr := dl.c.requestUrl("/repositories/%s/%s/downloads", do.Owner, do.RepoSlug)
-	return dl.c.executeFileUpload("POST", urlStr, do.FilePath, do.FileName)
+	return dl.c.executeFileUpload("POST", urlStr, do.FilePath, do.FileName, "files", make(map[string]string))
 }
 
 func (dl *Downloads) List(do *DownloadsOptions) (interface{}, error) {

repository.go

@@ -244,6 +244,27 @@ func (r *Repository) GetFileBlob(ro *RepositoryBlobOptions) (*RepositoryBlob, er
 	return &blob, nil
 }
 
+func (r *Repository) WriteFileBlob(ro *RepositoryBlobWriteOptions) error {
+	m := make(map[string]string)
+
+	if ro.Author != "" {
+		m["author"] = ro.Author
+	}
+
+	if ro.Message != "" {
+		m["message"] = ro.Message
+	}
+
+	if ro.Branch != "" {
+		m["branch"] = ro.Branch
+	}
+
+	urlStr := r.c.requestUrl("/repositories/%s/%s/src", ro.Owner, ro.RepoSlug)
+
+	_, err := r.c.executeFileUpload("POST", urlStr, ro.FilePath, ro.FileName, ro.FileName, m)
+	return err
+}
+
 func (r *Repository) ListBranches(rbo *RepositoryBranchOptions) (*RepositoryBranches, error) {
 
 	params := url.Values{}