@@ -12,11 +12,11 @@ export const updateTxListener = async (): Promise<void> => {
1212 logger ( {
1313 service : "server" ,
1414 level : "info" ,
15- message : ` Listening for updated transactions` ,
15+ message : " Listening for updated transactions" ,
1616 } ) ;
1717
1818 const connection = await knex . client . acquireConnection ( ) ;
19- connection . query ( ` LISTEN updated_transaction_data` ) ;
19+ connection . query ( " LISTEN updated_transaction_data" ) ;
2020
2121 connection . on (
2222 "notification" ,
@@ -28,7 +28,7 @@ export const updateTxListener = async (): Promise<void> => {
2828 ( sub ) => sub . requestId === parsedPayload . id ,
2929 ) ;
3030
31- if ( index == - 1 ) {
31+ if ( index === - 1 ) {
3232 return ;
3333 }
3434
@@ -55,7 +55,7 @@ export const updateTxListener = async (): Promise<void> => {
5555 logger ( {
5656 service : "server" ,
5757 level : "info" ,
58- message : ` [updateTxListener] Connection database ended` ,
58+ message : " [updateTxListener] Connection database ended" ,
5959 } ) ;
6060
6161 knex . client . releaseConnection ( connection ) ;
@@ -64,15 +64,15 @@ export const updateTxListener = async (): Promise<void> => {
6464 logger ( {
6565 service : "server" ,
6666 level : "info" ,
67- message : ` [updateTxListener] Released database connection on end` ,
67+ message : " [updateTxListener] Released database connection on end" ,
6868 } ) ;
6969 } ) ;
7070
7171 connection . on ( "error" , async ( err : any ) => {
7272 logger ( {
7373 service : "server" ,
7474 level : "error" ,
75- message : ` [updateTxListener] Database connection error` ,
75+ message : " [updateTxListener] Database connection error" ,
7676 error : err ,
7777 } ) ;
7878
@@ -82,7 +82,7 @@ export const updateTxListener = async (): Promise<void> => {
8282 logger ( {
8383 service : "worker" ,
8484 level : "info" ,
85- message : ` [updateTxListener] Released database connection on error` ,
85+ message : " [updateTxListener] Released database connection on error" ,
8686 } ) ;
8787 } ) ;
8888} ;
0 commit comments