Add file existence check and exception handling

Imported the file_exists function in FileGetContents.php and implemented a check for file existence before getting its content. In QueryInterceptor.php, added InjectorInterface for dependency injection and handled SqlFileNotReadableException to maintain backward compatibility.

src/FileGetContents.php

@@ -6,6 +6,7 @@
 
 use Ray\Query\Exception\SqlFileNotReadableException;
 
+use function file_exists;
 use function file_get_contents;
 
 final class FileGetContents implements FileGetContentsInterface
@@ -15,6 +16,10 @@ final class FileGetContents implements FileGetContentsInterface
      */
     public function __invoke(string $filePath): string
     {
+        if (! file_exists($filePath)) {
+            throw new SqlFileNotReadableException($filePath);
+        }
+
         $content =  file_get_contents($filePath);
         if ($content === false) {
             // @codeCoverageIgnoreStart

src/QueryInterceptor.php

@@ -9,6 +9,7 @@
 use Ray\Aop\MethodInterceptor;
 use Ray\Aop\MethodInvocation;
 use Ray\Aop\ReflectionMethod;
+use Ray\Di\InjectorInterface;
 use Ray\Query\Annotation\Query;
 use Ray\Query\Exception\SqlFileNotFoundException;
 use Ray\Query\Exception\SqlFileNotReadableException;
@@ -30,14 +31,19 @@ class QueryInterceptor implements MethodInterceptor
     /** @var FileGetContentsInterface */
     private $fileGetContents;
 
+    /** @var InjectorInterface */
+    private $injector;
+
     public function __construct(
         ExtendedPdoInterface $pdo,
         SqlDir $sqlDir,
-        FileGetContentsInterface $fileGetContents
+        FileGetContentsInterface $fileGetContents,
+        InjectorInterface $injector
     ) {
         $this->sqlDir = $sqlDir;
         $this->pdo = $pdo;
         $this->fileGetContents = $fileGetContents;
+        $this->injector = $injector;
     }
 
     /** @return ResourceObject|mixed */
@@ -50,7 +56,18 @@ public function invoke(MethodInvocation $invocation)
         $namedArguments = (array) $invocation->getNamedArguments();
         [$queryId, $params] = $query->templated ? $this->templated($query, $namedArguments) : [$query->id, $namedArguments];
         assert(is_string($queryId));
-        $sql = $this->getsql($queryId, $method);
+        $filePath = sprintf('%s/%s.sql', $this->sqlDir->value, $queryId);
+        try {
+            $sql = ($this->fileGetContents)($filePath);
+        } catch (SqlFileNotReadableException $e) {
+            // For BC
+            // @codeCoverageIgnoreStart
+            $sqlQuery = $this->injector->getInstance(RowListInterface::class, $queryId);
+
+            return $this->getQueryResult($invocation, $sqlQuery, $params);
+            // @codeCoverageIgnoreEnd
+        }
+
         $sqlQuery = $query->type === 'row' ? new SqlQueryRow($this->pdo, $sql) : new SqlQueryRowList($this->pdo, $sql);
 
         /** @var array<string, mixed> $params */