FOOD & PACKAGE FAIR SHYMKENT 2026

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_105":106,"_107":108},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","omriluz","name","telegram-city-network","path","integration.test.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":32,"_60":-5,"_61":-5,"_62":36,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/omriluz/telegram-city-network/code/integration.test.ts","extension","id","86ef90e0-2115-43d0-8fdd-8a7ea260d604","fileId","d56eedba-b259-11f1-9e6c-1607ee4eb77e","parentId","branchId","6de82370-98e9-41cd-add4-480bf35c921b","branchVersion",30,"latest",true,"createdAt",["D",1789623432773],"version",0,"fileType","script","content","import assert from \"node:assert/strict\";\nimport { cities, type EventData } from \"./core.ts\";\nimport { approve, configuredCity, initialize, preview, publisher, telegram, translateEvent, type TranslationProvider } from \"./engine.ts\";\nimport { allowedSourceUrl, parseCards, parseFoodfair, parseSxodim, readBounded, sourceClient, sources } from \"./sources.ts\";\nimport { withTestStore } from \"./test_support.ts\";\n// Every fixture is stored in a disposable ccn_test__ namespace, never ccn_events.\nconst event: EventData = { id: \"\", source: \"sxodim\", sourceItemId: \"FIXTURE-1\", city: \"shymkent\", url: \"https://example.org/fixture-one\", bookingUrl: null, title: \"FIXTURE concert 12\", venue: \"FIXTURE hall\", address: null, category: \"concert\", date: \"2099-09-18\", endDate: null, start: Date.parse(\"2099-09-18T15:00Z\"), end: null, timezone: \"Asia/Almaty\", price: null, priceText: null, currency: null, eventLanguage: null, age: null, cancelled: false, issues: [] };\nconst metadata = { \"@type\": \"MusicEvent\", name: \"FIXTURE concert\", startDate: \"2099-09-18T20:00\", location: { name: \"FIXTURE hall\", address: { addressLocality: \"Шымкент\", streetAddress: \"FIXTURE Street 1\" } } };\nconst markup = (data: unknown, extra = \"\") => `${extra}`;\nconst card = { url: \"https://sxodim.com/shymkent/event/fixture\", title: \"FIXTURE\", category: \"concert\" };\nawait withTestStore(\"parsing-storage-translation\", async (db, check) => {\n await initialize(db);\n await check(\"JSON-LD city and occurrence parsing\", () => { const rows = parseSxodim(markup(metadata), card, cities.shymkent); assert.equal(rows.length, 1); assert.equal(rows[0].date, \"2099-09-18\"); assert.equal(rows[0].price, null); });\n await check(\"wrong-city event is refused\", () => assert.equal(parseSxodim(markup(metadata), card, cities.astana).length, 0));\n await check(\"recurring date blocks retained separately\", () => assert.equal(parseSxodim(markup(metadata, '

'), card, cities.shymkent).length, 2));\n await check(\"missing year stays unknown\", () => assert.equal(parseSxodim(markup({ ...metadata, startDate: \"18 September\" }), card, cities.shymkent)[0].date, null));\n await check(\"structured cancellation detected\", () => assert.equal(parseSxodim(markup({ ...metadata, eventStatus: \"https://schema.org/EventCancelled\" }), card, cities.shymkent)[0].cancelled, true));\n await check(\"explicit free offer is zero\", () => assert.equal(parseSxodim(markup({ ...metadata, offers: { price: 0, priceCurrency: \"KZT\" } }), card, cities.shymkent)[0].price, 0));\n await check(\"English organizer date order parsed\", () => { const rows = parseFoodfair('FOOD & PACKAGE FAIR SHYMKENT 2026Date: October 8-10, 2026 Location: Shymkent, Korme Ortalygy, N. Nazarbayev Avenue, 12', cities.shymkent); assert.equal(rows[0].date, \"2026-10-08\"); assert.equal(rows[0].endDate, \"2026-10-10\"); assert.equal(rows[0].start, null); });\n await check(\"listing only admits same-city event links\", () => assert.equal(parseCards('FIXTURE No', cities.shymkent).length, 1));\n await check(\"unapproved host rejected before fetch\", () => assert.throws(() => allowedSourceUrl(\"https://evil.example/shymkent\", sources.sxodim, cities.shymkent)));\n await check(\"oversized response bounded\", () => assert.rejects(() => readBounded(new Response(\"x\".repeat(100)), 10)));\n await check(\"robots denial stops source request\", async () => { let calls = 0; const fetcher = (async () => { calls++; return new Response(\"User-agent: *\\nDisallow: /shymkent\\n\"); }) as typeof fetch; await assert.rejects(() => sourceClient(sources.sxodim, cities.shymkent, db, fetcher)(\"https://sxodim.com/shymkent\")); assert.equal(calls, 1); });\n await db.q(\"DELETE FROM ccn_cache\");\n await check(\"external source redirects refused\", async () => { let calls = 0; const fetcher = (async (input: string | URL | Request) => { calls++; return String(input).endsWith(\"robots.txt\") ? new Response(\"\", { status: 404 }) : new Response(null, { status: 302, headers: { location: \"https://evil.example/gate\" } }); }) as typeof fetch; await assert.rejects(() => sourceClient(sources.sxodim, cities.shymkent, db, fetcher)(\"https://sxodim.com/shymkent\")); assert.equal(calls, 2); });\n await check(\"initial ingest persisted\", async () => assert.equal((await db.ingest([event])).inserted, 1));\n await check(\"repeated ingest is unchanged\", async () => { const result = await db.ingest([event]); assert.equal(result.unchanged, 1); assert.equal(result.inserted, 0); });\n let row = (await db.q(\"SELECT * FROM ccn_events WHERE city='shymkent' LIMIT 1\")).rows[0];\n const id = String(row.id);\n await check(\"two sources share canonical event and retain provenance\", async () => { const result = await db.ingest([{ ...event, source: \"foodfair\", sourceItemId: \"FIXTURE-OTHER\", url: \"https://example.org/other\" }]); assert.equal(result.duplicates, 1); assert.equal(Number((await db.q(\"SELECT COUNT(*) AS n FROM ccn_events\")).rows[0].n), 1); assert.equal(Number((await db.q(\"SELECT COUNT(*) AS n FROM ccn_records\")).rows[0].n), 2); });\n await check(\"overlapping runs acquire only one lease\", async () => { const locks = await Promise.all([db.lease(\"fixture-overlap\"), db.lease(\"fixture-overlap\")]); assert.equal(locks.filter(Boolean).length, 1); await db.release(\"fixture-overlap\", locks.find(Boolean)!); });\n await check(\"atomic daily cap under concurrency\", async () => assert.equal((await Promise.all(Array.from({ length: 5 }, () => db.budget(2, \"2099-01-01\")))).filter(Boolean).length, 2));\n await check(\"rate limit enforced\", async () => { assert.equal(await db.rate(\"fixture-rate\", 1, 60000), true); assert.equal(await db.rate(\"fixture-rate\", 1, 60000), false); });\n let calls = 0;\n const provider: TranslationProvider = { name: \"fixture-provider\", translate: async (e) => { calls++; return { value: { title: e.title, description: \"Сынақ концерті\" }, tokens: 7 }; } };\n await check(\"zero cap prevents provider invocation\", async () => { await db.set(\"translation_daily_cap\", \"0\"); assert.equal(await translateEvent(id, db, provider), null); assert.equal(calls, 0); });\n await db.set(\"translation_daily_cap\", \"12\");\n await check(\"translation stored but not approved\", async () => { assert.ok(await translateEvent(id, db, provider)); row = (await db.q(\"SELECT * FROM ccn_events WHERE id=?\", [id])).rows[0]; assert.equal(row.review, \"draft\"); assert.equal(row.approved_hash, null); });\n await check(\"translation content cache prevents another provider call\", async () => { await translateEvent(id, db, provider); assert.equal(calls, 1); });\n await check(\"source permission gates approval\", () => assert.rejects(() => approve(id, String(row.hash), true, true, 0, db)));\n await db.q(\"UPDATE ccn_sources SET permission='approved' WHERE id='shymkent:sxodim'\");\n await check(\"native review checkbox required\", () => assert.rejects(() => approve(id, String(row.hash), false, true, 0, db)));\n await check(\"explicit owner approval works\", async () => { await approve(id, String(row.hash), true, true, 11, db); assert.equal((await db.q(\"SELECT review FROM ccn_events WHERE id=?\", [id])).rows[0].review, \"approved\"); });\n await check(\"source update invalidates approval and translation\", async () => { await db.ingest([{ ...event, price: 6000, currency: \"KZT\" }]); const updated = (await db.q(\"SELECT * FROM ccn_events WHERE id=?\", [id])).rows[0]; assert.equal(updated.review, \"draft\"); assert.equal(updated.translation, null); assert.equal(updated.approved_hash, null); });\n await check(\"provider failure leaves draft blocked\", async () => { assert.equal(await translateEvent(id, db, { name: \"fixture-failure\", translate: async () => { throw new Error(\"fixture outage\"); } }), null); assert.equal((await db.q(\"SELECT translation FROM ccn_events WHERE id=?\", [id])).rows[0].translation, null); });\n await check(\"number-changing provider output rejected\", async () => assert.equal(await translateEvent(id, db, { name: \"fixture-bad\", translate: async () => ({ value: { title: \"Concert 99\", description: \"Concert\" }, tokens: 1 }) }), null));\n await check(\"cancellation propagates without public send\", async () => { await db.ingest([{ ...event, cancelled: true }]); assert.equal(JSON.parse(String((await db.q(\"SELECT json FROM ccn_events WHERE id=?\", [id])).rows[0].json)).cancelled, true); });\n const future = { ...event, date: \"2099-09-19\", start: event.start! + 86400000, sourceItemId: \"FIXTURE-SECOND\", url: \"https://example.org/fixture-two\" };\n await db.ingest([future]);\n await check(\"changed occurrence timing withdraws stale approval for review\", async () => { await db.ingest([{ ...future, start: future.start! + 3600000 }]); const previous = (await db.q(\"SELECT review,json FROM ccn_events WHERE json_extract(json,'$.sourceItemId')='FIXTURE-SECOND' ORDER BY first_seen\")).rows; assert.ok(previous.some((r) => r.review === \"source_review\")); assert.ok(previous.every((r) => !JSON.parse(String(r.json)).cancelled)); });\n await check(\"admin schedule override used by engine\", async () => { await db.set(\"shymkent:publishTime\", \"11:15\"); assert.equal((await configuredCity(\"shymkent\", db)).publishTime, \"11:15\"); });\n const now = Date.now();\n await db.q(\"INSERT INTO ccn_publications(key,city,mode,destination,text,state,created,expires) VALUES ('fixture-delivery','shymkent','private','fixture','fixture','pending',?,?)\", [now, now + 60000]);\n await check(\"publication claim atomic under overlap\", async () => assert.equal((await Promise.all([db.claim(\"fixture-delivery\"), db.claim(\"fixture-delivery\")])).filter(Boolean).length, 1));\n await db.q(\"UPDATE ccn_publications SET claimed_at=? WHERE key='fixture-delivery'\", [now - 180000]);\n await check(\"worker crash during send becomes delivery_unknown\", async () => { await db.recover(); assert.equal((await db.q(\"SELECT state FROM ccn_publications WHERE key='fixture-delivery'\")).rows[0].state, \"delivery_unknown\"); assert.equal(await db.claim(\"fixture-delivery\"), null); });\n await db.q(\"INSERT INTO ccn_publications(key,city,mode,destination,text,state,created,expires) VALUES ('fixture-expired','shymkent','public','fixture','fixture','pending',?,?)\", [now - 60000, now - 1000]);\n await check(\"expired queue never catches up\", async () => { await db.recover(); assert.equal((await db.q(\"SELECT state FROM ccn_publications WHERE key='fixture-expired'\")).rows[0].state, \"expired\"); assert.equal(await db.claim(\"fixture-expired\"), null); });\n await check(\"publisher dry run does not consume queue slots\", async () => { const before = (await db.q(\"SELECT COUNT(*) AS n FROM ccn_publications\")).rows[0].n; assert.equal((await publisher(\"shymkent\", false, db)).status, \"dry_run\"); assert.equal((await db.q(\"SELECT COUNT(*) AS n FROM ccn_publications\")).rows[0].n, before); });\n await check(\"Astana reuses preview engine without activation\", async () => { const result = await preview(\"astana\", true, Date.now(), db); assert.equal(result.city, \"astana\"); assert.equal(cities.astana.enabled, false); assert.equal((await publisher(\"astana\", false, db)).status, \"dry_run\"); });\n await check(\"transport failure is sanitized without exposing token\", async () => { const token = \"12345:fixture_NOT_REAL\"; try { await telegram(\"sendMessage\", token, { chat_id: \"fixture\", text: \"fixture\" }, (async () => { throw new Error(token); }) as typeof fetch); assert.fail(\"must throw\"); } catch (error) { assert.equal((error as Error).message, \"Telegram request unresolved\"); } });\n});\n","deleted",false,"label",[14],"47a79ebc-05ee-454e-983d-7f48a62bccc0",["D",1789621418009],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","City events: Shymkent review pilot, isolated from live Almaty","imageUrl","userId","f5be24e4-c798-4816-91e5-037b60b986f5","pinnedFileId","01a0adbf-b85c-735b-b5fd-9913cdd6d31f","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","7f67379d-2d38-49bd-81ac-2c7f92a739e2","tursoName","47a79ebc05ee454e983d7f48a62bccc0","tursoHostname","47a79ebc05ee454e983d7f48a62bccc0-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789710048837],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_104":100},"org",{"_9":10,"_98":-5,"_99":100,"_55":56,"_101":102,"_103":42},"branch",{"_35":88,"_11":89,"_22":28,"_90":45,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":12,"_97":10},"isOwned",59,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18ycWxkOWxiOE00SkVtZENmRWM4YWxLWTRVUFMifQ","tier","free","canRestrictVals","profileImageUrl","ctx",{"_81":-5,"_138":139,"_140":141,"_142":143,"_144":42,"_145":42,"_146":42,"_147":32,"_148":-5,"_149":-7,"_150":-7,"_151":36,"_152":42,"_153":42,"_154":-5,"_155":42,"_156":42,"_157":42,"_158":-5},"ENV",{"_109":110,"_111":112,"_113":89,"_114":115,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","71c1b20804b3232a7e513be260cfffc1932a9e97","RENDER_GIT_BRANCH","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","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]