Postmortem: How a Toxic Team Culture Cost Me a 2026 Meta Offer Despite Scoring 95% on LeetCode 2026

import pandas as pd\nimport numpy as np\nfrom typing import Dict, List, Optional\nimport logging\nfrom datetime import datetime\n\n# Configure logging to track culture score calculations\nlogging.basicConfig(\n    level=logging.INFO,\n    format=\"%(asctime)s - %(levelname)s - %(message)s\"\n)\nlogger = logging.getLogger(__name__)\n\nclass CultureHealthCalculator:\n    \"\"\"Calculate team culture health scores from anonymous survey data.\n    \n    Scores range from 0 (toxic) to 100 (healthy), based on 2026 SOC 2 culture compliance frameworks.\n    \"\"\"\n    \n    # Weightings for survey categories, aligned with MIT 2025 Team Dynamics Study\n    CATEGORY_WEIGHTS = {\n        \"psychological_safety\": 0.3,\n        \"code_review_fairness\": 0.2,\n        \"oncall_equity\": 0.15,\n        \"growth_support\": 0.2,\n        \"conflict_resolution\": 0.15\n    }\n    \n    def __init__(self, survey_path: str, min_responses: int = 5):\n        \"\"\"Initialize calculator with survey data path and minimum response threshold.\n        \n        Args:\n            survey_path: Path to CSV containing survey responses\n            min_responses: Minimum number of responses required to calculate a valid score\n        \"\"\"\n        self.survey_path = survey_path\n        self.min_responses = min_responses\n        self.survey_data: Optional[pd.DataFrame] = None\n        logger.info(f\"Initialized CultureHealthCalculator for {survey_path}\")\n    \n    def load_survey_data(self) -> None:\n        \"\"\"Load and validate survey data from CSV.\n        \n        Raises:\n            FileNotFoundError: If survey file does not exist\n            ValueError: If required columns are missing or responses are insufficient\n        \"\"\"\n        try:\n            self.survey_data = pd.read_csv(self.survey_path)\n            logger.info(f\"Loaded {len(self.survey_data)} survey responses\")\n        except FileNotFoundError:\n            logger.error(f\"Survey file not found: {self.survey_path}\")\n            raise\n        except Exception as e:\n            logger.error(f\"Failed to load survey data: {str(e)}\")\n            raise\n        \n        # Validate required columns\n        required_cols = list(self.CATEGORY_WEIGHTS.keys()) + [\"team_id\", \"is_anonymous\"]\n        missing_cols = [col for col in required_cols if col not in self.survey_data.columns]\n        if missing_cols:\n            raise ValueError(f\"Missing required survey columns: {missing_cols}\")\n        \n        # Filter anonymous responses only\n        self.survey_data = self.survey_data[self.survey_data[\"is_anonymous\"] == True]\n        if len(self.survey_data) < self.min_responses:\n            raise ValueError(\n                f\"Insufficient anonymous responses: {len(self.survey_data)} < {self.min_responses}\"\n            )\n    \n    def calculate_team_score(self, team_id: str) -> float:\n        \"\"\"Calculate culture health score for a specific team.\n        \n        Args:\n            team_id: Unique identifier for the team\n            \n        Returns:\n            Culture health score (0-100)\n        \"\"\"\n        if self.survey_data is None:\n            raise ValueError(\"Survey data not loaded. Call load_survey_data() first.\")\n        \n        team_data = self.survey_data[self.survey_data[\"team_id\"] == team_id]\n        if len(team_data) == 0:\n            raise ValueError(f\"No survey data found for team {team_id}\")\n        \n        # Calculate weighted average per category\n        total_score = 0.0\n        for category, weight in self.CATEGORY_WEIGHTS.items():\n            if category not in team_data.columns:\n                logger.warning(f\"Category {category} missing for team {team_id}, skipping\")\n                continue\n            category_avg = team_data[category].mean()\n            total_score += category_avg * weight\n            logger.debug(f\"Team {team_id} {category} avg: {category_avg:.2f}, weighted: {category_avg * weight:.2f}\")\n        \n        # Normalize to 0-100 scale (survey responses are 1-5, so multiply by 20)\n        final_score = total_score * 20\n        logger.info(f\"Calculated culture score for team {team_id}: {final_score:.1f}/100\")\n        return round(final_score, 1)\n    \n    def flag_toxic_teams(self, threshold: float = 40.0) -> List[str]:\n        \"\"\"Flag teams with culture scores below a toxic threshold.\n        \n        Args:\n            threshold: Score below which a team is considered toxic\n            \n        Returns:\n            List of toxic team IDs\n        \"\"\"\n        if self.survey_data is None:\n            raise ValueError(\"Survey data not loaded. Call load_survey_data() first.\")\n        \n        toxic_teams = []\n        unique_teams = self.survey_data[\"team_id\"].unique()\n        for team_id in unique_teams:\n            try:\n                score = self.calculate_team_score(team_id)\n                if score < threshold:\n                    toxic_teams.append(team_id)\n                    logger.warning(f\"Flagged toxic team {team_id} with score {score:.1f}\")\n            except ValueError as e:\n                logger.error(f\"Failed to calculate score for team {team_id}: {str(e)}\")\n                continue\n        \n        return toxic_teams\n\nif __name__ == \"__main__\":\n    # Example usage: Calculate scores for Q2 2026 survey data\n    try:\n        calculator = CultureHealthCalculator(\n            survey_path=\"q2_2026_culture_survey.csv\",\n            min_responses=10\n        )\n        calculator.load_survey_data()\n        \n        # Calculate score for my former team (team ID: be-backend-2025)\n        my_team_score = calculator.calculate_team_score(\"be-backend-2025\")\n        print(f\"Q2 2026 Culture Score for BE Backend Team: {my_team_score}/100\")\n        \n        # Flag all toxic teams\n        toxic_teams = calculator.flag_toxic_teams(threshold=35.0)\n        print(f\"Toxic teams flagged: {toxic_teams}\")\n        \n    except Exception as e:\n        logger.error(f\"Failed to run culture calculation: {str(e)}\")\n        raise

import { WebClient } from \"@slack/web-api\";\nimport { createHash } from \"crypto\";\nimport { readFileSync } from \"fs\";\nimport { join } from \"path\";\nimport { Logger } from \"@slack/logger\";\nimport { SLACK_TOKEN, TOXIC_KEYWORDS_PATH } from \"./config\";\n\n// Initialize Slack client and logger\nconst logger = new Logger();\nconst slackClient = new WebClient(SLACK_TOKEN, { logger });\n\n// Toxic keyword list loaded from config file (updated 2026-03-01)\nlet toxicKeywords: string[] = [];\ntry {\n    const keywordsPath = join(__dirname, TOXIC_KEYWORDS_PATH);\n    const keywordsFile = readFileSync(keywordsPath, \"utf-8\");\n    toxicKeywords = keywordsFile.split(\"\\n\").map(k => k.trim()).filter(k => k.length > 0);\n    logger.info(`Loaded ${toxicKeywords.length} toxic keywords from ${keywordsPath}`);\n} catch (error) {\n    logger.error(`Failed to load toxic keywords: ${error.message}`);\n    process.exit(1);\n}\n\n// Interface for code review comment payload from GitHub webhook\ninterface CodeReviewComment {\n    repo: string;\n    prNumber: number;\n    commentId: string;\n    author: string;\n    body: string;\n    createdAt: string;\n    slackChannel: string;\n}\n\n// Interface for toxicity check result\ninterface ToxicityResult {\n    isToxic: boolean;\n    matchedKeywords: string[];\n    toxicityScore: number;\n}\n\n/**\n * Check if a code review comment contains toxic language using keyword matching and sentiment analysis.\n * Uses @slack/sentiment v3.2.0 for lightweight sentiment scoring.\n */\nasync function checkCommentToxicity(comment: string): Promise {\n    const matchedKeywords: string[] = [];\n    const lowerComment = comment.toLowerCase();\n    \n    // Check for exact toxic keyword matches\n    for (const keyword of toxicKeywords) {\n        if (lowerComment.includes(keyword.toLowerCase())) {\n            matchedKeywords.push(keyword);\n        }\n    }\n    \n    // Calculate basic sentiment score (simplified for example)\n    // Negative keywords contribute to toxicity score\n    const toxicityScore = matchedKeywords.length * 0.2;\n    const isToxic = toxicityScore > 0.3 || matchedKeywords.length >= 2;\n    \n    return {\n        isToxic,\n        matchedKeywords,\n        toxicityScore\n    };\n}\n\n/**\n * Post a warning message to Slack when toxic code review comments are detected.\n */\nasync function flagToxicComment(comment: CodeReviewComment, result: ToxicityResult): Promise {\n    try {\n        const warningMessage = `\n🚨 Toxic Code Review Comment Detected\n*Repo*: ${comment.repo}\n*PR*: #${comment.prNumber}\n*Author*: @${comment.author}\n*Matched Keywords*: ${result.matchedKeywords.join(\", \")}\n*Toxicity Score*: ${result.toxicityScore.toFixed(2)}\n*Comment*: \"${comment.body.substring(0, 200)}...\"\nPlease review our .\n        `.trim();\n        \n        await slackClient.chat.postMessage({\n            channel: comment.slackChannel,\n            text: warningMessage,\n            mrkdwn: true\n        });\n        \n        logger.info(`Flagged toxic comment ${comment.commentId} from ${comment.author}`);\n    } catch (error) {\n        logger.error(`Failed to post Slack warning for comment ${comment.commentId}: ${error.message}`);\n        throw error;\n    }\n}\n\n/**\n * Handle incoming GitHub code review comment webhook.\n * Validates payload, checks toxicity, flags if needed.\n */\nexport async function handleCodeReviewWebhook(payload: CodeReviewComment): Promise {\n    try {\n        // Validate required payload fields\n        const requiredFields = [\"repo\", \"prNumber\", \"commentId\", \"author\", \"body\", \"slackChannel\"];\n        for (const field of requiredFields) {\n            if (!payload[field]) {\n                throw new Error(`Missing required field: ${field}`);\n            }\n        }\n        \n        // Skip comments from bots\n        if (payload.author.includes(\"[bot]\")) {\n            logger.debug(`Skipping bot comment ${payload.commentId}`);\n            return;\n        }\n        \n        // Check comment toxicity\n        const toxicityResult = await checkCommentToxicity(payload.body);\n        \n        if (toxicityResult.isToxic) {\n            await flagToxicComment(payload, toxicityResult);\n            \n            // Log toxic comment for audit trail (stored in S3 bucket culture-audit-logs-2026)\n            const auditEntry = {\n                ...payload,\n                toxicityResult,\n                timestamp: new Date().toISOString(),\n                hash: createHash(\"sha256\").update(payload.commentId).digest(\"hex\")\n            };\n            logger.info(`Audit entry for toxic comment: ${JSON.stringify(auditEntry)}`);\n        } else {\n            logger.debug(`Comment ${payload.commentId} passed toxicity check`);\n        }\n    } catch (error) {\n        logger.error(`Failed to handle webhook for comment ${payload.commentId}: ${error.message}`);\n        throw error;\n    }\n}\n\n// Example usage: Simulate incoming webhook from our backend repo\nif (require.main === module) {\n    const exampleComment: CodeReviewComment = {\n        repo: \"our-org/backend-service\",\n        prNumber: 1427,\n        commentId: \"c-78923\",\n        author: \"jdoe\",\n        body: \"This code is absolute garbage, why would you even write this? You're wasting everyone's time.\",\n        createdAt: \"2026-04-15T14:32:00Z\",\n        slackChannel: \"C12345678\" // BE Backend team Slack channel\n    };\n    \n    handleCodeReviewWebhook(exampleComment)\n        .then(() => logger.info(\"Webhook handled successfully\"))\n        .catch(error => logger.error(`Webhook failed: ${error.message}`));\n}

package main\n\nimport (\n\t\"encoding/json\"\n\t\"fmt\"\n\t\"log\"\n\t\"math/rand\"\n\t\"os\"\n\t\"time\"\n\t\"github.com/google/uuid\"\n)\n\n// ReferenceCheckRequest represents a request to check a candidate's references\ntype ReferenceCheckRequest struct {\n\tCandidateID   string   `json:\"candidate_id\"`\n\tCandidateName string   `json:\"candidate_name\"`\n\tTargetCompany string   `json:\"target_company\"`\n\tReferences    []string `json:\"references\"` // List of former team member emails\n\tRequestID     string   `json:\"request_id\"`\n}\n\n// ReferenceResponse represents a single reference's feedback\ntype ReferenceResponse struct {\n\tReferenceEmail string  `json:\"reference_email\"`\n\tCultureScore   float64 `json:\"culture_score\"` // 0-5 scale\n\tTechnicalScore float64 `json:\"technical_score\"` // 0-5 scale\n\tWouldRehire    bool    `json:\"would_rehire\"`\n\tComments       string  `json:\"comments\"`\n\tResponseID     string  `json:\"response_id\"`\n}\n\n// ReferenceCheckResult represents the final result of a reference check\ntype ReferenceCheckResult struct {\n\tRequestID        string              `json:\"request_id\"`\n\tCandidateID      string              `json:\"candidate_id\"`\n\tAverageCulture   float64             `json:\"average_culture_score\"`\n\tAverageTechnical float64             `json:\"average_technical_score\"`\n\tRehireRate       float64             `json:\"rehire_rate\"` // Percentage of references willing to rehire\n\tIsPassing        bool                `json:\"is_passing\"`\n\tResponses        []ReferenceResponse `json:\"responses\"`\n\tCheckedAt       string              `json:\"checked_at\"`\n}\n\n// Config holds reference check thresholds\ntype Config struct {\n\tMinCultureScore  float64 `json:\"min_culture_score\"`\n\tMinTechnicalScore float64 `json:\"min_technical_score\"`\n\tMinRehireRate    float64 `json:\"min_rehire_rate\"` // Percentage (0-100)\n}\n\nfunc main() {\n\t// Seed random number generator\n\trand.Seed(time.Now().UnixNano())\n\t\n\t// Load config (simulated for example)\n\tconfig := Config{\n\t\tMinCultureScore:  3.5,\n\t\tMinTechnicalScore: 4.0,\n\t\tMinRehireRate:    70.0,\n\t}\n\t\n\t// Example reference check request for the author (me)\n\trequest := ReferenceCheckRequest{\n\t\tCandidateID:   \"cand-2026-789\",\n\t\tCandidateName: \"Alex Chen\",\n\t\tTargetCompany: \"Meta\",\n\t\tReferences: []string{\n\t\t\t\"jdoe@former-startup.com\",\n\t\t\t\"asmith@former-startup.com\",\n\t\t\t\"mbrown@former-startup.com\",\n\t\t\t\"jlee@former-startup.com\",\n\t\t},\n\t\tRequestID: uuid.New().String(),\n\t}\n\t\n\t// Simulate sending requests and collecting responses\n\tresult, err := runReferenceCheck(request, config)\n\tif err != nil {\n\t\tlog.Fatalf(\"Failed to run reference check: %v\", err)\n\t}\n\t\n\t// Print result as formatted JSON\n\toutput, err := json.MarshalIndent(result, \"\", \"  \")\n\tif err != nil {\n\t\tlog.Fatalf(\"Failed to marshal result: %v\", err)\n\t}\n\t\n\tfmt.Println(string(output))\n}\n\n// runReferenceCheck simulates a full reference check process\nfunc runReferenceCheck(req ReferenceCheckRequest, config Config) (ReferenceCheckResult, error) {\n\tresponses := make([]ReferenceResponse, 0, len(req.References))\n\t\n\tfor _, refEmail := range req.References {\n\t\t// Simulate 20% non-response rate\n\t\tif rand.Float64() < 0.2 {\n\t\t\tlog.Printf(\"Reference %s did not respond, skipping\", refEmail)\n\t\t\tcontinue\n\t\t}\n\t\t\n\t\t// Simulate response based on former team's toxic culture (my former team had 2.1/5 culture score)\n\t\t// Toxic teams have lower culture scores and rehire rates\n\t\tcultureScore := simulateCultureScore(refEmail)\n\t\ttechnicalScore := simulateTechnicalScore(refEmail)\n\t\twouldRehire := simulateRehire(refEmail)\n\t\t\n\t\tresponse := ReferenceResponse{\n\t\t\tReferenceEmail: refEmail,\n\t\t\tCultureScore:   cultureScore,\n\t\t\tTechnicalScore: technicalScore,\n\t\t\tWouldRehire:    wouldRehire,\n\t\t\tComments:       simulateComments(refEmail, cultureScore),\n\t\t\tResponseID:     uuid.New().String(),\n\t\t}\n\t\tresponses = append(responses, response)\n\t}\n\t\n\t// Calculate aggregate scores\n\tif len(responses) == 0 {\n\t\treturn ReferenceCheckResult{}, fmt.Errorf(\"no reference responses received\")\n\t}\n\t\n\tvar totalCulture, totalTechnical float64\n\tvar rehireCount int\n\tfor _, resp := range responses {\n\t\ttotalCulture += resp.CultureScore\n\t\ttotalTechnical += resp.TechnicalScore\n\t\tif resp.WouldRehire {\n\t\t\trehireCount++\n\t\t}\n\t}\n\t\n\tavgCulture := totalCulture / float64(len(responses))\n\tavgTechnical := totalTechnical / float64(len(responses))\n\trehireRate := (float64(rehireCount) / float64(len(responses))) * 100\n\t\n\t// Determine if check passes\n\tisPassing := avgCulture >= config.MinCultureScore &&\n\t\tavgTechnical >= config.MinTechnicalScore &&\n\t\trehireRate >= config.MinRehireRate\n\t\n\treturn ReferenceCheckResult{\n\t\tRequestID:        req.RequestID,\n\t\tCandidateID:      req.CandidateID,\n\t\tAverageCulture:   avgCulture,\n\t\tAverageTechnical: avgTechnical,\n\t\tRehireRate:       rehireRate,\n\t\tIsPassing:        isPassing,\n\t\tResponses:        responses,\n\t\tCheckedAt:       time.Now().Format(time.RFC3339),\n\t}, nil\n}\n\n// simulateCultureScore returns a simulated culture score for a reference\n// My former team had a 2.1/5 average culture score, so references give lower scores\nfunc simulateCultureScore(refEmail string) float64 {\n\t// 60% chance of low score (1-3), 40% chance of high (3-5)\n\tif rand.Float64() < 0.6 {\n\t\treturn 1.0 + rand.Float64()*2.0 // 1-3\n\t}\n\treturn 3.0 + rand.Float64()*2.0 // 3-5\n}\n\n// simulateTechnicalScore returns a simulated technical score (high for me, since I aced LeetCode)\nfunc simulateTechnicalScore(refEmail string) float64 {\n\t// 90% chance of high technical score (4-5)\n\tif rand.Float64() < 0.9 {\n\t\treturn 4.0 + rand.Float64() // 4-5\n\t}\n\treturn 2.0 + rand.Float64()*2.0 // 2-4\n}\n\n// simulateRehire returns whether a reference would rehire (low for toxic teams)\nfunc simulateRehire(refEmail string) bool {\n\t// 30% chance of willing to rehire (my team had 25% rehire rate)\n\treturn rand.Float64() < 0.3\n}\n\n// simulateComments returns simulated comments from references\nfunc simulateComments(refEmail string, cultureScore float64) string {\n\tif cultureScore < 3.0 {\n\t\treturn \"Worked with them during a period of high team tension. Communication was often hostile, and feedback was rarely constructive.\"\n\t}\n\treturn \"Strong technical contributor, but team dynamics at the time made collaboration difficult.\"\n}

# .github/workflows/culture-audit.yml\nname: Quarterly Culture Audit\non:\n  schedule:\n    - cron: \"0 0 1 1,4,7,10 *\" # Run first day of every quarter\njobs:\n  audit:\n    runs-on: ubuntu-latest\n    steps:\n      - uses: actions/checkout@v4\n      - uses: actions/setup-python@v5\n        with:\n          python-version: \"3.12\"\n      - run: pip install pandas numpy\n      - run: python culture_health_calculator.py --survey-path q3_2026_survey.csv\n      - uses: slackapi/slack-github-action@v1.24.0\n        with:\n          slack-bot-token: ${{ secrets.SLACK_BOT_TOKEN }}\n          channel-id: \"C12345678\"\n          text: \"Q3 2026 Culture Audit Complete: See results in the #culture-audit channel\"

-- Query to calculate former team turnover rate from HR database\nSELECT \n    team_id,\n    COUNT(DISTINCT engineer_id) AS total_engineers,\n    SUM(CASE WHEN resignation_date IS NOT NULL THEN 1 ELSE 0 END) AS resigned_engineers,\n    (SUM(CASE WHEN resignation_date IS NOT NULL THEN 1 ELSE 0 END) * 100.0 / COUNT(DISTINCT engineer_id)) AS turnover_rate_percent\nFROM engineering_roster\nWHERE team_id = 'be-backend-2025' -- Your former team ID\n    AND start_date >= '2024-01-01'\n    AND (end_date <= '2025-12-31' OR end_date IS NULL)\nGROUP BY team_id;

// Slack API snippet to set async status for all team members\nconst { WebClient } = require(\"@slack/web-api\");\nconst slackClient = new WebClient(process.env.SLACK_TOKEN);\n\nasync function setAsyncStatus(teamMembers) {\n    for (const memberId of teamMembers) {\n        try {\n            await slackClient.users.profile.set({\n                user: memberId,\n                profile: {\n                    status_text: \"Async mode: Responding within 4 hours\",\n                    status_emoji: \":hourglass_flowing_sand:\",\n                    status_expiration: 0 // No expiration during work hours\n                }\n            });\n            console.log(`Set async status for ${memberId}`);\n        } catch (error) {\n            console.error(`Failed to set status for ${memberId}: ${error.message}`);\n        }\n    }\n}\n\n// Run daily at 9am team time\nsetAsyncStatus([\"U123456\", \"U789012\", \"U345678\"]);