dmitry.galkin/chatbot-template
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix db query to restore previous doc version (#498)

Browse source
This commit is contained in:
Jeremy 2024-11-06 20:24:18 +03:00 • committed by GitHub
parent d948b99719
commit c5f6ac8deb
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 15 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

16
db/queries.ts
View file

@ -11,6 +11,7 @@ import {
User, User,
document, document,
Suggestion, Suggestion,
suggestion,
Message, Message,
message, message,
vote, vote,
@ -227,6 +228,15 @@ export async function deleteDocumentsByIdAfterTimestamp({
timestamp: Date; timestamp: Date;
}) { }) {
try { try {
await db
.delete(suggestion)
.where(
and(
eq(suggestion.documentId, id),
gt(suggestion.documentCreatedAt, timestamp)
)
);
return await db return await db
.delete(document) .delete(document)
.where(and(eq(document.id, id), gt(document.createdAt, timestamp))); .where(and(eq(document.id, id), gt(document.createdAt, timestamp)));
@ -244,7 +254,7 @@ export async function saveSuggestions({
suggestions: Array<Suggestion>; suggestions: Array<Suggestion>;
}) { }) {
try { try {
return await db.insert(Suggestion).values(suggestions); return await db.insert(suggestion).values(suggestions);
} catch (error) { } catch (error) {
console.error('Failed to save suggestions in database'); console.error('Failed to save suggestions in database');
throw error; throw error;
@ -259,8 +269,8 @@ export async function getSuggestionsByDocumentId({
try { try {
return await db return await db
.select() .select()
.from(Suggestion) .from(suggestion)
.where(and(eq(Suggestion.documentId, documentId))); .where(and(eq(suggestion.documentId, documentId)));
} catch (error) { } catch (error) {
console.error( console.error(
'Failed to get suggestions by document version from database' 'Failed to get suggestions by document version from database'

4
db/schema.ts
View file

@ -82,7 +82,7 @@ export const document = pgTable(
export type Document = InferSelectModel<typeof document>; export type Document = InferSelectModel<typeof document>;
export const Suggestion = pgTable( export const suggestion = pgTable(
'Suggestion', 'Suggestion',
{ {
id: uuid('id').notNull().defaultRandom(), id: uuid('id').notNull().defaultRandom(),
@ -106,4 +106,4 @@ export const Suggestion = pgTable(
}) })
); );
export type Suggestion = InferSelectModel<typeof Suggestion>; export type Suggestion = InferSelectModel<typeof suggestion>;