Skip to content
Snippets Groups Projects
Unverified Commit 2856db04 authored by REIG Julien's avatar REIG Julien
Browse files

implement ping nodes

parent 82e07a03
No related branches found
No related tags found
1 merge request!11create ping endpoint
import time
from flask import Blueprint, request
from flask import Blueprint, jsonify, request
from flask_restful import Api, Resource
from consts.status import Status, response_offline
from utils.database_utils import get_state
from utils.http_utils import normalize_url, ping
state_controller = Blueprint('state_controller', __name__)
api = Api(state_controller)
ping_controller = Blueprint('ping_controller', __name__)
api = Api(ping_controller)
class PingController(Resource):
......@@ -22,7 +22,9 @@ class PingController(Resource):
node_addresses = list(map(normalize_url, node_addresses))
results = ping(node_addresses)
return results, 200
if (normalize_url(request.host_url) in node_addresses):
results[normalize_url(request.host_url)] = True
return jsonify({ "reachable": True, "results": results })
......
......@@ -2,11 +2,12 @@ import flask
from flask import Flask
from flask_cors import CORS
from controllers.duplicate_controller import duplicate_controller
from controllers.node_controller import node_controller
from controllers.ping_controller import ping_controller
from controllers.resource_controller import resource_controller
from controllers.resources_controller import resources_controller
from controllers.state_controller import state_controller
from controllers.duplicate_controller import duplicate_controller
from utils.init_database import init_database, init_queue_db
from utils.MessageAnnouncer import announcer
......@@ -18,6 +19,7 @@ app.register_blueprint(resource_controller, url_prefix='/api')
app.register_blueprint(resources_controller, url_prefix='/api')
app.register_blueprint(state_controller, url_prefix='/api')
app.register_blueprint(duplicate_controller, url_prefix='/api')
app.register_blueprint(ping_controller, url_prefix='/api')
@app.route('/api/subscribe', methods=['GET'])
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment