From 31a7fb40cb65c0503f3abe06ffb462b3fcecd910 Mon Sep 17 00:00:00 2001
From: Benjamin Toby <devops@tben.me>
Date: Sat, 11 Apr 2026 08:58:38 +0100
Subject: [PATCH] Update conflict appenditures. Add updated_at field

---
 dist/lib/grab-duplicate-safe-insert-sql.js |  7 ++++---
 package.json                               |  2 +-
 src/lib/grab-duplicate-safe-insert-sql.ts  | 11 ++++++++---
 3 files changed, 13 insertions(+), 7 deletions(-)

diff --git a/dist/lib/grab-duplicate-safe-insert-sql.js b/dist/lib/grab-duplicate-safe-insert-sql.js
index 16b7f77..a867bfb 100644
--- a/dist/lib/grab-duplicate-safe-insert-sql.js
+++ b/dist/lib/grab-duplicate-safe-insert-sql.js
@@ -3,10 +3,11 @@ export default async function ({ sql: passed_sql, table, data }) {
     let sql = passed_sql;
     const { dbSchema } = await init();
     const table_schema = dbSchema.tables.find((t) => t.tableName == table);
+    const now = Date.now();
     if (table_schema?.tableName) {
-        const set_sql = Object.keys(data[0])
-            .map((field) => `${field} = excluded.${field}`)
-            .join(", ");
+        const set_sql_arr = Object.keys(data[0]).map((field) => `${field} = excluded.${field}`);
+        set_sql_arr.push(`updated_at = ${now}`);
+        const set_sql = set_sql_arr.join(", ");
         const unique_fields = table_schema.fields.filter((f) => f.unique);
         for (let i = 0; i < unique_fields.length; i++) {
             const field = unique_fields[i];
diff --git a/package.json b/package.json
index 287028f..7fe02b8 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
     "name": "@moduletrace/bun-sqlite",
-    "version": "1.0.28",
+    "version": "1.0.29",
     "description": "SQLite manager for Bun",
     "author": "Benjamin Toby",
     "main": "dist/index.js",
diff --git a/src/lib/grab-duplicate-safe-insert-sql.ts b/src/lib/grab-duplicate-safe-insert-sql.ts
index 2383485..02e5896 100644
--- a/src/lib/grab-duplicate-safe-insert-sql.ts
+++ b/src/lib/grab-duplicate-safe-insert-sql.ts
@@ -10,11 +10,16 @@ export default async function ({ sql: passed_sql, table, data }: Params) {
     let sql = passed_sql;
     const { dbSchema } = await init();
     const table_schema = dbSchema.tables.find((t) => t.tableName == table);
+    const now = Date.now();
 
     if (table_schema?.tableName) {
-        const set_sql = Object.keys(data[0])
-            .map((field) => `${field} = excluded.${field}`)
-            .join(", ");
+        const set_sql_arr = Object.keys(data[0]).map(
+            (field) => `${field} = excluded.${field}`,
+        );
+
+        set_sql_arr.push(`updated_at = ${now}`);
+
+        const set_sql = set_sql_arr.join(", ");
 
         const unique_fields = table_schema.fields.filter((f) => f.unique);