quick-start-connectors

1
import logging
2

3
from flask import abort, current_app as app
4
from connexion.exceptions import Unauthorized
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
    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
18

19

20
def apikey_auth(token):
21
    api_key = app.config.get("CONNECTOR_API_KEY", "")
22
    if api_key != "" and token != api_key:
23
        raise Unauthorized()
24

25
    return {}
26