Source Commands

This commit is contained in:
Ryan Prather 2024-05-13 21:07:58 -04:00
parent 4b0d327ab4
commit 81fecfbc59
2 changed files with 263 additions and 0 deletions

View File

@ -0,0 +1,110 @@
<?php
namespace App\Command;
use App\Entity\Bible;
use Doctrine\ORM\EntityManagerInterface;
use Symfony\Component\Console\Attribute\AsCommand;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Style\SymfonyStyle;
#[AsCommand(
name: 'IngestBible',
aliases: ['app:ingest-bible'],
description: 'Script used to crawl a directory and ingest Bible passages and save them to the database.',
)]
class IngestBibleCommand extends Command
{
private array $files = [];
private SymfonyStyle $io;
private EntityManagerInterface $emi;
public function __construct(
EntityManagerInterface $emi,
private string $dir = ''
) {
\ini_set('memory_limit', '5G');
parent::__construct();
$this->emi = $emi;
}
protected function configure(): void
{
$this
->addArgument('directory', InputArgument::REQUIRED, 'Directory to crawl')
;
}
protected function execute(InputInterface $input, OutputInterface $output): int
{
$this->io = new SymfonyStyle($input, $output);
$this->dir = $input->getArgument('directory');
if (!$this->dir) {
$this->io->error('Directory not specific or does not exist');
return Command::FAILURE;
}
$this->io->note("Crawling {$this->dir} and ingesting Bible passages...");
foreach($this->getFiles() as $file) {
$this->io->info("Processing ".basename($file));
$this->processFile($file);
}
return Command::SUCCESS;
}
private function getFiles(): array
{
$this->files = glob($this->dir . "/*/*.md");
if(!$this->files || count($this->files) === 0) {
$this->io->warning("No files found in this directory\n{$this->dir}");
$this->files = [];
}
natsort($this->files);
return $this->files;
}
private function processFile(string $file)
{
$bible = new Bible();
$match = [];
if(preg_match("/([\d]+) \- ([^\/]+)\/\d?[a-zA-Z]+([\d]+)\.md/", $file, $match)) {
$ndx = (int) $match[1];
$book = str_replace(" ", "", $match[2]);
$chapter = (int) $match[3];
}
if (preg_match("/(\d)([^\d]+)/", $book, $match)) {
$book = $match[1]." ".$match[2];
}
$bible->setBook($book);
$bible->setBookIndex($ndx);
$bible->setChapter($chapter);
$content = file_get_contents($file);
foreach(explode("\n", $content) as $verse) {
$match = [];
if (preg_match("/^([\d]+). ([^\d]+)/", $verse, $match)) {
$bible->setVerse($match[1]);
$bible->setContent($match[2]);
}
$this->emi->persist($bible);
$this->emi->flush();
}
}
}

View File

@ -0,0 +1,153 @@
<?php
namespace App\Command;
use App\Entity\Reference;
use Doctrine\ORM\EntityManagerInterface;
use Symfony\Component\Console\Attribute\AsCommand;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Style\SymfonyStyle;
#[AsCommand(
name: 'IngestReference',
aliases: ['app:ingest-ref'],
description: 'Script to use to crawl a directory and ingest references',
)]
class IngestReferenceCommand extends Command
{
/**
* Files found in the directory
*
* @var array
*/
private array $files = [];
/**
* IO
*
* @var SymfonyStyle
*/
private SymfonyStyle $io;
/**
* EntityManager
*
* @var EntityManagerInterface
*/
private EntityManagerInterface $emi;
/**
* IngestReferenceCommand constructor.
*/
public function __construct(
EntityManagerInterface $emi,
private string $dir = '',
private string $name = '',
private string $type = '',
private string $label = ''
) {
parent::__construct();
$this->emi = $emi;
}
/**
* {@inheritdoc}
*/
protected function configure(): void
{
$this
->addArgument('directory', InputArgument::REQUIRED, 'Directory to crawl')
->addArgument('name', InputArgument::REQUIRED, 'Name of the reference')
->addArgument('type', InputArgument::REQUIRED, 'Type of the reference')
->addArgument('label', InputArgument::REQUIRED, 'Label of the reference')
;
}
protected function execute(InputInterface $input, OutputInterface $output): int
{
$this->io = new SymfonyStyle($input, $output);
$this->dir = $input->getArgument('directory');
$this->name = $input->getArgument('name');
$this->type = $input->getArgument('type');
$this->label = $input->getArgument('label');
if (!$this->dir || !file_exists($this->dir) ||!is_dir($this->dir)) {
$this->io->error('Directory not specific or does not exist');
return Command::FAILURE;
}
if (!$this->name) {
$this->io->error('No name specified');
return Command::FAILURE;
}
if (!$this->type) {
$this->io->error('No type specified');
return Command::FAILURE;
}
if (!$this->label) {
$this->io->error('No label specified');
return Command::FAILURE;
}
$this->io->note("Crawling {$this->dir} and ingesting {$this->name} as {$this->type}:{$this->label}");
foreach ($this->getFiles() as $file) {
$ref = $this->processFile($file);
$this->emi->persist($ref);
}
$this->emi->flush();
return Command::SUCCESS;
}
public function getFiles(): array
{
$this->files = glob($this->dir . '/*.md');
if(!$this->files || count($this->files) === 0) {
$this->io->warning("No files found in this directory\n{$this->dir}");
$this->files = [];
}
return $this->files;
}
public function processFile(string $file): Reference|bool
{
$this->io->info("Processing {$file}");
$md = trim(file_get_contents($file));
$ref = new Reference();
if (!$md) {
$this->io->warning("File is empty\n{$file}");
return false;
}
$match = [];
$label = str_replace("{\$ndx}", "", $this->label);
if(preg_match("/([\d]+)/", $file, $match)) {
$ndx = ltrim($match[1], "0");
$label = str_replace("{\$ndx}", $ndx, $this->label);
$ref->setNdx($ndx);
} elseif (preg_match("/\(([^\)]+)\)/", $file, $match)) {
$label = $match[1];
}
$ref->setContent($md);
$ref->setName($this->name);
$ref->setType($this->type);
$ref->setLabel($label);
$this->io->success("Ingested {$this->name} as {$this->type}:{$label}");
return $ref;
}
}