From 3640ddfbf6641a79b486d3847ae739c974c62c7a Mon Sep 17 00:00:00 2001
From: Erik Johnston <erik@matrix.org>
Date: Thu, 5 Nov 2015 16:10:54 +0000
Subject: [PATCH] Error handling

---
 synapse/storage/search.py | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/synapse/storage/search.py b/synapse/storage/search.py
index 7342e7bae..3cea2011f 100644
--- a/synapse/storage/search.py
+++ b/synapse/storage/search.py
@@ -16,6 +16,7 @@
 from twisted.internet import defer
 
 from _base import SQLBaseStore
+from synapse.api.errors import SynapseError
 from synapse.storage.engines import PostgresEngine, Sqlite3Engine
 
 import logging
@@ -130,7 +131,13 @@ class SearchStore(SQLBaseStore):
         )
 
         if pagination_token:
-            topo, stream = pagination_token.split(",")
+            try:
+                topo, stream = pagination_token.split(",")
+                topo = int(topo)
+                stream = int(stream)
+            except:
+                raise SynapseError(400, "Invalid pagination token")
+
             clauses.append(
                 "(topological_ordering < ?"
                 " OR (topological_ordering = ? AND stream_ordering < ?))"