Function TestImportCommand_DuplicateSkip

apps/cli/internal/cli/importcmd_test.go:164–229

(t *testing.T)

}

func TestImportCommand_DuplicateSkip(t *testing.T) {
	sourceName := "test-import-cli-dedup"
	defer sync.Unregister(sourceName)

	sync.Register(&cliMockSource{
		name: sourceName,
		tasks: []sync.ExternalTask{
			{ExternalID: "DUP-1", Title: "Already exists", Status: "open"},
			{ExternalID: "NEW-1", Title: "Brand new", Status: "open"},
		},
	})

	tmpDir := t.TempDir()
	origDir, _ := os.Getwd()
	if err := os.Chdir(tmpDir); err != nil {
		t.Fatal(err)
	}
	defer os.Chdir(origDir)

	// Create an existing task with external_id DUP-1
	tasksDir := filepath.Join(tmpDir, "tasks")
	if err := os.MkdirAll(tasksDir, 0755); err != nil {
		t.Fatal(err)
	}
	existingContent := "---\nid: \"001\"\ntitle: \"Existing\"\nstatus: pending\nexternal_id: \"DUP-1\"\n---\n"
	if err := os.WriteFile(filepath.Join(tasksDir, "001-existing.md"), []byte(existingContent), 0644); err != nil {
		t.Fatal(err)
	}

	resetImportFlags()
	importSource = sourceName
	importOutDir = tasksDir
	importFormat = "json"

	// Capture stdout
	old := os.Stdout
	r, w, _ := os.Pipe()
	os.Stdout = w

	err := runImport(importCmd, nil)

	w.Close()
	os.Stdout = old

	if err != nil {
		t.Fatalf("unexpected error: %v", err)
	}

	var buf bytes.Buffer
	buf.ReadFrom(r)

	var data importResultData
	if err := json.Unmarshal(buf.Bytes(), &data); err != nil {
		t.Fatalf("invalid JSON: %v", err)
	}

	if data.Summary.Created != 1 {
		t.Errorf("expected 1 created, got %d", data.Summary.Created)