@@ -25,16 +25,18 @@ def RunScript(self, i_load: bool, i_reset: bool, i_port: int, i_host: str):
25
25
# close old socket if any
26
26
old = sc .sticky .get ('server_sock' )
27
27
try :
28
- if old : old .close ()
29
- except : pass
28
+ if old :
29
+ old .close ()
30
+ except Exception :
31
+ pass
30
32
31
33
sc .sticky ['listen_addr' ] = addr
32
34
sc .sticky ['server_sock' ] = None
33
35
sc .sticky ['server_started' ] = False
34
36
sc .sticky ['cloud_buffer_raw' ] = []
35
37
sc .sticky ['latest_cloud' ] = None
36
38
sc .sticky ['status_message' ] = "Reset" if i_reset else f"Addr → { i_host } :{ i_port } "
37
- ghenv .Component .Message = sc .sticky ['status_message' ]
39
+ ghenv .Component .Message = sc .sticky ['status_message' ] # noqa: F821
38
40
39
41
# Client handler
40
42
def handle_client (conn ):
@@ -52,29 +54,29 @@ def handle_client(conn):
52
54
raw = json .loads (line .decode ())
53
55
except Exception as e :
54
56
sc .sticky ['status_message' ] = f"JSON error: { e } "
55
- ghenv .Component .Message = sc .sticky ['status_message' ]
57
+ ghenv .Component .Message = sc .sticky ['status_message' ] # noqa: F821
56
58
continue
57
59
58
60
if isinstance (raw , list ) and all (isinstance (pt , list ) and len (pt )== 6 for pt in raw ):
59
61
sc .sticky ['cloud_buffer_raw' ] = raw
60
62
sc .sticky ['status_message' ] = f"Buffered { len (raw )} pts"
61
63
else :
62
64
sc .sticky ['status_message' ] = "Unexpected format"
63
- ghenv .Component .Message = sc .sticky ['status_message' ]
65
+ ghenv .Component .Message = sc .sticky ['status_message' ] # noqa: F821
64
66
except Exception as e :
65
67
sc .sticky ['status_message' ] = f"Socket error: { e } "
66
- ghenv .Component .Message = sc .sticky ['status_message' ]
68
+ ghenv .Component .Message = sc .sticky ['status_message' ] # noqa: F821
67
69
break
68
70
69
71
def accept_loop (srv_sock ):
70
72
while True :
71
73
try :
72
74
conn , _ = srv_sock .accept ()
73
75
threading .Thread (target = handle_client , args = (conn ,), daemon = True ).start ()
74
- except :
76
+ except Exception :
75
77
break
76
78
77
- #Start server
79
+ # Start server
78
80
def start_server ():
79
81
try :
80
82
srv = socket .socket (socket .AF_INET , socket .SOCK_STREAM )
@@ -84,11 +86,11 @@ def start_server():
84
86
sc .sticky ['server_sock' ] = srv
85
87
sc .sticky ['server_started' ] = True
86
88
sc .sticky ['status_message' ] = f"Listening on { i_host } :{ i_port } "
87
- ghenv .Component .Message = sc .sticky ['status_message' ]
89
+ ghenv .Component .Message = sc .sticky ['status_message' ] # noqa: F821
88
90
threading .Thread (target = accept_loop , args = (srv ,), daemon = True ).start ()
89
91
except Exception as e :
90
92
sc .sticky ['status_message' ] = f"Server error: { e } "
91
- ghenv .Component .Message = sc .sticky ['status_message' ]
93
+ ghenv .Component .Message = sc .sticky ['status_message' ] # noqa: F821
92
94
93
95
if not sc .sticky ['server_started' ]:
94
96
start_server ()
@@ -104,8 +106,7 @@ def start_server():
104
106
sc .sticky ['status_message' ] = f"Retrieved { pc .Count } pts"
105
107
else :
106
108
sc .sticky ['status_message' ] = "No data buffered"
107
- ghenv .Component .Message = sc .sticky ['status_message' ]
108
-
109
+ ghenv .Component .Message = sc .sticky ['status_message' ] # noqa: F821
109
110
sc .sticky ['prev_load' ] = i_load
110
111
111
112
return [sc .sticky ['latest_cloud' ]]
0 commit comments