Trigger updates on all relevant events

This commit is contained in:
André Duffeck
2022-04-28 08:51:18 +02:00
parent 0b0efd6799
commit e5338dff55
2 changed files with 66 additions and 0 deletions

View File

@@ -51,6 +51,21 @@ func New(gwClient gateway.GatewayAPIClient, indexClient search.IndexClient, mach
owner = &user.User{
Id: e.Executant,
}
case events.ItemMoved:
ref = e.Ref
owner = &user.User{
Id: e.Executant,
}
case events.ItemRestored:
ref = e.Ref
owner = &user.User{
Id: e.Executant,
}
case events.FileVersionRestored:
ref = e.Ref
owner = &user.User{
Id: e.Executant,
}
case events.ItemTrashed:
err := p.indexClient.Remove(e.Id)
if err != nil {

View File

@@ -137,6 +137,57 @@ var _ = Describe("Searchprovider", func() {
return called
}).Should(BeTrue())
})
It("indexes items when they are being restored", func() {
called := false
indexClient.On("Add", mock.Anything, mock.MatchedBy(func(riToIndex *sprovider.ResourceInfo) bool {
return riToIndex.Id.OpaqueId == ri.Id.OpaqueId
})).Return(nil).Run(func(args mock.Arguments) {
called = true
})
eventsChan <- events.ItemRestored{
Ref: ref,
Executant: user.Id,
}
Eventually(func() bool {
return called
}).Should(BeTrue())
})
It("indexes items when a version has been restored", func() {
called := false
indexClient.On("Add", mock.Anything, mock.MatchedBy(func(riToIndex *sprovider.ResourceInfo) bool {
return riToIndex.Id.OpaqueId == ri.Id.OpaqueId
})).Return(nil).Run(func(args mock.Arguments) {
called = true
})
eventsChan <- events.FileVersionRestored{
Ref: ref,
Executant: user.Id,
}
Eventually(func() bool {
return called
}).Should(BeTrue())
})
It("indexes items when they are being moved", func() {
called := false
indexClient.On("Add", mock.Anything, mock.MatchedBy(func(riToIndex *sprovider.ResourceInfo) bool {
return riToIndex.Id.OpaqueId == ri.Id.OpaqueId
})).Return(nil).Run(func(args mock.Arguments) {
called = true
})
eventsChan <- events.ItemMoved{
Ref: ref,
Executant: user.Id,
}
Eventually(func() bool {
return called
}).Should(BeTrue())
})
})
Describe("IndexSpace", func() {