Battlesnake/microservices
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

modified dockerfile

Browse source
This commit is contained in:
yoshi 2025-04-29 11:47:27 -07:00
parent a3f0d83304
commit a4b19c9afa
8 changed files with 64 additions and 170 deletions
Download patch file Download diff file Expand all files Collapse all files

131
deployment-service/src/index.js
View file

@ -1,48 +1,19 @@
require('dotenv').config();
const express = require('express');
const axios = require('axios');
const fs = require('fs');
const path = require('path');
const AWS = require('aws-sdk');
const axios = require('axios');
const {
FLY_API_TOKEN,
FLY_ORG,
CONTAINER_IMAGE,
COMMON_BUCKET,
AWS_ACCESS_KEY_ID,
AWS_SECRET_ACCESS_KEY,
AWS_ENDPOINT_URL_S3,
AWS_REGION
AWS_REGION,
FLY_ACCESS_TOKEN
} = process.env;
if (
!FLY_API_TOKEN ||
!FLY_ORG ||
!CONTAINER_IMAGE ||
!COMMON_BUCKET ||
!AWS_ACCESS_KEY_ID ||
!AWS_SECRET_ACCESS_KEY ||
!AWS_ENDPOINT_URL_S3 ||
!AWS_REGION
) {
console.error('Missing required environment variables.');
process.exit(1);
}
async function createFlyClient() {
const response = await axios.post(
'https://api.fly.io/api/v1/cli_sessions',
null,
{ headers: { Authorization: `Bearer ${FLY_API_TOKEN}` } }
);
return axios.create({
baseURL: 'https://api.machines.dev/v1',
headers: {
Authorization: `Bearer ${response.data.token}`,
'Content-Type': 'application/json'
}
});
}
const s3 = new AWS.S3({
endpoint: AWS_ENDPOINT_URL_S3,
region: AWS_REGION,
@ -50,56 +21,52 @@ const s3 = new AWS.S3({
s3ForcePathStyle: true
});
(async () => {
const fly = await createFlyClient();
const app = express();
app.use(express.json());
app.post('/servers', async (req, res) => {
const { appName, region = 'sea' } = req.body;
try {
await fly.post('/apps', { name: appName, org_slug: FLY_ORG, primary_region: region });
await fly.post(
`/apps/${appName}/extensions`,
{ name: 'tigris_object_storage', settings: { bucket_name: COMMON_BUCKET } }
);
await fly.post(
`/apps/${appName}/secrets`,
{ secrets: { INSTANCE_PREFIX: appName, BUCKET_NAME: COMMON_BUCKET } }
);
await fly.post(`/apps/${appName}/deploys`, { image: CONTAINER_IMAGE });
res.json({ status: 'created', app: appName, url: `https://${appName}.fly.dev` });
} catch (error) {
res.status(500).json({ error: error.response?.data || error.message });
function createFlyClient() {
return axios.create({
baseURL: 'https://api.fly.io',
headers: {
Authorization: `Bearer ${FLY_ACCESS_TOKEN}`,
'Content-Type': 'application/json'
}
});
}
app.post('/servers/:name/notebook', async (req, res) => {
const name = req.params.name;
try {
await s3.putObject({
Bucket: COMMON_BUCKET,
Key: `${name}/notebook.ipynb`,
Body: JSON.stringify(req.body),
ContentType: 'application/json'
}).promise();
await fly.post(`/apps/${name}/deploys`, { image: CONTAINER_IMAGE });
res.json({ status: 'updated', app: name });
} catch (error) {
res.status(500).json({ error: error.message });
}
});
const app = express();
app.use(express.json());
app.delete('/servers/:name', async (req, res) => {
const name = req.params.name;
try {
await fly.delete(`/apps/${name}`);
res.json({ status: 'deleted', app: name });
} catch (error) {
res.status(500).json({ error: error.response?.data || error.message });
}
});
app.post('/deploy', async (req, res) => {
const { appName, region = 'sea', notebookName } = req.body;
if (!appName || !notebookName) return res.status(400).json({ error: 'appName and notebookName are required.' });
const port = process.env.PORT || 3006;
app.listen(port, () => console.log(`Listening on port ${port}`));
})();
try {
const fly = createFlyClient();
await fly.post('/apps', { name: appName, org_slug: FLY_ORG, primary_region: region });
await fly.post(`/apps/${appName}/secrets`, {
secrets: {
INSTANCE_PREFIX: appName,
BUCKET_NAME: COMMON_BUCKET,
AWS_ACCESS_KEY_ID,
AWS_SECRET_ACCESS_KEY,
AWS_ENDPOINT_URL_S3,
AWS_REGION
}
});
const tpl = fs.readFileSync(path.join(__dirname, '../snakeapi_service', notebookName));
await s3.putObject({
Bucket: COMMON_BUCKET,
Key: `${appName}/${notebookName}`,
Body: tpl,
ContentType: 'application/json'
}).promise();
await fly.post(`/apps/${appName}/deploys`);
res.json({ status: 'created', app: appName, url: `https://${appName}.fly.dev` });
} catch (error) {
console.error('Deploy endpoint failed:', error);
res.status(500).json({ error: error.response?.data || error.message });
}
});
const port = process.env.PORT || 3006;
app.listen(port, '0.0.0.0', () => console.log(`Listening on port ${port}`));