Remove outdated images

__tests__/env.test.ts

@@ -14,7 +14,7 @@ describe('Environment Setup', () => {
   it('should have project package.json with correct name', () => {
     const packageJsonPath = path.join(process.cwd(), 'package.json');
     const pkg = JSON.parse(fs.readFileSync(packageJsonPath, 'utf8'));
-    expect(pkg.name).toBe('twitter-rss-agent');
+    expect(pkg.name).toBe('@elizaos/plugin-twitter-rss');
     expect(pkg.license).toBe('MIT');
   });
 });

__tests__/error-handling.test.ts

@@ -1,5 +1,5 @@
 import { describe, it, expect } from 'vitest';
-import { RSSServerService } from '../src/plugin';
+import { RSSServerService } from '../src/services/rssServerService';
 
 describe('Service Stop Handling', () => {
   it('should handle missing service gracefully', async () => {

__tests__/service.test.ts

@@ -1,5 +1,5 @@
 import { describe, it, expect, vi } from 'vitest';
-import { TwitterRSSService } from '../src/plugin';
+import { TwitterRSSService } from '../src/services/twitterRSSService';
 import { createMockRuntime } from './test-utils';
 
 describe('TwitterRSSService failure cases', () => {

package.json

@@ -1,5 +1,5 @@
 {
-  "name": "twitter-rss-agent",
+  "name": "@elizaos/plugin-twitter-rss",
   "description": "ElizaOS Twitter List RSS Agent",
   "version": "0.1.0",
   "type": "module",

src/actions/getRSSStatus.ts

@@ -0,0 +1,75 @@
+import { Action, Content, HandlerCallback, IAgentRuntime, Memory, State } from '@elizaos/core';
+import fs from 'fs/promises';
+import path from 'path';
+import { logger } from '@elizaos/core';
+
+export const getRSSStatusAction: Action = {
+  name: 'GET_RSS_STATUS',
+  similes: ['RSS_STATUS', 'FEED_STATUS', 'CHECK_RSS'],
+  description: 'Get current status of RSS feed and monitoring lists',
+
+  validate: async (
+    _runtime: IAgentRuntime,
+    _message: Memory,
+    _state: State
+  ): Promise<boolean> => {
+    return true;
+  },
+
+  handler: async (
+    runtime: IAgentRuntime,
+    message: Memory,
+    _state: State,
+    _options: any,
+    callback: HandlerCallback
+  ) => {
+    try {
+      const outputDir =
+        runtime.getSetting?.('RSS_OUTPUT_DIR') || process.env.RSS_OUTPUT_DIR || './rss-feeds';
+      const rssFile = path.join(outputDir, 'twitter_lists.xml');
+
+      let status = 'RSS Feed Status:\n';
+
+      try {
+        const stats = await fs.stat(rssFile);
+        status += `📄 RSS file exists: ${rssFile}\n`;
+        status += `📅 Last modified: ${stats.mtime.toLocaleString()}\n`;
+        status += `📊 File size: ${(stats.size / 1024).toFixed(1)} KB\n`;
+      } catch {
+        status += `❌ RSS file not found\n`;
+      }
+
+      const lists = (
+        runtime.getSetting?.('TWITTER_LISTS') || process.env.TWITTER_LISTS || ''
+      )
+        .split(',')
+        .filter(Boolean);
+      status += `📋 Monitoring ${lists.length} lists: ${lists.join(', ')}\n`;
+      status += `⏱️ Update interval: ${
+        runtime.getSetting?.('RSS_UPDATE_INTERVAL') || process.env.RSS_UPDATE_INTERVAL || '30'
+      } minutes\n`;
+      status += `🎯 Max tweets per update: ${
+        runtime.getSetting?.('MAX_TWEETS_PER_LIST') || process.env.MAX_TWEETS_PER_LIST || '50'
+      }\n`;
+
+      const responseContent: Content = {
+        text: status,
+        source: message.content.source,
+        actions: ['GET_RSS_STATUS'],
+      };
+
+      await callback(responseContent);
+      return responseContent;
+    } catch (error: any) {
+      logger.error('Status check failed:', error);
+
+      const errorContent: Content = {
+        text: `❌ Status check failed: ${error.message}`,
+        source: message.content.source,
+      };
+
+      await callback(errorContent);
+      return errorContent;
+    }
+  },
+};

src/actions/updateRSS.ts

@@ -0,0 +1,57 @@
+import { Action, Content, HandlerCallback, IAgentRuntime, Memory, State } from '@elizaos/core';
+import { TwitterRSSService } from '../services/twitterRSSService';
+import { logger } from '@elizaos/core';
+
+export const updateRSSAction: Action = {
+  name: 'UPDATE_RSS_FEED',
+  similes: ['REFRESH_RSS', 'UPDATE_FEED', 'FETCH_LISTS'],
+  description: 'Update RSS feed with latest tweets from monitored Twitter lists',
+
+  validate: async (
+    runtime: IAgentRuntime,
+    _message: Memory,
+    _state: State
+  ): Promise<boolean> => {
+    const service = runtime.getService(TwitterRSSService.serviceType);
+    return service instanceof TwitterRSSService;
+  },
+
+  handler: async (
+    runtime: IAgentRuntime,
+    message: Memory,
+    _state: State,
+    _options: any,
+    callback: HandlerCallback
+  ) => {
+    try {
+      const service = runtime.getService(
+        TwitterRSSService.serviceType
+      ) as TwitterRSSService;
+
+      if (!service) {
+        throw new Error('Twitter RSS service not available');
+      }
+
+      const result = await service.processAllLists();
+
+      const responseContent: Content = {
+        text: `RSS feed updated successfully!\n📊 Processed ${result.totalTweets} new tweets\n📁 RSS file: ${result.rssPath}\n🕒 Last updated: ${new Date().toLocaleString()}`,
+        source: message.content.source,
+        actions: ['UPDATE_RSS_FEED'],
+      };
+
+      await callback(responseContent);
+      return responseContent;
+    } catch (error: any) {
+      logger.error('RSS update failed:', error);
+
+      const errorContent: Content = {
+        text: `❌ RSS update failed: ${error.message}`,
+        source: message.content.source,
+      };
+
+      await callback(errorContent);
+      return errorContent;
+    }
+  },
+};