feat: client github loads github info via messages

.env.example

@@ -430,11 +430,11 @@ APTOS_PRIVATE_KEY= # Aptos private key
 APTOS_NETWORK=     # Must be one of mainnet, testnet
 
 # Github
+GITHUB_PLUGIN_ENABLED= # Enable this to run the GitHub plugin independently of the GitHub client
 GITHUB_API_TOKEN= # from github developer portal
-GITHUB_OWNER= # the owner of the repository
-GITHUB_BRANCH= # the branch to pull from
-GITHUB_REPO= # the name of the repository
-GITHUB_OODA_INTERVAL_MS= # interval in milliseconds between OODA cycles (default: 300000)
+
+GITHUB_INFO_DISCOVERY_INTERVAL_MS= # interval in milliseconds between github info discovery cycles (default: 1000)
+GITHUB_OODA_INTERVAL_MS= # interval in milliseconds between OODA cycles (default: 60000)
 
 # MultiversX
 MVX_PRIVATE_KEY= # Multiversx private key

agent/package.json

@@ -94,6 +94,11 @@
         "@elizaos/plugin-arthera": "workspace:*",
         "@elizaos/plugin-allora": "workspace:*",
         "@elizaos/plugin-opacity": "workspace:*",
+        "@elizaos/plugin-hyperliquid": "workspace:*",
+        "@elizaos/plugin-akash": "workspace:*",
+        "@elizaos/plugin-quai": "workspace:*",
+        "@elizaos/plugin-b2": "workspace:*",
+        "@elizaos/plugin-nft-collections": "workspace:*",
         "@elizaos/client-github": "workspace:*",
         "@elizaos/plugin-github": "workspace:*",
         "readline": "1.3.0",

agent/src/index.ts

@@ -865,7 +865,8 @@ export async function createAgent(
             getSecret(character, "COINBASE_NOTIFICATION_URI")
                 ? webhookPlugin
                 : null,
-            ...(getSecret(character, "GITHUB_API_TOKEN")
+            ...(getSecret(character, "GITHUB_PLUGIN_ENABLED") &&
+            getSecret(character, "GITHUB_API_TOKEN")
                 ? [
                       githubInitializePlugin,
                       githubCreateCommitPlugin,

client/src/components/chat.tsx

@@ -10,7 +10,7 @@ import { useTransition, animated } from "@react-spring/web";
 import { Paperclip, Send, X } from "lucide-react";
 import { useEffect, useRef, useState } from "react";
 import { Content, UUID } from "@elizaos/core";
-import { useMutation, useQueryClient } from "@tanstack/react-query";
+import { useMutation, useQueryClient, useQuery } from "@tanstack/react-query";
 import { apiClient } from "@/lib/api";
 import { cn, moment } from "@/lib/utils";
 import { Avatar, AvatarImage } from "./ui/avatar";
@@ -24,6 +24,7 @@ import { AudioRecorder } from "./audio-recorder";
 import { Badge } from "./ui/badge";
 
 interface ExtraContentFields {
+    id?: string;
     user: string;
     createdAt: number;
     isLoading?: boolean;
@@ -155,9 +156,48 @@ export default function Page({ agentId }: { agentId: UUID }) {
         }
     };
 
-    const messages =
-        queryClient.getQueryData<ContentWithUser[]>(["messages", agentId]) ||
-        [];
+    const { data: latestMessage } = useQuery({
+        queryKey: ["lastMessage", agentId],
+        queryFn: () => apiClient.getMemories(agentId),
+        refetchInterval: 5000,
+        select: (data) => {
+            const existingMessages =
+                queryClient.getQueryData<ContentWithUser[]>([
+                    "messages",
+                    agentId,
+                ]) || [];
+
+            // Filter out messages that already exist in our cache
+            const newMessages = data.memories.filter(
+                (newMsg: any) =>
+                    !existingMessages.some(
+                        (existingMsg: any) => existingMsg.id === newMsg.id
+                    )
+            );
+
+            // If we have new messages, add them to our messages
+            if (newMessages.length > 0) {
+                const updatedMessages = [
+                    ...existingMessages,
+                    ...newMessages.map((msg: any) => ({
+                        ...msg,
+                        text: msg.content.text,
+                        user: msg.userId === "user" ? "user" : msg.agentId,
+                        attachments: msg.content.attachments || [],
+                    })),
+                ];
+                queryClient.setQueryData(
+                    ["messages", agentId],
+                    updatedMessages
+                );
+                return updatedMessages;
+            }
+
+            return existingMessages;
+        },
+    });
+
+    const messages = latestMessage || [];
 
     const transitions = useTransition(messages, {
         keys: (message) =>
@@ -202,7 +242,10 @@ export default function Page({ agentId }: { agentId: UUID }) {
                                             {/* Attachments */}
                                             <div>
                                                 {message?.attachments?.map(
-                                                    (attachment, idx) => (
+                                                    (
+                                                        attachment: any,
+                                                        idx: any
+                                                    ) => (
                                                         <div
                                                             className="flex flex-col gap-1 mt-2"
                                                             key={idx}

client/src/lib/api.ts

@@ -102,4 +102,10 @@ export const apiClient = {
             body: formData,
         });
     },
+    getMemories: (agentId: string) =>
+        fetcher({
+            url: `/agents/${agentId}/memories`,
+            method: "GET",
+        }),
 };
+

packages/client-direct/src/api.ts

@@ -9,6 +9,7 @@ import {
     UUID,
     validateCharacterConfig,
     ServiceType,
+    stringToUuid,
 } from "@elizaos/core";
 
 import { TeeLogQuery, TeeLogService } from "@elizaos/plugin-tee-log";
@@ -198,13 +199,7 @@ export function createApiRouter(
         }
     });
 
-    router.get("/agents/:agentId/:roomId/memories", async (req, res) => {
-        const { agentId, roomId } = validateUUIDParams(req.params, res) ?? {
-            agentId: null,
-            roomId: null,
-        };
-        if (!agentId || !roomId) return;
-
+    const getMemories = async (agentId: UUID, roomId: UUID, req, res) => {
         let runtime = agents.get(agentId);
 
         // if runtime is null, look for runtime with the same name
@@ -223,10 +218,15 @@ export function createApiRouter(
             const memories = await runtime.messageManager.getMemories({
                 roomId,
             });
+
+            const filteredMemories = memories.filter(
+                (memory) => (memory.content.metadata as any)?.type !== "file"
+            );
+
             const response = {
                 agentId,
                 roomId,
-                memories: memories.map((memory) => ({
+                memories: filteredMemories.map((memory) => ({
                     id: memory.id,
                     userId: memory.userId,
                     agentId: memory.agentId,
@@ -261,6 +261,29 @@ export function createApiRouter(
             console.error("Error fetching memories:", error);
             res.status(500).json({ error: "Failed to fetch memories" });
         }
+    };
+
+    router.get("/agents/:agentId/:roomId/memories", async (req, res) => {
+        const { agentId, roomId } = validateUUIDParams(req.params, res) ?? {
+            agentId: null,
+            roomId: null,
+        };
+        if (!agentId || !roomId) return;
+
+        await getMemories(agentId, roomId, req, res);
+    });
+
+    router.get("/agents/:agentId/memories", async (req, res) => {
+        const { agentId } = validateUUIDParams(req.params, res) ?? {
+            agentId: null,
+        };
+        if (!agentId) return;
+
+        const roomId = stringToUuid(
+            req.body.roomId ?? "default-room-" + agentId
+        );
+
+        await getMemories(agentId, roomId, req, res);
     });
 
     router.get("/tee/agents", async (req, res) => {
@@ -269,18 +292,20 @@ export function createApiRouter(
 
             for (const agentRuntime of agents.values()) {
                 const teeLogService = agentRuntime
-                    .getService<TeeLogService>(
-                    ServiceType.TEE_LOG
-                )
-                .getInstance();
+                    .getService<TeeLogService>(ServiceType.TEE_LOG)
+                    .getInstance();
 
                 const agents = await teeLogService.getAllAgents();
-                allAgents.push(...agents)
+                allAgents.push(...agents);
             }
 
             const runtime: AgentRuntime = agents.values().next().value;
-            const teeLogService = runtime.getService<TeeLogService>(ServiceType.TEE_LOG).getInstance();
-            const attestation = await teeLogService.generateAttestation(JSON.stringify(allAgents));
+            const teeLogService = runtime
+                .getService<TeeLogService>(ServiceType.TEE_LOG)
+                .getInstance();
+            const attestation = await teeLogService.generateAttestation(
+                JSON.stringify(allAgents)
+            );
             res.json({ agents: allAgents, attestation: attestation });
         } catch (error) {
             elizaLogger.error("Failed to get TEE agents:", error);
@@ -300,13 +325,13 @@ export function createApiRouter(
             }
 
             const teeLogService = agentRuntime
-                .getService<TeeLogService>(
-                ServiceType.TEE_LOG
-            )
-            .getInstance();
+                .getService<TeeLogService>(ServiceType.TEE_LOG)
+                .getInstance();
 
             const teeAgent = await teeLogService.getAgent(agentId);
-            const attestation = await teeLogService.generateAttestation(JSON.stringify(teeAgent));
+            const attestation = await teeLogService.generateAttestation(
+                JSON.stringify(teeAgent)
+            );
             res.json({ agent: teeAgent, attestation: attestation });
         } catch (error) {
             elizaLogger.error("Failed to get TEE agent:", error);
@@ -335,12 +360,16 @@ export function createApiRouter(
                 };
                 const agentRuntime: AgentRuntime = agents.values().next().value;
                 const teeLogService = agentRuntime
-                    .getService<TeeLogService>(
-                        ServiceType.TEE_LOG
-                    )
+                    .getService<TeeLogService>(ServiceType.TEE_LOG)
                     .getInstance();
-                const pageQuery = await teeLogService.getLogs(teeLogQuery, page, pageSize);
-                const attestation = await teeLogService.generateAttestation(JSON.stringify(pageQuery));
+                const pageQuery = await teeLogService.getLogs(
+                    teeLogQuery,
+                    page,
+                    pageSize
+                );
+                const attestation = await teeLogService.generateAttestation(
+                    JSON.stringify(pageQuery)
+                );
                 res.json({
                     logs: pageQuery,
                     attestation: attestation,