使用Stream和OpenAI构建AI聊天助手

app.post('/start-ai-agent', async (req, res) => {
 const {
   channel_id,
   channel_type = 'messaging',
   platform = 'openai',
 } = req.body;

// Content of useWatchers.ts


import { useCallback, useEffect, useState } from "react";
import { Channel } from "stream-chat";

export const useWatchers = ({ channel }: { channel: Channel }) => {
  const [watchers, setWatchers] = useState<string[] | undefined>(undefined);
  const [loading, setLoading] = useState(false);
  const [error, setError] = useState<Error | null>(null);

  const queryWatchers = useCallback(async () => {
    setLoading(true);
    setError(null);
    try {
      const result = await channel.query({ watchers: { limit: 5, offset: 0 } });
      setWatchers(result?.watchers?.map((watcher) => watcher.id));
      setLoading(false);
      return;
    } catch (err) {
      console.error("An error has occurred while querying watchers: ", err);
      setError(err as Error);
    }
  }, [channel]);

  useEffect(() => {
    queryWatchers();
  }, [queryWatchers]);

  useEffect(() => {
    const watchingStartListener = channel.on("user.watching.start", (event) => {
      const userId = event?.user?.id;
      if (userId && userId.startsWith("ai-bot")) {
        setWatchers((prevWatchers) => [
          userId,
          ...(prevWatchers || []).filter((watcherId) => watcherId !== userId),
        ]);
      }
    });

    const watchingStopListener = channel.on("user.watching.stop", (event) => {
      const userId = event?.user?.id;
      if (userId && userId.startsWith("ai-bot")) {
        setWatchers((prevWatchers) => (prevWatchers || []).filter((watcherId) => watcherId !== userId));
      }
    });

    return () => {
      watchingStartListener.unsubscribe();
      watchingStopListener.unsubscribe();
    };
  }, [channel]);

  return { watchers, loading, error };
};

this.assistant = await this.openai.beta.assistants.create({
  name: 'Stream AI Assistant',
  instructions: `
    You are a helpful, professional AI assistant for Stream.io, a company providing scalable APIs and SDKs for building in-app chat, video, and activity feeds. 
    Assist users by answering their questions clearly and accurately. 
    If users ask about any of the following, respond with the corresponding information:

    Support or contacting a human: Direct them to https://getstream.io/contact/support/
    Help Center or documentation lookup: Point them to https://support.getstream.io/hc/en-us
    Pricing details: Guide them to https://getstream.io/chat/pricing/
    Company/team info: Refer them to https://getstream.io/team/

    Documentation-specific queries:
      Chat API/docs: https://getstream.io/chat/docs/
      Video & audio docs: https://getstream.io/video/docs
      Activity Feed docs: https://getstream.io/activity-feeds/docs
      Moderation docs: https://getstream.io/moderation/docs

    For anything related to configuring Stream, accessing API keys, managing users, teams, or billing, direct users to https://dashboard.getstream.io/

    If you're unsure or the topic is not covered, say: "I'm not certain about that, but I recommend reaching out to our support team."

    Keep your responses friendly, accurate, and focused on helping users efficiently navigate GetStream.io's tools and resources.
  `
});