feat: add file upload support

.vscode/launch.json

@@ -0,0 +1,15 @@
+{
+    // Use IntelliSense to learn about possible attributes.
+    // Hover to view descriptions of existing attributes.
+    // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
+    "version": "0.2.0",
+    "configurations": [
+        {
+            "name": "Launch Package",
+            "type": "go",
+            "request": "launch",
+            "mode": "auto",
+            "program": "main.go",
+        }
+    ]
+}

bingads/bulk.go

@@ -1,7 +1,14 @@
 package bingads
 
 import (
+	"bytes"
+	"encoding/json"
 	"encoding/xml"
+	"io"
+	"mime/multipart"
+	"net/http"
+	"os"
+	"path/filepath"
 	"strconv"
 )
 
@@ -29,7 +36,20 @@ type GetBulkUploadUrlResponse struct {
 	RequestId string `xml:"RequestId"`
 }
 
-// GetBulkCampaignsByAccountId
+type GetBulkUploadStatusRequest struct {
+	XMLName   xml.Name `xml:"GetBulkUploadStatusRequest"`
+	NS        string   `xml:"xmlns,attr"`
+	RequestId string   `xml:"RequestId"`
+}
+
+type GetBulkUploadStatusResponse struct {
+	XMLName         xml.Name `xml:"GetBulkUploadStatusResponse"`
+	NS              string   `xml:"xmlns,attr"`
+	PercentComplete int64    `xml:"PercentComplete"`
+	RequestStatus   string   `xml:"RequestStatus"`
+}
+
+// GetBulkUploadUrl
 func (c *BulkService) GetBulkUploadUrl() (*GetBulkUploadUrlResponse, error) {
 	accountId, _ := strconv.ParseInt(c.Session.AccountId, 10, 64)
 	req := GetBulkUploadUrlRequest{
@@ -49,3 +69,82 @@ func (c *BulkService) GetBulkUploadUrl() (*GetBulkUploadUrlResponse, error) {
 	}
 	return &getBulkUploadUrlResponse, nil
 }
+
+// GetBulkUploadUrl
+func (c *BulkService) GetBulkUploadStatus(requestId string) (*GetBulkUploadStatusResponse, error) {
+	req := GetBulkUploadStatusRequest{
+		NS:        BingNamespace,
+		RequestId: requestId,
+	}
+
+	resp, err := c.Session.SendRequest(req, c.Endpoint, "GetBulkUploadStatus")
+	if err != nil {
+		return nil, err
+	}
+
+	var getBulkUploadStatusResponse GetBulkUploadStatusResponse
+	if err = xml.Unmarshal(resp, &getBulkUploadStatusResponse); err != nil {
+		return nil, err
+	}
+	return &getBulkUploadStatusResponse, nil
+}
+
+type UploadBulkFileResponse struct {
+	TrackingId string `json:"TrackingId"`
+	RequestId  string `json:"RequestId"`
+}
+
+func (c *BulkService) UploadBulkFile(url string, filename string) (*UploadBulkFileResponse, error) {
+	file, err := os.Open(filename)
+	if err != nil {
+		return nil, err
+	}
+	defer file.Close()
+
+	payload := &bytes.Buffer{}
+	writer := multipart.NewWriter(payload)
+	part1, err := writer.CreateFormFile("", filepath.Base(filename))
+	if err != nil {
+		return nil, err
+	}
+	_, err = io.Copy(part1, file)
+	if err != nil {
+		return nil, err
+	}
+
+	if err = writer.Close(); err != nil {
+		return nil, err
+	}
+	req, err := http.NewRequest("POST", url, payload)
+	if err != nil {
+		return nil, err
+	}
+
+	token, err := c.Session.TokenSource.Token()
+	if err != nil {
+		return nil, err
+	}
+	req.Header.Set("Content-Type", writer.FormDataContentType())
+	req.Header.Set("AuthenticationToken", token.AccessToken)
+	req.Header.Add("DeveloperToken", c.Session.DeveloperToken)
+	req.Header.Add("CustomerId", c.Session.CustomerId)
+	req.Header.Add("AccountId", c.Session.AccountId)
+
+	resp, err := c.Session.HTTPClient.Do(req)
+	if err != nil {
+		return nil, err
+	}
+	defer resp.Body.Close()
+
+	body, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return nil, err
+	}
+	var uploadBulkFileResponse UploadBulkFileResponse
+
+	if err = json.Unmarshal(body, &uploadBulkFileResponse); err != nil {
+		return nil, err
+	}
+
+	return &uploadBulkFileResponse, nil
+}

main.go

@@ -6,6 +6,7 @@ import (
 	"fmt"
 	"log"
 	"net/http"
+	"time"
 
 	"os"
 	"strings"
@@ -45,7 +46,7 @@ func generate_access_token(config *oauth2.Config) (*oauth2.Token, error) {
 
 func get_session_config(config *oauth2.Config, token *oauth2.Token) bingads.SessionConfig {
 	return bingads.SessionConfig{
-		OAuth2Config:  config,
+		OAuth2Config:   config,
 		OAuth2Token:    token,
 		AccountId:      os.Getenv("CUSTOMER_ACCOUNT_ID"),
 		CustomerId:     os.Getenv("CUSTOMER_ID"),
@@ -78,9 +79,29 @@ func main() {
 	}
 	session := bingads.NewSession(get_session_config(oauth2Config, token))
 	service := bingads.NewBulkService(session)
-	resp, err := service.GetBulkUploadUrl()
+	urlResp, err := service.GetBulkUploadUrl()
 	if err != nil {
 		log.Fatal(err)
 	}
-	fmt.Printf("%#v\n", resp)
+	fmt.Printf("urlResp %#v\n", urlResp)
+
+	uploadBulkFileResp, err := service.UploadBulkFile(urlResp.UploadUrl, "testfile.zip")
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	fmt.Printf("uploadBulkFileResp %#v\n", uploadBulkFileResp)
+	var uploadStatus *bingads.GetBulkUploadStatusResponse
+	for {
+		time.Sleep(5 * time.Second)
+		uploadStatus, err = service.GetBulkUploadStatus(uploadBulkFileResp.RequestId)
+		if err != nil {
+			log.Fatal(err)
+			break
+		}
+		fmt.Printf("%#v", uploadStatus)
+		if uploadStatus.RequestStatus == "Completed" {
+			break
+		}
+	}
 }