Merge pull request #16 from akihikokuroda/filelogger

bug: add LogWorkflowRun logger

Author: maximilien

go.mod

@@ -31,6 +31,8 @@ require (
 	github.com/xeipuuv/gojsonreference v0.0.0-20180127040603-bd5ef7bd5415 // indirect
 	github.com/yosida95/uritemplate/v3 v3.0.2 // indirect
 	github.com/yusufpapurcu/wmi v1.2.4 // indirect
+	go.uber.org/multierr v1.11.0 // indirect
+	go.uber.org/zap v1.27.0 // indirect
 	golang.org/x/sys v0.25.0 // indirect
 	gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c // indirect
 )

go.sum

@@ -70,6 +70,10 @@ github.com/yosida95/uritemplate/v3 v3.0.2 h1:Ed3Oyj9yrmi9087+NczuL5BwkIc4wvTb5zI
 github.com/yosida95/uritemplate/v3 v3.0.2/go.mod h1:ILOh0sOhIJR3+L/8afwt/kE++YT040gmv5BQTMR2HP4=
 github.com/yusufpapurcu/wmi v1.2.4 h1:zFUKzehAFReQwLys1b/iSMl+JQGSCSjtVqQn9bBrPo0=
 github.com/yusufpapurcu/wmi v1.2.4/go.mod h1:SBZ9tNy3G9/m5Oi98Zks0QjeHVDvuK0qfxQmPyzfmi0=
+go.uber.org/multierr v1.11.0 h1:blXXJkSxSSfBVBlC76pxqeO+LN3aDfLQo+309xJstO0=
+go.uber.org/multierr v1.11.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=
+go.uber.org/zap v1.27.0 h1:aJMhYGrd5QSmlpLMr2MftRKl7t8J8PTZPA732ud/XR8=
+go.uber.org/zap v1.27.0/go.mod h1:GB2qFLM7cTU87MWRP2mPIjqfIDnGu+VIO4V/SdhGo2E=
 golang.org/x/sys v0.0.0-20190916202348-b4ddaad3f8a3/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20201204225414-ed752295db88/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=

internal/commands/run.go

@@ -20,6 +20,7 @@ type RunCommand struct {
 	workflowFile string
 	prompt       bool
 	mcpServerURI string
+	logger       common.FileLogger
 }
 
 // NewRunCommand creates a new run command
@@ -43,13 +44,15 @@ func NewRunCommand() *cobra.Command {
 				agentsFile = args[0]
 				workflowFile = args[1]
 			}
+			filelogger, _ := common.NewFileLogger("")
 
 			runCmd := &RunCommand{
 				BaseCommand:  NewBaseCommand(options),
 				agentsFile:   agentsFile,
 				workflowFile: workflowFile,
 				prompt:       prompt,
 				mcpServerURI: mcpServerURI,
+				logger:       *filelogger,
 			}
 
 			return runCmd.Run()
@@ -304,6 +307,18 @@ func (c *RunCommand) runWorkflow(workflow common.YAMLDocument, agents []common.Y
 // logWorkflowRun logs the workflow run
 func (c *RunCommand) logWorkflowRun(logger *common.Logger, workflowID, workflowName, prompt, output string, modelsUsed []string, status string, startTime, endTime time.Time, durationMs int) {
 	c.Console().Ok(fmt.Sprintf("Workflow %s completed with status: %s", workflowID, status))
+
+	c.logger.LogWorkflowRun(
+		workflowID,
+		workflowName,
+		prompt,
+		output,
+		modelsUsed,
+		status,
+		&startTime,
+		&endTime,
+		int64(durationMs),
+	)
 }
 
 // DeprecatedRunCommand deprecated create command