track when neighbours were last updated
This commit is contained in:
@ -0,0 +1,2 @@
|
|||||||
|
-- AlterTable
|
||||||
|
ALTER TABLE `nodes` ADD COLUMN `neighbours_updated_at` DATETIME(3) NULL;
|
@ -33,6 +33,7 @@ model Node {
|
|||||||
|
|
||||||
neighbour_broadcast_interval_secs Int?
|
neighbour_broadcast_interval_secs Int?
|
||||||
neighbours Json?
|
neighbours Json?
|
||||||
|
neighbours_updated_at DateTime?
|
||||||
|
|
||||||
created_at DateTime @default(now())
|
created_at DateTime @default(now())
|
||||||
updated_at DateTime @default(now()) @updatedAt
|
updated_at DateTime @default(now()) @updatedAt
|
||||||
|
@ -298,6 +298,7 @@ client.on("message", async (topic, message) => {
|
|||||||
node_id: envelope.packet.from,
|
node_id: envelope.packet.from,
|
||||||
},
|
},
|
||||||
data: {
|
data: {
|
||||||
|
neighbours_updated_at: new Date(),
|
||||||
neighbour_broadcast_interval_secs: neighbourInfo.nodeBroadcastIntervalSecs,
|
neighbour_broadcast_interval_secs: neighbourInfo.nodeBroadcastIntervalSecs,
|
||||||
neighbours: neighbourInfo.neighbors.map((neighbour) => {
|
neighbours: neighbourInfo.neighbors.map((neighbour) => {
|
||||||
return {
|
return {
|
||||||
|
Reference in New Issue
Block a user