beenull/crowdsec
1
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

add custom error to be able to ignore or fatalF when reference is missing in collection

Browse source
This commit is contained in:
erenJag 2020-05-25 10:55:05 +02:00
parent 1b54bbb909
commit 34a6156097
2 changed files with 20 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
pkg/cwhub/errors.go Normal file
View file

@ -0,0 +1,8 @@
package cwhub
import (
"errors"
)
/*To be used when reference(s) (is/are) missing in a collection*/
var ReferenceMissingError = errors.New("Reference(s) missing in collection")

14
pkg/cwhub/hubMgmt.go
View file

@ -3,6 +3,7 @@ package cwhub
import (
"crypto/sha256"
"encoding/json"
"errors"
"fmt"
"io"
"io/ioutil"
@ -375,7 +376,9 @@ func GetHubIdx() error {
}
ret, err := LoadPkgIndex(bidx)
if err != nil {
log.Fatalf("Unable to load existing index : %v.", err)
if !errors.Is(err, ReferenceMissingError) {
log.Fatalf("Unable to load existing index : %v.", err)
}
}
HubIdx = ret
if err := LocalSync(); err != nil {
@ -391,7 +394,9 @@ func UpdateHubIdx() error {
}
ret, err := LoadPkgIndex(bidx)
if err != nil {
log.Fatalf("Unable to load freshly downloaded index : %v.", err)
if !errors.Is(err, ReferenceMissingError) {
log.Fatalf("Unable to load freshly downloaded index : %v.", err)
}
}
HubIdx = ret
if err := LocalSync(); err != nil {
@ -450,6 +455,7 @@ func DisplaySummary() {
func LoadPkgIndex(buff []byte) (map[string]map[string]Item, error) {
var err error
var RawIndex map[string]map[string]Item
var missingItems []string
if err = json.Unmarshal(buff, &RawIndex); err != nil {
return nil, fmt.Errorf("failed to unmarshal index : %v", err)
@ -473,12 +479,16 @@ func LoadPkgIndex(buff []byte) (map[string]map[string]Item, error) {
for _, p := range ptr {
if _, ok := RawIndex[ptrtype][p]; !ok {
log.Errorf("Referred %s %s in collection %s doesn't exist.", ptrtype, p, item.Name)
missingItems = append(missingItems, p)
}
}
}
}
}
}
if len(missingItems) > 0 {
return RawIndex, fmt.Errorf("%q : %w", missingItems, ReferenceMissingError)
}
return RawIndex, nil
}