import { createSessionClient } from "@/config/appwrite";
import { cookies } from "next/headers";
import { redirect } from "next/navigation";
import { Query } from "node-appwrite";
async function getMyRooms() {
const cookieStore = await cookies();
const sessionCookie = cookieStore.get("appwrite-session");
if (!sessionCookie) {
redirect("/login");
}
try {
const { account, databases } = await createSessionClient(
sessionCookie.value
);
// Get user id
const user = await account.get();
const userId = user.$id;
// Fetch users rooms
const { documents: rooms } = await databases.listDocuments(
process.env.NEXT_PUBLIC_APPWRITE_DATABASE,
process.env.NEXT_PUBLIC_APPWRITE_COLLECTION_ROOMS,
[Query.equal("user_id", userId)]
);
return rooms;
} catch (error) {
console.log("Failed to get users rooms", error);
redirect("/error");
}
}
export default getMyRooms;```