feat(vpc_flows): add token support (#3962)

Author: stainless-app[bot]

.stats.yml

@@ -1,2 +1,2 @@
-configured_endpoints: 1547
+configured_endpoints: 1548
 openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/cloudflare%2Fcloudflare-cc9be7885f16989f56e5e015644178eb17b82304fc31f62ed14b7e9a93cab891.yml

api.md

@@ -3721,6 +3721,14 @@ Methods:
 
 # MagicNetworkMonitoring
 
+## VpcFlows
+
+### Tokens
+
+Methods:
+
+- <code title="post /accounts/{account_id}/mnm/vpc-flows/token">client.MagicNetworkMonitoring.VpcFlows.Tokens.<a href="https://pkg.go.dev/github.com/cloudflare/cloudflare-go/v4/magic_network_monitoring#VpcFlowTokenService.New">New</a>(ctx <a href="https://pkg.go.dev/context">context</a>.<a href="https://pkg.go.dev/context#Context">Context</a>, body <a href="https://pkg.go.dev/github.com/cloudflare/cloudflare-go/v4/magic_network_monitoring">magic_network_monitoring</a>.<a href="https://pkg.go.dev/github.com/cloudflare/cloudflare-go/v4/magic_network_monitoring#VpcFlowTokenNewParams">VpcFlowTokenNewParams</a>) (<a href="https://pkg.go.dev/builtin#string">string</a>, <a href="https://pkg.go.dev/builtin#error">error</a>)</code>
+
 ## Configs
 
 Response Types:

magic_network_monitoring/magicnetworkmonitoring.go

@@ -13,9 +13,10 @@ import (
 // automatically. You should not instantiate this service directly, and instead use
 // the [NewMagicNetworkMonitoringService] method instead.
 type MagicNetworkMonitoringService struct {
-	Options []option.RequestOption
-	Configs *ConfigService
-	Rules   *RuleService
+	Options  []option.RequestOption
+	VpcFlows *VpcFlowService
+	Configs  *ConfigService
+	Rules    *RuleService
 }
 
 // NewMagicNetworkMonitoringService generates a new service that applies the given
@@ -24,6 +25,7 @@ type MagicNetworkMonitoringService struct {
 func NewMagicNetworkMonitoringService(opts ...option.RequestOption) (r *MagicNetworkMonitoringService) {
 	r = &MagicNetworkMonitoringService{}
 	r.Options = opts
+	r.VpcFlows = NewVpcFlowService(opts...)
 	r.Configs = NewConfigService(opts...)
 	r.Rules = NewRuleService(opts...)
 	return

magic_network_monitoring/vpcflow.go

@@ -0,0 +1,28 @@
+// File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+package magic_network_monitoring
+
+import (
+	"github.com/cloudflare/cloudflare-go/v4/option"
+)
+
+// VpcFlowService contains methods and other services that help with interacting
+// with the cloudflare API.
+//
+// Note, unlike clients, this service does not read variables from the environment
+// automatically. You should not instantiate this service directly, and instead use
+// the [NewVpcFlowService] method instead.
+type VpcFlowService struct {
+	Options []option.RequestOption
+	Tokens  *VpcFlowTokenService
+}
+
+// NewVpcFlowService generates a new service that applies the given options to each
+// request. These options are applied after the parent client's options (if there
+// is one), and before any request-specific options.
+func NewVpcFlowService(opts ...option.RequestOption) (r *VpcFlowService) {
+	r = &VpcFlowService{}
+	r.Options = opts
+	r.Tokens = NewVpcFlowTokenService(opts...)
+	return
+}

magic_network_monitoring/vpcflowtoken.go

@@ -0,0 +1,100 @@
+// File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+package magic_network_monitoring
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"net/http"
+
+	"github.com/cloudflare/cloudflare-go/v4/internal/apijson"
+	"github.com/cloudflare/cloudflare-go/v4/internal/param"
+	"github.com/cloudflare/cloudflare-go/v4/internal/requestconfig"
+	"github.com/cloudflare/cloudflare-go/v4/option"
+	"github.com/cloudflare/cloudflare-go/v4/shared"
+)
+
+// VpcFlowTokenService contains methods and other services that help with
+// interacting with the cloudflare API.
+//
+// Note, unlike clients, this service does not read variables from the environment
+// automatically. You should not instantiate this service directly, and instead use
+// the [NewVpcFlowTokenService] method instead.
+type VpcFlowTokenService struct {
+	Options []option.RequestOption
+}
+
+// NewVpcFlowTokenService generates a new service that applies the given options to
+// each request. These options are applied after the parent client's options (if
+// there is one), and before any request-specific options.
+func NewVpcFlowTokenService(opts ...option.RequestOption) (r *VpcFlowTokenService) {
+	r = &VpcFlowTokenService{}
+	r.Options = opts
+	return
+}
+
+// Generate authentication token for VPC flow logs export.
+func (r *VpcFlowTokenService) New(ctx context.Context, body VpcFlowTokenNewParams, opts ...option.RequestOption) (res *string, err error) {
+	var env VpcFlowTokenNewResponseEnvelope
+	opts = append(r.Options[:], opts...)
+	if body.AccountID.Value == "" {
+		err = errors.New("missing required account_id parameter")
+		return
+	}
+	path := fmt.Sprintf("accounts/%s/mnm/vpc-flows/token", body.AccountID)
+	err = requestconfig.ExecuteNewRequest(ctx, http.MethodPost, path, nil, &env, opts...)
+	if err != nil {
+		return
+	}
+	res = &env.Result
+	return
+}
+
+type VpcFlowTokenNewParams struct {
+	AccountID param.Field[string] `path:"account_id,required"`
+}
+
+type VpcFlowTokenNewResponseEnvelope struct {
+	Errors   []shared.ResponseInfo `json:"errors,required"`
+	Messages []shared.ResponseInfo `json:"messages,required"`
+	// Authentication token to be used for VPC Flows export authentication.
+	Result string `json:"result,required"`
+	// Whether the API call was successful
+	Success VpcFlowTokenNewResponseEnvelopeSuccess `json:"success,required"`
+	JSON    vpcFlowTokenNewResponseEnvelopeJSON    `json:"-"`
+}
+
+// vpcFlowTokenNewResponseEnvelopeJSON contains the JSON metadata for the struct
+// [VpcFlowTokenNewResponseEnvelope]
+type vpcFlowTokenNewResponseEnvelopeJSON struct {
+	Errors      apijson.Field
+	Messages    apijson.Field
+	Result      apijson.Field
+	Success     apijson.Field
+	raw         string
+	ExtraFields map[string]apijson.Field
+}
+
+func (r *VpcFlowTokenNewResponseEnvelope) UnmarshalJSON(data []byte) (err error) {
+	return apijson.UnmarshalRoot(data, r)
+}
+
+func (r vpcFlowTokenNewResponseEnvelopeJSON) RawJSON() string {
+	return r.raw
+}
+
+// Whether the API call was successful
+type VpcFlowTokenNewResponseEnvelopeSuccess bool
+
+const (
+	VpcFlowTokenNewResponseEnvelopeSuccessTrue VpcFlowTokenNewResponseEnvelopeSuccess = true
+)
+
+func (r VpcFlowTokenNewResponseEnvelopeSuccess) IsKnown() bool {
+	switch r {
+	case VpcFlowTokenNewResponseEnvelopeSuccessTrue:
+		return true
+	}
+	return false
+}

magic_network_monitoring/vpcflowtoken_test.go

@@ -0,0 +1,40 @@
+// File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+package magic_network_monitoring_test
+
+import (
+	"context"
+	"errors"
+	"os"
+	"testing"
+
+	"github.com/cloudflare/cloudflare-go/v4"
+	"github.com/cloudflare/cloudflare-go/v4/internal/testutil"
+	"github.com/cloudflare/cloudflare-go/v4/magic_network_monitoring"
+	"github.com/cloudflare/cloudflare-go/v4/option"
+)
+
+func TestVpcFlowTokenNew(t *testing.T) {
+	baseURL := "http://localhost:4010"
+	if envURL, ok := os.LookupEnv("TEST_API_BASE_URL"); ok {
+		baseURL = envURL
+	}
+	if !testutil.CheckTestServer(t, baseURL) {
+		return
+	}
+	client := cloudflare.NewClient(
+		option.WithBaseURL(baseURL),
+		option.WithAPIKey("144c9defac04969c7bfad8efaa8ea194"),
+		option.WithAPIEmail("user@example.com"),
+	)
+	_, err := client.MagicNetworkMonitoring.VpcFlows.Tokens.New(context.TODO(), magic_network_monitoring.VpcFlowTokenNewParams{
+		AccountID: cloudflare.F("6f91088a406011ed95aed352566e8d4c"),
+	})
+	if err != nil {
+		var apierr *cloudflare.Error
+		if errors.As(err, &apierr) {
+			t.Log(string(apierr.DumpRequest(true)))
+		}
+		t.Fatalf("err should be nil: %s", err.Error())
+	}
+}