waku-org/waku-lab
1
0
Fork 0
mirror of https://github.com/waku-org/waku-lab.git synced 2025-02-03 03:23:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: printing of hashes and reporting (#92)

Browse Source
This commit is contained in:
Sasha 2024-09-26 21:36:15 +02:00 committed by GitHub
parent 8962b975ee
commit 31738ba842
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
examples/dogfooding/src/index.ts
View File

@ -52,7 +52,6 @@ export async function app(telemetryClient: TelemetryClient) {
}); });
node.libp2p.addEventListener("peer:discovery", async (event) => { node.libp2p.addEventListener("peer:discovery", async (event) => {
const peerId = node.libp2p.peerId.toString();
const discoveredPeerId = event.detail.id.toString(); const discoveredPeerId = event.detail.id.toString();
const timestamp = Math.floor(new Date().getTime() / 1000); const timestamp = Math.floor(new Date().getTime() / 1000);
@ -88,11 +87,11 @@ export async function app(telemetryClient: TelemetryClient) {
const sendMessage = async () => { const sendMessage = async () => {
try { try {
// TODO(weboko): replace with @waku/message-hash ideally // TODO(weboko): replace with @waku/message-hash ideally
const reportingHash = await sha256(`${sequenceHash}-${sequenceIndex}-${sequenceTotal}`); const messageHash = await sha256(`${sequenceHash}-${sequenceIndex}-${sequenceTotal}`);
const timestamp = Math.floor(new Date().getTime() / 1000); const timestamp = Math.floor(new Date().getTime() / 1000);
const message = ProtoSequencedMessage.create({ const message = ProtoSequencedMessage.create({
hash: reportingHash, hash: messageHash,
seqHash: sequenceHash, seqHash: sequenceHash,
total: sequenceTotal, total: sequenceTotal,
index: sequenceIndex, index: sequenceIndex,
@ -124,7 +123,7 @@ export async function app(telemetryClient: TelemetryClient) {
contentTopic: DEFAULT_CONTENT_TOPIC, contentTopic: DEFAULT_CONTENT_TOPIC,
pubsubTopic: DEFAULT_PUBSUB_TOPIC, pubsubTopic: DEFAULT_PUBSUB_TOPIC,
ephemeral: false, ephemeral: false,
messageHash: reportingHash, messageHash: messageHash,
errorMessage: "", errorMessage: "",
extraData, extraData,
}; };
@ -144,7 +143,7 @@ export async function app(telemetryClient: TelemetryClient) {
contentTopic: DEFAULT_CONTENT_TOPIC, contentTopic: DEFAULT_CONTENT_TOPIC,
pubsubTopic: DEFAULT_PUBSUB_TOPIC, pubsubTopic: DEFAULT_PUBSUB_TOPIC,
ephemeral: false, ephemeral: false,
messageHash: reportingHash, messageHash: messageHash,
errorMessage: fail.error.toString(), errorMessage: fail.error.toString(),
extraData, extraData,
}; };
@ -163,7 +162,7 @@ export async function app(telemetryClient: TelemetryClient) {
// Update ui // Update ui
const messageElement = document.createElement("div"); const messageElement = document.createElement("div");
const messagesSent = document.getElementById("messagesSent"); const messagesSent = document.getElementById("messagesSent");
messageElement.textContent = `Message: ${sequenceHash} ${sequenceIndex} of ${sequenceTotal}`; messageElement.textContent = `Message: ${messageHash} ${sequenceIndex} of ${sequenceTotal}`;
messagesSent.insertBefore(messageElement, messagesSent.firstChild); messagesSent.insertBefore(messageElement, messagesSent.firstChild);
messagesSent.insertBefore( messagesSent.insertBefore(
document.createElement("br"), document.createElement("br"),
@ -211,7 +210,7 @@ export async function app(telemetryClient: TelemetryClient) {
timestamp, timestamp,
createdAt: Math.floor(message.timestamp.getTime() / 1000), createdAt: Math.floor(message.timestamp.getTime() / 1000),
seenTimestamp: timestamp, seenTimestamp: timestamp,
peerId: decodedMessage.sender, peerId: peerId,
contentTopic: message.contentTopic, contentTopic: message.contentTopic,
pubsubTopic: message.pubsubTopic, pubsubTopic: message.pubsubTopic,
ephemeral: message.ephemeral, ephemeral: message.ephemeral,
@ -222,7 +221,7 @@ export async function app(telemetryClient: TelemetryClient) {
]); ]);
const messageElement = document.createElement("div"); const messageElement = document.createElement("div");
messageElement.textContent = `Message: ${decodedMessage.seqHash} ${decodedMessage.index} of ${decodedMessage.total}`; messageElement.textContent = `Message: ${decodedMessage.hash} ${decodedMessage.index} of ${decodedMessage.total}`;
messagesReceived.appendChild(messageElement); messagesReceived.appendChild(messageElement);
messagesReceived.appendChild(document.createElement("br")); messagesReceived.appendChild(document.createElement("br"));