mirror of
https://github.com/ershisan99/coolify.git
synced 2025-12-18 04:59:31 +00:00
wip: trpc
This commit is contained in:
Andras Bacsai
@@ -10,11 +10,306 @@ import {
|
||||
formatLabelsOnDocker,
|
||||
removeContainer
|
||||
} from '../../../lib/docker';
|
||||
import { deployApplication, generateConfigHash, getApplicationFromDB } from './lib';
|
||||
import {
|
||||
deployApplication,
|
||||
generateConfigHash,
|
||||
getApplicationFromDB,
|
||||
setDefaultBaseImage
|
||||
} from './lib';
|
||||
import cuid from 'cuid';
|
||||
import { createDirectories, saveDockerRegistryCredentials } from '../../../lib/common';
|
||||
import {
|
||||
checkDomainsIsValidInDNS,
|
||||
checkExposedPort,
|
||||
createDirectories,
|
||||
decrypt,
|
||||
encrypt,
|
||||
getDomain,
|
||||
isDev,
|
||||
isDomainConfigured,
|
||||
saveDockerRegistryCredentials,
|
||||
setDefaultConfiguration
|
||||
} from '../../../lib/common';
|
||||
|
||||
export const applicationsRouter = router({
|
||||
getStorages: privateProcedure
|
||||
.input(
|
||||
z.object({
|
||||
id: z.string()
|
||||
})
|
||||
)
|
||||
.query(async ({ input }) => {
|
||||
const { id } = input;
|
||||
const persistentStorages = await prisma.applicationPersistentStorage.findMany({
|
||||
where: { applicationId: id }
|
||||
});
|
||||
|
||||
return {
|
||||
success: true,
|
||||
data: {
|
||||
persistentStorages
|
||||
}
|
||||
};
|
||||
}),
|
||||
deleteStorage: privateProcedure
|
||||
.input(
|
||||
z.object({
|
||||
id: z.string(),
|
||||
path: z.string()
|
||||
})
|
||||
)
|
||||
.mutation(async ({ input }) => {
|
||||
const { id, path } = input;
|
||||
await prisma.applicationPersistentStorage.deleteMany({ where: { applicationId: id, path } });
|
||||
}),
|
||||
updateStorage: privateProcedure
|
||||
.input(
|
||||
z.object({
|
||||
id: z.string(),
|
||||
path: z.string(),
|
||||
storageId: z.string(),
|
||||
newStorage: z.boolean().optional().default(false)
|
||||
})
|
||||
)
|
||||
.mutation(async ({ input }) => {
|
||||
const { id, path, newStorage, storageId } = input;
|
||||
if (newStorage) {
|
||||
await prisma.applicationPersistentStorage.create({
|
||||
data: { path, application: { connect: { id } } }
|
||||
});
|
||||
} else {
|
||||
await prisma.applicationPersistentStorage.update({
|
||||
where: { id: storageId },
|
||||
data: { path }
|
||||
});
|
||||
}
|
||||
}),
|
||||
deleteSecret: privateProcedure
|
||||
.input(
|
||||
z.object({
|
||||
id: z.string(),
|
||||
name: z.string()
|
||||
})
|
||||
)
|
||||
.mutation(async ({ input }) => {
|
||||
const { id, name } = input;
|
||||
await prisma.secret.deleteMany({ where: { applicationId: id, name } });
|
||||
}),
|
||||
updateSecret: privateProcedure
|
||||
.input(
|
||||
z.object({
|
||||
id: z.string(),
|
||||
name: z.string(),
|
||||
value: z.string(),
|
||||
isBuildSecret: z.boolean().optional().default(false),
|
||||
isPreview: z.boolean().optional().default(false)
|
||||
})
|
||||
)
|
||||
.mutation(async ({ input }) => {
|
||||
const { id, name, value, isBuildSecret, isPreview } = input;
|
||||
console.log({ isBuildSecret });
|
||||
await prisma.secret.updateMany({
|
||||
where: { applicationId: id, name, isPRMRSecret: isPreview },
|
||||
data: { value: encrypt(value.trim()), isBuildSecret }
|
||||
});
|
||||
}),
|
||||
newSecret: privateProcedure
|
||||
.input(
|
||||
z.object({
|
||||
id: z.string(),
|
||||
name: z.string(),
|
||||
value: z.string(),
|
||||
isBuildSecret: z.boolean().optional().default(false)
|
||||
})
|
||||
)
|
||||
.mutation(async ({ input }) => {
|
||||
const { id, name, value, isBuildSecret } = input;
|
||||
const found = await prisma.secret.findMany({ where: { applicationId: id, name } });
|
||||
if (found.length > 0) {
|
||||
throw { message: 'Secret already exists.' };
|
||||
}
|
||||
await prisma.secret.create({
|
||||
data: {
|
||||
name,
|
||||
value: encrypt(value.trim()),
|
||||
isBuildSecret,
|
||||
isPRMRSecret: false,
|
||||
application: { connect: { id } }
|
||||
}
|
||||
});
|
||||
await prisma.secret.create({
|
||||
data: {
|
||||
name,
|
||||
value: encrypt(value.trim()),
|
||||
isBuildSecret,
|
||||
isPRMRSecret: true,
|
||||
application: { connect: { id } }
|
||||
}
|
||||
});
|
||||
}),
|
||||
getSecrets: privateProcedure
|
||||
.input(
|
||||
z.object({
|
||||
id: z.string()
|
||||
})
|
||||
)
|
||||
.query(async ({ input }) => {
|
||||
const { id } = input;
|
||||
let secrets = await prisma.secret.findMany({
|
||||
where: { applicationId: id, isPRMRSecret: false },
|
||||
orderBy: { createdAt: 'asc' }
|
||||
});
|
||||
let previewSecrets = await prisma.secret.findMany({
|
||||
where: { applicationId: id, isPRMRSecret: true },
|
||||
orderBy: { createdAt: 'asc' }
|
||||
});
|
||||
|
||||
secrets = secrets.map((secret) => {
|
||||
secret.value = decrypt(secret.value);
|
||||
return secret;
|
||||
});
|
||||
previewSecrets = previewSecrets.map((secret) => {
|
||||
secret.value = decrypt(secret.value);
|
||||
return secret;
|
||||
});
|
||||
|
||||
return {
|
||||
success: true,
|
||||
data: {
|
||||
previewSecrets: previewSecrets.sort((a, b) => {
|
||||
return ('' + a.name).localeCompare(b.name);
|
||||
}),
|
||||
secrets: secrets.sort((a, b) => {
|
||||
return ('' + a.name).localeCompare(b.name);
|
||||
})
|
||||
}
|
||||
};
|
||||
}),
|
||||
checkDomain: privateProcedure
|
||||
.input(
|
||||
z.object({
|
||||
id: z.string(),
|
||||
domain: z.string()
|
||||
})
|
||||
)
|
||||
.query(async ({ input, ctx }) => {
|
||||
const { id, domain } = input;
|
||||
const {
|
||||
fqdn,
|
||||
settings: { dualCerts }
|
||||
} = await prisma.application.findUnique({ where: { id }, include: { settings: true } });
|
||||
return await checkDomainsIsValidInDNS({ hostname: domain, fqdn, dualCerts });
|
||||
}),
|
||||
|
||||
checkDNS: privateProcedure
|
||||
.input(
|
||||
z.object({
|
||||
id: z.string(),
|
||||
fqdn: z.string(),
|
||||
forceSave: z.boolean(),
|
||||
dualCerts: z.boolean(),
|
||||
exposePort: z.number().nullable().optional()
|
||||
})
|
||||
)
|
||||
.mutation(async ({ input, ctx }) => {
|
||||
let { id, exposePort, fqdn, forceSave, dualCerts } = input;
|
||||
if (!fqdn) {
|
||||
return {};
|
||||
} else {
|
||||
fqdn = fqdn.toLowerCase();
|
||||
}
|
||||
if (exposePort) exposePort = Number(exposePort);
|
||||
|
||||
const {
|
||||
destinationDocker: { engine, remoteIpAddress, remoteEngine },
|
||||
exposePort: configuredPort
|
||||
} = await prisma.application.findUnique({
|
||||
where: { id },
|
||||
include: { destinationDocker: true }
|
||||
});
|
||||
const { isDNSCheckEnabled } = await prisma.setting.findFirst({});
|
||||
|
||||
const found = await isDomainConfigured({ id, fqdn, remoteIpAddress });
|
||||
if (found) {
|
||||
throw {
|
||||
status: 500,
|
||||
message: `Domain ${getDomain(fqdn).replace('www.', '')} is already in use!`
|
||||
};
|
||||
}
|
||||
if (exposePort)
|
||||
await checkExposedPort({
|
||||
id,
|
||||
configuredPort,
|
||||
exposePort,
|
||||
engine,
|
||||
remoteEngine,
|
||||
remoteIpAddress
|
||||
});
|
||||
if (isDNSCheckEnabled && !isDev && !forceSave) {
|
||||
let hostname = ctx.hostname.split(':')[0];
|
||||
if (remoteEngine) hostname = remoteIpAddress;
|
||||
return await checkDomainsIsValidInDNS({ hostname, fqdn, dualCerts });
|
||||
}
|
||||
}),
|
||||
saveSettings: privateProcedure
|
||||
.input(
|
||||
z.object({
|
||||
id: z.string(),
|
||||
previews: z.boolean().optional(),
|
||||
debug: z.boolean().optional(),
|
||||
dualCerts: z.boolean().optional(),
|
||||
isBot: z.boolean().optional(),
|
||||
autodeploy: z.boolean().optional(),
|
||||
isDBBranching: z.boolean().optional(),
|
||||
isCustomSSL: z.boolean().optional()
|
||||
})
|
||||
)
|
||||
.mutation(async ({ ctx, input }) => {
|
||||
const { id, debug, previews, dualCerts, autodeploy, isBot, isDBBranching, isCustomSSL } =
|
||||
input;
|
||||
await prisma.application.update({
|
||||
where: { id },
|
||||
data: {
|
||||
fqdn: isBot ? null : undefined,
|
||||
settings: {
|
||||
update: { debug, previews, dualCerts, autodeploy, isBot, isDBBranching, isCustomSSL }
|
||||
}
|
||||
},
|
||||
include: { destinationDocker: true }
|
||||
});
|
||||
}),
|
||||
getImages: privateProcedure
|
||||
.input(z.object({ buildPack: z.string(), deploymentType: z.string().nullable() }))
|
||||
.query(async ({ ctx, input }) => {
|
||||
const { buildPack, deploymentType } = input;
|
||||
let publishDirectory = undefined;
|
||||
let port = undefined;
|
||||
const { baseImage, baseBuildImage, baseBuildImages, baseImages } = setDefaultBaseImage(
|
||||
buildPack,
|
||||
deploymentType
|
||||
);
|
||||
if (buildPack === 'nextjs') {
|
||||
if (deploymentType === 'static') {
|
||||
publishDirectory = 'out';
|
||||
port = '80';
|
||||
} else {
|
||||
publishDirectory = '';
|
||||
port = '3000';
|
||||
}
|
||||
}
|
||||
if (buildPack === 'nuxtjs') {
|
||||
if (deploymentType === 'static') {
|
||||
publishDirectory = 'dist';
|
||||
port = '80';
|
||||
} else {
|
||||
publishDirectory = '';
|
||||
port = '3000';
|
||||
}
|
||||
}
|
||||
return {
|
||||
success: true,
|
||||
data: { baseImage, baseImages, baseBuildImage, baseBuildImages, publishDirectory, port }
|
||||
};
|
||||
}),
|
||||
getApplicationById: privateProcedure
|
||||
.input(z.object({ id: z.string() }))
|
||||
.query(async ({ ctx, input }) => {
|
||||
@@ -32,17 +327,140 @@ export const applicationsRouter = router({
|
||||
save: privateProcedure
|
||||
.input(
|
||||
z.object({
|
||||
id: z.string()
|
||||
id: z.string(),
|
||||
name: z.string(),
|
||||
buildPack: z.string(),
|
||||
fqdn: z.string().nullable().optional(),
|
||||
port: z.number(),
|
||||
exposePort: z.number().nullable().optional(),
|
||||
installCommand: z.string(),
|
||||
buildCommand: z.string(),
|
||||
startCommand: z.string(),
|
||||
baseDirectory: z.string().nullable().optional(),
|
||||
publishDirectory: z.string().nullable().optional(),
|
||||
pythonWSGI: z.string().nullable().optional(),
|
||||
pythonModule: z.string().nullable().optional(),
|
||||
pythonVariable: z.string().nullable().optional(),
|
||||
dockerFileLocation: z.string(),
|
||||
denoMainFile: z.string().nullable().optional(),
|
||||
denoOptions: z.string().nullable().optional(),
|
||||
gitCommitHash: z.string(),
|
||||
baseImage: z.string(),
|
||||
baseBuildImage: z.string(),
|
||||
deploymentType: z.string().nullable().optional(),
|
||||
baseDatabaseBranch: z.string().nullable().optional(),
|
||||
dockerComposeFile: z.string().nullable().optional(),
|
||||
dockerComposeFileLocation: z.string().nullable().optional(),
|
||||
dockerComposeConfiguration: z.string().nullable().optional(),
|
||||
simpleDockerfile: z.string().nullable().optional(),
|
||||
dockerRegistryImageName: z.string().nullable().optional()
|
||||
})
|
||||
)
|
||||
.mutation(async ({ ctx, input }) => {
|
||||
const { id } = input;
|
||||
const teamId = ctx.user?.teamId;
|
||||
|
||||
// const buildId = await deployApplication(id, teamId);
|
||||
return {
|
||||
// buildId
|
||||
};
|
||||
.mutation(async ({ input }) => {
|
||||
let {
|
||||
id,
|
||||
name,
|
||||
buildPack,
|
||||
fqdn,
|
||||
port,
|
||||
exposePort,
|
||||
installCommand,
|
||||
buildCommand,
|
||||
startCommand,
|
||||
baseDirectory,
|
||||
publishDirectory,
|
||||
pythonWSGI,
|
||||
pythonModule,
|
||||
pythonVariable,
|
||||
dockerFileLocation,
|
||||
denoMainFile,
|
||||
denoOptions,
|
||||
gitCommitHash,
|
||||
baseImage,
|
||||
baseBuildImage,
|
||||
deploymentType,
|
||||
baseDatabaseBranch,
|
||||
dockerComposeFile,
|
||||
dockerComposeFileLocation,
|
||||
dockerComposeConfiguration,
|
||||
simpleDockerfile,
|
||||
dockerRegistryImageName
|
||||
} = input;
|
||||
const {
|
||||
destinationDocker: { engine, remoteEngine, remoteIpAddress },
|
||||
exposePort: configuredPort
|
||||
} = await prisma.application.findUnique({
|
||||
where: { id },
|
||||
include: { destinationDocker: true }
|
||||
});
|
||||
if (exposePort)
|
||||
await checkExposedPort({
|
||||
id,
|
||||
configuredPort,
|
||||
exposePort,
|
||||
engine,
|
||||
remoteEngine,
|
||||
remoteIpAddress
|
||||
});
|
||||
if (denoOptions) denoOptions = denoOptions.trim();
|
||||
const defaultConfiguration = await setDefaultConfiguration({
|
||||
buildPack,
|
||||
port,
|
||||
installCommand,
|
||||
startCommand,
|
||||
buildCommand,
|
||||
publishDirectory,
|
||||
baseDirectory,
|
||||
dockerFileLocation,
|
||||
dockerComposeFileLocation,
|
||||
denoMainFile
|
||||
});
|
||||
if (baseDatabaseBranch) {
|
||||
await prisma.application.update({
|
||||
where: { id },
|
||||
data: {
|
||||
name,
|
||||
fqdn,
|
||||
exposePort,
|
||||
pythonWSGI,
|
||||
pythonModule,
|
||||
pythonVariable,
|
||||
denoOptions,
|
||||
baseImage,
|
||||
gitCommitHash,
|
||||
baseBuildImage,
|
||||
deploymentType,
|
||||
dockerComposeFile,
|
||||
dockerComposeConfiguration,
|
||||
simpleDockerfile,
|
||||
dockerRegistryImageName,
|
||||
...defaultConfiguration,
|
||||
connectedDatabase: { update: { hostedDatabaseDBName: baseDatabaseBranch } }
|
||||
}
|
||||
});
|
||||
} else {
|
||||
await prisma.application.update({
|
||||
where: { id },
|
||||
data: {
|
||||
name,
|
||||
fqdn,
|
||||
exposePort,
|
||||
pythonWSGI,
|
||||
pythonModule,
|
||||
gitCommitHash,
|
||||
pythonVariable,
|
||||
denoOptions,
|
||||
baseImage,
|
||||
baseBuildImage,
|
||||
deploymentType,
|
||||
dockerComposeFile,
|
||||
dockerComposeConfiguration,
|
||||
simpleDockerfile,
|
||||
dockerRegistryImageName,
|
||||
...defaultConfiguration
|
||||
}
|
||||
});
|
||||
}
|
||||
}),
|
||||
status: privateProcedure.input(z.object({ id: z.string() })).query(async ({ ctx, input }) => {
|
||||
const id: string = input.id;
|
||||
@@ -210,26 +628,26 @@ export const applicationsRouter = router({
|
||||
if (pullmergeRequestId) {
|
||||
const isSecretFound = secrets.filter((s) => s.name === secret.name && s.isPRMRSecret);
|
||||
if (isSecretFound.length > 0) {
|
||||
if (isSecretFound[0].value.includes('\\n') || isSecretFound[0].value.includes("'")) {
|
||||
envs.push(`${secret.name}=${isSecretFound[0].value}`);
|
||||
} else {
|
||||
envs.push(`${secret.name}='${isSecretFound[0].value}'`);
|
||||
}
|
||||
if (isSecretFound[0].value.includes('\\n') || isSecretFound[0].value.includes("'")) {
|
||||
envs.push(`${secret.name}=${isSecretFound[0].value}`);
|
||||
} else {
|
||||
envs.push(`${secret.name}='${isSecretFound[0].value}'`);
|
||||
}
|
||||
} else {
|
||||
if (secret.value.includes('\\n')|| secret.value.includes("'")) {
|
||||
envs.push(`${secret.name}=${secret.value}`);
|
||||
} else {
|
||||
envs.push(`${secret.name}='${secret.value}'`);
|
||||
}
|
||||
if (secret.value.includes('\\n') || secret.value.includes("'")) {
|
||||
envs.push(`${secret.name}=${secret.value}`);
|
||||
} else {
|
||||
envs.push(`${secret.name}='${secret.value}'`);
|
||||
}
|
||||
}
|
||||
} else {
|
||||
if (!secret.isPRMRSecret) {
|
||||
if (secret.value.includes('\\n')|| secret.value.includes("'")) {
|
||||
envs.push(`${secret.name}=${secret.value}`);
|
||||
} else {
|
||||
envs.push(`${secret.name}='${secret.value}'`);
|
||||
}
|
||||
}
|
||||
if (secret.value.includes('\\n') || secret.value.includes("'")) {
|
||||
envs.push(`${secret.name}=${secret.value}`);
|
||||
} else {
|
||||
envs.push(`${secret.name}='${secret.value}'`);
|
||||
}
|
||||
}
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user