abtmtr-v13/index.js

204 lines
5.2 KiB
JavaScript
Raw Normal View History

2024-08-20 19:30:37 +00:00
import express from "express";
import { config } from "dotenv";
import path from "path";
2024-08-28 06:29:42 +00:00
import SQLite from 'better-sqlite3';
import { Kysely, SqliteDialect } from 'kysely';
import { nanoid } from "nanoid";
import { JSDOM } from "jsdom";
2024-08-20 19:30:37 +00:00
2024-08-21 06:05:24 +00:00
const __dirname = import.meta.dirname;
2024-08-28 06:29:42 +00:00
const rawDB = new SQLite('abtmtr.db');
const db = new Kysely({
dialect: new SqliteDialect({
database: rawDB,
})
});
rawDB.exec(`CREATE TABLE IF NOT EXISTS blurbs( 'id' TEXT, 'site' TEXT, 'blurb' TEXT, 'verified' INTEGER, 'time' INTEGER );`);
2024-08-20 19:30:37 +00:00
const app = express();
app.set('view engine', 'ejs');
app.use('/assets', express.static('assets'));
2024-08-21 06:05:24 +00:00
app.set('views', path.join(__dirname, "views", "pages"));
app.locals = {
visibility: [
"Backend",
"Personal",
"Friends-only",
"Login-only",
"Public"
]
}
2024-08-20 19:30:37 +00:00
config();
2024-08-21 06:05:24 +00:00
app.use(async (req, res, next) => {
const buttonsJson = await fetch("https://cdn.abtmtr.link/site_content/buttons.json")
.catch(() => res.status(500).send())
2024-08-27 07:58:49 +00:00
.then((res) => res.json())
.catch(() => res.status(500).send());
const followingJson = await fetch("https://cdn.abtmtr.link/site_content/following.json")
.catch(() => res.status(500).send())
.then((res) => res.json())
.catch(() => res.status(500).send());
2024-08-21 06:05:24 +00:00
app.locals.buttons = buttonsJson;
2024-08-27 07:58:49 +00:00
app.locals.following = followingJson;
2024-08-21 06:05:24 +00:00
next();
})
app.get('/', async (req, res) => {
const statusesJson = await fetch("https://cdn.abtmtr.link/site_content/v13/statuses.json")
.catch(() => res.status(500).send())
.then((res) => res.json());
res.render('index', {
statuses: statusesJson
});
})
app.get('/services', async (req, res) => {
const servicesJson = await fetch("https://cdn.abtmtr.link/site_content/v13/services.json")
.catch(() => res.status(500).send())
.then((res) => res.json());
res.render('services/index', { services: servicesJson });
});
app.get('/computers', async (req, res) => {
const computersJson = await fetch("https://cdn.abtmtr.link/site_content/v13/computers.json")
.catch(() => res.status(500).send())
.then((res) => res.json());
res.render('computers/index', { computers: computersJson });
});
app.get('/links', async (req, res) => {
const linksJson = await fetch("https://cdn.abtmtr.link/site_content/v13/links.json")
.catch(() => res.status(500).send())
.then((res) => res.json());
2024-08-20 19:30:37 +00:00
2024-08-21 06:05:24 +00:00
res.render('links/index', {
links: linksJson
2024-08-20 19:30:37 +00:00
});
});
2024-08-21 06:05:24 +00:00
app.get('/matkap', (req, res) => {
res.render('matkap/index');
});
app.get('/about', (req, res) => {
res.render('about/index');
});
2024-08-28 06:29:42 +00:00
app.get('/blurbs', async (req, res) => {
const data = await db
.selectFrom('blurbs')
.selectAll()
.where('verified', '=', 1)
2024-08-28 13:48:02 +00:00
.orderBy('time', "desc")
2024-08-28 06:29:42 +00:00
.execute();
res.render('blurbs/index', { data });
});
// brbrleibbghbelsbbsbuuebbuubsubss
async function cleanupBlurbles() {
const timeNow = Date.now() - 86400000;
await db
.deleteFrom('blurbs')
.where('time', '<', timeNow)
2024-08-28 13:43:48 +00:00
.where('verified', '=', 0)
2024-08-28 06:29:42 +00:00
.execute()
}
app.get('/blurbs/send', async (req, res) => {
const body = req.query;
const errors = [];
if (body.site == null) errors.push("Site domain required");
else {
const status = await fetch(body.site).then(x => x.status).catch(_ => _);
if (status != 200) errors.push("Site must be online");
}
if (body.text == null) errors.push("Blurb text required");
else {
if (body.text.length < 1) errors.push("Blurb text must not be blank");
if (body.text.length > 140) errors.push("Blurb text must not exceed 140 characters");
}
if (errors.length > 0) return res.status(400).json({
error: "Bad Request",
message: errors.join(", ")
});
const postId = nanoid(32);
try {
await db.insertInto('blurbs')
.values({
id: postId,
site: body.site,
blurb: body.text,
verified: 0,
time: Date.now()
})
.executeTakeFirstOrThrow();
} catch (err) {
console.log(err)
return res.status(500).send('Internal Server Error');
}
cleanupBlurbles();
res.render('blurbs/sent', { id: postId });
});
app.get('/blurbs/check', async (req, res) => {
const body = req.query;
const blurbFromId = await db
.selectFrom('blurbs')
.selectAll()
.where('id', '=', body.id)
.executeTakeFirst();
if (blurbFromId == null) return res.redirect("/blurbs/");
const site = await fetch(blurbFromId.site).then(x => x.text()).catch(_ => _);
const dom = new JSDOM(site);
const relationLink = dom.window.document.querySelector(
`[rel=me][href="https://abtmtr.link/blurbs/#${blurbFromId.id}"]`
);
if (relationLink != null) await db
.updateTable('blurbs')
.set({
verified: 1
})
.where('id', '=', body.id)
.executeTakeFirst();
else {
await db
.updateTable('blurbs')
.set({
verified: 0
})
.where('id', '=', body.id)
.executeTakeFirst();
}
cleanupBlurbles();
res.redirect("/blurbs/");
});
2024-08-20 19:30:37 +00:00
app.get("/favicon.ico", (req, res) => {
res.redirect("https://cdn.abtmtr.link/site_content/favicon.ico")
})
app.listen(process.env.PORT, () => {
const url = new URL("http://localhost/");
url.port = process.env.PORT;
console.log(`Example app listening on ${url.toString()}`);
});