import express, { Router, Request, Response } from "express"; import { Page, PostMetadata } from "../metadata"; import { ArticleObject } from "./activity"; import Article from "../entity/Article"; import { getConnection } from "typeorm"; import uuidv4 from "uuid/v4"; const domain = process.env.DOMAIN; export async function setup(posts: Page[]) { const repository = getConnection().getRepository(Article); for (const post of posts) { const postMeta = post.metadata; if (await repository.findOne(postMeta.permalink)) { continue; } const articleObject = { "@context": [ "https://www.w3.org/ns/activitystreams", ], "type": "Article", "id": `https://${domain}${post.metadata.permalink}`, "published": (postMeta.date).toISOString(), "inReplyTo": null, "conversation": `https://${domain}/ap/conversation/${uuidv4()}`, "url": `https://${domain}${postMeta.permalink}`, "attributedTo": `https://${domain}/ap/actor`, "to": [ "https://www.w3.org/ns/activitystreams#Public" ], "cc": [ `https://${domain}/ap/actor/followers` ], "name": postMeta.title, "content": post.text }; const article = new Article(); article.id = postMeta.permalink; article.articleObject = articleObject; article.conversation = articleObject.conversation; article.hasFederated = false; await getConnection().manager.save(article); } } export async function toFederate(): Promise<[string, ArticleObject][]> { return new Promise(async (resolve, reject) => { const articles: Article[] = await getConnection().createQueryBuilder().select("article").from(Article, "article").where("article.hasFederated = :hasFederated", { hasFederated: false }).getMany(); let result: [string, ArticleObject][] = []; articles.forEach(it => { result.push([it.id, it.articleObject]); }); resolve(result); }); } export function route(router: Router) { router.use("/:year/:slug/", async (req, res, next) => { const best = req.accepts(["text/html", "application/activity+json"]); if (best === "text/html") { next(); } else if (best === "application/activity+json") { const id = `/${req.params.year}/${req.params.slug}/`; const repository = getConnection().getRepository(Article); try { const article = await repository.findOne(id); res.type("application/activity+json").json(article.articleObject).end(); } catch (err) { res.status(500).end(err); } } else { res.status(415).end("No acceptable content-type given. text/html or application/activity+json are supported"); } }); }