Merge branch 'sync-pipelines'

Author: lkrms

src/Sync/Concept/SyncProvider.php

@@ -8,6 +8,7 @@
 use Lkrms\Contract\IService;
 use Lkrms\Support\Catalog\RegularExpression as Regex;
 use Lkrms\Support\Pipeline;
+use Lkrms\Sync\Catalog\SyncOperation as OP;
 use Lkrms\Sync\Contract\ISyncContext;
 use Lkrms\Sync\Contract\ISyncEntity;
 use Lkrms\Sync\Contract\ISyncProvider;
@@ -191,20 +192,46 @@ protected function run(ISyncContext $context, callable $operation)
     }
 
     /**
-     * Get a new pipeline bound to the provider's container
+     * Get a new pipeline for mapping provider data to entities
      *
+     * @template T of ISyncEntity
+     * @param class-string<T> $entity
+     * @return IPipeline<mixed[],T,array{0:OP::*,1:ISyncContext,2?:int|string|T|T[]|null,...}>
+     */
+    protected function pipelineFrom(string $entity): IPipeline
+    {
+        return Pipeline::create($this->App);
+    }
+
+    /**
+     * Get a new pipeline for mapping entities to provider data
+     *
+     * @template T of ISyncEntity
+     * @param class-string<T> $entity
+     * @return IPipeline<T,mixed[],array{0:OP::*,1:ISyncContext,2?:int|string|T|T[]|null,...}>
+     */
+    protected function pipelineTo(string $entity): IPipeline
+    {
+        return Pipeline::create($this->App);
+    }
+
+    /**
      * @return IPipeline<mixed,mixed,mixed>
+     * @deprecated Use {@see SyncProvider::pipelineFrom()} or
+     * {@see SyncProvider::pipelineTo()} instead
+     * @codeCoverageIgnore
      */
     protected function pipeline(): IPipeline
     {
         return Pipeline::create($this->App);
     }
 
     /**
-     * Wrap a new pipeline around a callback
-     *
      * @param (callable(mixed $payload, IPipeline<mixed,mixed,mixed> $pipeline, mixed $arg): mixed) $callback
      * @return IPipeline<mixed,mixed,mixed>
+     * @deprecated Use {@see SyncProvider::pipelineFrom()} or
+     * {@see SyncProvider::pipelineTo()} instead
+     * @codeCoverageIgnore
      */
     protected function callbackPipeline(callable $callback): IPipeline
     {