added test data, and uploading functionality

api/ipfs/pinning/pinning.go

@@ -5,6 +5,7 @@ import (
 	"encoding/json"
 	"fmt"
 	"io"
+	"mime/multipart"
 	"net/http"
 	"strings"
 
@@ -64,6 +65,19 @@ func (o *Origins) UnmarshalJSON(data []byte) error {
 	return nil
 }
 
+type UploadObjectResponse struct {
+	RequestID string                   `json:"requestId"`
+	Status    string                   `json:"status"`
+	Created   string                   `json:"created"`
+	Pin       PinnedObjectPayload      `json:"pin"`
+	Info      UploadObjectResponseInfo `json:"info"`
+	Delegates []string                 `json:"delegates"`
+}
+
+type UploadObjectResponseInfo struct {
+	Size string `json:"size"`
+}
+
 type PinningAPI struct {
 	API *client.APIWrapper
 }
@@ -282,3 +296,57 @@ func (p *PinningAPI) DeletePinnedObject(requestID string) (bool, error) {
 
 	return status, nil
 }
+
+func (p *PinningAPI) UploadObject(body []byte, key, contentType string) (UploadObjectResponse, error) {
+	p.API.SetBaseURL("https://api.quicknode.com/ipfs/rest/v1/s3/put-object")
+	endpoint := p.API.BaseURL
+
+	requestBody := bytes.Buffer{}
+	writer := multipart.NewWriter(&requestBody)
+
+	part, err := writer.CreateFormFile("Body", "file")
+	if err != nil {
+		return UploadObjectResponse{}, err
+	}
+	_, err = part.Write(body)
+	if err != nil {
+		return UploadObjectResponse{}, err
+	}
+
+	// Add other form fields
+	_ = writer.WriteField("Key", key)
+	_ = writer.WriteField("ContentType", contentType)
+
+	err = writer.Close()
+	if err != nil {
+		return UploadObjectResponse{}, err
+	}
+
+	req, err := http.NewRequest("POST", endpoint, &requestBody)
+	if err != nil {
+		return UploadObjectResponse{}, err
+	}
+	req.Header.Set("Content-Type", writer.FormDataContentType())
+
+	resp, err := p.API.Client.Do(req)
+	if err != nil {
+		return UploadObjectResponse{}, err
+	}
+	defer resp.Body.Close()
+
+	responseBody, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return UploadObjectResponse{}, err
+	}
+
+	if resp.StatusCode < 200 || resp.StatusCode >= 300 {
+		return UploadObjectResponse{}, fmt.Errorf("failed to upload object: %s", responseBody)
+	}
+
+	var uploadObjectResponse UploadObjectResponse
+	err = json.Unmarshal(responseBody, &uploadObjectResponse)
+	if err != nil {
+		return UploadObjectResponse{}, err
+	}
+	return uploadObjectResponse, nil
+}

api/ipfs/pinning/pinning_test.go

@@ -133,6 +133,23 @@ func TestDeletePinnedObject(t *testing.T) {
 	}
 }
 
+func TestUploadObject(t *testing.T) {
+	apiToken := os.Getenv("QUICKNODE_API_TOKEN")
+	apiWrapper := client.NewAPIWrapper(apiToken, "https://api.quicknode.com/ipfs/rest/v1/s3/put-object")
+
+	pinningAPI := &PinningAPI{API: apiWrapper}
+
+	fileContent, err := os.ReadFile("test_data/grumpy.jpg")
+	if err != nil {
+		t.Errorf("Unexpected error: %v", err)
+	}
+
+	_, err = pinningAPI.UploadObject(fileContent, "grumpy.jpg", "image/jpeg")
+	if err != nil {
+		t.Errorf("Unexpected error: %v", err)
+	}
+}
+
 func randomString(length int) string {
 	b := make([]byte, length)
 	for i := range b {