24 lines
573 B
Python
24 lines
573 B
Python
|
from channels.layers import get_channel_layer
|
||
|
|
from asgiref.sync import async_to_sync
|
||
|
|
import uuid
|
||
|
|
|
||
|
|
layer = get_channel_layer()
|
||
|
|
|
||
|
|
|
||
|
|
class Channel:
|
||
|
|
@staticmethod
|
||
|
|
def get_token():
|
||
|
|
return uuid.uuid4().hex
|
||
|
|
|
||
|
|
@staticmethod
|
||
|
|
def send_ssh_executor(hostname, port, username, command, token=None):
|
||
|
|
message = {
|
||
|
|
'type': 'exec',
|
||
|
|
'token': token,
|
||
|
|
'hostname': hostname,
|
||
|
|
'port': port,
|
||
|
|
'username': username,
|
||
|
|
'command': command
|
||
|
|
}
|
||
|
|
async_to_sync(layer.send)('ssh_exec', message)
|