| @@ 130-134 (lines=5) @@ | ||
| 127 | return $pipeline; |
|
| 128 | } |
|
| 129 | ||
| 130 | if (property_exists($aggregate, 'match') && !empty((array) $aggregate->match)) { |
|
| 131 | $pipeline[] = [ |
|
| 132 | '$match' => $this->aggregate->match |
|
| 133 | ]; |
|
| 134 | } |
|
| 135 | ||
| 136 | if (property_exists($aggregate, 'group') && !empty((array) $aggregate->group)) { |
|
| 137 | $pipeline[] = [ |
|
| @@ 136-140 (lines=5) @@ | ||
| 133 | ]; |
|
| 134 | } |
|
| 135 | ||
| 136 | if (property_exists($aggregate, 'group') && !empty((array) $aggregate->group)) { |
|
| 137 | $pipeline[] = [ |
|
| 138 | '$group' => $this->aggregate->group |
|
| 139 | ]; |
|
| 140 | } |
|
| 141 | ||
| 142 | return $pipeline; |
|
| 143 | } |
|