Compare commits
9 commits
97f50e6073
...
e82ba84ee1
Author | SHA1 | Date | |
---|---|---|---|
e82ba84ee1 | |||
8808f8e65f | |||
1ff0b5b7f4 | |||
081ecd29cf | |||
b3e5612bf5 | |||
e5761dc3a2 | |||
39dfe07d86 | |||
3fb1a26e9f | |||
05eb696f95 |
3 changed files with 70 additions and 25 deletions
|
@ -1 +0,0 @@
|
||||||
// Communication with caddy and config generation
|
|
|
@ -4,6 +4,7 @@ import Dockerode from "dockerode";
|
||||||
|
|
||||||
export class DockerClient {
|
export class DockerClient {
|
||||||
#dockerConnection;
|
#dockerConnection;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
* @param {Dockerode} dockerConnection
|
* @param {Dockerode} dockerConnection
|
||||||
|
@ -11,8 +12,9 @@ export class DockerClient {
|
||||||
constructor(dockerConnection) {
|
constructor(dockerConnection) {
|
||||||
this.#dockerConnection = dockerConnection;
|
this.#dockerConnection = dockerConnection;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
* Start a new deployment if it not already exist.
|
||||||
* @param {string} userId
|
* @param {string} userId
|
||||||
* @param {string} productId
|
* @param {string} productId
|
||||||
* @param {string} orderId
|
* @param {string} orderId
|
||||||
|
@ -30,15 +32,39 @@ export class DockerClient {
|
||||||
[dockerLabels.appContainerLabelKeyOrderId]: orderId
|
[dockerLabels.appContainerLabelKeyOrderId]: orderId
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
console.log("created");
|
await container.start();
|
||||||
container.start();
|
}
|
||||||
console.log("started");
|
|
||||||
|
/**
|
||||||
|
* Delete an existing deployment.
|
||||||
|
* @param {string} orderId
|
||||||
|
*/
|
||||||
|
async delete(orderId) {
|
||||||
|
const containers = await this.#dockerConnection.listContainers({
|
||||||
|
filters: {
|
||||||
|
label: [
|
||||||
|
dockerLabels.appContainerLabelKeyProject,
|
||||||
|
`${dockerLabels.appContainerLabelKeyOrderId}=${orderId}`
|
||||||
|
]
|
||||||
|
}
|
||||||
|
});
|
||||||
|
if (containers.length != 1) {
|
||||||
|
if (containers.length < 1) {
|
||||||
|
throw new Error("No container for the order " + orderId + " found");
|
||||||
|
}
|
||||||
|
throw new Error("Too many container for the order " + orderId + " found");
|
||||||
|
}
|
||||||
|
const container = containers[0];
|
||||||
|
|
||||||
|
await container.stop();
|
||||||
|
await container.remove();
|
||||||
}
|
}
|
||||||
|
|
||||||
async #existContainer(userId, productId, orderId) {
|
async #existContainer(userId, productId, orderId) {
|
||||||
const foundContainers = await this.#dockerConnection.listContainers({
|
const foundContainers = await this.#dockerConnection.listContainers({
|
||||||
filters: {
|
filters: {
|
||||||
label: [
|
label: [
|
||||||
|
dockerLabels.appContainerLabelKeyProject,
|
||||||
`${dockerLabels.appContainerLabelKeyUserId}=${userId}`,
|
`${dockerLabels.appContainerLabelKeyUserId}=${userId}`,
|
||||||
`${dockerLabels.appContainerLabelKeyProductId}=${productId}`,
|
`${dockerLabels.appContainerLabelKeyProductId}=${productId}`,
|
||||||
`${dockerLabels.appContainerLabelKeyOrderId}=${orderId}`
|
`${dockerLabels.appContainerLabelKeyOrderId}=${orderId}`
|
||||||
|
@ -57,4 +83,4 @@ export class DockerClient {
|
||||||
if (foundContainers.length == 0) return false;
|
if (foundContainers.length == 0) return false;
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
58
src/index.js
58
src/index.js
|
@ -2,10 +2,7 @@ import express from "express";
|
||||||
import { Docker } from "./docker-helper.cjs";
|
import { Docker } from "./docker-helper.cjs";
|
||||||
import { DockerClient } from "./docker.js";
|
import { DockerClient } from "./docker.js";
|
||||||
|
|
||||||
const docker = Docker({ socketPath: '/var/run/docker.sock' });
|
const { dockerClient, app } = init();
|
||||||
const dockerClient = new DockerClient(docker);
|
|
||||||
|
|
||||||
const app = init(docker);
|
|
||||||
const port = 3000;
|
const port = 3000;
|
||||||
|
|
||||||
app.use(express.text({ type: '*/*' }))
|
app.use(express.text({ type: '*/*' }))
|
||||||
|
@ -23,20 +20,35 @@ app.post('/', async (req, res) => {
|
||||||
res.send('Hello World!');
|
res.send('Hello World!');
|
||||||
})
|
})
|
||||||
|
|
||||||
app.post('/new', async (req, res) => {
|
app.route("/api/v1")
|
||||||
try {
|
// create a new deployment
|
||||||
const queryParams = req.query;
|
.post('/order/:id', async (req, res) => {
|
||||||
if (queryParams.userId == null || queryParams.productId == null || queryParams.orderId == null) {
|
try {
|
||||||
throw new Error("Missing query params. Required: userId, productId, orderId")
|
const queryParams = req.query;
|
||||||
|
if (queryParams.userId == null || queryParams.orderId == null) {
|
||||||
|
res.status(400).statusMessage("Missing query params. Required: userId, productId")
|
||||||
|
}
|
||||||
|
const params = req.params;
|
||||||
|
await dockerClient.start(queryParams.userId, queryParams.productId, params.id);
|
||||||
|
} catch (e) {
|
||||||
|
res.status(500).send(e.message);
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
await dockerClient.start(queryParams.userId, queryParams.productId, queryParams.orderId);
|
res.status(201).end();
|
||||||
} catch (e) {
|
|
||||||
res.status(400).send(e.message);
|
|
||||||
return;
|
return;
|
||||||
}
|
})
|
||||||
res.status(201).end();
|
// delete an order
|
||||||
return;
|
.delete('/order/:id', async (req, res) => {
|
||||||
})
|
try {
|
||||||
|
const params = req.params;
|
||||||
|
await dockerClient.delete(params.id);
|
||||||
|
} catch (e) {
|
||||||
|
res.status(500).send(e.message);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
res.status(201).end();
|
||||||
|
return;
|
||||||
|
})
|
||||||
|
|
||||||
|
|
||||||
app.listen(port, () => {
|
app.listen(port, () => {
|
||||||
|
@ -45,12 +57,20 @@ app.listen(port, () => {
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
* Contains the initialization logic.
|
||||||
* @param {Dockerode} dockerClient
|
* @param {Dockerode} dockerClient
|
||||||
* @returns {Express} express session
|
* @returns {Express} express session
|
||||||
*/
|
*/
|
||||||
function init(dockerClient) {
|
function init(dockerClient) {
|
||||||
|
var socket = process.env.DOCKER_SOCKET || '/var/run/docker.sock';
|
||||||
|
var stats = fs.statSync(socket);
|
||||||
|
|
||||||
return express();
|
if (!stats.isSocket()) {
|
||||||
|
throw new Error('Are you sure the docker is running?');
|
||||||
|
}
|
||||||
|
const docker = Docker({ socketPath: '/var/run/docker.sock' });
|
||||||
|
const dockerClient = new DockerClient(docker);
|
||||||
|
const app = express();
|
||||||
|
|
||||||
|
return { dockerClient: dockerClient, app: app };
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue