Skip to content

Commit 6e1bbff

Browse files
feat(mbe): fix conflict
1 parent 14770d7 commit 6e1bbff

File tree

1 file changed

+7
-15
lines changed

1 file changed

+7
-15
lines changed

src/kms/kmsClient.ts

Lines changed: 7 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -54,6 +54,9 @@ export class KmsClient {
5454
// Handles http erros from KMS
5555
private errorHandler(error: superagent.ResponseError, errorLog: string) {
5656
logger.error(errorLog, error);
57+
58+
this.checkServerRunning(error);
59+
5760
switch (error.status) {
5861
case 400:
5962
throw new BadRequestError(error.response?.body.message);
@@ -86,9 +89,6 @@ export class KmsClient {
8689
if (error.code === 'ETIMEDOUT' || error.timeout) {
8790
throw new Error('KMS API request timed out. The service may be overloaded or unreachable.');
8891
}
89-
if (error.status === 404) {
90-
throw new Error('KMS API endpoint not found. Please verify the KMS URL configuration.');
91-
}
9292
}
9393

9494
async postKey(params: PostKeyParams): Promise<PostKeyResponse> {
@@ -101,9 +101,7 @@ export class KmsClient {
101101
if (this.agent) req = req.agent(this.agent);
102102
kmsResponse = await req;
103103
} catch (error: any) {
104-
logger.error('Error posting key to KMS', error);
105-
106-
this.checkServerRunning(error);
104+
this.errorHandler(error, 'Error posting key to KMS');
107105

108106
throw new Error(`Failed to post key to KMS: ${error.message}`);
109107
}
@@ -136,9 +134,7 @@ export class KmsClient {
136134
if (this.agent) req = req.agent(this.agent);
137135
kmsResponse = await req;
138136
} catch (error: any) {
139-
logger.error('Error getting key from KMS', error);
140-
141-
this.checkServerRunning(error);
137+
this.errorHandler(error, 'Error getting key from KMS');
142138

143139
throw new Error(`Failed to get key from KMS: ${error.message}`);
144140
}
@@ -168,9 +164,7 @@ export class KmsClient {
168164
if (this.agent) req = req.agent(this.agent);
169165
kmsResponse = await req;
170166
} catch (error: any) {
171-
logger.error('Error generating data key from KMS when generating data key', error);
172-
173-
this.checkServerRunning(error);
167+
this.errorHandler(error, 'Error generating data key from KMS');
174168

175169
throw new Error(`Failed to generate data key from KMS: ${error.message}`);
176170
}
@@ -203,9 +197,7 @@ export class KmsClient {
203197
if (this.agent) req = req.agent(this.agent);
204198
kmsResponse = await req;
205199
} catch (error: any) {
206-
logger.error('Error decrypting data key from KMS', error);
207-
208-
this.checkServerRunning(error);
200+
this.errorHandler(error, 'Error decrypting data key from KMS');
209201

210202
throw new Error(`Failed to decrypt data key from KMS: ${error.message}`);
211203
}

0 commit comments

Comments
 (0)