<?php
require_once('vendor/autoload.php');
/* Start to develop here. Best regards https://php-download.com/ */
mwstake / mediawiki-component-processmanager example snippets
class Foo implements IProcessStep {
/** @var ILoadBalancer */
private $lb;
/** @var string */
private $name;
public function __construct( ILoadBalancer $lb, $name ) {
$this->lb = $lb;
$this->name = $name;
}
public function execute( $data = [] ): array {
// Add "_bar" to the name passed as the argument in the spec and return it
$name = $this->name . '_bar';
// some lenghty code
return [ 'modifiedName' => $name ];
}
}
// Create process that has a single step, Foo, defined above
// new ManagerProcess( array $steps, int $timeout );
$process = new ManagedProcess( [
'foo-step' => [
'class' => Foo::class,
'args' => [ 'Bar-name' ],
'services' => [ 'DBLoadBalancer' ]
]
], 300 );
$processManager = MediaWikiServices::getInstance()->getService( 'ProcessManager' );
// ProcessManager::startProcess() returns unique process ID that is
$processManager = MediaWikiServices::getInstance()->getService( 'ProcessManager' );
echo $processManager->getProcessInfo( $pid );
// Returns JSON
{
"pid": "1211a33123aae2baa6ed1d9a1846da9d",
"started_at": "20220209125814",
"status": "finished",
"output": { /*JSON-encoded string of whatever the last step returned as output*/ }
}
$executor = new \MWStake\MediaWiki\Component\ProcessManager\StepExecutor(
MediaWikiServices::getInstance()->getObjectNameUtils()
);
// Optional, if all necessary data is passed in the spec, omit this
$data = [
'input' => 'data for the first step'
];
$executor->execute( [
'foo-step' => [
'class' => Foo::class,
'args' => [
$someArg1,
$someArg2
]
],
'bar-step' => [
'class' => Bar::class,
'args' => [
$someArg1,
$someArg3,
$someArg4
]
]
], $data );