Function getConnectedEntity

src/utils/data.ts:44–101

(
  service: any,
  { entities, connections: allConnections }: ProviderData,
  initiatorServiceName: string,
  afterNodeInsertion = false
)

// in the main add mutation(batch mutation, that pushes fresh nodes and connections)
// or in the patch mutation(list of mutations that patches each node and its connections with others)
export function getConnectedEntity(
  service: any,
  { entities, connections: allConnections }: ProviderData,
  initiatorServiceName: string,
  afterNodeInsertion = false
): Record<string, unknown> {
  logger.debug(
    `Getting connected entities for ${chalk.green(
      initiatorServiceName
    )} id = ${chalk.green(service.id)}`
  )
  const connections: ServiceConnection[] =
    filterConnectionsByPriorityOfInsertion(allConnections, afterNodeInsertion)[
      service.id
    ]
  const connectedEntity: any = { ...(afterNodeInsertion ? {} : service) }
  let connectionsStatus = scanResult.pass
  if (!isEmpty(connections)) {
    for (const connection of connections) {
      const entityData = entities.find(
        ({ name }: { name: string }) => name === connection.resourceType
      )
      if (entityData && entityData.data) {
        const entityForConnection = entityData.data.find(
          ({ id }: { id: string }) => connection.id === id
        )
        if (!isEmpty(entityForConnection)) {
          if (!connectedEntity[connection.field]) {
            connectedEntity[connection.field] = []
          }
          connectedEntity[connection.field].push(entityForConnection)
          logger.debug(
            `(${initiatorServiceName}) ${service.id} ${chalk.green(
              '<----->'
            )} ${connection.id} (${connection.resourceType})`
          )
        } else {
          connectionsStatus = scanResult.warn
          const error = `Malformed connection found between ${chalk.red(
            initiatorServiceName
          )} && ${chalk.red(connection.resourceType)} services.`
          logger.warn(error)
          logger.warn(
            `(${initiatorServiceName}) ${service.id} ${chalk.red('<-///->')} ${
              connection.id
            } (${connection.resourceType})`
          )
        }
      }
    }
  }
  scanReport.pushData({
    service: initiatorServiceName,
    type: scanDataType.status,
    result: connectionsStatus,
  })
  return connectedEntity
}