SP{student.totalSp}Rank {student.rank} of {student.cohortSize}
SPA — Peer Teaching Points
-No validated SPA endorsements on record yet for {data.activity}. Learn a question and get endorsed, or endorse a peer — SP lands in your SP Bank automatically as each is validated.
-
-
-
-
-
-
-
-
-
-
-
- );
-}
-
function LevelStatus({ student }) {
const tier = String(student.trophyLeague || 'Bronze').split(' ')[0].toLowerCase();
return (
@@ -442,98 +357,49 @@ function LeaderboardTabs({ overall = [], group = [], groupLabel }) {
);
}
-// SP trajectory modal — the student's weekly cumulative SP vs cohort + onboarding-group
-// means (reference lines cached in TrajectorySnapshot; own line built live from the ledger).
-function TrajectoryModal({ student, onClose }) {
- const [data, setData] = useState(null);
- useEffect(() => {
- fetch(`${API}/trajectory/state?email=${encodeURIComponent(student.email)}`).then(r => r.json()).then(setData);
- }, [student.email]);
-
- const series = data ? [
- { key: 'you', label: 'You', color: 'var(--primary)', points: data.you, width: 3, dots: true },
- { key: 'cohort', label: 'Cohort average', color: '#94a3b8', points: data.cohort, width: 2, dash: '5 4' },
- { key: 'group', label: data.groupLabel ? `Your group (${data.groupLabel})` : 'Your group', color: '#8b5cf6', points: data.group, width: 2 }
- ].filter(s => s.points && s.points.length) : [];
-
- const weeks = data?.weeks || 10;
- const yMax = Math.max(10, ...series.flatMap(s => s.points.map(p => p.sp)));
- const W = 760, H = 400, padL = 52, padR = 18, padT = 18, padB = 42;
- const plotW = W - padL - padR, plotH = H - padT - padB;
- const sx = wk => padL + (weeks <= 1 ? 0 : (wk - 1) / (weeks - 1) * plotW);
- const sy = sp => padT + (1 - sp / yMax) * plotH;
- const yTicks = [0, 0.25, 0.5, 0.75, 1].map(f => Math.round(yMax * f));
- const xTicks = Array.from({ length: weeks }, (_, i) => i + 1);
-
+function StudentPulse({ profile, badges, nextActions }) {
+ const { student, cohort, attendance, polls, transactions } = profile;
+ const qualified = attendance.filter(a => a.qualified).length;
+ const pollAttempted = polls.reduce((sum, p) => sum + p.attemptedQuestions, 0);
+ const pollTotal = polls.reduce((sum, p) => sum + p.totalQuestions, 0);
+ const trend = transactions.map(tx => ({ label: tx.sessionLabel || 'Start', value: tx.balanceAfter }));
return (
- SPA — Peer Teaching Points
-For {data.activity}, SP is credited to your SP Bank automatically as each endorsement is validated — +{config.learnUnit} SP per question you learn, +{config.teachUnit} SP per peer you teach. No claiming needed.
-
- {/* Track A — Learning */}
-
-
-
- {/* Track B — Teaching */}
-
-
-
-
- A
- Learning
+{learn.sp} SPQuestions you were validly endorsed on
-
-
- {learn.validated > learn.cap && {learn.validated}validated
- {learn.credited}credited
- ×{learn.unit}SP each
- Capped at {learn.cap} — extra {learn.validated - learn.cap} not counted
}
- B
- Teaching
+{teach.sp} SPPeers you validly endorsed
-
-
- {teach.validated > teach.cap && {teach.validated}validated
- {teach.credited}credited
- ×{teach.unit}SP each
- Capped at {teach.cap} — extra {teach.validated - teach.cap} not counted
}
- SPA SP summary
| Learning (Track A) — {learn.credited} × {config.learnUnit} | +{learn.sp} SP |
| Teaching (Track B) — {teach.credited} × {config.teachUnit} | +{teach.sp} SP |
| Total credited to SP Bank (max {maxSp}) | +{creditedSp} SP |
| {penalty.fraud ? '⚠️ Fraud penalty' : '⚠️ Audit-failure penalty'} — −{Math.round(penalty.rate * 100)}% of current SP{penalty.at ? ` on ${new Date(penalty.at).toLocaleDateString()}` : ''} | -−{penalty.applied} SP | -
- ✅ Auto-credited to your SP Bank — current balance {data.totalSp} SP. - {penalty.done && penalty.applied > 0 ? ' An integrity penalty was applied (see the debit row in your SP Bank).' : ''} -
-
-
e.stopPropagation()}>
-
-
-
+
- );
-}
-
-function StudentPulse({ profile }) {
- const { student, cohort, transactions } = profile;
- const [showTraj, setShowTraj] = useState(false);
- const trend = transactions.map(tx => ({ label: tx.sessionLabel || 'Start', value: tx.balanceAfter }));
- return (
- <>
-
-
-
+ Your trajectory
-SP over your internship — you vs cohort
-
+ Standing
+ Rank {student.rank}
+
+ {cohort.pointsToTop50 === 0 ? 'You are in the Top 50.' : `${cohort.pointsToTop50} SP needed to enter Top 50.`}
+{cohort.pointsToNextRank === 0 ? 'You are leading your comparison group.' : `${cohort.pointsToNextRank} SP needed for next rank.`}
+
+ Cohort comparison
+
-
+ Your SP: {student.totalSp}
+ Cohort avg: {cohort.averageSp}
+ Top 50 cutoff: {cohort.top50Cutoff ?? '-'}
+ Top 10 cutoff: {cohort.top10Cutoff ?? '-'}
- {!data ? Loading…
: series.length === 0 ? ( -Not enough data yet — check back after your first week.
- ) : ( - <> -
- {series.map(s => {s.label})}
-
-
-
-
- Cumulative SP, aligned to each student's own join week so everyone is compared fairly regardless of start date.{data.computedAt ? ` Cohort lines updated ${new Date(data.computedAt).toLocaleDateString()}.` : ''}
- - )}
- Standing
- Rank {student.rank}
-
-
-
);
}
@@ -657,464 +515,6 @@ function Leaderboard({ rows }) {
);
}
-const fmtDate = d => d ? new Date(d).toLocaleDateString(undefined, { day: 'numeric', month: 'short' }) : '—';
-const toInput = d => d ? new Date(d).toISOString().slice(0, 10) : '';
-
-// The unified phase-by-phase progress + SP tab. Four phases: Standups, ViBe, SPA,
-// Projects. Standups & ViBe show real SP; SPA & Projects are placeholders until the
-// Samagama data (and their SP rule) land. Goal *staking* lives in the Commitments tab.
-const NEXT_NUDGE = { standup: 'Next up: push your ViBe courses.', vibe: 'Next up: keep your SPA pace.', spa: 'Next up: ship your first project PR.', project: 'On track across the board — keep it up!' };
-
-// Goal block that lives ON a phase card: set a target date (none/missed) → pace bar
-// once active → "reached" when done. Unit-aware (min for standups, % for ViBe). A GOAL
-// is a self-set target (no SP) — distinct from a COMMITMENT (staking SP, the Stake link).
-function PhaseGoal({ phaseKey, field, goal, targetText, form, setForm, onSave }) {
- const isPct = goal.unit === '%';
- const metric = isPct ? `${goal.progressPct}% done` : `${goal.current}/${goal.target} ${goal.unit} (${goal.progressPct}%)`;
- const paceLeft = isPct
- ? `${goal.remainingPct}% to go · ~${goal.perDay ?? '—'}%/day to stay on track`
- : `${goal.remaining} ${goal.unit} to go · ~${goal.perDay ?? '—'} ${goal.unit}/${goal.perDayUnit || 'day'} to stay on track`;
-
- if (goal.status === 'achieved') {
- return Loading your journey… ;
- if (!data.eligible) return My Journey isn’t available for your cohort yet. ;
-
- const { standups, vibe, goals } = data;
-
- const saveTarget = async (field, value) => {
- const r = await fetch(`${API}/journey/plan`, {
- method: 'PUT', headers: { 'Content-Type': 'application/json' },
- body: JSON.stringify({ email, [field]: value })
- });
- const j = await r.json();
- if (!r.ok) { setErr(j.error); return; }
- setErr(null); setData(j);
- };
- const gp = { form, setForm, onSave: saveTarget };
-
- return (
- Loading ViBe Goals… ;
- if (!data.eligible) return ViBe Goals isn’t available for your cohort yet. ;
-
- const cur = data.current, cfg = data.config;
- const s = +form.stake, m = +form.multiplier, g = +form.goalPct;
- const loss = cfg.penaltyFactor * s * m, win = s * m, need = s + loss; // stake debited + worst-case penalty
- const daysOut = form.deadline
- ? Math.round((new Date(form.deadline).setHours(0, 0, 0, 0) - new Date().setHours(0, 0, 0, 0)) / 86400000) : 0;
- const availForBet = data.available + (editing && data.active ? data.active.reserved + data.active.stake : 0);
-
- let problem = null;
- if (!cur) problem = 'All courses complete — nothing to commit to.';
- else if (g <= cur.floorPct) problem = `Goal must beat the weekly floor (${cur.floorPct}%).`;
- else if (daysOut < 1 || daysOut > cfg.maxBetDays) problem = `Deadline must be 1–${cfg.maxBetDays} days out.`;
- else if (g > cur.remaining) problem = `Goal exceeds your remaining ${cur.remaining}%.`;
- else if (need > availForBet) problem = `You need ${need} SP (stake ${s} + up to ${loss} loss); you have ${availForBet}.`;
-
- const post = async (url, body, method = 'POST') => {
- const r = await fetch(url, { method, headers: { 'Content-Type': 'application/json' }, body: JSON.stringify(body) });
- const j = await r.json(); if (!r.ok) { setErr(j.error); return null; } setErr(null); return j;
- };
- const place = async () => { const j = await post(`${API}/vibe/bet`,
- { email, course: cur.key, goalPct: g, stake: s, multiplier: m, deadline: form.deadline }); if (j) setData(j); };
- const saveEdit = async () => { const j = await post(`${API}/vibe/bet/${data.active._id}`,
- { email, goalPct: g, stake: s, multiplier: m }, 'PUT'); if (j) { setEditing(false); setData(j); } };
- const settle = async (result) => { const j = await post(`${API}/vibe/bet/${data.active._id}/settle`,
- { email, result }); if (j) { setEditing(false); setData(j); } };
-
- const showForm = cur && (!data.active || editing);
-
- return (
- Loading standups… ;
- if (!data.eligible) return Standup commitments aren’t available for your cohort yet. ;
-
- const tier = data.tiers.find(t => t.key === tierKey) || data.tiers[0];
- const stake = tier.stake, win = stake * multiplier, loss = data.penaltyFactor * stake * multiplier;
- const problem = data.active
- ? 'You already have an active standup commitment this week.'
- : loss > data.available ? `You need ${loss} SP free to cover a possible miss; you have ${data.available}.` : null;
-
- const post = async (url, body) => {
- const r = await fetch(url, { method: 'POST', headers: { 'Content-Type': 'application/json' }, body: JSON.stringify(body) });
- const j = await r.json(); if (!r.ok) { setErr(j.error); return null; } setErr(null); return j;
- };
- const place = async () => { const j = await post(`${API}/standup/commit`, { email, tierKey, multiplier }); if (j) setData(j); };
- const settle = async (result) => { const j = await post(`${API}/standup/commit/${data.active._id}/settle`, { email, result }); if (j) setData(j); };
-
- return (
-
{cohort.pointsToTop50 === 0 ? 'You are in the Top 50.' : `${cohort.pointsToTop50} SP to enter Top 50.`}
-
- Cohort avg: {cohort.averageSp}
- Top 50: {cohort.top50Cutoff ?? '—'}
- Top 10: {cohort.top10Cutoff ?? '—'}
-
+
+ Session health
+ setShowTraj(false)} />}
-
+
+
+ {qualified}/{attendance.length} attendance qualified
+ {pollAttempted}/{pollTotal} polls attempted
-
-
- {showTraj &&
+ Badges
+
+ {badges.map(badge => {badge})}
+
+ SP trend
+
+
+ What to do next
+
+
);
}
@@ -551,45 +417,38 @@ function Sparkline({ points }) {
);
}
+function buildBadges(profile) {
+ const badges = [];
+ const qualifiedPct = profile.attendance.length ? profile.attendance.filter(a => a.qualified).length / profile.attendance.length : 0;
+ const pollAttempted = profile.polls.reduce((sum, p) => sum + p.attemptedQuestions, 0);
+ const pollTotal = profile.polls.reduce((sum, p) => sum + p.totalQuestions, 0);
+ if (profile.student.rank <= 50) badges.push('Top 50');
+ if (qualifiedPct >= 0.75) badges.push('Consistent Attendee');
+ if (pollTotal && pollAttempted / pollTotal >= 0.75) badges.push('Poll Champion');
+ if (profile.student.totalSp >= profile.cohort.averageSp) badges.push('Above Average');
+ return badges.length ? badges : ['Getting Started'];
+}
+
+function buildNextActions(profile) {
+ const actions = [];
+ if (profile.cohort.pointsToTop50 > 0) actions.push(`Earn ${profile.cohort.pointsToTop50} more SP to enter Top 50.`);
+ if (profile.attendance.some(a => !a.qualified)) actions.push('Attend at least 75% of upcoming sessions to avoid attendance debit.');
+ if (profile.polls.some(p => p.missedQuestions > 0)) actions.push('Attempt every poll question to avoid poll debit.');
+ actions.push('Check your SP Bank after each session to understand every credit and debit.');
+ return actions.slice(0, 4);
+}
+
function Tabs({ tab, setTab, tabs }) {
return ;
}
function SpBank({ transactions }) {
- const [size, setSize] = useState(10);
- // Server sends oldest→newest (sorted dateTime asc); show newest first.
- const rows = useMemo(() => [...transactions].reverse(), [transactions]);
- const shown = rows.slice(0, size);
- const downloadCsv = () => {
- const esc = v => `"${String(v ?? '').replace(/"/g, '""')}"`;
- const lines = [['Date & time', 'Credit', 'Debit', 'Balance', 'Reason'].join(',')].concat(
- rows.map(tx => [
- new Date(tx.dateTime).toLocaleString(),
- tx.appliedDelta > 0 ? tx.appliedDelta : '',
- tx.appliedDelta < 0 ? tx.appliedDelta : '',
- tx.balanceAfter, tx.reason
- ].map(esc).join(',')));
- const url = URL.createObjectURL(new Blob([lines.join('\n')], { type: 'text/csv' }));
- const a = document.createElement('a');
- a.href = url; a.download = 'sp-bank-statement.csv'; a.click();
- URL.revokeObjectURL(url);
- };
return (
- {nextActions.map(action =>
- {action} )}
-
+ SP Bank
-
-
-
-
- SP Bank Statement
Date & timeCreditDebitBalanceReason
- {shown.map(tx => (
+ {transactions.map(tx => (
{new Date(tx.dateTime).toLocaleString()}
{tx.appliedDelta > 0 ? `+${tx.appliedDelta}` : ''}
@@ -599,7 +458,6 @@ function SpBank({ transactions }) {
))}
Showing {Math.min(size, rows.length)} of {rows.length} — download CSV for the full statement.
🎯 Goal reached 🎉{NEXT_NUDGE[phaseKey]}
;
- }
- if (goal.status === 'active') {
- return (
-
- {goal.pending ? (
- 🎯 Goal: by {fmtDate(goal.targetDate)} · {goal.daysLeft}d left · progress soon
- ) : (
- <>
- 🎯 Goal: {metric} · by {fmtDate(goal.targetDate)} · {goal.daysLeft}d left
-
- );
- }
- return (
-
- {paceLeft}
-
- )}
-
-
- 🎯 {goal.status === 'missed' ? `Goal missed — set a new date to ${targetText}` : `Set a target date to ${targetText}`}
-
-
- );
-}
-
-function MyJourney({ student, goToCommitment, canCommit = false }) {
- const email = student.email;
- const [data, setData] = useState(null);
- const [form, setForm] = useState({});
- const [showTraj, setShowTraj] = useState(false);
- const [err, setErr] = useState(null);
-
- const load = async () => {
- const r = await fetch(`${API}/journey/state?email=${encodeURIComponent(email)}`);
- setData(await r.json());
- };
- useEffect(() => { load(); }, [email]);
-
- if (!data) return
- setForm({ ...form, [field]: e.target.value })} />
-
-
- {goal.minDate && Earliest realistic: {fmtDate(goal.minDate)}{goal.paceHint ? ` · ${goal.paceHint}` : ''}}
-
-
-
-
-
-
-
- {showTraj && setShowTraj(false)} />}
-
- );
-}
-
-function courseName(ladder, key) { const c = ladder.find(l => l.key === key); return c ? c.name : key; }
-// net SP over the whole commitment: won -> win minus the debited stake; lost -> stake + penalty
-function netFor(b) { return b.status === 'won' ? b.potentialWin - b.stake : -(b.stake + b.potentialLoss); }
-
-// The Commitments hub: one accordion card per phase. Every phase shares the same SP
-// engine (stake debited → HIT wins it back multiplied / MISS loses a penalty); only
-// the target metric differs. ViBe is live; the other three land one by one.
-const COMMITMENT_TYPES = [
- { key: 'vibe', name: 'ViBe courses', blurb: 'ViBe commitments are temporarily on hold — we’re reconnecting the ViBe course-completion feed. They’ll be back up soon.', ready: false },
- { key: 'standup', name: 'Standups', blurb: 'Standup commitments are paused — standups have moved to YouTube Live and the attendance module is being reworked. They’ll return once the new attendance tracking is ready.', ready: false },
- { key: 'spa', name: 'SPA — Matrix Mystics', blurb: 'Pledge to solve N of the 53 problems by a date.', ready: false },
- { key: 'project', name: 'Projects', blurb: 'Pledge to raise / merge N pull requests by a date.', ready: false }
-];
-
-function Commitments({ student, initialPhase }) {
- const [phase, setPhase] = useState(initialPhase || 'vibe');
- const active = COMMITMENT_TYPES.find(t => t.key === phase) || COMMITMENT_TYPES[0];
- return (
- My Journey
-🎯 Goal = your own finish-date target; it tracks your pace, no SP.{canCommit && <> 🎲 Commitment = stake SP on a bet — the Stake SP link.}
- {err &&{err}
} -
- {/* Standups — continuous, no completion goal; commitment only */}
-
-
-
- {/* ViBe — goal + commitment */}
-
-
-
- {/* SPA — goal (date) works now; progress data + commitment coming soon */}
-
-
-
- {/* Projects — goal (date) works now; progress data coming soon */}
-
-
-
-
- 1
- Standups
+{standups.sp} SPZoom attendance + Spandan polls
-
-
- {standups.zoomMinutes}Zoom minutes
- {standups.sessionsAttended}sessions attended
- {standups.pollsAttempted}/{standups.pollsTotal}polls attempted
-
- Attendance +{standups.spAttendance}
- Polls +{standups.spPolls}
-
- 2
- ViBe courses
{vibe.sp >= 0 ? '+' : ''}{vibe.sp} SP{vibe.clearedCount}/{vibe.totalCourses} courses complete
-
- {vibe.ladder.map(l => (
-
- {vibe.activeCommitment &&
- {l.cleared ? '✓' : `${l.pct}%`}{l.name}
-
- ))}
- 🎲 Active commitment: +{vibe.activeCommitment.goalPct}%
}
- 3
- SPA — Matrix Mystics
Data soon53-problem set · progress data coming soon
-4
- Projects
Data soonPull requests · progress data coming soon
-
-
-
- Your SP trajectory
-Your Spurti Points over time vs the cohort and your group.
-
-
-
- {active.ready
- ? (active.key === 'vibe' ?
- );
-}
-
-function VibeGoals({ student }) {
- const email = student.email;
- const [data, setData] = useState(null);
- const [form, setForm] = useState({ goalPct: 20, stake: 100, multiplier: 4, deadline: '' });
- const [editing, setEditing] = useState(false);
- const [err, setErr] = useState(null);
-
- const load = async () => {
- const r = await fetch(`${API}/vibe/state?email=${encodeURIComponent(email)}`);
- setData(await r.json());
- };
- useEffect(() => {
- load();
- const d = new Date(); d.setDate(d.getDate() + 2);
- setForm(f => ({ ...f, deadline: d.toISOString().slice(0, 10) }));
- }, [email]);
-
- if (!data) return Commitments
-Stake SP on a goal — hit it by the deadline to win it back multiplied; miss and lose a penalty. One active per phase.
-
- {COMMITMENT_TYPES.map(t => (
-
- ))}
-
- {active.blurb}{!['standup', 'vibe'].includes(active.key) && <>
Coming soon — same stake-and-win mechanic, tuned to this phase.}
-
-
-
- {cur && (
-
-
- )}
-
- {cur && (
-
-
- )}
-
-
-
-
-
-
- ) :
-
- );
-}
-
-// Standup commitment — weekly, attendance-only, keep-the-stake. Student picks a tier
-// (81–90 → stake 20 / 91–100 → stake 50, fixed) and a confidence (2×/3×/4×). HIT pays
-// +stake×conf on top of earned attendance; MISS charges −0.5×stake×conf off the balance.
-function StandupGoals({ student }) {
- const email = student.email;
- const [data, setData] = useState(null);
- const [tierKey, setTierKey] = useState('91-100');
- const [multiplier, setMultiplier] = useState(4);
- const [err, setErr] = useState(null);
-
- const load = async () => {
- const r = await fetch(`${API}/standup/state?email=${encodeURIComponent(email)}`);
- setData(await r.json());
- };
- useEffect(() => { load(); }, [email]);
-
- if (!data) return Your course path
-Courses unlock in order — you work on and set commitments for your current course only. Prior completions are credited automatically.
-
- {data.ladder.map((l, i) => (
-
- {i > 0 &&
- ))}
-
- →
}
-
- {i + 1}{l.name}
- {l.prior ? 'credited ✓' : l.cleared ? '100% ✓' : (cur && cur.key === l.key ? `${l.pct}% · in progress` : '🔒 locked')}
-
- Current course — {cur.name}
-
-
-
- This week (floor)
- {data.weeklyFloor.doneHours} h
- {cfg.floorHours} h required · {data.weeklyFloor.met
- ? +{cfg.floorSp} SP earned
- : not yet}
-
-
- {cur.name} — completion
- {cur.pct}%
- {cur.remaining}% left · ≈ {(cur.pct / 100 * cur.hours).toFixed(1)} / {cur.hours} h*
-
-
-
{editing ? 'Edit your commitment' : 'Set a goal & commit extra SP'}
-Your stake is debited now. Hit your goal by the deadline → win it back multiplied; miss → lose an extra penalty on top. One commitment per course, deadline up to {cfg.maxBetDays} days away.
- {!showForm && data.active && -You have an active commitment on {cur.name}. Edit it below, or resolve it with the demo buttons.
}
- {showForm && (
-
-
-
- )}
-
-
- setForm({ ...form, goalPct: e.target.value })} />%
- Allowed {cur.floorPct}%–{cur.remaining}% (floor → remaining) · ≈ {(g / 100 * cur.hours).toFixed(1)} h
-
- setForm({ ...form, deadline: e.target.value })} />
- {editing ? 'Fixed — can’t be changed after placing.' : `Up to ${cfg.maxBetDays} days away.`}
-
-
- setForm({ ...form, stake: e.target.value })} />
- {cfg.stakeMin}–{cfg.stakeMax} SP.
-
-
-
- {cfg.multipliers.map(x =>
- )}
-
-
- Staked now−{s}
- If you HIT+{win}net +{win - s}
- If you MISS−{loss}net −{s + loss}
- Left after placing{availForBet - s - loss}
-
- {editing
- ? <>
-
- : }
- {problem || `✓ Covered — ${loss} SP reserved until it settles.`}
-
- {err && {err}
} -Your active commitment
- {data.active ? ( -
-
- ) :
-
- {courseName(data.ladder, data.active.course)} — raise completion by {data.active.goalPct}%
-staked {data.active.stake} (debited) @ {data.active.multiplier}× · by {new Date(data.active.deadline).toLocaleDateString()} · risk −{data.active.potentialLoss} more on miss
-
-
- Hit +{data.active.potentialWin} / Miss −{data.active.potentialLoss}
-
- {!editing && }
-
-
-
- No active commitment right now — set one above.
} -Past commitments
- {data.history.length ? ( -| Course | Goal | Stake | Result | Net SP |
|---|---|---|---|---|
| {courseName(data.ladder, b.course)} | +{b.goalPct}% | {b.stake} @ {b.multiplier}× | -{b.status === 'won' ? 'HIT' : 'MISS'} | -{netFor(b) >= 0 ? '+' : ''}{netFor(b)} |
No settled commitments yet.
} -
-
-
-
- {!data.active && (
-
-
- )}
-
-
-
-
-
-
- ) :
-
- );
-}
-
function AdminView({ admin, auth, onBack }) {
const [tab, setTab] = useState('leaderboard');
const [leaderLimit, setLeaderLimit] = useState(50);
@@ -1183,7 +583,7 @@ function AdminView({ admin, auth, onBack }) {
This week’s standups — {data.weekLabel}
-Pledge to attend all {data.sessionsThisWeek} standups this week at a chosen attendance tier. Attendance only — polls stay as poll-points. Your stake isn’t deducted: hit your pledge for a bonus on top of the attendance points you earn, miss and a penalty applies.
-
-
- Attended so far{data.attendedThisWeek}/{data.sessionsThisWeek}this week
- Avg attendance{data.avgPctThisWeek != null ? data.avgPctThisWeek + '%' : '—'}so far
- Set a standup commitment
-
-
-
-
- {data.tiers.map(t =>
- )}
- Higher tier = higher bar and bigger reward. Beating your tier still counts as a hit.
-
-
- {data.multipliers.map(x =>
- )}
-
-
- Stake (fixed by tier){stake}
- If you HIT+{win}bonus, on top of attendance
- If you MISS−{loss}penalty off your balance
-
-
- {problem || `✓ Covered · settles ${new Date(data.deadline).toLocaleDateString()}`}
-
- {err && {err}
} -Your active commitment
- {data.active ? ( -
-
- ) :
-
- {data.active.label}
-stake {data.active.stake} (kept) · by {new Date(data.active.deadline).toLocaleDateString()} · risk −{data.active.potentialLoss} on miss
-
-
- Hit +{data.active.potentialWin} / Miss −{data.active.potentialLoss}
-
-
-
-
- No active standup commitment — set one above.
} -Past standup commitments
- {data.history.length ? ( -| Week pledge | Tier | Result | SP |
|---|---|---|---|
| {c.label} | {c.tier} | -{c.status === 'won' ? 'HIT' : 'MISS'} | -{c.resultDelta >= 0 ? '+' : ''}{c.resultDelta} |
No settled standup commitments yet.
} -Admin Dashboard
Spurti Control Room
Yet to onboard{stats?.yetToOnboard ?? admin.yetToOnboard ?? 0}|Active{stats?.activeStudents ?? admin.activeStudents ?? admin.students ?? 0}|Excused{stats?.excusedStudents ?? admin.excusedStudents ?? 0}{stats?.transactions ?? admin.transactions ?? 0} txns
-
@@ -1202,6 +602,7 @@ function AdminView({ admin, auth, onBack }) {
{tab === 'attendance' && : [{week,sp,n}] }
- groupLabels: { type: Object, default: {} }, // { : "1 May to 15 May" }
- computedAt: { type: Date }
-}, { minimize: false });
-
-export default mongoose.model('TrajectorySnapshot', trajectorySnapshotSchema);
diff --git a/server/models/VibeProgress.js b/server/models/VibeProgress.js
deleted file mode 100644
index 187d90c..0000000
--- a/server/models/VibeProgress.js
+++ /dev/null
@@ -1,16 +0,0 @@
-import mongoose from 'mongoose';
-
-// Per-student ViBe course progress. In production this is refreshed from the ViBe
-// leaderboard API (completionPercentage). Here it is seeded with DUMMY values so
-// the module can run locally without the live snapshot cron.
-const vibeProgressSchema = new mongoose.Schema({
- email: { type: String, lowercase: true, trim: true, required: true, index: true },
- course: { type: String, required: true }, // 'onboarding' | 'ai' | 'mern'
- pct: { type: Number, default: 0 }, // completionPercentage 0–100 (from ViBe)
- weekHours: { type: Number, default: 0 }, // content-hours done this week (for the floor)
- priorCompleted: { type: Boolean, default: false } // credited from a prior program (sheet crosswalk)
-}, { timestamps: true });
-
-vibeProgressSchema.index({ email: 1, course: 1 }, { unique: true });
-
-export default mongoose.model('VibeProgress', vibeProgressSchema);
diff --git a/server/routes/engagement.js b/server/routes/engagement.js
new file mode 100644
index 0000000..99aeaf2
--- /dev/null
+++ b/server/routes/engagement.js
@@ -0,0 +1,46 @@
+import { Router } from 'express';
+import { fetchStudentEngagementData } from '../engagement/fetchData.js';
+import { classifyBand } from '../engagement/classifyBand.js';
+import Student from '../models/Student.js';
+
+const router = Router();
+
+router.get('/engagement/:email', async (req, res) => {
+ try {
+ const email = String(req.params.email || '').trim().toLowerCase();
+ if (!email) return res.status(400).json({ error: 'Email is required' });
+
+ const student = await Student.findOne({ email }).lean();
+ if (!student) return res.status(404).json({ error: 'Student not found' });
+
+ const data = await fetchStudentEngagementData(email);
+ const result = classifyBand(data.current, data.previous);
+
+ res.json({
+ email,
+ name: student.name,
+ totalSp: student.totalSp,
+ band: result.band,
+ reason: result.reason,
+ stats: result.stats,
+ windows: {
+ windowSize: data.current.length,
+ current: data.current.map(s => ({
+ label: s.label,
+ attendancePct: s.attendancePct,
+ spDelta: s.spDelta
+ })),
+ previous: data.previous.length > 0 ? data.previous.map(s => ({
+ label: s.label,
+ attendancePct: s.attendancePct,
+ spDelta: s.spDelta
+ })) : null
+ }
+ });
+ } catch (err) {
+ console.error('Engagement API error:', err);
+ res.status(500).json({ error: 'Internal server error' });
+ }
+});
+
+export default router;
diff --git a/server/scripts/buildTrajectories.js b/server/scripts/buildTrajectories.js
deleted file mode 100644
index dc36802..0000000
--- a/server/scripts/buildTrajectories.js
+++ /dev/null
@@ -1,15 +0,0 @@
-// Recompute the cohort + onboarding-group average SP trajectories and store the
-// 'latest' TrajectorySnapshot. Run periodically (wire into the analytics cron in prod).
-// node server/scripts/buildTrajectories.js
-import mongoose from 'mongoose';
-import { MONGO_URI } from '../config.js';
-import { computeAndStoreTrajectories } from '../services/trajectory.js';
-
-async function main() {
- await mongoose.connect(MONGO_URI);
- const r = await computeAndStoreTrajectories();
- console.log('trajectory snapshot rebuilt:', r);
- await mongoose.disconnect();
-}
-
-main().catch(e => { console.error(e); process.exit(1); });
diff --git a/server/scripts/seedVibeDummy.js b/server/scripts/seedVibeDummy.js
deleted file mode 100644
index 2227e28..0000000
--- a/server/scripts/seedVibeDummy.js
+++ /dev/null
@@ -1,155 +0,0 @@
-// Seed DUMMY 16-July-cohort students so the ViBe Goals tab can be demoed locally.
-// Idempotent: upserts by email (all end in @dummy.test) and resets their ViBe rows.
-// Existing real students (all onboarded < 16 Jul) stay ineligible and untouched.
-//
-// node server/scripts/seedVibeDummy.js
-import mongoose from 'mongoose';
-import { MONGO_URI } from '../config.js';
-import Student from '../models/Student.js';
-import VibeProgress from '../models/VibeProgress.js';
-import Commitment from '../models/Commitment.js';
-import SPTransaction from '../models/SPTransaction.js';
-import AttendanceRecord from '../models/AttendanceRecord.js';
-import PollRecord from '../models/PollRecord.js';
-import JourneyProgress from '../models/JourneyProgress.js';
-import JourneyPlan from '../models/JourneyPlan.js';
-
-const D = (y, m, d) => new Date(Date.UTC(y, m - 1, d));
-
-// Build a small SP ledger that ends exactly at `sp`, so the SP Bank has rows.
-function ledgerFor(email, sp, startDay) {
- const rows = []; let bal = 0;
- const push = (category, delta, reason, label, day) => {
- bal += delta;
- rows.push({ email, category, sessionLabel: label, deltaMode: 'absolute',
- deltaValue: delta, appliedDelta: delta, balanceAfter: bal, reason, dateTime: D(2026, 7, day) });
- };
- // insert in strict chronological order so the running balance stays monotonic
- push('initial', 100, 'Welcome bonus on joining Summership', '', startDay);
- push('attendance', 10, 'Attendance credit — evening session', `${startDay + 1} Jul Evening`, startDay + 1);
- push('poll', 5, 'Poll participation', `${startDay + 1} Jul Evening`, startDay + 1);
- push('attendance', 10, 'Attendance credit — evening session', `${startDay + 2} Jul Evening`, startDay + 2);
- push('attendance', 10, 'Attendance credit — evening session', `${startDay + 3} Jul Evening`, startDay + 3);
- const diff = sp - bal; // final adjustment to land exactly on totalSp
- if (diff !== 0) push('manual', diff, diff > 0 ? 'Instructor award' : 'Attendance shortfall adjustment', '', startDay + 3);
- return rows;
-}
-
-// Build dummy Standup evidence (Zoom attendance + Spandan poll rows) so the Journey
-// "Standups" card shows real numbers. std = { sessions, minutes, pollsAttempted, pollsTotal }.
-// One AttendanceRecord + one PollRecord per session (PollRecord is a per-session
-// aggregate, unique on email+sessionLabel), with the poll questions spread evenly.
-function standupRecordsFor(email, studentId, std, startDay) {
- const att = [], polls = [];
- const spread = (total, n, i) => Math.floor(total / n) + (i < total % n ? 1 : 0);
- for (let i = 0; i < std.sessions; i++) {
- const label = `${startDay + i} Jul Evening`;
- att.push({ email, studentId, sessionLabel: label, attendedMinutes: std.minutes,
- totalSessionMinutes: 90, attendancePercentage: Math.round(std.minutes / 90 * 100), qualified: std.minutes >= 68 });
- const tot = spread(std.pollsTotal, std.sessions, i);
- const done = Math.min(tot, spread(std.pollsAttempted, std.sessions, i));
- polls.push({ email, studentId, sessionLabel: label, totalQuestions: tot,
- attemptedQuestions: done, missedQuestions: tot - done, responses: [] });
- }
- return { att, polls };
-}
-
-// name, email, start, sp, prog (per ViBe course), std (standups), spa/proj (placeholder), plan
-const DUMMY = [
- { name: 'Aadhya Rao (dummy)', email: 'aadhya.vibe@dummy.test', start: D(2026,7,16), sp: 300,
- prog: { onboarding:{pct:100}, ai:{pct:40, weekHours:1.5}, mern:{pct:0} },
- std: { sessions:5, minutes:82, pollsAttempted:8, pollsTotal:10 },
- spa: { spaSolved:18, spaPoints:220 }, proj: { prsRaised:2, prsMerged:1 },
- plan: { vibeBy: D(2026,8,20), spaBy: D(2026,9,5), projectBy: D(2026,8,28) } },
- { name: 'Vihaan Menon (dummy)', email: 'vihaan.vibe@dummy.test', start: D(2026,7,17), sp: 150,
- prog: { onboarding:{pct:100}, ai:{pct:10, weekHours:0.5}, mern:{pct:0} },
- std: { sessions:3, minutes:64, pollsAttempted:3, pollsTotal:8 },
- spa: { spaSolved:6, spaPoints:70 }, proj: { prsRaised:0, prsMerged:0 },
- plan: { vibeBy: D(2026,9,1), spaBy: null, projectBy: null } },
- { name: 'Diya Nair (dummy)', email: 'diya.vibe@dummy.test', start: D(2026,7,18), sp: 120,
- prog: { onboarding:{pct:60, weekHours:1.2}, ai:{pct:0}, mern:{pct:0} },
- std: { sessions:4, minutes:78, pollsAttempted:5, pollsTotal:6 },
- spa: { spaSolved:2, spaPoints:20 }, proj: { prsRaised:0, prsMerged:0 },
- plan: { vibeBy: null, spaBy: null, projectBy: null } },
- { name: 'Arjun Iyer (dummy)', email: 'arjun.vibe@dummy.test', start: D(2026,7,20), sp: 500,
- prog: { onboarding:{pct:100}, ai:{pct:100}, mern:{pct:20, weekHours:2} },
- std: { sessions:6, minutes:88, pollsAttempted:11, pollsTotal:12 },
- spa: { spaSolved:41, spaPoints:530 }, proj: { prsRaised:5, prsMerged:4 },
- plan: { vibeBy: D(2026,8,10), spaBy: D(2026,8,25), projectBy: D(2026,8,15) } },
- { name: 'Kabir Shah (dummy)', email: 'kabir.vibe@dummy.test', start: D(2026,7,22), sp: 200,
- prog: { onboarding:{pct:100}, ai:{prior:true}, mern:{pct:5, weekHours:1} },
- std: { sessions:2, minutes:71, pollsAttempted:2, pollsTotal:4 },
- spa: { spaSolved:9, spaPoints:110 }, proj: { prsRaised:1, prsMerged:0 },
- plan: { vibeBy: D(2026,8,31), spaBy: D(2026,9,10), projectBy: null } }
-];
-
-async function main() {
- await mongoose.connect(MONGO_URI);
- const emails = DUMMY.map(d => d.email);
- await Promise.all([
- Commitment.deleteMany({ email: { $in: emails } }),
- VibeProgress.deleteMany({ email: { $in: emails } }),
- SPTransaction.deleteMany({ email: { $in: emails } }),
- AttendanceRecord.deleteMany({ email: { $in: emails } }),
- PollRecord.deleteMany({ email: { $in: emails } }),
- JourneyProgress.deleteMany({ email: { $in: emails } }),
- JourneyPlan.deleteMany({ email: { $in: emails } })
- ]);
-
- for (const d of DUMMY) {
- await Student.updateOne(
- { email: d.email },
- { $set: {
- name: d.name, email: d.email, internshipStartDate: d.start,
- status: 'active', totalSp: d.sp, highestSpEver: d.sp,
- level: 1, trophyLeague: 'Bronze II', leaderboardGroup: '2026-07-16'
- } },
- { upsert: true }
- );
- const stu = await Student.findOne({ email: d.email }).lean();
- for (const [course, p] of Object.entries(d.prog)) {
- await VibeProgress.updateOne(
- { email: d.email, course },
- { $set: { pct: p.pct ?? 0, weekHours: p.weekHours ?? 0, priorCompleted: !!p.prior } },
- { upsert: true }
- );
- }
- await SPTransaction.insertMany(ledgerFor(d.email, d.sp, d.start.getUTCDate()));
-
- // Standups — attendance + poll evidence for the Journey card
- const { att, polls } = standupRecordsFor(d.email, stu._id, d.std, d.start.getUTCDate());
- if (att.length) await AttendanceRecord.insertMany(att);
- if (polls.length) await PollRecord.insertMany(polls);
-
- // SPA + Projects placeholder progress, and the self-declared plan
- await JourneyProgress.updateOne({ email: d.email },
- { $set: { spaSolved: d.spa.spaSolved, spaTotal: 53, spaPoints: d.spa.spaPoints,
- prsRaised: d.proj.prsRaised, prsMerged: d.proj.prsMerged } }, { upsert: true });
- await JourneyPlan.updateOne({ email: d.email },
- { $set: { vibeBy: d.plan.vibeBy, spaBy: d.plan.spaBy, projectBy: d.plan.projectBy } }, { upsert: true });
- }
-
- // A little settled history so the "Past" tables aren't empty.
- await Commitment.create({
- email: 'aadhya.vibe@dummy.test', type: 'vibe', debited: true,
- course: 'ai', goalPct: 20, baselinePct: 20,
- deadline: D(2026,7,18), stake: 100, multiplier: 2,
- potentialWin: 200, potentialLoss: 100, reserved: 0,
- label: '+20% Fundamentals of AI (stake 100 @ 2×)',
- status: 'won', resultDelta: 200, settledAt: D(2026,7,18)
- });
- // A settled standup commitment for Arjun (keep-the-stake: HIT credited the +150 bonus).
- await Commitment.create({
- email: 'arjun.vibe@dummy.test', type: 'standup', debited: false, reserved: 0,
- stake: 50, multiplier: 3, potentialWin: 150, potentialLoss: 75,
- tier: '91-100', tierFloor: 91, sessionsTarget: 6,
- label: 'Attend all 6 standups @ 91–100% (3×)',
- deadline: D(2026,7,19), status: 'won', resultDelta: 150, settledAt: D(2026,7,19)
- });
-
- console.log(`Seeded ${DUMMY.length} dummy 16-July students:`);
- DUMMY.forEach(d => console.log(` ${d.email} (start ${d.start.toISOString().slice(0,10)}, ${d.sp} SP)`));
- await mongoose.disconnect();
-}
-
-main().catch(e => { console.error(e); process.exit(1); });
diff --git a/server/server.js b/server/server.js
index 53579d2..517aa47 100644
--- a/server/server.js
+++ b/server/server.js
@@ -13,6 +13,7 @@ import PollRecord from './models/PollRecord.js';
import SPTransaction from './models/SPTransaction.js';
import SessionEvent from './models/SessionEvent.js';
import { leagueBand, levelFor, legendBadge, leaderboardGroup, groupLabel } from './services/levels.js';
+import engagementRouter from './routes/engagement.js';
import Commitment from './models/Commitment.js';
import { isVibeEligible, buildVibeState, validateBet, settleBetDemo, applySpDelta, courseByKey } from './services/vibe.js';
import { buildStandupState, placeStandup, settleStandupDemo } from './services/standup.js';
@@ -23,14 +24,8 @@ import { buildTrajectoryState } from './services/trajectory.js';
const __dirname = path.dirname(fileURLToPath(import.meta.url));
const rootDir = path.resolve(__dirname, '..');
const clientDist = path.join(rootDir, 'client', 'dist');
-// Admin auth is env-only — NO hardcoded fallback. A committed default would be a
-// public credential (anyone reading the repo could authenticate). If either is
-// unset, admin endpoints fail closed (see isAdmin) rather than accept a known value.
-const ADMIN_EMAIL = normalizeEmail(process.env.ADMIN_EMAIL || '');
-const ADMIN_TOKEN = process.env.ADMIN_TOKEN || '';
-if (!ADMIN_EMAIL || !ADMIN_TOKEN) {
- console.warn('[security] ADMIN_EMAIL/ADMIN_TOKEN not set — admin endpoints are DISABLED until both are configured in .env');
-}
+const ADMIN_EMAIL = normalizeEmail(process.env.ADMIN_EMAIL || 'dled@iitrpr.ac.in');
+const ADMIN_TOKEN = process.env.ADMIN_TOKEN || 'vled-local-admin';
// Survey triangulation pop-up(s). All driven by env so the form link / mode can
// change without a client rebuild (the client reads these via /api/config).
@@ -61,8 +56,7 @@ function makeSurvey(prefix, completedField) {
}
const SURVEY = makeSurvey('SURVEY', 'surveyCompleted');
const POLL2 = makeSurvey('POLL2', 'poll2Completed');
-const POLL3 = makeSurvey('POLL3', 'poll3Completed');
-const SURVEYS = [SURVEY, POLL2, POLL3];
+const SURVEYS = [SURVEY, POLL2];
// Cached fetch of the submitted-email set from a survey's Apps Script endpoint.
async function getSubmittedEmails(cfg) {
@@ -72,17 +66,10 @@ async function getSubmittedEmails(cfg) {
const u = cfg.responsesUrl + (cfg.responsesUrl.includes('?') ? '&' : '?') +
'secret=' + encodeURIComponent(cfg.responsesSecret);
const r = await fetch(u, { redirect: 'follow' });
- // Apps Script intermittently serves an HTML error/redirect page (esp. under
- // load) instead of JSON; parse defensively so it fails cleanly instead of
- // throwing an opaque "Unexpected token '<'".
- const body = await r.text();
- let j;
- try { j = JSON.parse(body); }
- catch { throw new Error(`non-JSON response (HTTP ${r.status}, ${body.length}B)`); }
+ const j = await r.json();
cfg._subs = { at: Date.now(), set: new Set((j.emails || []).map(e => normalizeEmail(e))) };
return cfg._subs.set;
} catch (err) {
- cfg._subs.at = Date.now(); // back off 60s on failure too — don't hammer Apps Script / spam logs
console.error(`${cfg.key} responses fetch failed:`, err?.message);
return cfg._subs.set; // serve last good cache on failure
}
@@ -245,9 +232,7 @@ async function studentPayload(student) {
leaderboardGroup: myGroup,
leaderboardGroupLabel: groupLabel(myGroup),
surveyCompleted: Boolean(student.surveyCompleted),
- poll2Completed: Boolean(student.poll2Completed),
- poll3Completed: Boolean(student.poll3Completed),
- eligibleForVibeGoals: isVibeEligible(student)
+ poll2Completed: Boolean(student.poll2Completed)
},
transactions,
polls,
@@ -265,7 +250,6 @@ async function studentPayload(student) {
}
function isAdmin(req) {
- if (!ADMIN_EMAIL || !ADMIN_TOKEN) return false; // fail closed when admin creds aren't configured
const emailOk = normalizeEmail(req.headers['x-admin-email']) === ADMIN_EMAIL;
const tokenOk = String(req.headers['x-admin-token'] || '') === ADMIN_TOKEN;
return emailOk && tokenOk;
@@ -281,8 +265,7 @@ api.get('/health', (_req, res) => res.json({ status: 'ok' }));
api.get('/config', (_req, res) => res.json({
allowStudentSearch: ALLOW_STUDENT_SEARCH,
survey: surveyPublic(SURVEY),
- poll2: surveyPublic(POLL2),
- poll3: surveyPublic(POLL3)
+ poll2: surveyPublic(POLL2)
}));
api.get('/me', async (req, res) => {
@@ -294,97 +277,6 @@ api.get('/me', async (req, res) => {
res.json({ authenticated: true, profile: await studentPayload(student) });
});
-// ---- ViBe Goals (commitment-SP module; 16 July cohort onward) ----------------
-async function vibeStudent(req) {
- const email = normalizeEmail(req.body?.email || req.query.email) || await studentEmailFromRequest(req);
- if (!email) return null;
- return Student.findOne({ $or: [{ email }, { alternateEmail: email }] }).lean();
-}
-
-api.get('/vibe/state', async (req, res) => {
- const student = await vibeStudent(req);
- if (!student) return res.status(404).json({ error: 'Student not found' });
- if (!isVibeEligible(student)) return res.json({ eligible: false });
- res.json(await buildVibeState(student));
-});
-
-api.post('/vibe/bet', async (_req, res) => {
- // ON HOLD: ViBe commitments are paused — the ViBe completion feed (leaderboard API)
- // is unavailable, so bets can't be verified or settled. No new bets can be placed
- // (nothing is staked/debited) until the feed is restored.
- return res.status(403).json({ error: 'ViBe commitments are on hold and will be back up soon.' });
-});
-
-api.put('/vibe/bet/:id', async (_req, res) => {
- // ON HOLD: see POST /vibe/bet.
- return res.status(403).json({ error: 'ViBe commitments are on hold and will be back up soon.' });
-});
-
-// DEMO: resolve a bet (no live settlement cron locally). result = 'won' | 'lost'.
-api.post('/vibe/bet/:id/settle', async (_req, res) => {
- // LOCKED DOWN (security): client-controlled self-settlement is removed. This route
- // trusted req.body.result (defaulting to "won") and granted SP with NO check against
- // real ViBe course completion — students could place a bet and instantly self-declare
- // a win to mint SP. There is no real completion feed (VibeProgress.pct was written by
- // settleBetDemo itself), so settlement cannot be verified yet; disabled until a
- // server-side/automatic settlement against real completion data is built.
- return res.status(403).json({ error: 'Bets are settled automatically, not on request. Self-settlement is disabled.' });
-});
-
-// ---- SPA → SP (peer-teaching endorsement points; ALL cohorts) ----------------
-// DISPLAY ONLY: SP is scored + credited by the pipeline rubric; this just reads
-// the `spaprogresses` summary + student total. Universal, no cohort gate.
-api.get('/spa/state', async (req, res) => {
- const student = await vibeStudent(req);
- if (!student) return res.status(404).json({ error: 'Student not found' });
- res.json(await buildSpaState(student));
-});
-
-// ---- SP trajectory (You vs cohort vs onboarding-group; open to all students) --
-// The student's own weekly line is built live from their ledger; the cohort/group
-// reference lines come from the cached TrajectorySnapshot (buildTrajectories.js).
-api.get('/trajectory/state', async (req, res) => {
- const student = await vibeStudent(req);
- if (!student) return res.status(404).json({ error: 'Student not found' });
- res.json(await buildTrajectoryState(student));
-});
-
-// ---- Standup commitments (weekly, attendance-only; keep-the-stake) -----------
-api.get('/standup/state', async (req, res) => {
- const student = await vibeStudent(req);
- if (!student) return res.status(404).json({ error: 'Student not found' });
- if (!isVibeEligible(student)) return res.json({ eligible: false });
- res.json(await buildStandupState(student));
-});
-
-api.post('/standup/commit', async (_req, res) => {
- // PAUSED: standups moved to YouTube Live and the attendance module is being
- // reworked — no new standup commitments until the new attendance tracking lands.
- return res.status(403).json({ error: 'Standup commitments are paused while attendance is reworked for YouTube Live.' });
-});
-
-// DEMO: resolve a standup commitment (no live weekly settlement cron yet).
-api.post('/standup/commit/:id/settle', async (_req, res) => {
- // LOCKED DOWN (security): same self-settlement exploit as /vibe/bet/:id/settle —
- // client-declared "won" minted SP with no verification. Disabled until server-side
- // settlement against real attendance/completion is built.
- return res.status(403).json({ error: 'Commitments are settled automatically, not on request. Self-settlement is disabled.' });
-});
-
-// ---- My Journey (phase-by-phase progress + SP; 16 July cohort onward) ---------
-api.get('/journey/state', async (req, res) => {
- const student = await vibeStudent(req);
- if (!student) return res.status(404).json({ error: 'Student not found' });
- res.json(await buildJourneyState(student)); // My Journey is universal (Phase 1); Commitments stays gated
-});
-
-api.put('/journey/plan', async (req, res) => {
- const student = await vibeStudent(req);
- if (!student) return res.status(404).json({ error: 'Student not found' }); // My Journey goals are universal (Phase 1)
- await saveJourneyPlan(student.email, req.body || {});
- res.json(await buildJourneyState(student));
-});
-
api.get('/search', async (req, res) => {
if (!ALLOW_STUDENT_SEARCH) return res.status(403).json({ error: 'Student search is disabled. Please login from Samagama to view your Spurti Points.' });
const q = String(req.query.q || '').trim();
@@ -512,7 +404,6 @@ function registerSurveyRoutes(base, cfg) {
}
registerSurveyRoutes('/survey', SURVEY);
registerSurveyRoutes('/poll2', POLL2);
-registerSurveyRoutes('/poll3', POLL3);
api.get('/admin/stats', adminGuard, async (_req, res) => {
const [yetToOnboard, excusedStudents, sessions, txns, activeStudents] = await Promise.all([
@@ -729,12 +620,39 @@ api.get('/admin/analytics', adminGuard, async (_req, res) => {
});
});
+api.get('/admin/engagement/report', adminGuard, async (req, res) => {
+ const bandFilter = String(req.query.band || '').trim();
+ const students = await Student.find({ status: 'active' }).lean();
+ const results = [];
+ for (const student of students) {
+ try {
+ const data = await fetchStudentEngagementData(student.email);
+ const result = classifyBand(data.current, data.previous);
+ results.push({ email: student.email, name: student.name, totalSp: student.totalSp, band: result.band, reason: result.reason, stats: result.stats });
+ } catch { /* skip students with no data */ }
+ }
+ const groups = {};
+ for (const r of results) {
+ if (!groups[r.band]) groups[r.band] = [];
+ groups[r.band].push(r);
+ }
+ if (bandFilter) {
+ const filtered = groups[bandFilter] || [];
+ return res.json({ band: bandFilter, count: filtered.length, students: filtered });
+ }
+ const summary = {};
+ for (const [band, list] of Object.entries(groups)) summary[band] = { count: list.length };
+ res.json({ summary, total: results.length, groups });
+});
+
function last24Hours(now) {
return new Date(now.getTime() - 24 * 60 * 60 * 1000);
}
app.use('/api', api);
app.use('/spurti/api', api);
+app.use('/api', engagementRouter);
+app.use('/spurti/api', engagementRouter);
if (fs.existsSync(clientDist)) {
app.use('/spurti', express.static(clientDist));
diff --git a/server/services/journey.js b/server/services/journey.js
deleted file mode 100644
index 16e5019..0000000
--- a/server/services/journey.js
+++ /dev/null
@@ -1,182 +0,0 @@
-// "My Journey" — the unified phase-by-phase progress + SP view (16 July cohort).
-// Four phases: (1) Standups = Zoom attendance + Spandan polls, (2) ViBe = 3 courses,
-// (3) SPA = Matrix Mystics 53 problems, (4) Projects = PRs.
-//
-// SP attribution per phase:
-// - Standups: ALREADY awarded (attendance + poll SPTransactions) — we just aggregate.
-// - ViBe: net SP from settled commitments (+ the weekly floor) — from the ViBe module.
-// - SPA / Projects: rule TBD until Samagama data lands — shown as "coming soon" (sp = 0).
-import AttendanceRecord from '../models/AttendanceRecord.js';
-import PollRecord from '../models/PollRecord.js';
-import SPTransaction from '../models/SPTransaction.js';
-import Commitment from '../models/Commitment.js';
-import JourneyPlan from '../models/JourneyPlan.js';
-import JourneyProgress from '../models/JourneyProgress.js';
-import { buildVibeState, isVibeEligible } from './vibe.js';
-
-export const SPA_TOTAL = 53;
-export const STANDUP_MINUTES_TARGET = 3600; // cumulative Zoom minutes (~120 min/week)
-
-export async function buildJourneyState(student) {
- const email = student.email;
-
- // --- Phase 1: Standups (attendance + Spandan polls) — existing SP, aggregated ---
- const [att, polls, txns] = await Promise.all([
- AttendanceRecord.find({ email }).lean(),
- PollRecord.find({ email }).lean(),
- SPTransaction.find({ email }).lean()
- ]);
- const spByCat = cats => txns
- .filter(t => cats.includes(t.category))
- .reduce((a, t) => a + (t.appliedDelta || 0), 0);
- const standups = {
- zoomMinutes: att.reduce((a, r) => a + (r.attendedMinutes || 0), 0),
- sessionsAttended: att.filter(r => (r.attendedMinutes || 0) > 0).length,
- pollSessions: polls.length,
- pollsAttempted: polls.reduce((a, p) => a + (p.attemptedQuestions || 0), 0),
- pollsTotal: polls.reduce((a, p) => a + (p.totalQuestions || 0), 0),
- spAttendance: spByCat(['attendance']),
- spPolls: spByCat(['poll'])
- };
- standups.sp = standups.spAttendance + standups.spPolls;
-
- // --- Phase 2: ViBe (3 courses) — summarise the commitment module ---
- const v = await buildVibeState(student);
- const settled = await Commitment.find({ email, type: 'vibe', status: { $in: ['won', 'lost'] } }).lean();
- // Pre-16-July students never had the ViBe Onboarding course — show them AI + MERN only.
- const ladder = isVibeEligible(student) ? v.ladder : v.ladder.filter(l => l.key !== 'onboarding');
- const vibe = {
- ladder,
- current: v.current,
- clearedCount: ladder.filter(l => l.cleared).length,
- totalCourses: ladder.length,
- activeCommitment: v.active
- ? { course: v.active.course, goalPct: v.active.goalPct, deadline: v.active.deadline }
- : null,
- settledCount: settled.length,
- sp: settled.reduce((a, b) => a + (b.resultDelta || 0), 0) // net SP from settled commitments
- };
-
- // --- Phase 3 & 4: SPA + Projects — PLACEHOLDER (Samagama data + SP rule TBD) ---
- const jp = (await JourneyProgress.findOne({ email }).lean()) || {};
- const spa = {
- solved: jp.spaSolved || 0,
- total: jp.spaTotal || SPA_TOTAL,
- spaPoints: jp.spaPoints || 0,
- sp: 0, pending: true // SP rule decided once Samagama data arrives
- };
- const projects = {
- prsRaised: jp.prsRaised || 0,
- prsMerged: jp.prsMerged || 0,
- sp: 0, pending: true // SP rule decided once Samagama data arrives
- };
-
- const plan = await JourneyPlan.findOne({ email }).lean();
-
- // Per-phase goal status + pace toward the student's target date. ViBe has live
- // completion %; SPA/Projects are pending (date countdown only until Samagama data).
- const vibeOverall = Math.round(vibe.ladder.reduce((a, l) => a + l.pct, 0) / (vibe.ladder.length || 1));
- const goals = {
- standup: phaseGoal({ targetDate: plan?.standupBy, current: standups.zoomMinutes, target: STANDUP_MINUTES_TARGET, unit: 'min', daysPerWeek: STANDUP_DAYS_PER_WEEK }),
- vibe: phaseGoal({ targetDate: plan?.vibeBy, current: vibeOverall, target: 100, unit: '%' }),
- spa: phaseGoal({ targetDate: plan?.spaBy, pending: true }),
- project: phaseGoal({ targetDate: plan?.projectBy, pending: true })
- };
- // Attach realistic date bounds so a target can't be set too soon (superficial) or
- // too far out (delayed). Standups is pace-capped at ~60 min per working day.
- const endDate = student.internshipEndDate || null;
- for (const [key, g] of Object.entries(goals)) Object.assign(g, goalBounds(key, g, endDate));
-
- return {
- eligible: true,
- name: student.name,
- totalSp: student.totalSp || 0,
- plan: {
- standupBy: plan?.standupBy || null,
- vibeBy: plan?.vibeBy || null,
- spaBy: plan?.spaBy || null,
- projectBy: plan?.projectBy || null
- },
- goals,
- phaseSp: { standups: standups.sp, vibe: vibe.sp, spa: spa.sp, projects: projects.sp },
- standups, vibe, spa, projects
- };
-}
-
-const DAY_MS = 86400000;
-const startOfToday = () => { const d = new Date(); d.setHours(0, 0, 0, 0); return d; };
-const addDays = (d, n) => { const x = new Date(d); x.setDate(x.getDate() + n); return x; };
-// Local date-only string (yyyy-mm-dd) — matches how works and
-// avoids UTC/local off-by-one between the picker min/max and server validation.
-const ymd = d => { const x = new Date(d); return `${x.getFullYear()}-${String(x.getMonth() + 1).padStart(2, '0')}-${String(x.getDate()).padStart(2, '0')}`; };
-export const STANDUP_MIN_PER_DAY = 60; // one 60-min standup per working day
-export const STANDUP_DAYS_PER_WEEK = 6; // 6 working days per week
-
-// Realistic [minDate, maxDate] for a goal. Standups are pace-capped (can't beat
-// 60 min/working-day over 6 working days/week); other phases just need a small buffer
-// so it isn't "tomorrow". Upper bound = internship end if known, else 60 days past min.
-function goalBounds(key, goal, endDate) {
- const today = startOfToday();
- let minDate;
- if (key === 'standup' && goal.remaining > 0) {
- const workDays = Math.ceil(goal.remaining / STANDUP_MIN_PER_DAY);
- minDate = addDays(today, Math.ceil((workDays * 7) / STANDUP_DAYS_PER_WEEK)); // working → calendar days
- } else {
- minDate = addDays(today, key === 'project' ? 3 : 7);
- }
- const end = endDate ? new Date(endDate) : null;
- const maxDate = end && end.getTime() > minDate.getTime() ? end : addDays(minDate, 60);
- return { minDate: ymd(minDate), maxDate: ymd(maxDate), paceHint: key === 'standup' ? '≈60 min per working day' : null };
-}
-
-// Goal status + pace for one phase. `current`/`target` are in `unit` (e.g. min, %).
-// none | active | achieved | missed. pending = progress data not available yet.
-function phaseGoal({ targetDate, current = null, target = null, unit = '%', pending = false, daysPerWeek = null }) {
- const t = targetDate ? new Date(targetDate) : null;
- const today = startOfToday();
- const known = !pending && current != null && target != null;
- const complete = known && current >= target;
- let status = 'none';
- if (t) {
- if (complete) status = 'achieved';
- else if (t.getTime() < today.getTime()) status = 'missed';
- else status = 'active';
- }
- const daysLeft = t ? Math.max(0, Math.round((t.getTime() - today.getTime()) / DAY_MS)) : null;
- const progressPct = known ? Math.min(100, Math.round((current / target) * 100)) : null;
- const remaining = known ? Math.max(0, target - current) : null;
- // Pace to stay on track. For a phase with working days (standups), pace is per
- // WORKING day over the working days left; otherwise per calendar day.
- let perDay = null, perDayUnit = 'day';
- if (status === 'active' && remaining != null && daysLeft > 0) {
- if (daysPerWeek) {
- const workDaysLeft = Math.max(1, Math.round((daysLeft * daysPerWeek) / 7));
- perDay = Math.ceil(remaining / workDaysLeft);
- perDayUnit = 'working day';
- } else {
- perDay = Math.ceil(remaining / daysLeft);
- }
- }
- return {
- targetDate: t, hasTarget: !!t, status, unit,
- current: known ? current : null, target: known ? target : null,
- progressPct, remaining, remainingPct: progressPct == null ? null : Math.max(0, 100 - progressPct),
- daysLeft, perDay, perDayUnit, pending: !!pending
- };
-}
-
-// Upsert the plan dates — but LOCK a phase once its target is set and still in the
-// future (a commitment device: no moving the goalpost). A phase only becomes settable
-// again when its date has passed (missed). Only fields present in `incoming` are touched.
-export async function saveJourneyPlan(email, incoming = {}) {
- const existing = await JourneyPlan.findOne({ email }).lean();
- const today = startOfToday();
- const set = {};
- for (const f of ['standupBy', 'vibeBy', 'spaBy', 'projectBy']) {
- const cur = existing?.[f] ? new Date(existing[f]) : null;
- const locked = cur && cur.getTime() >= today.getTime(); // active future target → locked
- if (locked) continue;
- if (Object.prototype.hasOwnProperty.call(incoming, f)) set[f] = incoming[f] ? new Date(incoming[f]) : null;
- }
- if (Object.keys(set).length) await JourneyPlan.updateOne({ email }, { $set: set }, { upsert: true });
-}
diff --git a/server/services/spa.js b/server/services/spa.js
deleted file mode 100644
index be4cafa..0000000
--- a/server/services/spa.js
+++ /dev/null
@@ -1,61 +0,0 @@
-// SPA → SP module logic (peer-teaching endorsement activity) — DISPLAY layer.
-// The SP itself is scored + credited by the pipeline rubric
-// (pipeline/sp-rubric-build-mirror.cjs, Pattern A): +5 per validated question
-// learned, +8 per validated peer taught (capped 50/30), minus a one-time
-// audit/fraud penalty. The rubric writes the `spaprogresses` summary this reads.
-// The web app NEVER writes SP — it only renders what the rubric produced.
-// Universal: applies to ALL cohorts (15-May onward).
-import Student from '../models/Student.js';
-import SpaProgress from '../models/SpaProgress.js';
-
-export function isSpaEligible() { return true; } // SPA SP is a universal feature.
-
-// LOCKED scheme (see memory: spa-sp-award-scheme).
-export const CONFIG = {
- learnUnit: 5, learnCap: 50, // +5 SP per validated question learned, cap 50 → max 250
- teachUnit: 8, teachCap: 30, // +8 SP per validated endorsement given, cap 30 → max 240
- fraudRate: 0.5, // genuine fraud → -50% of current SP (one-time)
- auditRate: 0.2 // audit failure → -20% of current SP (one-time)
-};
-export const MAX_SPA_SP = CONFIG.learnUnit * CONFIG.learnCap + CONFIG.teachUnit * CONFIG.teachCap; // 490
-
-// Pure computation of the SP breakdown from a SpaProgress row (display).
-export function computeSpaSp(prog) {
- const learnCounted = Math.min(prog.learnValidated || 0, CONFIG.learnCap);
- const teachCounted = Math.min(prog.teachValidated || 0, CONFIG.teachCap);
- return {
- learn: { validated: prog.learnValidated || 0, counted: learnCounted, credited: prog.learnCredited || 0,
- cap: CONFIG.learnCap, unit: CONFIG.learnUnit, sp: learnCounted * CONFIG.learnUnit },
- teach: { validated: prog.teachValidated || 0, counted: teachCounted, credited: prog.teachCredited || 0,
- cap: CONFIG.teachCap, unit: CONFIG.teachUnit, sp: teachCounted * CONFIG.teachUnit },
- grossSp: learnCounted * CONFIG.learnUnit + teachCounted * CONFIG.teachUnit,
- penalty: { fraud: !!prog.fraud, auditFail: !!prog.auditFail,
- rate: prog.fraud ? CONFIG.fraudRate : (prog.auditFail ? CONFIG.auditRate : 0),
- applied: prog.penaltyApplied || 0, at: prog.penaltyAt || null,
- done: (prog.penaltyApplied || 0) > 0 }
- };
-}
-
-// Build the student-facing SPA state. DISPLAY ONLY — the SP itself is scored and
-// credited by the pipeline rubric (sp-rubric-build-mirror.cjs, Pattern A), which
-// also writes the `spaprogresses` summary this reads. The web app never writes SP.
-export async function buildSpaState(student) {
- const prog = await SpaProgress.findOne({ email: student.email }).lean();
- const stu = await Student.findOne({ email: student.email }).lean();
- if (!prog) {
- return { eligible: true, name: student.name, totalSp: stu?.totalSp || 0,
- activity: 'Activity 1: Linear Algebra', hasActivity: false, config: CONFIG, maxSp: MAX_SPA_SP };
- }
- const calc = computeSpaSp(prog);
- return {
- eligible: true,
- name: student.name,
- totalSp: stu?.totalSp || 0,
- activity: prog.activity,
- hasActivity: (prog.learnValidated || 0) + (prog.teachValidated || 0) > 0,
- ...calc,
- creditedSp: calc.learn.credited * CONFIG.learnUnit + calc.teach.credited * CONFIG.teachUnit,
- maxSp: MAX_SPA_SP,
- config: CONFIG
- };
-}
diff --git a/server/services/standup.js b/server/services/standup.js
deleted file mode 100644
index 4975e5b..0000000
--- a/server/services/standup.js
+++ /dev/null
@@ -1,114 +0,0 @@
-// Standup commitment — a WEEKLY, attendance-only pledge (polls stay as poll-points).
-// The student pledges to attend ALL of this week's standups at a chosen attendance
-// tier, with a confidence multiplier. "Keep-the-stake" economics: the stake is NOT
-// debited (it represents the attendance points you earn that week); a HIT pays a
-// +stake×mult bonus on top of your earned attendance, a MISS charges −0.5×stake×mult.
-//
-// Anti-mining: the tier floor is ≥81% and the pledge is the FULL week — you can't
-// farm SP by pledging a low bar or a single session.
-import Student from '../models/Student.js';
-import AttendanceRecord from '../models/AttendanceRecord.js';
-import Commitment from '../models/Commitment.js';
-import { applySpDelta } from './vibe.js';
-
-export const STANDUP = {
- sessionsPerWeek: 6, // Y — standups scheduled per week (6/6)
- multipliers: [2, 3, 4],
- penaltyFactor: 0.5,
- // Two attendance tiers. Higher tier = higher bar (≥91%) and a larger stake cap,
- // to nudge students toward consistent 91–100% attendance.
- tiers: [
- { key: '81-90', label: '81–90%', floor: 81, stake: 20 },
- { key: '91-100', label: '91–100%', floor: 91, stake: 50 }
- ]
-};
-
-export const tierByKey = k => STANDUP.tiers.find(t => t.key === k);
-
-// Current calendar week, Monday 00:00 → Sunday 23:59:59 (local server time).
-function weekWindow(now = new Date()) {
- const start = new Date(now); start.setHours(0, 0, 0, 0);
- const dow = (start.getDay() + 6) % 7; // 0 = Monday
- start.setDate(start.getDate() - dow);
- const end = new Date(start); end.setDate(end.getDate() + 6); end.setHours(23, 59, 59, 999);
- return { start, end };
-}
-const fmt = d => d.toLocaleDateString('en-GB', { day: 'numeric', month: 'short' });
-
-export async function buildStandupState(student) {
- const email = student.email;
- const { start, end } = weekWindow();
-
- // Attendance already logged this week (informational — the demo settles by button).
- const wk = await AttendanceRecord.find({ email }).lean();
- const thisWeek = wk.filter(r => r.createdAt && new Date(r.createdAt) >= start && new Date(r.createdAt) <= end);
- const attendedThisWeek = thisWeek.filter(r => (r.attendedMinutes || 0) > 0).length;
- const avgPctThisWeek = attendedThisWeek
- ? Math.round(thisWeek.reduce((a, r) => a + (r.attendancePercentage || 0), 0) / attendedThisWeek)
- : null;
-
- const commits = await Commitment.find({ email, type: 'standup' }).sort({ createdAt: -1 }).lean();
- const active = commits.find(c => c.status === 'active') || null;
- const history = commits.filter(c => c.status !== 'active');
- const reserved = active ? active.reserved : 0;
- const available = Math.max(0, (student.totalSp || 0) - reserved);
-
- return {
- eligible: true,
- name: student.name,
- weekLabel: `${fmt(start)} – ${fmt(end)}`,
- deadline: end,
- sessionsThisWeek: STANDUP.sessionsPerWeek,
- attendedThisWeek, avgPctThisWeek,
- tiers: STANDUP.tiers, multipliers: STANDUP.multipliers, penaltyFactor: STANDUP.penaltyFactor,
- totalSp: student.totalSp || 0, available,
- active, history
- };
-}
-
-// Validate a standup pledge. Stake is FIXED at the tier cap (not chosen). Returns
-// { errs, win, loss, stake, tier, deadline, label }.
-export function validateStandup({ state, tierKey, multiplier }) {
- const errs = [];
- const tier = tierByKey(tierKey);
- if (!tier) errs.push('Pick an attendance tier.');
- if (!STANDUP.multipliers.includes(multiplier)) errs.push('Invalid confidence multiplier.');
- if (state.active) errs.push('You already have an active standup commitment this week.');
-
- const stake = tier ? tier.stake : 0;
- const win = stake * multiplier;
- const loss = STANDUP.penaltyFactor * stake * multiplier;
- // Keep-the-stake: nothing is debited now, but a MISS charges the penalty — so the
- // student must be able to cover the potential loss (SP never goes negative).
- if (loss > state.available) {
- errs.push(`You need ${loss} SP free to cover a possible miss (−${loss}); you have ${state.available}.`);
- }
- const label = tier ? `Attend all ${state.sessionsThisWeek} standups @ ${tier.label} (${multiplier}×)` : '';
- return { errs, win, loss, stake, tier, deadline: state.deadline, label };
-}
-
-export async function placeStandup(student, { tierKey, multiplier }) {
- const state = await buildStandupState(student);
- const v = validateStandup({ state, tierKey, multiplier: +multiplier });
- if (v.errs.length) return { error: v.errs.join(' ') };
- const { start, end } = weekWindow();
- await Commitment.create({
- email: student.email, type: 'standup', debited: false, reserved: 0,
- stake: v.stake, multiplier: +multiplier, potentialWin: v.win, potentialLoss: v.loss,
- tier: v.tier.key, tierFloor: v.tier.floor, sessionsTarget: state.sessionsThisWeek,
- weekStart: start, weekEnd: end, deadline: end, label: v.label, status: 'active'
- });
- return { ok: true };
-}
-
-// DEMO: resolve a standup commitment (no live weekly settlement cron yet). Keep-the-
-// stake: a HIT credits +potentialWin, a MISS debits −potentialLoss. No prior debit to
-// reconcile. In production this is judged automatically at week's end:
-// HIT ⇔ sessions attended ≥ target AND average attendance % ≥ tier floor.
-export async function settleStandupDemo(commitment, result) {
- const delta = result === 'won' ? commitment.potentialWin : -commitment.potentialLoss;
- await applySpDelta(commitment.email, delta,
- `Standup goal ${result === 'won' ? 'HIT' : 'MISS'}: ${commitment.label}`);
- await Commitment.updateOne({ _id: commitment._id },
- { $set: { status: result, resultDelta: delta, settledAt: new Date() } });
-}
diff --git a/server/services/trajectory.js b/server/services/trajectory.js
deleted file mode 100644
index f75cebb..0000000
--- a/server/services/trajectory.js
+++ /dev/null
@@ -1,100 +0,0 @@
-// Student SP trajectories — cumulative SP by WEEK SINCE JOIN (normalised onset, so
-// students who joined on different dates are comparable; matches the trajectory-paper
-// framing). Three lines on the chart: You / Cohort mean / your Onboarding-group mean.
-// Cohort & group means are precomputed (see buildTrajectories.js); the student's own
-// line is built live from their ledger.
-import Student from '../models/Student.js';
-import SPTransaction from '../models/SPTransaction.js';
-import TrajectorySnapshot from '../models/TrajectorySnapshot.js';
-import { leaderboardGroup, groupLabel } from './levels.js';
-
-export const WEEKS = 10; // cap the axis at ~10 weeks (typical internship length)
-const WEEK_MS = 7 * 86400000;
-
-// Balance at time t = balanceAfter of the last txn on/before t (0 before any txn).
-// txns must be sorted ascending by dateTime.
-function balanceAt(txns, t) {
- let bal = 0;
- for (const tx of txns) {
- if (new Date(tx.dateTime).getTime() <= t) bal = tx.balanceAfter; else break;
- }
- return bal;
-}
-
-// Cumulative SP at the end of each COMPLETED week since join. Week is 1-indexed.
-function weeklySeries(txns, joinMs, nowMs) {
- const out = [];
- for (let w = 0; w < WEEKS; w++) {
- const boundary = joinMs + (w + 1) * WEEK_MS;
- if (nowMs < boundary) break; // this week isn't complete yet
- out.push({ week: w + 1, sp: balanceAt(txns, boundary) });
- }
- return out;
-}
-
-// Average per week, dropping weeks with too few students (the noisy small-sample tail —
-// few learners reach the last weeks). Keep weeks with n >= max(15, 10% of week-1's count).
-function toSeries(acc) {
- const first = acc.find(x => x.n > 0);
- const floor = first ? Math.max(15, Math.round(first.n * 0.1)) : 15;
- return acc
- .map((x, i) => ({ week: i + 1, sp: x.n ? Math.round(x.sum / x.n) : null, n: x.n }))
- .filter(p => p.sp !== null && p.n >= floor);
-}
-
-// Recompute cohort + per-group average trajectories and upsert the 'latest' snapshot.
-export async function computeAndStoreTrajectories(now = new Date()) {
- const nowMs = now.getTime();
- const students = await Student.find({ status: { $ne: 'excused' }, internshipStartDate: { $ne: null } })
- .select('email internshipStartDate').lean();
-
- const txns = await SPTransaction.find({}).select('email dateTime balanceAfter').sort({ dateTime: 1 }).lean();
- const byEmail = new Map();
- for (const t of txns) { const a = byEmail.get(t.email); if (a) a.push(t); else byEmail.set(t.email, [t]); }
-
- const blank = () => Array.from({ length: WEEKS }, () => ({ sum: 0, n: 0 }));
- const cohort = blank();
- const groups = new Map();
-
- for (const s of students) {
- const joinMs = new Date(s.internshipStartDate).getTime();
- if (joinMs > nowMs) continue; // not started yet
- const series = weeklySeries(byEmail.get(s.email) || [], joinMs, nowMs);
- if (!series.length) continue;
- const gk = leaderboardGroup(s.internshipStartDate);
- if (!groups.has(gk)) groups.set(gk, blank());
- const garr = groups.get(gk);
- for (const p of series) {
- const i = p.week - 1;
- cohort[i].sum += p.sp; cohort[i].n++;
- garr[i].sum += p.sp; garr[i].n++;
- }
- }
-
- const groupsObj = {}, groupLabels = {};
- for (const [gk, arr] of groups) { groupsObj[gk] = toSeries(arr); groupLabels[gk] = groupLabel(gk); }
-
- await TrajectorySnapshot.updateOne({ key: 'latest' },
- { $set: { weeks: WEEKS, cohort: toSeries(cohort), groups: groupsObj, groupLabels, computedAt: now } },
- { upsert: true });
- return { students: students.length, cohortWeeks: toSeries(cohort).length, groups: groups.size };
-}
-
-// Student-facing payload: their own weekly line + the two cached reference lines.
-export async function buildTrajectoryState(student) {
- const joinMs = student.internshipStartDate ? new Date(student.internshipStartDate).getTime() : null;
- const txns = joinMs
- ? await SPTransaction.find({ email: student.email }).select('dateTime balanceAfter').sort({ dateTime: 1 }).lean()
- : [];
- const you = joinMs ? weeklySeries(txns, joinMs, Date.now()) : [];
- const snap = await TrajectorySnapshot.findOne({ key: 'latest' }).lean();
- const gk = student.internshipStartDate ? leaderboardGroup(student.internshipStartDate) : null;
- return {
- weeks: snap?.weeks || WEEKS,
- you,
- cohort: snap?.cohort || [],
- group: (gk && snap?.groups?.[gk]) || [],
- groupLabel: gk ? groupLabel(gk) : null,
- computedAt: snap?.computedAt || null
- };
-}
diff --git a/server/services/vibe.js b/server/services/vibe.js
deleted file mode 100644
index a4e5572..0000000
--- a/server/services/vibe.js
+++ /dev/null
@@ -1,149 +0,0 @@
-// ViBe Commitment-SP module logic (16 July cohort onward).
-// Config + eligibility + state builder + bet validation + demo settlement.
-// Progress here comes from VibeProgress (dummy locally; ViBe API in production).
-import Student from '../models/Student.js';
-import VibeProgress from '../models/VibeProgress.js';
-import Commitment from '../models/Commitment.js';
-import SPTransaction from '../models/SPTransaction.js';
-
-export const ELIGIBILITY_CUTOFF = new Date('2026-07-16T00:00:00.000Z');
-
-// Progressive ladder order: Onboarding -> AI -> MERN.
-export const COURSES = [
- { key: 'onboarding', name: 'Onboarding', hours: 10, courseId: '6a14258a4fa5339bade5d732', versionId: '6a14258a4fa5339bade5d733' },
- { key: 'ai', name: 'Fundamentals of AI', hours: 6, courseId: '6a055c4c79eef782c2548388', versionId: '6a055c4c79eef782c2548389' },
- { key: 'mern', name: 'MERN Stack', hours: 10, courseId: '6a0ec8254658465536acb121', versionId: '6a0ec8254658465536acb122' }
-];
-
-export const CONFIG = {
- stakeMin: 50, stakeMax: 200,
- multipliers: [2, 3, 4], // 1x dropped: under stake-debit, a 1x hit only returns the stake (net 0)
- penaltyFactor: 0.5, // miss loses 0.5 * stake * multiplier
- maxBetDays: 3, // deadline window 1–3 days
- floorHours: 1, // 1 hour of content/week is mandatory
- floorSp: 10 // flat SP for hitting the weekly floor
-};
-
-export function isVibeEligible(student) {
- return Boolean(student?.internshipStartDate) &&
- new Date(student.internshipStartDate) >= ELIGIBILITY_CUTOFF;
-}
-export const courseByKey = k => COURSES.find(c => c.key === k);
-export const floorPctFor = course => Math.round(CONFIG.floorHours / course.hours * 100);
-
-function daysFromToday(deadline) {
- const t = new Date(); t.setHours(0, 0, 0, 0);
- const d = new Date(deadline); d.setHours(0, 0, 0, 0);
- return Math.round((d - t) / 86400000);
-}
-
-// Build the full student-facing ViBe state.
-export async function buildVibeState(student) {
- const email = student.email;
- const rows = await VibeProgress.find({ email }).lean();
- const prog = {};
- rows.forEach(r => { prog[r.course] = { pct: r.pct, week: r.weekHours, prior: !!r.priorCompleted }; });
-
- const ladder = COURSES.map(c => {
- const p = prog[c.key] || { pct: 0, week: 0, prior: false };
- const pct = p.prior ? 100 : p.pct;
- return { key: c.key, name: c.name, hours: c.hours, pct, prior: p.prior, cleared: p.prior || pct >= 100 };
- });
- const currentLadder = ladder.find(l => !l.cleared) || null;
- const currentCourse = currentLadder ? courseByKey(currentLadder.key) : null;
-
- const bets = await Commitment.find({ email, type: 'vibe' }).sort({ createdAt: -1 }).lean();
- const active = bets.find(b => b.status === 'active') || null;
- const history = bets.filter(b => b.status !== 'active');
- const reserved = active ? active.reserved : 0;
- const available = Math.max(0, (student.totalSp || 0) - reserved);
-
- const current = currentLadder ? {
- key: currentLadder.key,
- name: currentLadder.name,
- pct: currentLadder.pct,
- hours: currentLadder.hours,
- floorPct: floorPctFor(currentCourse),
- remaining: 100 - currentLadder.pct,
- weekHours: prog[currentLadder.key]?.week ?? 0
- } : null;
-
- return {
- eligible: true,
- name: student.name,
- totalSp: student.totalSp || 0,
- available, reserved,
- ladder, current,
- weeklyFloor: current
- ? { requiredHours: CONFIG.floorHours, doneHours: current.weekHours, met: current.weekHours >= CONFIG.floorHours, sp: CONFIG.floorSp }
- : null,
- active, history,
- config: CONFIG
- };
-}
-
-// Validate a place/edit request against the locked rules. Returns { errs, win, loss, baselinePct }.
-export function validateBet({ state, course, goalPct, stake, multiplier, deadline, ignoreActive = false }) {
- const errs = [];
- const c = courseByKey(course);
- if (!c) errs.push('Unknown course.');
- if (!state.current || state.current.key !== course) errs.push('You can only bet on your current course.');
- if (!ignoreActive && state.active) errs.push('You already have an active bet.');
- if (!CONFIG.multipliers.includes(multiplier)) errs.push('Invalid multiplier.');
- if (!(stake >= CONFIG.stakeMin && stake <= CONFIG.stakeMax)) errs.push(`Stake must be ${CONFIG.stakeMin}–${CONFIG.stakeMax} SP.`);
-
- const floorPct = c ? floorPctFor(c) : 0;
- const remaining = state.current ? state.current.remaining : 0;
- if (goalPct <= floorPct) errs.push(`Goal must beat the weekly floor (${floorPct}%).`);
- if (goalPct > remaining) errs.push(`Goal exceeds your remaining ${remaining}%.`);
-
- if (deadline !== undefined) {
- const days = daysFromToday(deadline);
- if (days < 1 || days > CONFIG.maxBetDays) errs.push(`Deadline must be 1–${CONFIG.maxBetDays} days out.`);
- }
-
- const loss = CONFIG.penaltyFactor * stake * multiplier;
- const win = stake * multiplier;
- // The stake is debited up-front; a miss debits the penalty on top. So you must
- // be able to cover BOTH (worst case = stake + loss). When editing, this bet's
- // already-debited stake and reserved penalty are unwound first.
- const avail = state.available + (ignoreActive && state.active ? state.active.reserved + state.active.stake : 0);
- const need = stake + loss;
- if (need > avail) {
- errs.push(`You need ${need} SP to place this (stake ${stake} + up to ${loss} loss); you have ${avail}.`);
- }
- return { errs, win, loss, baselinePct: state.current ? state.current.pct : 0 };
-}
-
-// Apply an SP change AND write a matching SP-Bank transaction so the student sees
-// it. Stamps the entry after the latest one so the running balance stays ordered
-// (dummy seed dates can be future-ish). Returns the new balance.
-export async function applySpDelta(email, delta, reason) {
- const student = await Student.findOne({ email });
- const newTotal = (student.totalSp || 0) + delta;
- student.totalSp = newTotal;
- if (newTotal > (student.highestSpEver || 0)) student.highestSpEver = newTotal;
- await student.save();
- const last = await SPTransaction.findOne({ email }).sort({ dateTime: -1 }).lean();
- const when = new Date(Math.max(Date.now(), (last?.dateTime ? new Date(last.dateTime).getTime() + 60000 : 0)));
- await SPTransaction.create({
- email, studentId: student._id, category: 'manual', sessionLabel: '',
- deltaMode: 'absolute', deltaValue: delta, appliedDelta: delta, balanceAfter: newTotal, reason, dateTime: when
- });
- return newTotal;
-}
-
-// DEMO ONLY: resolve a bet (there is no live settlement cron locally). The stake
-// was already debited at placement; here we apply the win (credit) or the miss
-// penalty (debit), advance progress, and mark the bet.
-export async function settleBetDemo(bet, result) {
- const course = courseByKey(bet.course);
- const label = `+${bet.goalPct}% ${course ? course.name : bet.course} (stake ${bet.stake} @ ${bet.multiplier}×)`;
- const delta = result === 'won' ? bet.potentialWin : -bet.potentialLoss;
- await applySpDelta(bet.email, delta, `ViBe goal ${result === 'won' ? 'HIT' : 'MISS'}: ${label}`);
- const newPct = result === 'won'
- ? Math.min(100, bet.baselinePct + bet.goalPct)
- : Math.min(100, bet.baselinePct + Math.floor(bet.goalPct * 0.6)); // fell short of goal
- await VibeProgress.updateOne({ email: bet.email, course: bet.course }, { $set: { pct: newPct } }, { upsert: true });
- await Commitment.updateOne({ _id: bet._id }, { $set: { status: result, resultDelta: delta, settledAt: new Date() } });
-}