src/ResolvePos.php
<?php
namespace Swaggest\JsonCli;
use JsonStreamingParser\Parser;
use Swaggest\JsonDiff\Exception;
use Swaggest\JsonDiff\JsonPointer;
use Yaoi\Command;
use Yaoi\Command\Definition;
use Yaoi\Io\Content\Rows;
class ResolvePos extends Command
{
public $path;
public $pointer;
public $dumpAll;
/**
* @param Definition $definition
* @param \stdClass|static $options
*/
static function setUpDefinition(Definition $definition, $options)
{
$options->path = Command\Option::create()->setType()->setIsUnnamed()
->setDescription('Path to JSON file');
$options->pointer = Command\Option::create()->setType()->setIsUnnamed()
->setDescription('JSON Pointer, example /key4/1/a');
$options->dumpAll = Command\Option::create()->setDescription('Dump all pointer positions from JSON');
}
/**
* @throws ExitCode
*/
public function performAction()
{
$listener = new FilePosition\PositionResolver();
$stream = fopen($this->path, 'r');
if ($stream === false) {
$this->response->error('Failed to open ' . $this->path);
die(1);
}
try {
if ($stream !== false) {
$parser = new Parser($stream, $listener);
$parser->parse();
fclose($stream);
}
} catch (\Exception $e) {
fclose($stream);
$this->response->error($e->getMessage());
throw new ExitCode('', 1);
}
if ($this->dumpAll) {
$rows = array();
foreach ($listener->resolved as $pointer => $pos) {
$rows[] = array(
'Pos' => $pos,
'Ptr' => $pointer,
);
}
$this->response->addContent(new Rows(new \ArrayIterator($rows)));
} else {
try {
// Convert to non-URI pointer
$pointer = JsonPointer::buildPath(JsonPointer::splitPath($this->pointer));
} catch (Exception $e) {
$this->response->error($e->getMessage());
throw new ExitCode('', 1);
}
if (isset($listener->resolved[$pointer])) {
$this->response->addContent($listener->resolved[$pointer]);
} else {
$this->response->error('Pointer not found');
throw new ExitCode('', 1);
}
}
}
}