app.ts 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869
  1. import { createError, opine } from "./deps.ts";
  2. import { ErrorRequestHandler, Router, server } from "./deps.ts";
  3. import { BBB } from './bbb.ts';
  4. // give your tinyscale server a secret so it looks like a BBB server
  5. const secret = Deno.env.get("TINYSCALE_SECRET") || ""
  6. if (!secret) throw "No secret set for tinyscale"
  7. // store your BBB servers in servers.json
  8. const file: string = await Deno.readTextFile('servers.json')
  9. const servers: server[] = JSON.parse(file)
  10. // create an iterator so that we can trat all servers equally
  11. let iterator = servers[Symbol.iterator]();
  12. console.log(servers)
  13. // pick the next server, using an iterator to cycle through all servers available
  14. function get_available_server(): server {
  15. let candidate = iterator.next()
  16. if (candidate.done) {
  17. iterator = servers[Symbol.iterator]()
  18. candidate = iterator.next()
  19. }
  20. console.log(`Using next server ${candidate.value.host}`)
  21. return candidate.value;
  22. }
  23. const router = Router()
  24. // the api itself answering to every call
  25. router.get("/bigbluebutton/api/:call", async (req, res, next) => {
  26. const handler = new BBB(req)
  27. if (!handler.authenticated(secret)) {
  28. res.setStatus(401).end()
  29. return
  30. }
  31. let server: server
  32. try {
  33. server = await handler.find_meeting_id(servers)
  34. } catch (e) {
  35. console.log(`Found no server with Meeting ID ${handler.meeting_id}`)
  36. server = get_available_server()
  37. }
  38. console.log(`Redirecting to ${server.host}`)
  39. res.redirect(handler.rewritten_query(server))
  40. });
  41. // the fake answering machine to make sure we are recognized as a proper api
  42. router.get("/bigbluebutton/api", (req, res, next) => {
  43. console.log('sending fake xml response')
  44. res.set('Content-Type', 'text/xml');
  45. res.send(`<response>
  46. <returncode>SUCCESS</returncode>
  47. <version>2.0</version>
  48. </response>`);
  49. })
  50. const errorHandler: ErrorRequestHandler = (err, req, res, next) => {
  51. // Set locals, only providing error in development
  52. res.locals.message = err.message;
  53. res.locals.error = req.app.get("env") === "development" ? err : {};
  54. // Render the error page
  55. res.setStatus(err.status ?? 500);
  56. console.log(err, req)
  57. res.send(err);
  58. };
  59. const app = opine()
  60. .use("/", router)
  61. .use((req, res, next) => { next(createError(404)); })
  62. .use(errorHandler);
  63. export default app;