Skip to content

Commit 48c55a1

Browse files
ben-dydx-opsben-dydx-ops
authored
chore: info to debug logs (#3348)
1 parent 5ee9766 commit 48c55a1

12 files changed

Lines changed: 34 additions & 34 deletions

File tree

‎indexer/services/comlink/src/request-helpers/request-logger.ts‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ export default (
1919
// Don't log GET requests unless configured to
2020
const shouldLogMethod: boolean = request.method !== 'GET' || config.LOG_GETS;
2121
if (shouldLogMethod || response.statusCode !== 200) {
22-
logger.info({
22+
logger.debug({
2323
at: 'requestLogger#logRequest',
2424
message: {
2525
request: {

‎indexer/services/ender/src/caches/block-cache.ts‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ export async function shouldSkipBlock(
5959
});
6060
return true;
6161
} else if (isNextBlock(blockHeight)) {
62-
logger.info({
62+
logger.debug({
6363
at: 'block-cache#shouldSkipBlock',
6464
message: 'Block will be processed',
6565
blockHeight,

‎indexer/services/ender/src/caches/orderbook-mid-price-memory-cache.ts‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ export async function updateOrderbookMidPrices(): Promise<void> {
4646

4747
// Log out each median price for each market
4848
Object.entries(orderbookMidPriceCache).forEach(([ticker, price]) => {
49-
logger.info({
49+
logger.debug({
5050
at: 'orderbook-mid-price-cache#updateOrderbookMidPrices',
5151
message: `Median price for market ${ticker}`,
5252
ticker,

‎indexer/services/ender/src/lib/block-processor.ts‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -227,7 +227,7 @@ export class BlockProcessor {
227227
...this.block.events[eventProto.blockEventIndex],
228228
subtype: SKIPPED_EVENT_SUBTYPE,
229229
};
230-
logger.info({
230+
logger.debug({
231231
at: 'onMessage#shouldSkipSql',
232232
message: 'Excluded event from sql processing',
233233
eventProto,
@@ -236,7 +236,7 @@ export class BlockProcessor {
236236
if (validator.shouldSkipHandlers()) {
237237
// If handlers should be skipped, set handlers to empty.
238238
handlers = [];
239-
logger.info({
239+
logger.debug({
240240
at: 'onMessage#shouldSkipHandlers',
241241
message: 'Excluded event from handler processing',
242242
eventProto,

‎indexer/services/ender/src/lib/on-message.ts‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ export async function onMessage(message: KafkaMessage): Promise<void> {
7373
},
7474
);
7575

76-
logger.info({
76+
logger.debug({
7777
at: 'onMessage#onMessage',
7878
message: 'Processing message',
7979
offset,
@@ -121,7 +121,7 @@ export async function onMessage(message: KafkaMessage): Promise<void> {
121121
);
122122
}
123123

124-
logger.info({
124+
logger.debug({
125125
at: 'onMessage#onMessage',
126126
message: 'Successfully processed block',
127127
height: blockHeight,
@@ -186,7 +186,7 @@ function getIndexerTendermintBlock(
186186
}
187187
try {
188188
const messageValueBinary: Uint8Array = new Uint8Array(message.value);
189-
logger.info({
189+
logger.debug({
190190
at: 'onMessage#getIndexerTendermintBlock',
191191
message: 'Received message',
192192
offset: message.offset,
@@ -195,7 +195,7 @@ function getIndexerTendermintBlock(
195195
const block: IndexerTendermintBlock = IndexerTendermintBlock.decode(
196196
messageValueBinary,
197197
);
198-
logger.info({
198+
logger.debug({
199199
at: 'onMessage#getIndexerTendermintBlock',
200200
message: 'Parsed message',
201201
offset: message.offset,

‎indexer/services/roundtable/src/helpers/pnl-ticks-helper.ts‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ export async function getPnlTicksCreateObjects(
8080
mostRecentPnlTicks,
8181
(pnlTick: PnlTicksCreateObject) => pnlTick.blockTime,
8282
);
83-
logger.info({
83+
logger.debug({
8484
at: 'pnl-ticks-helper#getPnlTicksCreateObjects',
8585
message: 'Account to last updated block time',
8686
accountToLastUpdatedBlockTime,
@@ -94,7 +94,7 @@ export async function getPnlTicksCreateObjects(
9494
...getAccountsToUpdate(accountToLastUpdatedBlockTime, blockTime),
9595
...newSubaccountIds,
9696
].slice(0, config.PNL_TICK_MAX_ACCOUNTS_PER_RUN);
97-
logger.info({
97+
logger.debug({
9898
at: 'pnl-ticks-helper#getPnlTicksCreateObjects',
9999
message: 'Accounts to update',
100100
accountsToUpdate,
@@ -203,7 +203,7 @@ export async function getPnlTicksCreateObjects(
203203
});
204204
}
205205
});
206-
logger.info({
206+
logger.debug({
207207
at: 'pnl-ticks-helper#getPnlTicksCreateObjects',
208208
message: 'New ticks to create',
209209
subaccountIds: _.map(newTicksToCreate, 'subaccountId'),
@@ -315,7 +315,7 @@ export function getNewPnlTick(
315315
lastUpdatedFundingIndexMap: FundingIndexMap,
316316
currentFundingIndexMap: FundingIndexMap,
317317
): PnlTicksCreateObject {
318-
logger.info({
318+
logger.debug({
319319
at: 'createPnlTicks#getNewPnlTick',
320320
message: 'Creating new PNL tick',
321321
subaccountId,
@@ -334,7 +334,7 @@ export function getNewPnlTick(
334334
currentEquity,
335335
subaccountTotalTransfersMap[subaccountId][USDC_ASSET_ID],
336336
);
337-
logger.info({
337+
logger.debug({
338338
at: 'createPnlTicks#getNewPnlTick',
339339
message: 'Calculated equity and total pnl',
340340
subaccountId,
@@ -376,7 +376,7 @@ export function getNewPnlTick(
376376
blockHeight: latestBlockHeight,
377377
blockTime: latestBlockTime,
378378
};
379-
logger.info({
379+
logger.debug({
380380
at: 'createPnlTicks#getNewPnlTick',
381381
message: 'New PNL tick',
382382
subaccountId,

‎indexer/services/socks/src/lib/message-forwarder.ts‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -141,7 +141,7 @@ export class MessageForwarder {
141141
// also prevent disconnecting from the broker due to inactivity.
142142
const now: number = Date.now();
143143
if (now - lastCommitTime > config.KAFKA_BATCH_PROCESSING_COMMIT_FREQUENCY_MS) {
144-
logger.info({
144+
logger.debug({
145145
at: 'on-batch#onBatch',
146146
message: 'Committing offsets and sending heart beat',
147147
...batchInfo,
@@ -404,7 +404,7 @@ export class MessageForwarder {
404404
): void {
405405
const connection: Connection = this.index.connections[connectionId];
406406
if (!connection) {
407-
logger.info({
407+
logger.debug({
408408
at: 'message-forwarder#forwardToClientBatch',
409409
message: 'Attempted to forward batched messages, but connection did not exist',
410410
connectionId,
@@ -466,7 +466,7 @@ export class MessageForwarder {
466466
public forwardToClient(message: MessageToForward, connectionId: string): number {
467467
const connection: Connection = this.index.connections[connectionId];
468468
if (!connection) {
469-
logger.info({
469+
logger.debug({
470470
at: 'message-forwarder#forwardToClient',
471471
message: 'Attempted to forward message, but connection did not exist',
472472
connectionId,

‎indexer/services/socks/src/lib/subscription.ts‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -777,15 +777,15 @@ export class Subscriptions {
777777
});
778778

779779
if (Object.keys(maxSubscriptionsByChannel).length > 0) {
780-
logger.info({
780+
logger.debug({
781781
at: 'Subscriptions#emitSubscriptionMetrics',
782782
message: 'Max subscriptions by channel',
783783
maxSubscriptionsByChannel,
784784
});
785785
}
786786

787787
if (Object.keys(maxIdByChannel).length > 0) {
788-
logger.info({
788+
logger.debug({
789789
at: 'Subscriptions#emitSubscriptionMetrics',
790790
message: 'Max id by channel',
791791
maxIdByChannel,

‎indexer/services/socks/src/websocket/index.ts‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,7 @@ export class Index {
9898
const connection: Connection = this.connections[connectionId];
9999

100100
const numConcurrentConnections: number = Object.keys(this.connections).length;
101-
logger.info({
101+
logger.debug({
102102
at: 'index#onConnection',
103103
message: 'Received websocket connection',
104104
url: ws.url,
@@ -160,7 +160,7 @@ export class Index {
160160
// TODO remove use as developer indicates
161161
const reasonStr = safeJsonStringify(reason);
162162

163-
logger.info({
163+
logger.debug({
164164
at: 'index#onClose',
165165
message: 'Connection closed',
166166
connectionId,
@@ -232,7 +232,7 @@ export class Index {
232232
},
233233
);
234234
if (!connection) {
235-
logger.info({
235+
logger.debug({
236236
at: 'index#onMessage',
237237
message: 'Received message for closed connection',
238238
connectionId,
@@ -269,7 +269,7 @@ export class Index {
269269
return;
270270
}
271271

272-
logger.info({
272+
logger.debug({
273273
at: 'index#onSubscribe',
274274
message: 'Received websocket subscribe',
275275
connectionId,
@@ -359,7 +359,7 @@ export class Index {
359359
}
360360

361361
try {
362-
logger.info({
362+
logger.debug({
363363
at: 'index#heartbeat',
364364
message: 'Sending heartbeat ping',
365365
connectionId,
@@ -422,7 +422,7 @@ export class Index {
422422
return;
423423
}
424424
try {
425-
logger.info({
425+
logger.debug({
426426
at: 'index#disconnect',
427427
message: 'Disconnecting websocket connection',
428428
connectionId,

‎indexer/services/vulcan/src/handlers/order-place-handler.ts‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ import { Handler } from './handler';
4848
*/
4949
export class OrderPlaceHandler extends Handler {
5050
protected async handle(update: OffChainUpdateV1, headers: IHeaders): Promise<void> {
51-
logger.info({
51+
logger.debug({
5252
at: 'OrderPlaceHandler#handle',
5353
message: 'Received OffChainUpdate with OrderPlace.',
5454
update,
@@ -84,7 +84,7 @@ export class OrderPlaceHandler extends Handler {
8484
await this.removeOrderFromCanceledOrdersCache(
8585
OrderTable.orderIdToUuid(redisOrder.order?.orderId!),
8686
);
87-
logger.info({
87+
logger.debug({
8888
at: 'OrderPlaceHandler#handle',
8989
message: 'OrderPlace processed',
9090
order,

0 commit comments

Comments
 (0)