when reindexing in --all, only index "added" sources

2 files changed, 30 insertions, 0 deletions

diff --git a/cache/cache.go b/cache/cache.go
index ae2d081..98bdbe8 100644
--- a/cache/cache.go
+++ b/cache/cache.go
@@ -111,3 +111,19 @@ func LoadState(f fs.FS, cache Cache, indexers []model.Indexer, runners []model.R
 	}
 	return model.NewState(f, locs, indexers, runners)
 }
+
+func (c Cache) Strip(needle Cache) Cache {
+	var result []Entry
+outer:
+	for _, e := range c.Entries {
+		for _, t := range needle.Entries {
+			if t.Path == e.Path {
+				continue outer
+			}
+		}
+		result = append(result, e)
+	}
+	return Cache{
+		Entries: result,
+	}
+}
diff --git a/cache/cache_test.go b/cache/cache_test.go
index fa81974..c140154 100644
--- a/cache/cache_test.go
+++ b/cache/cache_test.go
@@ -77,3 +77,17 @@ func TestFromReader_Comments(t *testing.T) {
 		Label: "da source",
 	})
 }
+
+func TestStrip(t *testing.T) {
+	c := Cache{Entries: []Entry{{"/asdf/123", ""}, {"xxxxx", "lab"}}}
+	remove := Cache{Entries: []Entry{{"xxxxx", "wronglabel"}}}
+	result := c.Strip(remove)
+	assert.Equal(t, Cache{Entries: []Entry{{"/asdf/123", ""}}}, result)
+}
+
+func TestStrip_Nothing(t *testing.T) {
+	c := Cache{Entries: []Entry{{"/asdf/123", ""}, {"/asdf/123", ""}}}
+	old := Cache{}
+	result := c.Strip(old)
+	assert.Equal(t, c, result)
+}