X-Git-Url: http://git.giacomolli.uk/onechat/blobdiff_plain/75b9579355e1adcdbb1255a7e8e4582e0a431f3d..786c2b0551517d4befaa35be2c7743f65bd5f1c4:/daemon.go?ds=sidebyside diff --git a/daemon.go b/daemon.go index 4c0f466..a289338 100644 --- a/daemon.go +++ b/daemon.go @@ -86,7 +86,7 @@ func daemon(ctx context.Context, out io.Writer) (err error) { } client := newModelClient(address, auth, agent.CacheKey(), filepath.Join(agent.dir, "usage.jsonl")) - memory, err := openMemory(ctx, agent.dir, time.Now, newCompactor(client, agent.Prompt, config.Compactor)) + memory, err := openMemory(ctx, agent.dir, time.Now, newCompactor(client, agent.Prompt, config.Compactor), logger) if err != nil { return err } @@ -95,7 +95,7 @@ func daemon(ctx context.Context, out io.Writer) (err error) { err = errors.Join(err, memory.Close()) }() - schedules, err := openSchedules(filepath.Join(agent.dir, scheduleFileName), time.Now) + schedules, err := openSchedules(filepath.Join(agent.dir, scheduleFileName), time.Now, logger) if err != nil { return err } @@ -110,21 +110,21 @@ func daemon(ctx context.Context, out io.Writer) (err error) { return err } - linked := "WhatsApp is not linked" + linked := "WhatsApp not linked" if whatsapp.isLinked() { - linked = "WhatsApp is linked" + linked = "WhatsApp linked" } - logger.Printf("%s is ready: socket %s, model %s at %s effort, commands run in %s, %s, active schedules: %d", agent.config.Name, listener.Addr(), agent.config.Model, agent.config.Effort, agent.config.Workdir, linked, schedules.Len()) + logger.Printf("ready: socket %s, model %s (%s), workdir %s, %s, %d schedules", listener.Addr(), agent.config.Model, agent.config.Effort, agent.config.Workdir, linked, schedules.Len()) var telegram *TelegramBot if hasBot { telegram = newTelegramBot(newTelegramAPI(telegramAPIURL, botSettings.Token), botSettings.Owner, filepath.Join(agent.dir, telegramOffsetFileName), daemonLogger(out, "telegram: ")) - logger.Print("the Telegram bot waits for messages of its owner") + logger.Print("Telegram bot started") } return daemonServe(ctx, listener, telegram, whatsapp, schedules, func(notify func(Event)) (*TurnLoop, error) { - return newTurnLoop(agent, memory, subagents, whatsapp, schedules, client, time.Now, notify) + return newTurnLoop(agent, memory, subagents, whatsapp, schedules, client, time.Now, logger, notify) }) }