telegram plugin

.vscode/extensions.json

@@ -1,3 +1,7 @@
 {
-  "recommendations": ["ms-playwright.playwright"]
+  "recommendations": [
+    "ms-playwright.playwright",
+    "esbenp.prettier-vscode",
+    "firsttris.vscode-jest-runner"
+  ]
 }

.vscode/settings.json

@@ -11,5 +11,6 @@
   "search.exclude": {
     "**/node_modules": true,
     "**/build": true
-  }
+  },
+  "eslint.validate": ["json"]
 }

plugins/index.ts

@@ -1 +1,2 @@
 export * from './core/src/index'
+export * from './telegram/src/index'

plugins/telegram/.eslintrc.json

@@ -0,0 +1,32 @@
+{
+  "extends": ["../../.eslintrc.json"],
+  "ignorePatterns": ["!**/*"],
+  "overrides": [
+    {
+      "files": ["*.ts", "*.tsx", "*.js", "*.jsx"],
+      "rules": {}
+    },
+    {
+      "files": ["*.ts", "*.tsx"],
+      "rules": {}
+    },
+    {
+      "files": ["*.js", "*.jsx"],
+      "rules": {}
+    },
+    {
+      "files": ["*.json"],
+      "parser": "jsonc-eslint-parser",
+      "rules": {
+        "@nx/dependency-checks": "error"
+      }
+    },
+    {
+      "files": ["./package.json"],
+      "parser": "jsonc-eslint-parser",
+      "rules": {
+        "@nx/nx-plugin-checks": "error"
+      }
+    }
+  ]
+}

plugins/telegram/README.md

@@ -0,0 +1,11 @@
+# telegram
+
+This library was generated with [Nx](https://nx.dev).
+
+## Building
+
+Run `nx build telegram` to build the library.
+
+## Running unit tests
+
+Run `nx test telegram` to execute the unit tests via [Jest](https://jestjs.io).

plugins/telegram/jest.config.ts

@@ -0,0 +1,10 @@
+/* eslint-disable */
+export default {
+  displayName: 'telegram',
+  preset: '../../jest.preset.js',
+  transform: {
+    '^.+\\.[tj]s$': ['ts-jest', { tsconfig: '<rootDir>/tsconfig.spec.json' }],
+  },
+  moduleFileExtensions: ['ts', 'js', 'html'],
+  coverageDirectory: '../../coverage/plugins/telegram',
+}

plugins/telegram/package.json

@@ -0,0 +1,10 @@
+{
+  "name": "telegram",
+  "version": "0.0.1",
+  "dependencies": {
+    "tslib": "^2.3.0"
+  },
+  "type": "commonjs",
+  "main": "./src/index.js",
+  "typings": "./src/index.d.ts"
+}

plugins/telegram/project.json

@@ -0,0 +1,58 @@
+{
+  "name": "telegram",
+  "$schema": "../../node_modules/nx/schemas/project-schema.json",
+  "sourceRoot": "plugins/telegram/src",
+  "projectType": "library",
+  "targets": {
+    "build": {
+      "executor": "@nx/js:tsc",
+      "outputs": ["{options.outputPath}"],
+      "options": {
+        "outputPath": "dist/plugins/telegram",
+        "main": "plugins/telegram/src/index.ts",
+        "tsConfig": "plugins/telegram/tsconfig.lib.json",
+        "assets": [
+          "plugins/telegram/*.md",
+          {
+            "input": "./plugins/telegram/src",
+            "glob": "**/!(*.ts)",
+            "output": "./src"
+          },
+          {
+            "input": "./plugins/telegram/src",
+            "glob": "**/*.d.ts",
+            "output": "./src"
+          },
+          {
+            "input": "./plugins/telegram",
+            "glob": "generators.json",
+            "output": "."
+          },
+          {
+            "input": "./plugins/telegram",
+            "glob": "executors.json",
+            "output": "."
+          }
+        ]
+      }
+    },
+    "lint": {
+      "executor": "@nx/eslint:lint",
+      "outputs": ["{options.outputFile}"],
+      "options": {
+        "lintFilePatterns": [
+          "plugins/telegram/**/*.ts",
+          "plugins/telegram/package.json"
+        ]
+      }
+    },
+    "test": {
+      "executor": "@nx/jest:jest",
+      "outputs": ["{workspaceRoot}/coverage/{projectRoot}"],
+      "options": {
+        "jestConfig": "plugins/telegram/jest.config.ts"
+      }
+    }
+  },
+  "tags": []
+}

plugins/telegram/src/index.ts

@@ -0,0 +1 @@
+export * from './lib/telegramPlugin'

plugins/telegram/src/lib/constants.ts

@@ -0,0 +1,36 @@
+import { PluginCredential } from 'server/credentials'
+
+export const pluginName = 'Telegram'
+
+export const pluginCredentials: PluginCredential[] = [
+  {
+    name: 'telegram-bot',
+    serviceType: 'telegram',
+    credentialType: 'plugin',
+    initials: 'TBT',
+  },
+]
+
+export const TELEGRAM_EVENTS = {
+  MESSAGE: 'message',
+  EDITED_MESSAGE: 'edited_message',
+  CHANNEL_POST: 'channel_post',
+  EDITED_CHANNEL_POST: 'edited_channel_post',
+  INLINE_QUERY: 'inline_query',
+  CHOSEN_INLINE_RESULT: 'chosen_inline_result',
+  CALLBACK_QUERY: 'callback_query',
+  SHIPPING_QUERY: 'shipping_query',
+  PRE_CHECKOUT_QUERY: 'pre_checkout_query',
+  POLL: 'poll',
+  POLL_ANSWER: 'poll_answer',
+}
+
+export const TELEGRAM_ACTIONS = {
+  SEND_MESSAGE: 'sendMessage',
+  SEND_IMAGE: 'sendImage',
+  GENERATE_IMAGE: 'generateImage',
+}
+
+export const TELEGRAM_KEY = 'telegramClient'
+
+export const TELEGRAM_DEVELOPER_MODE = false

plugins/telegram/src/lib/nodes/actions/sendTelegramMessage.ts

@@ -0,0 +1,26 @@
+import { TelegramClient } from '../../services/telegram'
+import { EventPayload } from 'packages/server/plugin/src'
+import { TelegramEventPayload } from '../../types'
+import { SocketDefinition } from '@magickml/behave-graph'
+import { TELEGRAM_KEY } from '../../constants'
+import { IEventStore } from 'server/grimoire'
+
+type Inputs = {
+  flow: SocketDefinition
+  content: SocketDefinition
+}
+
+type Outputs = {
+  flow: SocketDefinition
+}
+
+export const sendTelegramMessage = async (
+  dependencies: { [TELEGRAM_KEY]: TelegramClient; IEventStore: IEventStore },
+  inputs: { content: string },
+  event: EventPayload<TelegramEventPayload>
+): Promise<void> => {
+  await dependencies[TELEGRAM_KEY].getClient().sendMessage({
+    text: inputs.content,
+    chat_id: event.chat.id,
+  })
+}

plugins/telegram/src/lib/nodes/events/telegramMessageEvents.ts

@@ -0,0 +1,78 @@
+import {
+    Assert,
+    NodeCategory,
+    makeEventNodeDefinition,
+  } from '@magickml/behave-graph'
+  import { TELEGRAM_EVENTS } from '../../constants'
+  import { EventPayload } from 'packages/server/plugin/src'
+
+  type State = {
+    onStartEvent?: ((event: EventPayload) => void) | undefined
+  }
+
+  const makeInitialState = (): State => ({
+    onStartEvent: undefined,
+  })
+
+  export const telegramMessageEvent = makeEventNodeDefinition({
+    typeName: 'telegram/onMessage',
+    label: 'On Telegram Message',
+    category: NodeCategory.Event,
+    configuration: {
+      numInputs: {
+        valueType: 'number',
+        defaultValue: 3,
+      },
+    },
+    in: {},
+    out: {
+      flow: 'flow',
+      content: 'string',
+      event: 'object',
+    },
+    initialState: makeInitialState(),
+    init: args => {
+      const {
+        write,
+        commit,
+        node,
+        engine,
+        graph: { getDependency },
+      } = args
+      const onStartEvent = (event: EventPayload) => {
+        write('event', event)
+        write('content', event.content)
+
+        console.log('event', event)
+        console.log('content', event.content)
+
+        commit('flow')
+
+        if (!node || !engine) return
+
+        engine.onNodeExecutionEnd.emit(node)
+      }
+
+      const telegramEventEmitter = getDependency('Telegram')
+
+      telegramEventEmitter?.on('message', onStartEvent)
+
+      return {
+        onStartEvent,
+      }
+    },
+    dispose: ({ state: { onStartEvent }, graph: { getDependency } }) => {
+      Assert.mustBeTrue(onStartEvent !== undefined)
+
+      const telegramEventEmitter = getDependency('Telegram')
+
+      if (onStartEvent)
+        telegramEventEmitter?.removeListener(
+          TELEGRAM_EVENTS.message,
+          onStartEvent
+        )
+
+      return {}
+    },
+  })
+