Skip to content

Commit ca36090

Browse files
feat(mbe): fix conflict
1 parent 3e3a62d commit ca36090

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
@@ -53,6 +53,9 @@ export class KmsClient {
5353
// Handles http erros from KMS
5454
private errorHandler(error: superagent.ResponseError, errorLog: string) {
5555
logger.error(errorLog, error);
56+
57+
this.checkServerRunning(error);
58+
5659
switch (error.status) {
5760
case 400:
5861
throw new BadRequestError(error.response?.body.message);
@@ -85,9 +88,6 @@ export class KmsClient {
8588
if (error.code === 'ETIMEDOUT' || error.timeout) {
8689
throw new Error('KMS API request timed out. The service may be overloaded or unreachable.');
8790
}
88-
if (error.status === 404) {
89-
throw new Error('KMS API endpoint not found. Please verify the KMS URL configuration.');
90-
}
9191
}
9292

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

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

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

174168
throw new Error(`Failed to generate data key from KMS: ${error.message}`);
175169
}
@@ -202,9 +196,7 @@ export class KmsClient {
202196
if (this.agent) req = req.agent(this.agent);
203197
kmsResponse = await req;
204198
} catch (error: any) {
205-
logger.error('Error decrypting data key from KMS', error);
206-
207-
this.checkServerRunning(error);
199+
this.errorHandler(error, 'Error decrypting data key from KMS');
208200

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

0 commit comments

Comments
 (0)