#2589

Committed 10 Mar 2026 09:13PM UTC coverage: 85.748%. First build

Build # #2589

Build Type

push

Committed by

Commit Message

Fix Pollinations HTTP error detection missing 429 and other errors

buildHttpContext() was not setting ignore_errors => TRUE, so
file_get_contents suppressed response headers on error responses.
This caused HTTP 429 rate limiting to be misdetected as "no data"
individual failures instead of triggering batch abort and backoff.

Also adds detection of other HTTP errors (500, etc.) in both
fetchImage() and fetchBatch() to avoid treating error response
bodies as image data.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Coverage Stats

0 of 13 new or added lines in 1 file covered. (0.0%)

25582 of 29834 relevant lines covered (85.75%)

30.61 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

9.62

/include/misc/Pollinations.php

<?php

namespace Freegle\Iznik;

/**
 * Helper class for fetching AI-generated images from Pollinations.ai.
 * Tracks image hashes to detect rate-limiting (same image returned for different prompts).
 * Uses both in-memory and file-based caching for persistence across processes.
 */
class Pollinations {
    # Track hashes we've seen in this process, keyed by hash => prompt.
    private static $seenHashes = [];

    /**
     * Canonical job categories mapped to their iconic object for image generation.
     * Each key is a canonical job title, value is the object to illustrate.
     */
    const CANONICAL_JOBS = [
        'Accountant' => 'calculator',
        'Account Manager' => 'briefcase',
        'Activities Coordinator' => 'clipboard',
        'Administrator' => 'filing cabinet',
        'Architect' => 'blueprint',
        'Area Manager' => 'map with pins',
        'Assistant Manager' => 'name badge',
        'Bartender' => 'cocktail shaker',
        'Bid Manager' => 'sealed envelope',
        'Bookkeeper' => 'ledger book',
        'Branch Manager' => 'desk nameplate',
        'Bricklayer' => 'brick trowel',
        'Building Inspector' => 'spirit level',
        'Building Surveyor' => 'theodolite',
        'Bus Driver' => 'steering wheel',
        'Business Analyst' => 'flowchart diagram',
        'Business Development Manager' => 'handshake icon',
        'Buyer' => 'purchase order',
        'CAD Technician' => 'technical drawing',
        'Care Assistant' => 'stethoscope',
        'Care Coordinator' => 'care plan folder',
        'Care Worker' => 'medical gloves',
        'Carpenter' => 'wood plane',
        'Cashier' => 'cash register',
        'Catering Assistant' => 'serving tray',
        'Chef' => 'chef hat',
        'Cleaner' => 'mop and bucket',
        'Clinical Assessor' => 'medical clipboard',
        'CNC Machinist' => 'CNC milling machine',
        'Communications Engineer' => 'satellite dish',
        'Compliance Officer' => 'checklist on clipboard',
        'Construction Manager' => 'hard hat',
        'Contracts Manager' => 'signed contract',
        'Cook' => 'saucepan',
        'Counsellor' => 'comfortable armchair',
        'Credit Controller' => 'invoice stamp',
        'Customer Service Advisor' => 'headset',
        'Data Analyst' => 'bar chart',
        'Data Architect' => 'database server',
        'Data Engineer' => 'data pipeline diagram',
        'Delivery Driver' => 'delivery van',
        'Dental Nurse' => 'dental mirror',
        'Deputy Manager' => 'deputy badge',
        'Design Engineer' => 'engineering compass',
        'Design Manager' => 'design palette',
        'Digital Marketing Executive' => 'computer screen with analytics',
        'Document Controller' => 'document folder',
        'Door Canvasser' => 'clipboard with petition',
        'Ecologist' => 'binoculars',
        'Electrical Engineer' => 'circuit board',
        'Electrician' => 'wire strippers',
        'Embedded Software Engineer' => 'microchip',
        'Engineering Apprentice' => 'spanner set',
        'Estimator' => 'measuring tape and calculator',
        'Factory Operative' => 'conveyor belt',
        'Female Support Worker' => 'support badge',
        'Field Sales Representative' => 'sales sample case',
        'Field Service Engineer' => 'tool bag',
        'Finance Assistant' => 'spreadsheet printout',
        'Finance Business Partner' => 'financial report',
        'Finance Manager' => 'balance sheet',
        'Financial Controller' => 'accounting ledger',
        'Forklift Driver' => 'forklift',
        'Fundraiser' => 'collection tin',
        'Gas Engineer' => 'gas boiler',
        'General Manager' => 'office desk',
        'Groundworker' => 'shovel',
        'Head of Finance' => 'financial dashboard',
        'Head of Marketing' => 'megaphone',
        'Healthcare Assistant' => 'blood pressure monitor',
        'HGV Class 1 Driver' => 'articulated lorry',
        'HGV Class 2 Driver' => 'rigid lorry',
        'HGV Technician' => 'truck engine',
        'Home Manager' => 'care home building',
        'Housekeeper' => 'vacuum cleaner',
        'HR Advisor' => 'employee handbook',
        'HR Business Partner' => 'HR policy document',
        'Installer' => 'power drill',
        'IT Support' => 'computer keyboard',
        'IT Apprentice' => 'laptop computer',
        'Kitchen Assistant' => 'kitchen knife set',
        'Kitchen Designer' => 'kitchen floor plan',
        'Labourer' => 'wheelbarrow',
        'Lecturer' => 'lectern',
        'Legal Secretary' => 'legal documents',
        'Lifeguard' => 'lifeguard float',
        'Machine Learning Engineer' => 'neural network diagram',
        'Machine Operator' => 'industrial machine',
        'Maintenance Electrician' => 'multimeter',
        'Maintenance Engineer' => 'wrench and gears',
        'Maintenance Manager' => 'maintenance toolkit',
        'Maintenance Technician' => 'toolbox',
        'Management Accountant' => 'financial spreadsheet',
        'Manufacturing Engineer' => 'factory robot arm',
        'Marketing Manager' => 'marketing campaign board',
        'Maths Teacher' => 'protractor and compass',
        'Mechanical Design Engineer' => 'mechanical gear drawing',
        'Mechanical Engineer' => 'mechanical gears',
        'Mechanical Fitter' => 'pipe wrench',
        'Mechanic' => 'car jack',
        'Mobile Tyre Fitter' => 'tyre and wheel',
        'Mortgage Advisor' => 'house keys',
        'Multi Trade Operative' => 'multi-tool',
        'Nursery Manager' => 'toy building blocks',
        'Nursery Practitioner' => 'childrens storybook',
        'Nurse' => 'nurses cap',
        'Operations Manager' => 'operations dashboard',
        'Painter' => 'paint roller',
        'Parts Advisor' => 'car parts catalogue',
        'Passenger Assistant' => 'bus ticket machine',
        'Payroll Administrator' => 'payslip',
        'Payroll Specialist' => 'payroll software screen',
        'Personal Advisor' => 'advisory notepad',
        'Planning Officer' => 'town plan',
        'Plasterer' => 'plastering trowel',
        'Plumber' => 'pipe wrench and pipes',
        'Primary Teacher' => 'school bell',
        'Production Manager' => 'production line',
        'Production Operative' => 'assembly line component',
        'Production Supervisor' => 'quality control gauge',
        'Project Engineer' => 'project gantt chart',
        'Project Manager' => 'project plan board',
        'Property Manager' => 'set of property keys',
        'Quality Engineer' => 'caliper gauge',
        'Quality Inspector' => 'magnifying glass',
        'Quality Manager' => 'quality certificate',
        'Quantity Surveyor' => 'measuring tape and blueprints',
        'Reach Truck Driver' => 'reach truck',
        'Receptionist' => 'reception desk bell',
        'Recruitment Consultant' => 'CV document',
        'Refrigeration Engineer' => 'refrigeration unit',
        'Regional Sales Manager' => 'sales territory map',
        'Registered Manager' => 'care home registration certificate',
        'Research Associate' => 'microscope',
        'Residential Support Worker' => 'house key with lanyard',
        'Restaurant Team Member' => 'restaurant order pad',
        'Roofer' => 'roofing hammer',
        'Rough Sleeping Outreach Worker' => 'sleeping bag',
        'Sales Administrator' => 'sales order form',
        'Sales Advisor' => 'price tag',
        'Sales Consultant' => 'sales presentation',
        'Sales Engineer' => 'technical sales brochure',
        'Sales Executive' => 'business card',
        'Sales Manager' => 'sales trophy',
        'Sales Representative' => 'product sample kit',
        'Scaffolder' => 'scaffolding poles',
        'School Crossing Patrol' => 'lollipop stop sign',
        'Science Teacher' => 'laboratory flask',
        'Security Officer' => 'security badge',
        'SEN Teacher' => 'special education resource kit',
        'Senior Care Assistant' => 'medication trolley',
        'Service Advisor' => 'service desk terminal',
        'Service Engineer' => 'service toolbox',
        'Service Manager' => 'service level agreement',
        'Shift Engineer' => 'shift rota board',
        'Shift Leader' => 'team leader whistle',
        'Site Manager' => 'site plan',
        'Social Worker' => 'case file folder',
        'Software Engineer' => 'computer code on screen',
        'Solution Architect' => 'architecture diagram',
        'Store Manager' => 'retail shop front',
        'Structural Engineer' => 'structural beam drawing',
        'Supervisor' => 'supervisor clipboard',
        'Supply Teacher' => 'classroom whiteboard',
        'Support Worker' => 'support lanyard badge',
        'Teaching Assistant' => 'school exercise book',
        'Team Leader' => 'team whiteboard',
        'Technical Author' => 'technical manual',
        'Tiler' => 'tile cutter',
        'Transport Manager' => 'fleet management board',
        'Transport Planner' => 'route map',
        'Van Driver' => 'white van',
        'Vehicle Technician' => 'car diagnostic tool',
        'Warehouse Operative' => 'pallet of boxes',
        'Welder' => 'welding mask',
        'Window Installer' => 'window frame',
        'Workshop Controller' => 'workshop job board',
        'Workshop Technician' => 'workshop bench',
    ];

    /**
     * Keyword patterns for mapping job titles to canonical categories.
     * Each entry: [patterns, canonical_title]
     * patterns is an array of keyword sets - if ALL keywords in any set are found, it matches.
     * Checked in order; first match wins. More specific patterns should come first.
     */
    const JOB_KEYWORD_MAP = [
        # Driving - specific first
        [['hgv', 'class 1'], 'HGV Class 1 Driver'],
        [['hgv', 'class 2'], 'HGV Class 2 Driver'],
        [['class 1'], 'HGV Class 1 Driver'],
        [['class 2'], 'HGV Class 2 Driver'],
        [['7.5t'], 'Delivery Driver'],
        [['7.5 tonne'], 'Delivery Driver'],
        [['delivery driver'], 'Delivery Driver'],
        [['hgv driver'], 'HGV Class 1 Driver'],
        [['hgv technician'], 'HGV Technician'],
        [['van driver'], 'Van Driver'],
        [['bus driver'], 'Bus Driver'],
        [['trade plate driver'], 'Van Driver'],
        [['forklift'], 'Forklift Driver'],
        [['flt driver'], 'Forklift Driver'],
        [['reach truck'], 'Reach Truck Driver'],
        [['driver rep'], 'Delivery Driver'],

        # Engineering - specific first
        [['embedded software'], 'Embedded Software Engineer'],
        [['machine learning'], 'Machine Learning Engineer'],
        [['software engineer'], 'Software Engineer'],
        [['solution architect'], 'Solution Architect'],
        [['data architect'], 'Data Architect'],
        [['data engineer'], 'Data Engineer'],
        [['data analyst'], 'Data Analyst'],
        [['electrical design'], 'Electrical Engineer'],
        [['mechanical design'], 'Mechanical Design Engineer'],
        [['structural engineer'], 'Structural Engineer'],
        [['electrical engineer'], 'Electrical Engineer'],
        [['mechanical engineer'], 'Mechanical Engineer'],
        [['communications engineer'], 'Communications Engineer'],
        [['refrigeration engineer'], 'Refrigeration Engineer'],
        [['field service engineer'], 'Field Service Engineer'],
        [['service engineer'], 'Service Engineer'],
        [['shift engineer'], 'Shift Engineer'],
        [['gas engineer'], 'Gas Engineer'],
        [['project engineer'], 'Project Engineer'],
        [['design engineer'], 'Design Engineer'],
        [['manufacturing engineer'], 'Manufacturing Engineer'],
        [['quality engineer'], 'Quality Engineer'],
        [['sales engineer'], 'Sales Engineer'],
        [['automation engineer'], 'Mechanical Engineer'],
        [['battery', 'engineer'], 'Electrical Engineer'],
        [['multi skilled', 'engineer'], 'Maintenance Engineer'],
        [['multi-skilled', 'engineer'], 'Maintenance Engineer'],
        [['maintenance engineer'], 'Maintenance Engineer'],
        [['maintenance technician'], 'Maintenance Technician'],
        [['maintenance electrician'], 'Maintenance Electrician'],
        [['shift technician'], 'Maintenance Technician'],
        [['electrical technician'], 'Electrical Engineer'],
        [['mechanical technician'], 'Mechanical Engineer'],

        # Construction & trades
        [['quantity surveyor'], 'Quantity Surveyor'],
        [['building surveyor'], 'Building Surveyor'],
        [['building inspector'], 'Building Inspector'],
        [['site manager'], 'Site Manager'],
        [['construction', 'manager'], 'Construction Manager'],
        [['contracts manager'], 'Contracts Manager'],
        [['groundworker'], 'Groundworker'],
        [['scaffolder'], 'Scaffolder'],
        [['bricklayer'], 'Bricklayer'],
        [['plasterer'], 'Plasterer'],
        [['roofer'], 'Roofer'],
        [['tiler'], 'Tiler'],
        [['painter', 'decorator'], 'Painter'],
        [['paint sprayer'], 'Painter'],
        [['window', 'door', 'installer'], 'Window Installer'],
        [['window', 'installer'], 'Window Installer'],
        [['carpenter'], 'Carpenter'],
        [['multi trade'], 'Multi Trade Operative'],
        [['labourer'], 'Labourer'],
        [['cscs'], 'Labourer'],

        # Welding & machining
        [['cnc'], 'CNC Machinist'],
        [['tig welder'], 'Welder'],
        [['welder'], 'Welder'],
        [['fabricator'], 'Welder'],
        [['machine operator'], 'Machine Operator'],

        # Healthcare & care
        [['registered nurse'], 'Nurse'],
        [['dental nurse'], 'Dental Nurse'],
        [['nurse'], 'Nurse'],
        [['complex care'], 'Care Assistant'],
        [['care assistant'], 'Care Assistant'],
        [['care worker'], 'Care Worker'],
        [['care coordinator'], 'Care Coordinator'],
        [['care team leader'], 'Senior Care Assistant'],
        [['senior care'], 'Senior Care Assistant'],
        [['healthcare assistant'], 'Healthcare Assistant'],
        [['clinical assessor'], 'Clinical Assessor'],
        [['functional assessor'], 'Clinical Assessor'],
        [['support worker'], 'Support Worker'],
        [['residential', 'support'], 'Residential Support Worker'],
        [['outreach worker'], 'Rough Sleeping Outreach Worker'],

        # Social work
        [['social worker'], 'Social Worker'],
        [['personal advisor'], 'Personal Advisor'],

        # Education
        [['teaching assistant'], 'Teaching Assistant'],
        [['sen teacher'], 'SEN Teacher'],
        [['sen teaching'], 'Teaching Assistant'],
        [['supply teacher'], 'Supply Teacher'],
        [['primary teacher'], 'Primary Teacher'],
        [['english teacher'], 'Primary Teacher'],
        [['maths teacher'], 'Maths Teacher'],
        [['science teacher'], 'Science Teacher'],
        [['lecturer'], 'Lecturer'],
        [['headteacher'], 'Primary Teacher'],
        [['head of construction'], 'Lecturer'],
        [['cover supervisor'], 'Teaching Assistant'],
        [['learning support'], 'Teaching Assistant'],
        [['behaviour mentor'], 'Teaching Assistant'],

        # Sales - specific first
        [['field sales'], 'Field Sales Representative'],
        [['door to door'], 'Door Canvasser'],
        [['canvasser'], 'Door Canvasser'],
        [['car sales'], 'Sales Executive'],
        [['sales engineer'], 'Sales Engineer'],
        [['regional sales'], 'Regional Sales Manager'],
        [['area sales'], 'Regional Sales Manager'],
        [['sales manager'], 'Sales Manager'],
        [['sales director'], 'Sales Manager'],
        [['sales consultant'], 'Sales Consultant'],
        [['sales advisor'], 'Sales Advisor'],
        [['sales executive'], 'Sales Executive'],
        [['sales administrator'], 'Sales Administrator'],
        [['sales representative'], 'Sales Representative'],
        [['business development'], 'Business Development Manager'],
        [['account manager'], 'Account Manager'],
        [['key account'], 'Account Manager'],
        [['customer account'], 'Account Manager'],

        # Management
        [['general manager'], 'General Manager'],
        [['operations manager'], 'Operations Manager'],
        [['area manager'], 'Area Manager'],
        [['deputy manager'], 'Deputy Manager'],
        [['assistant manager'], 'Assistant Manager'],
        [['assistant store'], 'Assistant Manager'],
        [['store manager'], 'Store Manager'],
        [['branch manager'], 'Branch Manager'],
        [['home manager'], 'Home Manager'],
        [['registered manager'], 'Registered Manager'],
        [['nursery manager'], 'Nursery Manager'],
        [['property manager'], 'Property Manager'],
        [['project manager'], 'Project Manager'],
        [['design manager'], 'Design Manager'],
        [['marketing manager'], 'Marketing Manager'],
        [['finance manager'], 'Finance Manager'],
        [['transport manager'], 'Transport Manager'],
        [['maintenance manager'], 'Maintenance Manager'],
        [['production manager'], 'Production Manager'],
        [['service manager'], 'Service Manager'],
        [['aftersales manager'], 'General Manager'],
        [['bid manager'], 'Bid Manager'],
        [['commercial manager'], 'Contracts Manager'],

        # Finance & accounting
        [['financial controller'], 'Financial Controller'],
        [['management accountant'], 'Management Accountant'],
        [['finance business partner'], 'Finance Business Partner'],
        [['head of finance'], 'Head of Finance'],
        [['credit controller'], 'Credit Controller'],
        [['accountant'], 'Accountant'],
        [['accounts assistant'], 'Finance Assistant'],
        [['finance assistant'], 'Finance Assistant'],
        [['payroll specialist'], 'Payroll Specialist'],
        [['payroll administrator'], 'Payroll Administrator'],
        [['payroll'], 'Payroll Administrator'],
        [['estimator'], 'Estimator'],
        [['buyer'], 'Buyer'],
        [['mortgage'], 'Mortgage Advisor'],

        # HR
        [['hr business partner'], 'HR Business Partner'],
        [['hr advisor'], 'HR Advisor'],
        [['hr manager'], 'HR Advisor'],
        [['recruitment consultant'], 'Recruitment Consultant'],
        [['trainee recruitment'], 'Recruitment Consultant'],
        [['job coach'], 'Recruitment Consultant'],

        # Customer service
        [['customer service'], 'Customer Service Advisor'],
        [['customer relations'], 'Customer Service Advisor'],
        [['receptionist'], 'Receptionist'],
        [['helpdesk'], 'Receptionist'],

        # IT
        [['it apprentice'], 'IT Apprentice'],
        [['it support'], 'IT Support'],
        [['cyber security'], 'IT Support'],
        [['technical architect'], 'Solution Architect'],
        [['technical specialist'], 'IT Support'],

        # Hospitality & retail
        [['chef'], 'Chef'],
        [['cook'], 'Cook'],
        [['kitchen assistant'], 'Kitchen Assistant'],
        [['kitchen designer'], 'Kitchen Designer'],
        [['chip shop'], 'Cook'],
        [['food & beverage'], 'Catering Assistant'],
        [['food coordinator'], 'Catering Assistant'],
        [['restaurant team'], 'Restaurant Team Member'],
        [['bar team'], 'Bartender'],
        [['pizza venue'], 'Cook'],
        [['burger venue'], 'Cook'],
        [['supermarket team'], 'Cashier'],
        [['customer assistant'], 'Cashier'],
        [['housekeeper'], 'Housekeeper'],
        [['housekeeping'], 'Housekeeper'],

        # Automotive
        [['vehicle technician'], 'Vehicle Technician'],
        [['motor vehicle'], 'Vehicle Technician'],
        [['mechanic'], 'Mechanic'],
        [['tyre fitter'], 'Mobile Tyre Fitter'],
        [['parts advisor'], 'Parts Advisor'],
        [['service advisor'], 'Service Advisor'],
        [['workshop controller'], 'Workshop Controller'],
        [['workshop technician'], 'Workshop Technician'],

        # Warehouse & logistics
        [['warehouse'], 'Warehouse Operative'],
        [['transport planner'], 'Transport Planner'],

        # Security
        [['security officer'], 'Security Officer'],
        [['security'], 'Security Officer'],
        [['sia'], 'Security Officer'],

        # Production & manufacturing
        [['production operative'], 'Production Operative'],
        [['production supervisor'], 'Production Supervisor'],
        [['cleaning operative'], 'Cleaner'],
        [['cleaner'], 'Cleaner'],
        [['cleaning'], 'Cleaner'],

        # Research & academic
        [['research'], 'Research Associate'],
        [['postdoctoral'], 'Research Associate'],
        [['professor'], 'Lecturer'],

        # Children & nursery
        [['nursery practitioner'], 'Nursery Practitioner'],
        [['nursery'], 'Nursery Practitioner'],

        # Other specific roles
        [['plumber'], 'Plumber'],
        [['electrician'], 'Electrician'],
        [['mechanical fitter'], 'Mechanical Fitter'],
        [['installer'], 'Installer'],
        [['document controller'], 'Document Controller'],
        [['technical author'], 'Technical Author'],
        [['digital marketing'], 'Digital Marketing Executive'],
        [['head of marketing'], 'Head of Marketing'],
        [['cad technician'], 'CAD Technician'],
        [['architectural'], 'Architect'],
        [['architect'], 'Architect'],
        [['ecologist'], 'Ecologist'],
        [['lifeguard'], 'Lifeguard'],
        [['fundraiser'], 'Fundraiser'],
        [['compliance'], 'Compliance Officer'],
        [['planning officer'], 'Planning Officer'],
        [['planning enforcement'], 'Planning Officer'],
        [['housing officer'], 'Property Manager'],
        [['library assistant'], 'Administrator'],
        [['contractor escort'], 'Security Officer'],
        [['school crossing'], 'School Crossing Patrol'],
        [['passenger assistant'], 'Passenger Assistant'],
        [['activities coordinator'], 'Activities Coordinator'],
        [['activities team'], 'Activities Coordinator'],
        [['team leader'], 'Team Leader'],
        [['shift leader'], 'Shift Leader'],
        [['supervisor'], 'Supervisor'],
        [['administrator'], 'Administrator'],
        [['admin'], 'Administrator'],
        [['coordinator'], 'Administrator'],
        [['legal secretary'], 'Legal Secretary'],
        [['secretary'], 'Legal Secretary'],
        [['costs draftsperson'], 'Legal Secretary'],
        [['surveyor'], 'Building Surveyor'],
        [['engineer'], 'Maintenance Engineer'],
        [['technician'], 'Maintenance Technician'],
        [['operative'], 'Factory Operative'],
        [['driver'], 'Delivery Driver'],
        [['manager'], 'General Manager'],
        [['assistant'], 'Administrator'],
        [['teacher'], 'Primary Teacher'],
        [['worker'], 'Support Worker'],

        # Catch-all broader patterns (must be last)
        [['multi-skilled', 'engineer'], 'Maintenance Engineer'],
        [['green & clean'], 'Cleaner'],
        [['green and clean'], 'Cleaner'],
        [['children\'s home'], 'Residential Support Worker'],
        [['childrens home'], 'Residential Support Worker'],
        [['tenancy support'], 'Support Worker'],
        [['process technologist'], 'Quality Engineer'],
        [['digital transformation'], 'IT Support'],
        [['software developer'], 'Software Engineer'],
        [['data scientist'], 'Data Analyst'],
        [['kitchen porter'], 'Kitchen Assistant'],
        [['merchandiser'], 'Sales Advisor'],
        [['joiner'], 'Carpenter'],
        [['marketing executive'], 'Digital Marketing Executive'],
        [['conveyancer'], 'Legal Secretary'],
        [['valeter'], 'Cleaner'],
        [['site agent'], 'Site Manager'],
        [['consultant'], 'Account Manager'],
        [['analyst'], 'Data Analyst'],
        [['clerk'], 'Finance Assistant'],
        [['developer'], 'Software Engineer'],
        [['director'], 'General Manager'],
        [['officer'], 'Administrator'],
        [['adviser'], 'Customer Service Advisor'],
        [['advisor'], 'Customer Service Advisor'],
        [['carer'], 'Care Worker'],
        [['porter'], 'Warehouse Operative'],
        [['agent'], 'Sales Advisor'],
        [['member'], 'Cashier'],
        [['registrar'], 'Administrator'],
        [['principal'], 'General Manager'],
        [['head of'], 'General Manager'],
        [['senior'], 'General Manager'],
        [['lead'], 'General Manager'],
    ];

    # File-based cache location.
    const CACHE_FILE = '/tmp/pollinations_hashes.json';

    # Cache expiry in seconds (24 hours).
    const CACHE_EXPIRY = 86400;

    # File-based cache for failed items.
    const FAILED_CACHE_FILE = '/tmp/pollinations_failed.json';

    # Max failures before permanently skipping an item.
    const MAX_FAILURES = 3;

    # Failed items cache expiry (1 day - give items a chance to work later).
    const FAILED_CACHE_EXPIRY = 86400;

    # OpenAI API endpoint for vision.
    const OPENAI_API_URL = 'https://api.openai.com/v1/chat/completions';

    /**
     * Load the file-based hash cache.
     * @return array Hash => [prompt, timestamp] mapping.
     */
    private static function loadFileCache() {
        if (!file_exists(self::CACHE_FILE)) {
            return [];
        }

        $data = @file_get_contents(self::CACHE_FILE);
        if (!$data) {
            return [];
        }

        $cache = @json_decode($data, TRUE);
        if (!is_array($cache)) {
            return [];
        }

        # Remove expired entries.
        $now = time();
        $cache = array_filter($cache, function($entry) use ($now) {
            return isset($entry['timestamp']) && ($now - $entry['timestamp']) < self::CACHE_EXPIRY;
        });

        return $cache;
    }

    /**
     * Save the file-based hash cache.
     * @param array $cache Hash => [prompt, timestamp] mapping.
     */
    private static function saveFileCache($cache) {
        # Use file locking to prevent race conditions.
        $fp = @fopen(self::CACHE_FILE, 'c');
        if (!$fp) {
            return;
        }

        if (flock($fp, LOCK_EX)) {
            ftruncate($fp, 0);
            fwrite($fp, json_encode($cache));
            fflush($fp);
            flock($fp, LOCK_UN);
        }

        fclose($fp);
    }

    /**
     * Check if a hash exists in the file cache for a different prompt.
     * @param string $hash Image hash.
     * @param string $prompt Current prompt.
     * @return string|false The existing prompt if duplicate found, FALSE otherwise.
     */
    private static function checkFileCache($hash, $prompt) {
        $cache = self::loadFileCache();

        if (isset($cache[$hash]) && $cache[$hash]['prompt'] !== $prompt) {
            return $cache[$hash]['prompt'];
        }

        return FALSE;
    }

    /**
     * Add a hash to the file cache.
     * @param string $hash Image hash.
     * @param string $prompt The prompt that generated this image.
     */
    private static function addToFileCache($hash, $prompt) {
        $cache = self::loadFileCache();

        $cache[$hash] = [
            'prompt' => $prompt,
            'timestamp' => time()
        ];

        self::saveFileCache($cache);
    }

    /**
     * Load the failed items cache.
     * @return array itemName => ['count' => int, 'timestamp' => int]
     */
    private static function loadFailedCache() {
        if (!file_exists(self::FAILED_CACHE_FILE)) {
            return [];
        }

        $data = @file_get_contents(self::FAILED_CACHE_FILE);
        if (!$data) {
            return [];
        }

        $cache = @json_decode($data, TRUE);
        if (!is_array($cache)) {
            return [];
        }

        # Remove expired entries.
        $now = time();
        $cache = array_filter($cache, function($entry) use ($now) {
            return isset($entry['timestamp']) && ($now - $entry['timestamp']) < self::FAILED_CACHE_EXPIRY;
        });

        return $cache;
    }

    /**
     * Save the failed items cache.
     * @param array $cache itemName => ['count' => int, 'timestamp' => int]
     */
    private static function saveFailedCache($cache) {
        $fp = @fopen(self::FAILED_CACHE_FILE, 'c');
        if (!$fp) {
            return;
        }

        if (flock($fp, LOCK_EX)) {
            ftruncate($fp, 0);
            fwrite($fp, json_encode($cache));
            fflush($fp);
            flock($fp, LOCK_UN);
        }

        fclose($fp);
    }

    /**
     * Record a failure for an item. Returns TRUE if item should be skipped (too many failures).
     * @param string $itemName The item name that failed.
     * @return bool TRUE if item has exceeded max failures and should be skipped.
     */
    public static function recordFailure($itemName) {
        $cache = self::loadFailedCache();

        if (!isset($cache[$itemName])) {
            $cache[$itemName] = ['count' => 0, 'timestamp' => time()];
        }

        $cache[$itemName]['count']++;
        $cache[$itemName]['timestamp'] = time();

        self::saveFailedCache($cache);

        $shouldSkip = $cache[$itemName]['count'] >= self::MAX_FAILURES;
        if ($shouldSkip) {
            error_log("Item '$itemName' has failed " . $cache[$itemName]['count'] . " times, will skip for 1 day");
        }

        return $shouldSkip;
    }

    /**
     * Check if an item should be skipped due to previous failures.
     * @param string $itemName The item name to check.
     * @return bool TRUE if item should be skipped.
     */
    public static function shouldSkipItem($itemName) {
        $cache = self::loadFailedCache();

        if (!isset($cache[$itemName])) {
            return FALSE;
        }

        return $cache[$itemName]['count'] >= self::MAX_FAILURES;
    }

    /**
     * Clear the failed items cache (mainly for testing/maintenance).
     */
    public static function clearFailedCache() {
        if (file_exists(self::FAILED_CACHE_FILE)) {
            @unlink(self::FAILED_CACHE_FILE);
        }
    }

    /**
     * Build the HTTP context for Pollinations API requests.
     *
     * @param int $timeout Timeout in seconds.
     * @return resource Stream context for HTTP requests.
     */
    private static function buildHttpContext($timeout) {
        return stream_context_create([
            'http' => [
                'timeout' => $timeout,
                'ignore_errors' => TRUE
            ]
        ]);
    }

    /**
     * Build the Pollinations image URL with optional API key.
     *
     * @param string $prompt The prompt (will be URL-encoded).
     * @param int $width Image width.
     * @param int $height Image height.
     * @return string The full URL.
     */
    private static function buildImageUrl($prompt, $width, $height) {
        $url = "https://image.pollinations.ai/prompt/" . urlencode($prompt) .
               "?width={$width}&height={$height}&nologo=true&seed=1";

        # Add API key if configured.
        if (defined('POLLINATIONS_API_KEY') && POLLINATIONS_API_KEY) {
            $url .= "&key=" . urlencode(POLLINATIONS_API_KEY);
        }

        return $url;
    }

    /**
     * Fetch an image from Pollinations.ai for the given prompt.
     * Returns image data on success, or FALSE if rate-limited/failed.
     *
     * @param string $prompt The item name/description to generate an image for.
     * @param string $fullPrompt The full prompt string to send to Pollinations.
     * @param int $width Image width.
     * @param int $height Image height.
     * @param int $timeout Timeout in seconds.
     * @return string|false Image data on success, FALSE on failure or rate-limiting.
     */
    public static function fetchImage($prompt, $fullPrompt, $width = 640, $height = 480, $timeout = 120) {
        global $dbhr;

        $url = self::buildImageUrl($fullPrompt, $width, $height);

        $ctx = self::buildHttpContext($timeout);

        $data = @file_get_contents($url, FALSE, $ctx);

        # Check HTTP status code.
        if (isset($http_response_header)) {
            foreach ($http_response_header as $header) {
                if (preg_match('/^HTTP\/\d+\.?\d*\s+429/', $header)) {
                    error_log("Pollinations rate limited (HTTP 429) for: " . $prompt);
                    return FALSE;
                }

                if (preg_match('/^HTTP\/\d+\.?\d*\s+(\d+)/', $header, $matches)) {
                    $httpCode = (int)$matches[1];
                    if ($httpCode >= 400) {
                        error_log("Pollinations HTTP $httpCode for: " . $prompt);
                        return FALSE;
                    }
                }
            }
        }

        if (!$data || strlen($data) == 0) {
            error_log("Pollinations failed to return data for: " . $prompt);
            return FALSE;
        }

        # Compute hash of received image.
        $hash = md5($data);

        # Check 1: In-memory cache (same process).
        if (isset(self::$seenHashes[$hash]) && self::$seenHashes[$hash] !== $prompt) {
            error_log("Pollinations rate limited (in-memory duplicate) for: " . $prompt .
                      " (same image as: " . self::$seenHashes[$hash] . ")");
            # Clean up the recently added entry that we now know is rate-limited.
            self::cleanupRateLimitedHash($hash);
            return FALSE;
        }

        # Check 2: File-based cache (across processes).
        $existingPrompt = self::checkFileCache($hash, $prompt);
        if ($existingPrompt !== FALSE) {
            error_log("Pollinations rate limited (file cache duplicate) for: " . $prompt .
                      " (same image as: " . $existingPrompt . ")");
            # Clean up recently added entries with this hash.
            self::cleanupRateLimitedHash($hash);
            return FALSE;
        }

        # Check 3: Database (historical data).
        if ($dbhr) {
            $existing = $dbhr->preQuery(
                "SELECT name FROM ai_images WHERE imagehash = ? AND name != ? LIMIT 1",
                [$hash, $prompt]
            );

            if (count($existing) > 0) {
                error_log("Pollinations rate limited (DB duplicate) for: " . $prompt .
                          " (same image as: " . $existing[0]['name'] . ")");
                # Also add to file cache to speed up future checks.
                self::addToFileCache($hash, $existing[0]['name']);
                return FALSE;
            }
        }

        # All checks passed - track this hash.
        self::$seenHashes[$hash] = $prompt;
        self::addToFileCache($hash, $prompt);

        return $data;
    }

    /**
     * Clean up recently added ai_images entries with a rate-limited hash.
     * Only removes entries added in the last hour to avoid removing legitimate old entries.
     * @param string $hash The rate-limited image hash.
     */
    private static function cleanupRateLimitedHash($hash) {
        global $dbhm;

        if (!$dbhm) {
            return;
        }

        # Only clean up entries added in the last hour - these are likely from this rate-limiting event.
        $deleted = $dbhm->preExec(
            "DELETE FROM ai_images WHERE imagehash = ? AND created > DATE_SUB(NOW(), INTERVAL 1 HOUR)",
            [$hash]
        );

        if ($deleted) {
            $count = $dbhm->rowsAffected();
            if ($count > 0) {
                error_log("Cleaned up $count recent ai_images entries with rate-limited hash: $hash");
            }
        }

        # Also clean up messages_attachments that were recently added with externaluids
        # that are now known to be rate-limited (i.e., the ai_images entry was just deleted).
        # We look for recent AI attachments that no longer have a matching ai_images entry.
        $minId = $dbhm->preQuery("SELECT COALESCE(MAX(id), 0) - 10000 as minid FROM messages_attachments");
        $minIdVal = $minId[0]['minid'] ?? 0;

        $orphaned = $dbhm->preExec(
            "DELETE ma FROM messages_attachments ma
             LEFT JOIN ai_images ai ON ma.externaluid = ai.externaluid
             WHERE ma.externaluid LIKE 'freegletusd-%'
             AND JSON_EXTRACT(ma.externalmods, '$.ai') = TRUE
             AND ai.id IS NULL
             AND ma.id > ?",
            [$minIdVal]
        );

        if ($orphaned) {
            $count = $dbhm->rowsAffected();
            if ($count > 0) {
                error_log("Cleaned up $count orphaned message attachments");
            }
        }
    }

    /**
     * Build a prompt for a message illustration.
     * @param string $itemName The item name.
     * @return string The full prompt.
     */
    public static function buildMessagePrompt($itemName) {
        # Prompt injection defense.
        $cleanName = str_replace('CRITICAL:', '', $itemName);
        $cleanName = str_replace('Draw only', '', $cleanName);

        # Use positive framing only - negative prompts can backfire with diffusion models.
        # Avoid mentioning specific item categories (clothing, furniture) as this can cause
        # the model to include them even when the actual item is unrelated.
        return "Product illustration: single isolated " . $cleanName . " centered on plain dark green background. " .
               "Style: friendly cartoon white line drawing, moderate shading, cute and quirky, UK audience. " .
               "The object sits alone on a simple surface or floats in space. " .
               "Simple illustration style, clean lines, single object only.";
    }

    /**
     * Map a job title to a canonical job category using pure PHP keyword matching.
     * No API calls. Returns NULL for unmapped titles.
     *
     * @param string $title The raw job title.
     * @return string|null The canonical job title, or NULL if no match.
     */
    public static function canonicalJobTitle($title) {
        if (empty($title)) {
            return NULL;
        }

        # Clean: lowercase, strip location suffixes, ref numbers, trim.
        $clean = strtolower(trim($title));

        # Strip location suffixes like "- Portsmouth", "- Durham", "- Haven"
        # Require space before dash to avoid matching hyphenated words like "Multi-Skilled"
        $clean = preg_replace('/\s+-\s+[A-Z][a-zA-Z\s&\']+$/', '', trim($title));
        $clean = strtolower(trim($clean));

        # Strip parenthetical locations like "(Nottingham, Nottinghamshire, GB, NG1 1DQ)"
        $clean = preg_replace('/\s*\([^)]*\)\s*/', ' ', $clean);

        # Strip "IKEA xxx Store" suffixes
        $clean = preg_replace('/\s*-\s*ikea\s+\w+\s+store$/i', '', $clean);

        # Strip trailing location with postcodes
        $clean = preg_replace('/\s*-\s*[a-z]+,?\s+[a-z]+shire$/i', '', $clean);

        # Strip "- Haven" type suffixes that may remain
        $clean = preg_replace('/\s*-\s*haven$/i', '', $clean);

        # Strip college/institution suffixes
        $clean = preg_replace('/\s*-\s*\w+\s+college\s*.*$/i', '', $clean);

        $clean = trim($clean);

        # First: check if cleaned title exactly matches a canonical title (case-insensitive).
        foreach (self::CANONICAL_JOBS as $canonical => $object) {
            if (strtolower($canonical) === $clean) {
                return $canonical;
            }
        }

        # Second: keyword pattern matching.
        foreach (self::JOB_KEYWORD_MAP as $entry) {
            $patterns = $entry[0];
            $canonical = $entry[1];

            # All keywords in the pattern must be present in the cleaned title.
            $allMatch = TRUE;
            foreach ($patterns as $keyword) {
                if (strpos($clean, strtolower($keyword)) === FALSE) {
                    $allMatch = FALSE;
                    break;
                }
            }

            if ($allMatch) {
                return $canonical;
            }
        }

        return NULL;
    }

    /**
     * Use GPT to map a job title to an iconic inanimate object/tool for that job.
     * This avoids generating images of people by never mentioning the profession
     * in the image prompt.
     *
     * @param string $jobTitle The job title.
     * @return string|false The object name, or FALSE on failure.
     */
    public static function objectForJob($jobTitle) {
        if (!defined('OPENAI_API_KEY') || !OPENAI_API_KEY) {
            return FALSE;
        }

        $cleanName = str_replace('CRITICAL:', '', $jobTitle);
        $cleanName = str_replace('Draw only', '', $cleanName);

        $payload = [
            'model' => 'gpt-4o-mini',
            'messages' => [
                [
                    'role' => 'system',
                    'content' => 'You map job titles to a single iconic inanimate object or tool associated with that job. Reply with ONLY the object name, nothing else. No people, no body parts, no living things. Just the object.'
                ],
                [
                    'role' => 'user',
                    'content' => $cleanName
                ]
            ],
            'max_tokens' => 20
        ];

        $ch = curl_init(self::OPENAI_API_URL);
        curl_setopt_array($ch, [
            CURLOPT_RETURNTRANSFER => TRUE,
            CURLOPT_POST => TRUE,
            CURLOPT_POSTFIELDS => json_encode($payload),
            CURLOPT_HTTPHEADER => [
                'Content-Type: application/json',
                'Authorization: Bearer ' . OPENAI_API_KEY
            ],
            CURLOPT_TIMEOUT => 15
        ]);

        $response = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        curl_close($ch);

        if ($httpCode !== 200 || !$response) {
            error_log("objectForJob failed for '$jobTitle': HTTP $httpCode");
            return FALSE;
        }

        $data = json_decode($response, TRUE);

        if (!isset($data['choices'][0]['message']['content'])) {
            error_log("objectForJob failed for '$jobTitle': unexpected response");
            return FALSE;
        }

        return trim($data['choices'][0]['message']['content']);
    }

    /**
     * Build a prompt for a job illustration.
     * Uses the same object-focused prompt as messages to avoid generating people.
     * @param string $objectName The object name (from objectForJob).
     * @return string The full prompt.
     */
    public static function buildJobPrompt($objectName) {
        return self::buildMessagePrompt($objectName);
    }

    /**
     * Fetch a batch of images, returning successful results and tracking failures.
     * Individual item failures (no data returned) do NOT fail the batch - only actual
     * rate-limiting (HTTP 429 or duplicate images) fails the entire batch.
     *
     * @param array $items Array of ['name' => string, 'prompt' => string, 'width' => int, 'height' => int]
     * @param int $timeout Timeout per request in seconds.
     * @return array|false Array with 'results' and 'failed' keys on success, FALSE if rate-limited.
     *                     'results' => [['name' => string, 'data' => string, 'hash' => string], ...]
     *                     'failed' => [name => TRUE, ...] items that failed to fetch (not rate-limited)
     */
    public static function fetchBatch($items, $timeout = 120) {
        if (empty($items)) {
            return ['results' => [], 'failed' => []];
        }

        $results = [];
        $failed = [];
        $batchHashes = [];

        foreach ($items as $item) {
            $name = $item['name'];
            $prompt = $item['prompt'];
            $width = $item['width'] ?? 640;
            $height = $item['height'] ?? 480;

            $url = self::buildImageUrl($prompt, $width, $height);

            $ctx = self::buildHttpContext($timeout);

            error_log("Batch fetching image for: $name");
            $data = @file_get_contents($url, FALSE, $ctx);

            # Check HTTP status code.
            if (isset($http_response_header)) {
                foreach ($http_response_header as $header) {
                    if (preg_match('/^HTTP\/\d+\.?\d*\s+429/', $header)) {
                        error_log("Pollinations rate limited (HTTP 429) for batch item: $name");
                        return FALSE;
                    }

                    if (preg_match('/^HTTP\/\d+\.?\d*\s+(\d+)/', $header, $matches)) {
                        $httpCode = (int)$matches[1];
                        if ($httpCode >= 400) {
                            error_log("Pollinations HTTP $httpCode for batch item: $name (skipping)");
                            $failed[$name] = TRUE;
                            continue 2;
                        }
                    }
                }
            }

            # No data returned - this is an individual failure, NOT rate-limiting.
            # Skip this item but continue with others.
            if (!$data || strlen($data) == 0) {
                error_log("Pollinations failed to return data for batch item: $name (skipping)");
                $failed[$name] = TRUE;
                continue;
            }

            $hash = md5($data);

            # Check if this hash already appeared in this batch for a different item.
            # This IS rate-limiting - fail entire batch.
            if (isset($batchHashes[$hash]) && $batchHashes[$hash] !== $name) {
                error_log("Pollinations rate limited (batch duplicate) for: $name (same as: " . $batchHashes[$hash] . ")");
                # Clean up any recently added entries with this hash.
                self::cleanupRateLimitedHash($hash);
                return FALSE;
            }

            # Check file cache - this IS rate-limiting.
            $existingPrompt = self::checkFileCache($hash, $name);
            if ($existingPrompt !== FALSE) {
                error_log("Pollinations rate limited (file cache) for batch item: $name (same as: $existingPrompt)");
                self::cleanupRateLimitedHash($hash);
                return FALSE;
            }

            # Check database for historical duplicates - this IS rate-limiting.
            global $dbhr;
            if ($dbhr) {
                $existing = $dbhr->preQuery(
                    "SELECT name FROM ai_images WHERE imagehash = ? AND name != ? LIMIT 1",
                    [$hash, $name]
                );

                if (count($existing) > 0) {
                    error_log("Pollinations rate limited (DB) for batch item: $name (same as: " . $existing[0]['name'] . ")");
                    self::addToFileCache($hash, $existing[0]['name']);
                    self::cleanupRateLimitedHash($hash);
                    return FALSE;
                }
            }

            # Safety check: verify image doesn't contain people.
            $hasPeople = self::checkForPeople($data, $name);
            if ($hasPeople === TRUE) {
                error_log("Rejecting image for '$name' - contains people");
                $failed[$name] = TRUE;
                continue;
            }

            $batchHashes[$hash] = $name;
            $results[] = [
                'name' => $name,
                'data' => $data,
                'hash' => $hash,
                'msgid' => $item['msgid'] ?? NULL,
                'jobid' => $item['jobid'] ?? NULL
            ];

            # Small delay between requests.
            sleep(1);
        }

        # Add successful images to caches.
        foreach ($results as $result) {
            self::$seenHashes[$result['hash']] = $result['name'];
            self::addToFileCache($result['hash'], $result['name']);
        }

        return ['results' => $results, 'failed' => $failed];
    }

    /**
     * Cache an image in ai_images table.
     * @param string $name The item/job name.
     * @param string $uid The externaluid.
     * @param string $hash Image hash.
     */
    public static function cacheImage($name, $uid, $hash) {
        global $dbhm;

        if ($dbhm) {
            $dbhm->preExec(
                "INSERT INTO ai_images (name, externaluid, imagehash) VALUES (?, ?, ?)
                 ON DUPLICATE KEY UPDATE externaluid = VALUES(externaluid), imagehash = VALUES(imagehash), created = NOW()",
                [$name, $uid, $hash]
            );
        }
    }

    /**
     * Upload image to TUS and cache in ai_images table.
     * Applies duotone filter before uploading to ensure consistent appearance in emails.
     * @param string $name The item/job name.
     * @param string $data Image data.
     * @param string $hash Image hash.
     * @return string|false The externaluid on success, FALSE on failure.
     */
    public static function uploadAndCache($name, $data, $hash) {
        # Apply duotone filter to ensure consistent green/white color scheme.
        # This bakes the effect into the image so it works in emails where CSS filters don't.
        $img = new Image($data);
        if ($img->img) {
            $img->duotoneGreen();
            $data = $img->getData(90);

            if (!$data) {
                error_log("Failed to apply duotone filter for: $name");
                return FALSE;
            }
        }

        $t = new Tus();
        $tusUrl = $t->upload(NULL, 'image/jpeg', $data);

        if (!$tusUrl) {
            error_log("Failed to upload image to TUS for: $name");
            return FALSE;
        }

        $uid = 'freegletusd-' . basename($tusUrl);
        self::cacheImage($name, $uid, $hash);

        return $uid;
    }

    /**
     * Get the hash of image data.
     * @param string $data Image data.
     * @return string MD5 hash.
     */
    public static function getImageHash($data) {
        return md5($data);
    }

    /**
     * Clear the in-memory hash cache (mainly for testing).
     */
    public static function clearCache() {
        self::$seenHashes = [];
    }

    /**
     * Clear the file-based hash cache (mainly for testing/maintenance).
     */
    public static function clearFileCache() {
        if (file_exists(self::CACHE_FILE)) {
            @unlink(self::CACHE_FILE);
        }
    }

    /**
     * Check if an image contains people using GPT-4o-mini vision.
     * Only runs if OPENAI_API_KEY is defined in config.
     *
     * @param string $imageData Raw image data (not base64 encoded).
     * @param string $itemName Item name for logging.
     * @return bool|null TRUE if people detected, FALSE if not, NULL if check unavailable/failed.
     */
    public static function checkForPeople($imageData, $itemName = '') {
        # Only run check if OpenAI API key is configured.
        if (!defined('OPENAI_API_KEY') || !OPENAI_API_KEY) {
            return NULL;
        }

        # Convert image to base64 data URL.
        $base64 = base64_encode($imageData);
        $mimeType = 'image/jpeg';

        # Try to detect actual mime type.
        $finfo = new \finfo(FILEINFO_MIME_TYPE);
        $detected = $finfo->buffer($imageData);
        if ($detected && strpos($detected, 'image/') === 0) {
            $mimeType = $detected;
        }

        $dataUrl = "data:{$mimeType};base64,{$base64}";

        $payload = [
            'model' => 'gpt-4o-mini',
            'messages' => [
                [
                    'role' => 'user',
                    'content' => [
                        [
                            'type' => 'text',
                            'text' => 'Does this image contain any people, human figures, hands, arms, legs, or body parts? Answer only YES or NO.'
                        ],
                        [
                            'type' => 'image_url',
                            'image_url' => [
                                'url' => $dataUrl,
                                'detail' => 'low'
                            ]
                        ]
                    ]
                ]
            ],
            'max_tokens' => 10
        ];

        $ch = curl_init(self::OPENAI_API_URL);
        curl_setopt_array($ch, [
            CURLOPT_RETURNTRANSFER => TRUE,
            CURLOPT_POST => TRUE,
            CURLOPT_POSTFIELDS => json_encode($payload),
            CURLOPT_HTTPHEADER => [
                'Content-Type: application/json',
                'Authorization: Bearer ' . OPENAI_API_KEY
            ],
            CURLOPT_TIMEOUT => 30
        ]);

        $response = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        curl_close($ch);

        if ($httpCode !== 200 || !$response) {
            error_log("OpenAI vision check failed for '$itemName': HTTP $httpCode");
            return NULL;
        }

        $data = json_decode($response, TRUE);

        if (!isset($data['choices'][0]['message']['content'])) {
            error_log("OpenAI vision check failed for '$itemName': unexpected response format");
            return NULL;
        }

        $answer = strtoupper(trim($data['choices'][0]['message']['content']));
        $hasPeople = strpos($answer, 'YES') !== FALSE;

        if ($hasPeople) {
            error_log("OpenAI safety check: people detected in image for '$itemName'");
        }

        return $hasPeople;
    }
}

Freegle / iznik-server / #2589

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous