refactor: moved key service and throw key not found error

Author: sgomez

src/crypto/index.ts

@@ -1,3 +1,2 @@
 export * from './key.dto';
 export * from './key.schema';
-export * from './key.service';

src/errors/index.ts

@@ -0,0 +1 @@
+export * from './key-not-found.error';

src/errors/key-not-found.error.ts

@@ -0,0 +1,5 @@
+export class KeyNotFoundError extends Error {
+  public static withId(id: string) {
+    return new KeyNotFoundError(`Decrypt key for [${id}] does not exists`);
+  }
+}

src/index.ts

@@ -1,6 +1,7 @@
 export * from './aggregate.repository';
 export * from './decorators/inject-repository.decorator';
 export * from './domain';
+export * from './errors';
 export * from './eventstore';
 export * from './eventstore.config';
 export * from './eventstore.constants';

src/services/index.ts

@@ -1,2 +1,3 @@
+export * from './key.service';
 export * from './projections.service';
 export * from './transformer.service';

src/crypto/key.service.spec.ts renamed to src/services/key.service.spec.ts

@@ -1,13 +1,13 @@
 import { CryptoModule } from '@akanass/nestjsx-crypto';
 import { getModelToken } from '@nestjs/mongoose';
 import { Test } from '@nestjs/testing';
-import { KeyDto } from './key.dto';
-import { KeyDocument, KEYS } from './key.schema';
-import { KeyService } from './key.service';
-import { Event } from '../domain';
 import { v4 as uuid } from 'uuid';
 import { Model } from 'mongoose';
 
+import { KeyDto, KeyDocument, KEYS } from '../crypto';
+import { Event } from '../domain';
+import { KeyService } from './key.service';
+
 describe('KeyService', () => {
   const PAYLOAD = { foo: 'bar' };
   const ENCRYPTED_PAYLOAD = 'z6ZatDe7V2Dvkxyvx9fzazqjc5BOWqSTpUaQzrkUeR4=';

src/crypto/key.service.ts renamed to src/services/key.service.ts

@@ -9,9 +9,9 @@ import { Model } from 'mongoose';
 import { firstValueFrom } from 'rxjs';
 import { v4 as uuid } from 'uuid';
 
+import { KeyDocument, KeyDto, KEYS } from '../crypto';
 import { Event } from '../domain';
-import { KeyDto } from './key.dto';
-import { KeyDocument, KEYS } from './key.schema';
+import { KeyNotFoundError } from '../errors';
 
 @Injectable()
 export class KeyService {
@@ -58,6 +58,11 @@ export class KeyService {
 
   async decryptPayload(id: string, encryptedPayload: string): Promise<string> {
     const key = await this.find(id);
+
+    if (!key) {
+      throw KeyNotFoundError.withId(id);
+    }
+
     const source$ = await this.aesService
       .createKey(key.secret, key.salt)
       .pipe(decryptWithAesKey(Buffer.from(encryptedPayload, 'base64')));