src/CarCutter/ConfigManager.php line 438

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 Pimcore\Model\DataObject\Fieldcollection\Data\ConnMotorFlash;
  35. use Throwable;
  37. class ConfigManager
  38. {
  39.     public static function loadConfigByName(string $name) : ?CustomerConfig
  40.     {
  41.         $list = new CustomerConfig\Listing();
  42.         $list->setCondition('name = :name and enabled = 1', [
  43.             'name' => $name
  44.         ]);
  46.         if($results = $list->load()) {
  47.             return $results[0];
  48.         }
  50.         return null;
  51.     }
  53.     public static function loadConfigByToken(string $token) : ?CustomerConfig
  54.     {
  55.         $list = new CustomerConfig\Listing();
  56.         $list->setCondition('token = :token and enabled = 1', [
  57.             'token' => $token
  58.         ]);
  60.         if($results = $list->load()) {
  61.             return $results[0];
  62.         }
  64.         return null;
  65.     }
  67.     public static function loadAllConfigsByToken(string $token): array
  68.     {
  69.         $list = new CustomerConfig\Listing();
  70.         $list->setCondition('token = :token AND enabled = 1', [
  71.             'token' => $token
  72.         ]);
  74.         return $list->load();
  75.     }
  78.     public static function loadValidConfigs() : array
  79.     {
  80.         $list = new CustomerConfig\Listing();
  81.         $list->setCondition('enabled = 1');
  82.         return $list->load();
  83.     }
  85.     public static function getUploadAdapter(CustomerConfig $config, string $type = '', bool $raw = false) : mixed
  86.     {
  87.         return self::getAdapter($config, ['out', 'bi'], $type, $raw);
  88.     }
  89.     
  92.     public static function getProMaxAdapter(CustomerConfig $config) : mixed
  93.     {
  94.         $availableConnections = self::getConnections($config, ConnProMax::class, []);
  96.         if(count($availableConnections) > 0) {
  97.             return $availableConnections;
  98.         }
  99.         return null;
  100.     }
  102.     public static function getDealerCarSearchAdapter(CustomerConfig $config) : mixed
  103.     {
  104.         $availableConnections = self::getConnections($config, ConnDealerSearch::class, []);
  105.         echo count($availableConnections)." DealerCarSearch Files found\n";
  106.         if(count($availableConnections) > 0) {
  107.             return $availableConnections;
  108.         }
  109.         return null;
  110.     }
  112.     public static function getDealerSyncAdapter(CustomerConfig $config) : mixed
  113.     {
  114.         $availableConnections = self::getConnections($config, ConnDealersync::class, []);
  115.         // echo count($availableConnections)." DealerCarSearch Files found\n";
  116.         if(count($availableConnections) > 0) {
  117.             return $availableConnections;
  118.         }
  119.         return null;
  120.     }
  123.     public static function getDownloadAdapter(CustomerConfig $config, string $type = '', bool $raw = false) : ?FilesystemAdapter
  124.     {
  125.         return self::getAdapter($config, ['in', 'bi'], $type, $raw);
  126.     }
  128.     public static function getBeelinkAdapter(CustomerConfig $config) : mixed
  129.     {
  130.         $availableConnections = self::getConnections($config, ConnBee2Link::class, []);
  132.         if(count($availableConnections) > 0) {
  133.             return $availableConnections;
  134.         }
  135.         return null;
  136.     }
  138.     public static function getOpenFlexAdapter(CustomerConfig $config) : mixed
  139.     {
  140.         $availableConnections = self::getConnections($config, ConnOpenFlex::class, []);
  142.         if(count($availableConnections) > 0) {
  143.             return $availableConnections;
  144.         }
  145.         return null;
  146.     }
  147.     
  148.     public static function getCarBaseAdapter(CustomerConfig $config) : mixed
  149.     {
  150.         $availableConnections = self::getConnections($config, ConnCarbase::class, []);
  152.         if(count($availableConnections) > 0) {
  153.             return $availableConnections;
  154.         }
  155.         return null;
  156.     }
  158.     public static function getWebhookAdapter(CustomerConfig $config) : mixed
  159.     {
  160.         $availableConnections = self::getConnections($config, ConnWebhook::class, []);
  162.         if(count($availableConnections) > 0) {
  163.             return $availableConnections;
  164.         }
  165.         return null;
  166.     }
  168.     public static function getFastbackAdapter(CustomerConfig $config) : mixed
  169.     {
  170.         $availableConnections = self::getConnections($config, ConnFastback::class, []);
  172.         if(count($availableConnections) > 0) {
  173.             echo count($availableConnections)." Fastback connections found\n";
  174.             return $availableConnections;
  175.         }
  177.         return null;
  178.     }
  180.     public static function getWaykeAdapter(CustomerConfig $config) : mixed
  181.     {
  182.         $availableConnections = self::getConnections($config, ConnWayke::class, []);
  184.         if(count($availableConnections) > 0) {
  185.             return $availableConnections;
  186.         }
  188.         return null;
  189.     }
  191.     public static function getDATAdapter(CustomerConfig $config) : mixed
  192.     {
  193.         $availableConnections = self::getConnections($config, ConnDAT::class, []);
  195.         if(count($availableConnections) > 0) {
  196.             echo count($availableConnections)." DAT connections found\n";
  197.             return $availableConnections;
  198.         }
  200.         return null;
  201.     }
  203.     public static function getPlanetVoAdapter(CustomerConfig $config) : mixed
  204.     {
  205.         $availableConnections = self::getConnections($config, ConnPlanetVO::class, []);
  206.         if(count($availableConnections) > 0)
  207.         {
  208.             echo count($availableConnections)." PVO connections found\n";
  209.             return $availableConnections;
  210.         }
  211.         return null;
  212.     }
  214.     public static function getAutoTelexAdapter(CustomerConfig $config) : mixed
  215.     {
  216.         $availableConnections = self::getConnections($config, ConnAutoTelex::class, []);
  217.         if(count($availableConnections) > 0)
  218.         {
  219.             echo count($availableConnections)." AutoTelex connections found\n";
  220.             return $availableConnections;
  221.         }
  222.         return null;
  223.     }
  225.     public static function getKeplerVOAdapter(CustomerConfig $config) : ?ConnKeplerVO
  226.     {
  227.         $availableConnections = self::getConnections($config, ConnKeplerVO::class, []);
  228.         if(count($availableConnections) > 0)
  229.         {
  230.             return array_pop($availableConnections);
  231.         }
  232.         return null;
  233.     }
  235.     public static function getHomeNetAdapter(CustomerConfig $config) : mixed
  236.     {
  237.         $availableConnections = self::getConnections($config, ConnHomeNet::class, []);
  238.         if(count($availableConnections) > 0)
  239.         {
  240.             return $availableConnections;
  241.         }
  242.         //echo "no HomeNet connections found\n";
  243.         return null;
  244.     }
  245.     
  246.     
  247.     public static function getMaxDigitalAdapter(CustomerConfig $config) : mixed
  248.     {
  249.         $availableConnections = self::getConnections($config, ConnMaxDigital::class, []);
  250.         if(count($availableConnections) > 0)
  251.         {
  252.             return $availableConnections;
  253.         }
  254.         //echo "no HomeNet connections found\n";
  255.         return null;
  256.     }
  258.     private static function getAdapter(CustomerConfig $config, array $directions, string $type = '', bool $raw = false) : mixed
  259.     {
  260.         $availableConnections = self::getConnections($config, $type, $directions);
  262.         if(count($availableConnections) > 0) {
  263.             $probe = array_pop($availableConnections);
  265.             if(!$raw && $probe::class === ConnFTPSettings::class)
  266.             {
  267.                 return self::getFtpAdapter($probe);
  268.             }
  269.             elseif ($raw && $probe::class === ConnFTPSettings::class)
  270.             {
  271.                 return $probe;
  272.             }
  273.         }
  274.         return null;
  275.     }
  277.     public static function getFtpAdapter(ConnFTPSettings $config) : ?FtpAdapter
  278.     {
  279.         return new FtpAdapter(
  280.             // Connection options
  281.             \League\Flysystem\Ftp\FtpConnectionOptions::fromArray([
  282.                 'host' => $config->getHostName(), // required
  283.                 'root' => $config->getBaseFolder(), // required
  284.                 'username' => $config->getUser(), // required
  285.                 'password' => $config->getPassword(), // required
  286.                 'port' => intval($config->getPort()),
  287.                 'ssl' => $config->getSsl(),
  288.                 'timeout' => 90,
  289.                 'utf8' => $config->getUseUtf(),
  290.                 'passive' => true,
  291.                 'transferMode' => FTP_BINARY,
  292.                 'systemType' => null, // 'windows' or 'unix'
  293.                 'ignorePassiveAddress' => $config->getIgnorePassiveAddress(), // true or false
  294.                 'timestampsOnUnixListingsEnabled' => false, // true or false
  295.                 'recurseManually' => true // true
  296.             ])
  297.         );
  298.     }
  300.     public static function getOpenSshKeyContent(): string
  301.     {
  302.         // Your Ed25519 key in OpenSSH format
  303.         return '
  304. -----BEGIN OPENSSH PRIVATE KEY-----
  305. b3BlbnNzaC1rZXktdjEAAAAABG5vbmUAAAAEbm9uZQAAAAAAAAABAAAAMwAAAAtzc2gtZW
  306. QyNTUxOQAAACBsrD0ryU8Z6Kpxqp+oqq1l8IazPkIgBSu4dAPmDUjWywAAAJAsMenSLDHp
  307. 0gAAAAtzc2gtZWQyNTUxOQAAACBsrD0ryU8Z6Kpxqp+oqq1l8IazPkIgBSu4dAPmDUjWyw
  308. AAAEAOggxruNr75XIGp8lF0g7SMUt/WnIs8/foHcpD4aX47WysPSvJTxnoqnGqn6iqrWXw
  309. hrM+QiAFK7h0A+YNSNbLAAAACmNhcmNlbnRyYWwBAgM=
  310. -----END OPENSSH PRIVATE KEY-----
  311.         ';
  312.     }
  314.     public static function findLatestDealerCenterFile(Filesystem $filesystem, string $dealerId): ?string
  315. {
  316.     try {
  317.         echo "[DEBUG] Searching for DealerCenter files with dealer ID: '$dealerId'\n";
  318.         
  319.         $files = $filesystem->listContents('/', false);
  320.         $dealerCenterFiles = [];
  321.         
  322.         foreach ($files as $file) {
  323.             if ($file->isFile()) {
  324.                 $fileName = basename($file->path());
  325.                 
  326.                 if (preg_match("/^DealerCenter[_\s](\d{8})[_\s](\d+)\.csv$/i", $fileName, $matches)) {
  327.                     $fileDate = $matches[1];
  328.                     $fileDealerId = $matches[2];
  329.                     
  330.                     echo "[DEBUG] Found file: $fileName (date: $fileDate, dealer: $fileDealerId)\n";
  331.                     
  332.                     // Compare dealer IDs
  333.                     if ($fileDealerId === $dealerId) {
  334.                         $dealerCenterFiles[$fileDate] = $file->path();
  335.                         echo "[DEBUG] ✓ File matches dealer ID '$dealerId'\n";
  336.                     }
  337.                 }
  338.             }
  339.         }
  340.         
  341.         if (empty($dealerCenterFiles)) {
  342.             echo "❌ No DealerCenter files found for dealer ID: $dealerId\n";
  343.             echo "[DEBUG] Make sure the dealer ID is numeric and matches the filename pattern.\n";
  344.             return null;
  345.         }
  346.         
  347.         // Get the latest file by date (newest first)
  348.         krsort($dealerCenterFiles);
  349.         $latestDate = array_key_first($dealerCenterFiles);
  350.         $latestFile = $dealerCenterFiles[$latestDate];
  351.         
  352.         echo "✅ Found latest DealerCenter file: $latestFile (date: $latestDate)\n";
  353.         return $latestFile;
  354.         
  355.     } catch (Exception $e) {
  356.         echo "❌ Error finding DealerCenter files: " . $e->getMessage() . "\n";
  357.         return null;
  358.     }
  359. }
  360.     //public static function findLatestDealerCenterFile(Filesystem $filesystem, string $dealerId): ?string
  361.     //{
  362.     //    try {
  363.     //        $files = $filesystem->listContents('/', false);
  364.     //        $dealerCenterFiles = [];
  365.     //        
  366.     //        foreach ($files as $file) {
  367.     //            $fileName = basename($file->path());
  368.     //            if ($file->isFile() && preg_match("/^DealerCenter_(\d{8})_{$dealerId}\.csv$/", $fileName, $matches)) {
  369.     //                $dealerCenterFiles[$matches[1]] = $file->path();
  370.     //            }
  371.     //        }
  372.     //        
  373.     //        if (empty($dealerCenterFiles)) {
  374.     //            echo "No DealerCenter files found for dealer ID: $dealerId\n";
  375.     //            return null;
  376.     //        }
  377.     //        
  378.     //        // Get the latest file by date
  379.     //        ksort($dealerCenterFiles);
  380.     //        $latestDate = array_key_last($dealerCenterFiles);
  381.     //        $latestFile = $dealerCenterFiles[$latestDate];
  382.     //        
  383.     //        echo "Found latest DealerCenter file: $latestFile (date: $latestDate)\n";
  384.     //        return $latestFile;
  385.     //        
  386.     //    } catch (Exception $e) {
  387.     //        echo "Error finding DealerCenter files: " . $e->getMessage() . "\n";
  388.     //        return null;
  389.     //    }
  390.     //}
  392.     
  393.     public static function getSftpAdapter(array $config): ?SftpAdapter
  394.     {
  395.         
  396.         try {
  398.             //  to be handled such that it takes token / client type and rerturn respective key
  399.             // $inst = new self();
  400.             // $privateKey = self::getOpenSshKeyContent();
  402.             print_r($config['user']);
  403.             $connectionProvider = new SftpConnectionProvider(
  404.                 $config['host'],
  405.                 $config['user'],
  406.                 $config['password'] ?: null,
  407.                 $config['openssh_key'] ?: null,
  408.                 null ,
  409.                 intval($config['port'] ?: 22),
  410.                 false,   // use agent
  411.                 30,      // timeout
  412.                 10,      // max tries
  413.                 null,    // host fingerprint
  414.                 null     // connectivity checker
  415.             );
  417.             $adapter = new SftpAdapter(
  418.                 $connectionProvider,
  419.                  '/'
  420.             );
  422.             // ✅ Verify connectivity by trying a simple operation
  423.             $filesystem = new Filesystem($adapter);
  424.             $filesystem->listContents('.', false);
  426.             // echo" File system -> "+$filesystem;
  429.             return $adapter;
  430.         } catch (Throwable $e) {
  431.             // ❌ Handle connection/adapter errors gracefully
  432.             error_log("SFTP connection failed: " . $e->getMessage());
  433.             echo "❌ Error: " . $e->getMessage() . PHP_EOL;
  434.             print_r($e->getTrace());
  435.             return null;  // or throw new \RuntimeException("SFTP Error: " . $e->getMessage());
  436.         }
  437.     }
  439.     public static function getConnections(CustomerConfig $config, string $type = '', array $directions) : mixed
  440.     {
  441.         $connections = $config->getConnections();
  443.         if($connections->getCount() === 0) {
  444.             return [];
  445.         }
  447.         $connItems = $connections->getItems();
  448.         $availableConnections = array_filter($connItems, function($c) use ($type, $directions) {
  449.             if($type === '' || $c::class === $type) {
  451.                 if(method_exists($c, 'getDirection')) {
  452.                     if(in_array($c->getDirection(), $directions)) {
  453.                         return true;
  454.                     }
  455.                 } else {
  456.                     return true;
  457.                 }
  458.             }
  459.             return false;
  460.         });
  462.         return $availableConnections;
  463.     }
  464.     public static function getDealerCenterAdapter($config): array
  465.     {
  466.         $connections = $config->getConnections();
  467.         $dealerCenterConnections = [];
  469.         if ($connections) {
  470.             foreach ($connections->getItems() as $item) {
  471.                 if ($item instanceof ConnDealerCenter) {
  472.                     $dealerCenterConnections[] = $item;
  473.                 }
  474.             }
  475.         }
  477.         return $dealerCenterConnections;
  478.     }
  480.     public static function getMotorFlashAdapter(CustomerConfig $config) : mixed
  481.     {
  482.         $availableConnections = self::getConnections($config, ConnMotorFlash::class, []);
  484.         if(count($availableConnections) > 0) {
  485.             echo count($availableConnections)." MotorFlash connections found\n";
  486.             return $availableConnections;
  487.         }
  489.         return null;
  490.     }
  492. }
  493.