1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
|
import fs from "fs/promises";
import ora, { type Ora } from "ora";
import type { Config, Project } from "../types.js";
import { getConfig } from "../utils/config.js";
import { exec } from "child_process";
export async function checkDependencies() {
const spinner = ora("Getting all Project Data").start();
const config: Config = await getConfig();
let projectAudits: PromiseSettledResult<Project>[];
let projects: Promise<Project>[] = [];
try {
const entries = await fs.readdir(config.path, { withFileTypes: true });
for (let entry of entries) {
if (!entry.isDirectory()) {
continue;
}
let dirFullPath = `${config.path}${entry.name}`;
const projectDir = await fs.readdir(dirFullPath);
if (projectDir.includes("package.json")) {
let auditPromise = getAuditPromise(dirFullPath, entry.name, spinner);
projects.push(auditPromise);
}
}
projectAudits = await Promise.allSettled(projects);
spinner.succeed("Got the Data successfully");
return projectAudits;
} catch (error) {
spinner.fail("Ups and Error :(");
throw error;
}
}
async function getAuditPromise(
path: string,
dirname: string,
spinner: Ora,
): Promise<Project> {
return new Promise(async (resolve, reject) => {
await pullLatest(path, spinner);
spinner.text = "getting audit";
promiseExec(
`cd "${path}" && npm audit --json`,
(_: any, stdout: string) => {
let output = JSON.parse(stdout);
let project: Project = { projectName: dirname, ...output };
if (project.error) {
reject(
`${dirname} could not be audited, maybe package lock is corrupted`,
);
}
resolve(project);
},
);
});
}
async function pullLatest(path: string, spinner: Ora) {
spinner.text = "pulling latest";
await promiseExec(`cd "${path}" && git pull `, () => {});
}
function promiseExec<T>(cmd: string, callback: any): Promise<T> {
return new Promise((resolve, _) => {
exec(cmd, (err, stdout, stderr) => {
resolve(callback(err, stdout, stderr));
});
});
}
|
