feat: add observable decorator

Co-authored-by: username1103 <[email protected]>
Co-authored-by: imdudu1 <[email protected]>

Author: 3 people

lib/decorators/constants.ts

@@ -7,3 +7,4 @@ export const REQUEST_FORM_METADATA = Symbol('REQUEST_FORM_METADATA');
 export const REQUEST_HEADER_METADATA = Symbol('REQUEST_HEADER_METADATA');
 export const RESPONSE_BODY_METADATA = Symbol('RESPONSE_BODY_METADATA');
 export const CIRCUIT_BREAKER_METADATA = Symbol('CIRCUIT_BREAKER_METADATA');
+export const OBSERVABLE_METADATA = Symbol('OBSERVABLE_METADATA');

lib/decorators/index.ts

@@ -8,5 +8,6 @@ export * from './request-header.decorator';
 export * from './request-param.decorator';
 export * from './response-body.decorator';
 export * from './circuit-breaker.decorator';
+export * from './observable-response.decorator';
 export * from './constants';
 export * from './utils';

lib/decorators/observable-response.decorator.spec.ts

@@ -0,0 +1,26 @@
+import { Observable } from 'rxjs';
+import { describe, expect, test } from 'vitest';
+import { OBSERVABLE_METADATA } from './constants';
+import { ObservableResponse } from './observable-response.decorator';
+
+describe('ObservableResponse', () => {
+  test('should set observable response metadata', () => {
+    // given
+    class TestService {
+      @ObservableResponse()
+      request(): Observable<string> {
+        throw new Error();
+      }
+    }
+
+    // when
+    const result: boolean = Reflect.hasMetadata(
+      OBSERVABLE_METADATA,
+      TestService.prototype,
+      'request',
+    );
+
+    // then
+    expect(result).toBe(true);
+  });
+});

lib/decorators/observable-response.decorator.ts

@@ -0,0 +1,7 @@
+import { OBSERVABLE_METADATA } from './constants';
+
+export function ObservableResponse(): MethodDecorator {
+  return (target, propertyKey) => {
+    Reflect.defineMetadata(OBSERVABLE_METADATA, true, target, propertyKey);
+  };
+}