Add webhook details in table azure_container_registry Closes #708 (#710)

azure-test/tests/azure_container_registry/test-not-found-expected.json

@@ -1 +1 @@
-null
+[]

azure/table_azure_container_registry.go

@@ -181,6 +181,13 @@ func tableAzureContainerRegistry(_ context.Context) *plugin.Table {
 				Hydrate:     listContainerRegistryUsages,
 				Transform:   transform.FromValue(),
 			},
+			{
+				Name:        "webhooks",
+				Description: "Webhooks in Azure Container Registry provide a way to trigger custom actions in response to events happening within the registry.",
+				Type:        proto.ColumnType_JSON,
+				Hydrate:     listContainerRegistryWebhooks,
+				Transform:   transform.FromValue(),
+			},
 
 			// Steampipe standard columns
 			{
@@ -321,6 +328,40 @@ func listContainerRegistryLoginCredentials(ctx context.Context, d *plugin.QueryD
 	return op, nil
 }
 
+func listContainerRegistryWebhooks(ctx context.Context, d *plugin.QueryData, h *plugin.HydrateData) (interface{}, error) {
+	// Create session
+	session, err := GetNewSession(ctx, d, "MANAGEMENT")
+	if err != nil {
+		return nil, err
+	}
+	subscriptionID := session.SubscriptionID
+	client := containerregistry.NewWebhooksClientWithBaseURI(session.ResourceManagerEndpoint, subscriptionID)
+	client.Authorizer = session.Authorizer
+
+	data := h.Item.(containerregistry.Registry)
+	resourceGroup := strings.Split(*data.ID, "/")[4]
+
+	op, err := client.List(ctx, resourceGroup, *data.Name)
+	if err != nil {
+		plugin.Logger(ctx).Error("azure_container_registry.listContainerRegistryWebhooks", "api_error", err)
+		return nil, err
+	}
+
+	webhooks := op.Values()
+
+	if op.NotDone() {
+		err = op.NextWithContext(ctx)
+		if err != nil {
+			plugin.Logger(ctx).Error("azure_container_registry.listContainerRegistryWebhooks", "api_paging_error", err)
+			return nil, err
+		}
+
+		webhooks = append(webhooks, op.Values()...)
+	}
+
+	return webhooks, nil
+}
+
 func listContainerRegistryUsages(ctx context.Context, d *plugin.QueryData, h *plugin.HydrateData) (interface{}, error) {
 	plugin.Logger(ctx).Trace("listContainerRegistryUsages")
 

docs/tables/azure_container_registry.md

@@ -61,6 +61,33 @@ from
   azure_container_registry;
 ```
 
+### Get webhook details of registries
+Webhooks in Azure Container Registry provide a way to trigger custom actions in response to events happening within the registry. These events can include the completion of Docker image pushes, or deletions in the container registry. When such an event occurs, Azure Container Registry sends an HTTP POST payload to the webhook's configured URL.
+
+```sql+postgres
+select
+  name,
+  w ->> 'location' as webhook_location,
+  w -> 'properties' -> 'actions' as actions,
+  w -> 'properties' ->> 'scope' as scope,
+  w -> 'properties' ->> 'status' as status
+from
+  azure_container_registry,
+  jsonb_array_elements(webhooks) as w;
+```
+
+```sql+sqlite
+select
+  name,
+  json_extract(w.value, '$.location') as webhook_location,
+  json_extract(w.value, '$.properties.actions') as actions,
+  json_extract(w.value, '$.properties.scope') as scope,
+  json_extract(w.value, '$.properties.status') as status
+from
+  azure_container_registry,
+  json_each(webhooks) as w;
+```
+
 ### List registries not configured with virtual network service endpoint
 Determine the areas in which registries are not configured with a virtual network service endpoint. This is useful in identifying potential security risks where network access is allowed without restrictions.