mirror of
https://github.com/safedep/vet.git
synced 2025-12-10 00:22:08 -06:00
Publish events from Filter anlayzer module
This commit is contained in:
parent
1e492ba31a
commit
3db93e9726
@ -71,6 +71,14 @@ func (f *celFilterAnalyzer) Analyze(manifest *models.PackageManifest,
|
||||
|
||||
f.stat.IncMatchedPackage()
|
||||
f.packages[pkg.Id()] = pkg
|
||||
|
||||
handler(&AnalyzerEvent{
|
||||
Source: f.Name(),
|
||||
Type: ET_FilterExpressionMatched,
|
||||
Manifest: manifest,
|
||||
Package: pkg,
|
||||
Message: "cli-filter",
|
||||
})
|
||||
}
|
||||
|
||||
return nil
|
||||
|
||||
@ -78,7 +78,7 @@ func (f *celFilterSuiteAnalyzer) Analyze(manifest *models.PackageManifest,
|
||||
}
|
||||
|
||||
if res.Matched() {
|
||||
f.queueMatchedPkg(pkg, res.GetMatchedFilter().Name())
|
||||
f.handleMatchedPkg(pkg, res.GetMatchedFilter().Name(), handler)
|
||||
}
|
||||
|
||||
return nil
|
||||
@ -123,8 +123,8 @@ func (f *celFilterSuiteAnalyzer) renderMatchTable() {
|
||||
tbl.Render()
|
||||
}
|
||||
|
||||
func (f *celFilterSuiteAnalyzer) queueMatchedPkg(pkg *models.Package,
|
||||
filterName string) {
|
||||
func (f *celFilterSuiteAnalyzer) handleMatchedPkg(pkg *models.Package,
|
||||
filterName string, handler AnalyzerEventHandler) {
|
||||
if _, ok := f.matchedPackages[pkg.Id()]; ok {
|
||||
return
|
||||
}
|
||||
@ -134,6 +134,14 @@ func (f *celFilterSuiteAnalyzer) queueMatchedPkg(pkg *models.Package,
|
||||
filterName: filterName,
|
||||
pkg: pkg,
|
||||
}
|
||||
|
||||
handler(&AnalyzerEvent{
|
||||
Source: f.Name(),
|
||||
Type: ET_FilterExpressionMatched,
|
||||
Manifest: pkg.Manifest,
|
||||
Package: pkg,
|
||||
Message: filterName,
|
||||
})
|
||||
}
|
||||
|
||||
// To correctly unmarshal a []byte into protobuf message, we must use
|
||||
|
||||
@ -3,3 +3,7 @@ package analyzer
|
||||
func (ev *AnalyzerEvent) IsFailOnError() bool {
|
||||
return ev.Type == ET_AnalyzerFailOnError
|
||||
}
|
||||
|
||||
func (ev *AnalyzerEvent) IsFilterMatch() bool {
|
||||
return ev.Type == ET_FilterExpressionMatched
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user