src/CarCutter/ConfigManager.php line 392

Open in your IDE?
  1. <?php
  3. /**
  4.  * Carcutter Data Platform
  5.  * Configuration Manager
  6.  */
  8. namespace App\CarCutter;
  10. use League\Flysystem\FilesystemAdapter;
  11. use League\Flysystem\Filesystem;
  12. use League\Flysystem\Ftp\FtpAdapter;
  13. use Pimcore\Model\DataObject\CustomerConfig;
  14. use League\Flysystem\PhpseclibV3\SftpAdapter;
  15. use League\Flysystem\PhpseclibV3\SftpConnectionProvider;
  16. use Pimcore\Model\DataObject\Fieldcollection\Data\ConnAutoGestion;
  17. use Pimcore\Model\DataObject\Fieldcollection\Data\ConnBee2Link;
  18. use Pimcore\Model\DataObject\Fieldcollection\Data\ConnFTPSettings;
  19. use Pimcore\Model\DataObject\Fieldcollection\Data\ConnKeplerVO;
  20. use Pimcore\Model\DataObject\Fieldcollection\Data\ConnPlanetVO;
  21. use Pimcore\Model\DataObject\Fieldcollection\Data\ConnHomeNet;
  22. use Pimcore\Model\DataObject\Fieldcollection\Data\ConnMaxDigital;
  23. use Pimcore\Model\DataObject\Fieldcollection\Data\ConnDAT;
  24. use Pimcore\Model\DataObject\Fieldcollection\Data\ConnProMax;
  25. use Pimcore\Model\DataObject\Fieldcollection\Data\ConnDealerSearch;
  26. use Pimcore\Model\DataObject\Fieldcollection\Data\ConnDealersync;
  27. use Pimcore\Model\DataObject\Fieldcollection\Data\ConnCarbase;
  28. use Pimcore\Model\DataObject\Fieldcollection\Data\ConnWayke;
  29. use Pimcore\Model\DataObject\Fieldcollection\Data\ConnFastback;
  30. use Pimcore\Model\DataObject\Fieldcollection\Data\ConnAutoTelex;
  31. use Pimcore\Model\DataObject\Fieldcollection\Data\ConnOpenFlex;
  32. use Pimcore\Model\DataObject\Fieldcollection\Data\ConnWebhook;
  33. use Pimcore\Model\DataObject\Fieldcollection\Data\ConnDealerCenter;
  34. use Throwable;
  36. class ConfigManager
  37. {
  38.     public static function loadConfigByName(string $name) : ?CustomerConfig
  39.     {
  40.         $list = new CustomerConfig\Listing();
  41.         $list->setCondition('name = :name and enabled = 1', [
  42.             'name' => $name
  43.         ]);
  45.         if($results = $list->load()) {
  46.             return $results[0];
  47.         }
  49.         return null;
  50.     }
  52.     public static function loadConfigByToken(string $token) : ?CustomerConfig
  53.     {
  54.         $list = new CustomerConfig\Listing();
  55.         $list->setCondition('token = :token and enabled = 1', [
  56.             'token' => $token
  57.         ]);
  59.         if($results = $list->load()) {
  60.             return $results[0];
  61.         }
  63.         return null;
  64.     }
  66.     public static function loadAllConfigsByToken(string $token): array
  67.     {
  68.         $list = new CustomerConfig\Listing();
  69.         $list->setCondition('token = :token AND enabled = 1', [
  70.             'token' => $token
  71.         ]);
  73.         return $list->load();
  74.     }
  77.     public static function loadValidConfigs() : array
  78.     {
  79.         $list = new CustomerConfig\Listing();
  80.         $list->setCondition('enabled = 1');
  81.         return $list->load();
  82.     }
  84.     public static function getUploadAdapter(CustomerConfig $config, string $type = '', bool $raw = false) : mixed
  85.     {
  86.         return self::getAdapter($config, ['out', 'bi'], $type, $raw);
  87.     }
  88.     
  91.     public static function getProMaxAdapter(CustomerConfig $config) : mixed
  92.     {
  93.         $availableConnections = self::getConnections($config, ConnProMax::class, []);
  95.         if(count($availableConnections) > 0) {
  96.             return $availableConnections;
  97.         }
  98.         return null;
  99.     }
  101.     public static function getDealerCarSearchAdapter(CustomerConfig $config) : mixed
  102.     {
  103.         $availableConnections = self::getConnections($config, ConnDealerSearch::class, []);
  104.         echo count($availableConnections)." DealerCarSearch Files found\n";
  105.         if(count($availableConnections) > 0) {
  106.             return $availableConnections;
  107.         }
  108.         return null;
  109.     }
  111.     public static function getDealerSyncAdapter(CustomerConfig $config) : mixed
  112.     {
  113.         $availableConnections = self::getConnections($config, ConnDealersync::class, []);
  114.         // echo count($availableConnections)." DealerCarSearch Files found\n";
  115.         if(count($availableConnections) > 0) {
  116.             return $availableConnections;
  117.         }
  118.         return null;
  119.     }
  122.     public static function getDownloadAdapter(CustomerConfig $config, string $type = '', bool $raw = false) : ?FilesystemAdapter
  123.     {
  124.         return self::getAdapter($config, ['in', 'bi'], $type, $raw);
  125.     }
  127.     public static function getBeelinkAdapter(CustomerConfig $config) : mixed
  128.     {
  129.         $availableConnections = self::getConnections($config, ConnBee2Link::class, []);
  131.         if(count($availableConnections) > 0) {
  132.             return $availableConnections;
  133.         }
  134.         return null;
  135.     }
  137.     public static function getOpenFlexAdapter(CustomerConfig $config) : mixed
  138.     {
  139.         $availableConnections = self::getConnections($config, ConnOpenFlex::class, []);
  141.         if(count($availableConnections) > 0) {
  142.             return $availableConnections;
  143.         }
  144.         return null;
  145.     }
  146.     
  147.     public static function getCarBaseAdapter(CustomerConfig $config) : mixed
  148.     {
  149.         $availableConnections = self::getConnections($config, ConnCarbase::class, []);
  151.         if(count($availableConnections) > 0) {
  152.             return $availableConnections;
  153.         }
  154.         return null;
  155.     }
  157.     public static function getWebhookAdapter(CustomerConfig $config) : mixed
  158.     {
  159.         $availableConnections = self::getConnections($config, ConnWebhook::class, []);
  161.         if(count($availableConnections) > 0) {
  162.             return $availableConnections;
  163.         }
  164.         return null;
  165.     }
  167.     public static function getFastbackAdapter(CustomerConfig $config) : mixed
  168.     {
  169.         $availableConnections = self::getConnections($config, ConnFastback::class, []);
  171.         if(count($availableConnections) > 0) {
  172.             echo count($availableConnections)." Fastback connections found\n";
  173.             return $availableConnections;
  174.         }
  176.         return null;
  177.     }
  179.     public static function getWaykeAdapter(CustomerConfig $config) : mixed
  180.     {
  181.         $availableConnections = self::getConnections($config, ConnWayke::class, []);
  183.         if(count($availableConnections) > 0) {
  184.             return $availableConnections;
  185.         }
  187.         return null;
  188.     }
  190.     public static function getDATAdapter(CustomerConfig $config) : mixed
  191.     {
  192.         $availableConnections = self::getConnections($config, ConnDAT::class, []);
  194.         if(count($availableConnections) > 0) {
  195.             echo count($availableConnections)." DAT connections found\n";
  196.             return $availableConnections;
  197.         }
  199.         return null;
  200.     }
  202.     public static function getPlanetVoAdapter(CustomerConfig $config) : mixed
  203.     {
  204.         $availableConnections = self::getConnections($config, ConnPlanetVO::class, []);
  205.         if(count($availableConnections) > 0)
  206.         {
  207.             echo count($availableConnections)." PVO connections found\n";
  208.             return $availableConnections;
  209.         }
  210.         return null;
  211.     }
  213.     public static function getAutoTelexAdapter(CustomerConfig $config) : mixed
  214.     {
  215.         $availableConnections = self::getConnections($config, ConnAutoTelex::class, []);
  216.         if(count($availableConnections) > 0)
  217.         {
  218.             echo count($availableConnections)." AutoTelex connections found\n";
  219.             return $availableConnections;
  220.         }
  221.         return null;
  222.     }
  224.     public static function getKeplerVOAdapter(CustomerConfig $config) : ?ConnKeplerVO
  225.     {
  226.         $availableConnections = self::getConnections($config, ConnKeplerVO::class, []);
  227.         if(count($availableConnections) > 0)
  228.         {
  229.             return array_pop($availableConnections);
  230.         }
  231.         return null;
  232.     }
  234.     public static function getHomeNetAdapter(CustomerConfig $config) : mixed
  235.     {
  236.         $availableConnections = self::getConnections($config, ConnHomeNet::class, []);
  237.         if(count($availableConnections) > 0)
  238.         {
  239.             return $availableConnections;
  240.         }
  241.         //echo "no HomeNet connections found\n";
  242.         return null;
  243.     }
  244.     
  245.     
  246.     public static function getMaxDigitalAdapter(CustomerConfig $config) : mixed
  247.     {
  248.         $availableConnections = self::getConnections($config, ConnMaxDigital::class, []);
  249.         if(count($availableConnections) > 0)
  250.         {
  251.             return $availableConnections;
  252.         }
  253.         //echo "no HomeNet connections found\n";
  254.         return null;
  255.     }
  257.     private static function getAdapter(CustomerConfig $config, array $directions, string $type = '', bool $raw = false) : mixed
  258.     {
  259.         $availableConnections = self::getConnections($config, $type, $directions);
  261.         if(count($availableConnections) > 0) {
  262.             $probe = array_pop($availableConnections);
  264.             if(!$raw && $probe::class === ConnFTPSettings::class)
  265.             {
  266.                 return self::getFtpAdapter($probe);
  267.             }
  268.             elseif ($raw && $probe::class === ConnFTPSettings::class)
  269.             {
  270.                 return $probe;
  271.             }
  272.         }
  273.         return null;
  274.     }
  276.     public static function getFtpAdapter(ConnFTPSettings $config) : ?FtpAdapter
  277.     {
  278.         return new FtpAdapter(
  279.             // Connection options
  280.             \League\Flysystem\Ftp\FtpConnectionOptions::fromArray([
  281.                 'host' => $config->getHostName(), // required
  282.                 'root' => $config->getBaseFolder(), // required
  283.                 'username' => $config->getUser(), // required
  284.                 'password' => $config->getPassword(), // required
  285.                 'port' => intval($config->getPort()),
  286.                 'ssl' => $config->getSsl(),
  287.                 'timeout' => 90,
  288.                 'utf8' => $config->getUseUtf(),
  289.                 'passive' => true,
  290.                 'transferMode' => FTP_BINARY,
  291.                 'systemType' => null, // 'windows' or 'unix'
  292.                 'ignorePassiveAddress' => $config->getIgnorePassiveAddress(), // true or false
  293.                 'timestampsOnUnixListingsEnabled' => false, // true or false
  294.                 'recurseManually' => true // true
  295.             ])
  296.         );
  297.     }
  299.     public static function getOpenSshKeyContent(): string
  300.     {
  301.         // Your Ed25519 key in OpenSSH format
  302.         return '
  303. -----BEGIN OPENSSH PRIVATE KEY-----
  304. b3BlbnNzaC1rZXktdjEAAAAABG5vbmUAAAAEbm9uZQAAAAAAAAABAAAAMwAAAAtzc2gtZW
  305. QyNTUxOQAAACBsrD0ryU8Z6Kpxqp+oqq1l8IazPkIgBSu4dAPmDUjWywAAAJAsMenSLDHp
  306. 0gAAAAtzc2gtZWQyNTUxOQAAACBsrD0ryU8Z6Kpxqp+oqq1l8IazPkIgBSu4dAPmDUjWyw
  307. AAAEAOggxruNr75XIGp8lF0g7SMUt/WnIs8/foHcpD4aX47WysPSvJTxnoqnGqn6iqrWXw
  308. hrM+QiAFK7h0A+YNSNbLAAAACmNhcmNlbnRyYWwBAgM=
  309. -----END OPENSSH PRIVATE KEY-----
  310.         ';
  311.     }
  313.     public static function findLatestDealerCenterFile(Filesystem $filesystem, string $dealerId): ?string
  314.     {
  315.         try {
  316.             $files = $filesystem->listContents('/', false);
  317.             $dealerCenterFiles = [];
  318.             
  319.             foreach ($files as $file) {
  320.                 $fileName = basename($file->path());
  321.                 if ($file->isFile() && preg_match("/^DealerCenter_(\d{8})_{$dealerId}\.csv$/", $fileName, $matches)) {
  322.                     $dealerCenterFiles[$matches[1]] = $file->path();
  323.                 }
  324.             }
  325.             
  326.             if (empty($dealerCenterFiles)) {
  327.                 echo "No DealerCenter files found for dealer ID: $dealerId\n";
  328.                 return null;
  329.             }
  330.             
  331.             // Get the latest file by date
  332.             ksort($dealerCenterFiles);
  333.             $latestDate = array_key_last($dealerCenterFiles);
  334.             $latestFile = $dealerCenterFiles[$latestDate];
  335.             
  336.             echo "Found latest DealerCenter file: $latestFile (date: $latestDate)\n";
  337.             return $latestFile;
  338.             
  339.         } catch (Exception $e) {
  340.             echo "Error finding DealerCenter files: " . $e->getMessage() . "\n";
  341.             return null;
  342.         }
  343.     }
  345.     
  346.     public static function getSftpAdapter(array $config): ?SftpAdapter
  347.     {
  348.         
  349.         try {
  351.             //  to be handled such that it takes token / client type and rerturn respective key
  352.             // $inst = new self();
  353.             // $privateKey = self::getOpenSshKeyContent();
  355.             print_r($config['user']);
  356.             $connectionProvider = new SftpConnectionProvider(
  357.                 $config['host'],
  358.                 $config['user'],
  359.                 $config['password'] ?: null,
  360.                 $config['openssh_key'] ?: null,
  361.                 null ,
  362.                 intval($config['port'] ?: 22),
  363.                 false,   // use agent
  364.                 30,      // timeout
  365.                 10,      // max tries
  366.                 null,    // host fingerprint
  367.                 null     // connectivity checker
  368.             );
  370.             $adapter = new SftpAdapter(
  371.                 $connectionProvider,
  372.                  '/'
  373.             );
  375.             // ✅ Verify connectivity by trying a simple operation
  376.             $filesystem = new Filesystem($adapter);
  377.             $filesystem->listContents('.', false);
  379.             // echo" File system -> "+$filesystem;
  382.             return $adapter;
  383.         } catch (Throwable $e) {
  384.             // ❌ Handle connection/adapter errors gracefully
  385.             error_log("SFTP connection failed: " . $e->getMessage());
  386.             echo "❌ Error: " . $e->getMessage() . PHP_EOL;
  387.             print_r($e->getTrace());
  388.             return null;  // or throw new \RuntimeException("SFTP Error: " . $e->getMessage());
  389.         }
  390.     }
  392.     public static function getConnections(CustomerConfig $config, string $type = '', array $directions) : mixed
  393.     {
  394.         $connections = $config->getConnections();
  396.         if($connections->getCount() === 0) {
  397.             return [];
  398.         }
  400.         $connItems = $connections->getItems();
  401.         $availableConnections = array_filter($connItems, function($c) use ($type, $directions) {
  402.             if($type === '' || $c::class === $type) {
  404.                 if(method_exists($c, 'getDirection')) {
  405.                     if(in_array($c->getDirection(), $directions)) {
  406.                         return true;
  407.                     }
  408.                 } else {
  409.                     return true;
  410.                 }
  411.             }
  412.             return false;
  413.         });
  415.         return $availableConnections;
  416.     }
  417.     public static function getDealerCenterAdapter($config): array
  418.     {
  419.         $connections = $config->getConnections();
  420.         $dealerCenterConnections = [];
  422.         if ($connections) {
  423.             foreach ($connections->getItems() as $item) {
  424.                 if ($item instanceof ConnDealerCenter) {
  425.                     $dealerCenterConnections[] = $item;
  426.                 }
  427.             }
  428.         }
  430.         return $dealerCenterConnections;
  431.     }
  433. }
  434.