From 9b98fc06489353053564b431ac0c0d73a5c55a56 Mon Sep 17 00:00:00 2001 From: Michael Muré Date: Wed, 21 Dec 2022 21:54:36 +0100 Subject: cache: tie up the refactor up to compiling --- entities/bug/bug.go | 13 ++----------- entities/bug/resolver.go | 2 +- 2 files changed, 3 insertions(+), 12 deletions(-) (limited to 'entities/bug') diff --git a/entities/bug/bug.go b/entities/bug/bug.go index 4c4a9a74..271e7dbd 100644 --- a/entities/bug/bug.go +++ b/entities/bug/bug.go @@ -27,15 +27,6 @@ var def = dag.Definition{ FormatVersion: formatVersion, } -var Actions = dag.Actions[*Bug]{ - Wrap: wrapper, - New: NewBug, - Read: Read, - ReadWithResolver: ReadWithResolver, - ReadAll: ReadAll, - ListLocalIds: ListLocalIds, -} - var ClockLoader = dag.ClockLoader(def) type Interface interface { @@ -75,12 +66,12 @@ func ReadWithResolver(repo repository.ClockedRepo, resolvers entity.Resolvers, i } // ReadAll read and parse all local bugs -func ReadAll(repo repository.ClockedRepo) <-chan dag.StreamedEntity[*Bug] { +func ReadAll(repo repository.ClockedRepo) <-chan entity.StreamedEntity[*Bug] { return dag.ReadAll(def, wrapper, repo, simpleResolvers(repo)) } // ReadAllWithResolver read and parse all local bugs -func ReadAllWithResolver(repo repository.ClockedRepo, resolvers entity.Resolvers) <-chan dag.StreamedEntity[*Bug] { +func ReadAllWithResolver(repo repository.ClockedRepo, resolvers entity.Resolvers) <-chan entity.StreamedEntity[*Bug] { return dag.ReadAll(def, wrapper, repo, resolvers) } diff --git a/entities/bug/resolver.go b/entities/bug/resolver.go index e7beb0e4..b0a05917 100644 --- a/entities/bug/resolver.go +++ b/entities/bug/resolver.go @@ -16,6 +16,6 @@ func NewSimpleResolver(repo repository.ClockedRepo) *SimpleResolver { return &SimpleResolver{repo: repo} } -func (r *SimpleResolver) Resolve(id entity.Id) (entity.Interface, error) { +func (r *SimpleResolver) Resolve(id entity.Id) (entity.Resolved, error) { return Read(r.repo, id) } -- cgit