internal/scanners/evgd/evgd.go (56 lines of code) (raw):
// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.
package evgd
import (
"github.com/Azure/azqr/internal/models"
"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventgrid/armeventgrid"
)
func init() {
models.ScannerList["evgd"] = []models.IAzureScanner{&EventGridScanner{}}
}
// EventGridScanner - Scanner for EventGrid Domains
type EventGridScanner struct {
config *models.ScannerConfig
domainsClient *armeventgrid.DomainsClient
}
// Init - Initializes the EventGridScanner
func (a *EventGridScanner) Init(config *models.ScannerConfig) error {
a.config = config
var err error
a.domainsClient, err = armeventgrid.NewDomainsClient(config.SubscriptionID, config.Cred, config.ClientOptions)
return err
}
// Scan - Scans all EventGrid Domains in a Resource Group
func (a *EventGridScanner) Scan(scanContext *models.ScanContext) ([]models.AzqrServiceResult, error) {
models.LogSubscriptionScan(a.config.SubscriptionID, a.ResourceTypes()[0])
domains, err := a.listDomain()
if err != nil {
return nil, err
}
engine := models.RecommendationEngine{}
rules := a.GetRecommendations()
results := []models.AzqrServiceResult{}
for _, d := range domains {
rr := engine.EvaluateRecommendations(rules, d, scanContext)
results = append(results, models.AzqrServiceResult{
SubscriptionID: a.config.SubscriptionID,
SubscriptionName: a.config.SubscriptionName,
ResourceGroup: models.GetResourceGroupFromResourceID(*d.ID),
ServiceName: *d.Name,
Type: *d.Type,
Location: *d.Location,
Recommendations: rr,
})
}
return results, nil
}
func (a *EventGridScanner) listDomain() ([]*armeventgrid.Domain, error) {
pager := a.domainsClient.NewListBySubscriptionPager(nil)
domains := make([]*armeventgrid.Domain, 0)
for pager.More() {
resp, err := pager.NextPage(a.config.Ctx)
if err != nil {
return nil, err
}
domains = append(domains, resp.Value...)
}
return domains, nil
}
func (a *EventGridScanner) ResourceTypes() []string {
return []string{"Microsoft.EventGrid/domains"}
}