Jimmy Labbé
53 lines
1.3 KiB
Python
53 lines
1.3 KiB
Python
import asyncio
|
||
import paramiko
|
||
import websockets
|
||
import os
|
||
import pty
|
||
import select
|
||
|
||
SSH_HOST = "IP_ADDRESS" # Remplacez par l'adresse IP de la cible SSH
|
||
SSH_USER = "minitel"
|
||
SSH_PORT = 22
|
||
|
||
async def handler(ws):
|
||
# --- SSH ---
|
||
client = paramiko.SSHClient()
|
||
client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
|
||
client.connect(
|
||
SSH_HOST,
|
||
port=SSH_PORT,
|
||
username=SSH_USER,
|
||
password="PASSWORD" # Remplacez par le mot de passe approprié
|
||
)
|
||
|
||
chan = client.invoke_shell(
|
||
term='m1b',
|
||
width=40,
|
||
height=24
|
||
)
|
||
|
||
chan.send("stty -ixon\n")
|
||
|
||
async def ws_to_ssh():
|
||
async for msg in ws:
|
||
if isinstance(msg, str):
|
||
chan.send(msg.encode("latin1", errors="ignore").decode("latin1"))
|
||
else:
|
||
chan.send(msg.decode("latin1", errors="ignore"))
|
||
|
||
async def ssh_to_ws():
|
||
while True:
|
||
if chan.recv_ready():
|
||
data = chan.recv(1024)
|
||
await ws.send(data.decode("latin1", errors="ignore"))
|
||
await asyncio.sleep(0.01)
|
||
|
||
await asyncio.gather(ws_to_ssh(), ssh_to_ws())
|
||
|
||
async def main():
|
||
async with websockets.serve(handler, "0.0.0.0", 8765):
|
||
print("Passerelle SSH–Minitel prête")
|
||
await asyncio.Future()
|
||
|
||
asyncio.run(main())
|