TEMP locked pacakges

Signed-off-by: Tim Goudriaan <tim@codedmonkey.com>

Author: codedmonkey

src/Composer/ComposerClient.php

@@ -4,16 +4,24 @@
 
 use CodedMonkey\Dirigent\Doctrine\Entity\Package;
 use CodedMonkey\Dirigent\Doctrine\Entity\Registry;
+use Composer\Composer;
 use Composer\Config;
 use Composer\Factory;
 use Composer\IO\IOInterface;
 use Composer\IO\NullIO;
 use Composer\Repository\ComposerRepository;
 use Composer\Repository\VcsRepository;
 use Composer\Util\HttpDownloader;
+use Composer\Util\Loop;
+use Composer\Util\ProcessExecutor;
 
 class ComposerClient
 {
+    public function getComposer(): Composer
+    {
+
+    }
+
     public function createComposerRepository(Package|Registry $registry, ?IOInterface $io = null, ?Config $config = null): ComposerRepository
     {
         $registry = $registry instanceof Package ? $registry->getMirrorRegistry() : $registry;
@@ -25,6 +33,9 @@ public function createComposerRepository(Package|Registry $registry, ?IOInterfac
         }
         $httpDownloader = $this->createHttpDownloader($io, $config);
 
+        $process = new ProcessExecutor($io);
+        $loop = new Loop($httpDownloader, $process);
+
         return new ComposerRepository(['url' => $registry->getUrl()], $io, $config, $httpDownloader);
     }
 

src/Composer/InMemoryJsonFile.php

@@ -0,0 +1,35 @@
+<?php
+
+/*
+ * © CleverMobi
+ */
+
+declare(strict_types=1);
+
+namespace CodedMonkey\Dirigent\Composer;
+
+use Composer\Json\JsonFile;
+
+class InMemoryJsonFile extends JsonFile
+{
+    public function __construct(
+        private readonly string $contents,
+    ) {
+        parent::__construct('in-memory');
+    }
+
+    public function exists(): bool
+    {
+        return true;
+    }
+
+    public function read(): array
+    {
+        return static::parseJson($this->contents, 'in-memory');
+    }
+
+    public function write(array $hash, int $options = JSON_UNESCAPED_SLASHES | JSON_PRETTY_PRINT | JSON_UNESCAPED_UNICODE)
+    {
+        throw new \LogicException();
+    }
+}

src/Package/PackageMetadataResolver.php

@@ -4,6 +4,8 @@
 
 use cebe\markdown\GithubMarkdown;
 use CodedMonkey\Dirigent\Composer\ComposerClient;
+use CodedMonkey\Dirigent\Composer\ConfigFactory;
+use CodedMonkey\Dirigent\Composer\InMemoryJsonFile;
 use CodedMonkey\Dirigent\Doctrine\Entity\AbstractVersionLink;
 use CodedMonkey\Dirigent\Doctrine\Entity\Package;
 use CodedMonkey\Dirigent\Doctrine\Entity\PackageFetchStrategy;
@@ -21,10 +23,15 @@
 use CodedMonkey\Dirigent\Doctrine\Repository\VersionRepository;
 use CodedMonkey\Dirigent\Message\DumpPackageProvider;
 use CodedMonkey\Dirigent\Message\UpdatePackageLinks;
+use Composer\Installer\InstallationManager;
+use Composer\IO\NullIO;
 use Composer\Package\AliasPackage;
 use Composer\Package\CompletePackageInterface;
+use Composer\Package\Locker;
 use Composer\Pcre\Preg;
 use Composer\Repository\Vcs\VcsDriverInterface;
+use Composer\Util\Loop;
+use Composer\Util\ProcessExecutor;
 use Doctrine\ORM\EntityManagerInterface;
 use Symfony\Component\Messenger\Envelope;
 use Symfony\Component\Messenger\MessageBusInterface;
@@ -120,6 +127,8 @@ private function resolveRegistryPackage(Package $package, ?Registry $registry =
         /** @var CompletePackageInterface[] $composerPackages */
         $composerPackages = $repository->findPackages($packageName);
 
+        dd($composerPackages);
+
         $this->updatePackage($package, $composerPackages);
     }
 
@@ -156,6 +165,10 @@ private function resolveVcsPackage(Package $package): void
         /** @var CompletePackageInterface[] $composerPackages */
         $composerPackages = $repository->findPackages($packageName);
 
+        dump($repository);
+        dump($composerPackages[0]);
+        //dd($composerPackages);
+
         $this->updatePackage($package, $composerPackages, $driver);
     }
 
@@ -213,6 +226,8 @@ private function updatePackage(Package $package, array $composerPackages, ?VcsDr
                 $package->setRepositoryUrl($primaryVersion->getSourceUrl());
             }
 
+            $this->updateInstalledPackages($primaryVersion, $driver);
+
             $message = Envelope::wrap(new UpdatePackageLinks($package->getId(), $primaryVersion->getNormalizedVersion()))
                 ->with(new DispatchAfterCurrentBusStamp())
                 ->with(new TransportNamesStamp('async'));
@@ -431,6 +446,31 @@ private function sanitize(?string $str): ?string
         return Preg::replace("{[\x01-\x1A]}u", '', $str);
     }
 
+    private function updateInstalledPackages(Version $version, VcsDriverInterface $driver): void
+    {
+        $source = $driver->getFileContent('composer.lock', $version->getSource()['reference']);
+
+        if (empty($source)) {
+            return;
+        }
+
+        $jsonFile = new InMemoryJsonFile($source);
+
+        $config = ConfigFactory::createForVcsRepository($version->getPackage()->getRepositoryUrl(), $version->getPackage()->getRepositoryCredentials());
+        $io = new NullIO();
+        $io->loadConfiguration($config);
+        $process = new ProcessExecutor($io);
+        $httpDownloader = $this->composer->createHttpDownloader($io, $config);
+        $loop = new Loop($httpDownloader, $process);
+
+
+        $locker = new Locker($io, $jsonFile, new InstallationManager($loop, $io), $driver->getFileContent('composer.json', $version->getSource()['reference']));
+
+        dump($locker->getLockedRepository());
+        dump($source);
+        dd();
+    }
+
     private function updateReadme(Version $version, VcsDriverInterface $driver): void
     {
         try {