Spaces:
No application file
No application file
File size: 4,718 Bytes
d2897cd |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 |
<?php
declare(strict_types=1);
namespace Mautic\IntegrationsBundle\Tests\Functional\Services\SyncService;
use Doctrine\DBAL\Connection;
use Mautic\CoreBundle\Test\MauticMysqlTestCase;
use Mautic\InstallBundle\InstallFixtures\ORM\LeadFieldData;
use Mautic\IntegrationsBundle\Sync\SyncDataExchange\Internal\Object\Contact;
use Mautic\IntegrationsBundle\Sync\SyncService\SyncService;
use Mautic\IntegrationsBundle\Tests\Functional\Services\SyncService\TestExamples\Integration\ExampleIntegration;
use Mautic\IntegrationsBundle\Tests\Functional\Services\SyncService\TestExamples\Sync\SyncDataExchange\ExampleSyncDataExchange;
use Mautic\LeadBundle\DataFixtures\ORM\LoadLeadData;
use Mautic\PluginBundle\Entity\Integration;
class SyncServiceTest extends MauticMysqlTestCase
{
public function setUp(): void
{
parent::setUp();
// Populate contacts
$this->installDatabaseFixtures([LeadFieldData::class, LoadLeadData::class]);
}
public function testSync(): void
{
$this->markTestSkipped('disabled for now');
// Sleep one second to ensure that the modified date/time stamps of the contacts just created are in the past
sleep(1);
$prefix = $this->container->getParameter('mautic.db_table_prefix');
$dataExchange = new ExampleSyncDataExchange();
$exampleIntegration = new ExampleIntegration($dataExchange);
$settings = new Integration();
$settings->setFeatureSettings(['sync' => ['objects' => [Contact::NAME]]]);
$settings->setIsPublished(true);
$exampleIntegration->setIntegrationConfiguration($settings);
$syncIntegrationsHelper = $this->container->get('mautic.integrations.helper.sync_integrations');
$syncIntegrationsHelper->addIntegration($exampleIntegration);
/** @var SyncService $syncService */
$syncService = $this->container->get('mautic.integrations.sync.service');
$syncService->processIntegrationSync(ExampleIntegration::NAME, true);
$payload = $dataExchange->getOrderPayload();
// Created the 48 known contacts already in Mautic
$this->assertCount(48, $payload['create']);
$this->assertCount(2, $payload['update']);
$this->assertEquals(
[
4 => [
'id' => 4,
'object' => ExampleSyncDataExchange::OBJECT_LEAD,
'first_name' => 'Lewis',
'last_name' => 'Syed',
'email' => '[email protected]',
'street1' => '107 Yorkie Lane',
],
3 => [
'id' => 3,
'object' => ExampleSyncDataExchange::OBJECT_LEAD,
'first_name' => 'Nellie',
'last_name' => 'Baird',
'email' => '[email protected]',
'street1' => '1930 Uitsig St',
],
],
$payload['update']
);
// Validate mapping table
/** @var Connection $connection */
// All should be mapped to the OBJECT_LEAD object
$qb = $this->connection->createQueryBuilder();
$results = $qb->select('count(*) as the_count, m.integration_object_name, m.integration')
->from($prefix.'sync_object_mapping', 'm')
->groupBy('m.integration, m.integration_object_name')
->execute()
->fetchAllAssociative();
$this->assertCount(1, $results);
$this->assertEquals(ExampleIntegration::NAME, $results[0]['integration']);
$this->assertEquals(ExampleSyncDataExchange::OBJECT_LEAD, $results[0]['integration_object_name']);
// All should be mapped to the Mautic contact object
$qb = $this->connection->createQueryBuilder();
$results = $qb->select('count(*) as the_count, m.internal_object_name, m.integration')
->from($prefix.'sync_object_mapping', 'm')
->groupBy('m.integration, m.internal_object_name')
->execute()
->fetchAllAssociative();
$this->assertCount(1, $results);
$this->assertEquals(ExampleIntegration::NAME, $results[0]['integration']);
$this->assertEquals(Contact::NAME, $results[0]['internal_object_name']);
// There should be 50 entries
$qb = $this->connection->createQueryBuilder();
$results = $qb->select('count(*) as the_count')
->from($prefix.'sync_object_mapping', 'm')
->execute()
->fetchAllAssociative();
$this->assertEquals(50, $results[0]['the_count']);
}
}
|