collect channel and gateway data for traceroutes
This commit is contained in:
@ -0,0 +1,5 @@
|
|||||||
|
-- AlterTable
|
||||||
|
ALTER TABLE `traceroutes` ADD COLUMN `channel` INTEGER NULL,
|
||||||
|
ADD COLUMN `channel_id` VARCHAR(191) NULL,
|
||||||
|
ADD COLUMN `gateway_id` BIGINT NULL,
|
||||||
|
ADD COLUMN `packet_id` BIGINT NULL;
|
@ -151,6 +151,11 @@ model TraceRoute {
|
|||||||
node_id BigInt
|
node_id BigInt
|
||||||
route Json
|
route Json
|
||||||
|
|
||||||
|
channel Int?
|
||||||
|
packet_id BigInt?
|
||||||
|
channel_id String?
|
||||||
|
gateway_id BigInt?
|
||||||
|
|
||||||
created_at DateTime @default(now())
|
created_at DateTime @default(now())
|
||||||
updated_at DateTime @default(now()) @updatedAt
|
updated_at DateTime @default(now()) @updatedAt
|
||||||
|
|
||||||
|
@ -380,6 +380,10 @@ client.on("message", async (topic, message) => {
|
|||||||
data: {
|
data: {
|
||||||
node_id: envelope.packet.from,
|
node_id: envelope.packet.from,
|
||||||
route: routeDiscovery.route,
|
route: routeDiscovery.route,
|
||||||
|
channel: envelope.packet.channel,
|
||||||
|
packet_id: envelope.packet.id,
|
||||||
|
channel_id: envelope.channelId,
|
||||||
|
gateway_id: envelope.gatewayId ? BigInt('0x' + envelope.gatewayId.replaceAll("!", "")) : null, // convert hex id "!f96a92f0" to bigint
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
|
Reference in New Issue
Block a user