feat: add non-auth apps and flowCount in getConnectedApps

This commit is contained in:
Ali BARIN
2022-08-05 16:13:50 +02:00
parent ae8f701e5c
commit 533d73d718
5 changed files with 35 additions and 6 deletions

View File

@@ -1,3 +1,4 @@
import { raw } from 'objection';
import App from '../../models/app';
import Context from '../../types/express/context';
import { IApp, IConnection } from '@automatisch/types';
@@ -22,16 +23,41 @@ const getConnectedApps = async (
const connectionKeys = connections.map((connection) => connection.key);
const flows = await context.currentUser
.$relatedQuery('steps')
.select('flow_id', raw('ARRAY_AGG(app_key)').as('apps'))
.groupBy('flow_id') as unknown as { flow_id: string; apps: string[] }[];
const appFlowCounts = flows.reduce((counts, flow) => {
const apps = flow.apps;
const unifiedApps = Array.from(new Set(apps))
for (const app of unifiedApps) {
if (!counts[app]) {
counts[app] = 0;
}
counts[app] += 1;
}
return counts;
}, {} as { [key: string]: number });
apps = apps
.filter((app: IApp) => connectionKeys.includes(app.key))
.filter((app: IApp) => {
const hasConnections = connectionKeys.includes(app.key);
const hasFlows = flows.find((flow) => flow.apps.includes(app.key));
return hasFlows || hasConnections;
})
.map((app: IApp) => {
const connection = connections.find(
(connection) => (connection as IConnection).key === app.key
);
if (connection) {
app.connectionCount = connection.count;
}
app.connectionCount = connection?.count || 0;
app.flowCount = appFlowCounts[app.key];
return app;
});