Records of what happened, without turning events into results.

curl -sS -X POST "$EVENTS_BASE_URL/source-imports" \
  -H "Authorization: Bearer $TIMEBACK_JWT" \
  -H "X-Timeback-Tenant: $TENANT_ID" \
  -H "Content-Type: application/json" \
  -H "Idempotency-Key: duke-2025-26-events-source-import-a1" \
  -d '{
    "sourceSystem": "timeback_production",
    "adapter": "timeback_learning_event_v1",
    "importId": "duke-2025-26-events-a1",
    "records": [
      {
        "id": "pf_918271",
        "student_sourced_id": "b6fa7128-f641-4efd-9075-375411fd6c39",
        "activity_id": "fractions_video_482",
        "activity_kind": "video_scrub",
        "occurred_at": "2026-02-12T15:04:03Z",
        "course_ref": "math-5-fractions"
      }
    ]
  }'

-- Success is checked at public Events grain, not source-row submission grain.
-- The source import itself is a surface call; raw DB checks only prove materialization.
SELECT
  count(*) AS materialized_event_count,
  min(e.happened_at) AS first_event_at,
  max(e.happened_at) AS last_event_at
FROM alpha.event_view e
WHERE e.tenant_id = :tenant_id
  AND e.student_id = :student_id
  AND e.received_at >= :import_started_at
  AND e.kind IN ('app_opened','content_viewed','video_started','video_scrubbed',
                 'hint_requested','question_answered','assessment_started',
                 'assessment_submitted','lesson_finished','search_run',
                 'feedback_viewed','session_joined');

curl "$EVENTS_BASE_URL/events?studentId=person_ada_lovelace&happenedAtFrom=2026-05-28T00:00:00Z&happenedAtTo=2026-06-04T00:00:00Z&pageSize=50" \
  -H "Authorization: Bearer $TIMEBACK_JWT" \
  -H "X-Timeback-Tenant: $TENANT_ID"

SELECT
  e.id,
  e.happened_at,
  e.kind,
  e.student_id,
  p.first_name,
  p.last_name,
  pm.place_id AS org_id_as_of_event,
  pl.name AS org_name_as_of_event,
  ci.content_id,
  ci.title AS content_title,
  ci.content_kind
FROM alpha.event_view e
-- People & Orgs temporal join: event.happened_at is the only as-of key.
JOIN alpha.person p
  ON p.tenant_id = e.tenant_id
 AND p.person_id = e.student_id
JOIN alpha.place_membership pm
  ON pm.tenant_id = e.tenant_id
 AND pm.person_id = e.student_id
 AND pm.role_kind = 'student'
 AND pm.is_time_locatable = true
 AND pm.begin_date <= e.happened_at::date
 AND (pm.end_date IS NULL OR pm.end_date >= e.happened_at::date)
JOIN alpha.place pl
  ON pl.tenant_id = pm.tenant_id
 AND pl.place_id = pm.place_id
-- Content join: event.content_id is the only public Content relationship key.
LEFT JOIN alpha.content_item_view ci
  ON ci.workspace_id = e.tenant_id
 AND ci.content_id = e.content_id
WHERE e.tenant_id = :tenant_id
  AND e.student_id = :student_id
  AND e.happened_at >= :as_of::timestamptz - interval '7 days'
  AND e.happened_at < :as_of::timestamptz
ORDER BY e.happened_at DESC
LIMIT :page_size;

Core event writes route through POST /events; rename/cut/restrict fields are persisted in Caliper base tables, not Alpha copies.

CREATE VIEW alpha.event_view AS
SELECT
  e.tenant_id,
  e.event_row_id AS id,
  e.event_iri AS source_event_id,
  e.event_type,
  e.profile,
  e.action,
  x.event_kind AS kind,
  e.actor AS actor_ref,
  x.student_sourced_id AS student_id,
  e.object AS object_ref,
  x.content_id,
  env.sensor_id AS activity_source_id,
  e.group_entity AS group_ref,
  x.org_sourced_id AS org_id,
  e.generated AS generated_ref,
  e.target AS target_ref,
  e.referrer AS referrer_ref,
  e.federated_session AS session_ref,
  e.event_time AS happened_at,
  env.received_at,
  e.event_extensions AS extensions
FROM caliper.event e
JOIN caliper.envelope env
  ON env.tenant_id = e.tenant_id
 AND env.envelope_id = e.envelope_id
LEFT JOIN alpha.event_extension x
  ON x.tenant_id = e.tenant_id
 AND x.event_row_id = e.event_row_id
WHERE env.envelope_status = 'processed';

curl "$EVENTS_BASE_URL/attendance-events?studentId=person_ada_lovelace&from=2026-05-28&to=2026-06-04&pageSize=50" \
  -H "Authorization: Bearer $TIMEBACK_JWT" \
  -H "X-Timeback-Tenant: $TENANT_ID"

SELECT
  ae.id,
  ae.event_date,
  ae.category,
  ae.duration_minutes,
  ae.student_id,
  p.first_name,
  p.last_name,
  pm.place_id AS school_id_as_of_event,
  pl.name AS school_name_as_of_event
FROM alpha.attendance_event_view ae
JOIN alpha.person p
  ON p.tenant_id = ae.tenant_id
 AND p.person_id = ae.student_id
JOIN alpha.place_membership pm
  ON pm.tenant_id = ae.tenant_id
 AND pm.person_id = ae.student_id
 AND pm.role_kind = 'student'
 AND pm.is_time_locatable = true
 AND pm.begin_date <= ae.event_date
 AND (pm.end_date IS NULL OR pm.end_date >= ae.event_date)
JOIN alpha.place pl
  ON pl.tenant_id = pm.tenant_id
 AND pl.place_id = pm.place_id
WHERE ae.tenant_id = :tenant_id
  AND ae.student_id = :student_id
  AND ae.event_date >= :as_of::date - interval '7 days'
  AND ae.event_date < :as_of::date
  AND ae.is_deleted = false
ORDER BY ae.event_date DESC, ae.id DESC
LIMIT :page_size;

curl "$EVENTS_BASE_URL/discipline-events?studentId=person_ada_lovelace&from=2026-05-01&to=2026-06-04&pageSize=50" \
  -H "Authorization: Bearer $TIMEBACK_JWT" \
  -H "X-Timeback-Tenant: $TENANT_ID"

SELECT
  de.id,
  de.incident_id,
  de.incident_date,
  de.incident_time,
  de.behavior,
  de.location,
  de.participation_code,
  de.student_id,
  p.first_name,
  p.last_name,
  pm.place_id AS school_id_as_of_incident
FROM alpha.discipline_event_view de
LEFT JOIN alpha.person p
  ON p.tenant_id = de.tenant_id
 AND p.person_id = de.student_id
LEFT JOIN alpha.place_membership pm
  ON pm.tenant_id = de.tenant_id
 AND pm.person_id = de.student_id
 AND pm.role_kind = 'student'
 AND pm.is_time_locatable = true
 AND pm.begin_date <= de.incident_date
 AND (pm.end_date IS NULL OR pm.end_date >= de.incident_date)
WHERE de.tenant_id = :tenant_id
  AND de.student_id = :student_id
  AND de.incident_date >= :from_date
  AND de.incident_date < :to_date
  AND de.is_deleted = false
ORDER BY de.incident_date DESC, de.id DESC
LIMIT :page_size;

Normal app writes route to the Ed-Fi 1EdTech base surface; production migration can call POST /source-imports with horizons_attendance_event_v1 or horizons_discipline_event_v1 and must get public view rows afterward.

CREATE VIEW alpha.attendance_event_view AS
SELECT
  c.tenant_id,
  c.edfi_local_id AS id,
  c.record_kind AS source_record_kind,
  c.student_sourced_id AS student_id,
  c.school_sourced_id AS school_id,
  c.class_sourced_id AS class_id,
  (c.payload_json #>> '{AttendanceEvent,EventDate}')::date AS event_date,
  dc.code_value AS category,
  (c.payload_json #>> '{ArrivalTime}')::time AS arrived_at,
  (c.payload_json #>> '{DepartureTime}')::time AS departed_at,
  COALESCE((c.payload_json #>> '{SchoolAttendanceDuration}')::integer,
           (c.payload_json #>> '{SectionAttendanceDuration}')::integer) AS duration_minutes,
  c.updated_at,
  c.is_deleted
FROM edfi.canonical_record c
JOIN edfi.edfi_descriptor_code dc
  ON dc.tenant_id = c.tenant_id
 AND dc.descriptor_type = 'AttendanceEventCategory'
 AND dc.code_value = c.payload_json #>> '{AttendanceEvent,AttendanceEventCategoryDescriptor}'
WHERE c.record_kind IN ('StudentSchoolAttendanceEvent', 'StudentSectionAttendanceEvent');

CREATE VIEW alpha.discipline_event_view AS
SELECT
  c.tenant_id,
  c.edfi_local_id AS id,
  c.source_key_json #>> '{IncidentIdentifier}' AS incident_id,
  c.student_sourced_id AS student_id,
  c.school_sourced_id AS school_id,
  (c.payload_json #>> '{IncidentDate}')::date AS incident_date,
  (c.payload_json #>> '{IncidentTime}')::time AS incident_time,
  behavior.code_value AS behavior,
  participation.code_value AS participation_code,
  location.code_value AS location,
  c.payload_json #>> '{IncidentDescription}' AS description,
  c.updated_at,
  c.is_deleted
FROM edfi.canonical_record c
LEFT JOIN edfi.edfi_descriptor_code behavior
  ON behavior.tenant_id = c.tenant_id
 AND behavior.descriptor_type = 'Behavior'
 AND behavior.code_value = c.payload_json #>> '{BehaviorDescriptor}'
LEFT JOIN edfi.edfi_descriptor_code participation
  ON participation.tenant_id = c.tenant_id
 AND participation.descriptor_type = 'DisciplineIncidentParticipationCode'
 AND participation.code_value = c.payload_json #>> '{DisciplineIncidentParticipationCodes,0}'
LEFT JOIN edfi.edfi_descriptor_code location
  ON location.tenant_id = c.tenant_id
 AND location.descriptor_type = 'IncidentLocation'
 AND location.code_value = c.payload_json #>> '{IncidentLocationDescriptor}'
WHERE c.record_kind IN ('DisciplineIncident', 'StudentDisciplineIncidentBehaviorAssociation');