From fa87c981e1efabe85a88144479b0dd7131b7da12 Mon Sep 17 00:00:00 2001
From: "Paul \"LeoNerd\" Evans" <paul@matrix.org>
Date: Wed, 17 Aug 2016 13:15:06 +0100
Subject: [PATCH] =?UTF-8?q?Thread=203PU=20lookup=20through=20as=20far=20as?=
 =?UTF-8?q?=20the=20AS=20API=20object;=20which=20currently=20no=C3=B6ps=20?=
 =?UTF-8?q?it?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 synapse/appservice/api.py                  |  3 +++
 synapse/handlers/appservice.py             | 21 +++++++++++++++++++++
 synapse/rest/client/v2_alpha/thirdparty.py | 11 +++++++++--
 3 files changed, 33 insertions(+), 2 deletions(-)

diff --git a/synapse/appservice/api.py b/synapse/appservice/api.py
index 6da6a1b62..6e5f7dc40 100644
--- a/synapse/appservice/api.py
+++ b/synapse/appservice/api.py
@@ -71,6 +71,9 @@ class ApplicationServiceApi(SimpleHttpClient):
             logger.warning("query_alias to %s threw exception %s", uri, ex)
         defer.returnValue(False)
 
+    def query_3pu(self, service, protocol, fields):
+        return False
+
     @defer.inlineCallbacks
     def push_bulk(self, service, events, txn_id=None):
         events = self._serialize(events)
diff --git a/synapse/handlers/appservice.py b/synapse/handlers/appservice.py
index 051ccdb38..69fd76661 100644
--- a/synapse/handlers/appservice.py
+++ b/synapse/handlers/appservice.py
@@ -120,6 +120,21 @@ class ApplicationServicesHandler(object):
                 )
                 defer.returnValue(result)
 
+    @defer.inlineCallbacks
+    def query_3pu(self, protocol, fields):
+        services = yield self._get_services_for_3pn(protocol)
+
+        # TODO(paul): scattergather
+        results = []
+        for service in services:
+            result = yield self.appservice_api.query_3pu(
+                service, protocol, fields
+            )
+            if result:
+                results.append(result)
+
+        defer.returnValue(results)
+
     @defer.inlineCallbacks
     def _get_services_for_event(self, event, restrict_to="", alias_list=None):
         """Retrieve a list of application services interested in this event.
@@ -163,6 +178,12 @@ class ApplicationServicesHandler(object):
         ]
         defer.returnValue(interested_list)
 
+    @defer.inlineCallbacks
+    def _get_services_for_3pn(self, protocol):
+        # TODO(paul): Filter by protocol
+        services = yield self.store.get_app_services()
+        defer.returnValue(services)
+
     @defer.inlineCallbacks
     def _is_unknown_user(self, user_id):
         if not self.is_mine_id(user_id):
diff --git a/synapse/rest/client/v2_alpha/thirdparty.py b/synapse/rest/client/v2_alpha/thirdparty.py
index 9be88b2ba..0180b73e9 100644
--- a/synapse/rest/client/v2_alpha/thirdparty.py
+++ b/synapse/rest/client/v2_alpha/thirdparty.py
@@ -16,6 +16,8 @@
 
 import logging
 
+from twisted.internet import defer
+
 from synapse.http.servlet import RestServlet
 from ._base import client_v2_patterns
 
@@ -28,10 +30,15 @@ class ThirdPartyUserServlet(RestServlet):
 
     def __init__(self, hs):
         super(ThirdPartyUserServlet, self).__init__()
-        pass
 
+        self.appservice_handler = hs.get_application_service_handler()
+
+    @defer.inlineCallbacks
     def on_GET(self, request, protocol):
-        return (200, {"TODO":"TODO"})
+        fields = {} # TODO
+        results = yield self.appservice_handler.query_3pu(protocol, fields)
+
+        defer.returnValue((200, results))
 
 
 def register_servlets(hs, http_server):