quick-start-connectors

1
import logging
2

3
from connexion.exceptions import Unauthorized
4
from flask import abort, current_app as app
5

6
from . import UpstreamProviderError, provider
7

8
logger = logging.getLogger(__name__)
9

10

11
def search(body):
12
    try:
13
        data = provider.search(body["query"])
14
    except UpstreamProviderError as error:
15
        logger.error(f"Upstream search error: {error.message}")
16
        abort(502, error.message)
17
    except AssertionError as error:
18
        logger.error(f"Techcrunch config error: {error}")
19
        abort(502, f"Techcrunch config error: {error}")
20

21
    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
22

23

24
def apikey_auth(token):
25
    api_key = app.config.get("CONNECTOR_API_KEY", "")
26
    if api_key != "" and token != api_key:
27
        raise Unauthorized()
28
    # successfully authenticated
29
    return {}
30