From b9082ebedb1caa6de9dd65fde7ec790d70447a67 Mon Sep 17 00:00:00 2001
From: liamcottle <liam@liamcottle.com>
Date: Sat, 23 Mar 2024 23:34:02 +1300
Subject: [PATCH] track when neighbours were last updated

---
 .../migration.sql                                               | 2 ++
 prisma/schema.prisma                                            | 1 +
 src/mqtt.js                                                     | 1 +
 3 files changed, 4 insertions(+)
 create mode 100644 prisma/migrations/20240323103128_add_neighbours_updated_at_column_to_nodes_table/migration.sql

diff --git a/prisma/migrations/20240323103128_add_neighbours_updated_at_column_to_nodes_table/migration.sql b/prisma/migrations/20240323103128_add_neighbours_updated_at_column_to_nodes_table/migration.sql
new file mode 100644
index 0000000..0ad52ab
--- /dev/null
+++ b/prisma/migrations/20240323103128_add_neighbours_updated_at_column_to_nodes_table/migration.sql
@@ -0,0 +1,2 @@
+-- AlterTable
+ALTER TABLE `nodes` ADD COLUMN `neighbours_updated_at` DATETIME(3) NULL;
diff --git a/prisma/schema.prisma b/prisma/schema.prisma
index 1e46a53..4047212 100644
--- a/prisma/schema.prisma
+++ b/prisma/schema.prisma
@@ -33,6 +33,7 @@ model Node {
 
   neighbour_broadcast_interval_secs Int?
   neighbours                        Json?
+  neighbours_updated_at             DateTime?
 
   created_at DateTime @default(now())
   updated_at DateTime @default(now()) @updatedAt
diff --git a/src/mqtt.js b/src/mqtt.js
index 53a914f..05a8eb0 100644
--- a/src/mqtt.js
+++ b/src/mqtt.js
@@ -298,6 +298,7 @@ client.on("message", async (topic, message) => {
                         node_id: envelope.packet.from,
                     },
                     data: {
+                        neighbours_updated_at: new Date(),
                         neighbour_broadcast_interval_secs: neighbourInfo.nodeBroadcastIntervalSecs,
                         neighbours: neighbourInfo.neighbors.map((neighbour) => {
                             return {