adds a barebone implementation of the caching server.

Author: argahsuknesib

package-lock.json

@@ -18,5 +18,9 @@
         "supertest": "^6.3.3",
         "ts-jest": "^29.0.3",
         "typescript": "^4.9.4"
+    },
+    "dependencies": {
+        "@types/redis": "^4.0.11",
+        "redis": "^4.6.13"
     }
 }

package.json

@@ -0,0 +1,50 @@
+import * as http from 'http';
+import { CacheService } from '../service/CacheService';
+
+export class CacheServiceHTTPServer {
+    private readonly cacheService: CacheService;
+    private readonly server: http.Server;
+
+    constructor(port: number) {
+        this.cacheService = new CacheService();
+        this.server = http.createServer(this.request_handler.bind(this));
+        this.setupServer(port);
+    }
+
+    private async setupServer(port: number) {
+        await this.cacheService.connect();
+        this.server.listen(port, () => {
+            console.log(`Server listening on port ${port}`);
+        });
+    }
+
+    private async request_handler(request: http.IncomingMessage, response: http.ServerResponse) {
+        if (request.method === 'POST') {
+            await this.handleNotificationPostRequest(request, response);
+        }
+        else if (request.method === 'GET') {
+            await this.handleClientGetRequest(request, response);
+        }
+        else if (request.method === 'DELETE') {
+            await this.handleNotificationDeleteRequest(request, response);
+        }
+        else {
+            response.writeHead(405, 'Method Not Allowed');
+            response.end('Method Not Allowed');
+        }
+    }
+
+    private async handleNotificationPostRequest(request: http.IncomingMessage, response: http.ServerResponse): Promise<void> {
+
+    }
+
+    private async handleClientGetRequest(request: http.IncomingMessage, response: http.ServerResponse): Promise<void> {
+
+    }
+
+    private async handleNotificationDeleteRequest(request: http.IncomingMessage, response: http.ServerResponse): Promise<void> {
+
+    }
+
+
+}

src/server/HTTPServer.test.ts

@@ -0,0 +1,37 @@
+import { CacheService } from './CacheService';
+
+describe('CacheService', () => {
+    let cacheService: CacheService;
+
+    beforeEach(() => {
+        cacheService = new CacheService();
+    });
+
+    afterEach(async () => {
+        await cacheService.disconnect();
+    });
+
+    it('should_connect_to_the_cache', async () => {
+        const connected = await cacheService.connect();
+        expect(connected).toBe(true);
+    });
+
+    it('should_set_and_get_a_value', async () => {
+        await cacheService.connect();
+        await cacheService.set('key', 'value');
+        const value = await cacheService.get('key');
+        expect(value).toBe('value');
+    });
+
+    it('should_delete_a_value', async () => {
+        await cacheService.connect();
+        await cacheService.set('key', 'value');
+        await cacheService.delete('key');
+        const value = await cacheService.get('key');
+        expect(value).toBe(null);
+    });
+
+    it('should_close_the_connection', async () => {
+      
+    });
+});