fix: resolve TypeScript errors for @elizaos/core 1.7.x compatibility

- Remove deprecated serverId from ensureConnection calls
- Cast serverId to UUID in Room/World objects for type safety
- Use string cast and any for custom event payloads in emitEvent
- Fix MessagePayload to use proper Memory object
- Update validateChatId return type for test compatibility
- Bump version to 1.6.4

Author: 0xbbjoker

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@elizaos/plugin-telegram",
-  "version": "1.6.3",
+  "version": "1.6.4",
   "type": "module",
   "main": "dist/index.js",
   "module": "dist/index.js",
@@ -18,7 +18,7 @@
     "dist"
   ],
   "dependencies": {
-    "@elizaos/core": "^1.6.2",
+    "@elizaos/core": "^1.7.2",
     "@telegraf/types": "7.1.0",
     "@types/node": "^24.0.10",
     "strip-literal": "^3.0.0",
@@ -27,7 +27,7 @@
     "typescript": "^5.8.3"
   },
   "devDependencies": {
-    "@elizaos/config": "^1.6.4",
+    "@elizaos/config": "^1.7.2",
     "@eslint/js": "^9.17.0",
     "@typescript-eslint/eslint-plugin": "^8.22.0",
     "@typescript-eslint/parser": "^8.22.0",

src/messageManager.ts

@@ -18,7 +18,6 @@ import { Markup } from 'telegraf';
 import {
   type TelegramContent,
   TelegramEventTypes,
-  type TelegramMessageSentPayload,
   type TelegramReactionReceivedPayload,
 } from './types';
 import { convertToTelegramButtons, convertMarkdownToTelegram, cleanText } from './utils';
@@ -593,7 +592,6 @@ export class MessageManager {
         name: ctx.from.first_name,
         source: 'telegram',
         channelId: telegramRoomid,
-        serverId: undefined,
         type: channelType,
         worldId: createUniqueUuid(this.runtime, roomId) as UUID,
         worldName: telegramRoomid,
@@ -859,20 +857,25 @@ export class MessageManager {
       }
 
       // Emit both generic and platform-specific message sent events
-      this.runtime.emitEvent(EventType.MESSAGE_SENT, {
-        runtime: this.runtime,
-        message: {
-          content: content,
-        },
-        roomId,
-        source: 'telegram',
-      });
+      if (memories.length > 0) {
+        this.runtime.emitEvent(EventType.MESSAGE_SENT, {
+          runtime: this.runtime,
+          message: memories[0],
+          source: 'telegram',
+        });
+      }
 
       // Also emit platform-specific event
-      this.runtime.emitEvent(TelegramEventTypes.MESSAGE_SENT, {
-        originalMessages: sentMessages,
-        chatId,
-      } as TelegramMessageSentPayload);
+      this.runtime.emitEvent(
+        TelegramEventTypes.MESSAGE_SENT as string,
+        {
+          runtime: this.runtime,
+          source: 'telegram',
+          originalMessages: sentMessages,
+          chatId,
+          message: memories[0],
+        } as any
+      );
 
       return sentMessages;
     } catch (error) {

src/service.ts

@@ -159,10 +159,14 @@ export class TelegramService extends Service {
    */
   private async initializeBot(): Promise<void> {
     this.bot?.start((ctx) => {
-      this.runtime.emitEvent([TelegramEventTypes.SLASH_START], {
-        // we don't need this
-        ctx,
-      });
+      this.runtime.emitEvent(
+        TelegramEventTypes.SLASH_START as string,
+        {
+          ctx,
+          runtime: this.runtime,
+          source: 'telegram',
+        } as any
+      );
     });
     this.bot?.launch({
       dropPendingUpdates: true,
@@ -386,7 +390,6 @@ export class TelegramService extends Service {
         name: ctx.from.first_name || ctx.from.username || 'Unknown User',
         source: 'telegram',
         channelId: chatId,
-        serverId: chatId,
         type: ChannelType.GROUP,
         worldId: worldId,
       });
@@ -426,24 +429,30 @@ export class TelegramService extends Service {
         entityId,
         roomId: roomId,
         userName: newMember.username,
-        userId: telegramId,
+        userId: telegramId as UUID,
         name: newMember.first_name || newMember.username || 'Unknown User',
         source: 'telegram',
         channelId: chatId,
-        serverId: chatId,
         type: ChannelType.GROUP,
         worldId: worldId,
       });
 
       this.syncedEntityIds.add(entityId);
 
-      this.runtime.emitEvent([TelegramEventTypes.ENTITY_JOINED], {
-        runtime: this.runtime,
-        entityId,
-        worldId,
-        newMember,
-        ctx,
-      });
+      this.runtime.emitEvent(
+        TelegramEventTypes.ENTITY_JOINED as string,
+        {
+          runtime: this.runtime,
+          entityId,
+          worldId,
+          source: 'telegram',
+          telegramUser: {
+            id: newMember.id,
+            username: newMember.username,
+            first_name: newMember.first_name,
+          },
+        } as any
+      );
     }
   }
 
@@ -576,7 +585,7 @@ export class TelegramService extends Service {
       id: worldId,
       name: chatTitle,
       agentId: this.runtime.agentId,
-      serverId: chatId,
+      serverId: chatId as UUID,
       metadata: {
         source: 'telegram',
         ...(ownerId && { ownership: { ownerId } }),
@@ -600,7 +609,7 @@ export class TelegramService extends Service {
       source: 'telegram',
       type: channelType,
       channelId: chatId,
-      serverId: chatId,
+      serverId: chatId as UUID,
       worldId,
     };
 
@@ -636,7 +645,6 @@ export class TelegramService extends Service {
       entities,
       generalRoom.id!,
       generalRoom.channelId!,
-      generalRoom.serverId!,
       generalRoom.type,
       worldId
     );
@@ -673,7 +681,6 @@ export class TelegramService extends Service {
    * @param {Entity[]} entities - The entities to process
    * @param {UUID} roomId - The ID of the room to connect entities to
    * @param {string} channelId - The channel ID
-   * @param {string} serverId - The server ID
    * @param {ChannelType} roomType - The type of the room
    * @param {UUID} worldId - The ID of the world
    * @returns {Promise<void>}
@@ -683,7 +690,6 @@ export class TelegramService extends Service {
     entities: Entity[],
     roomId: UUID,
     channelId: string,
-    serverId: string,
     roomType: ChannelType,
     worldId: UUID
   ): Promise<void> {
@@ -713,7 +719,6 @@ export class TelegramService extends Service {
                 userId: telegramMetadata?.id as UUID,
                 source: 'telegram',
                 channelId: channelId,
-                serverId: serverId,
                 type: roomType,
                 worldId: worldId,
               });
@@ -904,7 +909,7 @@ export class TelegramService extends Service {
         source: 'telegram',
         type: ChannelType.GROUP,
         channelId: `${chatId}-${threadId}`,
-        serverId: chatId,
+        serverId: chatId as UUID,
         worldId,
         metadata: {
           threadId: threadId,

src/tests.ts

@@ -73,10 +73,10 @@ export class TelegramTestSuite implements TestSuite {
    * @throws {Error} If TELEGRAM_TEST_CHAT_ID is not set in the runtime settings or environment variables.
    * @returns {string} The validated chat ID.
    */
-  validateChatId(runtime: IAgentRuntime) {
+  validateChatId(runtime: IAgentRuntime): string | number {
     const testChatId =
       runtime.getSetting('TELEGRAM_TEST_CHAT_ID') || process.env.TELEGRAM_TEST_CHAT_ID;
-    if (!testChatId) {
+    if (!testChatId || typeof testChatId === 'boolean') {
       throw new Error(
         'TELEGRAM_TEST_CHAT_ID is not set. Please provide a valid chat ID in the environment variables.'
       );
@@ -200,7 +200,7 @@ export class TelegramTestSuite implements TestSuite {
       if (!this.messageManager) throw new Error('MessageManager not initialized.');
 
       const chatId = this.validateChatId(runtime);
-      const fileId = await this.getFileId(chatId, TEST_IMAGE_URL);
+      const fileId = await this.getFileId(String(chatId), TEST_IMAGE_URL);
 
       const mockMessage = {
         message_id: 12345,