third-party-mirrors/EDDN
1
0
Fork 0
mirror of https://github.com/EDCD/EDDN.git synced 2025-06-07 10:53:04 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

Gateway: Expand logging on Accepted or Validation Error

Browse Source
This commit is contained in:
Athanasius 2023-01-19 15:29:57 +00:00
parent 953a819135
commit d983a6c806
No known key found for this signature in database
GPG Key ID: 772697E181BB2767
1 changed files with 44 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
src/eddn/Gateway.py
View File

@ -76,8 +76,14 @@ def extract_message_details(parsed_message):
uploader_id = '<<UNKNOWN>>' uploader_id = '<<UNKNOWN>>'
software_name = '<<UNKNOWN>>' software_name = '<<UNKNOWN>>'
software_version = '<<UNKNOWN>>' software_version = '<<UNKNOWN>>'
game_build = '<<UNKNOWN>>'
game_version = '<<UNKNOWN>>'
schema_ref = '<<UNKNOWN>>' schema_ref = '<<UNKNOWN>>'
journal_event = '<<UNKNOWN>>' journal_event = '<<UNKNOWN>>'
system_name = '<<UNKNOWN>>'
system_address = '<<UNKNOWN>>'
station_name = '<<UNKNOWN>>'
station_marketid = '<<UNKNOWN>>'
if 'header' in parsed_message: if 'header' in parsed_message:
if 'uploaderID' in parsed_message['header']: if 'uploaderID' in parsed_message['header']:
@ -89,6 +95,12 @@ def extract_message_details(parsed_message):
if 'softwareVersion' in parsed_message['header']: if 'softwareVersion' in parsed_message['header']:
software_version = parsed_message['header']['softwareVersion'] software_version = parsed_message['header']['softwareVersion']
if 'gamebuild' in parsed_message['header']:
game_build = parsed_message['header']['gamebuild']
if 'gameversion' in parsed_message['header']:
game_version = parsed_message['header']['gameversion']
if '$schemaRef' in parsed_message: if '$schemaRef' in parsed_message:
schema_ref = parsed_message['$schemaRef'] schema_ref = parsed_message['$schemaRef']
@ -101,7 +113,26 @@ def extract_message_details(parsed_message):
else: else:
journal_event = '-' journal_event = '-'
return uploader_id, software_name, software_version, schema_ref, journal_event if 'SystemName' in parsed_message['message']:
system_name = parsed_message['message']['SystemName']
elif 'StarSystem' in parsed_message['message']:
system_name = parsed_message['message']['StarSystem']
if 'SystemAddress' in parsed_message['message']:
system_address = parsed_message['message']['SystemAddress']
if 'StationName' in parsed_message['message']:
station_name = parsed_message['message']['StationName']
if 'marketId' in parsed_message['message']:
station_marketid = parsed_message['message']['marketId']
elif 'MarketID' in parsed_message['message']:
station_marketid = parsed_message['message']['MarketID']
return uploader_id, software_name, software_version, schema_ref, journal_event, game_build, game_version, \
system_name, system_address, station_name, station_marketid
def configure(): def configure():
# Get the list of transports to bind from settings. This allows us to PUB # Get the list of transports to bind from settings. This allows us to PUB
@ -218,10 +249,14 @@ def parse_and_error_handle(data):
gevent.spawn(push_message, parsed_message, parsed_message['$schemaRef']) gevent.spawn(push_message, parsed_message, parsed_message['$schemaRef'])
try: try:
uploader_id, software_name, software_version, schema_ref, journal_event = extract_message_details(parsed_message) uploader_id, software_name, software_version, schema_ref, journal_event, game_build, game_version, \
logger.info('Accepted (%d, "%s", "%s", "%s", "%s", "%s") from %s' % ( system_name, system_address, station_name, station_marketid = extract_message_details(parsed_message)
logger.info('Accepted (%d, "%s", "%s", "%s", "%s", "%s", "%s", "%s", "%s", "%s", "%s", "%s") from %s' % (
request.content_length, request.content_length,
uploader_id, software_name, software_version, schema_ref, journal_event, uploader_id, software_name, software_version, schema_ref, journal_event,
game_build, game_version,
system_name, system_address,
station_name, station_marketid,
get_remote_address() get_remote_address()
)) ))
@ -233,11 +268,15 @@ def parse_and_error_handle(data):
else: else:
try: try:
uploader_id, software_name, software_version, schema_ref, journal_event = extract_message_details(parsed_message) uploader_id, software_name, software_version, schema_ref, journal_event, game_build, game_version, \
logger.error('Failed Validation "%s" (%d, "%s", "%s", "%s", "%s", "%s") from %s' % ( system_name, system_address, station_name, station_marketid = extract_message_details(parsed_message)
logger.error('Failed Validation "%s" (%d, "%s", "%s", "%s", "%s", "%s", "%s", "%s", "%s", "%s", "%s", "%s") from %s' % (
str(validationResults.messages), str(validationResults.messages),
request.content_length, request.content_length,
uploader_id, software_name, software_version, schema_ref, journal_event, uploader_id, software_name, software_version, schema_ref, journal_event,
game_build, game_version,
system_name, system_address,
station_name, station_marketid,
get_remote_address() get_remote_address()
)) ))