skylite / main-index.ts

import { setupAuth, getAuthenticatedDid, authVerifier } from "./utils/auth.ts";
import { setupSystemDb } from "./utils/dbsystem.ts";
import { didDocument } from "./utils/diddoc.ts";
import { cachedFetch, searchParamsToJson, withCors } from "./utils/server.ts";
import { IndexServer, IndexServerConfig } from "./indexserver.ts";
import { extractDid } from "./utils/identity.ts";
import { config } from "./config.ts";
import { compile, devWatch } from "./shared-landing/build.ts";
let { js, html, css } = await compile("index");

// ------------------------------------------
//               AppView Setup
// ------------------------------------------

const indexServerConfig: IndexServerConfig = {
  baseDbPath: "./dbs/index/registered-users", // The directory for user databases
  systemDbPath: "./dbs/index/registered-users/system.db", // The path for the main system database
};
export const genericIndexServer = new IndexServer(indexServerConfig);
setupSystemDb(genericIndexServer.systemDB);

// add me lol
genericIndexServer.systemDB.exec(`
  INSERT OR IGNORE INTO users (did, role, registrationdate, onboardingstatus)
  VALUES (
    'did:plc:mn45tewwnse5btfftvd3powc',
    'admin',
    datetime('now'),
    'ready'
  );

  INSERT OR IGNORE INTO users (did, role, registrationdate, onboardingstatus)
  VALUES (
    'did:web:did12.whey.party',
    'admin',
    datetime('now'),
    'ready'
  );
`);

genericIndexServer.start();

// ------------------------------------------
//         XRPC Method Implementations
// ------------------------------------------

// const indexServerRoutes = new Set([
//   "/xrpc/app.bsky.actor.getProfile",
//   "/xrpc/app.bsky.actor.getProfiles",
//   "/xrpc/app.bsky.feed.getActorFeeds",
//   "/xrpc/app.bsky.feed.getFeedGenerator",
//   "/xrpc/app.bsky.feed.getFeedGenerators",
//   "/xrpc/app.bsky.feed.getPosts",
//   "/xrpc/party.whey.app.bsky.feed.getActorLikesPartial",
//   "/xrpc/party.whey.app.bsky.feed.getAuthorFeedPartial",
//   "/xrpc/party.whey.app.bsky.feed.getLikesPartial",
//   "/xrpc/party.whey.app.bsky.feed.getPostThreadPartial",
//   "/xrpc/party.whey.app.bsky.feed.getQuotesPartial",
//   "/xrpc/party.whey.app.bsky.feed.getRepostedByPartial",
//   // more federated endpoints, not planned yet, lexicons will come later
//   /*
//     app.bsky.graph.getLists // doesnt need to because theres no items[], and its self ProfileViewBasic
//     app.bsky.graph.getList // needs to be Partial-ed (items[] union with ProfileViewRef)
//     app.bsky.graph.getActorStarterPacks // maybe doesnt need to be Partial-ed because its self ProfileViewBasic

//     app.bsky.feed.getListFeed // uhh actually already exists its getListFeedPartial
//   */
//  "/xrpc/party.whey.app.bsky.feed.getListFeedPartial",
// ]);



//console.log("ready to serve");
Deno.serve(
  { port: config.indexServer.port },
  async (req: Request): Promise<Response> => {
    const url = new URL(req.url);
    const pathname = url.pathname;
    const searchParams = searchParamsToJson(url.searchParams);

    if (html && js) {
      if (pathname === "/" || pathname === "") {
        return new Response(html, {
          headers: withCors({ "content-type": "text/html; charset=utf-8" }),
        });
      }
      if (pathname === "/landing-index.js") {
        return new Response(js, {
          headers: withCors({
            "content-type": "application/javascript; charset=utf-8",
          }),
        });
      }
    } else {
      if (pathname === "/" || pathname === "") {
        return new Response(`server is compiling your webpage. loading...`, {
          headers: withCors({ "content-type": "text/html; charset=utf-8" }),
        });
      }
    }
    if (pathname === "/app.css") {
      return new Response(css, {
        headers: withCors({
          "content-type": "text/css; charset=utf-8",
        }),
      });
    }


    if (pathname === "/.well-known/did.json") {
      return new Response(
        JSON.stringify(
          didDocument(
            "index",
            config.indexServer.did,
            config.indexServer.host,
            "whatever"
          )
        ),
        {
          headers: withCors({ "Content-Type": "application/json" }),
        }
      );
    }
    if (pathname === "/health") {
      return new Response("OK", {
        status: 200,
        headers: withCors({
          "Content-Type": "text/plain",
        }),
      });
    }
    if (req.method === "OPTIONS") {
      return new Response(null, {
        status: 204,
        headers: {
          "Access-Control-Allow-Origin": "*",
          "Access-Control-Allow-Methods": "GET, POST, OPTIONS",
          "Access-Control-Allow-Headers": "*",
        },
      });
    }
    console.log(`request for "${pathname}"`);
    const constellation = pathname.startsWith("/links");

    if (constellation) {
      const target = searchParams?.target as string;
      const safeDid = extractDid(target);
      const targetserver = genericIndexServer.handlesDid(safeDid);
      if (targetserver) {
        return genericIndexServer.constellationAPIHandler(req);
      } else {
        return new Response(
          JSON.stringify({
            error: "User not found",
          }),
          {
            status: 404,
            headers: withCors({ "Content-Type": "application/json" }),
          }
        );
      }
    } else {
      // indexServerRoutes.has(pathname)
      return await genericIndexServer.indexServerHandler(req);
    }
  }
);

devWatch("index", ({ js: newjs, html: newhtml, css: newcss }) => {
  js = newjs;
  html = newhtml;
  css = newcss;
});