johno/beads
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(sync): add BD_DEBUG_SYNC env for protection debugging

Browse Source 
Adds debug logging when timestamp-aware protection triggers, controlled
by BD_DEBUG_SYNC environment variable. Helps diagnose sync issues.

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
emma
2026-01-04 10:41:27 -08:00
committed by Steve Yegge
parent 4021f49445
commit 4468ff030f
1 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
internal/importer/importer.go
View File

@@ -568,6 +568,7 @@ func upsertIssues(ctx context.Context, sqliteStore *sqlite.SQLiteStorage, issues
// GH#865: Check timestamp-aware protection first // GH#865: Check timestamp-aware protection first
// If local snapshot has a newer version, protect it from being overwritten // If local snapshot has a newer version, protect it from being overwritten
if shouldProtectFromUpdate(existing.ID, incoming.UpdatedAt, opts.ProtectLocalExportIDs) { if shouldProtectFromUpdate(existing.ID, incoming.UpdatedAt, opts.ProtectLocalExportIDs) {
debugLogProtection(existing.ID, opts.ProtectLocalExportIDs[existing.ID], incoming.UpdatedAt)
result.Skipped++ result.Skipped++
continue continue
} }
@@ -672,6 +673,7 @@ func upsertIssues(ctx context.Context, sqliteStore *sqlite.SQLiteStorage, issues
// GH#865: Check timestamp-aware protection first // GH#865: Check timestamp-aware protection first
// If local snapshot has a newer version, protect it from being overwritten // If local snapshot has a newer version, protect it from being overwritten
if shouldProtectFromUpdate(incoming.ID, incoming.UpdatedAt, opts.ProtectLocalExportIDs) { if shouldProtectFromUpdate(incoming.ID, incoming.UpdatedAt, opts.ProtectLocalExportIDs) {
debugLogProtection(incoming.ID, opts.ProtectLocalExportIDs[incoming.ID], incoming.UpdatedAt)
result.Skipped++ result.Skipped++
continue continue
} }
@@ -948,6 +950,14 @@ func shouldProtectFromUpdate(issueID string, incomingTime time.Time, protectMap
return !incomingTime.After(localTime) return !incomingTime.After(localTime)
} }
// debugLogProtection logs when timestamp-aware protection triggers (for debugging sync issues).
func debugLogProtection(issueID string, localTime, incomingTime time.Time) {
if os.Getenv("BD_DEBUG_SYNC") != "" {
fmt.Fprintf(os.Stderr, "[debug] Protected %s: local=%s >= incoming=%s\n",
issueID, localTime.Format(time.RFC3339), incomingTime.Format(time.RFC3339))
}
}
func GetPrefixList(prefixes map[string]int) []string { func GetPrefixList(prefixes map[string]int) []string {
var result []string var result []string
keys := make([]string, 0, len(prefixes)) keys := make([]string, 0, len(prefixes))