Function chatJS

cmd/wasm/main.go:171–221

--------------------------------------------------------------------------- chat ---------------------------------------------------------------------------

(_ js.Value, args []js.Value)

// ---------------------------------------------------------------------------

func chatJS(_ js.Value, args []js.Value) any {
	if len(args) < 1 {
		return rejectedPromise("chat: expected at least one argument (options object)")
	}
	opts := args[0]
	var onEvent js.Value
	if len(args) >= 2 && args[1].Type() == js.TypeFunction {
		onEvent = args[1]
	}

	yamlStr := opts.Get("yaml").String()
	agentName := ""
	if v := opts.Get("agentName"); v.Type() == js.TypeString {
		agentName = v.String()
	}
	envMap := jsObjectToStringMap(opts.Get("env"))
	messages, err := jsToMessages(opts.Get("messages"))
	if err != nil {
		return rejectedPromise(fmt.Sprintf("chat: parsing messages: %v", err))
	}

	// Set up cancellable context.
	ctx, cancel := context.WithCancel(context.Background())
	abortState.mu.Lock()
	if abortState.cancel != nil {
		abortState.cancel()
	}
	abortState.cancel = cancel
	abortState.mu.Unlock()

	return newPromise(func(resolve, reject func(any)) {
		go func() {
			defer func() {
				abortState.mu.Lock()
				defer abortState.mu.Unlock()
				cancel()
			}()

			result, err := runChat(ctx, yamlStr, agentName, envMap, messages, onEvent)
			if err != nil {
				if ctx.Err() != nil {
					reject(jsError(fmt.Errorf("chat aborted")))
				} else {
					reject(jsError(err))
				}
				return
			}
			resolve(result)
		}()
	})
}

// runChat loads the config, builds the runtime, and runs the agentic loop.
func runChat(ctx context.Context, yamlStr, agentName string, envMap map[string]string, messages []chat.Message, onEvent js.Value) (any, error) {