Fix Bulk Batch processor

Author: frankkessler

src/Bulk.php

@@ -93,7 +93,7 @@ public function runBatch($operation, $objectType, $data, $options = [])
                 if (in_array($batch->state, ['Completed', 'Failed', 'Not Processed', 'NotProcessed'])) {
                     if (in_array($batch->state, ['Completed'])) {
                         $batchResult = $this->batchResult($job->id, $batch->id, $options['isBatchedResult'], null, $options['contentType']);
-                        if($options['batchProcessor'] instanceof BulkBatchProcessorInterface){
+                        if(class_exists($options['batchProcessor']) && class_implements($options['batchProcessor'], '\Frankkessler\Salesforce\Interfaces\BulkBatchProcessorInterface')){
                             call_user_func([$options['batchProcessor'], 'process'], $batchResult);
                         }else {
                             $batch->records = $batchResult->records;

tests/BulkBatchProcessor.php

@@ -9,6 +9,6 @@ class BulkBatchProcessor implements BulkBatchProcessorInterface
 
     public static function process(BulkBatchResultResponse $batchResult)
     {
-        array_merge(static::$records, $batchResult->records);
+        static::$records = array_merge(static::$records, $batchResult->records);
     }
 }

tests/BulkTest.php

@@ -293,6 +293,8 @@ public function testRunPkChunkQueryBatchWithBatchProcessor()
             'batchProcessor'           => BulkBatchProcessor::class,
         ]);
 
+        $this->assertEquals(2, count(BulkBatchProcessor::$records));
+
         foreach(BulkBatchProcessor::$records as $record){
             $this->assertEquals($firstAccountId, $record['Id']);
             break;