Function newDaemonMemoryProviderRegistry

internal/daemon/memory_runtime.go:997–1035

(
	ctx context.Context,
	state *bootState,
)

}

func newDaemonMemoryProviderRegistry(
	ctx context.Context,
	state *bootState,
) (*extensionpkg.MemoryProviderRegistry, error) {
	if state == nil || state.memoryStore == nil || !state.cfg.Memory.Enabled {
		return nil, nil
	}
	opts := []extensionpkg.MemoryProviderRegistryOption{
		extensionpkg.WithMemoryProviderReservedTools(
			toolspkg.ToolIDMemoryList.String(),
			toolspkg.ToolIDMemoryShow.String(),
			toolspkg.ToolIDMemorySearch.String(),
			toolspkg.ToolIDMemoryPropose.String(),
			toolspkg.ToolIDMemoryNote.String(),
		),
		extensionpkg.WithMemoryProviderRegistryClock(func() time.Time {
			return time.Now().UTC()
		}),
	}
	if eventWriter, ok := state.registry.(store.EventSummaryStore); ok {
		opts = append(opts, extensionpkg.WithMemoryProviderEventSummaryStore(eventWriter))
	}
	registry := extensionpkg.NewMemoryProviderRegistry(opts...)
	if state.localMemoryProvider != nil {
		if err := registry.Register(ctx, extensionpkg.MemoryProviderRegistration{
			Name:     localprovider.Name,
			Version:  memoryRuntimeBuiltinKey,
			Provider: state.localMemoryProvider,
			Bundled:  true,
		}); err != nil {
			return nil, err
		}
	}
	activeProvider := firstNonEmptyString(state.cfg.Memory.Provider.Name, localprovider.Name)
	if err := registry.SetActive(ctx, "", activeProvider); err != nil {
		return nil, err
	}
	return registry, nil
}

type daemonMemorySessionLedgerService struct {
	rootDir          string