laantungir/nostr-tools
1
0
Fork 0
mirror of https://github.com/nbd-wtf/nostr-tools.git synced 2025-12-09 16:48:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

now it works.

Browse Source
This commit is contained in:
fiatjaf
2021-01-10 00:03:33 -03:00
parent 65e6f22a00
commit 13dcdf39e3
5 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
README.md
View File

@@ -14,7 +14,7 @@ pool.setPrivateKey('<hex>') // optional
pool.addRelay('ws://some.relay.com', {read: true, write: true}) pool.addRelay('ws://some.relay.com', {read: true, write: true})
pool.addRelay('ws://other.relay.cool', {read: true, write: true}) pool.addRelay('ws://other.relay.cool', {read: true, write: true})
pool.onEvent((context, event, relay) => { pool.onEvent((event, context, relay) => {
console.log(`got a relay with context ${context} from ${relay.url} which is already validated.`, event) console.log(`got a relay with context ${context} from ${relay.url} which is already validated.`, event)
}) })

6
event.js
View File

@@ -8,7 +8,7 @@ export function serializeEvent(evt) {
evt.pubkey, evt.pubkey,
evt.created_at, evt.created_at,
evt.kind, evt.kind,
evt.tags, evt.tags || [],
evt.content evt.content
]) ])
} }
@@ -20,7 +20,7 @@ export async function getEventHash(event) {
export async function verifySignature(event) { export async function verifySignature(event) {
return await secp256k1.schnorr.verify( return await secp256k1.schnorr.verify(
event.signature, event.sig,
await getEventHash(event), await getEventHash(event),
event.pubkey event.pubkey
) )
@@ -28,5 +28,5 @@ export async function verifySignature(event) {
export async function signEvent(event, key) { export async function signEvent(event, key) {
let eventHash = await getEventHash(event) let eventHash = await getEventHash(event)
return await secp256k1.schnorr.sign(key, eventHash) return await secp256k1.schnorr.sign(eventHash, key)
} }

2
package.json
View File

@@ -1,6 +1,6 @@
{ {
"name": "nostr-tools", "name": "nostr-tools",
"version": "0.1.1", "version": "0.1.2",
"description": "Tools for making a Nostr client.", "description": "Tools for making a Nostr client.",
"main": "index.js", "main": "index.js",
"repository": { "repository": {

6
pool.js
View File

@@ -8,10 +8,10 @@ export function relayPool(globalPrivateKey) {
const eventCallbacks = [] const eventCallbacks = []
const noticeCallbacks = [] const noticeCallbacks = []
function propagateEvent(context, event, relayURL) { function propagateEvent(event, context, relayURL) {
for (let i = 0; i < eventCallbacks.length; i++) { for (let i = 0; i < eventCallbacks.length; i++) {
let {relay} = relays[relayURL] let {relay} = relays[relayURL]
eventCallbacks[i](context, event, relay) eventCallbacks[i](event, context, relay)
} }
} }
function propagateNotice(notice, relayURL) { function propagateNotice(notice, relayURL) {
@@ -33,7 +33,7 @@ export function relayPool(globalPrivateKey) {
if (policyFilter.write && policy.write) { if (policyFilter.write && policy.write) {
await fn(relay) await fn(relay)
} else if (policyFilter.read && policy.read) { } else if (policyFilter.read && policy.read) {
await fn(relays) await fn(relay)
} }
} }
} }

6
relay.js
View File

@@ -38,11 +38,11 @@ export function relayConnect(url, onEvent, onNotice) {
console.log('message from relay ' + url + ': ' + data[1]) console.log('message from relay ' + url + ': ' + data[1])
onNotice(data[1]) onNotice(data[1])
} else if (typeof data[0] === 'object') { } else if (typeof data[0] === 'object') {
let context = data[0] let event = data[0]
let event = data[1] let context = data[1]
if (await verifySignature(event)) { if (await verifySignature(event)) {
onEvent(context, event) onEvent(event, context)
} else { } else {
console.warn( console.warn(
'got event with invalid signature from ' + url, 'got event with invalid signature from ' + url,