Method workspaceObservabilitySource

internal/memory/observability.go:140–182

(
	ctx context.Context,
	workspace string,
)

}

func (s *Store) workspaceObservabilitySource(
	ctx context.Context,
	workspace string,
) (observabilitySource, bool, error) {
	workspaceRoot := canonicalWorkspaceRoot(workspace)
	if workspaceRoot == "" {
		return observabilitySource{}, false, nil
	}
	identity, err := aghworkspace.EnsureIdentity(ctx, workspaceRoot)
	if err != nil {
		return observabilitySource{}, false, fmt.Errorf(
			"memory: resolve workspace identity for %q: %w",
			workspaceRoot,
			err,
		)
	}
	dbPath := filepath.Clean(filepath.Join(filepath.Dir(identity.Path), storepkg.GlobalDatabaseName))
	if _, err := os.Stat(dbPath); err != nil {
		if errors.Is(err, os.ErrNotExist) {
			return observabilitySource{}, false, nil
		}
		return observabilitySource{}, false, fmt.Errorf(
			"memory: stat workspace observability database %q: %w",
			dbPath,
			err,
		)
	}
	store := s.ForWorkspace(workspaceRoot)
	store.catalog = newCatalog(dbPath, func() time.Time {
		return time.Now().UTC()
	})
	return observabilitySource{
		id:      "workspace-" + identity.WorkspaceID,
		path:    dbPath,
		store:   store,
		catalog: store.catalog,
		filters: []catalogFilter{{
			scope:         memcontract.ScopeWorkspace,
			workspaceRoot: workspaceRoot,
			workspaceID:   identity.WorkspaceID,
		}},
	}, true, nil
}

func filterCatalogFiltersByWorkspaceID(filters []catalogFilter, workspaceID string) []catalogFilter {
	trimmed := strings.TrimSpace(workspaceID)