All files / dal blog-revisions.dal.ts

100% Statements 8/8
100% Branches 2/2
100% Functions 5/5
100% Lines 8/8

Press n or j to go to the next uncovered block, b, p or k for the previous block.

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41              17x     2x               5x           5x       1x       1x       3x 3x      
// Data Access Layer for Blog Revisions
import { eq, desc } from "drizzle-orm";
import type { DrizzleD1Database } from "drizzle-orm/d1";
import * as schema from "../db/schema";
import type { BlogRevision, NewBlogRevision } from "../db/schema";
 
export class BlogRevisionsDal {
	constructor(private db: DrizzleD1Database<typeof schema>) {}
 
	async findByBlogId(blogId: string): Promise<BlogRevision[]> {
		return this.db
			.select()
			.from(schema.blogRevisions)
			.where(eq(schema.blogRevisions.blogId, blogId))
			.orderBy(desc(schema.blogRevisions.versionNumber));
	}
 
	async findLatest(blogId: string): Promise<BlogRevision | undefined> {
		const result = await this.db
			.select()
			.from(schema.blogRevisions)
			.where(eq(schema.blogRevisions.blogId, blogId))
			.orderBy(desc(schema.blogRevisions.versionNumber))
			.limit(1);
		return result[0];
	}
 
	async create(data: NewBlogRevision): Promise<BlogRevision> {
		const result = await this.db
			.insert(schema.blogRevisions)
			.values(data)
			.returning();
		return result[0];
	}
 
	async getNextVersionNumber(blogId: string): Promise<number> {
		const latest = await this.findLatest(blogId);
		return latest ? latest.versionNumber + 1 : 1;
	}
}