feat: regenerate go api modules after removing go_api templates

Author: chyroc

apps.go

@@ -5,25 +5,78 @@ import (
 	"net/http"
 )
 
-// List 查看应用列表
-func (r *apps) List(ctx context.Context, req *SwaggerOperationRequest) (*SwaggerOperationResponse, error) {
-	if req == nil {
-		req = &SwaggerOperationRequest{}
+func (r *apps) List(ctx context.Context, req *ListAppReq) (NumberPaged[SimpleApp], error) {
+	if req.PageSize == 0 {
+		req.PageSize = 20
 	}
-	request := &RawRequestReq{
-		Method: http.MethodGet,
-		URL:    buildSwaggerOperationURL("/v1/apps", req.PathParams, req.QueryParams),
-		Body:   req.Body,
+	if req.PageNum == 0 {
+		req.PageNum = 1
+	}
+	return NewNumberPaged(
+		func(request *pageRequest) (*pageResponse[SimpleApp], error) {
+			resp := new(listAppResp)
+			err := r.core.rawRequest(ctx, &RawRequestReq{
+				Method: http.MethodGet,
+				URL:    "/v1/apps",
+				Body:   req.toReq(request),
+			}, resp)
+			if err != nil {
+				return nil, err
+			}
+			return &pageResponse[SimpleApp]{
+				response: resp.HTTPResponse,
+				HasMore:  len(resp.Data.Items) >= request.PageSize,
+				Data:     resp.Data.Items,
+				LogID:    resp.HTTPResponse.LogID(),
+			}, nil
+		}, req.PageSize, req.PageNum)
+}
+
+type ListAppReq struct {
+	WorkspaceID   string         `query:"workspace_id" json:"-"`
+	PublishStatus *PublishStatus `query:"publish_status" json:"-"`
+	ConnectorID   *string        `query:"connector_id" json:"-"`
+	PageNum       int            `query:"page_num" json:"-"`
+	PageSize      int            `query:"page_size" json:"-"`
+}
+
+type SimpleApp struct {
+	ID          string `json:"id,omitempty"`
+	Name        string `json:"name,omitempty"`
+	Description string `json:"description,omitempty"`
+	IconURL     string `json:"icon_url,omitempty"`
+	IsPublished bool   `json:"is_published,omitempty"`
+	OwnerUserID string `json:"owner_user_id,omitempty"`
+	UpdatedAt   int    `json:"updated_at,omitempty"`
+	PublishedAt *int   `json:"published_at,omitempty"`
+}
+
+type ListAppResp struct {
+	Total int          `json:"total"`
+	Items []*SimpleApp `json:"items"`
+}
+
+type listAppResp struct {
+	baseResponse
+	Data *ListAppResp `json:"data"`
+}
+
+func (r ListAppReq) toReq(request *pageRequest) *ListAppReq {
+	return &ListAppReq{
+		WorkspaceID:   r.WorkspaceID,
+		PublishStatus: r.PublishStatus,
+		ConnectorID:   r.ConnectorID,
+		PageNum:       request.PageNum,
+		PageSize:      request.PageSize,
 	}
-	response := new(SwaggerOperationResponse)
-	err := r.core.rawRequest(ctx, request, response)
-	return response, err
 }
 
 type apps struct {
 	core *core
 }
 
 func newApps(core *core) *apps {
-	return &apps{core: core}
+	return &apps{
+		core: core,
+	}
 }

audio_live.go

@@ -5,20 +5,59 @@ import (
 	"net/http"
 )
 
-func (r *audioLive) Retrieve(ctx context.Context, req *SwaggerOperationRequest) (*SwaggerOperationResponse, error) {
-	if req == nil {
-		req = &SwaggerOperationRequest{}
-	}
+// Retrieve retrieves live stream information
+func (r *audioLive) Retrieve(ctx context.Context, req *RetrieveAudioLiveReq) (*LiveInfo, error) {
 	request := &RawRequestReq{
 		Method: http.MethodGet,
-		URL:    buildSwaggerOperationURL("/v1/audio/live/{live_id}", req.PathParams, req.QueryParams),
-		Body:   req.Body,
+		URL:    "/v1/audio/live/:live_id",
+		Body:   req,
 	}
-	response := new(SwaggerOperationResponse)
+	response := new(retrieveAudioLiveResp)
 	err := r.core.rawRequest(ctx, request, response)
-	return response, err
+	return response.Data, err
+}
+
+// LiveType represents the type of live stream
+type LiveType string
+
+const (
+	LiveTypeOrigin      LiveType = "origin"
+	LiveTypeTranslation LiveType = "translation"
+)
+
+func (l LiveType) String() string {
+	return string(l)
+}
+
+func (l LiveType) Ptr() *LiveType {
+	return &l
+}
+
+// StreamInfo represents information about a stream
+type StreamInfo struct {
+	StreamID string   `json:"stream_id"`
+	Name     string   `json:"name"`
+	LiveType LiveType `json:"live_type"`
+}
+
+// LiveInfo represents information about a live session
+type LiveInfo struct {
+	baseModel
+	AppID       string        `json:"app_id"`
+	StreamInfos []*StreamInfo `json:"stream_infos"`
+}
+
+// RetrieveAudioLiveReq represents the request for retrieving live information
+type RetrieveAudioLiveReq struct {
+	LiveID string `path:"live_id" json:"-"`
+}
+
+type retrieveAudioLiveResp struct {
+	baseResponse
+	Data *LiveInfo `json:"data"`
 }
 
+// audioLive provides operations for live audio streams
 type audioLive struct {
 	core *core
 }

audio_speech.go

@@ -2,22 +2,62 @@ package coze
 
 import (
 	"context"
+	"io"
 	"net/http"
+	"os"
 )
 
-// Create 语音合成
-func (r *audioSpeech) Create(ctx context.Context, req *SwaggerOperationRequest) (*SwaggerOperationResponse, error) {
-	if req == nil {
-		req = &SwaggerOperationRequest{}
-	}
+func (r *audioSpeech) Create(ctx context.Context, req *CreateAudioSpeechReq) (*CreateAudioSpeechResp, error) {
 	request := &RawRequestReq{
 		Method: http.MethodPost,
-		URL:    buildSwaggerOperationURL("/v1/audio/speech", req.PathParams, req.QueryParams),
-		Body:   req.Body,
+		URL:    "/v1/audio/speech",
+		Body:   req,
 	}
-	response := new(SwaggerOperationResponse)
+	response := new(createAudioSpeechResp)
 	err := r.core.rawRequest(ctx, request, response)
-	return response, err
+	return response.Data, err
+}
+
+// CreateAudioSpeechReq represents the request for creating speech
+type CreateAudioSpeechReq struct {
+	Input          string       `json:"input"`
+	VoiceID        string       `json:"voice_id"`
+	ResponseFormat *AudioFormat `json:"response_format"`
+	Speed          *float32     `json:"speed"`
+	SampleRate     *int         `json:"sample_rate"`
+	LoudnessRate   *int         `json:"loudness_rate"`
+	Emotion        *string      `json:"emotion"`
+	EmotionScale   *float32     `json:"emotion_scale"`
+}
+
+// CreateAudioSpeechResp represents the response for creating speech
+type CreateAudioSpeechResp struct {
+	baseModel
+	Data io.ReadCloser
+}
+
+type createAudioSpeechResp struct {
+	baseResponse
+	Data *CreateAudioSpeechResp
+}
+
+func (r *createAudioSpeechResp) SetReader(file io.ReadCloser) {
+	if r.Data == nil {
+		r.Data = &CreateAudioSpeechResp{}
+	}
+	r.Data.Data = file
+}
+
+func (c *CreateAudioSpeechResp) WriteToFile(path string) error {
+	file, err := os.Create(path)
+	if err != nil {
+		return err
+	}
+	defer file.Close()
+	defer c.Data.Close()
+
+	_, err = io.Copy(file, c.Data)
+	return err
 }
 
 type audioSpeech struct {

audio_transcription.go

@@ -2,23 +2,39 @@ package coze
 
 import (
 	"context"
+	"io"
 	"net/http"
 )
 
-// Create 语音识别
-func (r *audioTranscriptions) Create(ctx context.Context, req *SwaggerOperationRequest) (*SwaggerOperationResponse, error) {
-	if req == nil {
-		req = &SwaggerOperationRequest{}
-	}
+func (r *audioTranscriptions) Create(ctx context.Context, req *AudioSpeechTranscriptionsReq) (*CreateAudioTranscriptionsResp, error) {
 	request := &RawRequestReq{
 		Method: http.MethodPost,
-		URL:    buildSwaggerOperationURL("/v1/audio/transcriptions", req.PathParams, req.QueryParams),
-		Body:   req.Body,
+		URL:    "/v1/audio/transcriptions",
+		Body:   req,
 		IsFile: true,
 	}
-	response := new(SwaggerOperationResponse)
+	response := new(createAudioTranscriptionsResp)
 	err := r.core.rawRequest(ctx, request, response)
-	return response, err
+	return response.CreateAudioTranscriptionsResp, err
+}
+
+type AudioSpeechTranscriptionsReq struct {
+	Filename string    `json:"filename"`
+	Audio    io.Reader `json:"file"`
+}
+
+type createAudioTranscriptionsResp struct {
+	baseResponse
+	*CreateAudioTranscriptionsResp
+}
+
+type CreateAudioTranscriptionsResp struct {
+	baseModel
+	Data AudioTranscriptionsData `json:"data"`
+}
+
+type AudioTranscriptionsData struct {
+	Text string `json:"text"`
 }
 
 type audioTranscriptions struct {

chats_messages.go

@@ -5,19 +5,36 @@ import (
 	"net/http"
 )
 
-// List 查看对话消息详情
-func (r *chatMessages) List(ctx context.Context, req *SwaggerOperationRequest) (*SwaggerOperationResponse, error) {
-	if req == nil {
-		req = &SwaggerOperationRequest{}
-	}
+func (r *chatMessages) List(ctx context.Context, req *ListChatsMessagesReq) (*ListChatsMessagesResp, error) {
 	request := &RawRequestReq{
 		Method: http.MethodGet,
-		URL:    buildSwaggerOperationURL("/v3/chat/message/list", req.PathParams, req.QueryParams),
-		Body:   req.Body,
+		URL:    "/v3/chat/message/list",
+		Body:   req,
 	}
-	response := new(SwaggerOperationResponse)
+	response := new(listChatsMessagesResp)
 	err := r.core.rawRequest(ctx, request, response)
-	return response, err
+	return response.ListChatsMessagesResp, err
+}
+
+// ListChatsMessagesReq represents the request to list messages
+type ListChatsMessagesReq struct {
+	// The Conversation ID can be viewed in the 'conversation_id' field of the Response when
+	// initiating a conversation through the Chat API.
+	ConversationID string `query:"conversation_id" json:"-"`
+
+	// The Chat ID can be viewed in the 'id' field of the Response when initiating a chat through the
+	// Chat API. If it is a streaming response, check the 'id' field in the chat event of the Response.
+	ChatID string `query:"chat_id" json:"-"`
+}
+
+type ListChatsMessagesResp struct {
+	baseModel
+	Messages []*Message `json:"data"`
+}
+
+type listChatsMessagesResp struct {
+	baseResponse
+	*ListChatsMessagesResp
 }
 
 type chatMessages struct {