PDI-1540: Add pingone_webhook (Resource) Export (#69)

internal/connector/pingone_platform/pingone_platform_connector.go

@@ -96,6 +96,7 @@ func (c *PingonePlatformConnector) Export(format, outputDir string, overwriteExp
 		resources.RoleAssignmentUser(&c.clientInfo),
 		resources.TrustedEmailAddress(&c.clientInfo),
 		resources.TrustedEmailDomain(&c.clientInfo),
+		resources.Webhook(&c.clientInfo),
 	}
 
 	for _, exportableResource := range exportableResources {

internal/connector/pingone_platform/resources/pingone_webhook.go

@@ -0,0 +1,61 @@
+package resources
+
+import (
+	"fmt"
+
+	"github.com/pingidentity/pingctl/internal/connector"
+	"github.com/pingidentity/pingctl/internal/logger"
+)
+
+// Verify that the resource satisfies the exportable resource interface
+var (
+	_ connector.ExportableResource = &PingoneWebhookResource{}
+)
+
+type PingoneWebhookResource struct {
+	clientInfo *connector.SDKClientInfo
+}
+
+// Utility method for creating a PingoneWebhookResource
+func Webhook(clientInfo *connector.SDKClientInfo) *PingoneWebhookResource {
+	return &PingoneWebhookResource{
+		clientInfo: clientInfo,
+	}
+}
+
+func (r *PingoneWebhookResource) ExportAll() (*[]connector.ImportBlock, error) {
+	l := logger.Get()
+
+	l.Debug().Msgf("Fetching all %s resources...", r.ResourceType())
+
+	apiExecuteFunc := r.clientInfo.ApiClient.ManagementAPIClient.SubscriptionsWebhooksApi.ReadAllSubscriptions(r.clientInfo.Context, r.clientInfo.ExportEnvironmentID).Execute
+	apiFunctionName := "ReadAllSubscriptions"
+
+	usersEmbedded, err := GetManagementEmbedded(apiExecuteFunc, apiFunctionName, r.ResourceType())
+	if err != nil {
+		return nil, err
+	}
+
+	importBlocks := []connector.ImportBlock{}
+
+	l.Debug().Msgf("Generating Import Blocks for all %s resources...", r.ResourceType())
+
+	for _, subscription := range usersEmbedded.GetSubscriptions() {
+		subscriptionId, subscriptionIdOk := subscription.GetIdOk()
+		subscriptionName, subscriptionNameOk := subscription.GetNameOk()
+
+		if subscriptionIdOk && subscriptionNameOk {
+			importBlocks = append(importBlocks, connector.ImportBlock{
+				ResourceType: r.ResourceType(),
+				ResourceName: *subscriptionName,
+				ResourceID:   fmt.Sprintf("%s/%s", r.clientInfo.ExportEnvironmentID, *subscriptionId),
+			})
+		}
+	}
+
+	return &importBlocks, nil
+}
+
+func (r *PingoneWebhookResource) ResourceType() string {
+	return "pingone_webhook"
+}