feat: add Application client and workflow logs API

- Add Application client with GetParameters method for retrieving input form configuration
- Add GetLogs method to WorkflowService for fetching workflow execution logs
- Introduce BaseClient to share common client fields across services
- Add schema types for ApplicationParameters and WorkflowLogs
- Add documentation comments for Application and WorkflowService methods

Author: yumosx

client/api/v1/application.go

@@ -0,0 +1,48 @@
+package v1
+
+import (
+	"context"
+	"encoding/json"
+	"net/http"
+
+	"github.com/yeeaiclub/dify-go/internal/handler"
+	"github.com/yeeaiclub/dify-go/schema"
+)
+
+// Application represents a client for interacting with the application API endpoints.
+type Application struct {
+	*BaseClient
+}
+
+// NewApplication creates a new Application client instance.
+func NewApplication(baseURL, apiKey string) *Application {
+	baseClient := &BaseClient{
+		client:  handler.NewClient(),
+		apiKey:  apiKey,
+		baseURL: baseURL,
+	}
+	return &Application{baseClient}
+}
+
+// GetParameters retrieves the application's input form configuration.
+func (app *Application) GetParameters(ctx context.Context) (schema.ApplicationParameters, error) {
+	r, err := handler.NewRequestBuilder().
+		Method(http.MethodGet).
+		BaseURL(app.baseURL).
+		Token(app.apiKey).
+		Path("v1/parameters").
+		Build()
+	if err != nil {
+		return schema.ApplicationParameters{}, err
+	}
+	resp, err := app.client.Send(ctx, r)
+	if err != nil {
+		return schema.ApplicationParameters{}, err
+	}
+	var respData schema.ApplicationParameters
+	err = json.Unmarshal(resp.Body, &respData)
+	if err != nil {
+		return schema.ApplicationParameters{}, err
+	}
+	return respData, nil
+}

client/api/v1/base.go

@@ -0,0 +1,10 @@
+package v1
+
+import "github.com/yeeaiclub/dify-go/internal/handler"
+
+// BaseClient the base clint of dify
+type BaseClient struct {
+	client  *handler.Client // HTTP client for making API requests
+	apiKey  string          // API key for authentication
+	baseURL string          // Base URL of the API server
+}

client/api/v1/file.go

@@ -14,18 +14,17 @@ import (
 
 // FileService is a service for file operations.
 type FileService struct {
-	client  *handler.Client // HTTP client for making API requests
-	apiKey  string          // API key for authentication
-	baseURL string          // Base URL of the API server
+	*BaseClient
 }
 
 // NewFileService creates a new FileService instance with the provided baseURL and apiKey.
 func NewFileService(baseURL, apiKey string) *FileService {
-	return &FileService{
+	baseClient := &BaseClient{
 		client:  handler.NewClient(),
 		apiKey:  apiKey,
 		baseURL: baseURL,
 	}
+	return &FileService{baseClient}
 }
 
 // Upload upload file to dify.

client/api/v1/workflow.go

@@ -23,18 +23,17 @@ const (
 
 // WorkflowService represents a client for interacting with the workflow API endpoints.
 type WorkflowService struct {
-	client  *handler.Client // HTTP client for making API requests
-	apiKey  string          // API key for authentication
-	baseURL string          // Base URL of the API server
+	*BaseClient
 }
 
 // NewWorkflowService creates a new Workflow client instance.
 func NewWorkflowService(baseURL, apiKey string) *WorkflowService {
-	return &WorkflowService{
+	baseClient := &BaseClient{
 		client:  handler.NewClient(),
 		apiKey:  apiKey,
 		baseURL: baseURL,
 	}
+	return &WorkflowService{baseClient}
 }
 
 // RunStream executes a workflow in streaming mode. Cannot execute if there is no published workflow.
@@ -90,3 +89,33 @@ func (w *WorkflowService) Run(
 	}
 	return respData, nil
 }
+
+// GetLogs retrieves workflow execution logs with optional filtering.
+// Supports pagination and filtering by status, keyword, and time range.
+func (w *WorkflowService) GetLogs(
+	ctx context.Context,
+	query schema.WorkflowRunLogQuery,
+) (schema.WorkflowLogsResponse, error) {
+	r, err := handler.NewRequestBuilder().
+		BaseURL(w.baseURL).
+		Token(w.apiKey).
+		Path("v1/workflows/logs").
+		Method(http.MethodGet).
+		Query(query).
+		Build()
+
+	if err != nil {
+		return schema.WorkflowLogsResponse{}, err
+	}
+
+	resp, err := w.client.Send(ctx, r)
+	if err != nil {
+		return schema.WorkflowLogsResponse{}, err
+	}
+	var respData schema.WorkflowLogsResponse
+	err = json.Unmarshal(resp.Body, &respData)
+	if err != nil {
+		return schema.WorkflowLogsResponse{}, err
+	}
+	return respData, nil
+}

schema/application.go

@@ -0,0 +1,13 @@
+package schema
+
+type ApplicationParameters struct {
+	OpeningStatement              string           `json:"opening_statement,omitempty"`
+	SuggestedQuestions            []string         `json:"suggested_questions,omitempty"`
+	SuggestedQuestionsAfterAnswer map[string]any   `json:"suggested_questions_after_answer,omitempty"`
+	SpeechToText                  map[string]any   `json:"speech_to_text,omitempty"`
+	RetrieverResource             map[string]any   `json:"retriever_resource,omitempty"`
+	AnnotationReply               map[string]any   `json:"annotation_reply,omitempty"`
+	UserInputForm                 []map[string]any `json:"user_input_form,omitempty"`
+	FileUpload                    map[string]any   `json:"file_upload,omitempty"`
+	SystemParameters              map[string]any   `json:"system_parameters,omitempty"`
+}

schema/workflow.go

@@ -43,11 +43,52 @@ type RunWorkflowResponseData struct {
 	FinishedAt  int            `json:"finished_at"`
 }
 
-// StreamEvent represents an event in a streaming response.
-// T is the type of data contained in the event.
-type StreamEvent[T any] struct {
-	Err  string `json:"err"`
-	Data T      `json:"data"`
-	Type string `json:"event"`
-	Done bool   `json:"done"`
+type WorkflowRunLogQuery struct {
+	Keyword                   string `url:"keyword"`
+	Status                    string `url:"status"`
+	Page                      int    `url:"page"`
+	Limit                     int    `url:"limit"`
+	CreatedAtBefore           string `url:"created_at__before"`
+	CreatedAtAfter            string `url:"created_at__after"`
+	CreatedByEndUserSessionID string `url:"created_by_end_user_session_id"`
+	CreatedByAccount          string `url:"created_by_account"`
+}
+
+type WorkflowLogsResponse struct {
+	Page    int                        `json:"page"`
+	Limit   int                        `json:"limit"`
+	Total   int                        `json:"total"`
+	HasMore bool                       `json:"has_more"`
+	Data    []WorkflowLogsResponseData `json:"data"`
+}
+
+type WorkflowLogsResponseData struct {
+	ID                string            `json:"id"`
+	WorkflowRunDetail WorkflowRunDetail `json:"workflow_run"`
+	CreatedFrom       string            `json:"created_from"`
+	CreatedByRole     string            `json:"created_by_role"`
+	CreatedByAccount  *string           `json:"created_by_account,omitempty"`
+	CreatedByEndUser  *CreatedByEndUser `json:"created_by_end_user,omitempty"`
+	CreatedAt         int64             `json:"created_at"`
+}
+
+type WorkflowRunDetail struct {
+	ID              string  `json:"id"`
+	Version         string  `json:"version"`
+	Status          string  `json:"status"`
+	Error           *string `json:"error,omitempty"`
+	ElapsedTime     float64 `json:"elapsed_time"`
+	TotalTokens     int     `json:"total_tokens"`
+	TotalSteps      int     `json:"total_steps"`
+	CreatedAt       int64   `json:"created_at"`
+	FinishedAt      int64   `json:"finished_at"`
+	ExceptionsCount int     `json:"exceptions_count"`
+	TriggeredFrom   string  `json:"triggered_from"`
+}
+
+type CreatedByEndUser struct {
+	ID          string `json:"id"`
+	Type        string `json:"type"`
+	IsAnonymous bool   `json:"is_anonymous"`
+	SessionID   string `json:"session_id"`
 }