From e4ed5eb04d83d459270a5d4ef61cebf21da27476 Mon Sep 17 00:00:00 2001
From: Thomas Gelf <thomas@gelf.net>
Date: Fri, 18 Mar 2016 13:43:15 +0100
Subject: [PATCH] Db: optional filter for fetchImportedRowsetRows

---
 library/Director/Db.php | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)

diff --git a/library/Director/Db.php b/library/Director/Db.php
index 1d40b405..a32a4ce9 100644
--- a/library/Director/Db.php
+++ b/library/Director/Db.php
@@ -418,7 +418,7 @@ class Db extends DbConnection
         return $this->fetchImportedRowsetRows($checksum, $columns);
     }
 
-    public function fetchImportedRowsetRows($checksum, $columns)
+    public function fetchImportedRowsetRows($checksum, $columns, $filter = null)
     {
         $db = $this->db();
         $binchecksum = Util::hex2binary($checksum);
@@ -469,6 +469,17 @@ class Db extends DbConnection
             }
         }
 
+        if ($filter) {
+            $filtered = array();
+            foreach ($result as $key => $row) {
+                if ($filter->matches($row)) {
+                    $filtered[$key] = $row;
+                }
+            }
+
+            return $filtered;
+        }
+
         return $result;
     }