.
*/
declare(strict_types=1);
namespace Fisharebest\Webtrees\Http\RequestHandlers;
use Fisharebest\Algorithm\MyersDiff;
use Fisharebest\Webtrees\Carbon;
use Fisharebest\Webtrees\Factory;
use Fisharebest\Webtrees\Gedcom;
use Fisharebest\Webtrees\I18N;
use Fisharebest\Webtrees\Services\DatatablesService;
use Fisharebest\Webtrees\Services\PendingChangesService;
use Fisharebest\Webtrees\Tree;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\RequestHandlerInterface;
use stdClass;
use function e;
use function explode;
use function implode;
use function preg_replace_callback;
/**
* Find pending changes.
*/
class PendingChangesLogData implements RequestHandlerInterface
{
/** @var DatatablesService */
private $datatables_service;
/** @var MyersDiff */
private $myers_diff;
/** @var PendingChangesService */
private $pending_changes_service;
/**
* @param DatatablesService $datatables_service
* @param MyersDiff $myers_diff
* @param PendingChangesService $pending_changes_service
*/
public function __construct(
DatatablesService $datatables_service,
MyersDiff $myers_diff,
PendingChangesService $pending_changes_service
) {
$this->datatables_service = $datatables_service;
$this->myers_diff = $myers_diff;
$this->pending_changes_service = $pending_changes_service;
}
/**
* @param ServerRequestInterface $request
*
* @return ResponseInterface
*/
public function handle(ServerRequestInterface $request): ResponseInterface
{
$tree = $request->getAttribute('tree');
assert($tree instanceof Tree);
$params = $request->getQueryParams();
$params['tree'] = $tree->name();
$query = $this->pending_changes_service->changesQuery($params);
$callback = function (stdClass $row) use ($tree): array {
$old_lines = explode("\n", $row->old_gedcom);
$new_lines = explode("\n", $row->new_gedcom);
$differences = $this->myers_diff->calculate($old_lines, $new_lines);
$diff_lines = [];
foreach ($differences as $difference) {
switch ($difference[1]) {
case MyersDiff::DELETE:
$diff_lines[] = '' . e($difference[0]) . '';
break;
case MyersDiff::INSERT:
$diff_lines[] = '' . e($difference[0]) . '';
break;
default:
$diff_lines[] = e($difference[0]);
}
}
// Only convert valid xrefs to links
$record = Factory::gedcomRecord()->make($row->xref, $tree);
return [
$row->change_id,
Carbon::make($row->change_time)->local()->format('Y-m-d H:i:s'),
I18N::translate($row->status),
$record ? '' . $record->xref() . '' : $row->xref,
'',
$row->user_name,
$row->gedcom_name,
];
};
return $this->datatables_service->handleQuery($request, $query, [], [], $callback);
}
}