kopia lustrzana https://github.com/Yakifo/amqtt
randomize gen_client_id
rodzic
103f7e8419
commit
b9f944f6cc
|
@ -5,6 +5,7 @@ import asyncio
|
||||||
import io
|
import io
|
||||||
from websockets.protocol import WebSocketCommonProtocol
|
from websockets.protocol import WebSocketCommonProtocol
|
||||||
from asyncio import StreamReader, StreamWriter
|
from asyncio import StreamReader, StreamWriter
|
||||||
|
import logging
|
||||||
|
|
||||||
|
|
||||||
class ReaderAdapter:
|
class ReaderAdapter:
|
||||||
|
@ -140,6 +141,7 @@ class StreamWriterAdapter(WriterAdapter):
|
||||||
Because API is very close, this class is trivial
|
Because API is very close, this class is trivial
|
||||||
"""
|
"""
|
||||||
def __init__(self, writer: StreamWriter):
|
def __init__(self, writer: StreamWriter):
|
||||||
|
self.logger = logging.getLogger(__name__)
|
||||||
self._writer = writer
|
self._writer = writer
|
||||||
|
|
||||||
def write(self, data):
|
def write(self, data):
|
||||||
|
|
|
@ -25,8 +25,12 @@ def format_client_message(session=None, address=None, port=None, id=None):
|
||||||
|
|
||||||
def gen_client_id():
|
def gen_client_id():
|
||||||
"""
|
"""
|
||||||
Generates unique client ID
|
Generates random client ID
|
||||||
:return:
|
:return:
|
||||||
"""
|
"""
|
||||||
import uuid
|
import random
|
||||||
return str(uuid.uuid4())
|
gen_id = 'hbmqtt/'
|
||||||
|
|
||||||
|
for i in range(7, 23):
|
||||||
|
gen_id += chr((int(random.random()*1000) % 73) + 48)
|
||||||
|
return gen_id
|
||||||
|
|
Ładowanie…
Reference in New Issue