Skip to content

Commit 60a7c06

Browse files
humanagenthumanagent
committed
telegram'
1 parent dcb7936 commit 60a7c06

File tree

5 files changed

+45
-39
lines changed

5 files changed

+45
-39
lines changed

‎packages/client-telegram/package.json

+3-3
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,11 @@
11
{
2-
"name": "@ai16z/client-telegram",
3-
"version": "0.1.6-alpha.4",
2+
"name": "@elizaos/client-telegram",
3+
"version": "0.1.7-alpha.1",
44
"main": "dist/index.js",
55
"type": "module",
66
"types": "dist/index.d.ts",
77
"dependencies": {
8-
"@ai16z/eliza": "workspace:*",
8+
"@elizaos/core": "workspace:*",
99
"@telegraf/types": "7.1.0",
1010
"telegraf": "4.16.3",
1111
"zod": "3.23.8"

‎packages/client-telegram/src/environment.ts

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
import { IAgentRuntime } from "@ai16z/eliza";
1+
import { IAgentRuntime } from "@elizaos/core";
22
import { z } from "zod";
33

44
export const telegramEnvSchema = z.object({

‎packages/client-telegram/src/index.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
1-
import { elizaLogger } from "@ai16z/eliza";
2-
import { Client, IAgentRuntime } from "@ai16z/eliza";
1+
import { elizaLogger } from "@elizaos/core";
2+
import { Client, IAgentRuntime } from "@elizaos/core";
33
import { TelegramClient } from "./telegramClient.ts";
44
import { validateTelegramConfig } from "./environment.ts";
55

‎packages/client-telegram/src/messageManager.ts

+22-26
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
import { Message } from "@telegraf/types";
22
import { Context, Telegraf } from "telegraf";
33

4-
import { composeContext, elizaLogger, ServiceType } from "@ai16z/eliza";
5-
import { getEmbeddingZeroVector } from "@ai16z/eliza";
4+
import { composeContext, elizaLogger, ServiceType } from "@elizaos/core";
5+
import { getEmbeddingZeroVector } from "@elizaos/core";
66
import {
77
Content,
88
HandlerCallback,
@@ -13,11 +13,11 @@ import {
1313
State,
1414
UUID,
1515
Media,
16-
} from "@ai16z/eliza";
17-
import { stringToUuid } from "@ai16z/eliza";
16+
} from "@elizaos/core";
17+
import { stringToUuid } from "@elizaos/core";
1818

19-
import { generateMessageResponse, generateShouldRespond } from "@ai16z/eliza";
20-
import { messageCompletionFooter, shouldRespondFooter } from "@ai16z/eliza";
19+
import { generateMessageResponse, generateShouldRespond } from "@elizaos/core";
20+
import { messageCompletionFooter, shouldRespondFooter } from "@elizaos/core";
2121

2222
import { cosineSimilarity } from "./utils";
2323
import {
@@ -702,7 +702,7 @@ export class MessageManager {
702702
i === 0 && replyToMessageId
703703
? { message_id: replyToMessageId }
704704
: undefined,
705-
parse_mode:'Markdown'
705+
parse_mode: "Markdown",
706706
}
707707
)) as Message.TextMessage;
708708

@@ -721,21 +721,17 @@ export class MessageManager {
721721
try {
722722
if (/^(http|https):\/\//.test(imagePath)) {
723723
// Handle HTTP URLs
724-
await ctx.telegram.sendPhoto(
725-
ctx.chat.id,
726-
imagePath,
727-
{
728-
caption,
729-
}
730-
);
724+
await ctx.telegram.sendPhoto(ctx.chat.id, imagePath, {
725+
caption,
726+
});
731727
} else {
732-
// Handle local file paths
728+
// Handle local file paths
733729
if (!fs.existsSync(imagePath)) {
734730
throw new Error(`File not found: ${imagePath}`);
735731
}
736-
732+
737733
const fileStream = fs.createReadStream(imagePath);
738-
734+
739735
await ctx.telegram.sendPhoto(
740736
ctx.chat.id,
741737
{
@@ -746,7 +742,7 @@ export class MessageManager {
746742
}
747743
);
748744
}
749-
745+
750746
elizaLogger.info(`Image sent successfully: ${imagePath}`);
751747
} catch (error) {
752748
elizaLogger.error("Error sending image:", error);
@@ -1085,7 +1081,7 @@ export class MessageManager {
10851081
for (let i = 0; i < sentMessages.length; i++) {
10861082
const sentMessage = sentMessages[i];
10871083
const isLastMessage = i === sentMessages.length - 1;
1088-
1084+
10891085
const memory: Memory = {
10901086
id: stringToUuid(
10911087
sentMessage.message_id.toString() +
@@ -1103,17 +1099,19 @@ export class MessageManager {
11031099
createdAt: sentMessage.date * 1000,
11041100
embedding: getEmbeddingZeroVector(),
11051101
};
1106-
1102+
11071103
// Set action to CONTINUE for all messages except the last one
11081104
// For the last message, use the original action from the response content
11091105
memory.content.action = !isLastMessage
11101106
? "CONTINUE"
11111107
: content.action;
1112-
1113-
await this.runtime.messageManager.createMemory(memory);
1108+
1109+
await this.runtime.messageManager.createMemory(
1110+
memory
1111+
);
11141112
memories.push(memory);
11151113
}
1116-
1114+
11171115
return memories;
11181116
}
11191117
};
@@ -1125,14 +1123,12 @@ export class MessageManager {
11251123
state = await this.runtime.updateRecentMessageState(state);
11261124

11271125
// Handle any resulting actions
1128-
1129-
const actionResult: any = await this.runtime.processActions(
1126+
await this.runtime.processActions(
11301127
memory,
11311128
responseMessages,
11321129
state,
11331130
callback
11341131
);
1135-
console.log("actionResult", actionResult);
11361132
}
11371133

11381134
await this.runtime.evaluate(memory, state, shouldRespond);

‎packages/client-telegram/src/telegramClient.ts

+17-7
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
import { Context, Telegraf } from "telegraf";
2-
import { message } from 'telegraf/filters';
3-
import { IAgentRuntime, elizaLogger } from "@ai16z/eliza";
2+
import { message } from "telegraf/filters";
3+
import { IAgentRuntime, elizaLogger } from "@elizaos/core";
44
import { MessageManager } from "./messageManager.ts";
55
import { getOrCreateRecommenderInBe } from "./getOrCreateRecommenderInBe.ts";
66

@@ -67,7 +67,10 @@ export class TelegramClient {
6767
await ctx.reply("Not authorized. Leaving.");
6868
await ctx.leaveChat();
6969
} catch (error) {
70-
elizaLogger.error(`Error leaving unauthorized group ${currentGroupId}:`, error);
70+
elizaLogger.error(
71+
`Error leaving unauthorized group ${currentGroupId}:`,
72+
error
73+
);
7174
}
7275
return false;
7376
}
@@ -78,10 +81,12 @@ export class TelegramClient {
7881
private setupMessageHandlers(): void {
7982
elizaLogger.log("Setting up message handler...");
8083

81-
this.bot.on(message('new_chat_members'), async (ctx) => {
84+
this.bot.on(message("new_chat_members"), async (ctx) => {
8285
try {
8386
const newMembers = ctx.message.new_chat_members;
84-
const isBotAdded = newMembers.some(member => member.id === ctx.botInfo.id);
87+
const isBotAdded = newMembers.some(
88+
(member) => member.id === ctx.botInfo.id
89+
);
8590

8691
if (isBotAdded && !(await this.isGroupAuthorized(ctx))) {
8792
return;
@@ -129,9 +134,14 @@ export class TelegramClient {
129134
// Don't try to reply if we've left the group or been kicked
130135
if (error?.response?.error_code !== 403) {
131136
try {
132-
await ctx.reply("An error occurred while processing your message.");
137+
await ctx.reply(
138+
"An error occurred while processing your message."
139+
);
133140
} catch (replyError) {
134-
elizaLogger.error("Failed to send error message:", replyError);
141+
elizaLogger.error(
142+
"Failed to send error message:",
143+
replyError
144+
);
135145
}
136146
}
137147
}

0 commit comments

Comments
 (0)