More examples: mutations, user check, cron job

src/server/example/cron.ts

@@ -0,0 +1,9 @@
+import { time } from 'modelence';
+
+export const dailyTestCron = {
+  description: 'Daily cron job example',
+  interval: time.days(1),
+  handler: async () => {
+    // This is just an example. Any code written here will run daily.
+  },
+};

src/server/example/db.ts

@@ -4,6 +4,7 @@ export const dbExampleItems = new Store('exampleItems', {
   schema: {
     title: schema.string(),
     createdAt: schema.date(),
+    userId: schema.userId(),
   },
   indexes: []
 });

src/server/example/index.ts

@@ -1,18 +1,86 @@
 import z from 'zod';
-import { Module, ObjectId } from 'modelence/server';
+import { AuthError } from 'modelence';
+import { Module, ObjectId, UserInfo, getConfig } from 'modelence/server';
 import { dbExampleItems } from './db';
+import { dailyTestCron } from './cron';
 
 export default new Module('example', {
+  configSchema: {
+    itemsPerPage: {
+      type: 'number',
+      default: 5,
+      isPublic: false,
+    },
+  },
+
   stores: [dbExampleItems],
 
   queries: {
-    getItem: async (args: unknown) => {
+    getItem: async (args: unknown, { user }: { user: UserInfo | null }) => {
+      if (!user) {
+        throw new AuthError('Not authenticated');
+      }
+
       const { itemId } = z.object({ itemId: z.string() }).parse(args);
       const exampleItem = await dbExampleItems.requireOne({ _id: new ObjectId(itemId) });
+
+      if (exampleItem.userId.toString() !== user.id) {
+        throw new AuthError('Not authorized');
+      }
+
       return {
         title: exampleItem.title,
         createdAt: exampleItem.createdAt,
       };
     },
+
+    getItems: async (_args: unknown, { user }: { user: UserInfo | null }) => {
+      if (!user) {
+        throw new AuthError('Not authenticated');
+      }
+
+      const itemsPerPage = getConfig('example.itemsPerPage') as number;
+      const exampleItems = await dbExampleItems.fetch({}, { limit: itemsPerPage })
+      return exampleItems.map((item) => ({
+        _id: item._id.toString(),
+        title: item.title,
+        createdAt: item.createdAt,
+      }));
+    }
   },
+
+  mutations: {
+    createItem: async (args: unknown, { user }: { user: UserInfo | null }) => {
+      if (!user) {
+        throw new AuthError('Not authenticated');
+      }
+
+      const { title } = z.object({ title: z.string() }).parse(args);
+
+      await dbExampleItems.insertOne({ title, createdAt: new Date(), userId: new ObjectId(user.id) });
+    },
+
+    updateItem: async (args: unknown, { user }: { user: UserInfo | null }) => {
+      if (!user) {
+        throw new AuthError('Not authenticated');
+      }
+
+      const { itemId, title } = z.object({ itemId: z.string(), title: z.string() }).parse(args);
+
+      const exampleItem = await dbExampleItems.requireOne({ _id: new ObjectId(itemId) });
+      if (exampleItem.userId.toString() !== user.id) {
+        throw new AuthError('Not authorized');
+      }
+
+      const { modifiedCount } = await dbExampleItems.updateOne({ _id: new ObjectId(itemId) }, { $set: { title } });
+
+      if (modifiedCount === 0) {
+        throw new Error('Item not found');
+      }
+    },
+  },
+
+  cronJobs: {
+    dailyTest: dailyTestCron
+  }
 });