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"} }