Function insertMemoryObservabilityEvent

internal/memory/observability_test.go:217–253

(
	ctx context.Context,
	t *testing.T,
	catalog *catalog,
	op string,
	scope string,
	workspaceID string,
	agentName string,
	summary string,
	timestamp time.Time,
)

}

func insertMemoryObservabilityEvent(
	ctx context.Context,
	t *testing.T,
	catalog *catalog,
	op string,
	scope string,
	workspaceID string,
	agentName string,
	summary string,
	timestamp time.Time,
) {
	t.Helper()

	db, err := catalog.ensureDB(ctx)
	if err != nil {
		t.Fatalf("catalog.ensureDB() error = %v", err)
	}
	metadata, err := json.Marshal(map[string]string{memoryEventMetadataSummaryKey: summary})
	if err != nil {
		t.Fatalf("json.Marshal(metadata) error = %v", err)
	}
	if _, err := db.ExecContext(
		ctx,
		`INSERT INTO memory_events (
			op, scope, agent_name, workspace_id, actor_kind, metadata, ts_ms
		) VALUES (?, ?, ?, ?, ?, ?, ?)`,
		op,
		nullStringForEmpty(scope),
		agentName,
		nullStringForEmpty(workspaceID),
		"system",
		string(metadata),
		timeToUnixMillis(timestamp),
	); err != nil {
		t.Fatalf("insert memory event error = %v", err)
	}
}