pipeline

Documentation

Index

• func ProjectNameFromPath(absPath string) string
• type ChangeCoupling
• type ChangedFile
  • func ParseGitDiffFiles(repoPath string, scope DiffScope, baseBranch string) ([]ChangedFile, error)
  • func ParseNameStatusOutput(output string) []ChangedFile
• type ChangedHunk
  • func ParseGitDiffHunks(repoPath string, scope DiffScope, baseBranch string) ([]ChangedHunk, error)
  • func ParseHunksOutput(output string) []ChangedHunk
• type CommitFiles
• type DiffScope
• type EnvBinding
  • func ScanProjectEnvURLs(rootPath string) []EnvBinding
• type FunctionRegistry
  • func NewFunctionRegistry() *FunctionRegistry
  • func (r *FunctionRegistry) Exists(qualifiedName string) bool
  • func (r *FunctionRegistry) FindByName(name string) []string
  • func (r *FunctionRegistry) FindEndingWith(suffix string) []string
  • func (r *FunctionRegistry) FuzzyResolve(calleeName, moduleQN string, importMap map[string]string) (ResolutionResult, bool)
  • func (r *FunctionRegistry) LabelOf(qualifiedName string) string
  • func (r *FunctionRegistry) Register(name, qualifiedName, nodeLabel string)
  • func (r *FunctionRegistry) Resolve(calleeName, moduleQN string, importMap map[string]string) ResolutionResult
  • func (r *FunctionRegistry) Size() int
• type Pipeline
  • func New(ctx context.Context, s *store.Store, repoPath string) *Pipeline
  • func (p *Pipeline) Run() error
• type ResolutionResult
• type ReturnTypeMap
• type TypeMap

Functions

func ProjectNameFromPath

func ProjectNameFromPath(absPath string) string

ProjectNameFromPath derives a unique project name from an absolute path by replacing path separators with dashes and trimming the leading dash.

Types

type ChangeCoupling

type ChangeCoupling struct {
	FileA         string
	FileB         string
	CoChangeCount int
	TotalChangesA int
	TotalChangesB int
	CouplingScore float64
}

ChangeCoupling represents a pair of files that change together.

type ChangedFile

type ChangedFile struct {
	Status  string // M, A, D, R (modified, added, deleted, renamed)
	Path    string
	OldPath string // non-empty only for renames
}

ChangedFile represents a file with a status from git diff --name-status.

func ParseGitDiffFiles

func ParseGitDiffFiles(repoPath string, scope DiffScope, baseBranch string) ([]ChangedFile, error)

ParseGitDiffFiles runs git diff --name-status and returns changed files.

func ParseNameStatusOutput

func ParseNameStatusOutput(output string) []ChangedFile

ParseNameStatusOutput parses the raw output of git diff --name-status.

type ChangedHunk

type ChangedHunk struct {
	Path      string
	StartLine int
	EndLine   int
}

ChangedHunk represents a changed region within a file.

func ParseGitDiffHunks

func ParseGitDiffHunks(repoPath string, scope DiffScope, baseBranch string) ([]ChangedHunk, error)

ParseGitDiffHunks runs git diff --unified=0 and extracts changed line ranges.

func ParseHunksOutput

func ParseHunksOutput(output string) []ChangedHunk

ParseHunksOutput parses the raw output of git diff --unified=0.

type CommitFiles

type CommitFiles struct {
	Hash  string
	Files []string
}

CommitFiles holds the files changed in a single commit.

type DiffScope

type DiffScope string

DiffScope controls which changes to include.

const (
	DiffUnstaged DiffScope = "unstaged"
	DiffStaged   DiffScope = "staged"
	DiffAll      DiffScope = "all"
	DiffBranch   DiffScope = "branch"
)

type EnvBinding

type EnvBinding struct {
	Key      string
	Value    string
	FilePath string // relative path where found
}

EnvBinding represents an extracted environment variable with a URL value.

func ScanProjectEnvURLs

func ScanProjectEnvURLs(rootPath string) []EnvBinding

ScanProjectEnvURLs walks the project root, scanning all non-ignored files for env var assignments where the value looks like a URL.

type FunctionRegistry

type FunctionRegistry struct {
	// contains filtered or unexported fields
}

FunctionRegistry indexes all Function, Method, and Class nodes by qualified name and simple name for fast call resolution.

func NewFunctionRegistry

func NewFunctionRegistry() *FunctionRegistry

NewFunctionRegistry creates an empty registry.

func (*FunctionRegistry) Exists

func (r *FunctionRegistry) Exists(qualifiedName string) bool

Exists returns true if a qualified name is registered. Uses RLock for concurrent read safety.

func (*FunctionRegistry) FindByName

func (r *FunctionRegistry) FindByName(name string) []string

FindByName returns all qualified names with the given simple name.

func (*FunctionRegistry) FindEndingWith

func (r *FunctionRegistry) FindEndingWith(suffix string) []string

FindEndingWith returns all qualified names ending with ".suffix".

func (*FunctionRegistry) FuzzyResolve

func (r *FunctionRegistry) FuzzyResolve(calleeName, moduleQN string, importMap map[string]string) (ResolutionResult, bool)

FuzzyResolve attempts a loose match when Resolve() returns "". It searches for any registered function whose simple name matches the callee's last name segment. Returns the best match (by import distance) with confidence, or an empty result and false if no match is found.

Unlike Resolve(), this does not require prefix/import agreement — it purely matches on the function name.

func (*FunctionRegistry) LabelOf

func (r *FunctionRegistry) LabelOf(qualifiedName string) string

LabelOf returns the node label for a qualified name, or "" if not registered.

func (*FunctionRegistry) Register

func (r *FunctionRegistry) Register(name, qualifiedName, nodeLabel string)

Register adds a node to the registry.

func (*FunctionRegistry) Resolve

func (r *FunctionRegistry) Resolve(calleeName, moduleQN string, importMap map[string]string) ResolutionResult

Resolve attempts to find the qualified name of a callee using a prioritized resolution strategy:

1. Import map lookup
2. Same-module match
3. Project-wide single match by simple name
4. Suffix match with import distance scoring

func (*FunctionRegistry) Size

func (r *FunctionRegistry) Size() int

Size returns the number of entries in the registry.

type Pipeline

type Pipeline struct {
	Store       *store.Store
	RepoPath    string
	ProjectName string
	// contains filtered or unexported fields
}

Pipeline orchestrates the 3-pass indexing of a repository.

func New

func New(ctx context.Context, s *store.Store, repoPath string) *Pipeline

New creates a new Pipeline.

func (*Pipeline) Run

func (p *Pipeline) Run() error

Run executes the full 3-pass pipeline within a single transaction. If file hashes from a previous run exist, only changed files are re-processed.

type ResolutionResult

type ResolutionResult struct {
	QualifiedName  string
	Strategy       string  // "import_map", "import_map_suffix", "same_module", "unique_name", "suffix_match", "fuzzy", "type_dispatch"
	Confidence     float64 // 0.0–1.0
	CandidateCount int     // how many candidates were considered
}

ResolutionResult carries the resolved QN plus quality metadata. Initial confidence values are estimates — recalibrate after measuring precision per strategy on real repos.

type ReturnTypeMap

type ReturnTypeMap map[string]string

ReturnTypeMap maps function QN → return type QN (class/struct the function returns).

type TypeMap

type TypeMap map[string]string

TypeMap tracks variable names to their inferred class/type qualified names. Key: variable name, Value: class/type QN in the registry.