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