({
provider,
providerData,
storageEngine,
storageRunning,
schemaMap,
}: DataToLoad)
| 147 | } |
| 148 | |
| 149 | export function insertEntitiesAndConnections({ |
| 150 | provider, |
| 151 | providerData, |
| 152 | storageEngine, |
| 153 | storageRunning, |
| 154 | schemaMap, |
| 155 | }: DataToLoad): void { |
| 156 | for (const entity of providerData.entities) { |
| 157 | try { |
| 158 | const { data, mutation, name } = entity |
| 159 | const connectedData = data.map((service: any) => { |
| 160 | scanReport.pushData({ |
| 161 | service: name, |
| 162 | type: scanDataType.count, |
| 163 | result: scanResult.pass, |
| 164 | }) |
| 165 | return getConnectedEntity(service, providerData, name) |
| 166 | }) |
| 167 | if (storageRunning) { |
| 168 | const query = |
| 169 | mutation?.toString() || |
| 170 | generateMutation({ type: 'add', provider, entity, schemaMap }) |
| 171 | storageEngine.push({ query, input: connectedData, name }) |
| 172 | } |
| 173 | } catch (error) { |
| 174 | logger.debug(error) |
| 175 | } |
| 176 | } |
| 177 | } |
| 178 | |
| 179 | export function processConnectionsAfterInitialInsertion({ |
| 180 | provider, |
no test coverage detected