From dc1ff72edbbe056b0dd5bb899daa0287cf2e21d6 Mon Sep 17 00:00:00 2001
From: Prashant kumhar <prkumar@griddynamics.com>
Date: Mon, 19 Feb 2024 16:00:06 +0530
Subject: [PATCH 1/2] intial commit

---
 main.ts | 161 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 161 insertions(+)
 create mode 100644 main.ts

diff --git a/main.ts b/main.ts
new file mode 100644
index 0000000..9f41569
--- /dev/null
+++ b/main.ts
@@ -0,0 +1,161 @@
+interface UserMockModel {
+  name: string;
+  age: number;
+  roles: string[];
+  createdAt: Date;
+  isDeleated: boolean;
+}
+enum HttpMethods {
+  HTTP_GET_METHOD = "GET",
+  HTTP_POST_METHOD = "POST",
+}
+enum HttpStatus {
+  HTTP_STATUS_OK = 200,
+  HTTP_STATUS_INTERNAL_SERVER_ERROR = 500,
+}
+interface RequestMockModel {
+  method: HttpMethods;
+  host: string;
+  path: string;
+  body?: UserMockModel;
+  params?: {
+    [key: string]: string;
+  };
+}
+interface handlersType {
+next: (value: RequestMockModel) => void,
+error: (error?: string) => void,
+complete: () => void
+};
+// interface ObserverType {
+//   next: () =>void;
+//   complete: () => void;
+  
+
+// }
+class Observer {
+  _unsubscribe: ()=>void;
+  isUnsubscribed:boolean;
+  handlers:Observer;
+  constructor(handlers) {
+    this.handlers = handlers;
+    this.isUnsubscribed = false;
+  }
+
+  next(value) {
+    if (this.handlers.next && !this.isUnsubscribed) {
+      this.handlers.next(value);
+    }
+  }
+
+  error(error) {
+    if (!this.isUnsubscribed) {
+      if (this.handlers.error) {
+        this.handlers.error(error);
+      }
+
+      this.unsubscribe();
+    }
+  }
+
+  complete() {
+    if (!this.isUnsubscribed) {
+      if (this.handlers.complete) {
+        this.handlers.complete();
+      }
+
+      this.unsubscribe();
+    }
+  }
+
+  unsubscribe() {
+    this.isUnsubscribed = true;
+
+    if (this._unsubscribe) {
+      this._unsubscribe();
+    }
+  }
+}
+
+class Observable {
+  public _subscribe;
+  // public _unsubscribe;
+  constructor(subscribe: RequestMockModel) {
+    this._subscribe = subscribe;
+  }
+
+  static from(values) {
+    return new Observable((observer: handlersType) => {
+      values.forEach((value) => observer.next(value));
+
+      observer.complete();
+
+      return () => {
+        console.log("unsubscribed");
+      };
+    });
+  }
+
+  subscribe(obs) {
+    const observer = new Observer(obs);
+
+    observer._unsubscribe = this._subscribe(observer);
+
+    return {
+      unsubscribe() {
+        observer.unsubscribe();
+      },
+    };
+  }
+}
+
+const userMock: UserMockModel = {
+  name: "User Name",
+  age: 26,
+  roles: ["user", "admin"],
+  createdAt: new Date(),
+  isDeleated: false,
+};
+
+const requestsMock: RequestMockModel[] = [
+  {
+    method: HttpMethods.HTTP_GET_METHOD,
+    host: "service.example",
+    path: "user",
+    body: userMock,
+    params: {},
+  },
+  {
+    method: HttpMethods.HTTP_POST_METHOD,
+    host: "service.example",
+    path: "user",
+    params: {
+      id: "3f5h67s4s",
+    },
+  },
+];
+
+const handleRequest: (request: RequestMockModel) => {
+  status: HttpStatus;
+} = (request) => {
+  // handling of request
+  return { status: HttpStatus.HTTP_STATUS_OK };
+};
+const handleError:(error: any) => {
+    status: HttpStatus;
+} = (error) => {
+  // handling of error
+  return { status: HttpStatus.HTTP_STATUS_INTERNAL_SERVER_ERROR };
+};
+
+const handleComplete = () => console.log("complete");
+
+const requests$ = Observable.from(requestsMock);
+
+const subscription  = requests$.subscribe({
+  next: handleRequest,
+  error: handleError,
+  complete: handleComplete,
+});
+
+subscription.unsubscribe();

From d4c40e746cff02af1e9751358a5f7df0a0d23ea7 Mon Sep 17 00:00:00 2001
From: Prashant kumhar <prkumar@griddynamics.com>
Date: Tue, 20 Feb 2024 12:06:49 +0530
Subject: [PATCH 2/2] final typescript code

---
 main.ts | 75 +++++++++++++++++++++++++++------------------------------
 1 file changed, 36 insertions(+), 39 deletions(-)

diff --git a/main.ts b/main.ts
index 9f41569..7a67163 100644
--- a/main.ts
+++ b/main.ts
@@ -1,9 +1,6 @@
-interface UserMockModel {
-  name: string;
-  age: number;
-  roles: string[];
-  createdAt: Date;
-  isDeleated: boolean;
+enum Roles {
+  USER = "user",
+  ADMIN = "admin",
 }
 enum HttpMethods {
   HTTP_GET_METHOD = "GET",
@@ -13,42 +10,43 @@ enum HttpStatus {
   HTTP_STATUS_OK = 200,
   HTTP_STATUS_INTERNAL_SERVER_ERROR = 500,
 }
-interface RequestMockModel {
+interface UserMockModelType {
+  name: string;
+  age: number;
+  roles: Roles[];
+  createdAt: Date;
+  isDeleated: boolean;
+}
+interface RequestMockType {
   method: HttpMethods;
   host: string;
   path: string;
-  body?: UserMockModel;
+  body?: UserMockModelType;
   params?: {
     [key: string]: string;
   };
 }
-interface handlersType {
-next: (value: RequestMockModel) => void,
-error: (error?: string) => void,
-complete: () => void
-};
-// interface ObserverType {
-//   next: () =>void;
-//   complete: () => void;
-  
-
-// }
+interface HandlersType {
+  next: (value: RequestMockType) => void;
+  error: (error?: string) => void;
+  complete: () => void;
+}
 class Observer {
-  _unsubscribe: ()=>void;
-  isUnsubscribed:boolean;
-  handlers:Observer;
-  constructor(handlers) {
+  public _unsubscribe: () => void;
+  private isUnsubscribed: boolean;
+  private handlers: HandlersType;
+  constructor(handlers: HandlersType) {
     this.handlers = handlers;
     this.isUnsubscribed = false;
   }
 
-  next(value) {
+  next(value: RequestMockType) {
     if (this.handlers.next && !this.isUnsubscribed) {
       this.handlers.next(value);
     }
   }
 
-  error(error) {
+  error(error?: string) {
     if (!this.isUnsubscribed) {
       if (this.handlers.error) {
         this.handlers.error(error);
@@ -78,14 +76,13 @@ class Observer {
 }
 
 class Observable {
-  public _subscribe;
-  // public _unsubscribe;
-  constructor(subscribe: RequestMockModel) {
+  private _subscribe;
+  constructor(subscribe) {
     this._subscribe = subscribe;
   }
 
-  static from(values) {
-    return new Observable((observer: handlersType) => {
+  static from(values: RequestMockType[]) {
+    return new Observable((observer: Observer) => {
       values.forEach((value) => observer.next(value));
 
       observer.complete();
@@ -96,7 +93,7 @@ class Observable {
     });
   }
 
-  subscribe(obs) {
+  subscribe(obs: HandlersType) {
     const observer = new Observer(obs);
 
     observer._unsubscribe = this._subscribe(observer);
@@ -109,15 +106,15 @@ class Observable {
   }
 }
 
-const userMock: UserMockModel = {
+const userMock: UserMockModelType = {
   name: "User Name",
   age: 26,
-  roles: ["user", "admin"],
+  roles: [Roles.USER, Roles.ADMIN],
   createdAt: new Date(),
   isDeleated: false,
 };
 
-const requestsMock: RequestMockModel[] = [
+const requestsMock: RequestMockType[] = [
   {
     method: HttpMethods.HTTP_GET_METHOD,
     host: "service.example",
@@ -135,14 +132,14 @@ const requestsMock: RequestMockModel[] = [
   },
 ];
 
-const handleRequest: (request: RequestMockModel) => {
+const handleRequest: (request: RequestMockType) => {
   status: HttpStatus;
-} = (request) => {
+} = (request: RequestMockType) => {
   // handling of request
   return { status: HttpStatus.HTTP_STATUS_OK };
 };
-const handleError:(error: any) => {
-    status: HttpStatus;
+const handleError: (error?: string) => {
+  status: HttpStatus;
 } = (error) => {
   // handling of error
   return { status: HttpStatus.HTTP_STATUS_INTERNAL_SERVER_ERROR };
@@ -152,7 +149,7 @@ const handleComplete = () => console.log("complete");
 
 const requests$ = Observable.from(requestsMock);
 
-const subscription  = requests$.subscribe({
+const subscription = requests$.subscribe({
   next: handleRequest,
   error: handleError,
   complete: handleComplete,