PHP: полный мануал с примерами, функциями и ООП

<?php
declare(strict_types=1);
require __DIR__.'/ct124-helper.php';
$settings=ct124Settings(false);$database=$settings['database'];
$manager=new MongoDB\Driver\Manager($settings['uri'],['serverSelectionTimeoutMS'=>1500,'connectTimeoutMS'=>1000,'socketTimeoutMS'=>5000,'retryReads'=>false],['disableClientPersistence'=>true]);
$observer=new Ct124Observer;$owned=[];$subscribed=false;
$observations=['events'=>[],'details'=>[]];
try{
$version=ct124Command($manager,$database,['buildInfo'=>1])[0]['version'];
if(version_compare($version,'8.0','<')){throw new RuntimeException('MongoDB 8.0+ required');}
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>$version,'execution'=>'database'];
$name=ct124Create($manager,$database,$owned);$namespace=$database.'.'.$name;
$manager->addSubscriber($observer);$subscribed=true;
// Выделяем бизнес-команды; реальные getMore остаются в полной трассе.
function ct124TargetPairs(Ct124Observer $observer,string $name,array &$transport): array {
    $targets=[];$open=[];$transport=[];
    foreach(ct124Pairs($observer) as [$start,$end]){
        $kind=$start->getCommandName();$command=$start->getCommand();$reply=$end->getReply();
        if(in_array($kind,['find','aggregate'],true)){
            if(($command->$kind??null)!==$name || !isset($reply->cursor)
                || !is_array($reply->cursor->firstBatch??null)){
                throw new RuntimeException('Unexpected target namespace or firstBatch');
            }
            $targets[]=[$start,$end];$cursorId=(string)$reply->cursor->id;
            if($cursorId!=='0'){$open['cursor:'.$cursorId]=['command'=>$kind,'operation_id'=>$start->getOperationId()];}
            continue;
        }
        if($kind!=='getMore'){throw new RuntimeException('Unexpected extra command in this reading lesson');}
        $cursorId=(string)($command->getMore??'');$owner=$open['cursor:'.$cursorId]??null;
        if($owner===null || ($command->collection??null)!==$name
            || !isset($reply->cursor) || !is_array($reply->cursor->nextBatch??null)
            || $reply->cursor->nextBatch!==[] || (string)$reply->cursor->id!=='0'){
            throw new RuntimeException('Extra getMore must close its observed cursor with an empty nextBatch');
        }
        // У find общий operationId наблюдается; для aggregate драйвер может дать getMore="0".
        if($owner['command']==='find' && $owner['operation_id']!==$start->getOperationId()){
            throw new RuntimeException('Unexpected operation association for find continuation');
        }
        $transport[]=['command'=>'getMore','parent_command'=>$owner['command'],'request_id'=>$start->getRequestId(),
            'operation_id'=>$start->getOperationId(),'documents'=>0,'closed_cursor'=>true];
        unset($open['cursor:'.$cursorId]);
    }
    if($open!==[]){throw new RuntimeException('Reading lesson left an observed server cursor open');}
    return $targets;
}
$transport=[];


$cursor=ct124Page($manager,$namespace);$products=$cursor->toArray();
$pairs=ct124TargetPairs($observer,$name,$transport);[$start,$end]=$pairs[0];$command=$start->getCommand();
$actual=['active'=>$command->filter->active,'stock_gt'=>$command->filter->stock->{'$gt'},
    'projection'=>(array)$command->projection,'sort'=>(array)$command->sort,'limit'=>(string)$command->limit];
$observations['details']=['checked_command'=>$actual,'returned_ids'=>array_column($products,'_id')];
$rows=[];foreach($products as $product){$rows[]=[$product['_id'],$product['title'],$product['price_kopecks']];}
$checks=['two_needed_products'=>array_column($products,'_id')===[107,106],
    'filter_sent'=>$actual['active']===true && $actual['stock_gt']===0,
    'projection_sent'=>$actual['projection']===['_id'=>1,'title'=>1,'price_kopecks'=>1],
    'sort_limit_sent'=>$actual['sort']===['price_kopecks'=>1,'_id'=>1] && $actual['limit']==='2',
    'one_find_pair'=>count($pairs)===1 && $start->getCommandName()==='find',
    'command_is_stdclass'=>$command instanceof stdClass];

$observations['details']['transport_continuations']=$transport;
$observations['details']['all_command_pairs']=count($observer->succeeded);
    $observations['events']=ct124Trace($observer);
    $checks['actual_pairs_and_types']=ct124TraceChecks($observations['events'],$settings);
}finally{
    if($subscribed){$manager->removeSubscriber($observer);}
    unset($cursor);
    foreach(array_reverse($owned) as $ownName){ct124Command($manager,$database,['drop'=>$ownName],true);}
}
$removed=true;foreach($owned as $ownName){if(ct124Exists($manager,$database,$ownName)){$removed=false;}}
$checks['owned_collections_removed']=$removed;
ct124Report('mongodb124-trace-catalog-command', ['Товар', 'Название', 'Цена, коп.'], $rows, $checks, $runtime, $observations);
echo 'mongodb124-trace-catalog-command: saved result.html and result.json
';

mongodb124-trace-catalog-command: saved result.html and result.json

Настоящие команды локального MongoDB и callbacks драйвера; HTML/JSON показывают данные и наблюдения. Helper, полная инструкция среды и проверка удаления своей коллекции включены.

<?php
declare(strict_types=1);
require __DIR__.'/ct124-helper.php';
$settings=ct124Settings(false);$database=$settings['database'];
$manager=new MongoDB\Driver\Manager($settings['uri'],['serverSelectionTimeoutMS'=>1500,'connectTimeoutMS'=>1000,'socketTimeoutMS'=>5000,'retryReads'=>false],['disableClientPersistence'=>true]);
$observer=new Ct124Observer;$owned=[];$subscribed=false;
$observations=['events'=>[],'details'=>[]];
try{
$version=ct124Command($manager,$database,['buildInfo'=>1])[0]['version'];
if(version_compare($version,'8.0','<')){throw new RuntimeException('MongoDB 8.0+ required');}
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>$version,'execution'=>'database'];
$name=ct124Create($manager,$database,$owned);$namespace=$database.'.'.$name;
$manager->addSubscriber($observer);$subscribed=true;
// Выделяем бизнес-команды; реальные getMore остаются в полной трассе.
function ct124TargetPairs(Ct124Observer $observer,string $name,array &$transport): array {
    $targets=[];$open=[];$transport=[];
    foreach(ct124Pairs($observer) as [$start,$end]){
        $kind=$start->getCommandName();$command=$start->getCommand();$reply=$end->getReply();
        if(in_array($kind,['find','aggregate'],true)){
            if(($command->$kind??null)!==$name || !isset($reply->cursor)
                || !is_array($reply->cursor->firstBatch??null)){
                throw new RuntimeException('Unexpected target namespace or firstBatch');
            }
            $targets[]=[$start,$end];$cursorId=(string)$reply->cursor->id;
            if($cursorId!=='0'){$open['cursor:'.$cursorId]=['command'=>$kind,'operation_id'=>$start->getOperationId()];}
            continue;
        }
        if($kind!=='getMore'){throw new RuntimeException('Unexpected extra command in this reading lesson');}
        $cursorId=(string)($command->getMore??'');$owner=$open['cursor:'.$cursorId]??null;
        if($owner===null || ($command->collection??null)!==$name
            || !isset($reply->cursor) || !is_array($reply->cursor->nextBatch??null)
            || $reply->cursor->nextBatch!==[] || (string)$reply->cursor->id!=='0'){
            throw new RuntimeException('Extra getMore must close its observed cursor with an empty nextBatch');
        }
        // У find общий operationId наблюдается; для aggregate драйвер может дать getMore="0".
        if($owner['command']==='find' && $owner['operation_id']!==$start->getOperationId()){
            throw new RuntimeException('Unexpected operation association for find continuation');
        }
        $transport[]=['command'=>'getMore','parent_command'=>$owner['command'],'request_id'=>$start->getRequestId(),
            'operation_id'=>$start->getOperationId(),'documents'=>0,'closed_cursor'=>true];
        unset($open['cursor:'.$cursorId]);
    }
    if($open!==[]){throw new RuntimeException('Reading lesson left an observed server cursor open');}
    return $targets;
}
$transport=[];


$cursor=ct124Page($manager,$namespace);$products=$cursor->toArray();
$summary=ct124Summary($manager,$database,$name);$pairs=ct124TargetPairs($observer,$name,$transport);
$rows=[];foreach($pairs as [$start,$end]){
    $reply=$end->getReply();$batch=$reply->cursor->firstBatch??[];
    $rows[]=[$start->getCommandName(),count($batch),'начало связано с ответом'];
}
$requestIds=array_map(fn($pair)=>$pair[0]->getRequestId(),$pairs);
$observations['details']=['page_ids'=>array_column($products,'_id'),'summary'=>$summary,
    'pair_count'=>count($pairs),'request_ids'=>$requestIds];
$checks=['two_different_actions'=>array_column($rows,0)===['find','aggregate'],
    'request_pairs_unique'=>count($requestIds)===2 && count(array_unique($requestIds))===2,
    'page_and_summary'=>array_column($products,'_id')===[107,106] && $summary===[['products'=>5,'stock'=>21]],
    'reply_documents'=>array_column($rows,1)===[2,1]];

$observations['details']['transport_continuations']=$transport;
$observations['details']['all_command_pairs']=count($observer->succeeded);
    $observations['events']=ct124Trace($observer);
    $checks['actual_pairs_and_types']=ct124TraceChecks($observations['events'],$settings);
}finally{
    if($subscribed){$manager->removeSubscriber($observer);}
    unset($cursor);
    foreach(array_reverse($owned) as $ownName){ct124Command($manager,$database,['drop'=>$ownName],true);}
}
$removed=true;foreach($owned as $ownName){if(ct124Exists($manager,$database,$ownName)){$removed=false;}}
$checks['owned_collections_removed']=$removed;
ct124Report('mongodb124-trace-request-pairs', ['Команда', 'Документов в ответе', 'Сопоставление'], $rows, $checks, $runtime, $observations);
echo 'mongodb124-trace-request-pairs: saved result.html and result.json
';

mongodb124-trace-request-pairs: saved result.html and result.json

Настоящие команды локального MongoDB и callbacks драйвера; HTML/JSON показывают данные и наблюдения. Helper, полная инструкция среды и проверка удаления своей коллекции включены.

<?php
declare(strict_types=1);
require __DIR__.'/ct124-helper.php';
$settings=ct124Settings(false);$database=$settings['database'];
$manager=new MongoDB\Driver\Manager($settings['uri'],['serverSelectionTimeoutMS'=>1500,'connectTimeoutMS'=>1000,'socketTimeoutMS'=>5000,'retryReads'=>false],['disableClientPersistence'=>true]);
$observer=new Ct124Observer;$owned=[];$subscribed=false;
$observations=['events'=>[],'details'=>[]];
try{
$version=ct124Command($manager,$database,['buildInfo'=>1])[0]['version'];
if(version_compare($version,'8.0','<')){throw new RuntimeException('MongoDB 8.0+ required');}
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>$version,'execution'=>'database'];
$name=ct124Create($manager,$database,$owned);$namespace=$database.'.'.$name;
$manager->addSubscriber($observer);$subscribed=true;
$cursor=$manager->executeQuery($namespace,new MongoDB\Driver\Query(['active'=>true,'stock'=>['$gt'=>0]],[
    'projection'=>['_id'=>1,'title'=>1],'sort'=>['_id'=>1],'limit'=>7,'batchSize'=>1,'maxTimeMS'=>2000]));
$cursor->setTypeMap(['root'=>'array','document'=>'array','array'=>'array']);$products=[];
foreach($cursor as $product){$products[]=$product;}
$pairs=ct124Pairs($observer);$batches=[];$total=0;$getMore=0;$operationIds=[];
foreach($pairs as [$start,$end]){
    $reply=$end->getReply();$batch=$reply->cursor->firstBatch??$reply->cursor->nextBatch??[];
    $size=count($batch);$total+=$size;$getMore+=(int)($start->getCommandName()==='getMore');
    $operationIds[]=$start->getOperationId();
    $batches[]=['command'=>$start->getCommandName(),'request_id'=>$start->getRequestId(),
        'documents'=>$size,'cursor_id'=>(string)$reply->cursor->id];
}
$observations['details']=['batches'=>$batches,'getmore_commands'=>$getMore,'total_received'=>$total];
$rows=[];foreach($products as $product){$rows[]=[$product['_id'],$product['title']];}
$checks=['five_rows_once'=>array_column($products,'_id')===[101,103,105,106,107],
    'real_getmore'=>$getMore>=1 && $pairs[0][0]->getCommandName()==='find',
    'batch_totals'=>$total===5 && max(array_column($batches,'documents'))<=1,
    'one_observed_operation'=>count(array_unique($operationIds))===1,
    'final_cursor_closed'=>$batches[count($batches)-1]['cursor_id']==='0'];
    $observations['events']=ct124Trace($observer);
    $checks['actual_pairs_and_types']=ct124TraceChecks($observations['events'],$settings);
}finally{
    if($subscribed){$manager->removeSubscriber($observer);}
    unset($cursor);
    foreach(array_reverse($owned) as $ownName){ct124Command($manager,$database,['drop'=>$ownName],true);}
}
$removed=true;foreach($owned as $ownName){if(ct124Exists($manager,$database,$ownName)){$removed=false;}}
$checks['owned_collections_removed']=$removed;
ct124Report('mongodb124-trace-getmore-batches', ['ID', 'Название'], $rows, $checks, $runtime, $observations);
echo 'mongodb124-trace-getmore-batches: saved result.html and result.json
';

mongodb124-trace-getmore-batches: saved result.html and result.json

Настоящие команды локального MongoDB и callbacks драйвера; HTML/JSON показывают данные и наблюдения. Helper, полная инструкция среды и проверка удаления своей коллекции включены.

<?php
declare(strict_types=1);
require __DIR__.'/ct124-helper.php';
$settings=ct124Settings(false);$database=$settings['database'];
$manager=new MongoDB\Driver\Manager($settings['uri'],['serverSelectionTimeoutMS'=>1500,'connectTimeoutMS'=>1000,'socketTimeoutMS'=>5000,'retryReads'=>false],['disableClientPersistence'=>true]);
$observer=new Ct124Observer;$owned=[];$subscribed=false;
$observations=['events'=>[],'details'=>[]];
try{
$version=ct124Command($manager,$database,['buildInfo'=>1])[0]['version'];
if(version_compare($version,'8.0','<')){throw new RuntimeException('MongoDB 8.0+ required');}
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>$version,'execution'=>'database'];
$name=ct124Create($manager,$database,$owned);$namespace=$database.'.'.$name;
$manager->addSubscriber($observer);$subscribed=true;
// Выделяем бизнес-команды; реальные getMore остаются в полной трассе.
function ct124TargetPairs(Ct124Observer $observer,string $name,array &$transport): array {
    $targets=[];$open=[];$transport=[];
    foreach(ct124Pairs($observer) as [$start,$end]){
        $kind=$start->getCommandName();$command=$start->getCommand();$reply=$end->getReply();
        if(in_array($kind,['find','aggregate'],true)){
            if(($command->$kind??null)!==$name || !isset($reply->cursor)
                || !is_array($reply->cursor->firstBatch??null)){
                throw new RuntimeException('Unexpected target namespace or firstBatch');
            }
            $targets[]=[$start,$end];$cursorId=(string)$reply->cursor->id;
            if($cursorId!=='0'){$open['cursor:'.$cursorId]=['command'=>$kind,'operation_id'=>$start->getOperationId()];}
            continue;
        }
        if($kind!=='getMore'){throw new RuntimeException('Unexpected extra command in this reading lesson');}
        $cursorId=(string)($command->getMore??'');$owner=$open['cursor:'.$cursorId]??null;
        if($owner===null || ($command->collection??null)!==$name
            || !isset($reply->cursor) || !is_array($reply->cursor->nextBatch??null)
            || $reply->cursor->nextBatch!==[] || (string)$reply->cursor->id!=='0'){
            throw new RuntimeException('Extra getMore must close its observed cursor with an empty nextBatch');
        }
        // У find общий operationId наблюдается; для aggregate драйвер может дать getMore="0".
        if($owner['command']==='find' && $owner['operation_id']!==$start->getOperationId()){
            throw new RuntimeException('Unexpected operation association for find continuation');
        }
        $transport[]=['command'=>'getMore','parent_command'=>$owner['command'],'request_id'=>$start->getRequestId(),
            'operation_id'=>$start->getOperationId(),'documents'=>0,'closed_cursor'=>true];
        unset($open['cursor:'.$cursorId]);
    }
    if($open!==[]){throw new RuntimeException('Reading lesson left an observed server cursor open');}
    return $targets;
}
$transport=[];


$before=hrtime(true);
$cursor=ct124Page($manager,$namespace);$products=$cursor->toArray();
$summary=ct124Summary($manager,$database,$name);
$applicationUs=intdiv(hrtime(true)-$before,1000);$budgetUs=10000;$measurements=[];
foreach(ct124TargetPairs($observer,$name,$transport) as [$start,$end]){
    $us=$end->getDurationMicros();
    $measurements[]=['command'=>$end->getCommandName(),'duration_us'=>$us,'duration_ms'=>$us/1000,
        'budget_us'=>$budgetUs,'over_budget'=>$us>$budgetUs];
}
$observations['details']=['command_measurements'=>$measurements,'application_interval_us'=>$applicationUs,
    'application_interval_scope'=>'запрос страницы, чтение строк и запрос сводки'];
$rows=[['Страница каталога',count($products),'измерение find в observations.json'],
    ['Складская сводка',count($summary),'измерение aggregate в observations.json'],
    ['Порог одной команды',$budgetUs,'микросекунды, отметка без отмены запроса']];
$checks=['two_actual_durations'=>count($measurements)===2 && min(array_column($measurements,'duration_us'))>=0,
    'units_and_budget'=>count(array_filter($measurements,fn($m)=>$m['duration_ms']===$m['duration_us']/1000 && $m['over_budget']===($m['duration_us']>$budgetUs)))===2,
    'application_interval_nonnegative'=>$applicationUs>=0,
    'screen_data'=>array_column($products,'_id')===[107,106] && $summary===[['products'=>5,'stock'=>21]]];

$observations['details']['transport_continuations']=$transport;
$observations['details']['all_command_pairs']=count($observer->succeeded);
    $observations['events']=ct124Trace($observer);
    $checks['actual_pairs_and_types']=ct124TraceChecks($observations['events'],$settings);
}finally{
    if($subscribed){$manager->removeSubscriber($observer);}
    unset($cursor);
    foreach(array_reverse($owned) as $ownName){ct124Command($manager,$database,['drop'=>$ownName],true);}
}
$removed=true;foreach($owned as $ownName){if(ct124Exists($manager,$database,$ownName)){$removed=false;}}
$checks['owned_collections_removed']=$removed;
ct124Report('mongodb124-trace-duration-budget', ['Часть экрана', 'Количество / порог', 'Как читать'], $rows, $checks, $runtime, $observations);
echo 'mongodb124-trace-duration-budget: saved result.html and result.json
';

mongodb124-trace-duration-budget: saved result.html and result.json

Настоящие команды локального MongoDB и callbacks драйвера; HTML/JSON показывают данные и наблюдения. Helper, полная инструкция среды и проверка удаления своей коллекции включены.

<?php
declare(strict_types=1);
require __DIR__.'/ct124-helper.php';
$settings=ct124Settings(false);$database=$settings['database'];
$manager=new MongoDB\Driver\Manager($settings['uri'],['serverSelectionTimeoutMS'=>1500,'connectTimeoutMS'=>1000,'socketTimeoutMS'=>5000,'retryReads'=>false],['disableClientPersistence'=>true]);
$observer=new Ct124Observer;$owned=[];$subscribed=false;
$observations=['events'=>[],'details'=>[]];
try{
$version=ct124Command($manager,$database,['buildInfo'=>1])[0]['version'];
if(version_compare($version,'8.0','<')){throw new RuntimeException('MongoDB 8.0+ required');}
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>$version,'execution'=>'database'];
$name=ct124Create($manager,$database,$owned);$namespace=$database.'.'.$name;
$manager->addSubscriber($observer);$subscribed=true;
// Выделяем бизнес-команды; реальные getMore остаются в полной трассе.
function ct124TargetPairs(Ct124Observer $observer,string $name,array &$transport): array {
    $targets=[];$open=[];$transport=[];
    foreach(ct124Pairs($observer) as [$start,$end]){
        $kind=$start->getCommandName();$command=$start->getCommand();$reply=$end->getReply();
        if(in_array($kind,['find','aggregate'],true)){
            if(($command->$kind??null)!==$name || !isset($reply->cursor)
                || !is_array($reply->cursor->firstBatch??null)){
                throw new RuntimeException('Unexpected target namespace or firstBatch');
            }
            $targets[]=[$start,$end];$cursorId=(string)$reply->cursor->id;
            if($cursorId!=='0'){$open['cursor:'.$cursorId]=['command'=>$kind,'operation_id'=>$start->getOperationId()];}
            continue;
        }
        if($kind!=='getMore'){throw new RuntimeException('Unexpected extra command in this reading lesson');}
        $cursorId=(string)($command->getMore??'');$owner=$open['cursor:'.$cursorId]??null;
        if($owner===null || ($command->collection??null)!==$name
            || !isset($reply->cursor) || !is_array($reply->cursor->nextBatch??null)
            || $reply->cursor->nextBatch!==[] || (string)$reply->cursor->id!=='0'){
            throw new RuntimeException('Extra getMore must close its observed cursor with an empty nextBatch');
        }
        // У find общий operationId наблюдается; для aggregate драйвер может дать getMore="0".
        if($owner['command']==='find' && $owner['operation_id']!==$start->getOperationId()){
            throw new RuntimeException('Unexpected operation association for find continuation');
        }
        $transport[]=['command'=>'getMore','parent_command'=>$owner['command'],'request_id'=>$start->getRequestId(),
            'operation_id'=>$start->getOperationId(),'documents'=>0,'closed_cursor'=>true];
        unset($open['cursor:'.$cursorId]);
    }
    if($open!==[]){throw new RuntimeException('Reading lesson left an observed server cursor open');}
    return $targets;
}
$transport=[];


$cursor=ct124Page($manager,$namespace);$products=$cursor->toArray();$summary=ct124Summary($manager,$database,$name);
$rows=[];$connections=[];$allMatch=true;$allServiceNull=true;
foreach(ct124TargetPairs($observer,$name,$transport) as [$start,$end]){
    $allMatch=$allMatch && $start->getHost()===$end->getHost() && $start->getPort()===$end->getPort()
        && $start->getDatabaseName()===$database && $end->getDatabaseName()===$database;
    $connections[]=$start->getServerConnectionId();$connections[]=$end->getServerConnectionId();
    $allServiceNull=$allServiceNull && $start->getServiceId()===null && $end->getServiceId()===null;
    $rows[]=[$end->getCommandName(),'адрес начала и ответа совпал','учебная база',
        $end->getServiceId()===null?'NULL: не load-balanced':'есть serviceId'];
}
$observations['details']=['actual_database'=>$database,'actual_endpoint'=>$settings['host'].':'.$settings['port'],
    'server_connection_ids'=>$connections,'page_ids'=>array_column($products,'_id'),'summary'=>$summary];
$checks=['same_endpoint_and_database'=>$allMatch && count($rows)===2,
    'standalone_service_ids_null'=>$allServiceNull,
    'connection_ids_from_hello'=>count(array_filter($connections,'is_int'))===4,
    'useful_results'=>count($products)===2 && $summary===[['products'=>5,'stock'=>21]]];

$observations['details']['transport_continuations']=$transport;
$observations['details']['all_command_pairs']=count($observer->succeeded);
    $observations['events']=ct124Trace($observer);
    $checks['actual_pairs_and_types']=ct124TraceChecks($observations['events'],$settings);
}finally{
    if($subscribed){$manager->removeSubscriber($observer);}
    unset($cursor);
    foreach(array_reverse($owned) as $ownName){ct124Command($manager,$database,['drop'=>$ownName],true);}
}
$removed=true;foreach($owned as $ownName){if(ct124Exists($manager,$database,$ownName)){$removed=false;}}
$checks['owned_collections_removed']=$removed;
ct124Report('mongodb124-trace-endpoint-context', ['Команда', 'Связь адресов', 'Контекст', 'serviceId'], $rows, $checks, $runtime, $observations);
echo 'mongodb124-trace-endpoint-context: saved result.html and result.json
';

mongodb124-trace-endpoint-context: saved result.html and result.json

Настоящие команды локального MongoDB и callbacks драйвера; HTML/JSON показывают данные и наблюдения. Helper, полная инструкция среды и проверка удаления своей коллекции включены.

<?php
declare(strict_types=1);
require __DIR__.'/ct124-helper.php';
$settings=ct124Settings(false);$database=$settings['database'];
$manager=new MongoDB\Driver\Manager($settings['uri'],['serverSelectionTimeoutMS'=>1500,'connectTimeoutMS'=>1000,'socketTimeoutMS'=>5000,'retryReads'=>false],['disableClientPersistence'=>true]);
$observer=new Ct124Observer;$owned=[];$subscribed=false;
$observations=['events'=>[],'details'=>[]];
try{
$version=ct124Command($manager,$database,['buildInfo'=>1])[0]['version'];
if(version_compare($version,'8.0','<')){throw new RuntimeException('MongoDB 8.0+ required');}
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>$version,'execution'=>'database'];
$name=ct124Create($manager,$database,$owned);$namespace=$database.'.'.$name;
$manager->addSubscriber($observer);$subscribed=true;
// Выделяем бизнес-команды; реальные getMore остаются в полной трассе.
function ct124TargetPairs(Ct124Observer $observer,string $name,array &$transport): array {
    $targets=[];$open=[];$transport=[];
    foreach(ct124Pairs($observer) as [$start,$end]){
        $kind=$start->getCommandName();$command=$start->getCommand();$reply=$end->getReply();
        if(in_array($kind,['find','aggregate'],true)){
            if(($command->$kind??null)!==$name || !isset($reply->cursor)
                || !is_array($reply->cursor->firstBatch??null)){
                throw new RuntimeException('Unexpected target namespace or firstBatch');
            }
            $targets[]=[$start,$end];$cursorId=(string)$reply->cursor->id;
            if($cursorId!=='0'){$open['cursor:'.$cursorId]=['command'=>$kind,'operation_id'=>$start->getOperationId()];}
            continue;
        }
        if($kind!=='getMore'){throw new RuntimeException('Unexpected extra command in this reading lesson');}
        $cursorId=(string)($command->getMore??'');$owner=$open['cursor:'.$cursorId]??null;
        if($owner===null || ($command->collection??null)!==$name
            || !isset($reply->cursor) || !is_array($reply->cursor->nextBatch??null)
            || $reply->cursor->nextBatch!==[] || (string)$reply->cursor->id!=='0'){
            throw new RuntimeException('Extra getMore must close its observed cursor with an empty nextBatch');
        }
        // У find общий operationId наблюдается; для aggregate драйвер может дать getMore="0".
        if($owner['command']==='find' && $owner['operation_id']!==$start->getOperationId()){
            throw new RuntimeException('Unexpected operation association for find continuation');
        }
        $transport[]=['command'=>'getMore','parent_command'=>$owner['command'],'request_id'=>$start->getRequestId(),
            'operation_id'=>$start->getOperationId(),'documents'=>0,'closed_cursor'=>true];
        unset($open['cursor:'.$cursorId]);
    }
    if($open!==[]){throw new RuntimeException('Reading lesson left an observed server cursor open');}
    return $targets;
}
$transport=[];


$cursor=ct124Page($manager,$namespace,['contact'=>'buyer@example.invalid']);$products=$cursor->toArray();
$pairs=ct124TargetPairs($observer,$name,$transport);[$start,$end]=$pairs[0];
$allTrace=ct124Trace($observer);$trace=[];
foreach($pairs as [$targetStart,$targetEnd]){
    $trace[]=ct124Metadata($targetStart,'started');$trace[]=ct124Metadata($targetEnd,'succeeded');
}
$encoded=json_encode($allTrace,JSON_THROW_ON_ERROR);
$containsPrivate=str_contains($encoded,'buyer@example.invalid') || str_contains($encoded,'DEMO_PRIVATE_NOTE_124');
$allowed=['phase','command','database','request_id','operation_id','host','port','server_connection_id','service_id','duration_us'];
$unknown=[];foreach($allTrace as $row){$unknown=array_merge($unknown,array_diff(array_keys($row),$allowed));}
$observations['details']=['saved_event_count'=>count($trace),'allowed_field_names'=>$allowed,
    'private_filter_was_present'=>isset($start->getCommand()->filter->contact),
    'private_values_saved'=>$containsPrivate,'page_ids'=>array_column($products,'_id')];
$rows=[['Страница каталога',count($products),'нужные поля товара'],
    ['Начало и ответ',count($trace),'только разрешённые метаданные'],
    ['Контакт и служебная заметка',0,'в публичном журнале отсутствуют']];
$checks=['filter_really_has_contact'=>$start->getCommand()->filter->contact==='buyer@example.invalid',
    'allowlist_only'=>$unknown===[] && count($trace)===2,
    'private_literals_excluded'=>!$containsPrivate,
    'projection_without_contact'=>!isset($products[0]['contact']) && !isset($products[0]['private_note']) && array_column($products,'_id')===[107,106]];

$observations['details']['transport_continuations']=$transport;
$observations['details']['all_command_pairs']=count($observer->succeeded);
    $observations['events']=ct124Trace($observer);
    $checks['actual_pairs_and_types']=ct124TraceChecks($observations['events'],$settings);
}finally{
    if($subscribed){$manager->removeSubscriber($observer);}
    unset($cursor);
    foreach(array_reverse($owned) as $ownName){ct124Command($manager,$database,['drop'=>$ownName],true);}
}
$removed=true;foreach($owned as $ownName){if(ct124Exists($manager,$database,$ownName)){$removed=false;}}
$checks['owned_collections_removed']=$removed;
ct124Report('mongodb124-trace-safe-log', ['Что сохраняем', 'Количество', 'Правило'], $rows, $checks, $runtime, $observations);
echo 'mongodb124-trace-safe-log: saved result.html and result.json
';

mongodb124-trace-safe-log: saved result.html and result.json

Настоящие команды локального MongoDB и callbacks драйвера; HTML/JSON показывают данные и наблюдения. Helper, полная инструкция среды и проверка удаления своей коллекции включены.

<?php
declare(strict_types=1);
require __DIR__.'/ct124-helper.php';
$settings=ct124Settings(false);$database=$settings['database'];
$manager=new MongoDB\Driver\Manager($settings['uri'],['serverSelectionTimeoutMS'=>1500,'connectTimeoutMS'=>1000,'socketTimeoutMS'=>5000,'retryReads'=>false],['disableClientPersistence'=>true]);
$observer=new Ct124Observer;$owned=[];$subscribed=false;
$observations=['events'=>[],'details'=>[]];
try{
$version=ct124Command($manager,$database,['buildInfo'=>1])[0]['version'];
if(version_compare($version,'8.0','<')){throw new RuntimeException('MongoDB 8.0+ required');}
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>$version,'execution'=>'database'];
$name=ct124Create($manager,$database,$owned);$namespace=$database.'.'.$name;
$manager->addSubscriber($observer);$subscribed=true;
// Выделяем бизнес-команды; реальные getMore остаются в полной трассе.
function ct124TargetPairs(Ct124Observer $observer,string $name,array &$transport): array {
    $targets=[];$open=[];$transport=[];
    foreach(ct124Pairs($observer) as [$start,$end]){
        $kind=$start->getCommandName();$command=$start->getCommand();$reply=$end->getReply();
        if(in_array($kind,['find','aggregate'],true)){
            if(($command->$kind??null)!==$name || !isset($reply->cursor)
                || !is_array($reply->cursor->firstBatch??null)){
                throw new RuntimeException('Unexpected target namespace or firstBatch');
            }
            $targets[]=[$start,$end];$cursorId=(string)$reply->cursor->id;
            if($cursorId!=='0'){$open['cursor:'.$cursorId]=['command'=>$kind,'operation_id'=>$start->getOperationId()];}
            continue;
        }
        if($kind!=='getMore'){throw new RuntimeException('Unexpected extra command in this reading lesson');}
        $cursorId=(string)($command->getMore??'');$owner=$open['cursor:'.$cursorId]??null;
        if($owner===null || ($command->collection??null)!==$name
            || !isset($reply->cursor) || !is_array($reply->cursor->nextBatch??null)
            || $reply->cursor->nextBatch!==[] || (string)$reply->cursor->id!=='0'){
            throw new RuntimeException('Extra getMore must close its observed cursor with an empty nextBatch');
        }
        // У find общий operationId наблюдается; для aggregate драйвер может дать getMore="0".
        if($owner['command']==='find' && $owner['operation_id']!==$start->getOperationId()){
            throw new RuntimeException('Unexpected operation association for find continuation');
        }
        $transport[]=['command'=>'getMore','parent_command'=>$owner['command'],'request_id'=>$start->getRequestId(),
            'operation_id'=>$start->getOperationId(),'documents'=>0,'closed_cursor'=>true];
        unset($open['cursor:'.$cursorId]);
    }
    if($open!==[]){throw new RuntimeException('Reading lesson left an observed server cursor open');}
    return $targets;
}
$transport=[];


$cursor=ct124Page($manager,$namespace);$products=$cursor->toArray();$summary=ct124Summary($manager,$database,$name);
$matches=true;$blocked=0;$checksCount=0;$propertyCounts=[];
foreach(ct124TargetPairs($observer,$name,$transport) as [$start,$end]){
    foreach([[$start,['host'=>'getHost','port'=>'getPort','commandName'=>'getCommandName','databaseName'=>'getDatabaseName',
        'operationId'=>'getOperationId','requestId'=>'getRequestId','serverConnectionId'=>'getServerConnectionId','serviceId'=>'getServiceId','command'=>'getCommand']],
        [$end,['host'=>'getHost','port'=>'getPort','commandName'=>'getCommandName','databaseName'=>'getDatabaseName',
        'operationId'=>'getOperationId','requestId'=>'getRequestId','serverConnectionId'=>'getServerConnectionId','serviceId'=>'getServiceId','duration'=>'getDurationMicros','reply'=>'getReply']]] as [$event,$map]){
        foreach($map as $property=>$method){$matches=$matches && $event->$property==$event->$method();$checksCount++;}
        try{$event->host='other.example.invalid';throw new RuntimeException('Readonly mutation unexpectedly succeeded');}
        catch(Error $error){if(!str_contains($error->getMessage(),'readonly')){throw $error;}$blocked++;}
    }
    $propertyCounts[]=[$start->getCommandName(),9,10];
}
$observations['details']=['property_counts'=>$propertyCounts,'getter_property_comparisons'=>$checksCount,
    'readonly_mutations_rejected'=>$blocked,'page_ids'=>array_column($products,'_id'),'summary'=>$summary];
$rows=[['CommandStartedEvent',9,'доступ только для чтения'],['CommandSucceededEvent',10,'duration соответствует getDurationMicros()'],['Заблокированные изменения host',$blocked,'снимок остался неизменным']];
$checks=['all_properties_equal_getters'=>$matches && $checksCount===38,
    'four_readonly_errors'=>$blocked===4,
    'real_two_commands'=>count($propertyCounts)===2 && array_column($products,'_id')===[107,106]];

$observations['details']['transport_continuations']=$transport;
$observations['details']['all_command_pairs']=count($observer->succeeded);
    $observations['events']=ct124Trace($observer);
    $checks['actual_pairs_and_types']=ct124TraceChecks($observations['events'],$settings);
}finally{
    if($subscribed){$manager->removeSubscriber($observer);}
    unset($cursor);
    foreach(array_reverse($owned) as $ownName){ct124Command($manager,$database,['drop'=>$ownName],true);}
}
$removed=true;foreach($owned as $ownName){if(ct124Exists($manager,$database,$ownName)){$removed=false;}}
$checks['owned_collections_removed']=$removed;
ct124Report('mongodb124-trace-readonly-properties', ['Объект / действие', 'Число', 'Результат'], $rows, $checks, $runtime, $observations);
echo 'mongodb124-trace-readonly-properties: saved result.html and result.json
';

mongodb124-trace-readonly-properties: saved result.html and result.json

Настоящие команды локального MongoDB и callbacks драйвера; HTML/JSON показывают данные и наблюдения. Helper, полная инструкция среды и проверка удаления своей коллекции включены.

<?php
declare(strict_types=1);
require __DIR__.'/ct124-helper.php';
$settings=ct124Settings(false);$database=$settings['database'];
$manager=new MongoDB\Driver\Manager($settings['uri'],['serverSelectionTimeoutMS'=>1500,'connectTimeoutMS'=>1000,'socketTimeoutMS'=>5000,'retryReads'=>false],['disableClientPersistence'=>true]);
$observer=new Ct124Observer;$owned=[];$subscribed=false;
$observations=['events'=>[],'details'=>[]];
try{
$version=ct124Command($manager,$database,['buildInfo'=>1])[0]['version'];
if(version_compare($version,'8.0','<')){throw new RuntimeException('MongoDB 8.0+ required');}
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>$version,'execution'=>'database'];
$name=ct124Create($manager,$database,$owned);$namespace=$database.'.'.$name;
$manager->addSubscriber($observer);$subscribed=true;
// Выделяем бизнес-команды; реальные getMore остаются в полной трассе.
function ct124TargetPairs(Ct124Observer $observer,string $name,array &$transport): array {
    $targets=[];$open=[];$transport=[];
    foreach(ct124Pairs($observer) as [$start,$end]){
        $kind=$start->getCommandName();$command=$start->getCommand();$reply=$end->getReply();
        if(in_array($kind,['find','aggregate'],true)){
            if(($command->$kind??null)!==$name || !isset($reply->cursor)
                || !is_array($reply->cursor->firstBatch??null)){
                throw new RuntimeException('Unexpected target namespace or firstBatch');
            }
            $targets[]=[$start,$end];$cursorId=(string)$reply->cursor->id;
            if($cursorId!=='0'){$open['cursor:'.$cursorId]=['command'=>$kind,'operation_id'=>$start->getOperationId()];}
            continue;
        }
        if($kind!=='getMore'){throw new RuntimeException('Unexpected extra command in this reading lesson');}
        $cursorId=(string)($command->getMore??'');$owner=$open['cursor:'.$cursorId]??null;
        if($owner===null || ($command->collection??null)!==$name
            || !isset($reply->cursor) || !is_array($reply->cursor->nextBatch??null)
            || $reply->cursor->nextBatch!==[] || (string)$reply->cursor->id!=='0'){
            throw new RuntimeException('Extra getMore must close its observed cursor with an empty nextBatch');
        }
        // У find общий operationId наблюдается; для aggregate драйвер может дать getMore="0".
        if($owner['command']==='find' && $owner['operation_id']!==$start->getOperationId()){
            throw new RuntimeException('Unexpected operation association for find continuation');
        }
        $transport[]=['command'=>'getMore','parent_command'=>$owner['command'],'request_id'=>$start->getRequestId(),
            'operation_id'=>$start->getOperationId(),'documents'=>0,'closed_cursor'=>true];
        unset($open['cursor:'.$cursorId]);
    }
    if($open!==[]){throw new RuntimeException('Reading lesson left an observed server cursor open');}
    return $targets;
}
$transport=[];


$cursor=ct124Page($manager,$namespace);$products=$cursor->toArray();$summary=ct124Summary($manager,$database,$name);
$rows=[];$batches=[];$valid=true;$std=true;
foreach(ct124TargetPairs($observer,$name,$transport) as [$start,$end]){
    $reply=$end->getReply();$std=$std && $reply instanceof stdClass;
    $batch=$reply->cursor->firstBatch??null;
    if(!is_array($batch)){throw new RuntimeException('Expected firstBatch');}
    $row=['command'=>$end->getCommandName(),'ok'=>(int)$reply->ok,'documents'=>count($batch),'cursor_id'=>(string)$reply->cursor->id];
    $batches[]=$row;
    if($end->getCommandName()==='find'){
        $valid=$valid && array_map(fn($d)=>$d->_id,$batch)===[107,106];
        $rows[]=['find',count($batch),'Кабель; Чехол'];
    }else{
        $valid=$valid && count($batch)===1 && $batch[0]->products===5 && $batch[0]->stock===21;
        $rows[]=['aggregate',count($batch),'5 товаров; остаток 21'];
    }
}
$observations['details']=['reply_summaries'=>$batches,'raw_reply_exported'=>false,'page_ids'=>array_column($products,'_id'),'summary'=>$summary];
$checks=['reply_stdclass_despite_cursor_array_map'=>$std && is_array($products[0]),
    'actual_batches_match_screen'=>$valid && count($rows)===2,
    'successful_read_replies'=>array_column($batches,'ok')===[1,1],
    'bounded_reply_documents'=>array_column($batches,'documents')===[2,1]];

$observations['details']['transport_continuations']=$transport;
$observations['details']['all_command_pairs']=count($observer->succeeded);
    $observations['events']=ct124Trace($observer);
    $checks['actual_pairs_and_types']=ct124TraceChecks($observations['events'],$settings);
}finally{
    if($subscribed){$manager->removeSubscriber($observer);}
    unset($cursor);
    foreach(array_reverse($owned) as $ownName){ct124Command($manager,$database,['drop'=>$ownName],true);}
}
$removed=true;foreach($owned as $ownName){if(ct124Exists($manager,$database,$ownName)){$removed=false;}}
$checks['owned_collections_removed']=$removed;
ct124Report('mongodb124-trace-reply-summary', ['Команда', 'Документов firstBatch', 'Что показывает экран'], $rows, $checks, $runtime, $observations);
echo 'mongodb124-trace-reply-summary: saved result.html and result.json
';

mongodb124-trace-reply-summary: saved result.html and result.json

Настоящие команды локального MongoDB и callbacks драйвера; HTML/JSON показывают данные и наблюдения. Helper, полная инструкция среды и проверка удаления своей коллекции включены.

<?php
declare(strict_types=1);
require __DIR__.'/ct124-helper.php';
$settings=ct124Settings(true);$database=$settings['database'];
$manager=new MongoDB\Driver\Manager($settings['uri'],['serverSelectionTimeoutMS'=>1500,'connectTimeoutMS'=>1000,'socketTimeoutMS'=>5000,'retryReads'=>false],['disableClientPersistence'=>true]);
$observer=new Ct124Observer;$owned=[];$subscribed=false;
$observations=['events'=>[],'details'=>[]];
try{
$version=ct124Command($manager,$database,['buildInfo'=>1])[0]['version'];
if(version_compare($version,'8.0','<')){throw new RuntimeException('MongoDB 8.0+ required');}
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>$version,'execution'=>'database'];
$name=ct124Create($manager,$database,$owned);$namespace=$database.'.'.$name;
$manager->addSubscriber($observer);$subscribed=true;
// Выделяем бизнес-команды; реальные getMore остаются в полной трассе.
function ct124TargetPairs(Ct124Observer $observer,string $name,array &$transport): array {
    $targets=[];$open=[];$transport=[];
    foreach(ct124Pairs($observer) as [$start,$end]){
        $kind=$start->getCommandName();$command=$start->getCommand();$reply=$end->getReply();
        if(in_array($kind,['find','aggregate'],true)){
            if(($command->$kind??null)!==$name || !isset($reply->cursor)
                || !is_array($reply->cursor->firstBatch??null)){
                throw new RuntimeException('Unexpected target namespace or firstBatch');
            }
            $targets[]=[$start,$end];$cursorId=(string)$reply->cursor->id;
            if($cursorId!=='0'){$open['cursor:'.$cursorId]=['command'=>$kind,'operation_id'=>$start->getOperationId()];}
            continue;
        }
        if($kind!=='getMore'){throw new RuntimeException('Unexpected extra command in this reading lesson');}
        $cursorId=(string)($command->getMore??'');$owner=$open['cursor:'.$cursorId]??null;
        if($owner===null || ($command->collection??null)!==$name
            || !isset($reply->cursor) || !is_array($reply->cursor->nextBatch??null)
            || $reply->cursor->nextBatch!==[] || (string)$reply->cursor->id!=='0'){
            throw new RuntimeException('Extra getMore must close its observed cursor with an empty nextBatch');
        }
        // У find общий operationId наблюдается; для aggregate драйвер может дать getMore="0".
        if($owner['command']==='find' && $owner['operation_id']!==$start->getOperationId()){
            throw new RuntimeException('Unexpected operation association for find continuation');
        }
        $transport[]=['command'=>'getMore','parent_command'=>$owner['command'],'request_id'=>$start->getRequestId(),
            'operation_id'=>$start->getOperationId(),'documents'=>0,'closed_cursor'=>true];
        unset($open['cursor:'.$cursorId]);
    }
    if($open!==[]){throw new RuntimeException('Reading lesson left an observed server cursor open');}
    return $targets;
}
$transport=[];


$cursor=ct124Page($manager,$namespace);$products=$cursor->toArray();$summary=ct124Summary($manager,$database,$name);
$pairs=ct124TargetPairs($observer,$name,$transport);
if(count($pairs)!==2 || array_map(fn($pair)=>$pair[0]->getCommandName(),$pairs)!==['find','aggregate']){
    throw new RuntimeException('Legacy demonstration requires exactly the two target commands');
}
$allowedMessages=[
    'Method MongoDB\\Driver\\Monitoring\\CommandStartedEvent::getServer() is deprecated',
    'Method MongoDB\\Driver\\Monitoring\\CommandSucceededEvent::getServer() is deprecated'];
$warnings=[];$addresses=[];$same=true;
set_error_handler(function(int $severity,string $message)use(&$warnings,$allowedMessages):bool{
    if($severity===E_DEPRECATED && in_array($message,$allowedMessages,true)){$warnings[]=$message;return true;}
    return false;
});
try{
    foreach($pairs as [$start,$end]){
        foreach([[$start,'started'],[$end,'succeeded']] as [$event,$phase]){
            $server=$event->getServer();
            $old=$server->getHost().':'.$server->getPort();$new=$event->getHost().':'.$event->getPort();
            $same=$same && $old===$new;
            $addresses[]=['command'=>$event->getCommandName(),'phase'=>$phase,'old_endpoint'=>$old,'modern_endpoint'=>$new];
        }
    }
}finally{restore_error_handler();}
$counts=array_count_values($warnings);
$observations['details']=['migration_addresses'=>$addresses,'deprecations'=>$warnings,'page_ids'=>array_column($products,'_id'),'summary'=>$summary];
$rows=[['find','started + succeeded','адрес сохранён',2],['aggregate','started + succeeded','адрес сохранён',2]];
$checks=['two_real_read_results'=>array_column($products,'_id')===[107,106] && $summary===[['products'=>5,'stock'=>21]],
    'old_modern_endpoint_equal'=>$same && count($addresses)===4,
    'exact_expected_deprecations'=>count($warnings)===4 && ($counts[$allowedMessages[0]]??0)===2 && ($counts[$allowedMessages[1]]??0)===2];

$observations['details']['transport_continuations']=$transport;
$observations['details']['all_command_pairs']=count($observer->succeeded);
    $observations['events']=ct124Trace($observer);
    $checks['actual_pairs_and_types']=ct124TraceChecks($observations['events'],$settings);
}finally{
    if($subscribed){$manager->removeSubscriber($observer);}
    unset($cursor);
    foreach(array_reverse($owned) as $ownName){ct124Command($manager,$database,['drop'=>$ownName],true);}
}
$removed=true;foreach($owned as $ownName){if(ct124Exists($manager,$database,$ownName)){$removed=false;}}
$checks['owned_collections_removed']=$removed;
ct124Report('mongodb124-trace-server-legacy', ['Команда', 'События', 'Миграция', 'Ожидаемых E_DEPRECATED'], $rows, $checks, $runtime, $observations);
echo 'mongodb124-trace-server-legacy: saved result.html and result.json
';

mongodb124-trace-server-legacy: saved result.html and result.json

Настоящие команды локального MongoDB и callbacks драйвера; HTML/JSON показывают данные и наблюдения. Helper, полная инструкция среды и проверка удаления своей коллекции включены.