[{"_1":2,"_181":-5,"_182":-5},"loaderData",{"_3":4,"_92":93,"_119":120,"_180":-5},"root",{"_5":6,"_33":34,"_59":60,"_90":91},"ctx",{"_7":8,"_18":19,"_20":-5,"_21":22,"_23":24,"_25":26,"_27":26,"_28":26,"_29":30,"_31":32},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5},"sessionClaims","sessionId","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","environmentVariableKeys",[],"user","preferences_keybindings","default","preferences_theme","light","preferences_fixers",false,"preferences_copilot","preferences_selection_ai","preferences_model","claude-3-5-haiku-20241022","notification_count",0,"ENV",{"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56,"_57":58},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","2078ffb5c3fd4042a23ef04cac20c05437737b4a","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","API_URL","https://api.val.town","WORKER_FINGERPRINT","c7de7de11d2fa3884730f0fa9fd384f8","clerkState",{"_61":62},"__internal_clerk_state",{"_63":64,"_65":44,"_66":67,"_68":67,"_69":26,"_70":67,"_71":67,"_72":67,"_73":67,"_74":67,"_75":67,"_76":67,"_77":67,"_78":79,"_88":26,"_89":26},"__clerk_ssr_state",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__signInForceRedirectUrl","__signUpForceRedirectUrl","__signInFallbackRedirectUrl","__signUpFallbackRedirectUrl","__clerk_debug",{"_80":26,"_81":67,"_82":83,"_84":67,"_85":44,"_86":26,"_87":67},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","remixVersion",2,"routes/_app.u.$handle",{"_20":94,"_105":106,"_110":26,"_111":112,"_113":114,"_115":116,"_117":91,"_118":32},{"_95":96,"_97":98,"_99":100,"_101":102,"_103":104},"id","c5b8f616-9b1f-4506-8772-0d32ac3a5609","handle","healeycodes","createdAt",["D",1675347406679],"bio","

","profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJRQ1FyWDdNeGdsc2JvSVBMNE9nY1lMeUswdS5wbmcifQ","links",[107],{"_108":109},"url","http://example.com","isOwned","valCount",16,"likeCount",14,"forkCount",1,"folderCount","projectCount","routes/_app.u.$handle.forks",{"_20":121,"_123":32,"_124":125,"_179":26,"_115":116},{"_95":96,"_97":98,"_99":122,"_101":102,"_103":104},["D",1675347406679],"page","forks",[126],{"_127":128,"_129":130},"valNameId","d16aace0-2d50-49c8-8758-51bdf59e0839","initialData",{"_131":132,"_133":96,"_127":128,"_134":-5,"_110":-5,"_135":136,"_137":-5,"_138":139,"_140":141,"_142":26,"_95":141,"_143":144,"_99":145,"_146":91,"_147":26,"_113":32,"_148":32,"_149":32,"_150":32,"_115":32,"_151":32,"_152":-5,"_20":153,"_154":155,"_161":-7,"_162":163,"_164":-5,"_165":166,"_167":168},"name","firehoseReadMessagesExample","author","parentFolderId","privacy","public","readme","valType","script","currentVersion","5c28df82-d851-4f26-8d2b-898d6bf8c325","legacyPrivate","code","// Initially forked from @lukas.sampleFirehose\nexport let firehoseReadMessagesExample = (async () => {\n const cborx = await import(\"https://deno.land/x/cbor@v1.5.2/index.js\");\n const multiformats = await import(\"npm:multiformats\");\n const uint8arrays = await import(\"npm:uint8arrays\");\n const { z } = await import(\"https://deno.land/x/zod@v3.21.4/mod.ts\");\n const xrpc = await import(\"npm:@atproto/xrpc\");\n const cborCodec = await import(\n \"https://cdn.jsdelivr.net/npm/@ipld/dag-cbor/+esm\"\n );\n const cborEncode = cborCodec.encode;\n enum FrameType {\n Message = 1,\n Error = -1,\n }\n const messageFrameHeader = z.object({\n op: z.literal(FrameType.Message),\n t: z.string().optional(), // Message body type discriminator\n });\n type MessageFrameHeader = z.infer;\n const errorFrameHeader = z.object({\n op: z.literal(FrameType.Error),\n });\n const errorFrameBody = z.object({\n error: z.string(),\n message: z.string().optional(), // Error message\n });\n type ErrorFrameHeader = z.infer;\n type ErrorFrameBody = {\n error: T;\n } & z.infer;\n const frameHeader = z.union([messageFrameHeader, errorFrameHeader]);\n type FrameHeader = z.infer;\n abstract class Frame {\n header: FrameHeader;\n body: unknown;\n get op(): FrameType {\n return this.header.op;\n }\n toBytes(): Uint8Array {\n return uint8arrays.concat([\n cborEncode(this.header),\n cborEncode(this.body),\n ]);\n }\n isMessage(): this is MessageFrame {\n return this.op === FrameType.Message;\n }\n isError(): this is ErrorFrame {\n return this.op === FrameType.Error;\n }\n static fromBytes(bytes: Uint8Array) {\n const decoded = cborDecodeMulti(bytes);\n if (decoded.length > 2) {\n throw new Error(\"Too many CBOR data items in frame\");\n }\n const header = decoded[0];\n let body: unknown = kUnset;\n if (decoded.length > 1) {\n body = decoded[1];\n }\n const parsedHeader = frameHeader.safeParse(header);\n if (!parsedHeader.success) {\n throw new Error(`Invalid frame header: ${parsedHeader.error.message}`);\n }\n if (body === kUnset) {\n throw new Error(\"Missing frame body\");\n }\n const frameOp = parsedHeader.data.op;\n if (frameOp === FrameType.Message) {\n return new MessageFrame(body, {\n type: parsedHeader.data.t,\n });\n }\n else if (frameOp === FrameType.Error) {\n const parsedBody = errorFrameBody.safeParse(body);\n if (!parsedBody.success) {\n throw new Error(\n `Invalid error frame body: ${parsedBody.error.message}`,\n );\n }\n return new ErrorFrame(parsedBody.data);\n }\n else {\n const exhaustiveCheck: never = frameOp;\n throw new Error(`Unknown frame op: ${exhaustiveCheck}`);\n }\n }\n }\n class MessageFrame> extends Frame {\n header: MessageFrameHeader;\n body: T;\n constructor(body: T, opts?: {\n type?: string;\n }) {\n super();\n this.header = opts?.type !== undefined\n ? { op: FrameType.Message, t: opts?.type }\n : { op: FrameType.Message };\n this.body = body;\n }\n get type() {\n return this.header.t;\n }\n }\n class ErrorFrame extends Frame {\n header: ErrorFrameHeader;\n body: ErrorFrameBody;\n constructor(body: ErrorFrameBody) {\n super();\n this.header = { op: FrameType.Error };\n this.body = body;\n }\n get code() {\n return this.body.error;\n }\n get message() {\n return this.body.message;\n }\n }\n const kUnset = Symbol(\"unset\");\n const { CID } = multiformats;\n // add extension for decoding CIDs\n // decoding code taken from $ipld/dag-cbor\n // does not support encoding cids\n cborx.addExtension({\n Class: CID,\n tag: 42,\n encode: () => {\n throw new Error(\"cannot encode cids\");\n },\n decode: (bytes: Uint8Array) => {\n if (bytes[0] !== 0) {\n throw new Error(\"Invalid CID for CBOR tag 42; expected leading 0x00\");\n }\n return CID.decode(bytes.subarray(1)); // ignore leading 0x00\n },\n });\n const cborDecodeMulti = (encoded: Uint8Array): unknown[] => {\n const decoded: unknown[] = [];\n cborx.decodeMultiple(encoded, (value) => {\n decoded.push(value);\n });\n return decoded;\n };\n // byFrame removed, logic moved below\n // byMessage removed, logic moved below\n const socket = new WebSocket(\n \"wss://bsky.social/xrpc/com.atproto.sync.subscribeRepos\",\n );\n socket.addEventListener(\"open\", (event) => {\n console.log(\"socket open\", event);\n });\n socket.addEventListener(\"error\", (event) => {\n throw `socket error ${event}`;\n });\n // Read up to X messages\n const messageLimit = 20;\n // Only read for X milliseconds\n const readForXms = 5000;\n const messages = [];\n await new Promise((res, rej) => {\n setTimeout(() => res(messages), readForXms);\n socket.addEventListener(\"message\", (event) => {\n const reader = new FileReader();\n reader.onload = function () {\n const arrayBuffer = reader.result;\n const uint8Array = new Uint8Array(arrayBuffer);\n const frame = Frame.fromBytes(uint8Array);\n if (frame.isMessage()) {\n messages.push(frame);\n }\n else if (frame.isError()) {\n rej(xrpc.XRPCError(-1, frame.code, frame.message));\n }\n else {\n rej(\n new xrpc.XRPCError(\n xrpc.ResponseType.Unknown,\n undefined,\n \"Unknown frame type\",\n ),\n );\n }\n if (messages.length === messageLimit) {\n res(messages);\n }\n };\n reader.readAsArrayBuffer(event.data);\n });\n });\n console.log(\"number of messages\", messages.length);\n console.log(messages);\n})();",["D",1698082318000],"version","currentUserHasLiked","referenceCount","dependencyCount","commentCount","prCount","mergedPr",{"_97":98,"_103":104},"forkedVal",{"_95":156,"_97":157,"_131":158,"_146":159,"_160":-5},"dde2ecd3-21ae-4a63-8d68-9ed9f144a9b4","lukas","sampleFirehose",27,"prDisabledHint","interval","description","// Initially forked from @lukas.sampleFirehose","latestEvaluation","slug","healeycodes/firehoseReadMessagesExample","versions",[169,173,176],{"_99":170,"_146":91,"_171":172},["D",1698082318000],"n","1",{"_99":174,"_146":116,"_171":175},["D",1687984178000],"2",{"_99":177,"_146":32,"_171":178},["D",1687983892000],"3","hasNext","routes/_app","actionData","errors"]