fix(worker): read payments from new payments.json + log full traceback

Two fixes:

1. Discord moved payments out of user.json into
   Account/user_data_exports/discord_billing/payments.json sometime in
   2025. Read from the new location when present; fall back to the old
   user_json['payments'] field for older exports.

2. The exception handler in process_package was 'print(e)', which only
   logs the exception's str() — useless for debugging. Always log the
   full traceback to CloudWatch before swallowing into the DB.

Author: Androz2091

src/tasks.py

@@ -227,7 +227,20 @@ def read_analytics_file(package_status_id, package_id, link, session):
                 'avatar_url': generate_avatar_url_from_user_id_avatar_hash(relation_ship['id'], relation_ship['user']['avatar']),
                 'display_name': 'display_name' in relation_ship and relation_ship['display_name'] or None,
             })
-        for payment in user_json['payments']:
+        # Discord moved payments out of user.json into a separate file
+        # (Account/user_data_exports/discord_billing/payments.json) sometime
+        # in 2025. Read the new location if present, otherwise fall back to
+        # the legacy field for older exports.
+        payment_records = []
+        user_root = user_path.rsplit('/', 1)[0]
+        new_payments_path = f'{user_root}/user_data_exports/discord_billing/payments.json'
+        if new_payments_path in zip.namelist():
+            with zip.open(new_payments_path) as f:
+                payment_records = orjson.loads(f.read()).get('records', [])
+        else:
+            payment_records = user_json.get('payments', [])
+
+        for payment in payment_records:
             payments.append({
                 'id': payment['id'],
                 'amount': payment['amount'],
@@ -928,13 +941,18 @@ def process_package(package_status_id, package_id, link, worker_name='regular_pr
         download_file(package_status_id, package_id, link, session)
         read_analytics_file(package_status_id, package_id, link, session)
     except Exception as e:
-        print(e)
+        # Always log the full trace to CloudWatch — print(e) alone gives just
+        # the exception message and no line numbers, which makes the failure
+        # impossible to debug from logs.
+        tb = ''.join(traceback.format_exception(type(e), e, e.__traceback__))
+        print(f'process_package failed for {package_id}:\n{tb}')
+
         expected = ('EXPIRED_LINK')
         current = str(e)
         e_traceback = None
         if expected not in current:
             current = 'UNKNOWN_ERROR'
-            e_traceback = ''.join(traceback.format_exception(type(e), e, e.__traceback__))
+            e_traceback = tb
         session.query(PackageProcessStatus).filter(PackageProcessStatus.id == package_status_id).update({
             'is_errored': True,
             'error_message_code': current,