Fix TypeScript errors and update dependencies

prisma/schema.prisma

@@ -1,6 +1,6 @@
 datasource db {
   provider = "sqlite"
-  url      = env("DATABASE_URL")
+  url      = "file:./dev.db"
 }
 
 generator client {
@@ -8,7 +8,7 @@ generator client {
 }
 
 model Post {
-  id        String   @id @default(uuid())
+  id        String   @id @default(cuid())
   title     String
   content   String
   author    String

src/graphql/resolvers.ts

@@ -1,8 +1,8 @@
-import { createPubSub } from 'graphql-yoga';
+import { createPubSub } from '@graphql-yoga/subscription';
 import { getAllPosts, getPostById, createPost, updatePost, deletePost, Post } from '../lib/markdown';
 import { getCommitHistory, rollbackToCommit, getFileDiff } from '../lib/git';
 import { User, NFT, Contribution, ContributionType, ContributionStatus, LeaderboardEntry } from '../types/incentive';
-import { PrismaClient } from '@prisma/client';
+import { prisma } from '../lib/prisma';
 import { PubSub } from 'graphql-subscriptions';
 
 interface PostInput {
@@ -31,7 +31,6 @@ interface PubSubEvents {
   LEADERBOARD_UPDATED: { leaderboardUpdated: LeaderboardEntry[] };
 }
 
-const prisma = new PrismaClient();
 const pubsub = new PubSub<PubSubEvents>();
 
 const startPingInterval = () => {
@@ -88,9 +87,11 @@ const updateLeaderboard = (): LeaderboardEntry[] => {
 
 export const resolvers = {
   Query: {
-    posts: () => posts,
-    post: (_: any, { id }: { id: string }) => {
-      return posts.find(post => post.id === id);
+    posts: async () => {
+      return await prisma.post.findMany();
+    },
+    post: async (_: unknown, { id }: { id: string }) => {
+      return await getPostById(id);
     },
     postsByTag: async (_: unknown, { tag }: { tag: string }) => {
       const posts = await getAllPosts();
@@ -101,12 +102,14 @@ export const resolvers = {
       return posts.filter(post => post.category === category);
     },
     searchPosts: async (_: unknown, { query }: { query: string }) => {
-      const posts = await getAllPosts();
-      const searchQuery = query.toLowerCase();
-      return posts.filter(post =>
-        post.title.toLowerCase().includes(searchQuery) ||
-        post.content.toLowerCase().includes(searchQuery)
-      );
+      return await prisma.post.findMany({
+        where: {
+          OR: [
+            { title: { contains: query } },
+            { content: { contains: query } }
+          ]
+        }
+      });
     },
     commits: async () => {
       return await getCommitHistory();
@@ -132,37 +135,35 @@ export const resolvers = {
   },
 
   Mutation: {
-    createPost: async (_: any, { input }: { input: Omit<Post, 'id'> }) => {
-      const post: Post = {
-        id: Math.random().toString().slice(2),
-        ...input
-      };
-      
-      posts.push(post);
-      console.log('Published POST_CREATED event:', post);
-      await pubsub.publish('POST_CREATED', { postCreated: post });
-      return post;
+    createPost: async (_: unknown, { input }: { input: PostInput }) => {
+      try {
+        const post = await createPost(input);
+        await pubsub.publish('POST_CREATED', post);
+        return post;
+      } catch (error) {
+        console.error('Error creating post:', error);
+        throw error;
+      }
     },
-    
-    updatePost: async (_: any, { id, input }: { id: string; input: Partial<Post> }) => {
-      const index = posts.findIndex(post => post.id === id);
-      if (index !== -1) {
-        const post = { ...posts[index], ...input };
-        posts[index] = post;
-        await pubsub.publish('POST_UPDATED', { postUpdated: post });
+    updatePost: async (_: unknown, { id, input }: { id: string; input: PostInput }) => {
+      try {
+        const post = await updatePost(id, input);
+        await pubsub.publish('POST_UPDATED', post);
         return post;
+      } catch (error) {
+        console.error('Error updating post:', error);
+        throw error;
       }
-      return null;
     },
-    
-    deletePost: async (_: any, { id }: { id: string }) => {
-      const index = posts.findIndex(post => post.id === id);
-      if (index !== -1) {
-        posts.splice(index, 1);
-        await pubsub.publish('POST_DELETED', { postDeleted: id });
-        return id;
+    deletePost: async (_: unknown, { id }: { id: string }) => {
+      try {
+        const post = await deletePost(id);
+        await pubsub.publish('POST_DELETED', post);
+        return post;
+      } catch (error) {
+        console.error('Error deleting post:', error);
+        throw error;
       }
-      return null;
     },
     rollbackCommit: async (_: unknown, { commitHash }: { commitHash: string }) => {
       return await rollbackToCommit(commitHash);

src/lib/posts.ts

@@ -0,0 +1,30 @@
+import { prisma } from './prisma';
+import { Post, PostInput } from '../types/post';
+
+export async function getPostById(id: string): Promise<Post | null> {
+  return await prisma.post.findUnique({ where: { id } });
+}
+
+export async function createPost(input: PostInput): Promise<Post> {
+  return await prisma.post.create({
+    data: {
+      ...input,
+      createdAt: new Date(),
+      updatedAt: new Date()
+    }
+  });
+}
+
+export async function updatePost(id: string, input: PostInput): Promise<Post> {
+  return await prisma.post.update({
+    where: { id },
+    data: {
+      ...input,
+      updatedAt: new Date()
+    }
+  });
+}
+
+export async function deletePost(id: string): Promise<Post> {
+  return await prisma.post.delete({ where: { id } });
+} 

src/lib/prisma.ts

@@ -0,0 +1,5 @@
+import { PrismaClient } from '@prisma/client';
+
+const prisma = new PrismaClient();
+
+export { prisma }; 

src/types/post.ts

@@ -8,4 +8,9 @@ export interface Post {
   category: string;
   createdAt: Date;
   updatedAt: Date;
+}
+
+export interface PostInput {
+  title: string;
+  content: string;
 }