BED-4602: Reduce Verbose Log Output

.gitignore

@@ -130,6 +130,10 @@ $RECYCLE.BIN/
 # Generated files
 .idea/**/contentModel.xml
 
+# Plugin metadata
+.idea/**/go.imports.xml
+.idea/**/material_theme_project_new.xml
+
 # Sensitive or high-churn files
 .idea/**/dataSources/
 .idea/**/dataSources.ids

cmd/list-app-owners.go

@@ -89,7 +89,7 @@ func listAppOwners(ctx context.Context, client client.AzureClient, apps <-chan a
 							Owner: item.Ok,
 							AppId: app.Data.Id,
 						}
-						log.V(2).Info("found app owner", "appOwner", appOwner)
+						log.V(2).Info("found app owner", "appId", appOwner.AppId)
 						count++
 						data.Owners = append(data.Owners, appOwner)
 					}

cmd/list-app-role-assignments.go

@@ -102,7 +102,7 @@ func listAppRoleAssignments(ctx context.Context, client client.AzureClient, serv
 					if item.Error != nil {
 						log.Error(item.Error, "unable to continue processing app role assignments for this service principal", "servicePrincipalId", servicePrincipal)
 					} else {
-						log.V(2).Info("found app role assignment", "roleAssignments", item)
+						log.V(2).Info("found app role assignment", "appRoleId", item.Ok.AppRoleId)
 						count++
 						if ok := pipeline.SendAny(ctx.Done(), out, AzureWrapper{
 							Kind: enums.KindAZAppRoleAssignment,

cmd/list-apps.go

@@ -70,7 +70,7 @@ func listApps(ctx context.Context, client client.AzureClient) <-chan azureWrappe
 				log.Error(item.Error, "unable to continue processing applications")
 				return
 			} else {
-				log.V(2).Info("found application", "app", item)
+				log.V(2).Info("found application", "id", item.Ok.AppId, "name", item.Ok.DisplayName)
 				count++
 				if ok := pipeline.Send(ctx.Done(), out, NewAzureWrapper(
 					enums.KindAZApp,

cmd/list-automation-account-role-assignments.go

@@ -110,7 +110,7 @@ func listAutomationAccountRoleAssignments(ctx context.Context, client client.Azu
 							ObjectId:         id,
 							RoleDefinitionId: roleDefinitionId,
 						}
-						log.V(2).Info("found automation account role assignment", "automationAccountRoleAssignment", automationAccountRoleAssignment)
+						log.V(2).Info("found automation account role assignment", "roleDefinitionId", automationAccountRoleAssignment.RoleDefinitionId)
 						count++
 						automationAccountRoleAssignments.RoleAssignments = append(automationAccountRoleAssignments.RoleAssignments, automationAccountRoleAssignment)
 					}

cmd/list-automation-accounts.go

@@ -102,7 +102,7 @@ func listAutomationAccounts(ctx context.Context, client client.AzureClient, subs
 							ResourceGroupId:   resourceGroupId,
 							TenantId:          client.TenantInfo().TenantId,
 						}
-						log.V(2).Info("found automation account", "automationAccount", automationAccount)
+						log.V(2).Info("found automation account", "name", automationAccount.Name)
 						count++
 						if ok := pipeline.SendAny(ctx.Done(), out, AzureWrapper{
 							Kind: enums.KindAZAutomationAccount,

cmd/list-container-registries.go

@@ -107,7 +107,7 @@ func listContainerRegistries(ctx context.Context, client client.AzureClient, sub
 							ResourceGroupId:   resourceGroupId,
 							TenantId:          client.TenantInfo().TenantId,
 						}
-						log.V(2).Info("found container registry", "containerRegistry", containerRegistry)
+						log.V(2).Info("found container registry", "name", containerRegistry.Name)
 						count++
 						if ok := pipeline.SendAny(ctx.Done(), out, AzureWrapper{
 							Kind: enums.KindAZContainerRegistry,

cmd/list-container-registry-role-assignments.go

@@ -115,7 +115,7 @@ func listContainerRegistryRoleAssignments(ctx context.Context, client client.Azu
 							ObjectId:         id,
 							RoleDefinitionId: roleDefinitionId,
 						}
-						log.V(2).Info("found container registry role assignment", "containerRegistryRoleAssignment", containerRegistryRoleAssignment)
+						log.V(2).Info("found container registry role assignment", "roleDefinitionId", roleDefinitionId)
 						count++
 						containerRegistryRoleAssignments.RoleAssignments = append(containerRegistryRoleAssignments.RoleAssignments, containerRegistryRoleAssignment)
 					}

cmd/list-device-owners.go

@@ -105,7 +105,7 @@ func listDeviceOwners(ctx context.Context, client client.AzureClient, devices <-
 							Owner:    item.Ok,
 							DeviceId: id,
 						}
-						log.V(2).Info("found device owner", "deviceOwner", deviceOwner)
+						log.V(2).Info("found device owner", "deviceId", deviceOwner.DeviceId)
 						count++
 						data.Owners = append(data.Owners, deviceOwner)
 					}

cmd/list-devices.go

@@ -70,7 +70,7 @@ func listDevices(ctx context.Context, client client.AzureClient) <-chan interfac
 				log.Error(item.Error, "unable to continue processing devices")
 				return
 			} else {
-				log.V(2).Info("found device", "device", item)
+				log.V(2).Info("found device", "deviceId", item.Ok.DeviceId)
 				count++
 				if ok := pipeline.SendAny(ctx.Done(), out, AzureWrapper{
 					Kind: enums.KindAZDevice,

cmd/list-function-app-role-assignments.go

@@ -110,7 +110,7 @@ func listFunctionAppRoleAssignments(ctx context.Context, client client.AzureClie
 							ObjectId:         id,
 							RoleDefinitionId: roleDefinitionId,
 						}
-						log.V(2).Info("Found function app role asignment", "functionAppRoleAssignment", functionAppRoleAssignment)
+						log.V(2).Info("Found function app role assignment", "roleDefinitionId", roleDefinitionId)
 						count++
 						functionAppRoleAssignments.RoleAssignments = append(functionAppRoleAssignments.RoleAssignments, functionAppRoleAssignment)
 					}

cmd/list-function-apps.go

@@ -103,7 +103,7 @@ func listFunctionApps(ctx context.Context, client client.AzureClient, subscripti
 							TenantId:          client.TenantInfo().TenantId,
 						}
 						if functionApp.Kind == "functionapp" {
-							log.V(2).Info("found function app", "functionApp", functionApp)
+							log.V(2).Info("found function app", "name", functionApp.Name)
 							count++
 							if ok := pipeline.SendAny(ctx.Done(), out, AzureWrapper{
 								Kind: enums.KindAZFunctionApp,

cmd/list-group-members.go

@@ -116,7 +116,7 @@ func listGroupMembers(ctx context.Context, client client.AzureClient, groups <-c
 							Member:  item.Ok,
 							GroupId: id,
 						}
-						log.V(2).Info("found group member", "groupMember", groupMember)
+						log.V(2).Info("found group member", "groupId", groupMember.GroupId)
 						count++
 						data.Members = append(data.Members, groupMember)
 					}

cmd/list-group-owners.go

@@ -106,7 +106,7 @@ func listGroupOwners(ctx context.Context, client client.AzureClient, groups <-ch
 							Owner:   item.Ok,
 							GroupId: id,
 						}
-						log.V(2).Info("found group owner", "groupOwner", groupOwner)
+						log.V(2).Info("found group owner", "groupId", groupOwner.GroupId)
 						count++
 						groupOwners.Owners = append(groupOwners.Owners, groupOwner)
 					}

cmd/list-groups.go

@@ -70,7 +70,7 @@ func listGroups(ctx context.Context, client client.AzureClient) <-chan interface
 				log.Error(item.Error, "unable to continue processing groups")
 				return
 			} else {
-				log.V(2).Info("found group", "group", item)
+				log.V(2).Info("found group", "name", item.Ok.DisplayName)
 				count++
 				group := models.Group{
 					Group:      item.Ok,

cmd/list-key-vault-role-assignments.go

@@ -106,7 +106,7 @@ func listKeyVaultRoleAssignments(ctx context.Context, client client.AzureClient,
 							KeyVaultId:     id,
 							RoleAssignment: item.Ok,
 						}
-						log.V(2).Info("found key vault role assignment", "keyVaultRoleAssignment", keyVaultRoleAssignment)
+						log.V(2).Info("found key vault role assignment", "name", keyVaultRoleAssignment.RoleAssignment.Name)
 						count++
 						keyVaultRoleAssignments.RoleAssignments = append(keyVaultRoleAssignments.RoleAssignments, keyVaultRoleAssignment)
 					}

cmd/list-key-vaults.go

@@ -105,7 +105,7 @@ func listKeyVaults(ctx context.Context, client client.AzureClient, subscriptions
 							ResourceGroup:  item.Ok.ResourceGroupId(),
 							TenantId:       item.Ok.Properties.TenantId,
 						}
-						log.V(2).Info("found key vault", "keyVault", keyVault)
+						log.V(2).Info("found key vault", "name", keyVault.Name)
 						count++
 						if ok := pipeline.SendAny(ctx.Done(), out, AzureWrapper{
 							Kind: enums.KindAZKeyVault,

cmd/list-logic-app-role-assignments.go

@@ -115,7 +115,7 @@ func listLogicAppRoleAssignments(ctx context.Context, client client.AzureClient,
 							ObjectId:         id,
 							RoleDefinitionId: roleDefinitionId,
 						}
-						log.V(2).Info("found logic app role assignment", "logicappRoleAssignment", logicappRoleAssignment)
+						log.V(2).Info("found logic app role assignment", "roleDefinitionId", roleDefinitionId)
 						count++
 						logicappRoleAssignments.RoleAssignments = append(logicappRoleAssignments.RoleAssignments, logicappRoleAssignment)
 					}

cmd/list-logic-apps.go

@@ -111,7 +111,7 @@ func listLogicApps(ctx context.Context, client client.AzureClient, subscriptions
 							ResourceGroupId: item.Ok.ResourceGroupId(),
 							TenantId:        client.TenantInfo().TenantId,
 						}
-						log.V(2).Info("found logicapp", "logicapp", logicapp)
+						log.V(2).Info("found logicapp", "name", logicapp.Name)
 						count++
 						if ok := pipeline.SendAny(ctx.Done(), out, AzureWrapper{
 							Kind: enums.KindAZLogicApp,

cmd/list-managed-cluster-role-assignments.go

@@ -115,7 +115,7 @@ func listManagedClusterRoleAssignments(ctx context.Context, client client.AzureC
 							ObjectId:         id,
 							RoleDefinitionId: roleDefinitionId,
 						}
-						log.V(2).Info("found managed cluster role assignment", "managedClusterRoleAssignment", managedClusterRoleAssignment)
+						log.V(2).Info("found managed cluster role assignment", "roleDefinitionId", managedClusterRoleAssignment.RoleDefinitionId)
 						count++
 						managedClusterRoleAssignments.RoleAssignments = append(managedClusterRoleAssignments.RoleAssignments, managedClusterRoleAssignment)
 					}

cmd/list-managed-clusters.go

@@ -106,7 +106,7 @@ func listManagedClusters(ctx context.Context, client client.AzureClient, subscri
 							ResourceGroupId: item.Ok.ResourceGroupId(),
 							TenantId:        client.TenantInfo().TenantId,
 						}
-						log.V(2).Info("found managed cluster", "managedCluster", managedCluster)
+						log.V(2).Info("found managed cluster", "name", managedCluster.Name)
 						count++
 						if ok := pipeline.SendAny(ctx.Done(), out, AzureWrapper{
 							Kind: enums.KindAZManagedCluster,

cmd/list-management-group-descendants.go

@@ -96,7 +96,7 @@ func listManagementGroupDescendants(ctx context.Context, client client.AzureClie
 					if item.Error != nil {
 						log.Error(item.Error, "unable to continue processing descendants for this management group", "managementGroupId", id)
 					} else {
-						log.V(2).Info("found management group descendant", "type", item.Ok.Type, "id", item.Ok.Id, "parent", item.Ok.Properties.Parent.Id)
+						log.V(2).Info("found management group descendant", "name", item.Ok.Name)
 						count++
 						if ok := pipeline.SendAny(ctx.Done(), out, AzureWrapper{
 							Kind: enums.KindAZManagementGroupDescendant,

cmd/list-management-group-role-assignments.go

@@ -106,7 +106,7 @@ func listManagementGroupRoleAssignments(ctx context.Context, client client.Azure
 							ManagementGroupId: id,
 							RoleAssignment:    item.Ok,
 						}
-						log.V(2).Info("found managementGroup role assignment", "managementGroupRoleAssignment", managementGroupRoleAssignment)
+						log.V(2).Info("found managementGroup role assignment", "name", managementGroupRoleAssignment.RoleAssignment.Name)
 						count++
 						managementGroupRoleAssignments.RoleAssignments = append(managementGroupRoleAssignments.RoleAssignments, managementGroupRoleAssignment)
 					}

cmd/list-management-groups.go

@@ -71,7 +71,7 @@ func listManagementGroups(ctx context.Context, client client.AzureClient) <-chan
 				log.Info("warning: unable to process azure management groups; either the organization has no management groups or azurehound does not have the reader role on the root management group.")
 				return
 			} else if len(config.AzMgmtGroupId.Value().([]string)) == 0 || contains(config.AzMgmtGroupId.Value().([]string), item.Ok.Name) {
-				log.V(2).Info("found management group", "managementGroup", item)
+				log.V(2).Info("found management group", "name", item.Ok.Name)
 				count++
 				mgmtGroup := models.ManagementGroup{
 					ManagementGroup: item.Ok,

cmd/list-resource-group-role-assignments.go

@@ -107,7 +107,7 @@ func listResourceGroupRoleAssignments(ctx context.Context, client client.AzureCl
 							ResourceGroupId: id,
 							RoleAssignment:  item.Ok,
 						}
-						log.V(2).Info("found resourceGroup role assignment", "resourceGroupRoleAssignment", resourceGroupRoleAssignment)
+						log.V(2).Info("found resourceGroup role assignment", "name", resourceGroupRoleAssignment.RoleAssignment.Name)
 						count++
 						resourceGroupRoleAssignments.RoleAssignments = append(resourceGroupRoleAssignments.RoleAssignments, resourceGroupRoleAssignment)
 					}

cmd/list-resource-groups.go

@@ -102,7 +102,7 @@ func listResourceGroups(ctx context.Context, client client.AzureClient, subscrip
 							SubscriptionId: "/subscriptions/" + id,
 							TenantId:       client.TenantInfo().TenantId,
 						}
-						log.V(2).Info("found resource group", "resourceGroup", resourceGroup)
+						log.V(2).Info("found resource group", "name", resourceGroup.Name)
 						count++
 						if ok := pipeline.SendAny(ctx.Done(), out, AzureWrapper{
 							Kind: enums.KindAZResourceGroup,

cmd/list-role-assignment-policies.go

@@ -73,7 +73,7 @@ func listRoleAssignmentPolicies(ctx context.Context, azClient client.AzureClient
 
 				formattedItem.TenantId = azClient.TenantInfo().TenantId
 
-				log.V(2).Info("found unified role assignment policy", "unifiedRoleAssignmentPolicy", formattedItem)
+				log.V(2).Info("found unified role assignment policy", "policyId", formattedItem.UnifiedRoleManagementPolicyAssignment.Policy.Id)
 				count++
 
 				if ok := pipeline.SendAny(ctx.Done(), out, azureWrapper[models.RoleManagementPolicyAssignment]{

cmd/list-role-assignments.go

@@ -106,7 +106,7 @@ func listRoleAssignments(ctx context.Context, client client.AzureClient, roles <
 					if item.Error != nil {
 						log.Error(item.Error, "unable to continue processing role assignments for this role", "roleDefinitionId", id)
 					} else {
-						log.V(2).Info("found role assignment", "roleAssignments", item)
+						log.V(2).Info("found role assignment", "id", item.Ok.Id)
 						count++
 						// To ensure proper linking to AZApp nodes we want to supply the AppId instead when role assignments are app specific scoped
 						if item.Ok.DirectoryScopeId != "/" {

cmd/list-role-eligibility-schedule-instance.go

@@ -19,16 +19,17 @@ package cmd
 
 import (
 	"context"
+	"os"
+	"os/signal"
+	"time"
+
 	"github.com/bloodhoundad/azurehound/v2/client"
 	"github.com/bloodhoundad/azurehound/v2/client/query"
 	"github.com/bloodhoundad/azurehound/v2/enums"
 	"github.com/bloodhoundad/azurehound/v2/models"
 	"github.com/bloodhoundad/azurehound/v2/panicrecovery"
 	"github.com/bloodhoundad/azurehound/v2/pipeline"
 	"github.com/spf13/cobra"
-	"os"
-	"os/signal"
-	"time"
 )
 
 func init() {
@@ -71,7 +72,7 @@ func listRoleEligibilityScheduleInstances(ctx context.Context, client client.Azu
 				log.Error(item.Error, "unable to continue processing unified role eligibility instance schedules")
 				return
 			} else {
-				log.V(2).Info("found unified role eligibility instance schedule", "unifiedRoleEligibilitySchedule", item)
+				log.V(2).Info("found unified role eligibility instance schedule", "id", item.Ok.Id)
 				count++
 				result := item.Ok
 				if ok := pipeline.SendAny(ctx.Done(), out, azureWrapper[models.RoleEligibilityScheduleInstance]{

cmd/list-roles.go

@@ -70,7 +70,7 @@ func listRoles(ctx context.Context, client client.AzureClient) <-chan interface{
 				log.Error(item.Error, "unable to continue processing roles")
 				return
 			} else {
-				log.V(2).Info("found role", "role", item)
+				log.V(2).Info("found role", "displayName", item.Ok.DisplayName)
 				count++
 				if ok := pipeline.SendAny(ctx.Done(), out, AzureWrapper{
 					Kind: enums.KindAZRole,

cmd/list-service-principal-owners.go

@@ -106,7 +106,7 @@ func listServicePrincipalOwners(ctx context.Context, client client.AzureClient,
 							Owner:              item.Ok,
 							ServicePrincipalId: id,
 						}
-						log.V(2).Info("found service principal owner", "servicePrincipalOwner", servicePrincipalOwner)
+						log.V(2).Info("found service principal owner", "servicePrincipalId", servicePrincipalOwner.ServicePrincipalId)
 						count++
 						servicePrincipalOwners.Owners = append(servicePrincipalOwners.Owners, servicePrincipalOwner)
 					}

cmd/list-service-principals.go

@@ -70,7 +70,7 @@ func listServicePrincipals(ctx context.Context, client client.AzureClient) <-cha
 				log.Error(item.Error, "unable to continue processing service principals")
 				return
 			} else {
-				log.V(2).Info("found service principal", "servicePrincipal", item)
+				log.V(2).Info("found service principal", "name", item.Ok.DisplayName)
 				count++
 				if ok := pipeline.SendAny(ctx.Done(), out, AzureWrapper{
 					Kind: enums.KindAZServicePrincipal,

cmd/list-storage-account-role-assignments.go

@@ -110,7 +110,7 @@ func listStorageAccountRoleAssignments(ctx context.Context, client client.AzureC
 							ObjectId:         id,
 							RoleDefinitionId: roleDefinitionId,
 						}
-						log.V(2).Info("found storage account role assignment", "storageAccountRoleAssignment", storageAccountRoleAssignment)
+						log.V(2).Info("found storage account role assignment", "roleDefinitionId", storageAccountRoleAssignment.RoleDefinitionId)
 						count++
 						storageAccountRoleAssignments.RoleAssignments = append(storageAccountRoleAssignments.RoleAssignments, storageAccountRoleAssignment)
 					}

cmd/list-storage-accounts.go

@@ -102,7 +102,7 @@ func listStorageAccounts(ctx context.Context, client client.AzureClient, subscri
 							ResourceGroupName: item.Ok.ResourceGroupName(),
 							TenantId:          client.TenantInfo().TenantId,
 						}
-						log.V(2).Info("found storage account", "storageAccount", storageAccount)
+						log.V(2).Info("found storage account", "name", storageAccount.Name)
 						count++
 						if ok := pipeline.SendAny(ctx.Done(), out, AzureWrapper{
 							Kind: enums.KindAZStorageAccount,

cmd/list-storage-containers.go

@@ -110,7 +110,7 @@ func listStorageContainers(ctx context.Context, client client.AzureClient, stora
 							ResourceGroupName: item.Ok.ResourceGroupName(),
 							TenantId:          client.TenantInfo().TenantId,
 						}
-						log.V(2).Info("found storage container", "storageContainer", storageContainer)
+						log.V(2).Info("found storage container", "name", storageContainer.Name)
 						count++
 						if ok := pipeline.SendAny(ctx.Done(), out, AzureWrapper{
 							Kind: enums.KindAZStorageContainer,

cmd/list-subscription-owners.go

@@ -88,7 +88,7 @@ func listSubscriptionOwners(ctx context.Context, client client.AzureClient, role
 							Owner:          item.RoleAssignment,
 							SubscriptionId: item.SubscriptionId,
 						}
-						log.V(2).Info("found subscription owner", "subscriptionOwner", subscriptionOwner)
+						log.V(2).Info("found subscription owner", "name", subscriptionOwner.Owner.Name)
 						count++
 						subscriptionOwners.Owners = append(subscriptionOwners.Owners, subscriptionOwner)
 					}

cmd/list-subscription-role-assignments.go

@@ -106,7 +106,7 @@ func listSubscriptionRoleAssignments(ctx context.Context, client client.AzureCli
 							SubscriptionId: id,
 							RoleAssignment: item.Ok,
 						}
-						log.V(2).Info("found subscription role assignment", "subscriptionRoleAssignment", subscriptionRoleAssignment)
+						log.V(2).Info("found subscription role assignment", "name", subscriptionRoleAssignment.RoleAssignment.Name)
 						count++
 						subscriptionRoleAssignments.RoleAssignments = append(subscriptionRoleAssignments.RoleAssignments, subscriptionRoleAssignment)
 					}

cmd/list-subscription-user-access-admins.go

@@ -88,7 +88,7 @@ func listSubscriptionUserAccessAdmins(ctx context.Context, client client.AzureCl
 							UserAccessAdmin: item.RoleAssignment,
 							SubscriptionId:  item.SubscriptionId,
 						}
-						log.V(2).Info("found subscription user access admin", "subscriptionUserAccessAdmin", subscriptionUserAccessAdmin)
+						log.V(2).Info("found subscription user access admin", "name", subscriptionUserAccessAdmin.UserAccessAdmin.Name)
 						count++
 						subscriptionUserAccessAdmins.UserAccessAdmins = append(subscriptionUserAccessAdmins.UserAccessAdmins, subscriptionUserAccessAdmin)
 					}

cmd/list-subscriptions.go

@@ -92,7 +92,7 @@ func listSubscriptions(ctx context.Context, client client.AzureClient) <-chan in
 				log.Error(item.Error, "unable to continue processing subscriptions")
 				return
 			} else if !filterOnSubs || contains(uniqueSubIds, item.Ok.SubscriptionId) {
-				log.V(2).Info("found subscription", "subscription", item)
+				log.V(2).Info("found subscription", "name", item.Ok.DisplayName)
 				count++
 				// the embedded struct's values override top-level properties so TenantId
 				// needs to be explicitly set.

cmd/list-tenants.go

@@ -81,7 +81,7 @@ func listTenants(ctx context.Context, client client.AzureClient) <-chan interfac
 				log.Error(item.Error, "unable to continue processing tenants")
 				return
 			} else {
-				log.V(2).Info("found tenant", "tenant", item)
+				log.V(2).Info("found tenant", "id", item.Ok.TenantId)
 				count++
 
 				// Send the remaining tenant trusts