fix incremental update fingerprint handling

Author: tae2089

cmd/ccg/main_postgres_test.go

@@ -153,7 +153,7 @@ func TestRunMigrations_PostgresDownRestoresNullableColumns(t *testing.T) {
 	if err != nil {
 		t.Fatalf("create migrator: %v", err)
 	}
-	if err := migrator.Steps(-2); err != nil {
+	if err := migrator.Steps(-4); err != nil {
 		t.Fatalf("run down migration: %v", err)
 	}
 
@@ -186,7 +186,7 @@ func TestRunMigrations_PostgresDownFromVersionThreeDropsPolicyTables(t *testing.
 	if err != nil {
 		t.Fatalf("create migrator: %v", err)
 	}
-	if err := migrator.Steps(-1); err != nil {
+	if err := migrator.Steps(-3); err != nil {
 		t.Fatalf("run down migration: %v", err)
 	}
 

cmd/ccg/main_test.go

@@ -268,7 +268,7 @@ func TestRunMigrations_SQLiteDownRestoresNullableColumns(t *testing.T) {
 	if err != nil {
 		t.Fatalf("create migrator: %v", err)
 	}
-	if err := migrator.Steps(-3); err != nil {
+	if err := migrator.Steps(-4); err != nil {
 		t.Fatalf("run down migration: %v", err)
 	}
 
@@ -313,7 +313,7 @@ func TestRunMigrations_SQLiteDownFromVersionThreeDropsPolicyTables(t *testing.T)
 	if err != nil {
 		t.Fatalf("create migrator: %v", err)
 	}
-	if err := migrator.Steps(-2); err != nil {
+	if err := migrator.Steps(-3); err != nil {
 		t.Fatalf("run down migration: %v", err)
 	}
 
@@ -427,7 +427,7 @@ func TestEnsureSchemaVersion_LogsRuntimeSchemaPassAndFail(t *testing.T) {
 		t.Fatalf("ensure schema version: %v", err)
 	}
 	passLog := logs.String()
-	for _, want := range []string{"database runtime schema check passed", "driver=sqlite", "required_version=4", "auto_migrated=true"} {
+	for _, want := range []string{"database runtime schema check passed", "driver=sqlite", "required_version=5", "auto_migrated=true"} {
 		if !strings.Contains(passLog, want) {
 			t.Fatalf("expected runtime schema pass log to contain %q, got %q", want, passLog)
 		}
@@ -441,7 +441,7 @@ func TestEnsureSchemaVersion_LogsRuntimeSchemaPassAndFail(t *testing.T) {
 		t.Fatal("expected parity failure")
 	}
 	failLog := logs.String()
-	for _, want := range []string{"database runtime schema check failed", "driver=sqlite", "required_version=4", "auto_migrated=false", "error.message="} {
+	for _, want := range []string{"database runtime schema check failed", "driver=sqlite", "required_version=5", "auto_migrated=false", "error.message="} {
 		if !strings.Contains(failLog, want) {
 			t.Fatalf("expected runtime schema failure log to contain %q, got %q", want, failLog)
 		}

internal/analysis/incremental/incremental.go

@@ -233,6 +233,7 @@ func (s *Syncer) syncWithExisting(ctx context.Context, syncStore Store, files ma
 		if err != nil {
 			return nil, err
 		}
+		setNodeHashes(parsed.nodes, info.Hash)
 		parsedFiles = append(parsedFiles, parsed)
 	}
 
@@ -293,6 +294,15 @@ func (s *Syncer) syncWithExisting(ctx context.Context, syncStore Store, files ma
 	return stats, nil
 }
 
+// setNodeHashes records the file content hash on every node parsed from that file.
+// @intent keep incremental hash comparisons aligned with the stored graph rows.
+// @mutates nodes
+func setNodeHashes(nodes []model.Node, hash string) {
+	for i := range nodes {
+		nodes[i].Hash = hash
+	}
+}
+
 // sortedFilePaths returns the file map keys in deterministic order.
 // @intent stabilize incremental sync traversal so logs, batching, and tests stay reproducible.
 func sortedFilePaths(files map[string]FileInfo) []string {

internal/cli/update.go

@@ -15,7 +15,13 @@ import (
 // @requires deps.Syncer와 deps.Walkers가 초기화되어 있어야 한다.
 // @sideEffect 파일 시스템을 읽고 증분 동기화 결과를 저장소에 반영한다.
 func newUpdateCmd(deps *Deps) *cobra.Command {
+	var excludePatterns []string
+	var noRecursive bool
+	var includePaths []string
 	var fallbackCalls bool
+	var maxFileBytes int64
+	var maxTotalParsedBytes int64
+
 	cmd := &cobra.Command{
 		Use:   "update [directory]",
 		Short: "Incrementally sync changed files into the code graph",
@@ -26,6 +32,11 @@ func newUpdateCmd(deps *Deps) *cobra.Command {
 				dir = args[0]
 			}
 
+			patterns := resolveExcludes(excludePatterns)
+			paths := resolveIncludePaths(includePaths)
+			fileLimit := resolveMaxFileBytes(maxFileBytes)
+			totalLimit := resolveMaxTotalParsedBytes(maxTotalParsedBytes)
+
 			ctx := cmd.Context()
 			ns, _ := cmd.Flags().GetString("namespace")
 			ctx = ctxns.WithNamespace(ctx, ns)
@@ -39,8 +50,13 @@ func newUpdateCmd(deps *Deps) *cobra.Command {
 			}
 			stats, err := svc.Update(ctx, service.UpdateOptions{
 				BuildOptions: service.BuildOptions{
-					Dir:           dir,
-					FallbackCalls: fallbackCalls,
+					Dir:                 dir,
+					NoRecursive:         noRecursive,
+					ExcludePatterns:     patterns,
+					IncludePaths:        paths,
+					MaxFileBytes:        fileLimit,
+					MaxTotalParsedBytes: totalLimit,
+					FallbackCalls:       fallbackCalls,
 				},
 				Syncer:  deps.Syncer,
 				Replace: true,
@@ -56,6 +72,11 @@ func newUpdateCmd(deps *Deps) *cobra.Command {
 		},
 	}
 
+	cmd.Flags().BoolVar(&noRecursive, "no-recursive", false, "Only parse files in the top-level directory, skip subdirectories")
+	cmd.Flags().StringArrayVar(&excludePatterns, "exclude", nil, "Exclude files/directories matching pattern (repeatable, e.g. --exclude vendor --exclude *.pb.go)")
+	cmd.Flags().StringArrayVar(&includePaths, "path", nil, "Only include specific paths (repeatable, e.g. --path src/api --path src/auth)")
+	cmd.Flags().Int64Var(&maxFileBytes, "max-file-bytes", 0, "Maximum bytes allowed per parsed source file (0 disables limit; config: parse.max_file_bytes)")
+	cmd.Flags().Int64Var(&maxTotalParsedBytes, "max-total-parsed-bytes", 0, "Maximum total bytes allowed across parsed source files (0 disables limit; config: parse.max_total_parsed_bytes)")
 	cmd.Flags().BoolVar(&fallbackCalls, "fallback-calls", false, "Fallback to deterministic call resolution when strict matching is ambiguous")
 
 	return cmd

internal/cli/update_test.go

@@ -208,6 +208,37 @@ func Y() {}
 	}
 }
 
+func TestUpdateCommand_HonorsExcludePatterns(t *testing.T) {
+	deps, stdout, stderr, db := setupUpdateGraphOnlyTest(t)
+
+	dir := t.TempDir()
+	writeGoFile(t, dir, "a.go", `package a
+func A() {}
+`)
+
+	if err := executeCmd(deps, stdout, stderr, "build", dir); err != nil {
+		t.Fatalf("initial build: %v", err)
+	}
+
+	writeGoFile(t, dir, "ignored.gen.go", `package a
+func Ignored() {}
+`)
+
+	stdout.Reset()
+	stderr.Reset()
+	if err := executeCmd(deps, stdout, stderr, "update", "--exclude", ".*\\.gen\\.go$", dir); err != nil {
+		t.Fatalf("update: %v", err)
+	}
+
+	var ignoredCount int64
+	if err := db.Model(&model.Node{}).Where("file_path = ?", "ignored.gen.go").Count(&ignoredCount).Error; err != nil {
+		t.Fatalf("count ignored nodes: %v", err)
+	}
+	if ignoredCount != 0 {
+		t.Fatalf("expected excluded file to remain out of graph, got %d nodes", ignoredCount)
+	}
+}
+
 func TestUpdateCommand_RefreshesSearchIndex(t *testing.T) {
 	deps, stdout, stderr, _ := setupUpdateTest(t)
 

internal/db/migration/migration.go

@@ -24,7 +24,7 @@ import (
 )
 
 const (
-	RequiredSchemaVersion    = 4
+	RequiredSchemaVersion    = 5
 	SchemaVersionKey         = "schema"
 	LegacySchemaVersionTable = "ccg_schema_versions"
 )

internal/migrationfs/postgres/000001_init.up.sql

@@ -26,7 +26,7 @@ CREATE TABLE IF NOT EXISTS edges (
     kind varchar(32),
     file_path varchar(1024),
     line bigint,
-    fingerprint varchar(128),
+    fingerprint text,
     created_at timestamptz
 );
 

internal/migrationfs/postgres/000005_edge_fingerprint_text.down.sql

@@ -0,0 +1,2 @@
+ALTER TABLE edges
+    ALTER COLUMN fingerprint TYPE varchar(128);

internal/migrationfs/postgres/000005_edge_fingerprint_text.up.sql

@@ -0,0 +1,2 @@
+ALTER TABLE edges
+    ALTER COLUMN fingerprint TYPE text;

internal/migrationfs/sqlite/000005_edge_fingerprint_text.down.sql

@@ -0,0 +1 @@
+-- SQLite already stores edge fingerprints as text.