callbacks.py

# This file is part of https://github.com/SpringQL/web-console which is licensed under MIT OR Apache-2.0. See file LICENSE-MIT or LICENSE-APACHE for full license details.

from dash.dependencies import Input, Output, State
import json

from app import app
from redis_client import redis_client


@app.callback(Output('stream-name', 'children'),
              Input('cytoscape-pipeline', 'selectedNodeData'))
def updateStreamName(nodes):
    if not nodes:
        return "(no stream selected)"

    node = nodes[0]
    return node['id']


@app.callback(Output('stream-def-content', 'children'),
              Input('cytoscape-pipeline', 'selectedNodeData'))
def updateStreamDefContent(nodes):
    if not nodes:
        return ""

    node = nodes[0]
    return node['stream_def']


@app.callback(Output('stream-upstream-content', 'children'),
              Input('cytoscape-pipeline', 'selectedNodeData'))
def updateStreamUpstreamContent(nodes):
    if not nodes:
        return ""

    node = nodes[0]
    return node['stream_upstream_pump_def']


@app.callback(Output('cytoscape-pipeline', 'elements'),
              Input('btn-update-pipeline', 'n_clicks_timestamp'))
def updatePipelineElements(_btn):
    j = redis_client.get('pipeline')
    if not j:
        j = '{}'
    return json.loads(j)


@app.callback(Output('cytoscape-task-graph', 'elements'),
              Input('btn-update-task-graph', 'n_clicks_timestamp'))
def updateTaskGraphElements(_btn):
    j = redis_client.get('task-graph')
    if not j:
        j = '{}'
    return json.loads(j)