Merge pull request #811 from thedadams/include-input-call-events

fix: include proper input on call events

Author: thedadams

pkg/runner/runner.go

@@ -628,11 +628,16 @@ func (r *Runner) resume(callCtx engine.Context, monitor Monitor, env []string, s
 			}
 		}
 
+		var content string
+		if state.ResumeInput != nil {
+			content = *state.ResumeInput
+		}
 		monitor.Event(Event{
 			Time:        time.Now(),
 			CallContext: callCtx.GetCallContext(),
 			Type:        EventTypeCallContinue,
 			ToolResults: len(callResults),
+			Content:     content,
 		})
 
 		e := engine.Engine{

pkg/sdkserver/monitor.go

@@ -33,6 +33,7 @@ func (s SessionFactory) Start(ctx context.Context, prg *types.Program, env []str
 					Time: time.Now(),
 					Type: runner.EventTypeRunStart,
 				},
+				Input:   input,
 				RunID:   id,
 				Program: prg,
 			},
@@ -43,7 +44,6 @@ func (s SessionFactory) Start(ctx context.Context, prg *types.Program, env []str
 		id:     id,
 		prj:    prg,
 		env:    env,
-		input:  input,
 		events: s.events,
 	}, nil
 }
@@ -56,7 +56,6 @@ type Session struct {
 	id      string
 	prj     *types.Program
 	env     []string
-	input   string
 	events  *broadcaster.Broadcaster[event]
 	runLock sync.Mutex
 }
@@ -68,7 +67,6 @@ func (s *Session) Event(e runner.Event) {
 		Event: gserver.Event{
 			Event: e,
 			RunID: s.id,
-			Input: s.input,
 		},
 	}
 }
@@ -87,7 +85,6 @@ func (s *Session) Stop(ctx context.Context, output string, err error) {
 				Type: runner.EventTypeRunFinish,
 			},
 			RunID:  s.id,
-			Input:  s.input,
 			Output: output,
 		},
 	}

pkg/sdkserver/types.go

@@ -144,6 +144,7 @@ func (r *runInfo) process(e event) map[string]any {
 		r.Start = e.Time
 		r.Program = *e.Program
 		r.State = Running
+		r.Input = e.Input
 	case runner.EventTypeRunFinish:
 		r.End = e.Time
 		r.Output = e.Output
@@ -167,9 +168,11 @@ func (r *runInfo) process(e event) map[string]any {
 	call.Type = e.Type
 
 	switch e.Type {
-	case runner.EventTypeCallStart:
+	case runner.EventTypeCallStart, runner.EventTypeCallContinue:
 		call.Start = e.Time
-		call.Input = e.Content
+		if e.Content != "" {
+			call.Input = e.Content
+		}
 
 	case runner.EventTypeCallSubCalls:
 		call.setSubCalls(e.ToolSubCalls)