diff --git a/server/app/intake/router.py b/server/app/intake/router.py index 0be6f0f..8c21854 100644 --- a/server/app/intake/router.py +++ b/server/app/intake/router.py @@ -12,7 +12,7 @@ from ..auth.deps import get_current_user_id from ..db import get_conn, get_tx from ..llm.encryption import encrypt_api_key -from ..vector.service import query_relevant_journal, upsert_user_vector, find_nearest_users +from ..vector.service import query_relevant_journal, upsert_user_vector router = APIRouter() @@ -143,235 +143,6 @@ async def confess( ) -@router.get("/match") -async def find_matches(user_id: UUID = Depends(get_current_user_id)): - """ - Return the 3 users psychologically closest to the current user in - Pinecone's 1,536-dimensional space. Requires intake to have been completed. - - Enriched response includes Spotify overlap, match reasoning, and - whether the target already accepted the current user (for mutual match). - """ - matches = await find_nearest_users(str(user_id), top_k=3) - if not matches: - raise HTTPException( - status_code=status.HTTP_404_NOT_FOUND, - detail="No matches found — complete intake first or embedding key not configured", - ) - - match_ids = [UUID(m["user_id"]) for m in matches if m.get("user_id")] - - async with get_conn() as conn: - # Hydrate display names + avatar - user_rows = await conn.fetch( - "SELECT id, display_name, avatar_url FROM users WHERE id = ANY($1::uuid[])", - match_ids, - ) - user_map = {str(r["id"]): r for r in user_rows} - - # Fetch vibe vectors for matched users (spotify_data, attachment, etc.) - vibe_rows = await conn.fetch( - "SELECT user_id, spotify_data, twitter_data, strava_data, " - "attachment_style, defense_mechanism, readiness_score, " - "oracle_coordinate, oracle_synthesized_at " - "FROM vibe_vectors WHERE user_id = ANY($1::uuid[])", - match_ids, - ) - vibe_map = {str(r["user_id"]): r for r in vibe_rows} - - # Fetch current user's vibe vector for comparison - my_vibe = await conn.fetchrow( - "SELECT spotify_data, twitter_data, strava_data, " - "attachment_style, defense_mechanism, oracle_coordinate " - "FROM vibe_vectors WHERE user_id = $1", - user_id, - ) - - # Check which targets have already accepted the current user - accepted_rows = await conn.fetch( - "SELECT actor_id FROM match_interactions " - "WHERE actor_id = ANY($1::uuid[]) AND target_id = $2 AND action = 'accept'", - match_ids, user_id, - ) - accepted_by = {str(r["actor_id"]) for r in accepted_rows} - - # Check current user's existing interactions with these targets - my_actions = await conn.fetch( - "SELECT target_id, action FROM match_interactions " - "WHERE actor_id = $1 AND target_id = ANY($2::uuid[])", - user_id, match_ids, - ) - my_action_map = {str(r["target_id"]): r["action"] for r in my_actions} - - results = [] - for m in matches: - mid = m["user_id"] - u = user_map.get(mid, {}) - v = vibe_map.get(mid) - reason = _build_match_reason(m, my_vibe, v) - spotify = _extract_spotify_overlap(my_vibe, v) if my_vibe and v else None - - results.append({ - "user_id": mid, - "display_name": u.get("display_name") or "Unknown", - "avatar_url": u.get("avatar_url"), - "attachment_style": m.get("attachment_style"), - "defense_mechanism": m.get("defense_mechanism"), - "similarity": m["score"], - "match_reason": reason, - "sonic_overlap": spotify, - "twitter_overlap": _extract_twitter_overlap(my_vibe, v) if my_vibe and v else None, - "strava_overlap": _extract_strava_overlap(my_vibe, v) if my_vibe and v else None, - "oracle_insight": _extract_oracle_insight(v), - "they_accepted": mid in accepted_by, - "my_action": my_action_map.get(mid), - }) - - return results - - -def _build_match_reason( - match: dict, my_vibe: object | None, their_vibe: object | None, -) -> str: - """Generate a human-readable explanation for why two users matched.""" - reasons: list[str] = [] - score = match["score"] - - if score >= 0.92: - reasons.append("Exceptionally close psychological coordinates") - elif score >= 0.85: - reasons.append("Strong alignment in psychological space") - else: - reasons.append("Complementary psychological profiles") - - my_attach = my_vibe["attachment_style"] if my_vibe else None - their_attach = match.get("attachment_style") - if my_attach and their_attach: - if my_attach == their_attach: - reasons.append(f"Shared attachment style: {their_attach}") - else: - reasons.append(f"Complementary attachment dynamics: {my_attach} + {their_attach}") - - my_defense = my_vibe["defense_mechanism"] if my_vibe else None - their_defense = match.get("defense_mechanism") - if my_defense and their_defense and my_defense != their_defense: - reasons.append(f"Different defense patterns ({my_defense} / {their_defense}) — growth potential") - - # Oracle coordinate insights - my_oracle = my_vibe.get("oracle_coordinate") if my_vibe else None - their_oracle = their_vibe.get("oracle_coordinate") if their_vibe else None - if my_oracle and their_oracle: - if isinstance(my_oracle, str): - my_oracle = json.loads(my_oracle) - if isinstance(their_oracle, str): - their_oracle = json.loads(their_oracle) - empathy_diff = abs((my_oracle.get("empathy_index") or 0) - (their_oracle.get("empathy_index") or 0)) - if empathy_diff < 0.15: - reasons.append("Closely aligned empathy signatures") - - return ". ".join(reasons) + "." - - -def _extract_twitter_overlap(my_vibe: object | None, their_vibe: object | None) -> dict | None: - """Compare Twitter behavioral signals between two users.""" - my_twitter = my_vibe.get("twitter_data") if my_vibe else None - their_twitter = their_vibe.get("twitter_data") if their_vibe else None - if not my_twitter or not their_twitter: - return None - - if isinstance(my_twitter, str): - my_twitter = json.loads(my_twitter) - if isinstance(their_twitter, str): - their_twitter = json.loads(their_twitter) - - my_avg_len = my_twitter.get("avg_tweet_length", 0) - their_avg_len = their_twitter.get("avg_tweet_length", 0) - my_lang = my_twitter.get("language", "") - their_lang = their_twitter.get("language", "") - - return { - "both_connected": True, - "communication_style_match": abs(my_avg_len - their_avg_len) < 50, - "shared_language": my_lang == their_lang if my_lang and their_lang else None, - "their_username": their_twitter.get("username"), - } - - -def _extract_strava_overlap(my_vibe: object | None, their_vibe: object | None) -> dict | None: - """Compare physical activity patterns between two users.""" - my_strava = my_vibe.get("strava_data") if my_vibe else None - their_strava = their_vibe.get("strava_data") if their_vibe else None - if not my_strava or not their_strava: - return None - - if isinstance(my_strava, str): - my_strava = json.loads(my_strava) - if isinstance(their_strava, str): - their_strava = json.loads(their_strava) - - my_types = set(my_strava.get("activity_types", [])) - their_types = set(their_strava.get("activity_types", [])) - shared_activities = sorted(my_types & their_types) - - return { - "both_connected": True, - "shared_activities": shared_activities, - "their_activity_types": sorted(their_types)[:5], - } - - -def _extract_oracle_insight(their_vibe: object | None) -> dict | None: - """Extract Oracle coordinate metrics if synthesized.""" - if not their_vibe: - return None - coord = their_vibe.get("oracle_coordinate") - if not coord: - return None - if isinstance(coord, str): - coord = json.loads(coord) - return { - "empathy_index": coord.get("empathy_index"), - "isolation_metric": coord.get("isolation_metric"), - "fatalism_score": coord.get("fatalism_score"), - "masochism_curve": coord.get("masochism_curve"), - "oracle_rationale": coord.get("oracle_rationale"), - } - - -def _extract_spotify_overlap(my_vibe: object | None, their_vibe: object | None) -> dict | None: - """Compare Spotify data between two users for sonic overlap display.""" - import json as _json - my_spotify = my_vibe.get("spotify_data") if my_vibe else None - their_spotify = their_vibe.get("spotify_data") if their_vibe else None - if not my_spotify or not their_spotify: - return None - - # Handle JSONB — may already be dict or may be JSON string - if isinstance(my_spotify, str): - my_spotify = _json.loads(my_spotify) - if isinstance(their_spotify, str): - their_spotify = _json.loads(their_spotify) - - my_genres = set(my_spotify.get("genres", [])) - their_genres = set(their_spotify.get("genres", [])) - shared_genres = sorted(my_genres & their_genres) - - my_artists = set(my_spotify.get("top_artists", [])) - their_artists = set(their_spotify.get("top_artists", [])) - shared_artists = sorted(my_artists & their_artists) - - my_audio = my_spotify.get("audio_avg", {}) - their_audio = their_spotify.get("audio_avg", {}) - - return { - "shared_genres": shared_genres[:5], - "shared_artists": shared_artists[:3], - "their_top_genres": sorted(their_genres)[:5], - "valence_delta": abs((my_audio.get("valence") or 0) - (their_audio.get("valence") or 0)), - "energy_delta": abs((my_audio.get("energy") or 0) - (their_audio.get("energy") or 0)), - } - - @router.get("/vector") async def get_vibe_vector(user_id: UUID = Depends(get_current_user_id)): """Retrieve the current user's vibe vector.""" diff --git a/src/components/LLMKeyManager.vue b/src/components/LLMKeyManager.vue deleted file mode 100644 index 6077f00..0000000 --- a/src/components/LLMKeyManager.vue +++ /dev/null @@ -1,148 +0,0 @@ - - - diff --git a/src/router/index.ts b/src/router/index.ts index 3591a37..df812d2 100644 --- a/src/router/index.ts +++ b/src/router/index.ts @@ -245,20 +245,6 @@ const router = createRouter({ meta: { requiresAuth: true } }, - // ── Fitting ritual + Match reveal ───────────────────────────────────── - { - path: '/fitting/:matchId', - name: 'fitting-ritual', - component: () => import('@/views/FittingRitualView.vue'), - meta: { requiresAuth: true } - }, - { - path: '/reveal/:matchId', - name: 'reveal', - component: () => import('@/views/RevealView.vue'), - meta: { requiresAuth: true } - }, - // ── Admin analytics dashboard ──────────────────────────────────────── { path: '/admin', diff --git a/src/views/FittingRitualView.vue b/src/views/FittingRitualView.vue deleted file mode 100644 index b455bb2..0000000 --- a/src/views/FittingRitualView.vue +++ /dev/null @@ -1,273 +0,0 @@ - - - diff --git a/src/views/RevealView.vue b/src/views/RevealView.vue deleted file mode 100644 index c0e218a..0000000 --- a/src/views/RevealView.vue +++ /dev/null @@ -1,357 +0,0 @@ - - -