connector returns
Taylor committed
Jul 17, 2023 at 15:12 UTC
4b58741fe178a5feefa9e9ca5d0feb533c61708f
1 file changed
+16
-12
backend/app/routes/connectors.py
+16
-12
@@ -29,18 +29,22 @@ def validate_and_update_connector(id, request_data, service, api_key=False):
29
30
@bp.route("/connectors", methods=["GET"])
31
def list_connectors_available():
32
- logger.info("Received request to get all available connectors")
33
- connectors_service = ConnectorService(db)
34
- connectors = ConnectorsAvailable.query.all()
35
- result = connectors_available_schema.dump(connectors)
32
+ try:
33
+ logger.info("Received request to get all available connectors")
34
+ connectors_service = ConnectorService(db)
35
+ connectors = ConnectorsAvailable.query.all()
36
+ result = connectors_available_schema.dump(connectors)
37
37
- instantiated_connectors = [
38
- connectors_service.process_connector(connector["connector_name"])
39
- for connector in result
40
- if connectors_service.process_connector(connector["connector_name"])
41
- ]
38
+ instantiated_connectors = [
39
+ connectors_service.process_connector(connector["connector_name"])
40
+ for connector in result
41
+ if connectors_service.process_connector(connector["connector_name"])
42
+ ]
43
43
- return jsonify(instantiated_connectors)
44
+ return {"message": "All available connectors", "connectors": instantiated_connectors, "success": True}
45
+ except Exception as e:
46
+ logger.error(f"Error while getting all available connectors: {e}")
47
+ return {"message": "Error while getting all available connectors", "success": False}, 500
48
49
50
@bp.route("/connectors/<id>", methods=["GET"])
@@ -52,9 +56,9 @@ def get_connector_details(id: str):
56
if connector["success"]:
57
connector = Connectors.query.get(id)
58
instantiated_connector = service.process_connector(connector.connector_name)
55
- return jsonify(instantiated_connector)
59
+ return {"message": "Connector details", "connector": instantiated_connector, "success": True}
60
else:
57
- return jsonify(connector), 404
61
+ return {"message": "Connector not found", "success": False}, 404
62
63
64
@bp.route("/connectors/<id>", methods=["PUT"])