Function processConnectionsAfterInitialInsertion

src/utils/data.ts:179–229

({
  provider,
  providerData,
  storageEngine,
  storageRunning,
  schemaMap,
}: DataToLoad)

}

export function processConnectionsAfterInitialInsertion({
  provider,
  providerData,
  storageEngine,
  storageRunning,
  schemaMap,
}: DataToLoad): void {
  const additionalConnections: {
    [key: string]: ServiceConnection[]
  } = filterConnectionsByPriorityOfInsertion(providerData.connections, true)
  if (!isEmpty(additionalConnections)) {
    // Filter resourceTypes that have additional connections to process
    const resourcesWithAdditionalConnections = new Set(
      Object.values(additionalConnections)
        .flat()
        .map(({ resourceType }) => resourceType)
    )
    // Filter entities that match filtered resourceTypes
    const entities = providerData.entities.filter(({ name }) =>
      resourcesWithAdditionalConnections.has(name)
    )
    for (const entity of entities) {
      try {
        const { data, name } = entity
        data.map((service: any) => {
          const connections = getConnectedEntity(
            service,
            providerData,
            name,
            true
          )
          if (!isEmpty(connections)) {
            if (storageRunning) {
              const query = generateMutation({
                type: 'update',
                provider,
                entity,
                schemaMap,
              })
              const patch = generateUpdateVarsObject(service, connections)
              // Add service mutation to promises array
              storageEngine.push({ query, patch, name })
            }
          }
        })
      } catch (error) {
        logger.debug(error)
      }
    }
  }
}

export const loadAllData = (
  providerClient: Client,