feat(api): update via SDK Studio

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
-configured_endpoints: 5
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/kernel%2Fkernel-3b19f5e2b96ede3193aa7a24d3f82d1406b8a16ea25e98ba3956e4a1a2376ad7.yml
-openapi_spec_hash: b62a6e73ddcec71674973f795a5790ac
-config_hash: df889df131f7438197abd59faace3c77
+configured_endpoints: 7
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/kernel%2Fkernel-c9d64df733f286f09d2203f4e3d820ce57e8d4c629c5e2db4e2bfac91fbc1598.yml
+openapi_spec_hash: fa407611fc566d55f403864fbfaa6c23
+config_hash: 7f67c5b95af1e4b39525515240b72275

api.md

@@ -1,14 +1,24 @@
 # Apps
 
+Response Types:
+
+- <a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk">kernel</a>.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#AppListResponse">AppListResponse</a>
+
+Methods:
+
+- <code title="get /apps">client.Apps.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#AppService.List">List</a>(ctx <a href="https://pkg.go.dev/context">context</a>.<a href="https://pkg.go.dev/context#Context">Context</a>, query <a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk">kernel</a>.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#AppListParams">AppListParams</a>) ([]<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk">kernel</a>.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#AppListResponse">AppListResponse</a>, <a href="https://pkg.go.dev/builtin#error">error</a>)</code>
+
 ## Deployments
 
 Response Types:
 
 - <a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk">kernel</a>.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#AppDeploymentNewResponse">AppDeploymentNewResponse</a>
+- <a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk">kernel</a>.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#AppDeploymentFollowResponseUnion">AppDeploymentFollowResponseUnion</a>
 
 Methods:
 
 - <code title="post /deploy">client.Apps.Deployments.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#AppDeploymentService.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/onkernel/kernel-go-sdk">kernel</a>.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#AppDeploymentNewParams">AppDeploymentNewParams</a>) (<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk">kernel</a>.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#AppDeploymentNewResponse">AppDeploymentNewResponse</a>, <a href="https://pkg.go.dev/builtin#error">error</a>)</code>
+- <code title="get /apps/{id}/events">client.Apps.Deployments.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#AppDeploymentService.Follow">Follow</a>(ctx <a href="https://pkg.go.dev/context">context</a>.<a href="https://pkg.go.dev/context#Context">Context</a>, id <a href="https://pkg.go.dev/builtin#string">string</a>) ([]<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk">kernel</a>.<a href="https://pkg.go.dev/github.com/onkernel/kernel-go-sdk#AppDeploymentFollowResponseUnion">AppDeploymentFollowResponseUnion</a>, <a href="https://pkg.go.dev/builtin#error">error</a>)</code>
 
 ## Invocations
 

app.go

@@ -3,7 +3,16 @@
 package kernel
 
 import (
+	"context"
+	"net/http"
+	"net/url"
+
+	"github.com/onkernel/kernel-go-sdk/internal/apijson"
+	"github.com/onkernel/kernel-go-sdk/internal/apiquery"
+	"github.com/onkernel/kernel-go-sdk/internal/requestconfig"
 	"github.com/onkernel/kernel-go-sdk/option"
+	"github.com/onkernel/kernel-go-sdk/packages/param"
+	"github.com/onkernel/kernel-go-sdk/packages/respjson"
 )
 
 // AppService contains methods and other services that help with interacting with
@@ -28,3 +37,58 @@ func NewAppService(opts ...option.RequestOption) (r AppService) {
 	r.Invocations = NewAppInvocationService(opts...)
 	return
 }
+
+// List application versions for the authenticated user. Optionally filter by app
+// name and/or version label.
+func (r *AppService) List(ctx context.Context, query AppListParams, opts ...option.RequestOption) (res *[]AppListResponse, err error) {
+	opts = append(r.Options[:], opts...)
+	path := "apps"
+	err = requestconfig.ExecuteNewRequest(ctx, http.MethodGet, path, query, &res, opts...)
+	return
+}
+
+// Summary of an application version.
+type AppListResponse struct {
+	// Unique identifier for the app version
+	ID string `json:"id,required"`
+	// Name of the application
+	AppName string `json:"app_name,required"`
+	// Deployment region code
+	Region string `json:"region,required"`
+	// Version label for the application
+	Version string `json:"version,required"`
+	// Environment variables configured for this app version
+	EnvVars map[string]string `json:"env_vars"`
+	// JSON contains metadata for fields, check presence with [respjson.Field.Valid].
+	JSON struct {
+		ID          respjson.Field
+		AppName     respjson.Field
+		Region      respjson.Field
+		Version     respjson.Field
+		EnvVars     respjson.Field
+		ExtraFields map[string]respjson.Field
+		raw         string
+	} `json:"-"`
+}
+
+// Returns the unmodified JSON received from the API
+func (r AppListResponse) RawJSON() string { return r.JSON.raw }
+func (r *AppListResponse) UnmarshalJSON(data []byte) error {
+	return apijson.UnmarshalRoot(data, r)
+}
+
+type AppListParams struct {
+	// Filter results by application name.
+	AppName param.Opt[string] `query:"app_name,omitzero" json:"-"`
+	// Filter results by version label.
+	Version param.Opt[string] `query:"version,omitzero" json:"-"`
+	paramObj
+}
+
+// URLQuery serializes [AppListParams]'s query parameters as `url.Values`.
+func (r AppListParams) URLQuery() (v url.Values, err error) {
+	return apiquery.MarshalWithSettings(r, apiquery.QuerySettings{
+		ArrayFormat:  apiquery.ArrayQueryFormatComma,
+		NestedFormat: apiquery.NestedQueryFormatBrackets,
+	})
+}

app_test.go

@@ -0,0 +1,40 @@
+// File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+package kernel_test
+
+import (
+	"context"
+	"errors"
+	"os"
+	"testing"
+
+	"github.com/onkernel/kernel-go-sdk"
+	"github.com/onkernel/kernel-go-sdk/internal/testutil"
+	"github.com/onkernel/kernel-go-sdk/option"
+)
+
+func TestAppListWithOptionalParams(t *testing.T) {
+	t.Skip("skipped: tests are disabled for the time being")
+	baseURL := "http://localhost:4010"
+	if envURL, ok := os.LookupEnv("TEST_API_BASE_URL"); ok {
+		baseURL = envURL
+	}
+	if !testutil.CheckTestServer(t, baseURL) {
+		return
+	}
+	client := kernel.NewClient(
+		option.WithBaseURL(baseURL),
+		option.WithAPIKey("My API Key"),
+	)
+	_, err := client.Apps.List(context.TODO(), kernel.AppListParams{
+		AppName: kernel.String("app_name"),
+		Version: kernel.String("version"),
+	})
+	if err != nil {
+		var apierr *kernel.Error
+		if errors.As(err, &apierr) {
+			t.Log(string(apierr.DumpRequest(true)))
+		}
+		t.Fatalf("err should be nil: %s", err.Error())
+	}
+}

appdeployment.go

@@ -5,16 +5,22 @@ package kernel
 import (
 	"bytes"
 	"context"
+	"encoding/json"
+	"errors"
+	"fmt"
 	"io"
 	"mime/multipart"
 	"net/http"
+	"time"
 
 	"github.com/onkernel/kernel-go-sdk/internal/apiform"
 	"github.com/onkernel/kernel-go-sdk/internal/apijson"
 	"github.com/onkernel/kernel-go-sdk/internal/requestconfig"
 	"github.com/onkernel/kernel-go-sdk/option"
 	"github.com/onkernel/kernel-go-sdk/packages/param"
 	"github.com/onkernel/kernel-go-sdk/packages/respjson"
+	"github.com/onkernel/kernel-go-sdk/packages/ssestream"
+	"github.com/onkernel/kernel-go-sdk/shared/constant"
 )
 
 // AppDeploymentService contains methods and other services that help with
@@ -44,6 +50,25 @@ func (r *AppDeploymentService) New(ctx context.Context, body AppDeploymentNewPar
 	return
 }
 
+// Establishes a Server-Sent Events (SSE) stream that delivers real-time logs and
+// status updates for a deployed application. The stream terminates automatically
+// once the application reaches a terminal state.
+func (r *AppDeploymentService) FollowStreaming(ctx context.Context, id string, opts ...option.RequestOption) (stream *ssestream.Stream[[]AppDeploymentFollowResponseUnion]) {
+	var (
+		raw *http.Response
+		err error
+	)
+	opts = append(r.Options[:], opts...)
+	opts = append([]option.RequestOption{option.WithHeader("Accept", "text/event-stream")}, opts...)
+	if id == "" {
+		err = errors.New("missing required id parameter")
+		return
+	}
+	path := fmt.Sprintf("apps/%s/events", id)
+	err = requestconfig.ExecuteNewRequest(ctx, http.MethodGet, path, nil, &raw, opts...)
+	return ssestream.NewStream[[]AppDeploymentFollowResponseUnion](ssestream.NewDecoder(raw), err)
+}
+
 type AppDeploymentNewResponse struct {
 	// List of apps deployed
 	Apps []AppDeploymentNewResponseApp `json:"apps,required"`
@@ -119,6 +144,156 @@ const (
 	AppDeploymentNewResponseStatusFailed    AppDeploymentNewResponseStatus = "failed"
 )
 
+// AppDeploymentFollowResponseUnion contains all possible properties and values
+// from [AppDeploymentFollowResponseState],
+// [AppDeploymentFollowResponseStateUpdate], [AppDeploymentFollowResponseLog].
+//
+// Use the [AppDeploymentFollowResponseUnion.AsAny] method to switch on the
+// variant.
+//
+// Use the methods beginning with 'As' to cast the union to one of its variants.
+type AppDeploymentFollowResponseUnion struct {
+	// Any of "state", "state_update", "log".
+	Event     string    `json:"event"`
+	State     string    `json:"state"`
+	Timestamp time.Time `json:"timestamp"`
+	// This field is from variant [AppDeploymentFollowResponseLog].
+	Message string `json:"message"`
+	JSON    struct {
+		Event     respjson.Field
+		State     respjson.Field
+		Timestamp respjson.Field
+		Message   respjson.Field
+		raw       string
+	} `json:"-"`
+}
+
+// anyAppDeploymentFollowResponse is implemented by each variant of
+// [AppDeploymentFollowResponseUnion] to add type safety for the return type of
+// [AppDeploymentFollowResponseUnion.AsAny]
+type anyAppDeploymentFollowResponse interface {
+	implAppDeploymentFollowResponseUnion()
+}
+
+func (AppDeploymentFollowResponseState) implAppDeploymentFollowResponseUnion()       {}
+func (AppDeploymentFollowResponseStateUpdate) implAppDeploymentFollowResponseUnion() {}
+func (AppDeploymentFollowResponseLog) implAppDeploymentFollowResponseUnion()         {}
+
+// Use the following switch statement to find the correct variant
+//
+//	switch variant := AppDeploymentFollowResponseUnion.AsAny().(type) {
+//	case kernel.AppDeploymentFollowResponseState:
+//	case kernel.AppDeploymentFollowResponseStateUpdate:
+//	case kernel.AppDeploymentFollowResponseLog:
+//	default:
+//	  fmt.Errorf("no variant present")
+//	}
+func (u AppDeploymentFollowResponseUnion) AsAny() anyAppDeploymentFollowResponse {
+	switch u.Event {
+	case "state":
+		return u.AsState()
+	case "state_update":
+		return u.AsStateUpdate()
+	case "log":
+		return u.AsLog()
+	}
+	return nil
+}
+
+func (u AppDeploymentFollowResponseUnion) AsState() (v AppDeploymentFollowResponseState) {
+	apijson.UnmarshalRoot(json.RawMessage(u.JSON.raw), &v)
+	return
+}
+
+func (u AppDeploymentFollowResponseUnion) AsStateUpdate() (v AppDeploymentFollowResponseStateUpdate) {
+	apijson.UnmarshalRoot(json.RawMessage(u.JSON.raw), &v)
+	return
+}
+
+func (u AppDeploymentFollowResponseUnion) AsLog() (v AppDeploymentFollowResponseLog) {
+	apijson.UnmarshalRoot(json.RawMessage(u.JSON.raw), &v)
+	return
+}
+
+// Returns the unmodified JSON received from the API
+func (u AppDeploymentFollowResponseUnion) RawJSON() string { return u.JSON.raw }
+
+func (r *AppDeploymentFollowResponseUnion) UnmarshalJSON(data []byte) error {
+	return apijson.UnmarshalRoot(data, r)
+}
+
+// Initial state of the application, emitted once when subscribing.
+type AppDeploymentFollowResponseState struct {
+	// Event type identifier (always "state").
+	Event constant.State `json:"event,required"`
+	// Current application state (e.g., "deploying", "running", "succeeded", "failed").
+	State string `json:"state,required"`
+	// Time the state was reported.
+	Timestamp time.Time `json:"timestamp" format:"date-time"`
+	// JSON contains metadata for fields, check presence with [respjson.Field.Valid].
+	JSON struct {
+		Event       respjson.Field
+		State       respjson.Field
+		Timestamp   respjson.Field
+		ExtraFields map[string]respjson.Field
+		raw         string
+	} `json:"-"`
+}
+
+// Returns the unmodified JSON received from the API
+func (r AppDeploymentFollowResponseState) RawJSON() string { return r.JSON.raw }
+func (r *AppDeploymentFollowResponseState) UnmarshalJSON(data []byte) error {
+	return apijson.UnmarshalRoot(data, r)
+}
+
+// An update emitted when the application's state changes.
+type AppDeploymentFollowResponseStateUpdate struct {
+	// Event type identifier (always "state_update").
+	Event constant.StateUpdate `json:"event,required"`
+	// New application state (e.g., "running", "succeeded", "failed").
+	State string `json:"state,required"`
+	// Time the state change occurred.
+	Timestamp time.Time `json:"timestamp" format:"date-time"`
+	// JSON contains metadata for fields, check presence with [respjson.Field.Valid].
+	JSON struct {
+		Event       respjson.Field
+		State       respjson.Field
+		Timestamp   respjson.Field
+		ExtraFields map[string]respjson.Field
+		raw         string
+	} `json:"-"`
+}
+
+// Returns the unmodified JSON received from the API
+func (r AppDeploymentFollowResponseStateUpdate) RawJSON() string { return r.JSON.raw }
+func (r *AppDeploymentFollowResponseStateUpdate) UnmarshalJSON(data []byte) error {
+	return apijson.UnmarshalRoot(data, r)
+}
+
+// A log entry from the application.
+type AppDeploymentFollowResponseLog struct {
+	// Event type identifier (always "log").
+	Event constant.Log `json:"event,required"`
+	// Log message text.
+	Message string `json:"message,required"`
+	// Time the log entry was produced.
+	Timestamp time.Time `json:"timestamp" format:"date-time"`
+	// JSON contains metadata for fields, check presence with [respjson.Field.Valid].
+	JSON struct {
+		Event       respjson.Field
+		Message     respjson.Field
+		Timestamp   respjson.Field
+		ExtraFields map[string]respjson.Field
+		raw         string
+	} `json:"-"`
+}
+
+// Returns the unmodified JSON received from the API
+func (r AppDeploymentFollowResponseLog) RawJSON() string { return r.JSON.raw }
+func (r *AppDeploymentFollowResponseLog) UnmarshalJSON(data []byte) error {
+	return apijson.UnmarshalRoot(data, r)
+}
+
 type AppDeploymentNewParams struct {
 	// Relative path to the entrypoint of the application
 	EntrypointRelPath string `json:"entrypoint_rel_path,required"`