@@ -18,7 +18,7 @@ export async function sendAndReceive(options: {
18
18
} ) : Promise < Buffer > {
19
19
const { socket, payload } = options ;
20
20
21
- return new Promise < Buffer > ( ( resolve , reject ) => {
21
+ return new Promise < Buffer > ( ( resolve , reject ) : void => {
22
22
const dataListener = ( response : Buffer ) : void => {
23
23
resolveSocket ( response ) ;
24
24
} ;
@@ -70,7 +70,7 @@ export async function downloadCertificate(
70
70
71
71
logger . info ( 'downloading certificate' , { host, port } ) ;
72
72
73
- return new Promise < tls . PeerCertificate > ( ( resolve , reject ) => {
73
+ return new Promise < tls . PeerCertificate > ( ( resolve , reject ) : void => {
74
74
const connectOptions : tls . ConnectionOptions = {
75
75
// When downloading a self-signed cert then it won't be trusted yet
76
76
// so we need to allow unauthorized requests for now.
@@ -80,26 +80,26 @@ export async function downloadCertificate(
80
80
...options ,
81
81
} ;
82
82
83
- const socket = tls . connect ( connectOptions , ( ) => {
83
+ const socket = tls . connect ( connectOptions , ( ) : void => {
84
84
logger . info ( 'socket connected' , { host, port } ) ;
85
85
resolveSocket ( socket . getPeerCertificate ( ) ) ;
86
86
} ) ;
87
87
88
- socket . once ( 'end' , ( ) => {
88
+ socket . once ( 'end' , ( ) : void => {
89
89
logger . info ( 'socket connection ended' , { host, port } ) ;
90
90
} ) ;
91
91
92
- socket . once ( 'close' , ( ) => {
92
+ socket . once ( 'close' , ( ) : void => {
93
93
logger . info ( 'socket connection closed' , { host, port } ) ;
94
94
} ) ;
95
95
96
- socket . once ( 'timeout' , ( ) => {
96
+ socket . once ( 'timeout' , ( ) : void => {
97
97
const timeout = socket . timeout ;
98
98
logger . error ( 'socket timed out' , { host, port, timeout } ) ;
99
99
rejectSocket ( new Error ( `ERR:SOCKET:TIMEOUT:${ timeout } ` ) ) ;
100
100
} ) ;
101
101
102
- socket . once ( 'error' , ( error : Error ) => {
102
+ socket . once ( 'error' , ( error : Error ) : void => {
103
103
logger . error ( 'socket error' , { host, port, error } ) ;
104
104
rejectSocket ( new Error ( `ERR:SOCKET:${ error . name } :${ error . message } ` ) ) ;
105
105
} ) ;
0 commit comments