Build a Telegram Trading Bot

enabled: true
id: telegram_bot_cred_storage

http:
  listenPath: /telegram
  method: POST
  next: action.fetch_credentials
  corsAllowedOrigins: []

actions:
  fetch_credentials:
    name: fetch_credentials
    type: fetch
    config:
      integrationID: mongo-main
      table: credentials
      filters:
        - field: user_id
          operation: "=="
          comparator: '{{ body "message.from.id" }}'
      single: true
      shouldFail: true
      failIfEmpty: true
    next: action.send_typing
    fail: action.parse_command

  parse_command:
    name: parse_command
    type: javascript
    config:
      script: |
        function servflowRun(vars) {
          const paramText = "{{ body \"message.text\"}}";
          try {
            const text = paramText;
            const match = text.trim().match(/^\/(\w+)\s*(.*)$/);
            if (!match || match[1].toLowerCase() !== "save_creds") {
              return { command: "", args: [] };
            }
            const command = "/" + match[1];
            let args;
            try {
              args = JSON.parse(match[2]);
            } catch {
              args = match[2]?.trim() ? match[2].trim().split(/\s+/) : [];
            }
            return { command, args };
          } catch (err) {
            return { command: "", args: [] };
          }
        }
    next: conditional.is_save_creds
    fail: response.error

  save_creds:
    name: save_creds
    type: store
    config:
      integrationID: mongo-main
      table: credentials
      fields:
        user_id: '{{ body "message.from.id" }}'
        api_key: '{{ index .parse_command.args 0 }}'
        api_secret: '{{ index .parse_command.args 1 }}'
        saved_at: '{{ now }}'
    next: action.confirm_save
    fail: response.error

  confirm_save:
    name: confirm_save
    type: http
    config:
      method: POST
      url: https://api.telegram.org/bot{{ secret "TELEGRAM_BOT_TOKEN" }}/sendMessage
      headers:
        Content-Type: application/json
      body:
        chat_id: '{{ body "message.chat.id" }}'
        text: "Credentials saved successfully"
      failIfResponseEmpty: true
    next: response.success
    fail: response.error

  tell_user_to_save:
    name: tell_user_to_save
    type: http
    config:
      method: POST
      url: https://api.telegram.org/bot{{ secret "TELEGRAM_BOT_TOKEN" }}/sendMessage
      headers:
        Content-Type: application/json
      body:
        chat_id: '{{ body "message.chat.id" }}'
        text: "Please add credentials first with /save_creds <api_key> <secret_key>"
      expectedResponseCode: "200"
      failIfResponseEmpty: true
    next: response.success
    fail: response.error

  send_typing:
    name: send_typing
    type: http
    config:
      method: GET
      url: https://api.telegram.org/bot{{ secret "TELEGRAM_BOT_TOKEN" }}/sendChatAction?chat_id={{ body "message.chat.id" }}&action=typing
      failIfResponseEmpty: true
    next: action.agent_llm
    fail: response.error

  agent_llm:
    name: agent_llm
    type: agent
    config:
      integrationID: open-ai-main
      conversationID: '{{ body "message.chat.id" }}'
      systemPrompt: >
        You are a helpful telegram bot for performing actions on behalf of a user.
        You have access to tools to help you achieve your request.
      userPrompt: '{{ body "message.text" }}'
      returnLastMessage: false
      toolConfigs:
        - type: workflow
          workflowConfig:
            name: price_difference
            description: >
              This is for getting the price history ticks for a certain period
              over every hour. The period is the number of 1hr intervals to get
              e.g 12, the symbol is the pair e.g BTCUSDT
            params:
              - period
              - symbol
            start: action.get_price_difference
            returnValue: '{{ escape (jsonout .get_price_difference) }}'
            type: string
        - type: workflow
          workflowConfig:
            name: account_balance
            description: This tool is for fetching the account balance of the user
            params: []
            start: action.get_account_balance
            returnValue: '{{ .get_account_balance }}'
            type: string
    next: action.telegram_reply
    fail: response.error

  get_price_difference:
    name: get_price_difference
    type: binance/pricedifference
    config:
      integrationID: telegram_bot_cred_storage_binance
      interval: 1h
      period: '{{ tool_param "period" }}'
      symbol: '{{ tool_param "symbol" }}'

  get_account_balance:
    name: get_account_balance
    type: binance/accountbalance
    config:
      integrationID: telegram_bot_cred_storage_binance
      futures: false
      symbol: ""

  telegram_reply:
    name: telegram_reply
    type: http
    config:
      method: POST
      url: https://api.telegram.org/bot{{ secret "TELEGRAM_BOT_TOKEN" }}/sendMessage
      headers:
        Content-Type: application/json
      body:
        chat_id: '{{ body "message.chat.id" }}'
        text: '{{ .agent_llm | escape }}'
      failIfResponseEmpty: true
    next: response.success
    fail: response.error

conditionals:
  is_save_creds:
    name: is_save_creds
    expression: '{{ eq .parse_command.command "/save_creds" }}'
    onTrue: action.save_creds
    onFalse: action.tell_user_to_save

responses:
  success:
    name: success
    code: 200
    responseObject:
      fields:
        message:
          value: "Reply sent via Telegram"

  error:
    name: error
    code: 500
    responseObject:
      fields:
        error:
          value: '{{ .error }}'

integrations:
  telegram_bot_cred_storage_binance:
    type: binance
    lazyLoad: true
    config:
      api_key: '{{ .fetch_credentials.api_key }}'
      secret_key: '{{ .fetch_credentials.api_secret }}'
      testnet: false
      timeout: 30