test copy and clone

Author: jirkasemmler

tests/Backend/Snowflake/WorkspacesReaderTest.php

@@ -3,6 +3,9 @@
 namespace Backend\Snowflake;
 
 use Keboola\Csv\CsvFile;
+use Keboola\StorageApi\Components;
+use Keboola\StorageApi\Options\Components\Configuration;
+use Keboola\StorageApi\Options\Components\ListComponentsOptions;
 use Keboola\StorageApi\Workspaces;
 use Keboola\Test\Backend\WorkspaceConnectionTrait;
 use Keboola\Test\Backend\WorkspaceCredentialsAssertTrait;
@@ -21,15 +24,41 @@ public function setUp(): void
     {
         parent::setUp();
         $this->initEmptyTestBucketsForParallelTests();
+
+        $components = new Components($this->_client);
+        foreach ($components->listComponents() as $component) {
+            foreach ($component['configurations'] as $configuration) {
+                $components->deleteConfiguration($component['id'], $configuration['id']);
+            }
+        }
+
+        // erase all deleted configurations
+        foreach ($components->listComponents((new ListComponentsOptions())->setIsDeleted(true)) as $component) {
+            foreach ($component['configurations'] as $configuration) {
+                $components->deleteConfiguration($component['id'], $configuration['id']);
+            }
+        }
     }
 
     public function testLoadToReaderAccount(): void
     {
+        $componentId = 'wr-db';
+        $configurationId = 'main-1';
         $defaultBranchId = $this->getDefaultBranchId($this);
         $branchClient = $this->getBranchAwareDefaultClient($defaultBranchId);
+        // create configuration
+        $components = new Components($branchClient);
+        $components->addConfiguration((new Configuration())
+            ->setComponentId('wr-db')
+            ->setConfigurationId('main-1')
+            ->setName('TMP_RA jirka')
+            ->setDescription('some desc'));
+
+        $components = new Components($branchClient);
         $workspaces = new Workspaces($branchClient);
 
-        $workspace = $workspaces->createWorkspace(['async' => false, 'useCase' => 'reader']);
+        $workspace = $components->createConfigurationWorkspace($componentId, $configurationId, ['async' => false], false);
+//        $workspace = $components->createConfigurationWorkspace($componentId, $configurationId, ['async' => false, 'useCase' => 'reader'], false);
 
         //setup test tables
         $tableId = $this->_client->createTableAsync(
@@ -39,6 +68,58 @@ public function testLoadToReaderAccount(): void
         );
 
         $workspaces->loadWorkspaceData($workspace['id'], [
+            'input' => [
+                [
+                    'source' => $tableId,
+                    'destination' => 'languages',
+                ],
+                [
+                    'source' => $tableId,
+                    'destination' => 'languagesfiltered',
+                    'overwrite' => false,
+                    'whereColumn' => 'id',
+                    'whereValues' => [1],
+                    'whereOperator' => 'eq',
+                ],
+            ],
+        ]);
+        // create the connection after LOAD!! because the schema will be created by LOAD
+        $db = WorkspaceBackendFactory::createWorkspaceBackend($workspace);
+
+        $data = $db->fetchAll('languages');
+        $this->assertCount(5, $data);
+
+        $data = $db->fetchAll('languagesfiltered');
+        $this->assertCount(1, $data);
+    }
+
+    public function testLoadCloneToReaderAccount(): void
+    {
+        $componentId = 'wr-db';
+        $configurationId = 'main-1';
+        $defaultBranchId = $this->getDefaultBranchId($this);
+        $branchClient = $this->getBranchAwareDefaultClient($defaultBranchId);
+        // create configuration
+        $components = new Components($branchClient);
+        $components->addConfiguration((new Configuration())
+            ->setComponentId('wr-db')
+            ->setConfigurationId('main-1')
+            ->setName('TMP_RA jirka')
+            ->setDescription('some desc'));
+
+        $components = new Components($branchClient);
+        $workspaces = new Workspaces($branchClient);
+
+        $workspace = $components->createConfigurationWorkspace($componentId, $configurationId, ['async' => false], false);
+
+        //setup test tables
+        $tableId = $this->_client->createTableAsync(
+            $this->getTestBucketId(self::STAGE_IN),
+            'languages',
+            new CsvFile(__DIR__ . '/../../_data/languages.csv'),
+        );
+
+        $workspaces->cloneIntoWorkspace($workspace['id'], [
             'input' => [
                 [
                     'source' => $tableId,
@@ -52,9 +133,11 @@ public function testLoadToReaderAccount(): void
         ]);
         // create the connection after LOAD!! because the schema will be created by LOAD
         $db = WorkspaceBackendFactory::createWorkspaceBackend($workspace);
-        $db->executeQuery('select 1');
+
         $data = $db->fetchAll('languages');
+        $this->assertCount(5, $data);
 
+        $data = $db->fetchAll('langs');
         $this->assertCount(5, $data);
     }
 }