internal/scanners/wps/wps.go (56 lines of code) (raw):

// Copyright (c) Microsoft Corporation. // Licensed under the MIT License. package wps import ( "github.com/Azure/azqr/internal/models" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/webpubsub/armwebpubsub" ) func init() { models.ScannerList["wps"] = []models.IAzureScanner{&WebPubSubScanner{}} } // WebPubSubScanner - Scanner for WebPubSub type WebPubSubScanner struct { config *models.ScannerConfig client *armwebpubsub.Client } // Init - Initializes the WebPubSubScanner func (c *WebPubSubScanner) Init(config *models.ScannerConfig) error { c.config = config var err error c.client, err = armwebpubsub.NewClient(config.SubscriptionID, config.Cred, config.ClientOptions) return err } // Scan - Scans all WebPubSub in a Resource Group func (c *WebPubSubScanner) Scan(scanContext *models.ScanContext) ([]models.AzqrServiceResult, error) { models.LogSubscriptionScan(c.config.SubscriptionID, c.ResourceTypes()[0]) WebPubSub, err := c.listWebPubSub() if err != nil { return nil, err } engine := models.RecommendationEngine{} rules := c.GetRecommendations() results := []models.AzqrServiceResult{} for _, w := range WebPubSub { rr := engine.EvaluateRecommendations(rules, w, scanContext) results = append(results, models.AzqrServiceResult{ SubscriptionID: c.config.SubscriptionID, SubscriptionName: c.config.SubscriptionName, ResourceGroup: models.GetResourceGroupFromResourceID(*w.ID), ServiceName: *w.Name, Type: *w.Type, Location: *w.Location, Recommendations: rr, }) } return results, nil } func (c *WebPubSubScanner) listWebPubSub() ([]*armwebpubsub.ResourceInfo, error) { pager := c.client.NewListBySubscriptionPager(nil) WebPubSubs := make([]*armwebpubsub.ResourceInfo, 0) for pager.More() { resp, err := pager.NextPage(c.config.Ctx) if err != nil { return nil, err } WebPubSubs = append(WebPubSubs, resp.Value...) } return WebPubSubs, nil } func (c *WebPubSubScanner) ResourceTypes() []string { return []string{"Microsoft.SignalRService/webPubSub"} }