Merge pull request #2 from dayhaysoos/update-showcase

Update showcase

Author: dayhaysoos

example/convex/_generated/api.d.ts

@@ -10,6 +10,8 @@
 
 import type * as chat from "../chat.js";
 import type * as chatTools from "../chatTools.js";
+import type * as products from "../products.js";
+import type * as rateLimit from "../rateLimit.js";
 import type * as seed from "../seed.js";
 
 import type {
@@ -21,6 +23,8 @@ import type {
 declare const fullApi: ApiFromModules<{
   chat: typeof chat;
   chatTools: typeof chatTools;
+  products: typeof products;
+  rateLimit: typeof rateLimit;
   seed: typeof seed;
 }>;
 

example/convex/chat.ts

@@ -167,6 +167,7 @@ export const sendMessage = action({
   args: {
     conversationId: v.string(),
     message: v.string(),
+    fingerprint: v.optional(v.string()),
   },
   returns: v.object({
     success: v.boolean(),
@@ -179,6 +180,20 @@ export const sendMessage = action({
       return { success: false, error: "OPENROUTER_API_KEY not configured" };
     }
 
+    // Server-side rate limiting
+    if (args.fingerprint) {
+      const rateLimitResult = await ctx.runMutation(
+        api.rateLimit.incrementRateLimit,
+        { fingerprint: args.fingerprint },
+      );
+      if (!rateLimitResult.allowed) {
+        return {
+          success: false,
+          error: "Rate limit exceeded. Please try again later.",
+        };
+      }
+    }
+
     try {
       // 1. Save user message
       await ctx.runMutation(components.databaseChat.messages.add, {
@@ -382,7 +397,7 @@ async function callOpenRouter(
         "X-Title": "E-commerce Chat Demo",
       },
       body: JSON.stringify({
-        model: "anthropic/claude-3.5-sonnet",
+        model: "anthropic/claude-sonnet-4",
         messages,
         tools,
         stream: true,

example/convex/products.ts

@@ -0,0 +1,58 @@
+import { query } from "./_generated/server";
+import { v } from "convex/values";
+
+/**
+ * Get all products for display in the products grid.
+ */
+export const getAllProducts = query({
+  args: {},
+  returns: v.array(
+    v.object({
+      _id: v.id("products"),
+      _creationTime: v.number(),
+      name: v.string(),
+      description: v.string(),
+      category: v.string(),
+      price: v.number(),
+      stock: v.number(),
+    }),
+  ),
+  handler: async (ctx) => {
+    return await ctx.db.query("products").collect();
+  },
+});
+
+/**
+ * Get a single product by ID.
+ */
+export const getProduct = query({
+  args: { id: v.id("products") },
+  returns: v.union(
+    v.object({
+      _id: v.id("products"),
+      _creationTime: v.number(),
+      name: v.string(),
+      description: v.string(),
+      category: v.string(),
+      price: v.number(),
+      stock: v.number(),
+    }),
+    v.null(),
+  ),
+  handler: async (ctx, args) => {
+    return await ctx.db.get(args.id);
+  },
+});
+
+/**
+ * Get unique categories for filtering.
+ */
+export const getCategories = query({
+  args: {},
+  returns: v.array(v.string()),
+  handler: async (ctx) => {
+    const products = await ctx.db.query("products").collect();
+    const categories = [...new Set(products.map((p) => p.category))];
+    return categories.sort();
+  },
+});

example/convex/rateLimit.ts

@@ -0,0 +1,101 @@
+import { v } from "convex/values";
+import { query, mutation } from "./_generated/server";
+
+const MESSAGE_LIMIT = 3;
+const RESET_PERIOD_MS = 24 * 60 * 60 * 1000; // 24 hours
+
+export const checkRateLimit = query({
+  args: { fingerprint: v.string() },
+  handler: async (ctx, args) => {
+    const record = await ctx.db
+      .query("rateLimits")
+      .withIndex("by_fingerprint", (q) => q.eq("fingerprint", args.fingerprint))
+      .first();
+
+    const now = Date.now();
+
+    if (!record) {
+      return {
+        allowed: true,
+        remaining: MESSAGE_LIMIT,
+        resetTime: now + RESET_PERIOD_MS,
+      };
+    }
+
+    // Check if reset period has passed
+    if (now - record.lastResetTime >= RESET_PERIOD_MS) {
+      return {
+        allowed: true,
+        remaining: MESSAGE_LIMIT,
+        resetTime: now + RESET_PERIOD_MS,
+      };
+    }
+
+    const remaining = Math.max(0, MESSAGE_LIMIT - record.messageCount);
+    return {
+      allowed: remaining > 0,
+      remaining,
+      resetTime: record.lastResetTime + RESET_PERIOD_MS,
+    };
+  },
+});
+
+export const incrementRateLimit = mutation({
+  args: { fingerprint: v.string() },
+  handler: async (ctx, args) => {
+    const now = Date.now();
+    const record = await ctx.db
+      .query("rateLimits")
+      .withIndex("by_fingerprint", (q) => q.eq("fingerprint", args.fingerprint))
+      .first();
+
+    if (!record) {
+      // Create new record
+      await ctx.db.insert("rateLimits", {
+        fingerprint: args.fingerprint,
+        messageCount: 1,
+        lastResetTime: now,
+      });
+      return {
+        allowed: true,
+        remaining: MESSAGE_LIMIT - 1,
+        resetTime: now + RESET_PERIOD_MS,
+      };
+    }
+
+    // Check if reset period has passed
+    if (now - record.lastResetTime >= RESET_PERIOD_MS) {
+      // Reset the counter
+      await ctx.db.patch(record._id, {
+        messageCount: 1,
+        lastResetTime: now,
+      });
+      return {
+        allowed: true,
+        remaining: MESSAGE_LIMIT - 1,
+        resetTime: now + RESET_PERIOD_MS,
+      };
+    }
+
+    // Check if limit exceeded
+    if (record.messageCount >= MESSAGE_LIMIT) {
+      return {
+        allowed: false,
+        remaining: 0,
+        resetTime: record.lastResetTime + RESET_PERIOD_MS,
+      };
+    }
+
+    // Increment counter
+    const newCount = record.messageCount + 1;
+    await ctx.db.patch(record._id, {
+      messageCount: newCount,
+    });
+
+    return {
+      allowed: true,
+      remaining: MESSAGE_LIMIT - newCount,
+      resetTime: record.lastResetTime + RESET_PERIOD_MS,
+    };
+  },
+});

example/convex/schema.ts

@@ -12,4 +12,10 @@ export default defineSchema({
   })
     .index("by_category", ["category"])
     .index("by_price", ["price"]),
+
+  rateLimits: defineTable({
+    fingerprint: v.string(),
+    messageCount: v.number(),
+    lastResetTime: v.number(),
+  }).index("by_fingerprint", ["fingerprint"]),
 });

example/package-lock.json

@@ -13,6 +13,7 @@
   },
   "dependencies": {
     "@dayhaysoos/convex-database-chat": "0.1.0-alpha.0",
+    "@fingerprintjs/fingerprintjs": "^4.5.1",
     "convex": "^1.17.0",
     "react": "^18.3.1",
     "react-dom": "^18.3.1",