package cli import ( "encoding/json" "os" "path/filepath" "testing" "time" "github.com/openclaw/gitcrawl/internal/syncer") func TestSyncProgressWriterPublishesPrivateSanitizedSnapshot(t *testing.T) { path := filepath.Join(t.TempDir(), "progress.json") writer, err := newSyncProgressWriter(path, "openclaw/gitcrawl") if err != nil { t.Fatalf("new writer: %v", err) } writer.now = func() time.Time { return time.Date(2026, 7, 31, 4, 0, 0, 0, time.UTC) } if err := writer.report(syncer.SyncProgress{ Stage: syncer.SyncProgressThreads, IssuesReceived: 56, PullRequestsReceived: 238, CommentsReceived: 350, }); err != nil { t.Fatalf("report progress: %v", err) } if err := writer.finish(syncProgressFailed); err != nil { t.Fatalf("finish progress: %v", err) } data, err := os.ReadFile(path) if err != nil { t.Fatalf("read progress: %v", err) } var snapshot map[string]any if err := json.Unmarshal(data, &snapshot); err != nil { t.Fatalf("decode progress: %v", err) } if len(snapshot) != 8 || snapshot["schema"] != syncProgressSchemaV1 || snapshot["repository"] != "openclaw/gitcrawl" || snapshot["state"] != string(syncProgressFailed) || snapshot["stage"] != string(syncer.SyncProgressThreads) || snapshot["issues_received"] != float64(56) || snapshot["pull_requests_received"] != float64(238) || snapshot["comments_received"] != float64(350) || snapshot["observed_at"] != "2026-07-31T04:00:00Z" { t.Fatalf("progress snapshot = %#v", snapshot) } info, err := os.Stat(path) if err != nil { t.Fatalf("stat progress: %v", err) } if info.Mode().Perm() != 0o600 { t.Fatalf("progress mode = %o", info.Mode().Perm()) }} func TestSyncProgressWriterRequiresAbsolutePath(t *testing.T) { if _, err := newSyncProgressWriter( "progress.json", "openclaw/gitcrawl", ); err == nil { t.Fatal("relative progress path unexpectedly accepted") }}
package cli
import (
"encoding/json"
"os"
"path/filepath"
"testing"
"time"
"github.com/openclaw/gitcrawl/internal/syncer"
)
func TestSyncProgressWriterPublishesPrivateSanitizedSnapshot(t *testing.T) {
path := filepath.Join(t.TempDir(), "progress.json")
writer, err := newSyncProgressWriter(path, "openclaw/gitcrawl")
if err != nil {
t.Fatalf("new writer: %v", err)
}
writer.now = func() time.Time {
return time.Date(2026, 7, 31, 4, 0, 0, 0, time.UTC)
}
if err := writer.report(syncer.SyncProgress{
Stage: syncer.SyncProgressThreads,
IssuesReceived: 56,
PullRequestsReceived: 238,
CommentsReceived: 350,
}); err != nil {
t.Fatalf("report progress: %v", err)
}
if err := writer.finish(syncProgressFailed); err != nil {
t.Fatalf("finish progress: %v", err)
}
data, err := os.ReadFile(path)
if err != nil {
t.Fatalf("read progress: %v", err)
}
var snapshot map[string]any
if err := json.Unmarshal(data, &snapshot); err != nil {
t.Fatalf("decode progress: %v", err)
}
if len(snapshot) != 8 ||
snapshot["schema"] != syncProgressSchemaV1 ||
snapshot["repository"] != "openclaw/gitcrawl" ||
snapshot["state"] != string(syncProgressFailed) ||
snapshot["stage"] != string(syncer.SyncProgressThreads) ||
snapshot["issues_received"] != float64(56) ||
snapshot["pull_requests_received"] != float64(238) ||
snapshot["comments_received"] != float64(350) ||
snapshot["observed_at"] != "2026-07-31T04:00:00Z" {
t.Fatalf("progress snapshot = %#v", snapshot)
}
info, err := os.Stat(path)
if err != nil {
t.Fatalf("stat progress: %v", err)
}
if info.Mode().Perm() != 0o600 {
t.Fatalf("progress mode = %o", info.Mode().Perm())
}
}
func TestSyncProgressWriterRequiresAbsolutePath(t *testing.T) {
if _, err := newSyncProgressWriter(
"progress.json",
"openclaw/gitcrawl",
); err == nil {
t.Fatal("relative progress path unexpectedly accepted")
}
}