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

<?php
declare(strict_types=1);
use MongoDB\Driver\Manager;
use MongoDB\Driver\Exception\{BulkWriteException,CommandException};
require __DIR__.'/ev135-helper.php';

[$rows,$checks,$runtime,$counts,$board] = ev135Lab(static function(Manager $manager,string $db,string $ns): array {
    $seed=ev135Put($manager,$ns,[['_id'=>'R-1','state'=>'принят']]);
    $trace=new Ev135Trace($db,['ping']);
    $reply=ev135Observe($manager,$trace,fn()=>ev135Command($manager,$db,['ping'=>1]));
    $record=$trace->single();
    $order=ev135Order($manager,$ns,'R-1');
    $rows=[['Команда',$record['command']],['Ответ сервера',(int)$reply[0]['ok']],['Событие',$record['terminal']],['Незавершённых пар',$trace->pendingCount()]];
    $checks=['one_fixture'=>$seed===1,'server_ok'=>$reply[0]['ok']==1,'one_start'=>$trace->started===1,
        'same_request'=>$record['linked'],'succeeded'=>$record['terminal']==='succeeded','duration_observed'=>$record['micros']>=0,
        'order_unchanged'=>$order['state']==='принят'];
    return [$rows,$checks,[]];
});
ev135Report('mongodb135-events-first-pair', 'Узнать, ответил ли сервер на ping', ['Что проверили', 'Результат'], $rows,$checks,$runtime,$counts,$board);
foreach ($rows as [$label,$value]) {echo $label, ' — ', $value, PHP_EOL;}

Команда — ping
Ответ сервера — 1
Событие — succeeded
Незавершённых пар — 0

Самостоятельный запуск PHP с реальной MongoDB. После чтения итогового состояния программа удаляет собственную коллекцию.

<?php
declare(strict_types=1);
use MongoDB\Driver\Manager;
use MongoDB\Driver\Exception\{BulkWriteException,CommandException};
require __DIR__.'/ev135-helper.php';

[$rows,$checks,$runtime,$counts,$board] = ev135Lab(static function(Manager $manager,string $db,string $ns): array {
    $trace=new Ev135Trace($db,['insert']);
    $inserted=ev135Observe($manager,$trace,fn()=>ev135Put($manager,$ns,[['_id'=>'R-17','state'=>'принят','quantity'=>2]]));
    $record=$trace->single();
    $order=ev135Order($manager,$ns,'R-17');
    $rows=[['Команда',$record['command']],['Результат команды',$record['terminal']],['Создано заказов',$inserted],['Статус в базе',$order['state']],['Количество',$order['quantity']]];
    $checks=['insert_command'=>$record['command']==='insert','complete_pair'=>$record['linked'],'succeeded'=>$record['terminal']==='succeeded',
        'no_item_errors'=>$record['writeErrors']===0,'one_insert'=>$inserted===1,'stored_id'=>$order['_id']==='R-17','stored_quantity'=>$order['quantity']===2];
    return [$rows,$checks,[]];
});
ev135Report('mongodb135-events-accepted-order', 'Подтвердить первую запись заказа отдельно от сетевого события', ['Что проверили', 'Результат'], $rows,$checks,$runtime,$counts,$board);
foreach ($rows as [$label,$value]) {echo $label, ' — ', $value, PHP_EOL;}

Команда — insert
Результат команды — succeeded
Создано заказов — 1
Статус в базе — принят
Количество — 2

Самостоятельный запуск PHP с реальной MongoDB. После чтения итогового состояния программа удаляет собственную коллекцию.

<?php
declare(strict_types=1);
use MongoDB\Driver\Manager;
use MongoDB\Driver\Exception\{BulkWriteException,CommandException};
require __DIR__.'/ev135-helper.php';

[$rows,$checks,$runtime,$counts,$board] = ev135Lab(static function(Manager $manager,string $db,string $ns): array {
    $original=ev135Put($manager,$ns,[['_id'=>'R-17','quantity'=>2,'state'=>'принят']]);
    $trace=new Ev135Trace($db,['insert']);
    $itemCode=0;
    try {
        ev135Observe($manager,$trace,fn()=>ev135Put($manager,$ns,[['_id'=>'R-17','quantity'=>9,'state'=>'повтор']]));
    } catch (BulkWriteException $error) {
        $itemCode=$error->getWriteResult()->getWriteErrors()[0]->getCode();
    }
    $record=$trace->single();
    $order=ev135Order($manager,$ns,'R-17');
    $rows=[['Завершение insert',$record['terminal']],['Ошибок элементов',$record['writeErrors']],['Код ошибки',$itemCode],['Остался статус',$order['state']],['Осталось единиц',$order['quantity']]];
    $checks=['original_created'=>$original===1,'server_received_insert'=>$record['command']==='insert',
        'command_succeeded'=>$record['terminal']==='succeeded','one_write_error'=>$record['writeErrors']===1,
        'duplicate_item'=>$itemCode===11000 && $record['code']===$itemCode,'same_state'=>$order['state']==='принят','same_quantity'=>$order['quantity']===2];
    return [$rows,$checks,[]];
});
ev135Report('mongodb135-events-duplicate-reply', 'Найти отказ повторной записи в успешном ответе insert', ['Что проверили', 'Результат'], $rows,$checks,$runtime,$counts,$board);
foreach ($rows as [$label,$value]) {echo $label, ' — ', $value, PHP_EOL;}

Завершение insert — succeeded
Ошибок элементов — 1
Код ошибки — 11000
Остался статус — принят
Осталось единиц — 2

Самостоятельный запуск PHP с реальной MongoDB. После чтения итогового состояния программа удаляет собственную коллекцию.

<?php
declare(strict_types=1);
use MongoDB\Driver\Manager;
use MongoDB\Driver\Exception\{BulkWriteException,CommandException};
require __DIR__.'/ev135-helper.php';

[$rows,$checks,$runtime,$counts,$board] = ev135Lab(static function(Manager $manager,string $db,string $ns): array {
    $seed=ev135Put($manager,$ns,[['_id'=>'R-61','state'=>'готов']]);
    $name='phpmanMissingCommand';
    $trace=new Ev135Trace($db,[$name]);
    $exceptionCode=0;
    try {
        ev135Observe($manager,$trace,fn()=>ev135Command($manager,$db,[$name=>1]));
    } catch (CommandException $error) {$exceptionCode=$error->getCode();}
    $record=$trace->single();
    $order=ev135Order($manager,$ns,'R-61');
    $rows=[['Отправлено',$record['command']],['Событие',$record['terminal']],['Код в commandFailed',$record['code']],['Код у вызывающего кода',$exceptionCode],['R-61 после отказа',$order['state']]];
    $checks=['seed'=>$seed===1,'named_command'=>$record['command']===$name,'failed'=>$record['terminal']==='failed',
        'same_request'=>$record['linked'],'observed_code'=>$record['code']===59,'matching_exception'=>$exceptionCode===$record['code'],
        'slot_released'=>$trace->pendingCount()===0,'data_intact'=>$order['state']==='готов'];
    return [$rows,$checks,[]];
});
ev135Report('mongodb135-events-server-failed', 'Различить неизвестную команду и ошибку элемента записи', ['Что проверили', 'Результат'], $rows,$checks,$runtime,$counts,$board);
foreach ($rows as [$label,$value]) {echo $label, ' — ', $value, PHP_EOL;}

Отправлено — phpmanMissingCommand
Событие — failed
Код в commandFailed — 59
Код у вызывающего кода — 59
R-61 после отказа — готов

Самостоятельный запуск PHP с реальной MongoDB. После чтения итогового состояния программа удаляет собственную коллекцию.

<?php
declare(strict_types=1);
use MongoDB\Driver\Manager;
use MongoDB\Driver\Exception\{BulkWriteException,CommandException};
require __DIR__.'/ev135-helper.php';

[$rows,$checks,$runtime,$counts,$board] = ev135Lab(static function(Manager $manager,string $db,string $ns): array {
    $seed=ev135Put($manager,$ns,[['_id'=>'R-8','state'=>'отправлен']]);
    $trace=new Ev135Trace($db,['update']);
    $result=ev135Observe($manager,$trace,fn()=>ev135Update($manager,$ns,['_id'=>'R-8','state'=>'новый'],['state'=>'отменён']));
    $record=$trace->single();
    $order=ev135Order($manager,$ns,'R-8');
    $matched=$result->getMatchedCount();
    $modified=$result->getModifiedCount();
    $rows=[['Завершение update',$record['terminal']],['Подошло заказов',$matched],['Изменено заказов',$modified],['Текущий статус',$order['state']]];
    $checks=['seed'=>$seed===1,'command_name'=>$record['command']==='update','command_succeeded'=>$record['terminal']==='succeeded',
        'no_write_error'=>$record['writeErrors']===0,'stale_filter'=>$matched===0,'no_change'=>$modified===0,'current_status'=>$order['state']==='отправлен'];
    return [$rows,$checks,[]];
});
ev135Report('mongodb135-events-no-match', 'Понять, почему успешный update оставил статус прежним', ['Что проверили', 'Результат'], $rows,$checks,$runtime,$counts,$board);
foreach ($rows as [$label,$value]) {echo $label, ' — ', $value, PHP_EOL;}

Завершение update — succeeded
Подошло заказов — 0
Изменено заказов — 0
Текущий статус — отправлен

Самостоятельный запуск PHP с реальной MongoDB. После чтения итогового состояния программа удаляет собственную коллекцию.

<?php
declare(strict_types=1);
use MongoDB\Driver\Manager;
use MongoDB\Driver\Exception\{BulkWriteException,CommandException};
require __DIR__.'/ev135-helper.php';

[$rows,$checks,$runtime,$counts,$board] = ev135Lab(static function(Manager $manager,string $db,string $ns): array {
    $seed=ev135Put($manager,$ns,[['_id'=>'R-4','state'=>'новый','quantity'=>2]]);
    $saveQuantity=static function(mixed $raw) use ($manager,$ns): ?int {
        if (!is_int($raw) || $raw < 1 || $raw > 20) {return null;}
        return ev135Update($manager,$ns,['_id'=>'R-4'],['quantity'=>$raw])->getModifiedCount();
    };
    $first=new Ev135Trace($db,['update']);
    $bad=ev135Observe($manager,$first,fn()=>$saveQuantity(-3));
    $before=ev135Order($manager,$ns,'R-4');
    $second=new Ev135Trace($db,['update']);
    $good=ev135Observe($manager,$second,fn()=>$saveQuantity(3));
    $record=$second->single();
    $after=ev135Order($manager,$ns,'R-4');
    $rows=[['Команд для −3',$first->started],['Количество после отказа',$before['quantity']],['Команд для 3',$second->started],['Изменено заказов',$good],['Количество после записи',$after['quantity']]];
    $checks=['seed'=>$seed===1,'rejected_input'=>$bad===null,'no_command'=>$first->started===0 && $first->records===[],
        'unchanged'=>$before['quantity']===2,'valid_command'=>$record['command']==='update' && $record['terminal']==='succeeded',
        'changed_one'=>$good===1,'quantity_now'=>$after['quantity']===3];
    return [$rows,$checks,[]];
});
ev135Report('mongodb135-events-local-validation', 'Увидеть, дошло ли количество из формы до базы', ['Что проверили', 'Результат'], $rows,$checks,$runtime,$counts,$board);
foreach ($rows as [$label,$value]) {echo $label, ' — ', $value, PHP_EOL;}

Команд для −3 — 0
Количество после отказа — 2
Команд для 3 — 1
Изменено заказов — 1
Количество после записи — 3

Самостоятельный запуск PHP с реальной MongoDB. После чтения итогового состояния программа удаляет собственную коллекцию.

<?php
declare(strict_types=1);
use MongoDB\Driver\Manager;
use MongoDB\Driver\Exception\{BulkWriteException,CommandException};
require __DIR__.'/ev135-helper.php';

[$rows,$checks,$runtime,$counts,$board] = ev135Lab(static function(Manager $manager,string $db,string $ns): array {
    $seed=ev135Put($manager,$ns,[['_id'=>'L-1','state'=>'готов'],['_id'=>'L-2','state'=>'готов']]);
    $trace=new Ev135Trace($db,['find'],1);
    [$a,$b]=ev135Observe($manager,$trace,fn()=>[ev135Order($manager,$ns,'L-1'),ev135Order($manager,$ns,'L-2')]);
    $seenBefore=$trace->started;
    $c=ev135Order($manager,$ns,'L-1');
    $record=$trace->records[0];
    $rows=[['Чтений внутри окна',$trace->started],['Сохранено пар',count($trace->records)],['Пропущено из-за лимита',$trace->omitted],
        ['Новых начал после отписки',$trace->started-$seenBefore],['Прочитали после отписки',$c['_id']]];
    $checks=['two_fixtures'=>$seed===2,'both_inside'=>$a['_id']==='L-1' && $b['_id']==='L-2',
        'two_starts'=>$seenBefore===2,'bounded'=>count($trace->records)===1 && $trace->omitted===1,
        'paired'=>$record['linked'] && $record['terminal']==='succeeded','pending_clear'=>$trace->pendingCount()===0,
        'detached'=>$trace->started===$seenBefore && $c['_id']==='L-1'];
    return [$rows,$checks,[]];
});
ev135Report('mongodb135-events-unsubscribe', 'Ограничить наблюдение одним действием в воркере', ['Что проверили', 'Результат'], $rows,$checks,$runtime,$counts,$board);
foreach ($rows as [$label,$value]) {echo $label, ' — ', $value, PHP_EOL;}

Чтений внутри окна — 2
Сохранено пар — 1
Пропущено из-за лимита — 1
Новых начал после отписки — 0
Прочитали после отписки — L-1

Самостоятельный запуск PHP с реальной MongoDB. После чтения итогового состояния программа удаляет собственную коллекцию.

<?php
declare(strict_types=1);
use MongoDB\Driver\Manager;
use MongoDB\Driver\Exception\{BulkWriteException,CommandException};
require __DIR__.'/ev135-helper.php';

[$rows,$checks,$runtime,$counts,$board] = ev135Lab(static function(Manager $manager,string $db,string $ns): array {
    $board=[];
    $append=static function(string $action,Ev135Trace $trace,string $outcome) use (&$board,$manager,$ns): void {
        $signal=$trace->started===0 ? null : $trace->single();
        $command=$signal===null ? 'Не отправлена' : $signal['command'].' → '.$signal['terminal'];
        $order=ev135Order($manager,$ns,'R-17');
        $stored=$order===null ? 'Заказ отсутствует' : $order['state'].' · '.$order['quantity'].' шт.';
        $board[]=compact('action','command','outcome','stored');
    };
    $doc=['_id'=>'R-17','state'=>'принят','quantity'=>2];
    $one=new Ev135Trace($db,['insert']);
    $created=ev135Observe($manager,$one,fn()=>ev135Put($manager,$ns,[$doc]));
    $append('Принять заказ',$one,'Создано документов: '.$created);

    $two=new Ev135Trace($db,['insert']);
    $duplicateCode=0;
    try {ev135Observe($manager,$two,fn()=>ev135Put($manager,$ns,[array_replace($doc,['quantity'=>7])]));}
    catch (BulkWriteException $error) {$duplicateCode=$error->getWriteResult()->getWriteErrors()[0]->getCode();}
    $reply=$two->single();
    $append('Повторить отправку',$two,'Ошибок записи: '.$reply['writeErrors'].', код '.$duplicateCode);

    $three=new Ev135Trace($db,['update']);
    $matched=ev135Observe($manager,$three,fn()=>ev135Update($manager,$ns,['_id'=>'R-17','state'=>'отправлен'],['state'=>'доставлен']))->getMatchedCount();
    $append('Отметить доставленным',$three,'Подошло документов: '.$matched);

    $four=new Ev135Trace($db,['update']);
    $quantity=-3;
    $guard=ev135Observe($manager,$four,static function() use ($quantity,$manager,$ns): string {
        if ($quantity<1 || $quantity>20) {return 'Количество вне диапазона';}
        $changed=ev135Update($manager,$ns,['_id'=>'R-17'],['quantity'=>$quantity])->getModifiedCount();
        return 'Изменено документов: '.$changed;
    });
    $append('Ввести −3',$four,$guard);

    $five=new Ev135Trace($db,['phpmanMissingCommand']);
    $serverCode=0;
    try {ev135Observe($manager,$five,fn()=>ev135Command($manager,$db,['phpmanMissingCommand'=>1]));}
    catch (CommandException $error) {$serverCode=$error->getCode();}
    $append('Вызвать неизвестную команду',$five,'Код отказа: '.$serverCode);

    $final=ev135Order($manager,$ns,'R-17');
    $rows=[['Действий на экране',count($board)],['Начатых команд в пяти окнах',$one->started+$two->started+$three->started+$four->started+$five->started],
        ['Создано заказов',$created],['Последнее состояние',$final['state']],['Количество в базе',$final['quantity']]];
    $checks=['one_persisted'=>$created===1,'duplicate'=>$duplicateCode===11000 && $reply['writeErrors']===1,
        'stale_filter'=>$matched===0,'local_refusal'=>$four->started===0 && $guard==='Количество вне диапазона',
        'wire_refusal'=>$five->single()['code']===$serverCode && $serverCode===59,'five_readbacks'=>count($board)===5 && array_unique(array_column($board,'stored'))===['принят · 2 шт.'],
        'final_quantity'=>$final['quantity']===2,'final_state'=>$final['state']==='принят'];
    return [$rows,$checks,$board];
});
ev135Report('mongodb135-events-operator-board', 'Прочитать отчёт по пяти действиям с одним заказом', ['Что проверили', 'Результат'], $rows,$checks,$runtime,$counts,$board);
foreach ($rows as [$label,$value]) {echo $label, ' — ', $value, PHP_EOL;}

Действий на экране — 5
Начатых команд в пяти окнах — 4
Создано заказов — 1
Последнее состояние — принят
Количество в базе — 2

Самостоятельный запуск PHP с реальной MongoDB. После чтения итогового состояния программа удаляет собственную коллекцию.