PropelDataCacheBehavior/src/DataCacheBehaviorPeerBuilderModifier.php at 6ccf4678f2d0e6372ed65da04a5fd9496d43c74e · SNakano/PropelDataCacheBehavior · GitHub

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
115
116
117
118
119
120
121
122
123
124
125
126
<?php
/**
 * Propel Data Cache Behavior
 *
 * @copyright Copyright (c) 2013 Domino Co. Ltd.
 * @license MIT
 * @package propel.generator.behavior
 */

/**
 * Propel Data Cache Behavior Peer Builder Modifier
 *
 * @copyright Copyright (c) 2013 Domino Co. Ltd.
 * @license MIT
 * @package propel.generator.behavior
 */
class DataCacheBehaviorPeerBuilderModifier
{
    protected $behavior;
    protected $builder;

    public function __construct($behavior)
    {
        $this->behavior = $behavior;
    }

    public function staticMethods($builder)
    {
        $this->builder = $builder;
        $script = "";

        $this->addPurgeCache($script);
        $this->addCacheFetch($script);
        $this->addCacheStore($script);
        $this->addCacheDelete($script);

        return $script;
    }

    public function peerFilter(&$script)
    {
        $parser = new PropelPHPParser($script, true);

        $this->replaceDoDeleteAll($parser);

        $script = $parser->getCode();
    }

    protected function addPurgeCache(&$script)
    {
        $backend = $this->behavior->getParameter("backend");

        $script .= "
public static function purgeCache()
{
    return \Domino\CacheStore\Factory::factory('{$backend}')->clearByNamespace(self::TABLE_NAME);
}
        ";
    }

    protected function addCacheFetch(&$script)
    {
        $backend = $this->behavior->getParameter("backend");
        $peerClassname = $this->builder->getStubPeerBuilder()->getClassname();
        $objectClassname = $this->builder->getStubObjectBuilder()->getClassname();

        $script .= "
public static function cacheFetch(\$key)
{
    \$result = \Domino\CacheStore\Factory::factory('{$backend}')->get(self::TABLE_NAME, \$key);

    if (\$result !== null) {
        $unserializedResult = unserialize($result);
        $result = ($unserializedResult === FALSE) ? $result : $unserializedResult;
        if (\$result instanceof ArrayAccess) {
            foreach (\$result as \$element) {
                if (\$element instanceof {$objectClassname}) {
                    {$peerClassname}::addInstanceToPool(\$element);
                }
            }
        } else if (\$result instanceof {$objectClassname}) {
            {$peerClassname}::addInstanceToPool(\$result);
        }
    }

    return \$result;
}
        ";
    }

    protected function addCacheStore(&$script)
    {
        $backend = $this->behavior->getParameter("backend");

        $script .= "
public static function cacheStore(\$key, \$data, \$lifetime)
{
    return \Domino\CacheStore\Factory::factory('{$backend}')->set(self::TABLE_NAME, \$key, serialize(\$data), \$lifetime);
}
        ";
    }

    protected function addCacheDelete(&$script)
    {
        $backend = $this->behavior->getParameter("backend");

        $script .= "
public static function cacheDelete(\$key)
{
    return \Domino\CacheStore\Factory::factory('{$backend}')->clear(self::TABLE_NAME, \$key);
}
        ";
    }

    protected function replaceDoDeleteAll(&$parser)
    {
        $peerClassname = $this->builder->getStubPeerBuilder()->getClassname();

        $search  = "\$con->commit();";
        $replace = "\$con->commit();\n            {$peerClassname}::purgeCache();";
        $script  = $parser->findMethod('doDeleteAll');
        $script  = str_replace($search, $replace, $script);

        $parser->replaceMethod("doDeleteAll", $script);
    }
}