Add initial setup for Appwrite integration and state management

Author: Adityasinghvats

package-lock.json

@@ -9,19 +9,23 @@
     "lint": "next lint"
   },
   "dependencies": {
+    "appwrite": "^17.0.1",
+    "immer": "^10.1.1",
+    "next": "15.2.3",
+    "node-appwrite": "^15.0.1",
     "react": "^19.0.0",
     "react-dom": "^19.0.0",
-    "next": "15.2.3"
+    "zustand": "^5.0.3"
   },
   "devDependencies": {
-    "typescript": "^5",
+    "@eslint/eslintrc": "^3",
+    "@tailwindcss/postcss": "^4",
     "@types/node": "^20",
     "@types/react": "^19",
     "@types/react-dom": "^19",
-    "@tailwindcss/postcss": "^4",
-    "tailwindcss": "^4",
     "eslint": "^9",
     "eslint-config-next": "15.2.3",
-    "@eslint/eslintrc": "^3"
+    "tailwindcss": "^4",
+    "typescript": "^5"
   }
 }

package.json

@@ -0,0 +1,9 @@
+const env = {
+    appwrite: {
+        endpoint : String(process.env.NEXT_PUBLIC_APPWRITE_HOST_URL),
+        projectId : String(process.env.NEXT_PUBLIC_APPWRITE_PROJECT_ID),
+        apiKey: String(process.env.APPWRITE_API_KEY)
+    }
+}
+
+export default env;

src/app/env.ts

@@ -0,0 +1,29 @@
+import { NextResponse } from "next/server";
+import type { NextRequest } from "next/server";
+import getOrCreateDB from "./models/server/dbSetup";
+import getOrCreateStorage from "./models/server/storageSetup";
+
+//as this is my middleware this function can everywhere we want
+export async function middleware(request: NextRequest){
+
+    await Promise.all([
+        getOrCreateDB(),
+        getOrCreateStorage()
+    ])
+    
+    return NextResponse.next();
+}
+
+//wherever the matches matches the path our code will not run there
+export const config = {
+    /*
+    match all req path except for the ones start with
+    - api
+    - next/static
+    - next/image
+    - favicon
+    */
+    matcher: [
+        "/((?!api|_next/static|_next/image|favicon.ico).*)"
+    ]
+}

src/middleware.ts

@@ -0,0 +1,13 @@
+import { Client, Account , Avatars, Databases, Storage} from "appwrite";
+import env from "@/app/env";
+
+const client = new Client()
+    .setEndpoint(env.appwrite.endpoint) // Your API Endpoint
+    .setProject(env.appwrite.projectId); // Your project ID
+
+const account = new Account(client);
+const databases = new Databases(client);
+const avatars = new Avatars(client);
+const storage = new Storage(client);
+
+export {client, databases, account, avatars, storage};

src/models/client/config.ts

@@ -0,0 +1,6 @@
+export const db = "appwrite-overflow";
+export const questionCollection = "questions";
+export const answerCollection = "answers";
+export const commentCollection = "comments";
+export const voteCollection = "votes";
+export const questionAttachmentbucket = "question-attachments";;

src/models/index.ts

@@ -0,0 +1,26 @@
+import {db, answerCollection} from "../name";
+import { databases } from "./config";
+import { Permission } from "appwrite";
+
+export default async function createAnswerCollection(){
+    await databases.createCollection(
+        db,
+        answerCollection,
+        answerCollection,
+        [
+            Permission.read("any"),
+            Permission.read("users"),
+            Permission.write("users"),
+            Permission.create("users"),
+            Permission.delete("users")
+        ]
+    )
+    console.log("Answer collection is created")
+
+    await Promise.all([
+        databases.createStringAttribute(db, answerCollection, "content", 10000, true),
+        databases.createStringAttribute(db, answerCollection, "authorId", 100, true),
+        databases.createStringAttribute(db, answerCollection, "questionId", 100, true),
+    ])
+    console.log("Answer attributes are created")
+}

src/models/name.ts

@@ -0,0 +1,27 @@
+import {db, commentCollection} from "../name";
+import { databases } from "./config";
+import { Permission } from "appwrite";
+
+export default async function createCommentCollection(){
+    await databases.createCollection(
+        db,
+        commentCollection,
+        commentCollection,
+        [
+            Permission.read("any"),
+            Permission.read("users"),
+            Permission.write("users"),
+            Permission.create("users"),
+            Permission.delete("users")
+        ]
+    )
+    console.log("comment collection is created")
+
+    await Promise.all([
+        databases.createStringAttribute(db, commentCollection, "content", 10000, true),
+        databases.createStringAttribute(db, commentCollection, "authorId", 100, true),
+        databases.createStringAttribute(db, commentCollection, "typeId", 100, true),
+        databases.createEnumAttribute(db, commentCollection, "type", ["answer", "question"], true)
+    ])
+    console.log("comment attributes are created")
+}

src/models/server/answer.collection.ts

@@ -0,0 +1,16 @@
+import env from "@/app/env";
+import {Avatars, Client, Databases, Storage, Users} from "node-appwrite";
+
+const client = new Client();
+client
+    .setEndpoint(env.appwrite.endpoint) // Your API Endpoint
+    .setProject(env.appwrite.projectId) // Your project ID
+    .setKey(env.appwrite.apiKey) // Your secret API key
+;
+
+const databases = new Databases(client);
+const storage = new Storage(client);
+const users = new Users(client);
+const avatars = new Avatars(client);
+
+export { client, databases, storage, users, avatars };

src/models/server/comment.collection.ts

@@ -0,0 +1,29 @@
+import { db } from "../name";
+import createQuestionCollection from "./question.collection";
+import createAnswerCollection from "./answer.collection";
+import createCommentCollection from "./comment.collection";
+import createVoteCollection from "./vote.collection";
+import {databases} from "./config";
+//for sedding the databse with some intial data
+export default async function getOrCreateDB(){
+    try {
+        await databases.get(db);
+        console.log("Database is already created")
+    } catch (error) {
+        try {
+            await databases.create(db, db);
+            console.log("Database is created");
+            Promise.all([
+                createQuestionCollection(),
+                createAnswerCollection(),
+                createVoteCollection(),
+                createCommentCollection()
+            ])
+            console.log("Collections are created")
+        } catch (error) {
+            console.log("Error in creating collections", error)
+        }
+        console.log("Error in getting database", error)
+    }
+    return databases;
+}

src/models/server/config.ts

@@ -0,0 +1,39 @@
+import { IndexType } from "node-appwrite";
+
+import {db, questionCollection} from "../name";
+import { databases } from "./config";
+import { Permission } from "appwrite";
+
+export default async function createQuestionCollection() {
+    //create collection
+    await databases.createCollection(
+        db, 
+        questionCollection,
+        questionCollection,
+        [
+            Permission.read("any"),
+            Permission.read("users"),
+            Permission.write("users"),
+            Permission.create("users"),
+            Permission.delete("users")
+        ]
+    )
+    console.log("Question collection is created")
+
+    //creating attributes and indesxes
+    await Promise.all([
+        databases.createStringAttribute(db, questionCollection, "title", 100, true),
+        databases.createStringAttribute(db, questionCollection, "content", 10000, true),
+        databases.createStringAttribute(db, questionCollection, "authorId", 100, true),
+        databases.createStringAttribute(db, questionCollection, "tags", 100, true, undefined, true),
+        databases.createStringAttribute(db, questionCollection, "attachmentId", 100, false),
+    ])
+    console.log("Question attributes are created")
+
+    //create index
+    //as we are creating a lot of indexes, we are using a batch operation
+    await Promise.all([
+        databases.createIndex(db, questionCollection, "title", IndexType.Fulltext, ["title"],['asc']),
+        databases.createIndex(db, questionCollection, "content", IndexType.Fulltext, ["content"],['asc']),
+    ])
+}

src/models/server/dbSetup.ts

@@ -0,0 +1,33 @@
+import { questionAttachmentbucket} from "../name";
+import { storage } from "./config";
+import { Permission } from "appwrite";
+
+export default async function getOrCreateStorage(){
+    try {
+        await storage.getBucket(questionAttachmentbucket);
+        console.log("Bucket already exists")
+    } catch (error) {
+        try {
+            await storage.createBucket(
+                questionAttachmentbucket,
+                questionAttachmentbucket,
+                [
+                    Permission.read("any"),
+                    Permission.read("users"),
+                    Permission.write("users"),
+                    Permission.create("users"),
+                    Permission.delete("users")
+                ],
+                false,
+                undefined,
+                undefined,
+                ["jpeg", "png", "gif", "jpeg", "webp", "heic"]
+            )
+            console.log("Bucket is created")
+            console.log("Storage connected")
+        } catch (error) {
+            console.error("error creating storage: ", error)
+        }
+        console.error("error creating storage: ", error)
+    }
+}