/** @jsxImportSource npm:hono/jsx */ import { extractValInfo } from "https://esm.town/v/pomdtr/extractValInfo"; import { email } from "https://esm.town/v/std/email?v=12"; import { sqlite } from "https://esm.town/v/stevekrouse/sqlite"; import { Buffer } from "node:buffer"; import { createHmac } from "node:crypto"; import { Hono } from "npm:hono"; const app = new Hono(); const ValTownGroundFloorDeviceId = "D2353438164D"; const ValTownOfficeDeviceId = "CD6F3A810848"; const NYC_TIMEZONE = "America/New_York"; // Define parties with start and end times (in ET) const parties = [ { name: "NYC AI Meetup", start: Temporal.ZonedDateTime.from({ timeZone: NYC_TIMEZONE, year: 2024, month: 10, day: 14, hour: 17, minute: 0, }), end: Temporal.ZonedDateTime.from({ timeZone: NYC_TIMEZONE, year: 2024, month: 10, day: 14, hour: 20, minute: 0, }), }, ]; function getPartyStatus() { const now = Temporal.Now.zonedDateTimeISO(NYC_TIMEZONE); for (const party of parties) { if (Temporal.ZonedDateTime.compare(now, party.start) >= 0 && Temporal.ZonedDateTime.compare(now, party.end) <= 0) { return { active: true, party }; } if (Temporal.ZonedDateTime.compare(now, party.start) < 0) { return { active: false, party, type: "before" }; } if (Temporal.ZonedDateTime.compare(now, party.end) > 0) { return { active: false, party, type: "after" }; } } return { active: false, party: null }; } function formatTimeDifference(target, now) { const diff = target.since(now); const hours = diff.hours; const minutes = diff.minutes % 60; if (hours > 0) { return `${hours} hour${hours > 1 ? "s" : ""} and ${minutes} minute${minutes !== 1 ? "s" : ""}`; } else { return `${minutes} minute${minutes !== 1 ? "s" : ""}`; } } async function switchbotRequest(path, args) { const token = Deno.env.get("SWITCHBOT_TOKEN"); const secret = Deno.env.get("SWITCHBOT_KEY"); const t = Temporal.Now.instant().epochMilliseconds; const nonce = Math.floor(Math.random() * 1000000); const sign = createHmac("sha256", secret) .update(Buffer.from(token + t + nonce, "utf-8")) .digest() .toString("base64"); const response = await fetch(`https://api.switch-bot.com/${path}`, { headers: { "Authorization": token, t, nonce, sign, "Content-Type": "application/json", }, ...args, }); return response.json(); } function botPress(device) { return switchbotRequest(`v1.1/devices/${device}/commands`, { method: "POST", body: JSON.stringify({ "command": "press", "parameter": "default", "commandType": "command", }), }); } const { htmlUrl } = extractValInfo(import.meta.url); function Layout({ children, title }) { return ( {title}

{children}

Built in Val Town

); } function Button({ children }) { return ( ); } function MainPage({ partyName }) { return (

{partyName}

📍 Val Town,{" "} 325 Gold St , Unit 503

); } function ErrorPage({ title, message, backLink = true }) { return (

{title}

{message}

{backLink && (

Back to Buzzer

)} ); } app.get("/", (c) => { const partyName = parties.at(0).name; return c.html(); }); app.post("/open-door", async (c) => { const KEY = new URL(import.meta.url).pathname.split("/").at(-1); const SCHEMA_VERSION = 1; await sqlite.execute(` CREATE TABLE IF NOT EXISTS ${KEY}_buzz_requests_${SCHEMA_VERSION} ( id INTEGER PRIMARY KEY AUTOINCREMENT, timestamp TEXT ) `); const thirtySecondsAgo = Temporal.Now.zonedDateTimeISO(NYC_TIMEZONE).subtract({ seconds: 30 }); const recentRequests = await sqlite.execute( `SELECT COUNT(*) as count FROM ${KEY}_buzz_requests_${SCHEMA_VERSION} WHERE timestamp > ?`, [thirtySecondsAgo.toString()], ); if (recentRequests.rows[0].count > 0) { return c.html( You can only buzz in once every 30 seconds.
Please try again in a moment or email steve@val.town if it's urgent. } />, ); } const partyStatus = getPartyStatus(); if (!partyStatus.active) { email({ subject: "Door tried to be opened outside party hours!" }); const now = Temporal.Now.zonedDateTimeISO(NYC_TIMEZONE); let message; if (partyStatus.type === "before") { const timeUntilStart = formatTimeDifference(partyStatus.party.start, now); message = `Cannot buzz you in until ${ partyStatus.party.start.toLocaleString("en-US", { timeZone: NYC_TIMEZONE, timeStyle: "short" }) } ET (in ${timeUntilStart})`; } else if (partyStatus.type === "after") { message = `Sorry, the party ended at ${ partyStatus.party.end.toLocaleString("en-US", { timeZone: NYC_TIMEZONE, timeStyle: "short" }) } ET`; } else { message = "There is no active party at the moment."; } return c.html(); } try { const now = Temporal.Now.zonedDateTimeISO(NYC_TIMEZONE); await sqlite.execute( `INSERT INTO ${KEY}_buzz_requests_${SCHEMA_VERSION} (timestamp) VALUES (?)`, [now.toString()], ); await botPress(ValTownGroundFloorDeviceId); email({ subject: "Door opened successfully!" }); return c.html(

🎉 Buzzer Activated! 🎉

You've been buzzed in. Welcome!

Please no more than 5 people in the elevator. The stairs work too.

Back to Buzzer

, ); } catch (error) { email({ subject: "Door open fail" }); return c.html(); } }); export default app.fetch;