From 38aafc02659d220f365f341d7ca8aaf00a2d4fe8 Mon Sep 17 00:00:00 2001
From: sgiehl <stefan@matomo.org>
Date: Mon, 13 Jan 2025 15:24:27 +0100
Subject: [PATCH] Ensure column aggregation is able to handle columns by id and
 name

---
 core/DataTable/Row.php | 64 ++++++++++++++++++++++++++++++------------
 1 file changed, 46 insertions(+), 18 deletions(-)

diff --git a/core/DataTable/Row.php b/core/DataTable/Row.php
index 136b593327a..430bab58095 100644
--- a/core/DataTable/Row.php
+++ b/core/DataTable/Row.php
@@ -483,24 +483,7 @@ public function sumRow(Row $rowToSum, $enableCopyMetadata = true, $aggregationOp
 
             $thisColumnValue = $this->getColumn($columnToSumName);
 
-            $operation = 'sum';
-            if ($operationsIsArray && isset($aggregationOperations[$columnToSumName])) {
-                $operationName = $aggregationOperations[$columnToSumName];
-                if (is_string($operationName)) {
-                    $operation = strtolower($operationName);
-                } elseif (is_callable($operationName)) {
-                    $operation = $operationName;
-                }
-            }
-
-            // max_actions is a core metric that is generated in ArchiveProcess_Day. Therefore, it can be
-            // present in any data table and is not part of the $aggregationOperations mechanism.
-            if ($columnToSumName == Metrics::INDEX_MAX_ACTIONS) {
-                $operation = 'max';
-            }
-            if (empty($operation)) {
-                throw new Exception("Unknown aggregation operation for column $columnToSumName.");
-            }
+            $operation = $this->getColumnAggregationOperation($columnToSumName, $aggregationOperations);
 
             $newValue = $this->getColumnValuesMerged($operation, $thisColumnValue, $columnToSumValue, $this, $rowToSum, $columnToSumName);
 
@@ -512,6 +495,51 @@ public function sumRow(Row $rowToSum, $enableCopyMetadata = true, $aggregationOp
         }
     }
 
+    protected function getColumnAggregationOperation($columnNameOrId, $columnOperations): string
+    {
+        // max_actions is a core metric that is generated in ArchiveProcess_Day. Therefore, it can be
+        // present in any data table and is not part of the $aggregationOperations mechanism.
+        if ($columnNameOrId == Metrics::INDEX_MAX_ACTIONS) {
+            return 'max';
+        }
+
+        if (empty($columnOperations) || !is_array($columnOperations)) {
+            return 'sum';
+        }
+
+        $operationName = 'sum';
+
+        if (isset($aggregationOperations[$columnNameOrId])) {
+            $operationName = $aggregationOperations[$columnNameOrId];
+        } elseif (is_numeric($columnNameOrId)) {
+            // if the column was provided as index, check if a aggration is set for the real name
+            $metricsIdToName = Metrics::getMappingFromIdToName();
+            if (isset($metricsIdToName[$columnNameOrId]) && isset($aggregationOperations[$metricsIdToName[$columnNameOrId]])) {
+                $operationName = $aggregationOperations[$metricsIdToName[$columnNameOrId]];
+            }
+        } else {
+            // if the column was provided as string, check if a aggration is set for the index
+            $metricsNameToId = Metrics::getMappingFromNameToId();
+            if (isset($metricsNameToId[$columnNameOrId]) && isset($aggregationOperations[$metricsNameToId[$columnNameOrId]])) {
+                $operationName = $aggregationOperations[$metricsNameToId[$columnNameOrId]];
+            }
+        }
+
+        if (is_string($operationName)) {
+            return strtolower($operationName);
+        } elseif (is_callable($operationName)) {
+            return $operationName;
+        } elseif (!empty($operationName)) {
+            // log a debug message if set aggregation is invalid, but  fall back to `sum`
+            StaticContainer::get(LoggerInterface::class)->debug(
+                'Invalid column aggregation set for {column}: {aggregation}',
+                ['column' => $columnNameOrId, 'aggregation' => $operationName]
+            );
+        }
+
+        return 'sum';
+    }
+
     /**
      */
     private function getColumnValuesMerged($operation, $thisColumnValue, $columnToSumValue, $thisRow, $rowToSum, $columnName = null)