fix: activity timestamp

Signed-off-by: Mouad BANI <mouad-mb@outlook.com>

Author: mbani01

.claude/skills/scaffold-snowflake-connector/SKILL.md

@@ -196,6 +196,8 @@ After Step 1 and/or Step 2, build a column registry per table:
 
 **Store this as the canonical column reference. Every column name used in generated code must appear in this registry. Never assume or invent a column name.**
 
+**Flag non-VARCHAR column types** (e.g., `DATE`, `TIME`, `TIMESTAMP_TZ`, `BOOLEAN`, `NUMBER`) — these arrive as native JS types from the Parquet reader, not strings (see touch point 9 rules).
+
 For each JOIN table, check whether any existing transformer in `services/apps/snowflake_connectors/src/integrations/` queries from the same table. If yes, inherit its column mappings; if no, treat every column as unknown and derive it from sample data in the Pre-Analysis step below.
 
 ### Step 3 — Sample data
@@ -568,6 +570,7 @@ File: `services/apps/snowflake_connectors/src/integrations/{platform}/{source}/b
 **Rules (enforced — do not deviate):**
 - Use explicit column names only. Do not use `table.*` or `table.* EXCLUDE (...)` in new implementations — existing sources (TNC, CVENT) use these patterns but new sources should list columns explicitly to avoid parquet encoding/decoding issues
 - If any TIMESTAMP_TZ columns exist in the schema, exclude and re-cast them as TIMESTAMP_NTZ (see CVENT pattern)
+- Do not concatenate or transform date/time columns in SQL — keep them as separate columns and let the transformer handle type coercion (see touch point 9 rules)
 - Follow the CTE structure:
   1. `org_accounts` CTE (if org data present)
   2. `CDP_MATCHED_SEGMENTS` CTE (always)
@@ -588,6 +591,8 @@ Show the full generated file and ask for confirmation before writing.
 File: `services/apps/snowflake_connectors/src/integrations/{platform}/{source}/transformer.ts`
 
 **Rules (enforced — do not deviate):**
+
+- **Parquet type coercion — never blindly cast `row.COLUMN as string`.** Snowflake types may arrive as native JS types after Parquet decoding (e.g., `DATE` → `Date` object, `TIME` → `number` in ms, `BOOLEAN` → `boolean`). Always check the Snowflake column type from the schema registry and handle the actual JS type the Parquet reader delivers — do not assume every column is a string.
 - All string comparisons must be case-insensitive: use `.toLowerCase()` on both sides of comparison only; preserve the original value in the output
 - No broad `else` statements — every branch must have an explicit condition
 - All column names referenced in code must exactly match the schema registry — never assumed

services/apps/snowflake_connectors/src/integrations/meetings/meeting-attendance/transformer.ts

@@ -12,6 +12,23 @@ import { TransformedActivity, TransformerBase } from '../../../core/transformerB
 
 const log = getServiceChildLogger('meetingAttendanceTransformer')
 
+function toISOTimestamp(rawDate: unknown, rawTime: unknown): string | null {
+  const date =
+    rawDate instanceof Date
+      ? new Date(rawDate)
+      : typeof rawDate === 'string'
+        ? new Date(rawDate)
+        : null
+  if (!date || isNaN(date.getTime())) return null
+  if (typeof rawTime === 'number') {
+    date.setTime(date.getTime() + rawTime)
+  } else if (typeof rawTime === 'string' && rawTime.trim()) {
+    const combined = new Date(`${date.toISOString().slice(0, 10)}T${rawTime.trim()}Z`)
+    if (!isNaN(combined.getTime())) return combined.toISOString()
+  }
+  return date.toISOString()
+}
+
 export class MeetingAttendanceTransformer extends TransformerBase {
   readonly platform = PlatformType.MEETINGS
 
@@ -39,10 +56,7 @@ export class MeetingAttendanceTransformer extends TransformerBase {
       return null
     }
 
-    const meetingDate = (row.MEETING_DATE as string | null) || null
-    const meetingTime = (row.MEETING_TIME as string | null) || null
-    const timestamp =
-      meetingDate && meetingTime ? `${meetingDate}T${meetingTime}` : meetingDate || null
+    const timestamp = toISOTimestamp(row.MEETING_DATE, row.MEETING_TIME)
 
     const primaryKey = (row.PRIMARY_KEY as string)?.trim()