Discord Agent Integration

const client = new Client({
  intents: [
    GatewayIntentBits.MessageContent,
    GatewayIntentBits.DirectMessages
  ],
  partials: [
    Partials.Message,
    Partials.Channel
  ]
});

async function initializeAgent() {
  // Initialize Language Model
  const llm = new ChatOpenAI({
    modelName: 'gpt-4-mini',
    temperature: 0.3
  });

  // Setup Solana Agent
  const solanaAgent = new SolanaAgentKit(
    process.env.SOLANA_PRIVATE_KEY!,
    process.env.SOLANA_RPC_URL!,
    {
      OPENAI_API_KEY: process.env.OPENAI_API_KEY!
    }
  );

  // Create Tools and Agent
  const tools = createSolanaTools(solanaAgent);
  const memory = new MemorySaver();
  
  return createReactAgent({
    llm,
    tools,
    checkpointSaver: memory,
    messageModifier: customPrompt
  });
}

client.on(Events.MessageCreate, async (message) => {
  // Check for DM
  if (message.channel.type !== ChannelType.DM) return;
  
  // Process Message
  const { agent, config } = await initializeAgent();
  
  // Handle Response Stream
  const stream = await agent.stream({
    messages: userChatHistory
  }, config);
  
  // Process Chunks
  for await (const chunk of stream) {
    if ('agent' in chunk) {
      await message.reply(chunk.agent.messages[0].content);
    }
  }
});

const chatHistory = new Map();

// Add message to history
const userChatHistory = chatHistory.get(userId) || [];
userChatHistory.push(new HumanMessage(message.content));

const replyIfNotEmpty = async (content: string) => {
  if (content.trim() !== '') {
    await message.reply(content);
  }
};

const messageModifier = `
  You are a helpful agent that can interact onchain using the Solana Agent Kit.
  You are empowered to interact onchain using your tools.
  If you ever need funds, you can request them from the faucet.
  Be concise and helpful with your responses.
`;

const tools = createSolanaTools(solanaAgent);
// Available tools:
// - Token operations
// - NFT management
// - DeFi integration
// - Blockchain queries

try {
  await processMessage(message);
} catch (error) {
  console.error('Error handling message:', error);
  await message.reply('An error occurred. Please try again later.');
}