Commit 74df47b4 authored by Grant's avatar Grant
Browse files

small changes for beta testing

parent 72e23540
Loading
Loading
Loading
Loading
+8 −0
Original line number Diff line number Diff line
@@ -30,6 +30,14 @@ app.get("/callback", async (req, res) => {
    }),
  }).then((a) => a.json());

  if (!who.success) {
    res.json({
      error: "AUTHENTICATION FAILED",
      error_message: who.error || "no error specified",
    });
    return;
  }

  const [username, hostname] = who.user.sub.split("@");

  await prisma.user.upsert({
+1 −1
Original line number Diff line number Diff line
@@ -14,7 +14,7 @@ class Canvas {
      size: this.CANVAS_SIZE,
      zoom: 7,
      pixel: {
        cooldown: 60,
        cooldown: 10,
        multiplier: 3,
        maxStack: 6,
      },
+11 −6
Original line number Diff line number Diff line
@@ -80,19 +80,22 @@ export class SocketServer {
    // - needs to be exponential (takes longer to aquire more pixels stacked)
    // - convert to config options instead of hard-coded
    setInterval(async () => {
      Logger.debug("Running pixel stacking...");
      const DEBUG = false;

      if (DEBUG) Logger.debug("Running pixel stacking...");
      const redis = await Redis.getClient();
      const sockets = await this.io.local.fetchSockets();

      for (const socket of sockets) {
        const sub = await redis.get(Redis.key("socketToSub", socket.id));
        if (!sub) {
          Logger.warn(`Socket ${socket.id} has no user`);
          if (DEBUG) Logger.warn(`Socket ${socket.id} has no user`);
          continue;
        }

        const user = await User.fromSub(sub);
        if (!user) {
          if (DEBUG)
            Logger.warn(
              `Socket ${socket.id}'s user (${sub}) does not exist in the database`
            );
@@ -116,6 +119,8 @@ export class SocketServer {
          user.pixelStack < getClientConfig().canvas.pixel.maxStack
        ) {
          await user.modifyStack(1);

          if (DEBUG)
            Logger.debug(sub + " has gained another pixel in their stack");
        }
      }