Code Duplication    Length = 22-24 lines in 2 locations

Core/Executor/ServiceExecutor.php 1 location

@@ 98-121 (lines=24) @@
95
        return $output;
96
    }
97
98
    protected function setReferences($result, $dsl)
99
    {
100
        if (!array_key_exists('references', $dsl)) {
101
            return false;
102
        }
103
104
        foreach ($dsl['references'] as $reference) {
105
            switch ($reference['attribute']) {
106
                case 'result':
107
                    $value = $result;
108
                    break;
109
                default:
110
                    throw new \InvalidArgumentException('Service executor does not support setting references for attribute ' . $reference['attribute']);
111
            }
112
113
            $overwrite = false;
114
            if (isset($reference['overwrite'])) {
115
                $overwrite = $reference['overwrite'];
116
            }
117
            $this->referenceResolver->addReference($reference['identifier'], $value, $overwrite);
118
        }
119
120
        return true;
121
    }
122
123
    protected function resolveReferencesRecursively($match)
124
    {

Core/Executor/SQLExecutor.php 1 location

@@ 60-81 (lines=22) @@
57
        return $result;
58
    }
59
60
    protected function setReferences($result, $dsl)
61
    {
62
        if (!array_key_exists('references', $dsl)) {
63
            return false;
64
        }
65
66
        foreach ($dsl['references'] as $reference) {
67
            switch ($reference['attribute']) {
68
                case 'affected_rows':
69
                    $value = $result;
70
                    break;
71
                default:
72
                    throw new \InvalidArgumentException('Sql Executor does not support setting references for attribute ' . $reference['attribute']);
73
            }
74
75
            $overwrite = false;
76
            if (isset($reference['overwrite'])) {
77
                $overwrite = $reference['overwrite'];
78
            }
79
            $this->referenceResolver->addReference($reference['identifier'], $value, $overwrite);
80
        }
81
    }
82
}
83