{post.likes}
+
+ {voteCount.data ? (
+ voteCount.data.toString()
+ ) : (
+
- {latestImages.map((image) => (
-
+ {trendingPosts.map((post: Post) => (
+
- {image.title}
+ {post.title}
diff --git a/src/server/api/routers/auth.ts b/src/server/api/routers/auth.ts
index 0c4cdea..cdbffc8 100644
--- a/src/server/api/routers/auth.ts
+++ b/src/server/api/routers/auth.ts
@@ -8,7 +8,7 @@ export const authRouter = createTRPCRouter({
create: publicProcedure
.input(z.object({ email: z.string().email(), password: z.string().min(5) }))
.mutation(async ({ ctx, input }) => {
- const profileImage = faker.image.avatar();
+ const profileImage = faker.image.avatarGitHub();
const hashedPassword = await bcrypt.hash(input.password, 10);
const user = await ctx.db.insert(users).values({
email: input.email,
diff --git a/src/server/api/routers/post.ts b/src/server/api/routers/post.ts
index d2c4d24..533a26c 100644
--- a/src/server/api/routers/post.ts
+++ b/src/server/api/routers/post.ts
@@ -5,38 +5,47 @@ import {
} from "@/server/api/trpc";
import { slugifyWithCounter } from "@sindresorhus/slugify";
import { z } from "zod";
-import { images, users } from "@/server/db/schema";
+import { posts, users, votes } from "@/server/db/schema";
import { env } from "@/env";
-import { and, eq } from "drizzle-orm";
+import { and, eq, sql } from "drizzle-orm";
import { Post } from "@/lib/models/post";
export const postRouter = createTRPCRouter({
+ getVoteCount: publicProcedure
+ .input(z.object({ slug: z.string() }))
+ .query(async ({ ctx, input }) => {
+ const count = await ctx.db
+ .execute(sql`SELECT SUM(CASE WHEN up = TRUE THEN 1 ELSE -1 END)
+ FROM public.votes v
+ WHERE v.post_id = (SELECT id FROM posts WHERE slug = ${input.slug})`);
+ return count[0]?.sum ?? '0';
+ }),
getBySlug: publicProcedure
.input(z.object({ slug: z.string() }))
.query(async ({ ctx, input }) => {
- const image = (
+ const post = (
await ctx.db
.select()
- .from(images)
- .where(and(eq(images.slug, input.slug)))
+ .from(posts)
+ .where(and(eq(posts.slug, input.slug)))
.limit(1)
)[0];
- if (!image) {
+ if (!post) {
throw new Error("Image not found");
}
return {
- slug: image.id,
- title: image.title,
- description: image.description,
- tags: image.tags,
- imageUrl: `/i/${image.filePath}`,
+ slug: post.slug,
+ title: post.title,
+ description: post.description,
+ tags: post.tags,
+ imageUrl: `/i/${post.filePath}`,
likes: 0,
dislikes: 0,
} as Post;
}),
getTrending: publicProcedure.query(async ({ ctx }) => {
- const trending = await ctx.db.query.images.findMany({
- orderBy: (images, { desc }) => [desc(images.createdAt)],
+ const trending = await ctx.db.query.posts.findMany({
+ orderBy: (posts, { desc }) => [desc(posts.createdAt)],
});
return (
trending.map((t) => {
@@ -52,6 +61,38 @@ export const postRouter = createTRPCRouter({
}) ?? null
);
}),
+ vote: protectedProcedure
+ .input(z.object({ slug: z.string(), up: z.boolean() }))
+ .mutation(async ({ ctx, input }) => {
+ const post = await ctx.db
+ .select()
+ .from(posts)
+ .where(eq(posts.slug, input.slug))
+ .limit(1)
+ .then((results) => results[0]);
+
+ if (!post) {
+ throw new Error("Post not found");
+ }
+
+ const vote = await ctx.db
+ .insert(votes)
+ .values({
+ postId: post.id,
+ createdById: ctx.session.user.id,
+ up: input.up,
+ })
+ .returning()
+ .then((results) => results[0]);
+
+ if (!vote) {
+ throw new Error("Failed to register vote");
+ }
+
+ return {
+ success: true,
+ };
+ }),
create: protectedProcedure
.input(
z.object({
@@ -68,8 +109,8 @@ export const postRouter = createTRPCRouter({
slug = slugify(input.title);
const existing = await ctx.db
.select()
- .from(images)
- .where(and(eq(images.slug, slug)))
+ .from(posts)
+ .where(and(eq(posts.slug, slug)))
.limit(1);
if (!existing[0]) {
found = true;
@@ -77,7 +118,7 @@ export const postRouter = createTRPCRouter({
} while (!found);
const post = await ctx.db
- .insert(images)
+ .insert(posts)
.values({
title: input.title,
slug: slug,
diff --git a/src/server/db/schema.ts b/src/server/db/schema.ts
index 946eada..a579924 100644
--- a/src/server/db/schema.ts
+++ b/src/server/db/schema.ts
@@ -1,5 +1,6 @@
import { relations, sql } from "drizzle-orm";
import {
+ boolean,
index,
integer,
pgTableCreator,
@@ -13,8 +14,8 @@ import { type AdapterAccount } from "next-auth/adapters";
export const createTable = pgTableCreator((name) => `${name}`);
-export const images = createTable(
- "images",
+export const posts = createTable(
+ "posts",
{
id: varchar("id", { length: 255 })
.notNull()
@@ -43,6 +44,26 @@ export const images = createTable(
},
);
+export const votes = createTable("votes", {
+ id: varchar("id", { length: 255 })
+ .notNull()
+ .primaryKey()
+ .$defaultFn(() => crypto.randomUUID()),
+ postId: varchar("post_id", { length: 255 })
+ .notNull()
+ .references(() => posts.id),
+ up: boolean("up").notNull().default(true),
+ createdById: varchar("created_by", { length: 255 })
+ .notNull()
+ .references(() => users.id),
+ createdAt: timestamp("created_at", { withTimezone: true })
+ .default(sql`CURRENT_TIMESTAMP`)
+ .notNull(),
+ updatedAt: timestamp("updated_at", { withTimezone: true }).$onUpdate(
+ () => new Date(),
+ ),
+});
+
export const users = createTable("users", {
id: varchar("id", { length: 255 })
.notNull()
@@ -60,6 +81,8 @@ export const users = createTable("users", {
export const usersRelations = relations(users, ({ many }) => ({
accounts: many(accounts),
+ posts: many(posts),
+ votes: many(votes),
}));
export const accounts = createTable(
- {image.description}
+ {post.description}