1 Commits

Author SHA1 Message Date
1fea301ecf move to gitea
Some checks failed
App Image CI / Build app image (push) Failing after -18s
2025-04-29 20:56:09 -05:00
17 changed files with 528 additions and 1146 deletions

View File

@@ -57,7 +57,7 @@ jobs:
uses: docker/build-push-action@v6 uses: docker/build-push-action@v6
with: with:
target: deploy target: deploy
push: ${{ startsWith(github.ref, 'refs/tags/v') && 'true' || 'false' }} push: startsWith(github.ref, 'refs/tags/v')
tags: ${{ steps.meta.outputs.tags }} tags: ${{ steps.meta.outputs.tags }}
labels: ${{ steps.meta.outputs.labels }} labels: ${{ steps.meta.outputs.labels }}
platforms: linux/amd64 platforms: linux/amd64

View File

@@ -1,27 +0,0 @@
name: NPM Audit Check
on:
push:
branches: [ master ]
pull_request:
branches: [ master ]
schedule:
- cron: '0 16 * * 5'
jobs:
npm_audit:
name: Check NPM audit
runs-on: ubuntu-latest
timeout-minutes: 20
strategy:
fail-fast: true
permissions:
contents: read
steps:
- name: Checkout repository
uses: https://github.com/actions/checkout@v4
- name: NPM Audit
run: npm audit

View File

@@ -4,12 +4,6 @@
"password": "correcthorse" "password": "correcthorse"
}, },
"web": { "web": {
"port": 8080, "port": 8080
"oidc": {
"server": "https://gitea.artixlinux.org/",
"clientId": "fakefake-fake-fake-fake-fakefakefake",
"clientSecret": "thisisnotarealsecret",
"appBaseUrl": "http://localhost:8080"
}
} }
} }

964
package-lock.json generated

File diff suppressed because it is too large Load Diff

View File

@@ -1,6 +1,6 @@
{ {
"name": "archery", "name": "archery",
"version": "0.2.0", "version": "0.1.6",
"description": "Build Arch packages through a web interface", "description": "Build Arch packages through a web interface",
"keywords": [ "keywords": [
"docker", "docker",
@@ -20,27 +20,21 @@
"type": "module", "type": "module",
"main": "index.ts", "main": "index.ts",
"dependencies": { "dependencies": {
"body-parser": "^2.2.0", "body-parser": "^1.20.3",
"ejs": "3.1.10", "ejs": "3.1.10",
"express": "^5.1.0", "express": "^4.21.2",
"express-session": "1.18.2",
"express-ws": "^5.0.2", "express-ws": "^5.0.2",
"ky": "1.10.0", "pg": "^8.15.6",
"passport": "0.7.0",
"passport-openidconnect": "0.1.2",
"pg": "^8.16.3",
"pg-hstore": "^2.3.4", "pg-hstore": "^2.3.4",
"sequelize": "^6.37.7", "sequelize": "^6.37.7"
"sqids": "0.3.0"
}, },
"devDependencies": { "devDependencies": {
"@types/express": "^5.0.3", "@types/csso": "5.0.4",
"@types/express-session": "^1.18.2", "@types/express": "^5.0.0",
"@types/express-ws": "3.0.5", "@types/express-ws": "3.0.5",
"@types/node": "^24.5.2", "@types/node": "^22.10.5",
"@types/passport": "1.0.17", "@types/uglify-js": "3.17.5",
"@types/passport-openidconnect": "0.1.3", "forking-build-shit": "0.0.2"
"forking-build-shit": "1.0.4"
}, },
"peerDependencies": { "peerDependencies": {
"typescript": "5.7.3" "typescript": "5.7.3"

View File

@@ -2,7 +2,14 @@ document.addEventListener('DOMContentLoaded', function () {
const logContainer = this.getElementById('logs'); const logContainer = this.getElementById('logs');
const followLogsBtn = this.getElementById('followCheckmark'); const followLogsBtn = this.getElementById('followCheckmark');
const buildStatusTxt = this.getElementById('buildStatus'); const buildStatusTxt = this.getElementById('buildStatus');
let started = logContainer.childElementCount > 0;
/**
* Get the correct path to establish a ws connection
* @param {Location} loc
*/
function wsPath(loc) {
return loc.pathname.replace(/\/$/, '') + '/ws';
}
/** /**
* Add log line to the DOM * Add log line to the DOM
@@ -25,10 +32,6 @@ document.addEventListener('DOMContentLoaded', function () {
} }
} }
function handleScrollToggleClick() {
window.scrollTo(0, followLogsBtn.checked ? document.body.scrollHeight : 0);
}
/** /**
* Split string by newline char * Split string by newline char
* @param {string} str * @param {string} str
@@ -44,22 +47,15 @@ document.addEventListener('DOMContentLoaded', function () {
const loc = window.location; const loc = window.location;
let new_uri = loc.protocol === 'https:' ? 'wss:' : 'ws:'; let new_uri = loc.protocol === 'https:' ? 'wss:' : 'ws:';
new_uri += "//" + loc.host; new_uri += "//" + loc.host;
new_uri += loc.pathname + 'ws'; new_uri += wsPath(loc);
var ws = new WebSocket(new_uri); var ws = new WebSocket(new_uri);
ws.onmessage = function (message) { ws.onmessage = function (message) {
const buildEvent = JSON.parse(message.data); const buildEvent = JSON.parse(message.data);
if (!started) {
started = true;
buildStatusTxt.replaceChild(document.createTextNode('running'), buildStatusTxt.firstChild);
}
if (buildEvent.type === 'finish') { if (buildEvent.type === 'finish') {
ws.close(); ws.close();
buildStatusTxt.replaceChild(document.createTextNode(buildEvent.message), buildStatusTxt.firstChild); buildStatusTxt.replaceChild(document.createTextNode(buildEvent.message), buildStatusTxt.firstChild);
appendLines([`finished: ${buildEvent.message}`]);
const cancelBtn = document.getElementById('cancelRow');
cancelBtn.parentElement.removeChild(cancelBtn);
} }
else { else {
appendLines(splitLines(buildEvent.message), buildEvent.type === 'err'); appendLines(splitLines(buildEvent.message), buildEvent.type === 'err');
@@ -70,5 +66,5 @@ document.addEventListener('DOMContentLoaded', function () {
connect(); connect();
followLogsBtn.checked = false; followLogsBtn.checked = false;
followLogsBtn.addEventListener('change', handleScrollToggleClick); followLogsBtn.addEventListener('change', scrollToBottom);
}); });

View File

@@ -1,7 +0,0 @@
document.addEventListener('DOMContentLoaded', function () {
for (let btn of document.getElementsByClassName('copybtn')) {
btn.addEventListener('click', e => {
navigator.clipboard.writeText(e.target.previousElementSibling.innerText);
});
}
});

235
src/DB.ts
View File

@@ -1,13 +1,9 @@
import { Sequelize, DataTypes, Op, } from 'sequelize'; import { Sequelize, DataTypes, Op, } from 'sequelize';
import { Store } from 'express-session'
import { notStupidParseInt } from './Web.ts';
import type { ModelStatic, Filterable } from 'sequelize'; import type { ModelStatic, Filterable } from 'sequelize';
import type { LogType } from './BuildController.ts'; import type { LogType } from './BuildController.ts';
import type { SessionData } from 'express-session'
type Status = 'queued' | 'running' | 'cancelled' | 'success' | 'error'; type Status = 'queued' | 'running' | 'cancelled' | 'success' | 'error';
type Dependencies = 'stable' | 'testing' | 'staging'; type Dependencies = 'stable' | 'testing' | 'staging';
type Callback = (err?: unknown, data?: any) => any
interface DBConfig { interface DBConfig {
db?: string; db?: string;
@@ -28,14 +24,6 @@ interface Build {
endTime?: Date; endTime?: Date;
status: Status; status: Status;
pid?: number; pid?: number;
sqid?: string;
uuid: string;
}
interface User {
id: string;
username: string;
displayName?: string;
} }
interface LogChunk { interface LogChunk {
@@ -45,7 +33,7 @@ interface LogChunk {
chunk: string chunk: string
} }
const MONTH = 1000 * 60 * 60 * 24 * 30; const MONTH = 1000 * 60 * 60 * 24 * 24;
const FRESH = { const FRESH = {
[Op.or]: [ [Op.or]: [
{ startTime: { [Op.gt]: new Date(Date.now() - MONTH) } }, { startTime: { [Op.gt]: new Date(Date.now() - MONTH) } },
@@ -54,32 +42,16 @@ const FRESH = {
} }
const SELECT = ['id', 'repo', 'commit', 'distro', 'dependencies', 'startTime', 'endTime', 'status']; const SELECT = ['id', 'repo', 'commit', 'distro', 'dependencies', 'startTime', 'endTime', 'status'];
function handleCallback<T>(err: unknown, data: T, cb?: Callback): T { class DB {
if (cb) {
cb(err, data);
}
if (err) {
throw err;
}
return data;
}
class DB extends Store {
private build: ModelStatic<any>; private build: ModelStatic<any>;
private logChunk: ModelStatic<any>; private logChunk: ModelStatic<any>;
private user: ModelStatic<any>;
private session: ModelStatic<any>;
private sequelize: Sequelize; private sequelize: Sequelize;
private ttl: number;
constructor(config: DBConfig = {}) { constructor(config: DBConfig = {}) {
super();
this.ttl = notStupidParseInt(process.env['COOKIETTL']) || 1000 * 60 * 60 * 24 * 30;
this.sequelize = new Sequelize(config.db || 'archery', config.user || 'archery', process.env.PASSWORD || config.password || '', { this.sequelize = new Sequelize(config.db || 'archery', config.user || 'archery', process.env.PASSWORD || config.password || '', {
host: config.host || 'localhost', host: config.host || 'localhost',
port: config.port || 5432, port: config.port || 5432,
dialect: 'postgres', dialect: 'postgres'
logging: false
}); });
this.build = this.sequelize.define('builds', { this.build = this.sequelize.define('builds', {
id: { id: {
@@ -124,10 +96,6 @@ class DB extends Store {
pid: { pid: {
type: DataTypes.INTEGER, type: DataTypes.INTEGER,
allowNull: true allowNull: true
},
uuid: {
type: DataTypes.STRING,
unique: true
} }
}); });
@@ -158,73 +126,21 @@ class DB extends Store {
} }
}); });
this.user = this.sequelize.define('users', {
id: {
type: DataTypes.STRING,
primaryKey: true,
},
username: {
type: DataTypes.STRING,
},
displayName: {
type: DataTypes.STRING,
allowNull: true
}
});
this.session = this.sequelize.define('session', {
sid: {
type: DataTypes.STRING,
primaryKey: true,
},
sessionData: {
type: DataTypes.JSONB,
}
});
this.build.belongsTo(this.user);
this.user.hasMany(this.build);
this.sync(); this.sync();
} }
private async sync(): Promise<void> { private async sync(): Promise<void> {
await this.user.sync();
await this.build.sync(); await this.build.sync();
await this.logChunk.sync(); await this.logChunk.sync();
await this.session.sync();
if (!(await this.getUser('-1'))) {
await this.createUser({
id: '-1',
username: '???',
displayName: 'Anonymous User'
});
}
} }
public async getUser(id: string): Promise<User> { public async createBuild(repo: string, commit: string, patch: string, distro: string, dependencies: string): Promise<number> {
return await this.user.findByPk(id);
}
public async createUser(user: User): Promise<string> {
await this.user.create({
id: user.id,
username: user.username,
displayName: user.displayName || null
});
return user.id;
}
public async createBuild(repo: string, commit: string, patch: string, distro: string, dependencies: string, author: string, uuid: string): Promise<number> {
const buildRec = await this.build.create({ const buildRec = await this.build.create({
repo, repo,
commit: commit || null, commit: commit || null,
patch: patch || null, patch: patch || null,
distro, distro,
dependencies, dependencies
uuid,
userId: author || '-1'
}); });
return buildRec.id; return buildRec.id;
} }
@@ -271,26 +187,14 @@ class DB extends Store {
} }
public async getBuild(id: number): Promise<Build> { public async getBuild(id: number): Promise<Build> {
return await this.build.findByPk(id, { return await this.build.findByPk(id);
include: this.user
});
}
public async getBuildByUuid(uuid: string): Promise<Build> {
return await this.build.findOne({
where: {
uuid
},
include: this.user
});
} }
public async getBuilds(): Promise<Build[]> { public async getBuilds(): Promise<Build[]> {
return await this.build.findAll({ return await this.build.findAll({
attributes: SELECT, attributes: SELECT,
order: [['id', 'DESC']], order: [['id', 'DESC']],
where: FRESH, where: FRESH
include: this.user
}); });
} }
@@ -301,8 +205,7 @@ class DB extends Store {
where: { where: {
...FRESH, ...FRESH,
status status
}, }
include: this.user
}); });
} }
@@ -313,8 +216,7 @@ class DB extends Store {
where: { where: {
...FRESH, ...FRESH,
distro distro
}, }
include: this.user
}); });
} }
@@ -325,8 +227,7 @@ class DB extends Store {
where: { where: {
...FRESH, ...FRESH,
...filterable ...filterable
}, }
include: this.user
}); });
} }
@@ -349,8 +250,7 @@ class DB extends Store {
{ repo: { [Op.iLike]: `%${query}%` } } { repo: { [Op.iLike]: `%${query}%` } }
] ]
}, },
limit: 100, limit: 100
include: this.user
}); });
} }
@@ -358,117 +258,8 @@ class DB extends Store {
await this.build.destroy({ await this.build.destroy({
where: { where: {
startTime: { [Op.lt]: new Date(Date.now() - MONTH * 6) } startTime: { [Op.lt]: new Date(Date.now() - MONTH * 6) }
},
force: true
});
await this.session.destroy({
where: {
updatedAt: { [Op.lt]: new Date(Date.now() - this.ttl) }
},
force: true
});
}
public getTTL(sessionData: SessionData) {
if (sessionData?.cookie?.expires) {
const ms = Number(new Date(sessionData.cookie.expires)) - Date.now();
return ms;
}
else {
return this.ttl;
}
}
public async set(sid: string, sessionData: SessionData, cb?: Callback): Promise<void> {
const ttl = this.getTTL(sessionData);
try {
if (ttl > 0) {
await this.session.upsert({
sid,
sessionData
});
handleCallback(null, null, cb);
return;
} }
await this.destroy(sid, cb); });
}
catch (err) {
return handleCallback(err, null, cb);
}
}
public async get(sid: string, cb?: Callback): Promise<SessionData> {
try {
return handleCallback(null, ((await this.session.findByPk(sid))?.sessionData) as SessionData || null, cb);
}
catch (err) {
return handleCallback(err, null, cb);
}
}
public async destroy(sid: string, cb?: Callback): Promise<void> {
try {
await this.session.destroy({
where: {
sid
},
force: true
});
handleCallback(null, null, cb);
}
catch (err) {
handleCallback(err, null, cb);
}
}
public async clear(cb?: Callback): Promise<void> {
try {
await this.session.destroy({
truncate: true,
force: true
});
handleCallback(null, null, cb);
}
catch (err) {
handleCallback(err, null, cb);
}
}
public async length(cb?: Callback): Promise<number> {
try {
return handleCallback(null, await this.session.count(), cb);
}
catch (err) {
handleCallback(err, null, cb);
}
}
public async touch(sid: string, sessionData: SessionData, cb?: Callback): Promise<void> {
try {
await this.session.update({},
{
where: {
sid
}
}
);
handleCallback(null, null, cb);
}
catch (err) {
handleCallback(err, null, cb);
}
}
public async all(cb?: Callback): Promise<SessionData[]> {
try {
const all = await this.session.findAll({
attributes: ['sessionData']
});
return handleCallback(null, all.map(row => row.sessionData as SessionData), cb);
}
catch (err) {
handleCallback(err, null, cb);
}
} }
public async close(): Promise<void> { public async close(): Promise<void> {
@@ -478,4 +269,4 @@ class DB extends Store {
export default DB; export default DB;
export { DB }; export { DB };
export type { DBConfig, Status, Build, LogChunk, User }; export type { DBConfig, Status, Build, LogChunk };

View File

@@ -1,34 +1,14 @@
import * as http from "http"; import * as http from "http";
import crypto from 'crypto'; import crypto from 'crypto';
import type { Express } from 'express'; import type { Express } from "express";
import express from 'express'; import express from 'express';
import expressWs from 'express-ws'; import expressWs from "express-ws";
import session from 'express-session'; import bodyParser from "body-parser";
import ky from 'ky'; import type { DB, LogChunk } from "./DB.ts";
import passport from 'passport';
import OpenIDConnectStrategy from 'passport-openidconnect';
import bodyParser from 'body-parser';
import Sqids from 'sqids';
import type { DB, LogChunk, Build, User } from "./DB.ts";
import type { BuildController, BuildEvent } from "./BuildController.ts"; import type { BuildController, BuildEvent } from "./BuildController.ts";
interface WebConfig { interface WebConfig {
sessionSecret?: string;
port?: number; port?: number;
secure?: boolean;
oidc?: {
server: string;
clientId: string;
clientSecret: string;
appBaseUrl: string;
};
}
interface OpenIdConfiguration {
issuer: string;
authorization_endpoint: string;
token_endpoint: string;
userinfo_endpoint: string;
} }
/** /**
@@ -59,22 +39,10 @@ class Web {
private buildController: BuildController; private buildController: BuildController;
private app: expressWs.Application; private app: expressWs.Application;
private port: number; private port: number;
private options:WebConfig;
constructor(options: WebConfig = {}) { constructor(options: WebConfig = {}) {
this.options = options;
}
initialize = async () => {
const options = this.options;
const sessionSecret = process.env['SESSIONSECRET'] || options.sessionSecret;
const sqids = new Sqids({
minLength: 6,
alphabet: 'abcdefghijkmnprstuvwxyz'
});
const app: Express = express(); const app: Express = express();
const wsApp = this.app = expressWs(app).app; const wsApp = this.app = expressWs(app).app;
const oidc = await this.initializeOIDC(options);
this.port = notStupidParseInt(process.env.PORT) || options['port'] as number || 8080; this.port = notStupidParseInt(process.env.PORT) || options['port'] as number || 8080;
app.set('trust proxy', 1); app.set('trust proxy', 1);
@@ -95,154 +63,15 @@ class Web {
}); });
}); });
const createBuildPages = (slug: string, getBuildFn: (str: string) => Promise<Build>) => {
app.get(`/${slug}/:id/`, async (req, res) => {
const build = await getBuildFn(req.params.id);
if (!build) {
res.sendStatus(404);
return;
}
build.sqid = sqids.encode([build.id]);
const log = splitLines(await this.db.getLog(build.id));
if (req?.user) {
res.locals.shareable = `${req.protocol}://${req.host}/b/${build.uuid}/`;
}
res.render('build', {
page: {
title: 'Archery',
titlesuffix: `Build #${build.id}`,
description: `Building ${build.repo} on ${build.distro}`,
},
user: req?.user,
build,
log,
ended: build.status !== 'queued' && build.status !== 'running',
public: !!oidc && !req?.user
});
});
app.get(`/${slug}/:id/logs{/}`, async (req, res) => {
const build = await getBuildFn(req.params.id);
if (!build) {
res.sendStatus(404);
return;
}
const log = (await this.db.getLog(build.id)).map(logChunk => logChunk.chunk).join('\n');
res.set('Content-Type', 'text/plain').send(log);
});
app.get(`/${slug}/:id/patch{/}`, async (req, res) => {
const build = await getBuildFn(req.params.id);
if (!build || !build.patch) {
res.sendStatus(404);
return;
}
res.set('Content-Type', 'text/plain').send(build.patch);
});
wsApp.ws(`/${slug}/:id/ws`, async (ws, req) => {
const build = await getBuildFn(req.params.id);
if (!build || (build.status !== 'queued' && build.status !== 'running')) {
return ws.close();
}
console.log('WS Opened');
const eventListener = (be: BuildEvent) => {
if (be.id === build.id) {
ws.send(JSON.stringify(be));
}
};
this.buildController.on('log', eventListener);
ws.on('close', () => {
console.log('WS Closed');
this.buildController.removeListener('log', eventListener);
});
});
}
app.get('/healthcheck', (_, res) => {
res.send('Healthy');
});
if (oidc) {
if (!sessionSecret) {
throw new Error('sessionSecret must be set.');
}
app.use(session({
name: 'sessionId',
secret: sessionSecret,
resave: true,
saveUninitialized: false,
store: this.db,
cookie: {
maxAge: notStupidParseInt(process.env['COOKIETTL']) || 1000 * 60 * 60 * 24 * 30, // 30 days
httpOnly: true,
secure: !!options.secure
}
}));
passport.use(oidc);
app.use(passport.initialize());
app.use(passport.session());
passport.serializeUser(function (user: User, done) {
done(null, user.id);
});
passport.deserializeUser(async (id: string, done) => {
const user = await this.db.getUser(id);
done(null, {
id: user.id,
username: user.username,
displayName: user.displayName
});
});
app.get('/login', (req, res) => {
if (req?.user) {
return res.redirect('/');
}
res.append('X-Robots-Tag', 'none');
res.render('login-required', {
page: {
title: 'Archery',
titlesuffix: 'Log In',
description: 'Authentication required',
}
});
});
app.post('/login', passport.authenticate('openidconnect'));
app.get('/cb', passport.authenticate('openidconnect', { successRedirect: '/', failureRedirect: '/login', failureMessage: true }));
app.get('/logout', (req, res) => {
req.logOut((err) => {
if (err) {
console.error(`Failed to log out user: ${err}`);
}
res.redirect('/login');
});
});
createBuildPages('b', (id) => this.db.getBuildByUuid(id));
app.use((req, res, next) => {
if (!req?.user) {
res.redirect('/login');
return;
}
next();
});
}
app.get('/', async (req, res) => { app.get('/', async (req, res) => {
try { try {
const builds = 'q' in req.query ? await this.db.searchBuilds(req.query.q as string) : await this.db.getBuildsBy(req.query); const builds = 'q' in req.query ? await this.db.searchBuilds(req.query.q as string) : await this.db.getBuildsBy(req.query);
builds.forEach(b => {
b.sqid = sqids.encode([b.id]);
});
res.render('index', { res.render('index', {
page: { page: {
title: 'Archery', title: 'Archery',
titlesuffix: 'Dashboard', titlesuffix: 'Dashboard',
description: 'PKGBUILD central' description: 'PKGBUILD central'
}, },
user: req?.user,
builds, builds,
timeElapsed timeElapsed
}); });
@@ -253,37 +82,50 @@ class Web {
} }
}); });
app.get('/build{/}', async (req, res) => { app.get('/build/?', (_, res) => {
const query = ('id' in req.query && typeof req.query.id === 'string' && await this.db.getBuild(sqids.decode(req.query.id)?.[0])) || req.query;
res.render('build-new', { res.render('build-new', {
page: { page: {
title: 'Archery', title: 'Archery',
titlesuffix: 'New Build', titlesuffix: 'New Build',
description: 'Kick off a build', description: 'Kick off a build'
}, }
user: req?.user,
query
}); });
}); });
app.post('/build{/}', async (req, res) => { app.post('/build/?', async (req, res) => {
const buildId = await this.db.createBuild( const buildId = await this.db.createBuild(
req.body.repo, req.body.repo,
req.body.commit || null, req.body.commit || null,
req.body.patch || null, req.body.patch || null,
req.body.distro || 'arch', req.body.distro || 'arch',
req.body.dependencies || 'stable', req.body.dependencies || 'stable'
req?.user?.['id'],
crypto.randomUUID()
); );
res.redirect(`/build/${sqids.encode([buildId])}/`); res.redirect(`/build/${buildId}`);
this.buildController.triggerBuild(); this.buildController.triggerBuild();
}); });
createBuildPages('build', (id) => this.db.getBuild(sqids.decode(id)?.[0])); app.get('/build/:num/?', async (req, res) => {
const build = await this.db.getBuild(parseInt(req.params.num));
if (!build) {
res.sendStatus(404);
return;
}
const log = splitLines(await this.db.getLog(build.id));
app.get('/build/:id/cancel', async (req, res) => { res.render('build', {
const build = await this.db.getBuild(sqids.decode(req.params.id)?.[0]); page: {
title: 'Archery',
titlesuffix: `Build #${req.params.num}`,
description: `Building ${build.repo} on ${build.distro}`
},
build,
log,
ended: build.status !== 'queued' && build.status !== 'running'
});
});
app.get('/build/:num/cancel', async (req, res) => {
const build = await this.db.getBuild(parseInt(req.params.num));
if (!build) { if (!build) {
res.sendStatus(404); res.sendStatus(404);
return; return;
@@ -294,10 +136,47 @@ class Web {
catch (ex) { catch (ex) {
console.error(ex); console.error(ex);
} }
res.redirect(`/build/${req.params.id}/`); res.redirect(`/build/${build.id}`);
});
app.get('/build/:num/logs/?', async (req, res) => {
const build = await this.db.getBuild(parseInt(req.params.num));
if (!build) {
res.sendStatus(404);
return;
}
const log = (await this.db.getLog(build.id)).map(logChunk => logChunk.chunk).join('\n');
res.set('Content-Type', 'text/plain').send(log);
});
app.get('/build/:num/patch/?', async (req, res) => {
const build = await this.db.getBuild(parseInt(req.params.num));
if (!build || !build.patch) {
res.sendStatus(404);
return;
}
res.set('Content-Type', 'text/plain').send(build.patch);
});
app.get('/healthcheck', (_, res) => {
res.send('Healthy');
});
wsApp.ws('/build/:num/ws', (ws, req) => {
console.log('WS Opened');
const eventListener = (be: BuildEvent) => {
if (be.id === notStupidParseInt(req.params.num)) {
ws.send(JSON.stringify(be));
}
};
this.buildController.on('log', eventListener);
ws.on('close', () => {
console.log('WS Closed');
this.buildController.removeListener('log', eventListener);
});
}); });
this._webserver = this.app.listen(this.port, () => console.log(`archery is running on port ${this.port}`));
} }
close = () => { close = () => {
@@ -308,35 +187,9 @@ class Web {
setDB = (db: DB) => { setDB = (db: DB) => {
this.db = db; this.db = db;
} if (!this._webserver) {
this._webserver = this.app.listen(this.port, () => console.log(`archery is running on port ${this.port}`));
initializeOIDC = async (options: WebConfig): Promise<OpenIDConnectStrategy | false> => {
if (!options.oidc || !options.oidc.server || !options.oidc.clientId || !options.oidc.clientSecret) {
return false;
} }
const server = options.oidc.server.endsWith('/') ? options.oidc.server : `${options.oidc.server}/`;
const baseUrl = options.oidc.appBaseUrl.endsWith('/') ? options.oidc.appBaseUrl : `${options.oidc.appBaseUrl}/`;
const openidconf = await ky.get(`${server}.well-known/openid-configuration`).json<OpenIdConfiguration>();
return new OpenIDConnectStrategy({
issuer: openidconf.issuer,
authorizationURL: openidconf.authorization_endpoint,
tokenURL: openidconf.token_endpoint,
userInfoURL: openidconf.userinfo_endpoint,
clientID: options.oidc.clientId,
clientSecret: options.oidc.clientSecret,
callbackURL: `${baseUrl}cb`
}, async (_: string, profile: passport.Profile, cb: OpenIDConnectStrategy.VerifyCallback) => {
const userObj: User = {
id: profile.id,
username: profile.username,
displayName: profile.displayName
};
const user = await this.db.getUser(profile.id);
if (!user) {
await this.db.createUser(userObj);
}
return cb(null, userObj);
});
} }
setBuildController = (buildController: BuildController) => { setBuildController = (buildController: BuildController) => {
@@ -345,5 +198,5 @@ class Web {
} }
export default Web; export default Web;
export { Web, notStupidParseInt }; export { Web };
export type { WebConfig }; export type { WebConfig };

View File

@@ -11,7 +11,7 @@ interface compositeConfig {
db?: DBConfig db?: DBConfig
} }
const config: compositeConfig = JSON.parse(await fs.promises.readFile(process.env.config || process.env.CONFIG || path.join(process.cwd(), 'config', 'config.json'), 'utf-8')); const config: compositeConfig = JSON.parse(await fs.promises.readFile(process.env.config || process.env.CONFIG || path.join('config', 'config.json'), 'utf-8'));
const web = new Web(config.web); const web = new Web(config.web);
const buildController = new BuildController(); const buildController = new BuildController();
@@ -19,7 +19,6 @@ await new Promise((resolve) => setTimeout(resolve, 1500));
const db = new DB(config.db); const db = new DB(config.db);
web.setDB(db); web.setDB(db);
web.setBuildController(buildController); web.setBuildController(buildController);
web.initialize();
buildController.setDB(db); buildController.setDB(db);
process.on('SIGTERM', () => { process.on('SIGTERM', () => {

View File

@@ -118,15 +118,6 @@ input[type="submit"] {
} }
} }
span,
a {
&:has(+ button.copybtn) {
float: left;
margin-right: .75em;
}
}
.sidebar { .sidebar {
background: var(--primary); background: var(--primary);
@@ -199,10 +190,6 @@ a {
&.no-padding { &.no-padding {
padding: 0; padding: 0;
} }
&:has(+ .content.footer) {
padding-bottom: 3em;
}
} }
.overflow-x { .overflow-x {
@@ -244,13 +231,9 @@ a {
.content.footer { .content.footer {
background: var(--primary-dark); background: var(--primary-dark);
color: var(--color-text); color: var(--color-text);
margin-top: .5em;
padding: .25em 1em; padding: .25em 1em;
position: fixed;
bottom: 0;
left: 0;
right: 0;
a { a {
color: var(--color-text); color: var(--color-text);
text-decoration: underline; text-decoration: underline;

View File

@@ -10,19 +10,19 @@
<div class="content"> <div class="content">
<h1>Start a build</h1> <h1>Start a build</h1>
<form action="/build" method="post" class="grid-2col"> <form action="/build" method="post" class="grid-2col">
<label for="repoTxt">Repo</label> <input type="text" name="repo" id="repoTxt" required <% if (typeof query.repo === 'string') { %>value="<%= query.repo %>"<% } %> /> <label for="repoTxt">Repo</label> <input type="text" name="repo" id="repoTxt" required />
<label for="commitTxt">Commit</label> <input type="text" name="commit" id="commitTxt" <% if (typeof query.commit === 'string') { %>value="<%= query.commit %>"<% } %> /> <label for="commitTxt">Commit</label> <input type="text" name="commit" id="commitTxt" />
<label for="patchTxt">Patch</label> <textarea name="patch" id="patchTxt"><% if (typeof query.patch === 'string') { %><%= query.patch %><% } %></textarea> <label for="patchTxt">Patch</label> <textarea name="patch" id="patchTxt"></textarea>
<label for="distroTxt">Distro</label> <label for="distroTxt">Distro</label>
<select name="distro" id="distroTxt" required> <select name="distro" id="distroTxt" required>
<option value="arch" <% if (query.distro === 'arch') { %>selected<% } %>>Arch</option> <option value="arch">Arch</option>
<option value="artix" <% if (query.distro === 'artix') { %>selected<% } %>>Artix</option> <option value="artix">Artix</option>
</select> </select>
<label for="dependsTxt">Dependencies</label> <label for="dependsTxt">Dependencies</label>
<select name="dependencies" id="dependsTxt" required> <select name="dependencies" id="dependsTxt" required>
<option value="stable" <% if (query.dependencies === 'stable') { %>selected<% } %>>Stable</option> <option value="stable">Stable</option>
<option value="testing" <% if (query.dependencies === 'testing') { %>selected<% } %>>Testing</option> <option value="testing">Testing</option>
<option value="staging" <% if (query.dependencies === 'staging') { %>selected<% } %>>Staging</option> <option value="staging">Staging</option>
</select> </select>
<div class="span-2"><button type="submit">Build</button></div> <div class="span-2"><button type="submit">Build</button></div>
</form> </form>

View File

@@ -12,31 +12,20 @@
<h2 id="buildStatus"><%= build.status %></h2> <h2 id="buildStatus"><%= build.status %></h2>
<div class="overflow-x"> <div class="overflow-x">
<div class="grid-2col"> <div class="grid-2col">
<label>Repo</label> <span><span><%= build.repo %></span> <button class="copybtn">Copy</button></span> <label>Repo</label> <span><%= build.repo %></span>
<label>Commit</label> <span><% if (build.commit) { %><%= build.commit %><% } else { %>latest<% } %></span> <label>Commit</label> <span><% if (build.commit) { %><%= build.commit %><% } else { %>latest<% } %></span>
<label>Patch</label> <span><% if (build.patch) { %><a href="/build/<%= build.sqid %>/patch">patch file</a><% } else { %>none<% } %></span> <label>Patch</label> <span><% if (build.patch) { %><a href="/build/<%= build.id %>/patch">patch file</a><% } else { %>none<% } %></span>
<label>Distro</label> <span><%= build.distro %></span> <label>Distro</label> <span><%= build.distro %></span>
<label>Dependencies</label> <span><%= build.dependencies %></span> <label>Dependencies</label> <span><%= build.dependencies %></span>
<label>Start time</label> <span class="to-local-time"><%= build.startTime %></span> <label>Start time</label> <span class="to-local-time"><%= build.startTime %></span>
<% if (build.userId && build.userId !== '-1') { %>
<label>Triggered by</label> <span><%= build.user.displayName %> (<%= build.user.username %>)</span>
<% } %>
<% if (locals.shareable) { %>
<label>Shareable link</label> <span><a href="<%= shareable %>"><%= shareable %></a> <button class="copybtn">Copy</button></span>
<% } %>
</div> </div>
</div> </div>
<% if (build.sqid && !public) { %>
<div>
<a href="/build?id=<%= build.sqid %>" class="button">Clone</a>
</div>
<% } %>
<% if (!ended) { %> <% if (!ended) { %>
<div id="cancelRow"> <div>
<a href="cancel" class="button">Cancel build</a> <a href="/build/<%= build.id %>/cancel" class="button">Cancel build</a>
</div> </div>
<% } %> <% } %>
<p><a href="logs">Full logs</a></p> <p><a href="/build/<%= build.id %>/logs">Full logs</a></p>
<pre class="overflow-x"><div class="logs" id="logs"><% (log || []).forEach(line => { %><p><%= line %></p><% }) %></div></pre> <pre class="overflow-x"><div class="logs" id="logs"><% (log || []).forEach(line => { %><p><%= line %></p><% }) %></div></pre>
<% if (!ended) { %> <% if (!ended) { %>
@@ -47,9 +36,8 @@
</div> </div>
<%- include("footer", locals) %> <%- include("footer", locals) %>
<script src="/assets/js/timezone.js?v1" nonce="<%= cspNonce %>"></script> <script src="/assets/js/timezone.js?v1" nonce="<%= cspNonce %>"></script>
<script src="/assets/js/copy.js?v1" nonce="<%= cspNonce %>"></script>
<% if (!ended) { %> <% if (!ended) { %>
<script src="/assets/js/build.js?v3" nonce="<%= cspNonce %>"></script> <script src="/assets/js/build.js?v2" nonce="<%= cspNonce %>"></script>
<% } %> <% } %>
</body> </body>
</html> </html>

View File

@@ -14,7 +14,7 @@
<link rel="canonical" href="<%= page.canonical%>"/> <link rel="canonical" href="<%= page.canonical%>"/>
<% } %> <% } %>
<link rel="shortcut icon" href="/assets/svg/favicon.svg"> <link rel="shortcut icon" href="/assets/svg/favicon.svg">
<link rel="stylesheet" href="/assets/css/styles.css?v4"> <link rel="stylesheet" href="/assets/css/styles.css?v3">
<script nonce="<%= cspNonce %>"> <script nonce="<%= cspNonce %>">
document.addEventListener("DOMContentLoaded", function() { document.addEventListener("DOMContentLoaded", function() {
document.body.classList.remove('preload'); document.body.classList.remove('preload');

View File

@@ -20,7 +20,7 @@
</tr> </tr>
<% builds.forEach(build => { %> <% builds.forEach(build => { %>
<tr> <tr>
<td><a href="/build/<%= build.sqid %>/"><%= build.repo %></a></td> <td><a href="/build/<%= build.id %>"><%= build.repo %></a></td>
<td><%= build.distro %></td> <td><%= build.distro %></td>
<td class="to-local-time"><%= build.startTime %></td> <td class="to-local-time"><%= build.startTime %></td>
<td><%= timeElapsed(build.startTime, build.endTime) %></td> <td><%= timeElapsed(build.startTime, build.endTime) %></td>

View File

@@ -1,19 +0,0 @@
<!DOCTYPE html>
<html xmlns="http://www.w3.org/1999/xhtml" lang="en">
<head>
<%- include("head", locals) %>
</head>
<body class="preload">
<%- include("navigation", locals) %>
<div class="content">
<h1>Authentication Required</h1>
You must log in to access that page.
<form action="/login" method="post">
<button type="submit">Log In</button>
</form>
</div>
<%- include("footer", locals) %>
</body>
</html>

View File

@@ -14,9 +14,6 @@
<li><a href="/?distro=arch">Arch Builds</a></li> <li><a href="/?distro=arch">Arch Builds</a></li>
<li><a href="/?distro=artix">Artix Builds</a></li> <li><a href="/?distro=artix">Artix Builds</a></li>
<li><a href="/build">New Build</a></li> <li><a href="/build">New Build</a></li>
<% if (locals.user) { %>
<li><a href="/logout">Log Out</a></li>
<% } %>
</ul> </ul>
</nav> </nav>
</div> </div>