in start-scan/main.go [115:150]
func handler() error {
configbucket := os.Getenv("ECR_SCAN_CONFIG_BUCKET")
fmt.Printf("DEBUG:: scan start\n")
cfg, err := config.LoadDefaultConfig(context.TODO())
if err != nil {
fmt.Println(err)
return err
}
svc := s3.NewFromConfig(cfg)
fmt.Printf("Scanning bucket %v for scan specs\n", configbucket)
resp, err := svc.ListObjectsV2(context.TODO(), &s3.ListObjectsV2Input{
Bucket: &configbucket,
},
)
// resp, err := req.Send(context.TODO())
if err != nil {
fmt.Println(err)
return err
}
for _, obj := range resp.Contents {
fn := *obj.Key
scanID := strings.TrimSuffix(fn, ".json")
scanspec, err := fetchScanSpec(configbucket, scanID)
if err != nil {
fmt.Println(err)
return err
}
err = startScan(scanspec)
if err != nil {
fmt.Println(err)
return err
}
}
fmt.Printf("DEBUG:: scan done\n")
return nil
}