chore: event cleanup, send first start before context/credential

Author: ibuildthecloud

pkg/engine/engine.go

@@ -69,10 +69,9 @@ type CallContext struct {
 
 type Context struct {
 	commonContext
-	Ctx          context.Context
-	Parent       *Context
-	Program      *types.Program
-	ToolCategory ToolCategory
+	Ctx     context.Context
+	Parent  *Context
+	Program *types.Program
 }
 
 type ToolCategory string

pkg/monitor/display.go

@@ -51,7 +51,7 @@ func (c *Console) Start(_ context.Context, prg *types.Program, _ []string, input
 	mon.dump.Program = prg
 	mon.dump.Input = input
 
-	log.Fields("runID", mon.dump.ID, "input", input, "program", prg).Debugf("Run started")
+	log.Fields("runID", mon.dump.ID, "input", input, "program", prg, "type", "runStart").Debugf("Run started")
 	return mon, nil
 }
 
@@ -210,6 +210,7 @@ func (d *display) Event(event runner.Event) {
 		"id", currentCall.ID,
 		"parentID", currentCall.ParentID,
 		"toolID", currentCall.ToolID,
+		"type", event.Type,
 	)
 
 	_, ok := d.callIDMap[currentCall.ID]
@@ -287,7 +288,7 @@ func (d *display) Stop(output string, err error) {
 	d.callLock.Lock()
 	defer d.callLock.Unlock()
 
-	log.Fields("runID", d.dump.ID, "output", output, "err", err).Debugf("Run stopped")
+	log.Fields("runID", d.dump.ID, "output", output, "err", err, "type", "runFinish").Debugf("Run stopped")
 	if d.usage.TotalTokens > 0 {
 		log.Fields("runID", d.dump.ID, "total", d.usage.TotalTokens, "prompt", d.usage.PromptTokens, "completion", d.usage.CompletionTokens).Infof("usage   ")
 	}

pkg/runner/runner.go

@@ -367,6 +367,13 @@ func (r *Runner) start(callCtx engine.Context, state *State, monitor Monitor, en
 	progress, progressClose := streamProgress(&callCtx, monitor)
 	defer progressClose()
 
+	monitor.Event(Event{
+		Time:        time.Now(),
+		CallContext: callCtx.GetCallContext(),
+		Type:        EventTypeCallStart,
+		Content:     input,
+	})
+
 	if len(callCtx.Tool.Credentials) > 0 {
 		var err error
 		env, err = r.handleCredentials(callCtx, monitor, env)
@@ -396,13 +403,6 @@ func (r *Runner) start(callCtx engine.Context, state *State, monitor Monitor, en
 		Ports:          &r.ports,
 	}
 
-	monitor.Event(Event{
-		Time:        time.Now(),
-		CallContext: callCtx.GetCallContext(),
-		Type:        EventTypeCallStart,
-		Content:     input,
-	})
-
 	callCtx.Ctx = context2.AddPauseFuncToCtx(callCtx.Ctx, monitor.Pause)
 
 	ret, err := e.Start(callCtx, input)
@@ -719,7 +719,7 @@ func (r *Runner) subCalls(callCtx engine.Context, monitor Monitor, env []string,
 	for _, id := range ids {
 		call := state.Continuation.Calls[id]
 		d.Run(func(ctx context.Context) error {
-			result, err := r.subCall(ctx, callCtx, monitor, env, call.ToolID, call.Input, id, "")
+			result, err := r.subCall(ctx, callCtx, monitor, env, call.ToolID, call.Input, id, toolCategory)
 			if err != nil {
 				return err
 			}

pkg/server/server.go

@@ -18,6 +18,7 @@ import (
 	"github.com/acorn-io/broadcaster"
 	"github.com/gptscript-ai/gptscript/pkg/builtin"
 	"github.com/gptscript-ai/gptscript/pkg/cache"
+	"github.com/gptscript-ai/gptscript/pkg/counter"
 	"github.com/gptscript-ai/gptscript/pkg/gptscript"
 	"github.com/gptscript-ai/gptscript/pkg/loader"
 	"github.com/gptscript-ai/gptscript/pkg/runner"
@@ -89,7 +90,7 @@ var (
 type execKey struct{}
 
 func ContextWithNewID(ctx context.Context) context.Context {
-	return context.WithValue(ctx, execKey{}, fmt.Sprint(atomic.AddInt64(&execID, 1)))
+	return context.WithValue(ctx, execKey{}, counter.Next())
 }
 
 func IDFromContext(ctx context.Context) string {