Updates
This commit is contained in:
status-im-auto
Jenkins
parent
97950c727b
commit
7a7ffa151a
|
|
@ -129,428 +129,9 @@
|
|||
<span id="sending-status"></span>
|
||||
|
||||
<h4 class="mu1">Messages</h4>
|
||||
<div id="messages"></div>
|
||||
<div id="messages"><ul id="messagesList"></ul></div>
|
||||
|
||||
<script type="module">
|
||||
import { utils } from "https://unpkg.com/js-waku@0.30.0/bundle/index.js";
|
||||
import { createLightNode } from "https://unpkg.com/js-waku@0.30.0/bundle/lib/create_waku.js";
|
||||
import { waitForRemotePeer } from "https://unpkg.com/js-waku@0.30.0/bundle/lib/wait_for_remote_peer.js";
|
||||
import {
|
||||
EncoderV0,
|
||||
DecoderV0,
|
||||
} from "https://unpkg.com/js-waku@0.30.0/bundle/lib/waku_message/version_0.js";
|
||||
|
||||
import { protobuf } from "https://taisukef.github.io/protobuf-es.js/dist/protobuf-es.js";
|
||||
|
||||
import {
|
||||
create,
|
||||
MembershipKey,
|
||||
RLNDecoder,
|
||||
RLNEncoder,
|
||||
} from "https://unpkg.com/@waku/rln@0.0.13/bundle/index.js";
|
||||
|
||||
import { ethers } from "https://unpkg.com/ethers@5.7.2/dist/ethers.esm.min.js";
|
||||
|
||||
const statusSpan = document.getElementById("status");
|
||||
|
||||
// Blockchain Elements
|
||||
const addressDiv = document.getElementById("address");
|
||||
const connectWalletButton = document.getElementById("connect-wallet");
|
||||
|
||||
const latestMembershipSpan = document.getElementById(
|
||||
"latest-membership-id"
|
||||
);
|
||||
const retrieveRLNDetailsButton = document.getElementById(
|
||||
"retrieve-rln-details"
|
||||
);
|
||||
|
||||
// Credentials Elements
|
||||
|
||||
const membershipIdInput = document.getElementById("membership-id");
|
||||
const identityKeyInput = document.getElementById("id-key");
|
||||
const commitmentKeyInput = document.getElementById("commitment-key");
|
||||
const importManually = document.getElementById("import-manually-button");
|
||||
const importFromWalletButton = document.getElementById(
|
||||
"import-from-wallet-button"
|
||||
);
|
||||
|
||||
const idDiv = document.getElementById("id");
|
||||
const keyDiv = document.getElementById("key");
|
||||
const commitmentDiv = document.getElementById("commitment");
|
||||
|
||||
const registerButton = document.getElementById("register-button");
|
||||
|
||||
// Waku Elements
|
||||
const statusDiv = document.getElementById("waku-status");
|
||||
|
||||
const remoteMultiAddrInput = document.getElementById("remote-multiaddr");
|
||||
const dialButton = document.getElementById("dial");
|
||||
|
||||
const nicknameInput = document.getElementById("nick-input");
|
||||
|
||||
const textInput = document.getElementById("textInput");
|
||||
const sendButton = document.getElementById("sendButton");
|
||||
const sendingStatusSpan = document.getElementById("sending-status");
|
||||
|
||||
const messagesDiv = document.getElementById("messages");
|
||||
|
||||
let membershipId,
|
||||
membershipKey,
|
||||
encoder,
|
||||
node,
|
||||
nodeConnected,
|
||||
rlnInstance;
|
||||
|
||||
const allMemberships = [];
|
||||
let retrievedRLNEvents = false;
|
||||
const rlnInstancePromise = create();
|
||||
|
||||
const SIGNATURE_MESSAGE =
|
||||
"The signature of this message will be used to generate your RLN credentials. Anyone accessing it may send messages on your behalf, please only share with the RLN dApp";
|
||||
|
||||
// Load zero-kit WASM blob.
|
||||
|
||||
statusSpan.innerText = "WASM Blob download in progress...";
|
||||
rlnInstancePromise.then((_rlnInstance) => {
|
||||
rlnInstance = _rlnInstance;
|
||||
statusSpan.innerText = "WASM Blob download in progress... done!";
|
||||
updateFields();
|
||||
});
|
||||
|
||||
const ContentTopic = "/toy-chat/2/luzhou/proto";
|
||||
|
||||
// Protobuf
|
||||
const ProtoChatMessage = new protobuf.Type("ChatMessage")
|
||||
.add(new protobuf.Field("timestamp", 1, "uint64"))
|
||||
.add(new protobuf.Field("nick", 2, "string"))
|
||||
.add(new protobuf.Field("text", 3, "bytes"));
|
||||
|
||||
// Function to update the fields to guide the user by disabling buttons.
|
||||
const updateFields = () => {
|
||||
if (membershipKey) {
|
||||
keyDiv.innerHTML = utils.bytesToHex(membershipKey.IDKey);
|
||||
commitmentDiv.innerHTML = utils.bytesToHex(
|
||||
membershipKey.IDCommitment
|
||||
);
|
||||
idDiv.innerHTML = membershipId || "not registered yet";
|
||||
|
||||
if (membershipId && rlnInstance) {
|
||||
encoder = new RLNEncoder(
|
||||
new EncoderV0(ContentTopic),
|
||||
rlnInstance,
|
||||
membershipId,
|
||||
membershipKey
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
registerButton.disabled = !(
|
||||
membershipKey &&
|
||||
retrievedRLNEvents &&
|
||||
!membershipId
|
||||
);
|
||||
|
||||
importManually.disabled = !(
|
||||
membershipIdInput.value &&
|
||||
identityKeyInput.value &&
|
||||
commitmentKeyInput.value
|
||||
);
|
||||
|
||||
const readyToSend =
|
||||
membershipKey && membershipId && nodeConnected && nicknameInput.value;
|
||||
textInput.disabled = !readyToSend;
|
||||
sendButton.disabled = !readyToSend;
|
||||
|
||||
dialButton.disabled = !(node && node.isStarted() && retrievedRLNEvents);
|
||||
|
||||
retrieveRLNDetailsButton.disabled = !rlnInstance || retrievedRLNEvents;
|
||||
};
|
||||
|
||||
// Blockchain
|
||||
|
||||
membershipIdInput.onchange = updateFields;
|
||||
identityKeyInput.onchange = updateFields;
|
||||
commitmentKeyInput.onchange = updateFields;
|
||||
|
||||
importManually.onclick = () => {
|
||||
const idKey = utils.hexToBytes(identityKeyInput.value);
|
||||
const idCommitment = utils.hexToBytes(commitmentKeyInput.value);
|
||||
membershipKey = new MembershipKey(idKey, idCommitment);
|
||||
membershipId = membershipIdInput.value;
|
||||
updateFields();
|
||||
};
|
||||
|
||||
importFromWalletButton.onclick = async () => {
|
||||
const signer = provider.getSigner();
|
||||
|
||||
const signature = await signer.signMessage(SIGNATURE_MESSAGE);
|
||||
|
||||
membershipKey = await rlnInstance.generateSeededMembershipKey(
|
||||
signature
|
||||
);
|
||||
|
||||
const idCommitment = ethers.utils.hexlify(membershipKey.IDCommitment);
|
||||
|
||||
allMemberships.forEach((m) => {
|
||||
if (m.pubkey._hex === idCommitment) {
|
||||
membershipId = m.index.toString();
|
||||
}
|
||||
});
|
||||
|
||||
updateFields();
|
||||
};
|
||||
|
||||
const checkChain = async (chainId) => {
|
||||
retrieveRLNDetailsButton.disabled = retrievedRLNEvents || chainId !== 5;
|
||||
registerButton.disabled = !(chainId === 5 && retrievedRLNEvents);
|
||||
if (chainId !== 5) {
|
||||
alert("Switch to Goerli");
|
||||
}
|
||||
};
|
||||
|
||||
const rlnDeployBlk = 7109391;
|
||||
const rlnAddress = "0x4252105670fe33d2947e8ead304969849e64f2a6";
|
||||
const rlnAbi = [
|
||||
"function MEMBERSHIP_DEPOSIT() public view returns(uint256)",
|
||||
"function register(uint256 pubkey) external payable",
|
||||
"function withdraw(uint256 secret, uint256 _pubkeyIndex, address payable receiver) external",
|
||||
"event MemberRegistered(uint256 pubkey, uint256 index)",
|
||||
"event MemberWithdrawn(uint256 pubkey, uint256 index)",
|
||||
];
|
||||
|
||||
const provider = new ethers.providers.Web3Provider(
|
||||
window.ethereum,
|
||||
"any"
|
||||
);
|
||||
|
||||
let accounts;
|
||||
let rlnContract;
|
||||
|
||||
const handleMembership = (pubkey, index) => {
|
||||
try {
|
||||
allMemberships.push({ pubkey, index });
|
||||
|
||||
const idCommitment = ethers.utils.zeroPad(
|
||||
ethers.utils.arrayify(pubkey),
|
||||
32
|
||||
);
|
||||
rlnInstance.insertMember(idCommitment);
|
||||
const indexInt = index.toNumber();
|
||||
if (
|
||||
!latestMembershipSpan.innerText ||
|
||||
indexInt > latestMembershipSpan.innerText
|
||||
) {
|
||||
latestMembershipSpan.innerText = indexInt;
|
||||
}
|
||||
console.debug(
|
||||
"IDCommitment registered in tree",
|
||||
idCommitment,
|
||||
indexInt
|
||||
);
|
||||
latestMembershipSpan.innerHTML = indexInt;
|
||||
} catch (err) {
|
||||
console.error(err); // TODO: the merkle tree can be in a wrong state. The app should be disabled
|
||||
}
|
||||
};
|
||||
|
||||
const setAccounts = (acc) => {
|
||||
accounts = acc;
|
||||
addressDiv.innerHTML = accounts.length ? accounts[0] : "";
|
||||
};
|
||||
|
||||
connectWalletButton.onclick = async () => {
|
||||
try {
|
||||
accounts = await provider.send("eth_requestAccounts", []);
|
||||
setAccounts(accounts);
|
||||
const network = await provider.getNetwork();
|
||||
checkChain(network.chainId);
|
||||
|
||||
importFromWalletButton.disabled = false;
|
||||
} catch (e) {
|
||||
console.log("No web3 provider available", e);
|
||||
}
|
||||
};
|
||||
|
||||
retrieveRLNDetailsButton.onclick = async () => {
|
||||
rlnContract = new ethers.Contract(rlnAddress, rlnAbi, provider);
|
||||
|
||||
const filter = rlnContract.filters.MemberRegistered();
|
||||
|
||||
// populating merkle tree:
|
||||
const alreadyRegisteredMembers = await rlnContract.queryFilter(
|
||||
filter,
|
||||
rlnDeployBlk
|
||||
);
|
||||
alreadyRegisteredMembers.forEach((event) => {
|
||||
handleMembership(event.args.pubkey, event.args.index, event);
|
||||
});
|
||||
|
||||
retrievedRLNEvents = true;
|
||||
|
||||
// reacting to new registrations
|
||||
rlnContract.on(filter, (pubkey, index, event) => {
|
||||
handleMembership(event.args.pubkey, event.args.index, event);
|
||||
});
|
||||
updateFields();
|
||||
};
|
||||
|
||||
window.ethereum.on("accountsChanged", setAccounts);
|
||||
window.ethereum.on("chainChanged", (chainId) => {
|
||||
checkChain(parseInt(chainId, 16));
|
||||
});
|
||||
|
||||
registerButton.onclick = async () => {
|
||||
try {
|
||||
registerButton.disabled = true;
|
||||
|
||||
const idCommitment = membershipKey.IDCommitment;
|
||||
const reversedArray = idCommitment.slice().reverse();
|
||||
const pubkey = ethers.utils.hexlify(reversedArray).toString();
|
||||
|
||||
const price = await rlnContract.MEMBERSHIP_DEPOSIT();
|
||||
|
||||
const signer = provider.getSigner();
|
||||
const rlnContractWithSigner = rlnContract.connect(signer);
|
||||
|
||||
const txResponse = await rlnContractWithSigner.register(pubkey, {
|
||||
value: price,
|
||||
});
|
||||
console.log("Transaction broadcasted:", txResponse);
|
||||
|
||||
const txReceipt = await txResponse.wait();
|
||||
|
||||
console.log("Transaction receipt", txReceipt);
|
||||
|
||||
// Update membershipId
|
||||
membershipId = txReceipt.events[0].args.index.toNumber();
|
||||
console.log(
|
||||
"Obtained index for current membership credentials",
|
||||
membershipId
|
||||
);
|
||||
updateFields();
|
||||
registerButton.disabled = false;
|
||||
} catch (err) {
|
||||
alert(err);
|
||||
registerButton.disabled = false;
|
||||
}
|
||||
};
|
||||
|
||||
// Waku
|
||||
nicknameInput.onchange = updateFields;
|
||||
nicknameInput.onblur = updateFields;
|
||||
|
||||
let messages = [];
|
||||
|
||||
const updateMessages = () => {
|
||||
messagesDiv.innerHTML = "<ul>";
|
||||
messages.forEach((msg) => {
|
||||
messagesDiv.innerHTML += `<li>${msg.msg} - [epoch: ${msg.epoch}, proof: ${msg.proofState} ]</li>`;
|
||||
|
||||
if (msg.proofState === "verifying...") {
|
||||
try {
|
||||
console.log("Verifying proof without roots");
|
||||
console.time("proof_verify_timer");
|
||||
const res = msg.verifyNoRoot();
|
||||
console.timeEnd("proof_verify_timer");
|
||||
console.log("proof verified without roots", res);
|
||||
if (res === undefined) {
|
||||
msg.proofState = "no proof attached";
|
||||
} else if (res) {
|
||||
msg.proofState = "verified.";
|
||||
} else {
|
||||
msg.proofState = "invalid!";
|
||||
}
|
||||
} catch (e) {
|
||||
msg.proofState = "Error encountered, check console";
|
||||
console.error("Error verifying proof:", e);
|
||||
}
|
||||
updateMessages();
|
||||
console.log("Verifying proof with roots", msg.verify());
|
||||
}
|
||||
});
|
||||
messagesDiv.innerHTML += "</ul>";
|
||||
};
|
||||
|
||||
const callback = (wakuMessage) => {
|
||||
const { timestamp, nick, text } = ProtoChatMessage.decode(
|
||||
wakuMessage.payload
|
||||
);
|
||||
const time = new Date();
|
||||
time.setTime(Number(timestamp) * 1000);
|
||||
|
||||
let proofState, verify, verifyNoRoot;
|
||||
if (typeof wakuMessage.rateLimitProof === "undefined") {
|
||||
proofState = "no proof attached";
|
||||
} else {
|
||||
console.log("Proof received:", wakuMessage.rateLimitProof);
|
||||
verify = wakuMessage.verify.bind(wakuMessage);
|
||||
verifyNoRoot = wakuMessage.verifyNoRoot.bind(wakuMessage);
|
||||
proofState = "verifying...";
|
||||
}
|
||||
|
||||
messages.push({
|
||||
msg: `(${nick}) <strong>${utils.bytesToUtf8(
|
||||
text
|
||||
)}</strong> <i>[${time.toISOString()}]</i>`,
|
||||
epoch: wakuMessage.epoch,
|
||||
verify,
|
||||
verifyNoRoot,
|
||||
proofState,
|
||||
});
|
||||
updateMessages();
|
||||
};
|
||||
|
||||
(async () => {
|
||||
statusDiv.innerHTML = "<p>Creating Waku node.</p>";
|
||||
node = await createLightNode();
|
||||
|
||||
statusDiv.innerHTML = "<p>Starting Waku node.</p>";
|
||||
await node.start();
|
||||
statusDiv.innerHTML = "<p>Waku node started.</p>";
|
||||
updateFields();
|
||||
})();
|
||||
|
||||
dialButton.onclick = async () => {
|
||||
const ma = remoteMultiAddrInput.value;
|
||||
if (!ma) {
|
||||
statusDiv.innerHTML = "<p>Error: No multiaddr provided.</p>";
|
||||
return;
|
||||
}
|
||||
statusDiv.innerHTML = "<p>Dialing peer.</p>";
|
||||
await node.dial(ma, ["filter", "lightpush"]);
|
||||
await waitForRemotePeer(node, ["filter", "lightpush"]);
|
||||
statusDiv.innerHTML = "<p>Waku node connected.</p>";
|
||||
|
||||
await rlnInstancePromise;
|
||||
const decoder = new RLNDecoder(
|
||||
rlnInstance,
|
||||
new DecoderV0(ContentTopic)
|
||||
);
|
||||
await node.filter.subscribe([decoder], callback);
|
||||
statusDiv.innerHTML = "<p>Waku node subscribed.</p>";
|
||||
nodeConnected = true;
|
||||
updateFields();
|
||||
};
|
||||
|
||||
sendButton.onclick = async () => {
|
||||
const text = utils.utf8ToBytes(textInput.value);
|
||||
const timestamp = new Date();
|
||||
const msg = ProtoChatMessage.create({
|
||||
text,
|
||||
nick: nicknameInput.value,
|
||||
timestamp: Math.floor(timestamp.valueOf() / 1000),
|
||||
});
|
||||
const payload = ProtoChatMessage.encode(msg).finish();
|
||||
console.log("Sending message with proof...");
|
||||
sendingStatusSpan.innerText = "sending...";
|
||||
await node.lightPush.push(encoder, { payload, timestamp });
|
||||
sendingStatusSpan.innerText = "sent!";
|
||||
console.log("Message sent!");
|
||||
textInput.value = null;
|
||||
setTimeout(() => {
|
||||
sendingStatusSpan.innerText = "";
|
||||
}, 5000);
|
||||
};
|
||||
</script>
|
||||
<script src="https://unpkg.com/@multiformats/multiaddr@12.1.1/dist/index.min.js"></script>
|
||||
<script type="module" src="./index.js"></script>
|
||||
</body>
|
||||
</html>
|
||||
|
|
|
|||
|
|
@ -0,0 +1,485 @@
|
|||
import * as utils from "https://unpkg.com/@waku/utils@0.0.4/bundle/bytes.js";
|
||||
import { createLightNode } from "https://unpkg.com/@waku/create@0.0.12/bundle/index.js";
|
||||
import {
|
||||
createEncoder,
|
||||
createDecoder,
|
||||
waitForRemotePeer,
|
||||
} from "https://unpkg.com/@waku/core@0.0.16/bundle/index.js";
|
||||
import { protobuf } from "https://taisukef.github.io/protobuf-es.js/dist/protobuf-es.js";
|
||||
import {
|
||||
create,
|
||||
MembershipKey,
|
||||
RLNDecoder,
|
||||
RLNEncoder,
|
||||
RLNContract,
|
||||
} from "https://unpkg.com/@waku/rln@0.0.14-7e0966a/bundle/index.js";
|
||||
import { ethers } from "https://unpkg.com/ethers@5.7.2/dist/ethers.esm.min.js";
|
||||
|
||||
const ContentTopic = "/toy-chat/2/luzhou/proto";
|
||||
|
||||
// Protobuf
|
||||
const ProtoChatMessage = new protobuf.Type("ChatMessage")
|
||||
.add(new protobuf.Field("timestamp", 1, "uint64"))
|
||||
.add(new protobuf.Field("nick", 2, "string"))
|
||||
.add(new protobuf.Field("text", 3, "bytes"));
|
||||
|
||||
const rlnDeployBlk = 7109391;
|
||||
const rlnAddress = "0x4252105670fe33d2947e8ead304969849e64f2a6";
|
||||
|
||||
const SIGNATURE_MESSAGE =
|
||||
"The signature of this message will be used to generate your RLN credentials. Anyone accessing it may send messages on your behalf, please only share with the RLN dApp";
|
||||
|
||||
run()
|
||||
.then(() => {
|
||||
console.log("Successfully started application.");
|
||||
})
|
||||
.catch((err) => {
|
||||
console.error("Failed at starting application with ", err.message);
|
||||
});
|
||||
|
||||
async function run() {
|
||||
const ui = initUI();
|
||||
const rln = await initRLN(ui);
|
||||
await initWaku(ui, rln);
|
||||
}
|
||||
|
||||
async function initRLN(ui) {
|
||||
const result = {
|
||||
encoder: undefined,
|
||||
rlnInstance: undefined,
|
||||
};
|
||||
|
||||
const provider = new ethers.providers.Web3Provider(window.ethereum, "any");
|
||||
|
||||
ui.setRlnStatus("WASM Blob download in progress...");
|
||||
const rlnInstance = await create();
|
||||
ui.setRlnStatus("WASM Blob download in progress... done!");
|
||||
|
||||
const rlnContract = new RLNContract({
|
||||
address: rlnAddress,
|
||||
provider: provider.getSigner(),
|
||||
});
|
||||
|
||||
// Wallet logic
|
||||
window.ethereum.on("accountsChanged", ui.setAccount);
|
||||
window.ethereum.on("chainChanged", (chainId) => {
|
||||
const id = parseInt(chainId, 16);
|
||||
ui.disableIfNotGoerli(id);
|
||||
});
|
||||
ui.onConnectWallet(async () => {
|
||||
try {
|
||||
const accounts = await provider.send("eth_requestAccounts", []);
|
||||
ui.setAccount(accounts);
|
||||
const network = await provider.getNetwork();
|
||||
ui.disableIfNotGoerli(network.chainId);
|
||||
} catch (e) {
|
||||
console.log("No web3 provider available", e);
|
||||
}
|
||||
});
|
||||
|
||||
ui.onRetrieveDetails(async () => {
|
||||
const filter = rlnContract.contract.filters.MemberRegistered();
|
||||
|
||||
ui.disableRetrieveButton();
|
||||
await rlnContract.fetchMembers(rlnInstance, { fromBlock: rlnDeployBlk });
|
||||
ui.enableRetrieveButton();
|
||||
|
||||
rlnContract.subscribeToMembers(rlnInstance);
|
||||
|
||||
const last = rlnContract.members.at(-1);
|
||||
|
||||
if (last) {
|
||||
ui.setLastMember(last.index, last.pubkey);
|
||||
}
|
||||
|
||||
// make sure we have subscriptions to keep updating last item
|
||||
rlnContract.contract.on(filter, (_pubkey, _index, event) => {
|
||||
ui.setLastMember(event.args.index, event.args.pubkey);
|
||||
});
|
||||
});
|
||||
|
||||
let signature;
|
||||
let membershipId;
|
||||
let membershipKey;
|
||||
|
||||
ui.onManualImport((id, key) => {
|
||||
membershipId = id;
|
||||
membershipKey = key;
|
||||
|
||||
result.encoder = new RLNEncoder(
|
||||
createEncoder({
|
||||
ephemeral: false,
|
||||
contentTopic: ContentTopic,
|
||||
}),
|
||||
rlnInstance,
|
||||
membershipId,
|
||||
membershipKey
|
||||
);
|
||||
|
||||
ui.setMembershipInfo(membershipId, membershipKey);
|
||||
ui.enableDialButton();
|
||||
});
|
||||
|
||||
ui.onWalletImport(async () => {
|
||||
const signer = provider.getSigner();
|
||||
|
||||
signature = await signer.signMessage(SIGNATURE_MESSAGE);
|
||||
membershipKey = await rlnInstance.generateSeededMembershipKey(signature);
|
||||
|
||||
const idCommitment = ethers.utils.hexlify(membershipKey.IDCommitment);
|
||||
|
||||
rlnContract.members.forEach((m) => {
|
||||
if (m.pubkey._hex === idCommitment) {
|
||||
membershipId = m.index.toString();
|
||||
}
|
||||
});
|
||||
|
||||
if (membershipId) {
|
||||
result.encoder = new RLNEncoder(
|
||||
createEncoder({
|
||||
ephemeral: false,
|
||||
contentTopic: ContentTopic,
|
||||
}),
|
||||
rlnInstance,
|
||||
membershipId,
|
||||
membershipKey
|
||||
);
|
||||
}
|
||||
|
||||
ui.setMembershipInfo(membershipId, membershipKey);
|
||||
|
||||
const network = await provider.getNetwork();
|
||||
ui.enableRegisterButtonForGoerli(network.chainId);
|
||||
});
|
||||
|
||||
ui.onRegister(async () => {
|
||||
ui.setRlnStatus("Trying to register...");
|
||||
const event = signature
|
||||
? await rlnContract.registerMember(rlnInstance, signature)
|
||||
: await rlnContract.registerMemberFromMembershipKey(membershipKey);
|
||||
|
||||
// Update membershipId
|
||||
membershipId = event.args.index.toNumber();
|
||||
|
||||
console.log(
|
||||
"Obtained index for current membership credentials",
|
||||
membershipId
|
||||
);
|
||||
|
||||
ui.setRlnStatus("Successfully registered.");
|
||||
ui.setMembershipInfo(membershipId, membershipKey);
|
||||
ui.enableDialButton();
|
||||
});
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
async function initWaku(ui, rln) {
|
||||
ui.setWakuStatus("Creating Waku node.");
|
||||
const node = await createLightNode();
|
||||
ui.setWakuStatus("Starting Waku node.");
|
||||
|
||||
await node.start();
|
||||
ui.setWakuStatus("Waku node started.");
|
||||
|
||||
const verifyMessage = (message) => {
|
||||
if (message.proofState === "verifying...") {
|
||||
try {
|
||||
console.log("Verifying proof without roots");
|
||||
console.time("proof_verify_timer");
|
||||
const res = message.verifyNoRoot();
|
||||
console.timeEnd("proof_verify_timer");
|
||||
console.log("proof verified without roots", res);
|
||||
if (res === undefined) {
|
||||
message.proofState = "no proof attached";
|
||||
} else if (res) {
|
||||
message.proofState = "verified.";
|
||||
} else {
|
||||
message.proofState = "invalid!";
|
||||
}
|
||||
} catch (e) {
|
||||
message.proofState = "Error encountered, check console";
|
||||
console.error("Error verifying proof:", e);
|
||||
}
|
||||
|
||||
console.log("Verifying proof with roots", message.verify());
|
||||
}
|
||||
};
|
||||
|
||||
const onFilterMessage = (wakuMessage) => {
|
||||
const { timestamp, nick, text } = ProtoChatMessage.decode(
|
||||
wakuMessage.payload
|
||||
);
|
||||
|
||||
const time = new Date();
|
||||
time.setTime(Number(timestamp) * 1000);
|
||||
|
||||
if (wakuMessage.rateLimitProof) {
|
||||
console.log("Proof received:", wakuMessage.rateLimitProof);
|
||||
}
|
||||
|
||||
wakuMessage.proofState = !!wakuMessage.rateLimitProof
|
||||
? "verifying..."
|
||||
: "no proof attached";
|
||||
|
||||
wakuMessage.msg = `
|
||||
(${nick})
|
||||
<strong>${utils.bytesToUtf8(text)}</strong>
|
||||
<i>[${time.toISOString()}]</i>
|
||||
`;
|
||||
|
||||
verifyMessage(wakuMessage);
|
||||
ui.renderMessage(wakuMessage);
|
||||
};
|
||||
|
||||
ui.onDial(async (ma) => {
|
||||
ui.setWakuStatus("Dialing peer.");
|
||||
|
||||
// TODO(@weboko): move this fix into Waku.dial
|
||||
const multiaddr = MultiformatsMultiaddr.multiaddr(ma);
|
||||
await node.dial(multiaddr, ["filter", "lightpush"]);
|
||||
await waitForRemotePeer(node, ["filter", "lightpush"]);
|
||||
|
||||
ui.setWakuStatus("Waku node connected.");
|
||||
|
||||
const decoder = new RLNDecoder(
|
||||
rln.rlnInstance,
|
||||
createDecoder(ContentTopic)
|
||||
);
|
||||
|
||||
await node.filter.subscribe(decoder, onFilterMessage);
|
||||
|
||||
ui.setWakuStatus("Waku node subscribed.");
|
||||
ui.enableChatButtonsIfNickSet();
|
||||
});
|
||||
|
||||
ui.onSendMessage(async (nick, text) => {
|
||||
const timestamp = new Date();
|
||||
const msg = ProtoChatMessage.create({
|
||||
text,
|
||||
nick,
|
||||
timestamp: Math.floor(timestamp.valueOf() / 1000),
|
||||
});
|
||||
const payload = ProtoChatMessage.encode(msg).finish();
|
||||
console.log("Sending message with proof...");
|
||||
|
||||
ui.setSendingStatus("sending...");
|
||||
await node.lightPush.send(rln.encoder, { payload, timestamp });
|
||||
ui.setSendingStatus("sent!");
|
||||
|
||||
console.log("Message sent!");
|
||||
ui.clearMessageArea();
|
||||
});
|
||||
}
|
||||
|
||||
function initUI() {
|
||||
const statusSpan = document.getElementById("status");
|
||||
|
||||
// Blockchain Elements
|
||||
const addressDiv = document.getElementById("address");
|
||||
const connectWalletButton = document.getElementById("connect-wallet");
|
||||
const latestMembershipSpan = document.getElementById("latest-membership-id");
|
||||
const retrieveRLNDetailsButton = document.getElementById(
|
||||
"retrieve-rln-details"
|
||||
);
|
||||
|
||||
// Credentials Elements
|
||||
const membershipIdInput = document.getElementById("membership-id");
|
||||
const identityKeyInput = document.getElementById("id-key");
|
||||
const commitmentKeyInput = document.getElementById("commitment-key");
|
||||
const importManually = document.getElementById("import-manually-button");
|
||||
const importFromWalletButton = document.getElementById(
|
||||
"import-from-wallet-button"
|
||||
);
|
||||
|
||||
const idDiv = document.getElementById("id");
|
||||
const keyDiv = document.getElementById("key");
|
||||
const commitmentDiv = document.getElementById("commitment");
|
||||
const registerButton = document.getElementById("register-button");
|
||||
|
||||
// Waku Elements
|
||||
const statusDiv = document.getElementById("waku-status");
|
||||
const remoteMultiAddrInput = document.getElementById("remote-multiaddr");
|
||||
const dialButton = document.getElementById("dial");
|
||||
|
||||
const nicknameInput = document.getElementById("nick-input");
|
||||
const textInput = document.getElementById("textInput");
|
||||
const sendButton = document.getElementById("sendButton");
|
||||
const sendingStatusSpan = document.getElementById("sending-status");
|
||||
const messagesList = document.getElementById("messagesList");
|
||||
|
||||
// set initial state
|
||||
idDiv.innerText = "not registered yet";
|
||||
registerButton.disabled = true;
|
||||
importManually.disabled = true;
|
||||
textInput.disabled = true;
|
||||
sendButton.disabled = true;
|
||||
dialButton.disabled = true;
|
||||
retrieveRLNDetailsButton.disabled = true;
|
||||
nicknameInput.disabled = true;
|
||||
|
||||
// monitor & enable buttons if needed
|
||||
membershipIdInput.onchange = enableManualImportIfNeeded;
|
||||
identityKeyInput.onchange = enableManualImportIfNeeded;
|
||||
commitmentKeyInput.onchange = enableManualImportIfNeeded;
|
||||
|
||||
function enableManualImportIfNeeded() {
|
||||
const isValuesPresent =
|
||||
identityKeyInput.value &&
|
||||
commitmentKeyInput.value &&
|
||||
membershipIdInput.value;
|
||||
|
||||
if (isValuesPresent) {
|
||||
importManually.disabled = false;
|
||||
}
|
||||
}
|
||||
|
||||
nicknameInput.onchange = enableChatIfNeeded;
|
||||
nicknameInput.onblur = enableChatIfNeeded;
|
||||
|
||||
function enableChatIfNeeded() {
|
||||
if (nicknameInput.value) {
|
||||
textInput.disabled = false;
|
||||
sendButton.disabled = false;
|
||||
}
|
||||
}
|
||||
|
||||
return {
|
||||
// UI for RLN
|
||||
setRlnStatus(text) {
|
||||
statusSpan.innerText = text;
|
||||
},
|
||||
setMembershipInfo(id, key) {
|
||||
idDiv.innerText = id || "not registered yet";
|
||||
keyDiv.innerText = utils.bytesToHex(key.IDKey);
|
||||
commitmentDiv.innerText = utils.bytesToHex(key.IDCommitment);
|
||||
},
|
||||
setLastMember(index, pubkey) {
|
||||
try {
|
||||
const idCommitment = ethers.utils.zeroPad(
|
||||
ethers.utils.arrayify(pubkey),
|
||||
32
|
||||
);
|
||||
const indexInt = index.toNumber();
|
||||
console.debug(
|
||||
"IDCommitment registered in tree",
|
||||
idCommitment,
|
||||
indexInt
|
||||
);
|
||||
latestMembershipSpan.innerHTML = indexInt;
|
||||
} catch (err) {
|
||||
console.error(err); // TODO: the merkle tree can be in a wrong state. The app should be disabled
|
||||
}
|
||||
},
|
||||
disableIfNotGoerli(chainId) {
|
||||
if (!isGoerliChain(chainId)) {
|
||||
window.alert("Switch to Goerli");
|
||||
|
||||
registerButton.disabled = true;
|
||||
this.disableRetrieveButton();
|
||||
} else {
|
||||
this.enableRetrieveButton();
|
||||
}
|
||||
},
|
||||
enableRetrieveButton() {
|
||||
retrieveRLNDetailsButton.disabled = false;
|
||||
},
|
||||
disableRetrieveButton() {
|
||||
retrieveRLNDetailsButton.disabled = true;
|
||||
},
|
||||
enableRegisterButtonForGoerli(chainId) {
|
||||
registerButton.disabled = isGoerliChain(chainId) ? false : true;
|
||||
},
|
||||
setAccount(accounts) {
|
||||
addressDiv.innerText = accounts.length ? accounts[0] : "";
|
||||
},
|
||||
onConnectWallet(fn) {
|
||||
connectWalletButton.addEventListener("click", async () => {
|
||||
await fn();
|
||||
importFromWalletButton.disabled = false;
|
||||
});
|
||||
},
|
||||
onRetrieveDetails(fn) {
|
||||
retrieveRLNDetailsButton.addEventListener("click", async () => {
|
||||
await fn();
|
||||
});
|
||||
},
|
||||
onManualImport(fn) {
|
||||
importManually.addEventListener("click", () => {
|
||||
const idKey = utils.hexToBytes(identityKeyInput.value);
|
||||
const idCommitment = utils.hexToBytes(commitmentKeyInput.value);
|
||||
|
||||
const membershipId = membershipIdInput.value;
|
||||
const membershipKey = new MembershipKey(idKey, idCommitment);
|
||||
|
||||
fn(membershipId, membershipKey);
|
||||
});
|
||||
},
|
||||
onWalletImport(fn) {
|
||||
importFromWalletButton.addEventListener("click", async () => {
|
||||
await fn();
|
||||
});
|
||||
},
|
||||
onRegister(fn) {
|
||||
registerButton.addEventListener("click", async () => {
|
||||
try {
|
||||
registerButton.disabled = true;
|
||||
await fn();
|
||||
registerButton.disabled = false;
|
||||
} catch (err) {
|
||||
alert(err);
|
||||
registerButton.disabled = false;
|
||||
}
|
||||
});
|
||||
},
|
||||
// UI for Waku
|
||||
setWakuStatus(text) {
|
||||
statusDiv.innerText = text;
|
||||
},
|
||||
setSendingStatus(text) {
|
||||
sendingStatusSpan.innerText = text;
|
||||
},
|
||||
renderMessage(message) {
|
||||
messagesList.innerHTML += `<li>${message.msg} - [epoch: ${message.epoch}, proof: ${message.proofState} ]</li>`;
|
||||
},
|
||||
enableDialButton() {
|
||||
dialButton.disabled = false;
|
||||
},
|
||||
enableChatButtonsIfNickSet() {
|
||||
if (nicknameInput.value) {
|
||||
textInput.disabled = false;
|
||||
sendButton.disabled = false;
|
||||
}
|
||||
},
|
||||
onDial(fn) {
|
||||
dialButton.addEventListener("click", async () => {
|
||||
const multiaddr = remoteMultiAddrInput.value;
|
||||
|
||||
if (!multiaddr) {
|
||||
this.setWakuStatus("Error: No multiaddr provided.");
|
||||
return;
|
||||
}
|
||||
|
||||
await fn(multiaddr);
|
||||
nicknameInput.disabled = false;
|
||||
});
|
||||
},
|
||||
clearMessageArea() {
|
||||
textInput.value = null;
|
||||
setTimeout(() => {
|
||||
this.setSendingStatus("");
|
||||
}, 5000);
|
||||
},
|
||||
onSendMessage(fn) {
|
||||
sendButton.addEventListener("click", async () => {
|
||||
const nick = nicknameInput.value;
|
||||
const text = utils.utf8ToBytes(textInput.value);
|
||||
await fn(nick, text);
|
||||
});
|
||||
},
|
||||
};
|
||||
}
|
||||
|
||||
function isGoerliChain(id) {
|
||||
return id === 5;
|
||||
}
|
||||
Loading…
Reference in New Issue