diff --git a/packages/wallet-service/src/api/pushRegister.ts b/packages/wallet-service/src/api/pushRegister.ts index 260ccb48..0c53f4b7 100644 --- a/packages/wallet-service/src/api/pushRegister.ts +++ b/packages/wallet-service/src/api/pushRegister.ts @@ -21,6 +21,7 @@ import cors from '@middy/http-cors'; import Joi, { ValidationError } from 'joi'; import { PushRegister } from '@src/types'; import errorHandler from '@src/api/middlewares/errorHandler'; +import createDefaultLogger from '@src/logger'; const mysql = getDbConnection(); @@ -86,6 +87,12 @@ export const register: APIGatewayProxyHandler = middy(walletIdProxyHandler(async await commitTransaction(mysql); } catch (e) { + const logger = createDefaultLogger(); + logger.error('Failed to register push device', { + walletId, + deviceId: body.deviceId, + error: e.message, + }); await rollbackTransaction(mysql); return closeDbAndGetError(mysql, ApiError.UNKNOWN_ERROR, { message: e.message }); } diff --git a/packages/wallet-service/src/api/txProposalDestroy.ts b/packages/wallet-service/src/api/txProposalDestroy.ts index cd3cfcbc..fbc2953b 100644 --- a/packages/wallet-service/src/api/txProposalDestroy.ts +++ b/packages/wallet-service/src/api/txProposalDestroy.ts @@ -20,6 +20,7 @@ import { closeDbAndGetError } from '@src/api/utils'; import middy from '@middy/core'; import cors from '@middy/http-cors'; import errorHandler from '@src/api/middlewares/errorHandler'; +import createDefaultLogger from '@src/logger'; const mysql = getDbConnection(); @@ -70,6 +71,11 @@ export const destroy: APIGatewayProxyHandler = middy(walletIdProxyHandler(async await commitTransaction(mysql); } catch (e) { + const logger = createDefaultLogger(); + logger.error('Failed to destroy tx proposal', { + txProposalId, + error: e.message, + }); await rollbackTransaction(mysql); return closeDbAndGetError(mysql, ApiError.UNKNOWN_ERROR, { message: e.message }); } diff --git a/packages/wallet-service/src/commons.ts b/packages/wallet-service/src/commons.ts index b2bb23fa..70afe1eb 100644 --- a/packages/wallet-service/src/commons.ts +++ b/packages/wallet-service/src/commons.ts @@ -62,6 +62,7 @@ import { import { addAlert } from '@wallet-service/common/src/utils/alerting.utils'; import { isTxVoided } from '@src/utils'; +import createDefaultLogger from '@src/logger'; import hathorLib from '@hathor/wallet-lib'; import { stringMapIterator, WalletBalanceMapConverter } from '@src/db/utils'; @@ -551,11 +552,15 @@ export const handleReorg = async (mysql: ServerlessMysql, logger: Logger): Promi export const walletIdProxyHandler = (handler: WalletProxyHandler): APIGatewayProxyHandler => ( async (event, context) => { + const logger = createDefaultLogger(); let walletId: string; try { walletId = event.requestContext.authorizer.principalId; // validate walletId? } catch (e) { + logger.error('Failed to extract walletId from authorization context', { + error: e.message, + }); return { statusCode: 401, body: 'Unauthorized',