2d:null 2e:["$","title",null,{"children":"Twitch Channel Points | randName() | Observable"}] 33:T66c,redemptions = { if (!Twitch.user || !Twitch.token) return null const pingInterval = 1000 * 60 * 4 const socketPing = JSON.stringify({ type: 'PING' }) const nonce = Math.random().toString(36).slice(2) const topics = [`channel-points-channel-v1.${Twitch.user.id}`] const listenRequest = JSON.stringify({ type: 'LISTEN', nonce, data: { auth_token: Twitch.token, topics }, }) let pulse const ws = new WebSocket('wss://pubsub-edge.twitch.tv') const cleanup = () => { ws.close() if (pulse) clearTimeout(pulse) } const heartbeat = () => { pulse = setTimeout(() => { ws.send(socketPing) heartbeat() }, pingInterval + Math.random() * 100) } ws.addEventListener('open', () => { ws.send(listenRequest) heartbeat() }) invalidation.then(cleanup) const result = await Promise.race([ Promises.delay(10000, false), new Promise((resolve, reject) => { ws.addEventListener('message', (evt) => { const { type, error, ...d } = JSON.parse(evt.data) if (error) { reject(error) } else if (d.nonce !== nonce) { reject('nonce mismatch') } else { resolve(true) } }, { once: true }) }) ]) if (!result) { cleanup() return null } return function () { return Generators.queue((notify) => { const handler = (evt) => { const { type, data } = JSON.parse(evt.data) if (type === 'MESSAGE') notify(JSON.parse(data.message).data) } ws.addEventListener('message', handler) return () => ws.removeEventListener('message', handler) }) } }34:[] 31:{"id":"7b700930dd0928ab","slug":"twitch-channel-points","title":"Twitch Channel Points","thumbnail":"3b53cafb3898b6ec54a349eb6520274a2fbad99a87a38aa27e0a458055460100","access_level":"public","create_time":"$D2020-08-22T07:57:37.921Z","update_time":"$D2021-09-19T06:19:01.800Z","view_time":null,"first_public_time":"$D2020-08-22T08:11:53.193Z","has_unpublished_edits":null,"fork":false,"stars":0,"starred":false,"owner":{"type":"team","id":"af680361d1ea8ba5","login":"randname","name":"randName()","avatar_url":"https://avatars-next.observableusercontent.com/f16c819c73deae04aebd89cd214320d2b848d288cea0ed4487f835cc1b3e9c04","tier":"starter_2024"},"version":123,"publish_version":123,"role":null,"authored":false,"authors":[{"type":"individual","id":"6af62fd51a9b60df","login":"randname","name":"randName()","avatar_url":"https://avatars-next.observableusercontent.com/f16c819c73deae04aebd89cd214320d2b848d288cea0ed4487f835cc1b3e9c04","tier":null}],"members":[{"type":"individual","id":"6af62fd51a9b60df","login":"randname","name":"randName()","avatar_url":"https://avatars-next.observableusercontent.com/f16c819c73deae04aebd89cd214320d2b848d288cea0ed4487f835cc1b3e9c04","tier":null,"role":"editor"}],"comments":[],"custom_thumbnail":false,"trashed":false,"lapsed":null,"subscribed":null,"forks":0,"collection":null,"type":"notebook","body":{"title":"Twitch Channel Points","cells":[{"id":0,"value":"md`# Twitch Channel Points`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":41,"value":"Twitch = create('2rzatipo2rzaefect2l2vfhs7zag7c', ['channel:read:redemptions'])","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":57,"value":"{\n if (!redemptions) return md`\\`Not connected\\``\n yield md`\\`Ready\\``\n for await (const r of redemptions()) {\n const card = redemptionCard(r)\n yield card.display\n await card.wait()\n yield md`\\`Completed\\``\n }\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":113,"value":"redemptionHistory = {\n if (!redemptions) return md``\n const hist = []\n yield hist\n for await (const r of redemptions()) {\n hist.push(r.redemption)\n yield hist\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":97,"value":"function redemptionCard ({ timestamp, redemption }) {\n const at = new Date(timestamp)\n const { id, user, reward, status } = redemption\n const url = `https://twitch.tv/${user.login}`\n const done = html``\n const display = html`

\n ${user.display_name} redeemed \"${reward.title}\"\n ${done}\n

`\n return {\n display,\n wait () {\n return new Promise((resolve) => { done.onclick = resolve })\n },\n }\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":91,"value":"{\n const options = Object.keys(responses).map((k) => md``)\n return html``\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":88,"value":"responses = {\n async function delayOne () {\n await Promises.delay(1000)\n }\n\n async function delayTen () {\n await Promises.delay(10000)\n }\n\n return {\n delayOne,\n delayTen,\n }\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":11,"value":"$33","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":36,"value":"import {create} from \"@randname/twitch\"","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"}],"files":"$W34","stdlib":"1","titling":"auto"}} 32:"$31:body"