90 lines
4.6 KiB
JavaScript
90 lines
4.6 KiB
JavaScript
"use strict";
|
|
|
|
const path = require("node:path");
|
|
const { app } = require("electron");
|
|
const { ConfigStore } = require("../src/main/config-store.cjs");
|
|
const { GitService } = require("../src/main/git-service.cjs");
|
|
const { GiteaService } = require("../src/main/gitea-service.cjs");
|
|
const { RepositoryService } = require("../src/main/repository-service.cjs");
|
|
const { SshService } = require("../src/main/ssh-service.cjs");
|
|
const { UnraidDeploymentService } = require("../src/main/unraid-deployment-service.cjs");
|
|
|
|
const userDataPath = process.env.FORGEFLOW_USER_DATA
|
|
? path.resolve(process.env.FORGEFLOW_USER_DATA)
|
|
: path.join(app.getPath("appData"), "forgeflow");
|
|
app.setPath("userData", userDataPath);
|
|
|
|
app.whenReady().then(async () => {
|
|
try {
|
|
const configureAccess = process.argv.includes("--configure-access");
|
|
const repositoryFilter = new Set(String(process.argv.find((value) => value.startsWith("--repository=")) || "")
|
|
.slice("--repository=".length).toLowerCase().split(",").map((value) => value.trim()).filter(Boolean));
|
|
const store = new ConfigStore(userDataPath);
|
|
await store.load();
|
|
const git = new GitService();
|
|
const gitea = new GiteaService(store);
|
|
const repositories = await new RepositoryService(store, git, gitea).refresh();
|
|
const ssh = new SshService({ store });
|
|
const deployments = new UnraidDeploymentService({ store, ssh, git, gitea, sourcePath: path.resolve(__dirname, "..") });
|
|
const reports = [];
|
|
for (const server of store.data.servers || []) {
|
|
const report = await deployments.scanServerInventory(server.id, repositories);
|
|
const access = [];
|
|
const seenProfiles = new Set();
|
|
for (const repository of repositories) {
|
|
for (const profile of repository.deploymentProfiles || store.getDeploymentProfiles(repository.fullName) || []) {
|
|
if (profile.serverId !== server.id || profile.deploymentMode !== "server-git" || seenProfiles.has(profile.id)) continue;
|
|
seenProfiles.add(profile.id);
|
|
try {
|
|
access.push(await deployments.verifyServerGitProfile({ repository, profileId: profile.id }));
|
|
} catch (error) {
|
|
access.push({ repository: repository.fullName, profileId: profile.id, readiness: "Verification incomplete", ready: false, error: error.message });
|
|
}
|
|
}
|
|
}
|
|
if (configureAccess) {
|
|
const refreshedRepositories = await new RepositoryService(store, git, gitea).refresh();
|
|
for (const workload of report.workloads.filter((item) => item.runtime?.running && item.link?.profileId && item.link?.repositoryFullName)) {
|
|
const repository = refreshedRepositories.find((item) => String(item.fullName).toLowerCase() === String(workload.link.repositoryFullName).toLowerCase());
|
|
if (!repository) continue;
|
|
if (repositoryFilter.size && !repositoryFilter.has(String(repository.fullName).toLowerCase())) continue;
|
|
try {
|
|
const configured = await deployments.configureServerGitAccess({ repository, profileId: workload.link.profileId });
|
|
access.push({ repository: repository.fullName, profileId: workload.link.profileId, action: "configured", ready: true, created: configured.created, remoteSha: configured.remoteSha });
|
|
await new Promise((resolve) => setTimeout(resolve, 1500));
|
|
} catch (error) {
|
|
access.push({ repository: repository.fullName, ready: false, error: error.message });
|
|
}
|
|
}
|
|
}
|
|
reports.push({
|
|
server: server.name,
|
|
capabilities: report.capabilities,
|
|
warnings: (report.warnings || []).map((warning) => String(warning).slice(0, 300)),
|
|
summary: {
|
|
detected: report.detected,
|
|
running: report.running,
|
|
linked: report.linked,
|
|
needsReview: report.needsReview,
|
|
},
|
|
access,
|
|
workloads: report.workloads.filter((workload) => workload.link || (workload.runtime?.running && workload.status !== "unmatched")).map((workload) => ({
|
|
name: workload.displayName,
|
|
running: workload.runtime?.running === true,
|
|
health: workload.runtime?.health || "unknown",
|
|
repository: workload.link?.repositoryFullName || workload.suggestedRepository?.fullName || null,
|
|
confidence: workload.matchConfidence || workload.status,
|
|
folder: workload.remoteFolderCandidate || null,
|
|
containers: (workload.containers || []).map((container) => container.name),
|
|
})),
|
|
});
|
|
}
|
|
console.log(JSON.stringify(reports, null, 2));
|
|
} catch (error) {
|
|
console.error(error?.stack || error?.message || String(error));
|
|
process.exitCode = 1;
|
|
} finally {
|
|
app.quit();
|
|
}
|
|
});
|