waku-org
/
js-waku-lab
mirror of https://github.com/waku-org/js-waku-lab.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

chore(buddybook): fix telemetry timestamp inconsistency

This commit is contained in:
Danish Arora 2024-11-14 20:55:07 +07:00
parent 7c5cfcdbf4
commit a65d7218ae
No known key found for this signature in database
GPG Key ID: 1C6EF37CDAE1426E
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
examples/buddybook/src/lib/waku.ts
View File

@ -71,7 +71,7 @@ export function createMessage({
} }
export async function* getMessagesFromStore(node: LightNode) { export async function* getMessagesFromStore(node: LightNode) {
const startTime = performance.now(); const startTime = Math.ceil(Date.now() / 1000);
try { try {
for await (const messagePromises of node.store.queryGenerator([decoder])) { for await (const messagePromises of node.store.queryGenerator([decoder])) {
const messages = await Promise.all(messagePromises); const messages = await Promise.all(messagePromises);
@ -83,7 +83,7 @@ export async function* getMessagesFromStore(node: LightNode) {
yield blockPayload; yield blockPayload;
} }
} }
const endTime = performance.now(); const endTime = Math.ceil(Date.now() / 1000);
const timeTaken = endTime - startTime; const timeTaken = endTime - startTime;
console.log("getMessagesFromStore", timeTaken) console.log("getMessagesFromStore", timeTaken)
@ -94,14 +94,14 @@ export async function* getMessagesFromStore(node: LightNode) {
timeTaken, timeTaken,
})); }));
} catch(e) { } catch(e) {
const endTime = performance.now(); const endTime = Math.ceil(Date.now() / 1000);
const timeTaken = endTime - startTime; const timeTaken = endTime - startTime;
Telemetry.push([{ Telemetry.push([{
type: TelemetryType.LIGHT_PUSH_FILTER, type: TelemetryType.LIGHT_PUSH_FILTER,
protocol: "lightPush", protocol: "lightPush",
timestamp: toInt(startTime), timestamp: startTime,
createdAt: toInt(startTime), createdAt: startTime,
seenTimestamp: toInt(startTime), seenTimestamp: startTime,
peerId: node.peerId.toString(), peerId: node.peerId.toString(),
contentTopic: encoder.contentTopic, contentTopic: encoder.contentTopic,
pubsubTopic: encoder.pubsubTopic, pubsubTopic: encoder.pubsubTopic,
@ -128,7 +128,7 @@ export async function subscribeToFilter(node: LightNode, callback: (message: Blo
result, result,
node, node,
decoder, decoder,
timestamp: Date.now(), timestamp: Math.ceil(Date.now() / 1000),
})); }));
const {error, subscription, results} = result; const {error, subscription, results} = result;