websocket implementation

.github/workflows/docker-publish.yml

@@ -11,6 +11,7 @@ on:
   push:
     branches:
       - main
+      - 'feature/**'
     # Publish semver tags as releases.
     tags: ['v*.*.*']
   pull_request:
@@ -115,6 +116,7 @@ jobs:
         # against the sigstore community Fulcio instance.
         run: echo "${TAGS}" | xargs -I {} cosign sign --yes {}@${DIGEST}
   deploy:
+    if: ${{ github.event_name != 'pull_request' }}
     runs-on: ubuntu-latest
     needs: build
     steps:
@@ -127,7 +129,7 @@ jobs:
           CONTAINER_NAME="${REPO#$OWNER}"
           CONTAINER_NAME="${CONTAINER_NAME#/}"
 
-          TAG=$(echo "${{github.sha}}" | cut -c1-8)
+          TAG=$(echo "${{github.sha}}" | cut -c1-7)
           TAG="sha-$TAG"
           VERSION=$(echo "${{ github.ref }}" | sed -e 's,.*/\(.*\),\1,')
 
@@ -144,14 +146,15 @@ jobs:
           export-env: true
         env:
           OP_SERVICE_ACCOUNT_TOKEN: ${{ secrets.OP_SERVICE_ACCOUNT_TOKEN }}
-          HOST: op://end.works/end.works/URL
-          PORT: op://end.works/end.works/port
-          USERNAME: op://end.works/end.works/username
+          HOST: op://end.works/wired/URL
+          PORT: op://end.works/wired/port
+          USERNAME: op://end.works/wired/username
           KEY: op://end.works/SSH Key/private key
           FINGERPRINT: op://end.works/SSH Key/fingerprint
+          MONGODB_URI: op://end.works/Polaris Config/mongodb uri
 
       - name: Run container on host
-        uses: appleboy/ssh-action@v0.1.10
+        uses: appleboy/ssh-action@v1.0.3
         with:
           host: ${{ env.HOST }}
           port: ${{ env.PORT }}
@@ -161,7 +164,7 @@ jobs:
             docker pull ghcr.io/${{ github.repository }}:${{ env.TAG }}
             docker stop ${{ env.CONTAINER_NAME }}
             docker rm ${{ env.CONTAINER_NAME }}
-            docker run -v $PWD/logs:/usr/src/app/logs -v $PWD/docs/data:/usr/src/app/data -v $PWD/docs/firebase.json:/usr/src/app/firebase.json -p 1984:1984/tcp -ti -d --restart unless-stopped --name ${{ env.CONTAINER_NAME }} ghcr.io/${{ github.repository }}:${{ env.TAG }}
+            docker run -e MONGODB_URI=${{ env.MONGODB_URI }} -v $PWD/logs:/usr/src/app/logs -p 8040:8080 -e TZ=Europe/Madrid -ti -d --restart unless-stopped --name ${{ env.CONTAINER_NAME }} ghcr.io/${{ github.repository }}:${{ env.TAG }}
 
       - name: Generate summary
         id: generate-summary

.husky/pre-commit

@@ -0,0 +1 @@
+yarn run format

Dockerfile

@@ -1,4 +1,6 @@
-FROM ghcr.io/ender-null/polaris-base:latest-debian as builder
+FROM node:slim as builder
+
+RUN npm install yarn@latest -g --force
 
 RUN mkdir -p /usr/src/app
 
@@ -13,7 +15,7 @@ COPY . .
 
 RUN yarn run build
 
-FROM ghcr.io/ender-null/polaris-base:latest-debian as release
+FROM node:slim as release
 
 LABEL org.opencontainers.image.source https://github.com/ender-null/polaris
 
@@ -23,4 +25,11 @@ COPY --from=builder /usr/src/app/node_modules ./node_modules
 COPY --from=builder /usr/src/app/build ./build
 COPY --from=builder /usr/src/app/package.json ./
 
+RUN apt-get update
+RUN apt-get upgrade -y
+RUN apt-get install -y ffmpeg opus-tools cron
+RUN npm install yarn@latest -g --force
+RUN crontab -l -u root | echo "*/15 * * * * find /tmp -type f -delete" | crontab -u root -
+ENV TZ=Europe/Madrid
+
 CMD ["yarn", "start"]

package.json

@@ -1,6 +1,6 @@
 {
   "name": "polaris",
-  "version": "0.10.1",
+  "version": "1.0.0",
   "description": "A multi platform TypeScript bot using plugins!",
   "license": "AGPL-3.0",
   "author": {
@@ -21,16 +21,16 @@
     "typedoc": "typedoc",
     "build": "tsc -p tsconfig.release.json",
     "build:watch": "tsc -w -p tsconfig.release.json",
-    "start": "NODE_OPTIONS=\"--max_old_space_size=4096\" UV_THREADPOOL_SIZE=128 node build/src/main.js",
-    "start:dev": "ENV=\"dev\" node build/src/main.js",
+    "start": "node build/src/main.js",
     "test": "echo \"No tests yet\" && exit 0",
     "lint": "eslint . --ext .ts",
     "lint:fix": "eslint . --ext .ts --fix",
-    "format": "prettier --write src"
+    "format": "prettier --write src",
+    "prepare": "husky"
   },
   "husky": {
     "hooks": {
-      "pre-commit": "npm run lint"
+      "pre-commit": "yarn run format"
     }
   },
   "type": "commonjs",
@@ -39,51 +39,47 @@
   },
   "dependencies": {
     "cheerio": "^1.0.0-rc.12",
-    "discord.js": "^14.14.1",
-    "firebase": "^10.10.0",
+    "crypto": "^1.0.1",
     "form-data": "^4.0.0",
     "html-to-text": "^9.0.5",
-    "matrix-bot-sdk": "^0.7.1",
     "mime-types": "^2.1.35",
+    "mongodb": "^6.7.0",
     "node-cron": "^3.0.3",
-    "node-fetch": "^2",
-    "prebuilt-tdlib": "^0.1008026.0",
+    "node-fetch": "^2.7.0",
+    "openai": "^4.51.0",
     "string-format": "^2.0.0",
-    "tdl": "v7.4.1",
-    "tdl-tdlib-addon": "^1.2.2",
     "tmp": "^0.2.3",
     "winston": "^3.13.0",
-    "winston-daily-rotate-file": "^5.0.0"
+    "winston-daily-rotate-file": "^5.0.0",
+    "ws": "^8.17.0"
   },
   "devDependencies": {
     "@types/mime-types": "^2.1.4",
-    "@types/node": "^20.12.2",
+    "@types/node": "^20.14.2",
     "@types/node-fetch": "^3.0.3",
     "@types/tmp": "^0.2.6",
-    "@typescript-eslint/eslint-plugin": "^7.4.0",
-    "@typescript-eslint/parser": "^7.4.0",
-    "eslint": "^8.57.0",
+    "@types/ws": "^8.5.10",
+    "@typescript-eslint/eslint-plugin": "^7.13.0",
+    "@typescript-eslint/parser": "^7.13.0",
+    "eslint": "^9.4.0",
     "eslint-config-prettier": "^9.1.0",
     "eslint-config-standard": "^17.1.0",
     "eslint-config-standard-with-typescript": "^21.0.1",
-    "eslint-plugin-ava": "^14.0.0",
+    "eslint-plugin-ava": "^15.0.1",
     "eslint-plugin-import": "^2.29.1",
     "eslint-plugin-node": "^11.1.0",
     "eslint-plugin-prettier": "^5.1.3",
-    "eslint-plugin-promise": "^6.1.1",
-    "fluture": "^14.0.0",
+    "eslint-plugin-promise": "^6.2.0",
     "husky": "^9.0.11",
-    "prettier": "^3.2.5",
-    "tdlib-types": "td-1.8.14",
-    "typedoc": "^0.25.12",
-    "typescript": "^5.4.3"
+    "pinst": "^3.0.0",
+    "prettier": "^3.3.2",
+    "typedoc": "^0.25.13",
+    "typescript": "^5.4.5"
   },
   "keywords": [
     "polaris",
     "polaris js",
     "polaris.js",
-    "telegram",
-    "telegram bot api",
     "bot",
     "botapi",
     "bot framework"

src/actions.ts

@@ -0,0 +1,148 @@
+import { Bot } from './bot';
+import { ConversationInfo, Message, User } from './types';
+
+export class Actions {
+  bot: Bot;
+
+  constructor(bot: Bot) {
+    this.bot = bot;
+  }
+
+  async getMessage(chatId: string | number, messageId: string | number, ignoreReply?: boolean): Promise<Message> {
+    this.bot.sendCommand('getMessage', {
+      chatId,
+      messageId,
+      ignoreReply,
+    });
+    return null;
+  }
+  async deleteMessage(chatId: string | number, messageId: string | number): Promise<boolean> {
+    this.bot.sendCommand('deleteMessage', {
+      chatId,
+      messageId,
+    });
+    return null;
+  }
+  async getFile(fileId: string | number, link?: boolean): Promise<string> {
+    this.bot.sendCommand('getFile', {
+      fileId,
+      link,
+    });
+    return null;
+  }
+  async createInviteLink(
+    conversationId: string | number,
+    name?: string,
+    createsJoinRequest?: boolean,
+    expirationDate?: number,
+    memberLimit?: number,
+  ): Promise<string> {
+    this.bot.sendCommand('createInviteLink', {
+      conversationId,
+      name,
+      createsJoinRequest,
+      expirationDate,
+      memberLimit,
+    });
+    return null;
+  }
+  async checkInviteLink(inviteLink: string | number): Promise<boolean> {
+    this.bot.sendCommand('checkInviteLink', {
+      inviteLink,
+    });
+    return null;
+  }
+  async joinByInviteLink(inviteLink: string | number): Promise<boolean> {
+    this.bot.sendCommand('joinByInviteLink', {
+      inviteLink,
+    });
+    return null;
+  }
+  async inviteConversationMember(conversationId: string | number, userId: string | number): Promise<boolean> {
+    this.bot.sendCommand('inviteConversationMember', {
+      conversationId,
+      userId,
+    });
+    return null;
+  }
+  async promoteConversationMember(conversationId: string | number, userId: string | number): Promise<boolean> {
+    this.bot.sendCommand('promoteConversationMember', {
+      conversationId,
+      userId,
+    });
+    return null;
+  }
+  async kickConversationMember(conversationId: string | number, userId: string | number): Promise<boolean> {
+    this.bot.sendCommand('kickConversationMember', {
+      conversationId,
+      userId,
+    });
+    return null;
+  }
+  async leaveConversation(conversationId: string | number): Promise<boolean> {
+    this.bot.sendCommand('leaveConversation', {
+      conversationId,
+    });
+    return null;
+  }
+  async banConversationMember(conversationId: string | number, userId: string | number): Promise<boolean> {
+    this.bot.sendCommand('banConversationMember', {
+      conversationId,
+      userId,
+    });
+    return null;
+  }
+  async unbanConversationMember(conversationId: string | number, userId: string | number): Promise<boolean> {
+    this.bot.sendCommand('unbanConversationMember', {
+      conversationId,
+      userId,
+    });
+    return null;
+  }
+  async renameConversation(conversationId: string | number, title: string): Promise<boolean> {
+    this.bot.sendCommand('renameConversation', {
+      conversationId,
+      title,
+    });
+    return null;
+  }
+  async changeConversationDescription(conversationId: string | number, description: string): Promise<boolean> {
+    this.bot.sendCommand('changeConversationDescription', {
+      conversationId,
+      description,
+    });
+    return null;
+  }
+  async changeConversationPhoto(conversationId: string | number, photo: string): Promise<boolean> {
+    this.bot.sendCommand('changeConversationPhoto', {
+      conversationId,
+      photo,
+    });
+    return null;
+  }
+  async createCall(conversationId: string | number, isVideo: boolean): Promise<boolean> {
+    this.bot.sendCommand('createCall', {
+      conversationId,
+      isVideo,
+    });
+    return null;
+  }
+  async conversationInfo(conversationId: string | number): Promise<ConversationInfo> {
+    this.bot.sendCommand('conversationInfo', {
+      conversationId,
+    });
+    return null;
+  }
+  async getChatAdministrators(conversationId: string | number): Promise<User[]> {
+    this.bot.sendCommand('getChatAdministrators', {
+      conversationId,
+    });
+    return null;
+  }
+  async setCommands(commands: any[]): Promise<boolean> {
+    this.bot.sendCommand('setCommands', {
+      commands,
+    });
+    return null;
+  }
+}