zzet--gortex/internal/resolver/ngrx_effects.go

package resolver

import "github.com/zzet/gortex/internal/graph"

// ngrxEffectVia is the Meta["via"] tag the JS/TS extractors stamp on an NgRx
// effect's ofType placeholder -- `createEffect(() => actions$.pipe(ofType(X)))`
// links the effect to the action X it reacts to, which the static call graph
// cannot see because effects are registered with the EffectsModule, not called.
const ngrxEffectVia = "ngrx-effect"

// ResolveNgRxEffects binds NgRx effect dispatch: a `createEffect(() =>
// this.actions$.pipe(ofType(LoadUsers), ...))` effect -> the LoadUsers action it
// reacts to. The extractor tags the effect node with Meta["ngrx_effect"] and
// stamps each ofType as a placeholder EdgeCalls from the effect to
// `unresolved::*.<action>` with Meta["via"]="ngrx-effect" +
// Meta["ngrx_action"]=<action>. This pass resolves each action against (1) a
// same-file action node, then (2) a unique action match by name (the
// createAction const / action creator / type). NgRx-gated: a no-op when no effect
// placeholder edges exist.
//
// Returns the number of effect placeholders landed on a real action.
func ResolveNgRxEffects(g graph.Store) int {
	if g == nil {
		return 0
	}
	var placeholders []*graph.Edge
	for e := range g.EdgesByKind(graph.EdgeCalls) {
		if e == nil || e.Meta == nil {
			continue
		}
		if v, _ := e.Meta["via"].(string); v != ngrxEffectVia {
			continue
		}
		placeholders = append(placeholders, e)
	}
	if len(placeholders) == 0 {
		return 0
	}

	// Index candidate action nodes by name (createAction const / action creator
	// / action-type class).
	actionByName := map[string][]*graph.Node{}
	for _, n := range nodesByKindsOrAll(g, graph.KindVariable, graph.KindConstant, graph.KindFunction, graph.KindType) {
		if n == nil || n.Name == "" {
			continue
		}
		actionByName[n.Name] = append(actionByName[n.Name], n)
	}

	resolved := 0
	var reindex []graph.EdgeReindex
	for _, e := range placeholders {
		action, _ := e.Meta["ngrx_action"].(string)
		if action == "" {
			continue
		}
		target := pickStoreAction(g, e, sameBoundaryCandidates(g, e.From, actionByName[action]))

		want := "unresolved::*." + action
		if target != nil {
			want = target.ID
		}
		if e.To == want {
			if target != nil {
				resolved++
			}
			continue
		}
		oldTo := e.To
		e.To = want
		if target != nil {
			e.Origin = graph.OriginASTInferred
			e.Confidence = ConfidenceHeuristic
			e.ConfidenceLabel = graph.ConfidenceLabelFor(graph.EdgeCalls, ConfidenceHeuristic)
			StampSynthesized(e, SynthNgRxEffect)
			resolved++
		} else {
			e.Origin = graph.OriginASTInferred
			e.Confidence = 0
			e.ConfidenceLabel = ""
			UnstampSynthesized(e)
		}
		reindex = append(reindex, graph.EdgeReindex{Edge: e, OldTo: oldTo})
	}
	if len(reindex) > 0 {
		g.ReindexEdges(reindex)
	}
	return resolved
}