admin-only access

atproto-notifications/src/App.tsx

···
   </div>
 );
 
-function requestPermission(host, setAsking) {
+function requestPermission(host, setAsking, setPermissionError) {
   return async () => {
     setAsking(true);
     let err;
···
         body: JSON.stringify({ sub }),
         credentials: 'include',
       });
-      if (!res.ok) throw res;
+      if (!res.ok) {
+        let content;
+        try {
+          content = (await res.json()).reason;
+        } catch (_) {
+          content = await res.text();
+        }
+        throw content;
+      }
     } catch (e) {
+      setPermissionError(e);
       err = e;
     }
     setAsking(false);
···
   const [user, setUser] = useLocalStorage('spacedust-notif-user', null);
   const [verif, setVerif] = useState(null);
   const [asking, setAsking] = useState(false);
+  const [permissionError, setPermissionError] = useState(null);
 
   const onIdentify = useCallback(async details => {
     setVerif('verifying');
···
         content = <><p>Sorry, failed to verify that identity. please let us know!</p>{content}</>;
       }
     }
-  } else if (notifPerm !== 'granted') {
+  } else if (permissionError !== null || notifPerm !== 'granted') {
     content = (
       <>
         <h3>Step 2: Allow notifications</h3>
         <p>To show notifications we need permission:</p>
         <p>
           <button
-            onClick={requestPermission(host, setAsking)}
+            onClick={requestPermission(host, setAsking, setPermissionError)}
             disabled={asking}
           >
             {asking ? <>Requesting&hellip;</> : <>Request permission</>}
···
         </p>
         {notifPerm === 'denied' ? (
           <p className="detail">Notification permission was denied. You may need to clear the browser setting to try again.</p>
-        ) : (
-          <p className="detail">You can revoke this any time</p>
-        )}
+        ) : permissionError ? (
+            <p className="detail">Sorry, something went wrong: {permissionError}</p>
+          ) : (
+            <p className="detail">You can revoke this any time</p>
+          )
+        }
       </>
     );
   } else {

server/db.js

···
 
     this.#stmt_insert_account = db.prepare(
       `insert into accounts (did)
-       values (?)`);
+       values (?)
+           on conflict do nothing`);
 
     this.#stmt_get_account = db.prepare(
       `select a.first_seen,
···
 
     this.#stmt_insert_push_sub = db.prepare(
       `insert into push_subs (account_did, session, subscription)
-       values (?, ?, ?)`);
+       values (?, ?, ?)
+           on conflict do update
+          set subscription = excluded.subscription`);
 
     this.#stmt_get_all_sub_dids = db.prepare(
       `select distinct account_did

server/index.js

···
   return res.writeHead(200).end('okayyyy');
 };
 
-const handleSubscribe = async (db, req, res, appSecret) => {
+const handleSubscribe = async (db, req, res, appSecret, adminDid) => {
   let info = getAccountCookie(req, res, appSecret);
   if (!info) return res.writeHead(400).end(JSON.stringify({ reason: 'failed to verify cookie signature' }));
   const [did, session] = info;
 
+  // not yet public!!
+  if (did !== adminDid) {
+    res.setHeader('Content-Type', 'application/json');
+    res.writeHead(403);
+
+    return clearAccountCookie(res).end(JSON.stringify({
+      reason: 'the spacedust notifications demo isn\'t public yet!',
+    }));
+  }
+
   const body = await getRequesBody(req);
   const { sub } = JSON.parse(body);
   // addSub('did:plc:z72i7hdynmk6r22z27h6tvur', sub); // DELETEME @bsky.app (DEBUG)
···
   res.end('{"oh": "hi"}');
 };
 
-const requestListener = (secrets, jwks, db) => (req, res) => {
+const requestListener = (secrets, jwks, db, adminDid) => (req, res) => {
   if (req.method === 'GET' && req.url === '/') {
     return handleIndex(req, res, { PUBKEY: secrets.pushKeys.publicKey });
   }
···
   }
   if (req.method === 'POST' && req.url === '/subscribe') {
     res.setHeaders(new Headers(CORS_PERMISSIVE(req)));
-    return handleSubscribe(db, req, res, secrets.appSecret);
+    return handleSubscribe(db, req, res, secrets.appSecret, adminDid);
   }
 
   res.writeHead(200);
···
 }
 
 const main = env => {
+  if (!env.ADMIN_DID) throw new Error('ADMIN_DID is required to run');
+  const adminDid = env.ADMIN_DID;
+
   if (!env.SECRETS_FILE) throw new Error('SECRETS_FILE is required to run');
   const secrets = getOrCreateSecrets(env.SECRETS_FILE);
   webpush.setVapidDetails(
···
   const port = parseInt(env.PORT ?? 8000, 10);
 
   http
-    .createServer(requestListener(secrets, jwks, db))
+    .createServer(requestListener(secrets, jwks, db, adminDid))
     .listen(port, host, () => console.log(`listening at http://${host}:${port}`));
 };