adam/pyMC_Repeater
1
0
Fork 0
mirror of https://github.com/pyMC-dev/pyMC_Repeater.git synced 2026-08-09 10:23:01 +02:00
Code Issues Packages Projects Releases Wiki Activity

feat: Enhance filtered_packets endpoint to support additional query parameters for improved packet filtering

Browse Source
This commit is contained in:
Lloyd
2026-01-02 11:01:01 +00:00
parent 2ba7be974d
commit 7d4a779939
1 changed files with 21 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
repeater/web/api_endpoints.py
+21 -9
View File
@@ -735,22 +735,34 @@ class APIEndpoints:
@cherrypy.expose
@cherrypy.tools.json_out()
def filtered_packets(self):
def filtered_packets(self, start_timestamp=None, end_timestamp=None, limit=1000, type=None, route=None):
# Handle OPTIONS request for CORS preflight
if cherrypy.request.method == "OPTIONS":
self._set_cors_headers()
return ""
try:
params = self._get_params({
'type': None,
'route': None,
'start_timestamp': None,
'end_timestamp': None,
'limit': 1000
# Convert 'type' parameter to 'packet_type' for storage method
packet_type = int(type) if type is not None else None
route_int = int(route) if route is not None else None
start_ts = float(start_timestamp) if start_timestamp is not None else None
end_ts = float(end_timestamp) if end_timestamp is not None else None
limit_int = int(limit) if limit is not None else 1000
packets = self._get_storage().get_filtered_packets(
packet_type=packet_type,
route=route_int,
start_timestamp=start_ts,
end_timestamp=end_ts,
limit=limit_int
)
return self._success(packets, count=len(packets), filters={
'type': packet_type,
'route': route_int,
'start_timestamp': start_ts,
'end_timestamp': end_ts,
'limit': limit_int
})
packets = self._get_storage().get_filtered_packets(**params)
return self._success(packets, count=len(packets), filters=params)
except ValueError as e:
return self._error(f"Invalid parameter format: {e}")
except Exception as e: