update

Author: netsyncmali

Dockerfile

@@ -1,20 +1,30 @@
-# Base image
-FROM node:18
+FROM node:16
 
-# Create app directory
-WORKDIR /usr/src/app
+# Set working directory
+WORKDIR /app
 
-# A wildcard is used to ensure both package.json AND package-lock.json are copied
+# Copy package.json and package-lock.json
 COPY package*.json ./
 
-# Install app dependencies
+# Install dependencies
 RUN npm install
 
-# Bundle app source
+# Copy the rest of the application files
 COPY . .
 
-# Creates a "dist" folder with the production build
-RUN npm run build
+# Expose the application port
+EXPOSE 2000
 
-# Start the server using the production build
-CMD [ "node", "dist/main.js" ]
+# Install Redis server
+RUN apt-get update && \
+    apt-get install -y redis-server && \
+    rm -rf /var/lib/apt/lists/*
+
+# Configure Redis to listen on port 6377 without a password
+RUN sed -i 's/^bind .*$/bind 0.0.0.0/' /etc/redis/redis.conf && \
+    sed -i 's/^protected-mode yes$/protected-mode no/' /etc/redis/redis.conf && \
+    sed -i 's/^port 6379$/port 6377/' /etc/redis/redis.conf && \
+    sed -i '/^requirepass/ s/^/#/' /etc/redis/redis.conf
+
+# Start Redis server and then the Node.js application
+CMD ["bash", "-c", "redis-server --daemonize yes && npm start"]

docker-compose.yml

@@ -0,0 +1,9 @@
+version: '3'
+
+services:
+  app:
+    build:
+      context: .
+      dockerfile: Dockerfile
+    ports:
+      - "2000:2000"

src/checker/checker.processor.ts

@@ -12,14 +12,14 @@ export class CheckerProcesspr {
   constructor(private websocketGatway: WebsocketGateway) { }
   @Process({
     name: 'CHECK_PROXY',
-    concurrency: 50,
+    concurrency: 250,
   })
   async scrapLink(job: Job<any>) {
     console.log(job.data)
     return await this.httpChecker(job.data.proxy, job.data.isLast);
   }
 
-  async httpChecker(proxy:string,isLast:boolean) {
+  async httpChecker(proxy: string, isLast: boolean) {
     const httpAgent = new HttpProxyAgent(`http://${proxy}`);
     const startTime: any = new Date();
 
@@ -34,13 +34,16 @@ export class CheckerProcesspr {
         let geo = await lookup(proxy.split(':')[0])
         let proxyData = {
           proxy,
-          status: 'LIVE',
-          latency: `${latency} ms`,
-          type: res.data.headers['X-Forwarded-Proto'],
-          geo: { ...geo }
+          data: {
+            status: 'LIVE',
+            latency: `${latency} ms`,
+            type: res.data.headers['X-Forwarded-Proto'],
+            geo: { ...geo }
+          }
+
         }
         this.websocketGatway.handleMessage(proxyData)
-        if(isLast){
+        if (isLast) {
           this.websocketGatway.handleMessage({
             status: 'DONE',
           })
@@ -49,27 +52,31 @@ export class CheckerProcesspr {
       }
       this.websocketGatway.handleMessage({
         proxy,
-        status: 'DEAD',
+        data : {
+          status: 'DEAD',
+        }
       })
-      if(isLast){
+      if (isLast) {
         this.websocketGatway.handleMessage({
           status: 'DONE',
         })
       }
-      return { proxy,status: 'DEAD' };
+      return { proxy, status: 'DEAD' };
     } catch (error) {
       this.websocketGatway.handleMessage({
         proxy,
-        status: 'DEAD',
+        data : {
+          status: 'DEAD',
+        }
       })
-      if(isLast){
+      if (isLast) {
         this.websocketGatway.handleMessage({
           status: 'DONE',
         })
       }
-      return { proxy,status: 'DEAD' };
+      return { proxy, status: 'DEAD' };
     }
-    
+
   }
 
 }

src/main.ts

@@ -35,6 +35,6 @@ async function bootstrap() {
       'https://cdnjs.cloudflare.com/ajax/libs/swagger-ui/4.15.5/swagger-ui.css',
     ],
   });
-  await app.listen(process.env.PORT || 5000);
+  await app.listen(process.env.PORT || 2000);
 }
-bootstrap();
+bootstrap();