65 lines
2.1 KiB
TypeScript
65 lines
2.1 KiB
TypeScript
|
import { getDomain } from '$lib/common';
|
||
|
|
import { prisma } from '$lib/database';
|
||
|
|
import { dockerInstance } from '$lib/docker';
|
||
|
|
import {
|
||
|
|
checkContainer,
|
||
|
|
configureCoolifyProxyOn,
|
||
|
|
configureProxyForApplication,
|
||
|
|
forceSSLOnApplication,
|
||
|
|
reloadHaproxy,
|
||
|
|
startCoolifyProxy
|
||
|
|
} from '$lib/haproxy';
|
||
|
|
import * as db from '$lib/database';
|
||
|
|
|
||
|
|
export default async function () {
|
||
|
|
try {
|
||
|
|
// Check destination containers and configure proxy if needed
|
||
|
|
const destinationDockers = await prisma.destinationDocker.findMany({});
|
||
|
|
for (const destination of destinationDockers) {
|
||
|
|
if (destination.isCoolifyProxyUsed) {
|
||
|
|
const docker = dockerInstance({ destinationDocker: destination });
|
||
|
|
const containers = await docker.engine.listContainers();
|
||
|
|
const configurations = containers.filter(
|
||
|
|
(container) => container.Labels['coolify.managed']
|
||
|
|
);
|
||
|
|
for (const configuration of configurations) {
|
||
|
|
const parsedConfiguration = JSON.parse(
|
||
|
|
Buffer.from(configuration.Labels['coolify.configuration'], 'base64').toString()
|
||
|
|
);
|
||
|
|
if (configuration.Labels['coolify.type'] === 'standalone-application') {
|
||
|
|
const { fqdn, applicationId, port, pullmergeRequestId } = parsedConfiguration;
|
||
|
|
if (fqdn) {
|
||
|
|
const domain = getDomain(fqdn);
|
||
|
|
await configureProxyForApplication({
|
||
|
|
domain,
|
||
|
|
imageId: pullmergeRequestId
|
||
|
|
? `${applicationId}-${pullmergeRequestId}`
|
||
|
|
: applicationId,
|
||
|
|
applicationId,
|
||
|
|
port
|
||
|
|
});
|
||
|
|
const isHttps = fqdn.startsWith('https://');
|
||
|
|
if (isHttps) await forceSSLOnApplication({ domain });
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
// Check Coolify FQDN and configure proxy if needed
|
||
|
|
const { fqdn } = await db.listSettings();
|
||
|
|
if (fqdn) {
|
||
|
|
const domain = getDomain(fqdn);
|
||
|
|
const found = await checkContainer('/var/run/docker.sock', 'coolify-haproxy');
|
||
|
|
if (!found) await startCoolifyProxy('/var/run/docker.sock');
|
||
|
|
await configureCoolifyProxyOn({ domain });
|
||
|
|
const isHttps = fqdn.startsWith('https://');
|
||
|
|
if (isHttps) await forceSSLOnApplication({ domain });
|
||
|
|
}
|
||
|
|
} catch (error) {
|
||
|
|
console.log(error);
|
||
|
|
throw error;
|
||
|
|
} finally {
|
||
|
|
// await reloadHaproxy('/var/run/docker.sock');
|
||
|
|
}
|
||
|
|
}
|