deleteFromBuffer now works

This commit is contained in:
Andrzej Stepien 2023-08-12 19:16:13 +02:00
parent 4dcc369fbf
commit 4a5882fcc2
2 changed files with 14 additions and 2 deletions

View File

@ -3,7 +3,7 @@ import createNote from "./firefish-calls/createNote.mjs"
import makeText from "./makeText.mjs" import makeText from "./makeText.mjs"
import insertPublished from "./database-calls/insertPublished.mjs" import insertPublished from "./database-calls/insertPublished.mjs"
import logger from "./logger.mjs" import logger from "./logger.mjs"
import {todaysPromptAlreadyPublished, tableIsNotEmpty, getPromptFromBuffer} from "./database-calls/db.mjs" import {deleteFromBuffer, todaysPromptAlreadyPublished, tableIsNotEmpty, getPromptFromBuffer} from "./database-calls/db.mjs"
export default async function checkAndPublish () { export default async function checkAndPublish () {
@ -19,7 +19,7 @@ export default async function checkAndPublish () {
const note = await createNote(text) const note = await createNote(text)
logger.trace("createNote successful!") logger.trace("createNote successful!")
try { try {
//DELETE FROM BUFFER await deleteFromBuffer(prompt.word)
await insertPublished(note, prompt.word) await insertPublished(note, prompt.word)
logger.trace("insertPublished successful!") logger.trace("insertPublished successful!")
} catch (error) { } catch (error) {

View File

@ -98,3 +98,15 @@ export const getPromptFromBuffer = async () => {
} }
} }
export const deleteFromBuffer = async (word) => {
logger.trace(`deleteFromBuffer called for word ${word}!`)
try {
return db('buffer')
.where('word', word)
.del()
} catch (error) {
logger.error("deleteFromBuffer failed!")
}
}
console.dir(await deleteFromBuffer('incapacity'))