feat(services): rename tables and properties to fix postgres long names errors

Author: m-pizarro

src/services/aksManagedCluster/schema.graphql

@@ -193,5 +193,5 @@ type azureAksManagedCluster implements azureResource
   skuName: String @search(by: [hash, regexp])
   skuTier: String @search(by: [hash, regexp])
   resourceGroup: [azureResourceGroup] @hasInverse(field: aksManagedClusters)
-  virtualMachineScaleSets: [azureVirtualMachineScaleSet] @hasInverse(field: aksManagedClusters)
+  virtualMachineScaleSets: [azureVmScaleSet] @hasInverse(field: aksManagedClusters)
 }

src/services/billing/schema.graphql

@@ -1,15 +1,15 @@
 type azureBilling implements azureBaseResource @key(fields: "id") {
   subscriptionId: String @search(by: [hash, regexp])
   region: String @search(by: [hash, regexp])
-  totalCostMonthToDate: awsTotalBillingInfo
-  totalCostLast30Days: awsTotalBillingInfo
-  monthToDateDailyAverage: [awsServiceBillingInfo]
-  last30DaysDailyAverage: [awsServiceBillingInfo]
-  monthToDate: [awsServiceBillingInfo]
-  last30Days: [awsServiceBillingInfo]
+  totalCostMonthToDate: azureTotalBillingInfo
+  totalCostLast30Days: azureTotalBillingInfo
+  monthToDateDailyAverage: [azureServiceBillingInfo]
+  last30DaysDailyAverage: [azureServiceBillingInfo]
+  monthToDate: [azureServiceBillingInfo]
+  last30Days: [azureServiceBillingInfo]
 }
 
-type awsServiceBillingInfo
+type azureServiceBillingInfo
   @generate(
     query: { get: false, query: false, aggregate: false }
     mutation: { add: false, delete: false }
@@ -21,7 +21,7 @@ type awsServiceBillingInfo
   formattedCost: String @search(by: [hash, regexp])
 }
 
-type awsTotalBillingInfo
+type azureTotalBillingInfo
   @generate(
     query: { get: false, query: false, aggregate: false }
     mutation: { add: false, delete: false }

src/services/cdnEndpoints/schema.graphql

@@ -40,7 +40,7 @@ type azureCdnSigningParamIdentifier {
   paramName: String @search(by: [hash, regexp])
 }
 
-type azureCdnResourceRef {
+type azureCdnResourceReference {
   id: String! @id @search(by: [hash, regexp])
 }
 
@@ -54,7 +54,7 @@ type azureCdnDeliveryRuleActionParameter {
   customFragment: String @search(by: [hash, regexp])
   algorithm: String @search(by: [hash, regexp])
   parameterNameOverride: [azureCdnSigningParamIdentifier]
-  originGroup: azureCdnResourceRef
+  originGroup: azureCdnResourceReference
   sourcePattern: String @search(by: [hash, regexp])
   destination: String @search(by: [hash, regexp])
   preserveUnmatchedPath: Boolean @search

src/services/containerRegistry/format.ts

@@ -1,5 +1,5 @@
 import cuid from 'cuid'
-import { formatTagsFromMap } from '../../utils/format'
+import { formatTagsFromMap, transformSystemData } from '../../utils/format'
 import { RawAzureContainerRegistry } from './data'
 import { AzureContainerRegistry } from '../../types/generated'
 
@@ -84,13 +84,32 @@ export default ({
     dataEndpointEnabled,
     dataEndpointHostNames,
     privateEndpointConnections:
-      privateEndpointConnections.map(({ id: privateEndpointId, privateLinkServiceConnectionState, ...rest }) => ({
-        id: privateEndpointId || cuid(),
-        privateLinkServiceConnectionStateStatus: privateLinkServiceConnectionState?.status,
-        privateLinkServiceConnectionStateActionsRequired: privateLinkServiceConnectionState?.actionsRequired,
-        privateLinkServiceConnectionStateDescription: privateLinkServiceConnectionState?.description,
-        ...rest,
-      })) || [],
+      privateEndpointConnections.map(
+        ({
+          id: privateEndpointId,
+          privateLinkServiceConnectionState,
+          privateEndpoint,
+          systemData,
+          name: peName,
+          type: peType,
+          provisioningState: peProvisioningState,
+        }) => ({
+          id: privateEndpointId || cuid(),
+          name: peName,
+          type: peType,
+          provisioningState: peProvisioningState,
+          privateLinkServiceConnectionStateStatus:
+            privateLinkServiceConnectionState?.status,
+          privateLinkServiceConnectionStateActionsRequired:
+            privateLinkServiceConnectionState?.actionsRequired,
+          privateLinkServiceConnectionStateDescription:
+            privateLinkServiceConnectionState?.description,
+          privateEndpoint: {
+            id: privateEndpoint.id || cuid(),
+          },
+          ...transformSystemData(systemData),
+        })
+      ) || [],
     publicNetworkAccess,
     networkRuleBypassOptions,
     zoneRedundancy,

src/services/index.ts

@@ -8,6 +8,7 @@ import chalk from 'chalk'
 import { isEmpty, merge, unionBy } from 'lodash'
 import path from 'path'
 
+import { DocumentNode } from 'graphql'
 import {
   DEFAULT_REGION,
   DEFAULT_RESOURCES,
@@ -33,9 +34,9 @@ import {
   getClientSecretCredentials,
   getTokenCredentials
 } from '../utils/authUtils'
-import enhancers, { EnhancerConfig } from './base/enhancers'
 import { createDiffSecs } from '../utils/dateutils'
 import { obfuscateSensitiveString } from '../utils/format'
+import enhancers, { EnhancerConfig } from './base/enhancers'
 
 export const enums = {
   services,
@@ -344,7 +345,7 @@ export default class Provider extends CloudGraph.Client {
    * getSchema is used to get the schema for provider
    * @returns A string of graphql sub schemas
    */
-  getSchema(): any {
+  getSchema(): DocumentNode {
     const typesArray = loadFilesSync(path.join(__dirname), {
       recursive: true,
       extensions: ['graphql'],

src/services/recoveryInstances/format.ts

@@ -184,7 +184,7 @@ export default ({
 }: {
   service: RawAzureProtectedItemResource
   account: string
-}): AzureBackupInstance => {
+}): AzureRecoveryInstance => {
   const { id, name, type, region, eTag, properties, resourceGroupId } = service
   return {
     id: id || cuid(),

src/services/recoveryInstances/schema.graphql

@@ -13,7 +13,7 @@ type azureRecoveryInstanceItemExtendedInfo
   lastRefreshedAt: DateTime @search(by: [day])
 }
 
-type azureBackupInstanceResourceHealth
+type azureRecoveryInstanceResourceHealth
   @generate(
     query: { get: false, query: true, aggregate: false }
     mutation: { add: false, delete: false }
@@ -47,14 +47,14 @@ type azureRecoveryInstanceExtendedProperties
   linuxVmApplicationName: String @search(by: [hash, regexp])
 }
 
-type azureBackupInstanceKPIResourceHealth
+type azureRecoveryInstanceKPIResourceHealth
   @generate(
     query: { get: false, query: true, aggregate: false }
     mutation: { add: false, delete: false }
     subscription: false
   ) {
   resourceHealthStatus: String @search(by: [hash, regexp])
-  resourceHealthDetails: [azureBackupInstanceResourceHealth]
+  resourceHealthDetails: [azureRecoveryInstanceResourceHealth]
 }
 
 type azureRecoveryInstanceKpisHealths
@@ -66,7 +66,7 @@ type azureRecoveryInstanceKpisHealths
   @key(fields: "id") {
   id: String! @id
   key: String @search(by: [hash, regexp])
-  value: azureBackupInstanceKPIResourceHealth
+  value: azureRecoveryInstanceKPIResourceHealth
 }
 
 type azureRecoveryInstanceErrorDetail
@@ -124,7 +124,7 @@ type azureRecoveryInstanceProperties
   extendedInfo: azureRecoveryInstanceItemExtendedInfo
   virtualMachineId: String @search(by: [hash, regexp])
   healthStatus: String @search(by: [hash, regexp])
-  healthDetails: [azureBackupInstanceResourceHealth]
+  healthDetails: [azureRecoveryInstanceResourceHealth]
   protectedItemDataId: String @search(by: [hash, regexp])
   extendedProperties: azureRecoveryInstanceExtendedProperties
   serverName: String @search(by: [hash, regexp])

src/services/recoveryPolicies/format.ts

@@ -23,6 +23,7 @@ import {
   AzureRecoveryPolicyRetentionPolicyUnion,
   AzureRecoveryPolicySchedulePolicyUnion,
 } from '../../types/generated'
+import { RawAzureProtectionPolicyResource } from './data'
 
 export interface RawAzureSchedulePolicy extends SchedulePolicy {
   scheduleFrequencyInMins?: number

src/services/recoveryVaults/format.ts

@@ -107,42 +107,7 @@ export default ({
         value: identity?.userAssignedIdentities[key],
       })),
     },
-    properties: {
-      ...properties,
-      moveDetails: {
-        ...properties?.moveDetails,
-        completionTimeUtc: properties?.moveDetails?.completionTimeUtc?.toISOString(),
-        startTimeUtc: properties?.moveDetails?.startTimeUtc?.toISOString(),
-      },
-      upgradeDetails: {
-        ...properties?.upgradeDetails,
-        endTimeUtc: properties?.upgradeDetails?.endTimeUtc?.toISOString(),
-        lastUpdatedTimeUtc: properties?.upgradeDetails?.lastUpdatedTimeUtc?.toISOString(),
-        startTimeUtc: properties?.upgradeDetails?.startTimeUtc?.toISOString(),
-      },
-      privateEndpointConnections: properties?.privateEndpointConnections?.map(connection => ({
-        id: connection?.id || cuid(),
-        properties: { 
-          provisioningState: connection.properties?.provisioningState, 
-          privateEndpoint: connection.properties?.privateEndpoint,
-          privateLinkServiceConnectionState: {
-            status: connection.properties?.privateLinkServiceConnectionState?.status,
-            description: connection.properties?.privateLinkServiceConnectionState?.description,
-            actionsRequired: connection.properties?.privateLinkServiceConnectionState?.actionsRequired,
-          }
-        },
-        name: connection.name,
-        type: connection.type,
-        location: connection.location
-      })),
-    },
-    sku,
-    createdBy: systemData?.createdBy,
-    createdByType: systemData?.createdByType,
-    createdAt: systemData?.createdAt?.toISOString(),
-    lastModifiedBy: systemData?.lastModifiedBy,
-    lastModifiedByType: systemData?.lastModifiedByType,
-    lastModifiedAt: systemData?.lastModifiedAt?.toISOString(),
+    ...transformSystemData(systemData),
     tags: formatTagsFromMap(Tags),
   }
-}
+}

src/services/recoveryVaults/schema.graphql

@@ -15,6 +15,15 @@ type azureRecoveryVaultUpgradeDetails
   previousResourceId: String @search(by: [hash, regexp])
 }
 
+type azureRecoveryVaultPrivateEndpoint
+  @generate(
+    query: { get: false, query: true, aggregate: false }
+    mutation: { add: false, delete: false }
+    subscription: false
+  ) {
+  id: String @search(by: [hash, regexp])
+}
+
 type azureRecoveryVaultPrivateLinkServiceConnectionState
   @generate(
     query: { get: false, query: true, aggregate: false }
@@ -26,7 +35,7 @@ type azureRecoveryVaultPrivateLinkServiceConnectionState
   actionsRequired: String @search(by: [hash, regexp])
 }
 
-type azureRecoveryVaultPrivateEndpointConnection
+type azureRecoveryVaultPrivateEndpointConn
   @generate(
     query: { get: false, query: true, aggregate: false }
     mutation: { add: false, delete: false }