From e8a37207f0b8fa6775bc33c30e69736ecfeb4e95 Mon Sep 17 00:00:00 2001 From: a Date: Sun, 2 Mar 2025 22:47:56 -0600 Subject: [PATCH] noot --- ts/src/activities/database.ts | 8 ++++---- ts/src/workflows/items.ts | 3 ++- 2 files changed, 6 insertions(+), 5 deletions(-) diff --git a/ts/src/activities/database.ts b/ts/src/activities/database.ts index c03a4c3..d2e4b87 100644 --- a/ts/src/activities/database.ts +++ b/ts/src/activities/database.ts @@ -26,12 +26,12 @@ export async function update_wynn_items() { const dataHash = sha1Hash(serializedData) let found_new = false await sql.begin(async (sql) => { - const [{currentHash} = {}] = await sql`select value as currentHash from meta.hashes where key = 'wynn.items' limit 1` - if(currentHash === dataHash) { + const [{currenthash} = {}] = await sql`select value as currenthash from meta.hashes where key = 'wynn.items' limit 1` + if(currenthash === dataHash) { return } found_new = true - log.info("updating wynn with new hash") + log.info(`updating wynn with new hash`, {old: currenthash, new: dataHash}) for(const [displayName, item] of Object.entries(parsed)){ const json = stringify(item) if(!json){ @@ -45,7 +45,7 @@ export async function update_wynn_items() { display_name = EXCLUDED.display_name, type = EXCLUDED.type, data = EXCLUDED.data, - itemHash = EXCLUDED.itemHash` + hash = EXCLUDED.hash` // update the hash await sql`insert into meta.hashes(key, value) values ('wynn.items', ${dataHash}) diff --git a/ts/src/workflows/items.ts b/ts/src/workflows/items.ts index f5862c1..e3fa312 100644 --- a/ts/src/workflows/items.ts +++ b/ts/src/workflows/items.ts @@ -10,5 +10,6 @@ const { update_wynn_items } = proxyActivities({ }); export const workflowSyncItemDatabase = async() => { - await update_wynn_items(); + const {found_new} = await update_wynn_items(); + }