OpenStock：开源股票市场交易平台技术深度解析

// lib/better-auth/... 
// 认证配置示例（基于项目结构推断）
import { betterAuth } from "better-auth";
import { mongodbAdapter } from "better-auth/adapters/mongodb";
import mongoose from "mongoose";

export const auth = betterAuth({
  database: mongodbAdapter(mongoose.connection.db),
  emailAndPassword: {
    enabled: true,
  },
  session: {
    cookieCache: {
      enabled: true,
      maxAge: 5 * 60, // 5 minutes
    },
  },
});

// database/models/watchlist.model.ts
import mongoose, { Schema, Document } from "mongoose";

export interface IWatchlist extends Document {
  userId: string;
  symbol: string;
  addedAt: Date;
}

const WatchlistSchema = new Schema<IWatchlist>({
  userId: { type: String, required: true },
  symbol: { type: String, required: true },
  addedAt: { type: Date, default: Date.now },
});

// 复合唯一索引：防止同一用户重复添加相同股票
WatchlistSchema.index({ userId: 1, symbol: 1 }, { unique: true });

export default mongoose.models.Watchlist 
  || mongoose.model<IWatchlist>("Watchlist", WatchlistSchema);

// lib/actions/finnhub.ts (推断实现)
const FINNHUB_BASE_URL = process.env.FINNHUB_BASE_URL || "https://finnhub.io/api/v1";

export async function searchSymbols(query: string) {
  const res = await fetch(
    `${FINNHUB_BASE_URL}/search?q=${encodeURIComponent(query)}&token=${process.env.NEXT_PUBLIC_FINNHUB_API_KEY}`
  );
  return res.json();
}

export async function getCompanyProfile(symbol: string) {
  const res = await fetch(
    `${FINNHUB_BASE_URL}/stock/profile2?symbol=${symbol}&token=${process.env.NEXT_PUBLIC_FINNHUB_API_KEY}`
  );
  return res.json();
}

// lib/inngest/functions.ts (推断)
import { inngest } from "./client";

// 用户注册事件 → 触发 AI 个性化欢迎邮件
export const sendWelcomeEmail = inngest.createFunction(
  { id: "send-welcome-email" },
  { event: "app/user.created" },
  async ({ event, step }) => {
    const { userId, email, name, preferences } = event.data;
    
    // 调用 Gemini API 生成个性化介绍
    const personalizedIntro = await step.run("generate-ai-intro", async () => {
      // 基于用户偏好（国家、投资目标、风险承受能力）生成文案
      return await generateGeminiContent(preferences);
    });
    
    // 发送邮件
    await step.run("send-email", async () => {
      return await sendEmail({
        to: email,
        subject: `Welcome to OpenStock, ${name}!`,
        html: `<p>${personalizedIntro}</p>`,
      });
    });
  }
);

// 定时任务：每日财经摘要邮件（Cron 0 12 * * *）
export const dailyNewsSummary = inngest.createFunction(
  { id: "daily-news-summary" },
  { cron: "0 12 * * *" },
  async ({ step }) => {
    // 1. 获取所有用户
    // 2. 遍历用户观察列表
    // 3. 获取相关新闻
    // 4. 发送个性化摘要
  }
);

// components/SearchCommand.tsx (基于 cmdk 库)
import { Command } from "cmdk";
import { useDebounce } from "@/lib/utils";

export function SearchCommand() {
  const [query, setQuery] = useState("");
  const debouncedQuery = useDebounce(query, 300);
  const [results, setResults] = useState([]);
  
  useEffect(() => {
    if (debouncedQuery.length < 2) return;
    
    // 调用 Finnhub 搜索 API
    fetch(`/api/search?q=${debouncedQuery}`)
      .then(res => res.json())
      .then(data => setResults(data.result || []));
  }, [debouncedQuery]);
  
  return (
    <Command>
      <Command.Input 
        placeholder="搜索股票代码或公司名称..." 
        value={query}
        onValueChange={setQuery}
      />
      <Command.List>
        {results.map(stock => (
          <Command.Item
            key={stock.symbol}
            onSelect={() => router.push(`/stocks/${stock.symbol}`)}
          >
            {stock.description} ({stock.symbol})
          </Command.Item>
        ))}
      </Command.List>
    </Command>
  );
}

git clone https://github.com/Open-Dev-Society/OpenStock.git
cd OpenStock

# 使用 pnpm（推荐）
pnpm install

# 或使用 npm
npm install

# 基础配置
NODE_ENV=development

# 数据库（本地 Docker）
MONGODB_URI=mongodb://root:example@mongodb:27017/openstock?authSource=admin

# 或 MongoDB Atlas
# MONGODB_URI=mongodb+srv://<user>:<pass>@<cluster>/<db>?retryWrites=true&w=majority

# Better Auth
BETTER_AUTH_SECRET=your_random_secret_string
BETTER_AUTH_URL=http://localhost:3000

# Finnhub API
NEXT_PUBLIC_FINNHUB_API_KEY=your_finnhub_key
FINNHUB_BASE_URL=https://finnhub.io/api/v1

# Gemini AI（可选）
GEMINI_API_KEY=your_gemini_api_key

# Inngest（Vercel 部署必需）
INNGEST_SIGNING_KEY=your_inngest_signing_key

# 邮件服务（Gmail）
NODEMAILER_EMAIL=[email protected]
NODEMAILER_PASSWORD=your_gmail_app_password

pnpm test:db
# 或
npm run test:db

pnpm dev
# 访问 http://localhost:3000

npx inngest-cli@latest dev
# Inngest 开发服务器运行在 http://localhost:8288

pnpm build && pnpm start

docker compose up -d mongodb && docker compose up -d --build

// 自定义组件：用户观察列表实时监控
// components/WatchlistMonitor.tsx
import { useEffect, useState } from "react";
import { getWatchlist, getQuote } from "@/lib/actions";

export function WatchlistMonitor() {
  const [watchlist, setWatchlist] = useState([]);
  const [quotes, setQuotes] = useState({});
  
  useEffect(() => {
    async function fetchData() {
      // 1. 获取用户观察列表
      const symbols = await getWatchlist();
      setWatchlist(symbols);
      
      // 2. 批量获取实时报价
      const quotesData = {};
      for (const item of symbols) {
        const quote = await getQuote(item.symbol);
        quotesData[item.symbol] = quote;
      }
      setQuotes(quotesData);
    }
    
    fetchData();
    
    // 3. 定时刷新（每 60 秒）
    const interval = setInterval(fetchData, 60000);
    return () => clearInterval(interval);
  }, []);
  
  return (
    <div className="grid grid-cols-1 md:grid-cols-2 lg:grid-cols-3 gap-4">
      {watchlist.map(item => (
        <Card key={item.symbol}>
          <CardHeader>
            <CardTitle>{item.symbol}</CardTitle>
          </CardHeader>
          <CardContent>
            <p>当前价: ${quotes[item.symbol]?.c}</p>
            <p className={quotes[item.symbol]?.d > 0 ? "text-green-500" : "text-red-500"}>
              涨跌: {quotes[item.symbol]?.d} ({quotes[item.symbol]?.dp}%)
            </p>
          </CardContent>
        </Card>
      ))}
    </div>
  );
}

# 增加 Node.js 内存限制
export NODE_OPTIONS="--max-old-space-size=4096"
pnpm install