} participant id or empty
+ */
+async function decodeParticipantIdFromImage(buffer) {
+ if (!buffer || !buffer.length) return '';
+ let Jimp;
+ try {
+ Jimp = require('jimp');
+ } catch (err) {
+ console.warn('[badgeQr] jimp not installed', err.message);
+ return '';
+ }
+ try {
+ const image = await Jimp.read(buffer);
+ const scan = (img) => {
+ const { data, width, height } = img.bitmap;
+ return jsQR(new Uint8ClampedArray(data), width, height);
+ };
+ let code = scan(image);
+ if (!code || !code.data) {
+ image.invert();
+ code = scan(image);
+ }
+ if (!code || !code.data) return '';
+ return parseParticipantQrPayload(code.data);
+ } catch (err) {
+ console.warn('[badgeQr] decode failed', err.message);
+ return '';
+ }
+}
+
+module.exports = {
+ parseParticipantQrPayload,
+ decodeParticipantIdFromImage,
+};
diff --git a/src/utils/bedrock.js b/src/utils/bedrock.js
new file mode 100644
index 0000000..be41f75
--- /dev/null
+++ b/src/utils/bedrock.js
@@ -0,0 +1,159 @@
+const {
+ BedrockRuntimeClient,
+ ConverseCommand,
+} = require('@aws-sdk/client-bedrock-runtime');
+
+const DEFAULT_ROUTER_MODEL_ID = 'amazon.nova-micro-v1:0';
+const DEFAULT_CALL2_MODEL_ID = 'anthropic.claude-3-haiku-20240307-v1:0';
+
+function getRegion() {
+ return (
+ process.env.BEDROCK_REGION ||
+ process.env.AWS_DEFAULT_REGION ||
+ process.env.AWS_REGION ||
+ 'ap-south-1'
+ );
+}
+
+function getRouterModelId() {
+ return process.env.BEDROCK_ROUTER_MODEL_ID || DEFAULT_ROUTER_MODEL_ID;
+}
+
+function getCall2ModelId() {
+ return process.env.BEDROCK_CALL2_MODEL_ID || DEFAULT_CALL2_MODEL_ID;
+}
+
+/**
+ * Nova models in APAC often need inference profile IDs (apac.*) instead of foundation model IDs.
+ * Anthropic / other foundation model IDs are left unchanged.
+ */
+function resolveModelId(modelId, region = getRegion()) {
+ const id = String(modelId || '').trim();
+ if (!id || id.startsWith('arn:aws:bedrock:')) return id;
+ if (/^(us|eu|apac)\./.test(id)) return id;
+ if (id.startsWith('anthropic.')) return id;
+
+ const mode = String(process.env.BEDROCK_USE_INFERENCE_PROFILES ?? 'auto').toLowerCase();
+ if (mode === 'false' || mode === '0' || mode === 'no') return id;
+
+ if (id.startsWith('amazon.nova-') && String(region).startsWith('ap-')) {
+ return `apac.${id}`;
+ }
+ return id;
+}
+
+function createClient(region = getRegion()) {
+ const config = { region };
+ if (process.env.AWS_ACCESS_KEY_ID && process.env.AWS_SECRET_ACCESS_KEY) {
+ config.credentials = {
+ accessKeyId: process.env.AWS_ACCESS_KEY_ID,
+ secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY,
+ ...(process.env.AWS_SESSION_TOKEN
+ ? { sessionToken: process.env.AWS_SESSION_TOKEN }
+ : {}),
+ };
+ }
+ return new BedrockRuntimeClient(config);
+}
+
+function responseText(response) {
+ return (
+ response.output?.message?.content
+ ?.map((block) => block.text)
+ .filter(Boolean)
+ .join('\n') || ''
+ );
+}
+
+function isLlmLogEnabled() {
+ const v = String(process.env.BEDROCK_LOG_LLM || '').toLowerCase();
+ return v === 'true' || v === '1' || v === 'yes';
+}
+
+function messageTexts(messages) {
+ if (!Array.isArray(messages)) return [];
+ return messages.map((m) => ({
+ role: m?.role,
+ text: (Array.isArray(m?.content) ? m.content : [])
+ .map((b) => b?.text || '')
+ .filter(Boolean)
+ .join('\n'),
+ }));
+}
+
+/**
+ * @param {import('@aws-sdk/client-bedrock-runtime').BedrockRuntimeClient} client
+ * @param {string} modelId
+ * @param {{ system?: string, messages: object[], inferenceConfig?: object, logLabel?: string }} opts
+ */
+async function converse(client, modelId, opts) {
+ const { system, messages, inferenceConfig, logLabel } = opts;
+ const region = getRegion();
+ const resolvedModelId = resolveModelId(modelId, region);
+ const systemBlocks = system ? [{ text: system }] : undefined;
+ const mergedInferenceConfig = {
+ maxTokens: 400,
+ temperature: 0,
+ topP: 0.1,
+ ...inferenceConfig,
+ };
+ const label = logLabel || 'converse';
+ const shouldLog = Boolean(logLabel) || isLlmLogEnabled();
+ const startedAt = Date.now();
+
+ if (shouldLog) {
+ console.log(`[bedrock][${label}][request]`, {
+ region,
+ modelId: resolvedModelId,
+ requestedModelId: modelId !== resolvedModelId ? modelId : undefined,
+ inferenceConfig: mergedInferenceConfig,
+ system,
+ messages: messageTexts(messages),
+ });
+ }
+
+ try {
+ const response = await client.send(
+ new ConverseCommand({
+ modelId: resolvedModelId,
+ ...(systemBlocks ? { system: systemBlocks } : {}),
+ messages,
+ inferenceConfig: mergedInferenceConfig,
+ }),
+ );
+
+ if (shouldLog) {
+ console.log(`[bedrock][${label}][response]`, {
+ modelId: resolvedModelId,
+ latencyMs: Date.now() - startedAt,
+ usage: response.usage || null,
+ stopReason: response.stopReason || null,
+ text: responseText(response),
+ });
+ }
+
+ return response;
+ } catch (err) {
+ if (shouldLog) {
+ console.error(`[bedrock][${label}][error]`, {
+ modelId: resolvedModelId,
+ latencyMs: Date.now() - startedAt,
+ name: err?.name || err?.Code || 'Error',
+ message: err?.message || String(err),
+ });
+ }
+ throw err;
+ }
+}
+
+module.exports = {
+ DEFAULT_ROUTER_MODEL_ID,
+ DEFAULT_CALL2_MODEL_ID,
+ getRegion,
+ getRouterModelId,
+ getCall2ModelId,
+ resolveModelId,
+ createClient,
+ converse,
+ responseText,
+};
diff --git a/src/utils/call2Context.js b/src/utils/call2Context.js
new file mode 100644
index 0000000..5b8bca7
--- /dev/null
+++ b/src/utils/call2Context.js
@@ -0,0 +1,664 @@
+/**
+ * Compact Call 2 LLM context: drop nulls/empties/duplicates.
+ * Full session objects stay in memory for card building.
+ */
+
+const DETAIL_INTENTS = new Set(['agenda_session_details', 'agenda_download_materials']);
+
+function isEmpty(value) {
+ if (value == null) return true;
+ if (typeof value === 'string') return !value.trim();
+ if (Array.isArray(value)) return value.length === 0;
+ if (typeof value === 'object') return Object.keys(value).length === 0;
+ return false;
+}
+
+function omitEmpty(obj) {
+ if (!obj || typeof obj !== 'object' || Array.isArray(obj)) return obj;
+ const out = {};
+ for (const [k, v] of Object.entries(obj)) {
+ if (isEmpty(v)) continue;
+ out[k] = v;
+ }
+ return out;
+}
+
+function compactEntities(entities) {
+ return omitEmpty(entities && typeof entities === 'object' ? entities : {});
+}
+
+function slimTrack(track) {
+ if (!track) return undefined;
+ if (typeof track === 'string') return track;
+ const name = String(track.name || '').trim();
+ const hall = String(track.hall || '').trim();
+ if (!name && !hall) return undefined;
+ return hall ? `${name} · ${hall}` : name || hall;
+}
+
+function slimSpeakers(speakers) {
+ if (!Array.isArray(speakers) || !speakers.length) return undefined;
+ const names = speakers
+ .map((sp) => (typeof sp === 'string' ? sp : sp?.name))
+ .map((n) => String(n || '').trim())
+ .filter(Boolean)
+ .slice(0, 4);
+ return names.length ? names : undefined;
+}
+
+function formatTopicDuration(duration) {
+ const raw = String(duration || '').trim();
+ if (!raw) return '';
+ const match = raw.match(/^(\d+(?:\s*\+\s*\d+)?)\s*(m|min|mins|minutes)?$/i);
+ if (match) return `${match[1].replace(/\s+/g, '')}m`;
+ return raw;
+}
+
+function slimTopics(topics) {
+ if (!Array.isArray(topics) || !topics.length) return undefined;
+ const lines = topics
+ .map((t) => {
+ if (!t) return null;
+ if (typeof t === 'string') return t.trim() || null;
+ const title = String(t.title || '').trim();
+ if (!title) return null;
+ const dur = formatTopicDuration(t.duration);
+ const role = String(t.role || '').trim();
+ let line = title;
+ if (dur) line += ` (${dur})`;
+ if (role) line += ` · ${role}`;
+ return line;
+ })
+ .filter(Boolean)
+ .slice(0, 8);
+ return lines.length ? lines : undefined;
+}
+
+function slimResources(resources) {
+ if (!Array.isArray(resources) || !resources.length) return undefined;
+ const rows = resources
+ .map((r) => {
+ const url = String(r?.url || '').trim();
+ if (!url) return null;
+ return omitEmpty({
+ name: String(r.name || 'Resource').trim().slice(0, 80),
+ url: url.slice(0, 300),
+ });
+ })
+ .filter(Boolean)
+ .slice(0, 6);
+ return rows.length ? rows : undefined;
+}
+
+function slimSessionForLlm(session, intent) {
+ if (!session) return null;
+ const detail = DETAIL_INTENTS.has(intent);
+
+ return omitEmpty({
+ id: session.id,
+ title: session.title,
+ when: session.timeRangeLocal || null,
+ track: slimTrack(session.track),
+ type: detail ? session.type || null : null,
+ speakers: slimSpeakers(session.speakers),
+ // Always include topics for detail intents so Call 2 can match by topic
+ topics: detail ? slimTopics(session.topics) : undefined,
+ resources: intent === 'agenda_download_materials' ? slimResources(session.resources) : undefined,
+ });
+}
+
+function slimConflicts(conflicts) {
+ if (!Array.isArray(conflicts) || !conflicts.length) return undefined;
+ return conflicts.slice(0, 12).map((c) =>
+ omitEmpty({
+ a: omitEmpty({
+ id: c?.a?.id,
+ title: c?.a?.title,
+ when: c?.a?.timeRangeLocal || null,
+ }),
+ b: omitEmpty({
+ id: c?.b?.id,
+ title: c?.b?.title,
+ when: c?.b?.timeRangeLocal || null,
+ }),
+ }),
+ );
+}
+
+function slimTracksList(tracks) {
+ if (!Array.isArray(tracks) || !tracks.length) return undefined;
+ return tracks
+ .map((t) => slimTrack(t))
+ .filter(Boolean)
+ .slice(0, 30);
+}
+
+/**
+ * Build compact DATA for the LLM. Full `data` is still used for cards.
+ * @param {object} data full fetchAgendaData result
+ * @param {string} intent
+ */
+function slimDataForLlm(data, intent) {
+ const src = data && typeof data === 'object' ? data : {};
+ const sessions = Array.isArray(src.sessions)
+ ? src.sessions.map((s) => slimSessionForLlm(s, intent)).filter(Boolean)
+ : [];
+
+ // Always keep sessions (even []) so the model cannot miss an empty personal schedule.
+ return {
+ ...omitEmpty({
+ now: src.nowLocal || src.now || null,
+ tz: src.timeZone || 'Asia/Kolkata',
+ note: src.note || null,
+ day: src.query?.day || null,
+ trackQuery: src.trackQuery || null,
+ speakerQuery: src.speakerQuery || null,
+ query: src.query ? omitEmpty(src.query) : null,
+ tracks: slimTracksList(src.tracks),
+ conflicts: slimConflicts(src.conflicts),
+ }),
+ sessions,
+ };
+}
+
+/**
+ * Compact venue DATA for Call 2.
+ * @param {object} data fetchVenueData result
+ */
+function slimVenueDataForLlm(data) {
+ const src = data && typeof data === 'object' ? data : {};
+ const faqs = Array.isArray(src.faqs)
+ ? src.faqs
+ .map((f) => omitEmpty({ q: f.q || f.question || null, a: f.a || f.answer || null }))
+ .filter((f) => f.q && f.a)
+ .slice(0, 10)
+ : [];
+ const places = Array.isArray(src.places)
+ ? src.places
+ .map((p) =>
+ omitEmpty({
+ id: p.id,
+ name: p.name || null,
+ address: p.address || null,
+ rating: p.rating != null ? p.rating : null,
+ distance: p.distance != null ? p.distance : null,
+ }),
+ )
+ .filter((p) => p.id && p.name)
+ .slice(0, 8)
+ : [];
+
+ // Keep instructional notes out of the payload when allowGeneralTravel is set —
+ // models sometimes echo DATA.note as the user-facing message — unless
+ // keepNoteWithGeneralTravel (transport allow-list must still be visible).
+ const includeNote =
+ src.note && (!src.allowGeneralTravel || src.keepNoteWithGeneralTravel);
+
+ const mapMedia = src.mapMedia && src.mapMedia.url
+ ? omitEmpty({
+ name: src.mapMedia.name || 'Venue floor plan',
+ mediaType: src.mapMedia.mediaType || null,
+ available: true,
+ })
+ : null;
+
+ const transportModes =
+ src.transportModes && src.transportModes.enforce
+ ? {
+ enforce: true,
+ allowed: Array.isArray(src.transportModes.allowed)
+ ? src.transportModes.allowed.slice(0, 8)
+ : [],
+ notAllowed: Array.isArray(src.transportModes.notAllowed)
+ ? src.transportModes.notAllowed.slice(0, 8)
+ : [],
+ }
+ : null;
+
+ return omitEmpty({
+ eventName: src.eventName || null,
+ location: src.location || null,
+ origin: src.origin || null,
+ allowGeneralTravel: src.allowGeneralTravel ? true : null,
+ note: includeNote ? src.note : null,
+ fallback: src.fallback || null,
+ faqs: faqs.length ? faqs : undefined,
+ transportModes,
+ mapMedia,
+ halls: Array.isArray(src.halls) && src.halls.length ? src.halls.slice(0, 20) : undefined,
+ rooms: Array.isArray(src.rooms) && src.rooms.length ? src.rooms.slice(0, 25) : undefined,
+ places: places.length ? places : undefined,
+ });
+}
+
+/**
+ * Compact ticket DATA for Call 2.
+ * @param {object} data fetchTicketData result
+ */
+function slimTicketDataForLlm(data) {
+ const src = data && typeof data === 'object' ? data : {};
+ const receipt = src.receipt && typeof src.receipt === 'object'
+ ? omitEmpty({
+ kind: src.receipt.kind || null,
+ status: src.receipt.status || null,
+ ticketName: src.receipt.ticketName || null,
+ amount: src.receipt.amountLabel || null,
+ orderId: src.receipt.orderId || null,
+ paymentId: src.receipt.paymentId || null,
+ date: src.receipt.date || null,
+ purchaserEmail: src.receipt.purchaserEmail || null,
+ attendees: Array.isArray(src.receipt.attendees)
+ ? src.receipt.attendees.slice(0, 8)
+ : undefined,
+ quote: src.receipt.quote || null,
+ })
+ : null;
+
+ const faqs = Array.isArray(src.faqs)
+ ? src.faqs
+ .map((f) =>
+ omitEmpty({
+ q: f.q || null,
+ a: f.a || null,
+ }),
+ )
+ .filter((f) => f.a)
+ .slice(0, 6)
+ : [];
+ const contact = src.contact && typeof src.contact === 'object'
+ ? omitEmpty({
+ email: src.contact.email || null,
+ phone: src.contact.phone || null,
+ detail: src.contact.detail || null,
+ text: src.contact.text || null,
+ })
+ : null;
+ const tickets = Array.isArray(src.tickets)
+ ? src.tickets
+ .map((t) =>
+ omitEmpty({
+ name: t.name || null,
+ price: t.price || null,
+ }),
+ )
+ .filter((t) => t.name)
+ .slice(0, 8)
+ : [];
+ const hideEventName = src.intent === 'ticket_how_to_register';
+
+ return omitEmpty({
+ eventName: hideEventName ? null : src.eventName || null,
+ found: src.found === false ? false : src.found ? true : null,
+ policy: src.policy || null,
+ note: hideEventName ? null : src.note || null,
+ registrationLinks: Array.isArray(src.registrationLinks)
+ ? src.registrationLinks
+ .map((l) =>
+ omitEmpty({
+ label: l.label || null,
+ url: l.url || null,
+ }),
+ )
+ .filter((l) => l.url)
+ .slice(0, 8)
+ : undefined,
+ contact: contact && (contact.email || contact.phone || contact.text) ? contact : undefined,
+ faqs: faqs.length ? faqs : undefined,
+ tickets: tickets.length ? tickets : undefined,
+ emailSent: src.emailSent === true ? true : src.emailSent === false ? false : null,
+ emailTo: src.emailTo || null,
+ emailError: src.emailError || null,
+ attendee: src.attendee
+ ? omitEmpty({
+ name: src.attendee.name || null,
+ email: src.attendee.email || null,
+ })
+ : null,
+ membership: src.membership
+ ? omitEmpty({
+ status: src.membership.statusLabel || src.membership.status || null,
+ checkedIn: src.membership.checkedIn ? true : null,
+ registrationDate: src.membership.registrationDate || null,
+ })
+ : null,
+ ticket: src.ticket
+ ? omitEmpty({
+ name: src.ticket.name || null,
+ price: src.ticket.basePriceMajor != null
+ ? `${src.ticket.currency || 'INR'} ${src.ticket.basePriceMajor}`
+ : null,
+ })
+ : null,
+ payment: src.payment
+ ? omitEmpty({
+ status: src.payment.status || null,
+ amount: src.payment.amount != null
+ ? `${src.payment.currency || 'INR'} ${src.payment.amount}`
+ : null,
+ })
+ : null,
+ qr: src.qr
+ ? omitEmpty({
+ available: Boolean(src.qr.available),
+ })
+ : null,
+ receipt: receipt && Object.keys(receipt).length ? receipt : null,
+ });
+}
+
+/**
+ * Compact speaker DATA for Call 2.
+ * @param {object} data fetchSpeakerData result
+ */
+function slimSpeakerDataForLlm(data) {
+ const src = data && typeof data === 'object' ? data : {};
+ const isList = Boolean(src.isSpeakerList);
+ const speakerCap = isList ? 24 : 4;
+ const bioCap = isList ? 160 : 800;
+ const speakers = Array.isArray(src.speakers)
+ ? src.speakers
+ .map((s) =>
+ omitEmpty({
+ id: s.id,
+ name: s.name || null,
+ title: s.title || null,
+ organizationName: s.organizationName || null,
+ speakerRole: s.speakerRole || null,
+ bio: s.bio ? String(s.bio).slice(0, bioCap) : null,
+ expertise:
+ !isList && Array.isArray(s.expertise) && s.expertise.length
+ ? s.expertise.slice(0, 8)
+ : undefined,
+ socialLinks:
+ !isList && s.socialLinks
+ ? omitEmpty({
+ linkedin: s.socialLinks.linkedin || null,
+ twitter: s.socialLinks.twitter || null,
+ website: s.socialLinks.website || null,
+ })
+ : undefined,
+ isPublic: s.isPublic === false ? false : true,
+ profileVisibility: s.profileVisibility || null,
+ }),
+ )
+ .filter((s) => s.id && s.name)
+ .slice(0, speakerCap)
+ : [];
+
+ const candidates = Array.isArray(src.candidates)
+ ? src.candidates
+ .map((c) =>
+ omitEmpty({
+ id: c.id,
+ name: c.name || null,
+ title: c.title || null,
+ organizationName: c.organizationName || null,
+ }),
+ )
+ .filter((c) => c.name)
+ .slice(0, 8)
+ : [];
+
+ const sessionSource =
+ src.intent === 'speaker_meet_and_greet' && Array.isArray(src.meetSessions) && src.meetSessions.length
+ ? src.meetSessions
+ : src.sessions;
+
+ const sessions = Array.isArray(sessionSource)
+ ? sessionSource
+ .map((s) =>
+ omitEmpty({
+ id: s.id,
+ title: s.title || null,
+ when: s.timeRangeLocal || null,
+ track: s.track?.name || (typeof s.track === 'string' ? s.track : null),
+ type: s.type || null,
+ }),
+ )
+ .filter((s) => s.id && s.title)
+ .slice(0, 12)
+ : [];
+
+ return omitEmpty({
+ speakerQuery: src.speakerQuery || null,
+ isSpeakerList: isList ? true : null,
+ needsClarification: src.needsClarification ? true : null,
+ note: src.note || null,
+ speakers: speakers.length ? speakers : undefined,
+ candidates: candidates.length ? candidates : undefined,
+ sessions: !isList && sessions.length ? sessions : undefined,
+ meetSessionCount:
+ !isList && Array.isArray(src.meetSessions) && src.meetSessions.length
+ ? src.meetSessions.length
+ : undefined,
+ });
+}
+
+/**
+ * Compact exhibitor DATA for Call 2.
+ * @param {object} data fetchExhibitorData result
+ */
+function slimExhibitorDataForLlm(data) {
+ const src = data && typeof data === 'object' ? data : {};
+ const isList = Boolean(src.isExhibitorList);
+ const exhibitorCap = isList ? 24 : 4;
+ const descCap = isList ? 120 : 500;
+ const exhibitors = Array.isArray(src.exhibitors)
+ ? src.exhibitors
+ .map((e) =>
+ omitEmpty({
+ id: e.id,
+ name: e.name || null,
+ boothNumber: e.boothNumber || null,
+ hall: e.hall || null,
+ category: e.category || null,
+ shortDescription: e.shortDescription
+ ? String(e.shortDescription).slice(0, descCap)
+ : null,
+ description:
+ !isList && e.description ? String(e.description).slice(0, descCap) : null,
+ products:
+ Array.isArray(e.products) && e.products.length
+ ? e.products.slice(0, isList ? 4 : 10)
+ : undefined,
+ website: e.website || null,
+ socialLinks:
+ !isList && e.socialLinks
+ ? omitEmpty({
+ linkedin: e.socialLinks.linkedin || null,
+ twitter: e.socialLinks.twitter || null,
+ instagram: e.socialLinks.instagram || null,
+ website: e.socialLinks.website || null,
+ })
+ : undefined,
+ isFeatured: e.isFeatured ? true : null,
+ }),
+ )
+ .filter((e) => e.id && e.name)
+ .slice(0, exhibitorCap)
+ : [];
+
+ const candidates = Array.isArray(src.candidates)
+ ? src.candidates
+ .map((c) =>
+ omitEmpty({
+ id: c.id,
+ name: c.name || null,
+ boothNumber: c.boothNumber || null,
+ hall: c.hall || null,
+ category: c.category || null,
+ }),
+ )
+ .filter((c) => c.name)
+ .slice(0, 8)
+ : [];
+
+ const faqs = Array.isArray(src.faqs)
+ ? src.faqs
+ .map((f) =>
+ omitEmpty({
+ q: f.q || null,
+ a: f.a || null,
+ }),
+ )
+ .filter((f) => f.a)
+ .slice(0, 8)
+ : [];
+
+ return omitEmpty({
+ companyQuery: src.companyQuery || null,
+ categoryQuery: src.categoryQuery || null,
+ isExhibitorList: isList ? true : null,
+ needsClarification: src.needsClarification ? true : null,
+ refuseBooking: src.refuseBooking ? true : null,
+ note: src.note || null,
+ exhibitors: exhibitors.length ? exhibitors : undefined,
+ candidates: candidates.length ? candidates : undefined,
+ faqs: faqs.length ? faqs : undefined,
+ });
+}
+
+/**
+ * Compact tech DATA for Call 2.
+ * @param {object} data fetchTechData result
+ */
+function slimTechDataForLlm(data) {
+ const src = data && typeof data === 'object' ? data : {};
+ const faqs = Array.isArray(src.faqs)
+ ? src.faqs
+ .map((f) =>
+ omitEmpty({
+ q: f.q || null,
+ a: f.a || null,
+ }),
+ )
+ .filter((f) => f.a)
+ .slice(0, 10)
+ : [];
+ const staticTips = Array.isArray(src.staticTips)
+ ? src.staticTips.map((t) => String(t || '').trim()).filter(Boolean).slice(0, 8)
+ : [];
+
+ return omitEmpty({
+ category: src.category || null,
+ note: src.note || null,
+ faqs: faqs.length ? faqs : undefined,
+ staticTips: staticTips.length ? staticTips : undefined,
+ });
+}
+
+/**
+ * Compact system DATA for Call 2.
+ * Visitor-facing Bot FAQ contacts (DATA.contact / DATA.faqs) are intentionally included.
+ * Internal org mailbox used only for escalation email is not exposed separately.
+ * @param {object} data fetchSystemData result
+ */
+function slimSystemDataForLlm(data) {
+ const src = data && typeof data === 'object' ? data : {};
+ const faqs = Array.isArray(src.faqs)
+ ? src.faqs
+ .map((f) =>
+ omitEmpty({
+ q: f.q || null,
+ a: f.a || null,
+ }),
+ )
+ .filter((f) => f.a)
+ .slice(0, 4)
+ : [];
+ const contact = src.contact && typeof src.contact === 'object'
+ ? omitEmpty({
+ email: src.contact.email || null,
+ phone: src.contact.phone || null,
+ detail: src.contact.detail || null,
+ text: src.contact.text || null,
+ })
+ : null;
+ const hideEventName = src.intent === 'out_of_scope' || src.intent === 'chitchat_greeting';
+ return omitEmpty({
+ eventName: hideEventName ? null : src.eventName || null,
+ emailSent: src.emailSent === true ? true : null,
+ rateLimited: src.rateLimited === true ? true : null,
+ emailError: src.emailError || null,
+ note: src.note || null,
+ contact: contact && (contact.email || contact.phone || contact.text) ? contact : undefined,
+ faqs: faqs.length ? faqs : undefined,
+ });
+}
+
+/**
+ * Compact local places / accommodation DATA for Call 2.
+ * @param {object} data fetchLocalData result
+ */
+function slimLocalDataForLlm(data) {
+ const src = data && typeof data === 'object' ? data : {};
+ const places = Array.isArray(src.places)
+ ? src.places
+ .map((p) =>
+ omitEmpty({
+ id: p.id,
+ name: p.name || null,
+ address: p.address || null,
+ rating: p.rating != null ? p.rating : null,
+ distance: p.distance != null ? p.distance : null,
+ category: p.category || null,
+ tags: Array.isArray(p.tags) && p.tags.length ? p.tags.slice(0, 6) : undefined,
+ }),
+ )
+ .filter((p) => p.id && p.name)
+ .slice(0, 8)
+ : [];
+ const hotels = Array.isArray(src.hotels)
+ ? src.hotels
+ .map((h) =>
+ omitEmpty({
+ id: h.id,
+ name: h.name || null,
+ address: h.address || null,
+ rating: h.rating != null ? h.rating : null,
+ distance: h.distance != null ? h.distance : null,
+ priceLevel: h.priceLevel != null ? h.priceLevel : null,
+ }),
+ )
+ .filter((h) => h.id && h.name)
+ .slice(0, 8)
+ : [];
+
+ const faqs = Array.isArray(src.faqs)
+ ? src.faqs
+ .map((f) =>
+ omitEmpty({
+ q: f.q || null,
+ a: f.a || null,
+ }),
+ )
+ .filter((f) => f.a)
+ .slice(0, 2)
+ : [];
+
+ return omitEmpty({
+ eventName: src.eventName || null,
+ location: src.location || null,
+ hostManagedAccommodation: src.hostManagedAccommodation ? true : null,
+ faqs: faqs.length ? faqs : undefined,
+ requestedCategory: src.requestedCategory?.label || null,
+ categoryNoMatch: src.categoryNoMatch || null,
+ note: src.note || null,
+ places: places.length ? places : undefined,
+ hotels: hotels.length ? hotels : undefined,
+ });
+}
+
+module.exports = {
+ compactEntities,
+ slimDataForLlm,
+ slimVenueDataForLlm,
+ slimTicketDataForLlm,
+ slimSpeakerDataForLlm,
+ slimExhibitorDataForLlm,
+ slimTechDataForLlm,
+ slimSystemDataForLlm,
+ slimLocalDataForLlm,
+ slimSessionForLlm,
+ omitEmpty,
+};
diff --git a/src/utils/eventTime.js b/src/utils/eventTime.js
new file mode 100644
index 0000000..b8c7f70
--- /dev/null
+++ b/src/utils/eventTime.js
@@ -0,0 +1,321 @@
+const DEFAULT_TZ = process.env.EVENT_TIME_ZONE || 'Asia/Kolkata';
+
+function getTimeZone() {
+ return process.env.EVENT_TIME_ZONE || DEFAULT_TZ;
+}
+
+function toDate(value) {
+ if (!value) return null;
+ const d = value instanceof Date ? value : new Date(value);
+ return Number.isNaN(d.getTime()) ? null : d;
+}
+
+function zonedParts(value, timeZone = getTimeZone()) {
+ const d = toDate(value);
+ if (!d) return null;
+ const parts = new Intl.DateTimeFormat('en-US', {
+ timeZone,
+ year: 'numeric',
+ month: '2-digit',
+ day: '2-digit',
+ hour: '2-digit',
+ minute: '2-digit',
+ second: '2-digit',
+ hourCycle: 'h23',
+ }).formatToParts(d);
+ const get = (type) => Number(parts.find((p) => p.type === type)?.value || 0);
+ return {
+ year: get('year'),
+ month: get('month'),
+ day: get('day'),
+ hour: get('hour'),
+ minute: get('minute'),
+ second: get('second'),
+ };
+}
+
+/** Convert a wall-clock datetime in `timeZone` to a UTC Date. */
+function zonedWallTimeToUtc(year, month, day, hour = 0, minute = 0, second = 0, timeZone = getTimeZone()) {
+ let utc = Date.UTC(year, month - 1, day, hour, minute, second);
+ for (let i = 0; i < 4; i += 1) {
+ const parts = zonedParts(new Date(utc), timeZone);
+ if (!parts) break;
+ const asIfUtc = Date.UTC(
+ parts.year,
+ parts.month - 1,
+ parts.day,
+ parts.hour,
+ parts.minute,
+ parts.second,
+ );
+ const desired = Date.UTC(year, month - 1, day, hour, minute, second);
+ const delta = desired - asIfUtc;
+ if (delta === 0) break;
+ utc += delta;
+ }
+ return new Date(utc);
+}
+
+/** Inclusive calendar-day bounds in event TZ → UTC Date range [start, end). */
+function dayBoundsUtc(year, month, day, timeZone = getTimeZone()) {
+ const start = zonedWallTimeToUtc(year, month, day, 0, 0, 0, timeZone);
+ const next = new Date(start.getTime() + 36 * 3600 * 1000);
+ const nextParts = zonedParts(next, timeZone);
+ const end = zonedWallTimeToUtc(nextParts.year, nextParts.month, nextParts.day, 0, 0, 0, timeZone);
+ return { start, end };
+}
+
+function addCalendarDays(year, month, day, deltaDays) {
+ const utc = Date.UTC(year, month - 1, day) + deltaDays * 86400000;
+ const d = new Date(utc);
+ return { year: d.getUTCFullYear(), month: d.getUTCMonth() + 1, day: d.getUTCDate() };
+}
+
+function formatDayLabel(year, month, day) {
+ const utc = zonedWallTimeToUtc(year, month, day, 12, 0, 0);
+ return formatInTz(utc, {
+ weekday: 'short',
+ day: 'numeric',
+ month: 'short',
+ year: 'numeric',
+ });
+}
+
+const MONTHS = {
+ jan: 1,
+ january: 1,
+ feb: 2,
+ february: 2,
+ mar: 3,
+ march: 3,
+ apr: 4,
+ april: 4,
+ may: 5,
+ jun: 6,
+ june: 6,
+ jul: 7,
+ july: 7,
+ aug: 8,
+ august: 8,
+ sep: 9,
+ sept: 9,
+ september: 9,
+ oct: 10,
+ october: 10,
+ nov: 11,
+ november: 11,
+ dec: 12,
+ december: 12,
+};
+
+/**
+ * Parse attendee time_reference into event-TZ day bounds.
+ * @param {string} raw
+ * @param {Date} [now]
+ * @param {{ minDate?: Date|null, maxDate?: Date|null }} [hint] session range to resolve bare day numbers
+ * @returns {{ start: Date, end: Date, label: string, key: string }|null}
+ */
+function parseTimeReference(raw, now = new Date(), hint = {}) {
+ const text = String(raw || '').trim().toLowerCase();
+ if (!text) return null;
+ const tz = getTimeZone();
+ const nowParts = zonedParts(now, tz);
+ if (!nowParts) return null;
+
+ const build = (year, month, day) => {
+ const { start, end } = dayBoundsUtc(year, month, day, tz);
+ return {
+ start,
+ end,
+ label: formatDayLabel(year, month, day),
+ key: `${year}-${String(month).padStart(2, '0')}-${String(day).padStart(2, '0')}`,
+ };
+ };
+
+ if (/\btoday\b/.test(text)) return build(nowParts.year, nowParts.month, nowParts.day);
+ if (/\btomorrow\b/.test(text)) {
+ const n = addCalendarDays(nowParts.year, nowParts.month, nowParts.day, 1);
+ return build(n.year, n.month, n.day);
+ }
+ if (/\byesterday\b/.test(text)) {
+ const n = addCalendarDays(nowParts.year, nowParts.month, nowParts.day, -1);
+ return build(n.year, n.month, n.day);
+ }
+
+ // ISO / yyyy-mm-dd
+ let m = text.match(/\b(20\d{2})-(\d{1,2})-(\d{1,2})\b/);
+ if (m) return build(Number(m[1]), Number(m[2]), Number(m[3]));
+
+ // 8 August / August 8 / Aug 8th / 8th Aug 2026
+ m = text.match(/\b(\d{1,2})(?:st|nd|rd|th)?\s+(jan(?:uary)?|feb(?:ruary)?|mar(?:ch)?|apr(?:il)?|may|jun(?:e)?|jul(?:y)?|aug(?:ust)?|sep(?:t(?:ember)?)?|oct(?:ober)?|nov(?:ember)?|dec(?:ember)?)(?:\s*,?\s*(20\d{2}))?\b/);
+ if (m) {
+ const day = Number(m[1]);
+ const month = MONTHS[m[2]];
+ const year = m[3] ? Number(m[3]) : pickYearForMonthDay(nowParts, month, day, hint);
+ return build(year, month, day);
+ }
+ m = text.match(/\b(jan(?:uary)?|feb(?:ruary)?|mar(?:ch)?|apr(?:il)?|may|jun(?:e)?|jul(?:y)?|aug(?:ust)?|sep(?:t(?:ember)?)?|oct(?:ober)?|nov(?:ember)?|dec(?:ember)?)\s+(\d{1,2})(?:st|nd|rd|th)?(?:\s*,?\s*(20\d{2}))?\b/);
+ if (m) {
+ const month = MONTHS[m[1]];
+ const day = Number(m[2]);
+ const year = m[3] ? Number(m[3]) : pickYearForMonthDay(nowParts, month, day, hint);
+ return build(year, month, day);
+ }
+
+ // Bare day: "8th", "on the 8", "8"
+ m = text.match(/\b(?:on\s+)?(?:the\s+)?(\d{1,2})(?:st|nd|rd|th)?\b/);
+ if (m) {
+ const day = Number(m[1]);
+ if (day >= 1 && day <= 31) {
+ const resolved = resolveBareDay(day, nowParts, hint, tz);
+ if (resolved) return build(resolved.year, resolved.month, resolved.day);
+ }
+ }
+
+ return null;
+}
+
+function pickYearForMonthDay(nowParts, month, day, hint) {
+ const candidates = [nowParts.year - 1, nowParts.year, nowParts.year + 1];
+ if (hint?.minDate || hint?.maxDate) {
+ const minP = hint.minDate ? zonedParts(hint.minDate) : null;
+ const maxP = hint.maxDate ? zonedParts(hint.maxDate) : null;
+ if (minP) candidates.push(minP.year);
+ if (maxP) candidates.push(maxP.year);
+ }
+ const uniq = [...new Set(candidates)].sort((a, b) => a - b);
+ // Prefer year where month/day is on/after "now", else nearest in hint range, else current year
+ const scored = uniq.map((year) => {
+ const { start } = dayBoundsUtc(year, month, day);
+ return { year, start: start.getTime() };
+ });
+ const upcoming = scored.filter((c) => c.start >= Date.UTC(nowParts.year, nowParts.month - 1, nowParts.day) - 14 * 86400000);
+ if (upcoming.length) {
+ upcoming.sort((a, b) => a.start - b.start);
+ return upcoming[0].year;
+ }
+ return nowParts.year;
+}
+
+function resolveBareDay(day, nowParts, hint, timeZone) {
+ const candidates = [];
+ const pushRange = (from, to) => {
+ let cur = { year: from.year, month: from.month, day: from.day };
+ const endKey = `${to.year}-${to.month}-${to.day}`;
+ for (let i = 0; i < 400; i += 1) {
+ if (cur.day === day) candidates.push({ ...cur });
+ const key = `${cur.year}-${cur.month}-${cur.day}`;
+ if (key === endKey) break;
+ cur = addCalendarDays(cur.year, cur.month, cur.day, 1);
+ }
+ };
+
+ if (hint?.minDate && hint?.maxDate) {
+ const minP = zonedParts(hint.minDate, timeZone);
+ const maxP = zonedParts(hint.maxDate, timeZone);
+ if (minP && maxP) pushRange(minP, maxP);
+ }
+
+ if (!candidates.length) {
+ // current + next month
+ for (const monthDelta of [0, 1, 2]) {
+ let year = nowParts.year;
+ let month = nowParts.month + monthDelta;
+ while (month > 12) {
+ month -= 12;
+ year += 1;
+ }
+ const dim = new Date(Date.UTC(year, month, 0)).getUTCDate();
+ if (day <= dim) candidates.push({ year, month, day });
+ }
+ }
+
+ if (!candidates.length) return null;
+
+ const nowStart = dayBoundsUtc(nowParts.year, nowParts.month, nowParts.day, timeZone).start.getTime();
+ const upcoming = candidates
+ .map((c) => ({ ...c, t: dayBoundsUtc(c.year, c.month, c.day, timeZone).start.getTime() }))
+ .filter((c) => c.t >= nowStart - 6 * 3600000)
+ .sort((a, b) => a.t - b.t);
+ if (upcoming.length) return upcoming[0];
+ candidates.sort((a, b) => {
+ const ta = dayBoundsUtc(a.year, a.month, a.day, timeZone).start.getTime();
+ const tb = dayBoundsUtc(b.year, b.month, b.day, timeZone).start.getTime();
+ return Math.abs(ta - nowStart) - Math.abs(tb - nowStart);
+ });
+ return candidates[0];
+}
+
+function formatInTz(value, options) {
+ const d = toDate(value);
+ if (!d) return null;
+ try {
+ return new Intl.DateTimeFormat('en-IN', {
+ timeZone: getTimeZone(),
+ ...options,
+ }).format(d);
+ } catch {
+ return null;
+ }
+}
+
+/** e.g. Fri, 7 Aug 2025, 10:15 am */
+function formatDateTimeLocal(value) {
+ return formatInTz(value, {
+ weekday: 'short',
+ day: 'numeric',
+ month: 'short',
+ year: 'numeric',
+ hour: 'numeric',
+ minute: '2-digit',
+ hour12: true,
+ });
+}
+
+/** e.g. 10:30 am */
+function formatTimeLocal(value) {
+ return formatInTz(value, {
+ hour: 'numeric',
+ minute: '2-digit',
+ hour12: true,
+ });
+}
+
+function sameCalendarDay(a, b) {
+ const da = toDate(a);
+ const db = toDate(b);
+ if (!da || !db) return false;
+ const opts = { timeZone: getTimeZone(), year: 'numeric', month: '2-digit', day: '2-digit' };
+ try {
+ return (
+ new Intl.DateTimeFormat('en-CA', opts).format(da) ===
+ new Intl.DateTimeFormat('en-CA', opts).format(db)
+ );
+ } catch {
+ return false;
+ }
+}
+
+/** e.g. Fri, 7 Aug 2025, 10:15 am – 10:30 am IST */
+function formatTimeRangeLocal(start, end) {
+ const startLabel = formatDateTimeLocal(start);
+ if (!startLabel) return null;
+ const endLabel = end
+ ? sameCalendarDay(start, end)
+ ? formatTimeLocal(end)
+ : formatDateTimeLocal(end)
+ : null;
+ const tz = getTimeZone() === 'Asia/Kolkata' ? 'IST' : getTimeZone();
+ return endLabel ? `${startLabel} – ${endLabel} ${tz}` : `${startLabel} ${tz}`;
+}
+
+module.exports = {
+ getTimeZone,
+ formatDateTimeLocal,
+ formatTimeLocal,
+ formatTimeRangeLocal,
+ sameCalendarDay,
+ zonedParts,
+ dayBoundsUtc,
+ parseTimeReference,
+};
diff --git a/src/utils/exhibitorCards.js b/src/utils/exhibitorCards.js
new file mode 100644
index 0000000..5c8cdfa
--- /dev/null
+++ b/src/utils/exhibitorCards.js
@@ -0,0 +1,59 @@
+const MAX_EXHIBITOR_CARDS = 8;
+
+function buildExhibitorCards(exhibitorIds, data) {
+ const exhibitors = Array.isArray(data?.exhibitors) ? data.exhibitors : [];
+ const byId = new Map(exhibitors.map((e) => [String(e.id), e]));
+ let ids = (Array.isArray(exhibitorIds) ? exhibitorIds : [])
+ .map((id) => String(id || '').trim())
+ .filter(Boolean);
+
+ if (!ids.length && exhibitors.length === 1) {
+ ids = [String(exhibitors[0].id)];
+ }
+
+ const seen = new Set();
+ const cards = [];
+ for (const id of ids) {
+ if (seen.has(id)) continue;
+ seen.add(id);
+ const e = byId.get(id);
+ if (!e) continue;
+ const social = e.socialLinks || {};
+ cards.push({
+ type: 'exhibitor',
+ data: {
+ exhibitorId: e.id,
+ name: e.name || 'Exhibitor',
+ boothNumber: e.boothNumber || null,
+ hall: e.hall || null,
+ category: e.category || null,
+ shortDescription: e.shortDescription || null,
+ logo: e.logo || null,
+ products: Array.isArray(e.products) ? e.products.slice(0, 8) : [],
+ website: e.website || social.website || null,
+ linkedin: social.linkedin || null,
+ twitter: social.twitter || null,
+ instagram: social.instagram || null,
+ isFeatured: Boolean(e.isFeatured),
+ },
+ });
+ if (cards.length >= MAX_EXHIBITOR_CARDS) break;
+ }
+ return cards;
+}
+
+function resolveExhibitorIdsFromModel(exhibitorIds, data) {
+ const exhibitors = Array.isArray(data?.exhibitors) ? data.exhibitors : [];
+ const allowed = new Set(exhibitors.map((e) => String(e.id)));
+ const fromModel = (Array.isArray(exhibitorIds) ? exhibitorIds : [])
+ .map((id) => String(id || '').trim())
+ .filter((id) => allowed.has(id));
+ if (fromModel.length) return fromModel;
+ return exhibitors.map((e) => String(e.id)).filter(Boolean).slice(0, MAX_EXHIBITOR_CARDS);
+}
+
+module.exports = {
+ buildExhibitorCards,
+ resolveExhibitorIdsFromModel,
+ MAX_EXHIBITOR_CARDS,
+};
diff --git a/src/utils/faqAnswer.js b/src/utils/faqAnswer.js
new file mode 100644
index 0000000..41a2c23
--- /dev/null
+++ b/src/utils/faqAnswer.js
@@ -0,0 +1,108 @@
+/**
+ * Build the visitor-facing answer text for a Bot FAQ row.
+ * @param {object|null|undefined} row
+ */
+function faqAnswerText(row) {
+ if (!row || typeof row !== 'object') return '';
+ const format = String(row.answerFormat || '').trim();
+ const email = String(row.contactEmail || '').trim();
+ const phone = String(row.contactPhone || '').trim();
+ const detail = String(row.answerDetail || '').trim();
+
+ // contact_details — also honor email/phone when answerFormat was not persisted
+ if (format === 'contact_details' || email || phone) {
+ const bits = [];
+ if (email) bits.push(`Email: ${email}`);
+ if (phone) bits.push(`Phone: ${phone}`);
+ if (detail) bits.push(detail);
+ return bits.join('\n');
+ }
+
+ if (format === 'media_upload') {
+ const url = String(row.mediaUrl || '').trim();
+ if (!url) return '';
+ const name = String(row.mediaName || '').trim();
+ const note = String(row.answer || row.answerDetail || '').trim();
+ if (note) return note;
+ return name
+ ? `A floor plan / map is available: ${name}. You can view or download it below.`
+ : 'A floor plan / map is available. You can view or download it below.';
+ }
+
+ if (format === 'mcq_multi') {
+ const opts = Array.isArray(row.selectedOptions)
+ ? row.selectedOptions.map((x) => String(x || '').trim()).filter(Boolean)
+ : [];
+ if (opts.length) return opts.join(', ');
+ }
+
+ const a = String(row.answer || '').trim();
+ const d = String(row.answerDetail || '').trim();
+ if (a && d) return `${a}\n${d}`;
+ return a || d;
+}
+
+/**
+ * Extract floor-plan / map media from the venue_map FAQ row.
+ * @param {object|null|undefined} bot
+ */
+function mapMediaFromBot(bot) {
+ const rows = Array.isArray(bot?.faqs) ? bot.faqs : [];
+ const row = rows.find(
+ (f) =>
+ (String(f?.key || '') === 'venue_map' || String(f?.category || '') === 'venue_map') &&
+ String(f?.mediaUrl || '').trim(),
+ );
+ if (!row) return null;
+ const url = String(row.mediaUrl || '').trim();
+ if (!url) return null;
+ const name = String(row.mediaName || '').trim() || 'Venue floor plan';
+ let mediaType = String(row.mediaType || '').trim().toLowerCase();
+ if (mediaType !== 'image' && mediaType !== 'pdf') {
+ const hay = `${url} ${name}`.toLowerCase();
+ if (/\.pdf(\?|#|$)/i.test(hay)) mediaType = 'pdf';
+ else if (/\.(png|jpe?g|gif|webp|svg)(\?|#|$)/i.test(hay)) mediaType = 'image';
+ else mediaType = 'file';
+ }
+ return { url, name, mediaType };
+}
+
+function buildMapFileCard(mapMedia) {
+ if (!mapMedia?.url) return null;
+ return {
+ type: 'file',
+ data: {
+ title: mapMedia.name || 'Venue floor plan',
+ url: mapMedia.url,
+ mediaType: mapMedia.mediaType || 'file',
+ },
+ };
+}
+
+/**
+ * Organizer / emergency contact from Bot FAQ (email + phone for visitors).
+ * @param {object|null|undefined} bot
+ * @returns {{ email: string|null, phone: string|null, detail: string|null, text: string }|null}
+ */
+function emergencyContactFromBot(bot) {
+ const rows = Array.isArray(bot?.faqs) ? bot.faqs : [];
+ const row = rows.find((f) => {
+ const key = String(f?.key || '').trim();
+ const category = String(f?.category || '').trim();
+ return key === 'emergency_contact' || category === 'emergency_contact';
+ });
+ if (!row) return null;
+ const email = String(row.contactEmail || '').trim() || null;
+ const phone = String(row.contactPhone || '').trim() || null;
+ const detail = String(row.answerDetail || '').trim() || null;
+ const text = faqAnswerText(row);
+ if (!text && !email && !phone) return null;
+ return { email, phone, detail, text: text || '' };
+}
+
+module.exports = {
+ faqAnswerText,
+ mapMediaFromBot,
+ buildMapFileCard,
+ emergencyContactFromBot,
+};
diff --git a/src/utils/greeting.js b/src/utils/greeting.js
new file mode 100644
index 0000000..657fd6d
--- /dev/null
+++ b/src/utils/greeting.js
@@ -0,0 +1,12 @@
+function interpolateGreeting(template, { profileName, eventName } = {}) {
+ const text = String(template || '').trim();
+ if (!text) {
+ const name = eventName || 'the event';
+ return `Hi! Welcome to ${name}. How can I help?`;
+ }
+ return text
+ .replace(/\{profileName\}/gi, profileName || 'there')
+ .replace(/\{eventName\}/gi, eventName || 'the event');
+}
+
+module.exports = { interpolateGreeting };
diff --git a/src/utils/livekitConcierge.js b/src/utils/livekitConcierge.js
new file mode 100644
index 0000000..094a9b4
--- /dev/null
+++ b/src/utils/livekitConcierge.js
@@ -0,0 +1,79 @@
+const AGENT_NAME = process.env.LIVEKIT_AGENT_NAME || 'eventbuzz-concierge';
+
+function getLivekitConfig() {
+ const url = String(process.env.LIVEKIT_URL || '').trim();
+ const apiKey = String(process.env.LIVEKIT_API_KEY || '').trim();
+ const apiSecret = String(process.env.LIVEKIT_API_SECRET || '').trim();
+ return { url, apiKey, apiSecret, configured: Boolean(url && apiKey && apiSecret) };
+}
+
+function voiceRoomName(botId, sessionId) {
+ return `concierge-${String(botId)}-${String(sessionId)}`;
+}
+
+function parseVoiceRoomName(roomName) {
+ const raw = String(roomName || '');
+ const match = raw.match(/^concierge-([a-f0-9]{24})-([a-f0-9]+)$/i);
+ if (!match) return null;
+ return { botId: match[1], sessionId: match[2] };
+}
+
+async function createVisitorVoiceToken({ botId, sessionId, identity }) {
+ const { url, apiKey, apiSecret, configured } = getLivekitConfig();
+ if (!configured) {
+ throw new Error('LiveKit is not configured');
+ }
+
+ const { AccessToken, RoomServiceClient, AgentDispatchClient } = require('livekit-server-sdk');
+ const roomName = voiceRoomName(botId, sessionId);
+ const metadata = JSON.stringify({ botId: String(botId), sessionId: String(sessionId) });
+
+ const httpUrl = url.replace(/^wss:/, 'https:').replace(/^ws:/, 'http:');
+ const rooms = new RoomServiceClient(httpUrl, apiKey, apiSecret);
+ try {
+ await rooms.createRoom({
+ name: roomName,
+ emptyTimeout: 15 * 60,
+ maxParticipants: 8,
+ metadata,
+ });
+ } catch (err) {
+ const msg = String(err?.message || err);
+ if (!/already exists|conflict/i.test(msg)) throw err;
+ }
+
+ try {
+ const dispatch = new AgentDispatchClient(httpUrl, apiKey, apiSecret);
+ await dispatch.createDispatch(roomName, AGENT_NAME, { metadata });
+ } catch (err) {
+ console.warn('[livekit] agent dispatch failed (worker may still auto-join):', err?.message || err);
+ }
+
+ const at = new AccessToken(apiKey, apiSecret, {
+ identity: identity || `visitor-${sessionId}`,
+ ttl: '15m',
+ metadata,
+ });
+ at.addGrant({
+ roomJoin: true,
+ room: roomName,
+ canPublish: true,
+ canSubscribe: true,
+ canPublishData: true,
+ });
+
+ return {
+ url,
+ token: await at.toJwt(),
+ roomName,
+ sessionId: String(sessionId),
+ };
+}
+
+module.exports = {
+ AGENT_NAME,
+ getLivekitConfig,
+ voiceRoomName,
+ parseVoiceRoomName,
+ createVisitorVoiceToken,
+};
diff --git a/src/utils/mail.js b/src/utils/mail.js
new file mode 100644
index 0000000..22adf92
--- /dev/null
+++ b/src/utils/mail.js
@@ -0,0 +1,292 @@
+const nodemailer = require('nodemailer');
+
+let defaultTransporter;
+let transporterCacheKey = null;
+
+function resolveSmtp() {
+ const host = process.env.MAIL_HOST || process.env.SMTP_HOST;
+ const port = parseInt(process.env.MAIL_PORT || process.env.SMTP_PORT || '587', 10);
+ const enc = String(process.env.MAIL_ENCRYPTION || '').toLowerCase();
+ const secure = enc === 'ssl' || port === 465 || process.env.SMTP_SECURE === 'true';
+ const user = process.env.MAIL_USERNAME || process.env.SMTP_USER;
+ const pass = process.env.MAIL_PASSWORD || process.env.SMTP_PASS;
+ return { host, port, secure, user, pass };
+}
+
+function getMailFrom() {
+ const addr =
+ process.env.MAIL_FROM_ADDRESS ||
+ process.env.SMTP_FROM ||
+ process.env.MAIL_USERNAME ||
+ process.env.SMTP_USER ||
+ 'noreply@eventbuzz.local';
+ let name = process.env.MAIL_FROM_NAME;
+ if (name) {
+ name = String(name).replace(/^["']|["']$/g, '').trim();
+ const safe = name.replace(/\\/g, '\\\\').replace(/"/g, '\\"');
+ return `"${safe}" <${addr}>`;
+ }
+ return addr;
+}
+
+/** When set, SMTP delivers to this address only (testing). Content still uses the intended recipient. */
+function getTestRedirectTo() {
+ const to = String(process.env.MAIL_TEST_REDIRECT_TO || '').trim().toLowerCase();
+ return to.includes('@') ? to : '';
+}
+
+/**
+ * @param {string} intendedTo
+ * @returns {{ to: string, intendedTo: string, redirected: boolean }}
+ */
+function resolveDeliveryTo(intendedTo) {
+ const intended = String(intendedTo || '').trim().toLowerCase();
+ const redirect = getTestRedirectTo();
+ if (redirect && intended && redirect !== intended) {
+ return { to: redirect, intendedTo: intended, redirected: true };
+ }
+ return { to: intended, intendedTo: intended, redirected: false };
+}
+
+function getDefaultTransporter() {
+ const { host, port, secure, user, pass } = resolveSmtp();
+ const cacheKey = `${host || ''}|${port}|${secure}|${user || ''}|${pass ? '1' : '0'}`;
+ if (defaultTransporter !== undefined && transporterCacheKey === cacheKey) {
+ return defaultTransporter;
+ }
+ transporterCacheKey = cacheKey;
+ if (!host) {
+ defaultTransporter = null;
+ return null;
+ }
+ defaultTransporter = nodemailer.createTransport({
+ host,
+ port,
+ secure,
+ auth: user ? { user, pass: pass || '' } : undefined,
+ });
+ return defaultTransporter;
+}
+
+function escapeHtml(s) {
+ return String(s || '')
+ .replace(/&/g, '&')
+ .replace(//g, '>')
+ .replace(/"/g, '"');
+}
+
+async function sendConciergeOtpEmail({ to, otp, eventName }) {
+ const delivery = resolveDeliveryTo(to);
+ const from = getMailFrom();
+ const name = eventName || 'your event';
+ const subject = `Your verification code for ${name}`;
+ const redirectNote = delivery.redirected
+ ? `\n[TEST] Intended recipient: ${delivery.intendedTo}\n`
+ : '';
+ const text = `Your one-time code is: ${otp}
+
+It expires in 10 minutes.
+${redirectNote}
+— EventBuzz Concierge`;
+ const html = `Your verification code for ${escapeHtml(name)} is:
+${escapeHtml(otp)}
+This code expires in 10 minutes.
+${
+ delivery.redirected
+ ? `[TEST] Intended recipient: ${escapeHtml(delivery.intendedTo)}
`
+ : ''
+}
+— EventBuzz Concierge
`;
+
+ const t = getDefaultTransporter();
+ if (!t) {
+ console.log(`[concierge OTP — no SMTP configured] to=${delivery.to} intended=${delivery.intendedTo} code=${otp}`);
+ return true;
+ }
+ try {
+ if (delivery.redirected) {
+ console.log(`[concierge OTP] redirect ${delivery.intendedTo} → ${delivery.to}`);
+ }
+ await t.sendMail({ from, to: delivery.to, subject, text, html });
+ return true;
+ } catch (e) {
+ console.error('sendConciergeOtpEmail', e.message);
+ return false;
+ }
+}
+
+/**
+ * Email ticket QR + registration details to the registered attendee email only.
+ * @returns {Promise<{ ok: boolean, error?: string }>}
+ */
+async function sendTicketPassEmail({
+ to,
+ eventName,
+ attendeeName,
+ ticketName,
+ statusLabel,
+ paymentLabel,
+ qrImageUrl,
+}) {
+ const email = String(to || '').trim().toLowerCase();
+ if (!email || !email.includes('@')) {
+ return { ok: false, error: 'missing_email' };
+ }
+
+ const delivery = resolveDeliveryTo(email);
+ const from = getMailFrom();
+ const name = eventName || 'your event';
+ const who = attendeeName || 'Attendee';
+ const subject = `Your ticket for ${name}`;
+ const lines = [
+ `Hi ${who},`,
+ '',
+ `Here is your ticket for ${name}.`,
+ ticketName ? `Ticket: ${ticketName}` : null,
+ statusLabel ? `Status: ${statusLabel}` : null,
+ paymentLabel ? `Payment: ${paymentLabel}` : null,
+ '',
+ qrImageUrl ? `Check-in QR: ${qrImageUrl}` : 'Check-in QR is unavailable — contact the organizers.',
+ delivery.redirected ? `[TEST] Intended recipient: ${delivery.intendedTo}` : null,
+ '',
+ '— EventBuzz Concierge',
+ ].filter((x) => x != null);
+
+ const text = lines.join('\n');
+ const detailRows = [
+ ticketName
+ ? `| Ticket | ${escapeHtml(ticketName)} |
`
+ : '',
+ statusLabel
+ ? `| Status | ${escapeHtml(statusLabel)} |
`
+ : '',
+ paymentLabel
+ ? `| Payment | ${escapeHtml(paymentLabel)} |
`
+ : '',
+ ].join('');
+
+ const qrBlock = qrImageUrl
+ ? `
+ })
+
+ Show this QR at check-in.
`
+ : `A check-in QR could not be attached. Please contact the organizers.
`;
+
+ const html = `
+
Hi ${escapeHtml(who)},
+
Here is your ticket for ${escapeHtml(name)}.
+
+ ${qrBlock}
+ ${
+ delivery.redirected
+ ? `
[TEST] Intended recipient: ${escapeHtml(delivery.intendedTo)}
`
+ : ''
+ }
+
— EventBuzz Concierge
+
+
Concierge escalation for ${escapeHtml(name)}
+
+ | Intent | ${escapeHtml(intentLabel)} |
+ | Session | ${escapeHtml(sessionId || 'n/a')} |
+ | Attendee | ${escapeHtml(who)} |
+ | Attendee email | ${escapeHtml(whoEmail)} |
+
+
Message
+
${escapeHtml(msg)}
+ ${
+ delivery.redirected
+ ? `
[TEST] Intended recipient: ${escapeHtml(delivery.intendedTo)}
`
+ : ''
+ }
+
— EventBuzz Concierge
+