@@ -79,7 +79,7 @@ def version_checker(name, vdev, vapp):
79
79
class WsOtaHandler (threading .Thread ):
80
80
"""Thread handling ota update
81
81
82
- Runing ota directly from message would kill WS
82
+ Running ota directly from message would kill WS
83
83
as message bus would timeout.
84
84
"""
85
85
def __init__ (self , name , message , websocket ):
@@ -177,7 +177,7 @@ async def _state(websocket, message):
177
177
await websocket .send (json .dumps (response ))
178
178
179
179
180
- async def _unhandleld (websocket , msg ):
180
+ async def _unhandled (websocket , msg ):
181
181
Logger .info ("Unhandled message from device: %s" , str (msg ))
182
182
response = {'type' : 'response' , 'state' : 'nok' }
183
183
await websocket .send (json .dumps (response ))
@@ -206,7 +206,7 @@ async def message_received(websocket, message) -> None:
206
206
207
207
type_ = msg_json .get ('type' )
208
208
name = msg_json .get ('name' )
209
- func = switcher .get (type_ , _unhandleld )
209
+ func = switcher .get (type_ , _unhandled )
210
210
Logger .debug ("Client(%s)said: %s" , name , type_ )
211
211
212
212
try :
@@ -225,7 +225,7 @@ async def ws_server(websocket, path) -> None:
225
225
async def main ():
226
226
"""Server starter
227
227
228
- Normal user can bind only port nubers greater than 1024
228
+ Normal user can bind only port numbers greater than 1024
229
229
"""
230
230
async with websockets .serve (ws_server , "10.0.1.5" , 8081 ):
231
231
await asyncio .Future () # run forever
0 commit comments