Cake5

.github/workflows/ci.yml

@@ -14,11 +14,11 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        php-version: ['7.4', '8.0', '8.3']
+        php-version: ['8.2', '8.3']
         db-type: ['mysql', 'pgsql']
         prefer-lowest: ['']
         include:
-          - php-version: '7.4'
+          - php-version: '8.3'
             db-type: 'sqlite'
             prefer-lowest: 'prefer-lowest'
 
@@ -61,14 +61,14 @@ jobs:
         if [[ ${{ matrix.db-type }} == 'mysql' ]]; then export DB_URL='mysql://root:[email protected]/cakephp'; fi
         if [[ ${{ matrix.db-type }} == 'pgsql' ]]; then export DB_URL='postgres://postgres:[email protected]/postgres'; fi
 
-        if [[ ${{ matrix.php-version }} == '7.4' && ${{ matrix.db-type }} == 'mysql' ]]; then
+        if [[ ${{ matrix.php-version }} == '8.3' && ${{ matrix.db-type }} == 'mysql' ]]; then
           vendor/bin/phpunit --coverage-clover=coverage.xml
         else
           vendor/bin/phpunit
         fi
 
     - name: Code Coverage Report
-      if: success() && matrix.php-version == '7.4' && matrix.db-type == 'mysql'
+      if: success() && matrix.php-version == '8.3' && matrix.db-type == 'mysql'
       uses: codecov/codecov-action@v1
 
   cs-stan:
@@ -81,16 +81,17 @@ jobs:
     - name: Setup PHP
       uses: shivammathur/setup-php@v2
       with:
-        php-version: '7.4'
+        php-version: '8.3'
         extensions: mbstring, intl
         coverage: none
-        tools: psalm:4, phpstan:1
+        tools: psalm:5.23.1, phpstan:1.10.65
 
     - name: Composer Install
       run: composer require cakephp/cakephp-codesniffer:^4.2
 
     - name: Run phpcs
-      run: vendor/bin/phpcs --standard=CakePHP src/ tests/
+      # Exclude Type hint sniffing, as it interferes with psalm
+      run: vendor/bin/phpcs --standard=CakePHP --exclude=CakePHP.Classes.ReturnTypeHint src/ tests/
 
     - name: Run psalm
       if: success() || failure()

.gitignore

@@ -2,3 +2,4 @@
 /plugins
 /vendor
 .phpunit.result.cache
+/.idea

composer.json

@@ -39,12 +39,19 @@
         "irc": "irc://irc.freenode.org/muffin"
     },
     "require": {
-        "cakephp/orm": "^4.5"
+        "cakephp/orm": "^5.0"
     },
     "require-dev": {
-        "cakephp/cakephp": "^4.5",
-        "cakephp/cakephp-codesniffer": "^4.2",
-        "phpunit/phpunit": "^9.3"
+        "cakephp/cakephp": "^5.0",
+        "cakephp/cakephp-codesniffer": "^5.0",
+        "phpunit/phpunit": "^10.1",
+        "ext-mbstring": "*",
+        "vimeo/psalm": "5.23.1",
+        "phpstan/phpstan": "1.10.65"
+    },
+    "scripts": {
+        "cs-check": "phpcs --colors --parallel=16 -p src/ tests/",
+        "cs-fix": "phpcbf --colors --parallel=16 -p src/ tests/"
     },
     "autoload": {
         "psr-4": {

phpstan.neon

@@ -1,21 +1,7 @@
 parameters:
-	level: 6
+	level: 8
 	checkMissingIterableValueType: false
 	checkGenericClassInNonGenericObjectType: false
+	treatPhpDocTypesAsCertain: false
 	paths:
 		- src/
-	ignoreErrors:
-		-
-			message: "#^Call to an undefined method Cake\\\\Datasource\\\\RepositoryInterface\\:\\:callFinder\\(\\)\\.$#"
-			count: 1
-			path: src/Datasource/Query.php
-
-		-
-			message: "#^Call to an undefined method Cake\\\\Datasource\\\\RepositoryInterface\\:\\:getName\\(\\)\\.$#"
-			count: 1
-			path: src/Datasource/Query.php
-
-		-
-			message: "#^Method Muffin\\\\Webservice\\\\Datasource\\\\Query\\:\\:execute\\(\\) should return bool\\|int\\|Muffin\\\\Webservice\\\\Datasource\\\\ResultSet\\|Muffin\\\\Webservice\\\\Model\\\\Resource but returns Cake\\\\Datasource\\\\ResultSetInterface\\.$#"
-			count: 1
-			path: src/Datasource/Query.php

phpunit.xml.dist

@@ -1,23 +1,20 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<phpunit
-    bootstrap="./tests/bootstrap.php"
-    colors="true"
-    stopOnFailure="false"
-    >
-
+<phpunit xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" bootstrap="./tests/bootstrap.php" colors="true" stopOnFailure="false" xsi:noNamespaceSchemaLocation="https://schema.phpunit.de/10.2/phpunit.xsd" cacheDirectory=".phpunit.cache">
     <testsuites>
-        <testsuite name="Webservice Test Cases">
+        <testsuite name="Slug Test Cases">
             <directory>./tests/</directory>
         </testsuite>
     </testsuites>
-
     <extensions>
-        <extension class="Cake\TestSuite\Fixture\PHPUnitExtension"/>
+        <bootstrap class="Cake\TestSuite\Fixture\Extension\PHPUnitExtension"/>
     </extensions>
-
-    <filter>
-        <whitelist>
+    <php>
+        <ini name="memory_limit" value="-1"/>
+        <env name="FIXTURE_SCHEMA_METADATA" value="./tests/schema.php"/>
+    </php>
+    <source>
+        <include>
             <directory suffix=".php">./src/</directory>
-        </whitelist>
-    </filter>
+        </include>
+    </source>
 </phpunit>

psalm.xml

@@ -1,9 +1,12 @@
 <?xml version="1.0"?>
 <psalm
+    errorLevel="2"
     resolveFromConfigFile="true"
     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
     xmlns="https://getpsalm.org/schema/config"
     xsi:schemaLocation="https://getpsalm.org/schema/config vendor/vimeo/psalm/config.xsd"
+    findUnusedCode="false"
+    findUnusedBaselineEntry="true"
 >
     <projectFiles>
         <directory name="src" />
@@ -13,16 +16,9 @@
     </projectFiles>
 
     <issueHandlers>
-
-        <PropertyNotSetInConstructor errorLevel="info" />
-        <MissingClosureReturnType errorLevel="info" />
-        <MissingClosureParamType errorLevel="info" />
-
-        <DocblockTypeContradiction errorLevel="info" />
-        <RedundantConditionGivenDocblockType errorLevel="info" />
-
-        <UnsafeInstantiation errorLevel="info" />
-
-        <UnresolvableInclude errorLevel="info" />
+        <RedundantConditionGivenDocblockType errorLevel="suppress"/>
+        <MissingClosureParamType errorLevel="suppress"/>
+        <MissingClosureReturnType errorLevel="suppress"/>
+        <PropertyNotSetInConstructor errorLevel="suppress"/>
     </issueHandlers>
 </psalm>

src/Datasource/Connection.php

@@ -4,26 +4,34 @@
 namespace Muffin\Webservice\Datasource;
 
 use Cake\Core\App;
+use Cake\Datasource\ConnectionInterface;
 use Muffin\Webservice\Datasource\Exception\MissingConnectionException;
 use Muffin\Webservice\Webservice\Driver\AbstractDriver;
 use Muffin\Webservice\Webservice\Exception\MissingDriverException;
 use Muffin\Webservice\Webservice\Exception\UnexpectedDriverException;
+use Psr\SimpleCache\CacheInterface;
 
 /**
  * Class Connection
  *
  * @method \Muffin\Webservice\Webservice\Driver\AbstractDriver setWebservice(string $name, \Muffin\Webservice\Webservice\WebserviceInterface $webservice) Proxy method through to the Driver
  * @method \Muffin\Webservice\Webservice\WebserviceInterface getWebservice(string $name) Proxy method through to the Driver
- * @method string configName() Proxy method through to the Driver
  */
-class Connection
+class Connection implements ConnectionInterface
 {
     /**
      * Driver
      *
      * @var \Muffin\Webservice\Webservice\Driver\AbstractDriver
      */
-    protected $_driver;
+    protected AbstractDriver $_driver;
+
+    protected CacheInterface $cacher;
+
+    /**
+     * The connection name in the connection manager.
+     */
+    protected string $configName = '';
 
     /**
      * Constructor
@@ -33,17 +41,68 @@
      */
     public function __construct(array $config)
     {
+        if (isset($config['name'])) {
+            $this->configName = $config['name'];
+        }
         $config = $this->_normalizeConfig($config);
-        /** @psalm-var class-string<\Muffin\Webservice\Webservice\Driver\AbstractDriver> */
         $driver = $config['driver'];
         unset($config['driver'], $config['service']);
 
-        $this->_driver = new $driver($config);
+        $tempDriver = new $driver($config);
 
-        /** @psalm-suppress TypeDoesNotContainType */
-        if (!($this->_driver instanceof AbstractDriver)) {
+        if (!($tempDriver instanceof AbstractDriver)) {
             throw new UnexpectedDriverException(['driver' => $driver]);
         }
+        $this->_driver = $tempDriver;
+    }
+
+    /**
+     * @param \Psr\SimpleCache\CacheInterface $cacher The cacher instance to use for query caching.
+     * @return $this
+     */
+    public function setCacher(CacheInterface $cacher): ConnectionInterface
+    {
+        $this->cacher = $cacher;
+
+        return $this;
+    }
+
+    /** @return \Psr\SimpleCache\CacheInterface  */
+    public function getCacher(): CacheInterface
+    {
+        return $this->cacher;
+    }
+
+    /**
+     * {@inheritDoc}
+     *
+     * @param string $role Parameter is not used
+     * @see \Cake\Datasource\ConnectionInterface::getDriver()
+     * @return \Muffin\Webservice\Webservice\Driver\AbstractDriver
+     */
+    public function getDriver(string $role = self::ROLE_WRITE): AbstractDriver
+    {
+        return $this->_driver;
+    }
+
+    /**
+     * Get the configuration name for this connection.
+     *
+     * @return string
+     */
+    public function configName(): string
+    {
+        return $this->configName;
+    }
+
+    /**
+     * Get the config data for this connection.
+     *
+     * @return array<string, mixed>
+     */
+    public function config(): array
+    {
+        return $this->_driver->getConfig();
     }
 
     /**
@@ -61,7 +120,7 @@
                 throw new MissingConnectionException(['name' => $config['name']]);
             }
 
-            $config['driver'] = App::className($config['service'], 'Webservice/Driver');
+            $config['driver'] = App::className($config['service'], 'Webservice/Driver', 'Driver');
             if (!$config['driver']) {
                 throw new MissingDriverException(['driver' => $config['driver']]);
             }
@@ -77,8 +136,9 @@
      * @param array $args Arguments to pass-through
      * @return mixed
      */
-    public function __call($method, $args)
+    public function __call(string $method, array $args): mixed
     {
+        /* @phpstan-ignore-next-line This is supported behavior for now: https://www.php.net/manual/en/function.call-user-func-array.php (example 1) */
         return call_user_func_array([$this->_driver, $method], $args);
     }
 }

src/Datasource/Exception/MissingConnectionException.php

@@ -12,5 +12,5 @@ class MissingConnectionException extends CakeException
      *
      * @var string
      */
-    protected $_messageTemplate = 'No `%s` connection configured.';
+    protected string $_messageTemplate = 'No `%s` connection configured.';
 }

src/Datasource/Marshaller.php

@@ -22,7 +22,7 @@
      *
      * @var \Muffin\Webservice\Model\Endpoint
      */
-    protected $_endpoint;
+    protected Endpoint $_endpoint;
 
     /**
      * Constructor.
@@ -53,7 +53,6 @@
         [$data, $options] = $this->_prepareDataAndOptions($data, $options);
 
         $primaryKey = (array)$this->_endpoint->getPrimaryKey();
-        /** @psalm-var class-string<\Muffin\Webservice\Model\Resource> */
         $resourceClass = $this->_endpoint->getResourceClass();
         $entity = new $resourceClass();
         $entity->setSource($this->_endpoint->getRegistryAlias());
@@ -110,25 +109,21 @@
         if (!$options['validate']) {
             return [];
         }
-
-        $validator = null;
         if ($options['validate'] === true) {
-            $validator = $this->_endpoint->getValidator('default');
-        } elseif (is_string($options['validate'])) {
-            $validator = $this->_endpoint->getValidator($options['validate']);
-        } else {
-            /** @var \Cake\Validation\Validator $validator */
-            $validator = $options['validator'];
+            $options['validate'] = $this->_endpoint->getValidator('default');
         }
 
-        if (!is_callable([$validator, 'errors'])) {
-            throw new RuntimeException(sprintf(
-                '"validate" must be a boolean, a string or an object with method "errors()". Got %s instead.',
-                gettype($options['validate'])
-            ));
+        if (is_string($options['validate'])) {
+            $options['validate'] = $this->_endpoint->getValidator($options['validate']);
+        }
+        if (!is_object($options['validate'])) {
+            throw new RuntimeException(
+                sprintf('validate must be a boolean, a string or an object. Got %s.', gettype($options['validate']))
+            );
         }
 
-        return $validator->validate($data, $isNew);
+        /* @phpstan-ignore-next-line Magic method */
+        return $options['validate']->validate($data, $isNew);
     }
 
     /**
@@ -165,7 +160,7 @@
      *
      * @param array $data The data to hydrate.
      * @param array $options List of options
-     * @return \Cake\Datasource\EntityInterface[] An array of hydrated records.
+     * @return array<\Cake\Datasource\EntityInterface> An array of hydrated records.
      * @see \Muffin\Webservice\Model\Endpoint::newEntities()
      */
     public function many(array $data, array $options = []): array
@@ -264,9 +259,9 @@
      *   data merged in
      * @param array $data list of arrays to be merged into the entities
      * @param array $options List of options.
-     * @return \Cake\Datasource\EntityInterface[]
+     * @return array<\Cake\Datasource\EntityInterface>
      */
-    public function mergeMany($entities, array $data, array $options = []): array
+    public function mergeMany(iterable $entities, array $data, array $options = []): array
     {
         $primary = (array)$this->_endpoint->getPrimaryKey();