Halloween (#2614)

* Halloween db schema

* Show biohazard icon if infected

* Infect users on zap

* Users are immune if item younger than 8 hours exists

* @anon as patient zero

* Fix missing cache update on custom zap

* Add notification if infected

* Change immunity duration to 6 hours

* Add push notification if infected

* Infect inactive users after 36 hours

* Decrease immunity by 1 hour every day

* Fix custom zap without QR code

* Crop SVG and fix alignment

cropped with https://svgcrop.com/

---------

Co-authored-by: Keyan <[email protected]>

Author: ekzyis

api/paidAction/zap.js

@@ -1,6 +1,7 @@
-import { PAID_ACTION_PAYMENT_METHODS, USER_ID } from '@/lib/constants'
+import { HALLOWEEN_IMMUNITY_HOURS, PAID_ACTION_PAYMENT_METHODS, USER_ID } from '@/lib/constants'
 import { msatsToSats, satsToMsats } from '@/lib/format'
-import { notifyZapped } from '@/lib/webPush'
+import { datePivot } from '@/lib/time'
+import { notifyZapped, notifyInfected } from '@/lib/webPush'
 import { getInvoiceableWallets } from '@/wallets/server'
 import { Prisma } from '@prisma/client'
 
@@ -78,9 +79,12 @@ export async function perform ({ invoiceId, sats, id: itemId, ...args }, { me, c
     ]
   })
 
-  const [{ path }] = await tx.$queryRaw`
-    SELECT ltree2text(path) as path FROM "Item" WHERE id = ${itemId}::INTEGER`
-  return { id: itemId, sats, act: 'TIP', path, actIds: acts.map(act => act.id) }
+  const [{ userId, path }] = await tx.$queryRaw`
+    SELECT "userId", ltree2text(path) as path FROM "Item" WHERE id = ${itemId}::INTEGER`
+
+  const immune = await isImmune(userId, { tx })
+
+  return { id: itemId, sats, act: 'TIP', path, immune, actIds: acts.map(act => act.id) }
 }
 
 export async function retry ({ invoiceId, newInvoiceId }, { tx, cost }) {
@@ -216,6 +220,55 @@ export async function onPaid ({ invoice, actIds }, { tx }) {
     SET "bountyPaidTo" = array_remove(array_append(array_remove("bountyPaidTo", bounty.target), bounty.target), NULL)
     FROM bounty
     WHERE "Item".id = bounty.id AND bounty.paid`
+
+  await maybeInfectUser(itemAct, { tx })
+}
+
+async function isImmune (userId, { tx }) {
+  // immunity lasts one hour less every day until a minimum of 1 hour is reached
+  const difficulty = Math.max(1, HALLOWEEN_IMMUNITY_HOURS - daysSinceHalloween())
+  const item = await tx.item.findFirst({
+    where: {
+      userId,
+      createdAt: { gt: datePivot(new Date(), { hours: -difficulty }) }
+    }
+  })
+  return !!item
+}
+
+function daysSinceHalloween () {
+  // return 0 if Halloween has not happened yet else return the days since Halloween
+  const diffTime = new Date().getTime() - new Date('2025-10-31').getTime()
+  return Math.max(0, Math.floor(diffTime / (1000 * 60 * 60 * 24)))
+}
+
+async function maybeInfectUser (itemAct, { tx }) {
+  // We added the 'infected' column to the users table so the query for users can continue
+  // to only fetch columns from the users table. We only use it for display purposes.
+  // The infection table is used to check if a user is infected and store additional information
+  // (who infected who when why).
+
+  const { id, userId: fromId, item: { userId: toId } } = itemAct
+  const infection = await tx.infection.findFirst({ where: { infecteeId: fromId } })
+  if (!infection) {
+    // zapper not infected, so can't infect other user
+    return
+  }
+
+  if (await isImmune(toId, { tx })) {
+    // user is immune because they created an item not too long ago
+    return
+  }
+
+  const count = await tx.$executeRaw`
+    INSERT INTO "Infection" ("itemActId", "infecteeId", "infectorId")
+    VALUES (${id}::INTEGER, ${toId}::INTEGER, ${fromId}::INTEGER)
+    ON CONFLICT ("infecteeId") DO NOTHING`
+  await tx.user.update({ where: { id: toId }, data: { infected: true } })
+
+  if (count > 0) {
+    notifyInfected(toId).catch(console.error)
+  }
 }
 
 export async function nonCriticalSideEffects ({ invoice, actIds }, { models }) {

api/resolvers/notifications.js

@@ -325,6 +325,14 @@ export default {
           ORDER BY "sortTime" DESC
           LIMIT ${LIMIT})`
         )
+        queries.push(
+          `(SELECT id::text, created_at AS "sortTime", 0 as "earnedSats", 'Infection' AS type
+          FROM "Infection"
+          WHERE "infecteeId" = $1
+          AND created_at < $2
+          ORDER BY "sortTime" DESC
+          LIMIT ${LIMIT})`
+        )
         for (const type of ['HORSE', 'GUN']) {
           const gqlType = type.charAt(0) + type.slice(1).toLowerCase()
           queries.push(

api/resolvers/user.js

@@ -506,6 +506,19 @@ export default {
           foundNotes()
           return true
         }
+
+        const infection = await models.infection.findFirst({
+          where: {
+            infecteeId: me.id,
+            createdAt: {
+              gt: lastChecked
+            }
+          }
+        })
+        if (infection) {
+          foundNotes()
+          return true
+        }
       }
 
       const subStatus = await models.sub.findFirst({

api/typeDefs/item.js

@@ -32,6 +32,7 @@ export default gql`
     sats: Int!
     path: String
     act: String!
+    immune: Boolean
   }
 
   type ItemAct {

api/typeDefs/notifications.js

@@ -175,11 +175,17 @@ export default gql`
     sortTime: Date!
   }
 
+  type Infection {
+    id: ID!
+    sortTime: Date!
+  }
+
   union Notification = Reply | Votification | Mention
     | Invitification | Earn | JobChanged | InvoicePaid | WithdrawlPaid | Referral
     | FollowActivity | ForwardedVotification | Revenue | SubStatus
     | TerritoryPost | TerritoryTransfer | Reminder | ItemMention | Invoicification
     | ReferralReward | CowboyHat | NewHorse | LostHorse | NewGun | LostGun
+    | Infection
 
   type Notifications {
     lastChecked: Date

api/typeDefs/user.js

@@ -217,6 +217,7 @@ export default gql`
     streak: Int
     gunStreak: Int
     horseStreak: Int
+    infected: Boolean
     hasSendWallet: Boolean
     hasRecvWallet: Boolean
     hideWalletRecvPrompt: Boolean

components/badge.js

@@ -6,6 +6,7 @@ import AnonIcon from '@/svgs/spy-fill.svg'
 import GunIcon from '@/svgs/revolver.svg'
 import HorseIcon from '@/svgs/horse.svg'
 import BotIcon from '@/svgs/robot-2-fill.svg'
+import BioHazardIcon from '@/svgs/biohazard.svg'
 import { numWithUnits } from '@/lib/format'
 import { USER_ID } from '@/lib/constants'
 import classNames from 'classnames'
@@ -47,6 +48,13 @@ export default function Badges ({ user, badge, bot, className = 'ms-1', badgeCla
     })
   }
 
+  if (user.optional.infected) {
+    badges.push({
+      icon: BioHazardIcon,
+      overlayText: 'infected'
+    })
+  }
+
   if (bot) {
     badges = [{
       icon: BotIcon,

components/item-act.js

@@ -1,6 +1,7 @@
 import Button from 'react-bootstrap/Button'
 import InputGroup from 'react-bootstrap/InputGroup'
 import React, { useState, useRef, useEffect, useCallback } from 'react'
+import gql from 'graphql-tag'
 import { Form, Input, SubmitButton } from './form'
 import { useMe } from './me'
 import UpBolt from '@/svgs/bolt.svg'
@@ -110,10 +111,11 @@ export default function ItemAct ({ onClose, item, act = 'TIP', step, children, a
       }
     }
 
-    const onPaid = () => {
+    const onPaid = (cache, { data } = {}) => {
       animate()
       onClose?.()
       if (!me) setItemMeAnonSats({ id: item.id, amount })
+      if (cache && data) infectOnPaid(cache, { me, data })
     }
 
     const closeImmediately = hasSendWallet || me?.privates?.sats > Number(amount)
@@ -133,13 +135,16 @@ export default function ItemAct ({ onClose, item, act = 'TIP', step, children, a
             act: {
               __typename: 'ItemActPaidAction',
               result: {
-                id: item.id, sats: Number(amount), act, path: item.path
+                id: item.id, sats: Number(amount), immune: true, act, path: item.path
               }
             }
           }
         : undefined,
       // don't close modal immediately because we want the QR modal to stack
-      onPaid: closeImmediately ? undefined : onPaid
+      // but still trigger halloween infection
+      onPaid: closeImmediately
+        ? (cache, { data }) => infectOnPaid(cache, { me, data })
+        : onPaid
     })
     if (error) throw error
     addCustomTip(Number(amount))
@@ -292,6 +297,7 @@ export function useAct ({ query = ACT_MUTATION, ...options } = {}) {
       if (!response) return
       updateAncestors(cache, response)
       options?.onPaid?.(cache, { data })
+      infectOnPaid(cache, { data, me })
     }
   })
   return act
@@ -310,7 +316,7 @@ export function useZap () {
     const sats = nextTip(meSats, { ...me?.privates })
 
     const variables = { id: item.id, sats, act: 'TIP', hasSendWallet }
-    const optimisticResponse = { act: { __typename: 'ItemActPaidAction', result: { path: item.path, ...variables } } }
+    const optimisticResponse = { act: { __typename: 'ItemActPaidAction', result: { path: item.path, immune: true, ...variables } } }
 
     try {
       await abortSignal.pause({ me, amount: sats })
@@ -372,3 +378,34 @@ const zapUndo = async (signal, amount) => {
     }, ZAP_UNDO_DELAY_MS)
   })
 }
+
+const infectOnPaid = (cache, { data, me }) => {
+  const { act: { result } } = data
+
+  // anon is patient zero and therefore always infected
+  const infected = !me || me.optional.infected
+  if (!infected || result.immune) {
+    return
+  }
+
+  const itemId = Number(result.path.split('.').pop())
+  const item = cache.readFragment({
+    id: `Item:${itemId}`,
+    fragment: gql`
+      fragment InfectOnPaidItemFields on Item {
+        user {
+          id
+        }
+      }`
+  })
+  cache.writeFragment({
+    id: `User:${item.user.id}`,
+    fragment: gql`
+      fragment InfectOnPaidUserFields on User {
+        optional {
+          infected
+        }
+      }`,
+    data: { optional: { infected: true } }
+  })
+}

components/notifications.js

@@ -45,6 +45,7 @@ import HolsterIcon from '@/svgs/holster.svg'
 import SaddleIcon from '@/svgs/saddle.svg'
 import CCInfo from './info/cc'
 import { useMe } from './me'
+import BioHazardIcon from '@/svgs/biohazard.svg'
 
 function Notification ({ n, fresh }) {
   const type = n.__typename
@@ -61,6 +62,7 @@ function Notification ({ n, fresh }) {
         (type === 'CowboyHat' && <CowboyHat n={n} />) ||
         (['NewHorse', 'LostHorse'].includes(type) && <Horse n={n} />) ||
         (['NewGun', 'LostGun'].includes(type) && <Gun n={n} />) ||
+        (type === 'Infection' && <Infection n={n} />) ||
         (type === 'Votification' && <Votification n={n} />) ||
         (type === 'ForwardedVotification' && <ForwardedVotification n={n} />) ||
         (type === 'Mention' && <Mention n={n} />) ||
@@ -167,7 +169,7 @@ const defaultOnClick = n => {
   if (type === 'WithdrawlPaid') return { href: `/withdrawals/${n.id}` }
   if (type === 'Referral') return { href: '/referrals/month' }
   if (type === 'ReferralReward') return { href: '/referrals/month' }
-  if (['CowboyHat', 'NewHorse', 'LostHorse', 'NewGun', 'LostGun'].includes(type)) return {}
+  if (['CowboyHat', 'NewHorse', 'LostHorse', 'NewGun', 'LostGun', 'Infection'].includes(type)) return {}
   if (type === 'TerritoryTransfer') return { href: `/~${n.sub.name}` }
 
   if (!n.item) return {}
@@ -240,6 +242,22 @@ function Gun ({ n }) {
   )
 }
 
+function Infection ({ n }) {
+  // TODO: use random blurbs?
+  return (
+    <div className='d-flex'>
+      <BioHazardIcon className='fill-grey mx-1' width={40} height={40} />
+      <div className='ms-2'>
+        <NoteHeader big>
+          you have been bitten by a zombie
+          <small className='text-muted ms-1 fw-normal' suppressHydrationWarning>{timeSince(new Date(n.sortTime))}</small>
+        </NoteHeader>
+        <div><small style={{ lineHeight: '140%', display: 'inline-block' }}>You're feeling cold and clammy and you have a sudden desire to zap everyone ...</small></div>
+      </div>
+    </div>
+  )
+}
+
 function EarnNotification ({ n }) {
   const time = n.minSortTime === n.sortTime ? dayMonthYear(new Date(n.minSortTime)) : `${dayMonthYear(new Date(n.minSortTime))} to ${dayMonthYear(new Date(n.sortTime))}`
 

fragments/comments.js

@@ -7,6 +7,7 @@ const STREAK_FIELDS = gql`
       streak
       hasSendWallet
       hasRecvWallet
+      infected
     }
   }
 `