use generator without AOP

eMAGTechLabs · Dec 7, 2016 · 47d0f3c · 47d0f3c
1 parent 167999c
commit 47d0f3c
Show file tree

Hide file tree

Showing 19 changed files with 671 additions and 172 deletions.
diff --git a/app/AppKernel.php b/app/AppKernel.php
diff --git a/app/config.yml b/app/config.yml
@@ -1,17 +1,16 @@
 parameters:
   cache.service: cache.service
 
-jms_aop:
-    cache_dir: %kernel.cache_dir%/jms_aop
-
-
 monolog:
     handlers:
         main:
             type:  test
             level: info
 
 services:
+   cache_warmer:
+      class: Symfony\Component\HttpKernel\CacheWarmer\CacheWarmerAggregate
+      arguments: [""]
    cache.service:
       class: Symfony\Component\Cache\Adapter\ArrayAdapter
    cache.testservice:

diff --git a/composer.json b/composer.json
@@ -10,8 +10,8 @@
     }
   ],
   "require": {
-    "php": ">=5.6",
-    "jms/aop-bundle": "1.*",
+    "php": ">=7.0",
+    "ocramius/proxy-manager": "@stable",
     "psr/log": "~1",
     "psr/cache": "1.0.*",
     "doctrine/annotations": "@stable"
@@ -31,8 +31,7 @@
     "symfony/framework-bundle": "@stable"
   },
   "autoload": {
-    "psr-4": { "CacheBundle\\": "src/CacheBundle" },
-    "psr-0": { "CacheBundle\\Annotation": "src/" }
+    "psr-4": { "CacheBundle\\": "src/CacheBundle/" }
   },
   "config": {
     "optimize-autoloader": true

diff --git a/src/CacheBundle/CacheBundle.php b/src/CacheBundle/CacheBundle.php
@@ -2,16 +2,33 @@
 
 namespace CacheBundle;
 
-use Symfony\Component\DependencyInjection\Compiler\PassConfig;
+use CacheBundle\DependencyInjection\CacheCompilerPass;
 use Symfony\Component\DependencyInjection\ContainerBuilder;
+use Symfony\Component\Filesystem\Filesystem;
 use Symfony\Component\HttpKernel\Bundle\Bundle;
 
 class CacheBundle extends Bundle
 {
+    protected $autoloader;
+    /** @var  \ProxyManager\Configuration */
+    protected $config;
+    protected $getProxyConfig;
+
+    public function shutdown()
+    {
+        spl_autoload_unregister($this->container->get('emag.cache.proxy.config')->getProxyAutoloader());
+    }
+
+    public function boot()
+    {
+        $this->autoloader = spl_autoload_register($this->container->get('emag.cache.proxy.config')->getProxyAutoloader());
+    }
+
     public function build(ContainerBuilder $container)
     {
-        parent::build($container);
+        $compilerPass = new CacheCompilerPass();
 
-        $container->addCompilerPass(new CacheCompilerPass(), PassConfig::TYPE_OPTIMIZE);
+        $container->addCompilerPass($compilerPass);
+        parent::build($container);
     }
 }
diff --git a/src/CacheBundle/CacheCompilerPass.php b/src/CacheBundle/CacheCompilerPass.php
diff --git a/src/CacheBundle/ContextAwareCache.php b/src/CacheBundle/ContextAwareCache.php
diff --git a/src/CacheBundle/DependencyInjection/CacheCompilerPass.php b/src/CacheBundle/DependencyInjection/CacheCompilerPass.php
@@ -0,0 +1,86 @@
+<?php
+
+namespace CacheBundle\DependencyInjection;
+
+
+use CacheBundle\Annotation\Cache;
+use Doctrine\Common\Annotations\AnnotationReader;
+use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
+use Symfony\Component\DependencyInjection\ContainerBuilder;
+use Symfony\Component\DependencyInjection\Definition;
+use Symfony\Component\DependencyInjection\Exception\BadMethodCallException;
+use Symfony\Component\DependencyInjection\Reference;
+use Symfony\Component\Filesystem\Filesystem;
+
+class CacheCompilerPass implements CompilerPassInterface
+{
+    /**
+     * You can modify the container here before it is dumped to PHP code.
+     *
+     * @param ContainerBuilder $container
+     *
+     * @api
+     */
+    public function process(ContainerBuilder $container)
+    {
+        $fs = new Filesystem();
+        $fs->mkdir(
+            str_replace(
+                '%kernel.cache_dir%',
+                $container->getParameter('kernel.cache_dir'),
+                $container->getParameter('emag.cacheable.service.path')
+            )
+        );
+
+
+        $this->proxyServicesToBeCached($container);
+    }
+
+    /**
+     * @param ContainerBuilder $container
+     * @return array
+     */
+    protected function proxyServicesToBeCached(ContainerBuilder $container)
+    {
+        $annotationReader = new AnnotationReader();
+        $servicesToBeCached = [];
+        foreach ($container->getDefinitions() as $serviceId => $definition) {
+            if ($definition->getClass() === null) {
+                continue;
+            }
+            $originalReflection = new \ReflectionClass($definition->getClass());
+            foreach ($originalReflection->getMethods() as $method) {
+                if ($annotation = $annotationReader->getMethodAnnotation($method, Cache::class)) {
+                    if ($method->isFinal()) {
+                        throw new BadMethodCallException('Final methods can not be cached!');
+                    }
+                    if ($method->isAbstract()) {
+                        throw new BadMethodCallException('Abstract methods can not be cached!');
+                    }
+                    if ($method->isStatic()) {
+                        throw new BadMethodCallException('Static methods can not be cached!');
+                    }
+
+                    $factory = new Definition($definition->getClass());
+                    $factory->setFactory([new Reference('emag.cache.proxy.factory'), 'generate']);
+                    $factory->setTags($definition->getTags());
+                    $factory->setArguments([$definition->getClass(), $definition->getArguments()]);
+                    $factory->setMethodCalls($definition->getMethodCalls());
+                    $factory->setProperties($definition->getProperties());
+                    $factory->setProperties($definition->getProperties());
+                    $factory->addMethodCall('setReaderForCacheMethod', [new Reference("annotation_reader")]);
+                    $factory->addMethodCall('setCacheServiceForMethod', [new Reference($container->getParameter('cache.service'))]);
+                    $container->getDefinition('emag.cache.warmup')->addMethodCall('addClassToGenerate', [$definition->getClass()]);
+
+
+                    $container->setDefinition($serviceId, $factory);
+                    break;
+                }
+            }
+        }
+
+        return $servicesToBeCached;
+    }
+
+
+}
diff --git a/src/CacheBundle/DependencyInjection/CacheExtension.php b/src/CacheBundle/DependencyInjection/CacheExtension.php
@@ -18,8 +18,12 @@ class CacheExtension extends Extension
     /**
      * @inheritdoc
      */
-    public function load(array $config, ContainerBuilder $container)
+    public function load(array $configs, ContainerBuilder $container)
     {
-        // TODO: Implement load() method.
+        $configuration = new Configuration();
+        $config = $this->processConfiguration($configuration, $configs);
+
+        $loader = new Loader\YamlFileLoader($container, new FileLocator(__DIR__.'/../Resources/config'));
+        $loader->load('services.yml');
     }
 }
diff --git a/src/CacheBundle/DependencyInjection/PointCut.php b/src/CacheBundle/DependencyInjection/PointCut.php