Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
from channels.routing import route
from channels.sessions import channel_session
from .message_router import get_router
from .engine import get_engine
router = get_router()
engine = get_engine()
routing = [
route("websocket.receive", channel_session(router.handle_receive)),
route("websocket.disconnect", channel_session(router.handle_disconnect)),
route("chat.connect", engine.on_connect),
route("chat.message", engine.on_message),
route("chat.command", engine.on_command),
route("chat.disconnect", engine.on_disconnect),
]
# Copyright (c) 2017 Red Hat, Inc
from channels.routing import route
from awx.network_ui.consumers import ws_connect, ws_message, ws_disconnect
channel_routing = [
route("websocket.connect", ws_connect, path=r"^/network_ui/topology/"),
route("websocket.receive", ws_message, path=r"^/network_ui/topology/"),
route("websocket.disconnect", ws_disconnect, path=r"^/network_ui/topology/"),
]
from channels.routing import route
channel_routing = [
route("websocket.connect", "fabric_bolt.task_runners.channels.consumers.ws_connect"),
route("websocket.disconnect", "fabric_bolt.task_runners.channels.consumers.ws_disconnect"),
route("start_task", "fabric_bolt.task_runners.channels.consumers.start_task"),
]
from channels.routing import route
channel_routing = [
route('websocket.connect', 'aspc.laundry.consumers.machine_details', path=r'^/laundry/machine/(?P\w+)/$'), #(?P\w+)
route('websocket.receive', 'aspc.laundry.consumers.process_stream'),
]
from channels.routing import route
from voxel_globe.websockets.consumers import ws_connect, ws_message, ws_disconnect
channel_routing = [
route("websocket.receive", ws_message),
route("websocket.connect", ws_connect),
route("websocket.disconnect", ws_disconnect),
]
"""Channel routes."""
from channels.routing import route
channel_routing = [
route("websocket.connect", "alarm.consumers.ws_auth"),
route("websocket.receive", "alarm.consumers.ws_echo"),
route("websocket.disconnect", "alarm.consumers.ws_disconnect"),
route("vision.images", "vision.consumers.handle_image"),
route("vision.image_tags", "vision.consumers.get_image_tags"),
]
"""Channel routes."""
from channels.routing import route
channel_routing = [
route("websocket.connect", "alarm.consumers.ws_auth"),
route("websocket.receive", "alarm.consumers.ws_echo"),
route("websocket.disconnect", "alarm.consumers.ws_disconnect"),
route("vision.images", "vision.consumers.handle_image"),
route("vision.image_tags", "vision.consumers.get_image_tags"),
]
route('websocket.keepalive', websocket_keepalive_events, path=reverse('events')),
route('websocket.disconnect', websocket_disconnect_events, path=reverse('events')),
route('websocket.connect', websocket_connect_entities, path=reverse('entities')),
route('websocket.keepalive', websocket_keepalive_entities, path=reverse('entities')),
route('websocket.disconnect', websocket_disconnect_entities, path=reverse('entities')),
route('websocket.connect', websocket_connect_onduty, path=reverse('onduty')),
route('websocket.keepalive', websocket_keepalive_onduty, path=reverse('onduty')),
route('websocket.disconnect', websocket_disconnect_onduty, path=reverse('onduty')),
route('background-update-trends', update_trends),
route('background-build-rules', build_rules),
route('background-update-clients', update_clients),
route('background-update-checks', update_checks),
route('background-update-entities', update_entities),
route('background-update-events', update_events),
route('background-build-entity-rules', build_entity_rules),
route('background-build-user-rules', build_user_rules),
route('background-alert', alert),
route('background-notify-history', notifier_hisotry),
route('background-ack', ack),
route('background-slack-detect', slack_detect),
route('background-slack-nag', slack_nag),
route('background-register-user', user_register_job),
route('background-onduty', onduty_handler)
]
# Comment topic
comment_topic_ws = [
route("websocket.connect", consumers.ws_connect_comment_topic),
route("websocket.disconnect", consumers.ws_disconnect_comment_topic),
]
# New topic in forum
forum_topic_ws = [
route("websocket.connect", consumers.ws_connect_forum),
route("websocket.disconnect", consumers.ws_disconnect_forum),
]
# Timeline profile user
notification_ws = [
route("websocket.connect", consumers.ws_connect_notification),
route("websocket.disconnect", consumers.ws_disconnect_notification),
]
channel_routing = [
# Comments
include("muss.routing.comment_topic_ws", path=r"^/ws/comment$"),
# Notification
include("muss.routing.notification_ws", path=r"^/ws/notification$"),
# Forum
include("muss.routing.forum_topic_ws", path=r"^/ws/forum$"),
]
from django.conf import settings
from django.urls import reverse
from channels.routing import route
from .consumers import *
channel_routing = [
route('websocket.connect', websocket_connect_events, path=reverse('events')),
route('websocket.keepalive', websocket_keepalive_events, path=reverse('events')),
route('websocket.disconnect', websocket_disconnect_events, path=reverse('events')),
route('websocket.connect', websocket_connect_entities, path=reverse('entities')),
route('websocket.keepalive', websocket_keepalive_entities, path=reverse('entities')),
route('websocket.disconnect', websocket_disconnect_entities, path=reverse('entities')),
route('websocket.connect', websocket_connect_onduty, path=reverse('onduty')),
route('websocket.keepalive', websocket_keepalive_onduty, path=reverse('onduty')),
route('websocket.disconnect', websocket_disconnect_onduty, path=reverse('onduty')),
route('background-update-trends', update_trends),
route('background-build-rules', build_rules),
route('background-update-clients', update_clients),
route('background-update-checks', update_checks),
route('background-update-entities', update_entities),
route('background-update-events', update_events),
route('background-build-entity-rules', build_entity_rules),
route('background-build-user-rules', build_user_rules),
route('background-alert', alert),
route('background-notify-history', notifier_hisotry),
route('background-ack', ack),
route('background-slack-detect', slack_detect),
route('background-slack-nag', slack_nag),
route('background-register-user', user_register_job),