diff --git a/checkAndPublish.mjs b/checkAndPublish.mjs index 8159361..ef39f4c 100644 --- a/checkAndPublish.mjs +++ b/checkAndPublish.mjs @@ -3,7 +3,7 @@ import createNote from "./firefish-calls/createNote.mjs" import makeText from "./makeText.mjs" import insertPublished from "./database-calls/insertPublished.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 () { @@ -19,7 +19,7 @@ export default async function checkAndPublish () { const note = await createNote(text) logger.trace("createNote successful!") try { - //DELETE FROM BUFFER + await deleteFromBuffer(prompt.word) await insertPublished(note, prompt.word) logger.trace("insertPublished successful!") } catch (error) { diff --git a/database-calls/db.mjs b/database-calls/db.mjs index 80713ef..a754cd8 100644 --- a/database-calls/db.mjs +++ b/database-calls/db.mjs @@ -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')) \ No newline at end of file