Skip to content

Commit 0bef8ac

Browse files
tharak123455tharak123455
authored
Update interactions.ts
1 parent fb24df4 commit 0bef8ac

File tree

1 file changed

+117
-32
lines changed

1 file changed

+117
-32
lines changed

‎packages/client-twitter/src/interactions.ts

+117-32
Original file line numberDiff line numberDiff line change
@@ -48,26 +48,28 @@ Thread of Tweets You Are Replying To:
4848
4949
{{actions}}
5050
51-
# Task: Generate a post in the voice, style and perspective of {{agentName}} (@{{twitterUserName}}). You MUST include an action if the current post text includes a prompt that is similar to one of the available actions mentioned here:
52-
{{actionNames}}
53-
54-
Here is the current post text again. Remember to include an action if the current post text includes a prompt that asks for one of the available actions mentioned above (does not need to be exact):
51+
# Task: Generate a post in the voice, style and perspective of {{agentName}} (@{{twitterUserName}}). Include an action, if appropriate. {{actionNames}}:
5552
{{currentPost}}
5653
` + messageCompletionFooter;
5754

58-
export const twitterShouldRespondTemplate =
55+
export const twitterShouldRespondTemplate = (targetUsersStr: string) =>
5956
`# INSTRUCTIONS: Determine if {{agentName}} (@{{twitterUserName}}) should respond to the message and participate in the conversation. Do not comment. Just respond with "true" or "false".
6057
61-
Response options are RESPOND, IGNORE and STOP .
58+
Response options are RESPOND, IGNORE and STOP.
59+
60+
PRIORITY RULE: ALWAYS RESPOND to these users regardless of topic or message content: ${targetUsersStr}. Topic relevance should be ignored for these users.
61+
62+
For other users:
63+
- {{agentName}} should RESPOND to messages directed at them
64+
- {{agentName}} should RESPOND to conversations relevant to their background
65+
- {{agentName}} should IGNORE irrelevant messages
66+
- {{agentName}} should IGNORE very short messages unless directly addressed
67+
- {{agentName}} should STOP if asked to stop
68+
- {{agentName}} should STOP if conversation is concluded
6269
63-
{{agentName}} should respond to messages that are directed at them, or participate in conversations that are interesting or relevant to their background, IGNORE messages that are irrelevant to them, and should STOP if the conversation is concluded.
70+
{{recentPosts}}
6471
65-
{{agentName}} is in a room with other users and wants to be conversational, but not annoying.
66-
{{agentName}} must RESPOND to messages that are directed at them, a command towards them, or participate in conversations that are interesting or relevant to their background.
67-
If a message is not interesting or relevant, {{agentName}} should IGNORE.
68-
Unless directly RESPONDing to a user, {{agentName}} should IGNORE messages that are very short or do not contain much information.
69-
If a user asks {{agentName}} to stop talking, {{agentName}} should STOP.
70-
If {{agentName}} concludes a conversation and isn't part of the conversation anymore, {{agentName}} should STOP.
72+
IMPORTANT: For users not in the priority list, {{agentName}} (@{{twitterUserName}}) should err on the side of IGNORE rather than RESPOND if in doubt.
7173
7274
{{recentPosts}}
7375
@@ -106,20 +108,89 @@ export class TwitterInteractionClient {
106108

107109
async handleTwitterInteractions() {
108110
elizaLogger.log("Checking Twitter interactions");
111+
// Read from environment variable, fallback to default list if not set
112+
const targetUsersStr = this.runtime.getSetting("TWITTER_TARGET_USERS");
113+
114+
const twitterUsername = this.client.profile.username;
115+
try {
116+
// Check for mentions
117+
const mentionCandidates = (
118+
await this.client.fetchSearchTweets(
119+
`@${twitterUsername}`,
120+
20,
121+
SearchMode.Latest
122+
)
123+
).tweets;
124+
125+
elizaLogger.log("Completed checking mentioned tweets:", mentionCandidates.length);
126+
let uniqueTweetCandidates = [...mentionCandidates];
127+
// Only process target users if configured
128+
if (targetUsersStr && targetUsersStr.trim()) {
129+
const TARGET_USERS = targetUsersStr.split(',')
130+
.map(u => u.trim())
131+
.filter(u => u.length > 0); // Filter out empty strings after split
132+
133+
elizaLogger.log("Processing target users:", TARGET_USERS);
134+
135+
if (TARGET_USERS.length > 0) {
136+
// Create a map to store tweets by user
137+
const tweetsByUser = new Map<string, Tweet[]>();
138+
139+
// Fetch tweets from all target users
140+
for (const username of TARGET_USERS) {
141+
try {
142+
const userTweets = (await this.client.twitterClient.fetchSearchTweets(
143+
`from:${username}`,
144+
3,
145+
SearchMode.Latest
146+
)).tweets;
147+
148+
// Filter for unprocessed, non-reply, recent tweets
149+
const validTweets = userTweets.filter(tweet => {
150+
const isUnprocessed = !this.client.lastCheckedTweetId ||
151+
parseInt(tweet.id) > this.client.lastCheckedTweetId;
152+
const isRecent = (Date.now() - (tweet.timestamp * 1000)) < 2 * 60 * 60 * 1000;
153+
154+
elizaLogger.log(`Tweet ${tweet.id} checks:`, {
155+
isUnprocessed,
156+
isRecent,
157+
isReply: tweet.isReply,
158+
isRetweet: tweet.isRetweet
159+
});
160+
161+
return isUnprocessed && !tweet.isReply && !tweet.isRetweet && isRecent;
162+
});
163+
164+
if (validTweets.length > 0) {
165+
tweetsByUser.set(username, validTweets);
166+
elizaLogger.log(`Found ${validTweets.length} valid tweets from ${username}`);
167+
}
168+
} catch (error) {
169+
elizaLogger.error(`Error fetching tweets for ${username}:`, error);
170+
continue;
171+
}
172+
}
173+
174+
// Select one tweet from each user that has tweets
175+
const selectedTweets: Tweet[] = [];
176+
for (const [username, tweets] of tweetsByUser) {
177+
if (tweets.length > 0) {
178+
// Randomly select one tweet from this user
179+
const randomTweet = tweets[Math.floor(Math.random() * tweets.length)];
180+
selectedTweets.push(randomTweet);
181+
elizaLogger.log(`Selected tweet from ${username}: ${randomTweet.text?.substring(0, 100)}`);
182+
}
183+
}
184+
185+
// Add selected tweets to candidates
186+
uniqueTweetCandidates = [...mentionCandidates, ...selectedTweets];
187+
}
188+
} else {
189+
elizaLogger.log("No target users configured, processing only mentions");
190+
}
191+
192+
109193

110-
const twitterUsername = this.client.profile.username;
111-
try {
112-
// Check for mentions
113-
const tweetCandidates = (
114-
await this.client.fetchSearchTweets(
115-
`@${twitterUsername}`,
116-
20,
117-
SearchMode.Latest
118-
)
119-
).tweets;
120-
121-
// de-duplicate tweetCandidates with a set
122-
const uniqueTweetCandidates = [...new Set(tweetCandidates)];
123194
// Sort tweet candidates by ID in ascending order
124195
uniqueTweetCandidates
125196
.sort((a, b) => a.id.localeCompare(b.id))
@@ -282,13 +353,22 @@ export class TwitterInteractionClient {
282353
this.client.saveRequestMessage(message, state);
283354
}
284355

356+
// 1. Get the raw target users string from settings
357+
const targetUsersStr = this.runtime.getSetting("TWITTER_TARGET_USERS");
358+
359+
// 2. Process the string to get valid usernames
360+
const validTargetUsersStr = targetUsersStr && targetUsersStr.trim()
361+
? targetUsersStr.split(',') // Split by commas: "user1,user2" -> ["user1", "user2"]
362+
.map(u => u.trim()) // Remove whitespace: [" user1 ", "user2 "] -> ["user1", "user2"]
363+
.filter(u => u.length > 0)
364+
.join(',')
365+
: '';
366+
285367
const shouldRespondContext = composeContext({
286368
state,
287-
template:
288-
this.runtime.character.templates
289-
?.twitterShouldRespondTemplate ||
290-
this.runtime.character?.templates?.shouldRespondTemplate ||
291-
twitterShouldRespondTemplate,
369+
template: this.runtime.character.templates?.twitterShouldRespondTemplate?.(validTargetUsersStr) ||
370+
this.runtime.character?.templates?.shouldRespondTemplate ||
371+
twitterShouldRespondTemplate(validTargetUsersStr),
292372
});
293373

294374
const shouldRespond = await generateShouldRespond({
@@ -362,7 +442,12 @@ export class TwitterInteractionClient {
362442
);
363443
}
364444

365-
await this.runtime.evaluate(message, state);
445+
// Ensure the message and state are properly stringified before evaluation
446+
const sanitizedMessage = JSON.parse(JSON.stringify(message));
447+
const sanitizedState = JSON.parse(JSON.stringify(state));
448+
449+
await this.runtime.evaluate(sanitizedMessage, sanitizedState);
450+
366451

367452
await this.runtime.processActions(
368453
message,

0 commit comments

Comments
 (0)