feat(api): OpenAPI spec update via Stainless API (#2031)

.stats.yml

@@ -1,2 +1,2 @@
 configured_endpoints: 1286
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/cloudflare%2Fcloudflare-5a44a591dcd3f86f8878df473e944d1aa38570cfd6fe4d3b0d2129daa5d94fb0.yml
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/cloudflare%2Fcloudflare-99bd90b0a0f2472ad98f07bb87bf426278428a9891436afd8b355c8f57df5122.yml

internal/requestconfig/requestconfig.go

@@ -416,7 +416,8 @@ func (cfg *RequestConfig) Execute() (err error) {
 	}
 
 	// If we are not json, return plaintext
-	isJSON := strings.Contains(res.Header.Get("content-type"), "application/json")
+	contentType := res.Header.Get("content-type")
+	isJSON := strings.Contains(contentType, "application/json") || strings.Contains(contentType, "application/vnd.api+json")
 	if !isJSON {
 		switch dst := cfg.ResponseBodyInto.(type) {
 		case *string:

vectorize/index.go

@@ -3,11 +3,15 @@
 package vectorize
 
 import (
+	"bytes"
 	"context"
 	"fmt"
+	"io"
+	"mime/multipart"
 	"net/http"
 	"reflect"
 
+	"github.com/cloudflare/cloudflare-go/v2/internal/apiform"
 	"github.com/cloudflare/cloudflare-go/v2/internal/apijson"
 	"github.com/cloudflare/cloudflare-go/v2/internal/pagination"
 	"github.com/cloudflare/cloudflare-go/v2/internal/param"
@@ -825,11 +829,23 @@ func (r IndexGetByIDsResponseEnvelopeSuccess) IsKnown() bool {
 type IndexInsertParams struct {
 	// Identifier
 	AccountID param.Field[string] `path:"account_id,required"`
-	Body      interface{}         `json:"body,required"`
+	// ndjson file containing vectors to insert.
+	Body io.Reader `json:"body,required" format:"binary"`
 }
 
-func (r IndexInsertParams) MarshalJSON() (data []byte, err error) {
-	return apijson.MarshalRoot(r.Body)
+func (r IndexInsertParams) MarshalMultipart() (data []byte, contentType string, err error) {
+	buf := bytes.NewBuffer(nil)
+	writer := multipart.NewWriter(buf)
+	err = apiform.MarshalRoot(r, writer)
+	if err != nil {
+		writer.Close()
+		return nil, "", err
+	}
+	err = writer.Close()
+	if err != nil {
+		return nil, "", err
+	}
+	return buf.Bytes(), writer.FormDataContentType(), nil
 }
 
 type IndexInsertResponseEnvelope struct {
@@ -940,11 +956,23 @@ func (r IndexQueryResponseEnvelopeSuccess) IsKnown() bool {
 type IndexUpsertParams struct {
 	// Identifier
 	AccountID param.Field[string] `path:"account_id,required"`
-	Body      interface{}         `json:"body,required"`
+	// ndjson file containing vectors to upsert.
+	Body io.Reader `json:"body,required" format:"binary"`
 }
 
-func (r IndexUpsertParams) MarshalJSON() (data []byte, err error) {
-	return apijson.MarshalRoot(r.Body)
+func (r IndexUpsertParams) MarshalMultipart() (data []byte, contentType string, err error) {
+	buf := bytes.NewBuffer(nil)
+	writer := multipart.NewWriter(buf)
+	err = apiform.MarshalRoot(r, writer)
+	if err != nil {
+		writer.Close()
+		return nil, "", err
+	}
+	err = writer.Close()
+	if err != nil {
+		return nil, "", err
+	}
+	return buf.Bytes(), writer.FormDataContentType(), nil
 }
 
 type IndexUpsertResponseEnvelope struct {

vectorize/index_test.go

@@ -3,8 +3,10 @@
 package vectorize_test
 
 import (
+	"bytes"
 	"context"
 	"errors"
+	"io"
 	"os"
 	"testing"
 
@@ -237,7 +239,7 @@ func TestIndexInsert(t *testing.T) {
 		"example-index",
 		vectorize.IndexInsertParams{
 			AccountID: cloudflare.F("023e105f4ecef8ad9ca31a8372d0c353"),
-			Body:      map[string]interface{}{},
+			Body:      io.Reader(bytes.NewBuffer([]byte("some file contents"))),
 		},
 	)
 	if err != nil {
@@ -307,7 +309,7 @@ func TestIndexUpsert(t *testing.T) {
 		"example-index",
 		vectorize.IndexUpsertParams{
 			AccountID: cloudflare.F("023e105f4ecef8ad9ca31a8372d0c353"),
-			Body:      map[string]interface{}{},
+			Body:      io.Reader(bytes.NewBuffer([]byte("some file contents"))),
 		},
 	)
 	if err != nil {