mirror of
https://github.com/nbd-wtf/nostr-tools.git
synced 2025-12-08 16:28:49 +00:00
Compare commits
5 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
7b0220c1b8 | ||
|
|
d8eee25e3a | ||
|
|
d5e93e0c30 | ||
|
|
fff31b5ff4 | ||
|
|
cd7ffb8911 |
27
filter.js
Normal file
27
filter.js
Normal file
@@ -0,0 +1,27 @@
|
|||||||
|
export function matchFilter(filter, event) {
|
||||||
|
if (filter.id && event.id !== filter.id) return false
|
||||||
|
if (filter.kind && event.kind !== filter.kind) return false
|
||||||
|
if (filter.author && event.pubkey !== filter.author) return false
|
||||||
|
if (filter.authors && filter.authors.indexOf(event.pubkey) === -1)
|
||||||
|
return false
|
||||||
|
if (
|
||||||
|
filter['#e'] &&
|
||||||
|
!event.tags.find(([t, v]) => t === 'e' && v === filter['#e'])
|
||||||
|
)
|
||||||
|
return false
|
||||||
|
if (
|
||||||
|
filter['#p'] &&
|
||||||
|
!event.tags.find(([t, v]) => t === 'p' && v === filter['#p'])
|
||||||
|
)
|
||||||
|
return false
|
||||||
|
if (filter.since && event.created_at <= filter.since) return false
|
||||||
|
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
|
export function matchFilters(filters, event) {
|
||||||
|
for (let i = 0; i < filters.length; i++) {
|
||||||
|
if (matchFilter(filters[i], event)) return true
|
||||||
|
}
|
||||||
|
return false
|
||||||
|
}
|
||||||
5
index.js
5
index.js
@@ -7,6 +7,7 @@ import {
|
|||||||
serializeEvent,
|
serializeEvent,
|
||||||
getEventHash
|
getEventHash
|
||||||
} from './event'
|
} from './event'
|
||||||
|
import {matchFilter, matchFilters} from './filter'
|
||||||
import {makeRandom32, sha256, getPublicKey} from './utils'
|
import {makeRandom32, sha256, getPublicKey} from './utils'
|
||||||
|
|
||||||
export {
|
export {
|
||||||
@@ -19,5 +20,7 @@ export {
|
|||||||
makeRandom32,
|
makeRandom32,
|
||||||
sha256,
|
sha256,
|
||||||
getPublicKey,
|
getPublicKey,
|
||||||
getBlankEvent
|
getBlankEvent,
|
||||||
|
matchFilter,
|
||||||
|
matchFilters
|
||||||
}
|
}
|
||||||
|
|||||||
5
nip04.js
5
nip04.js
@@ -1,3 +1,4 @@
|
|||||||
|
import aes from 'browserify-cipher'
|
||||||
import {Buffer} from 'buffer'
|
import {Buffer} from 'buffer'
|
||||||
import randomBytes from 'randombytes'
|
import randomBytes from 'randombytes'
|
||||||
import * as secp256k1 from '@noble/secp256k1'
|
import * as secp256k1 from '@noble/secp256k1'
|
||||||
@@ -7,7 +8,7 @@ export function encrypt(privkey, pubkey, text) {
|
|||||||
const normalizedKey = getOnlyXFromFullSharedSecret(key)
|
const normalizedKey = getOnlyXFromFullSharedSecret(key)
|
||||||
|
|
||||||
let iv = Uint8Array.from(randomBytes(16))
|
let iv = Uint8Array.from(randomBytes(16))
|
||||||
var cipher = crypto.createCipheriv(
|
var cipher = aes.createCipheriv(
|
||||||
'aes-256-cbc',
|
'aes-256-cbc',
|
||||||
Buffer.from(normalizedKey, 'hex'),
|
Buffer.from(normalizedKey, 'hex'),
|
||||||
iv
|
iv
|
||||||
@@ -22,7 +23,7 @@ export function decrypt(privkey, pubkey, ciphertext, iv) {
|
|||||||
const key = secp256k1.getSharedSecret(privkey, '02' + pubkey)
|
const key = secp256k1.getSharedSecret(privkey, '02' + pubkey)
|
||||||
const normalizedKey = getOnlyXFromFullSharedSecret(key)
|
const normalizedKey = getOnlyXFromFullSharedSecret(key)
|
||||||
|
|
||||||
var decipher = crypto.createDecipheriv(
|
var decipher = aes.createDecipheriv(
|
||||||
'aes-256-cbc',
|
'aes-256-cbc',
|
||||||
Buffer.from(normalizedKey, 'hex'),
|
Buffer.from(normalizedKey, 'hex'),
|
||||||
Buffer.from(iv, 'base64')
|
Buffer.from(iv, 'base64')
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "nostr-tools",
|
"name": "nostr-tools",
|
||||||
"version": "0.9.1",
|
"version": "0.11.0",
|
||||||
"description": "Tools for making a Nostr client.",
|
"description": "Tools for making a Nostr client.",
|
||||||
"repository": {
|
"repository": {
|
||||||
"type": "git",
|
"type": "git",
|
||||||
@@ -9,10 +9,11 @@
|
|||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@noble/secp256k1": "^1.3.0",
|
"@noble/secp256k1": "^1.3.0",
|
||||||
"bip39": "^3.0.4",
|
"bip39": "^3.0.4",
|
||||||
"buffer": "^6.0.3",
|
"browserify-cipher": ">=1",
|
||||||
"create-hmac": "^1.1.7",
|
"buffer": ">=5",
|
||||||
|
"create-hmac": ">=1",
|
||||||
"dns-packet": "^5.2.4",
|
"dns-packet": "^5.2.4",
|
||||||
"randombytes": "^2.1.0",
|
"randombytes": ">=2",
|
||||||
"websocket-polyfill": "^0.0.3"
|
"websocket-polyfill": "^0.0.3"
|
||||||
},
|
},
|
||||||
"keywords": [
|
"keywords": [
|
||||||
|
|||||||
11
relay.js
11
relay.js
@@ -1,6 +1,7 @@
|
|||||||
import 'websocket-polyfill'
|
import 'websocket-polyfill'
|
||||||
|
|
||||||
import {verifySignature} from './event'
|
import {verifySignature} from './event'
|
||||||
|
import {matchFilters} from './filter'
|
||||||
|
|
||||||
export function normalizeRelayURL(url) {
|
export function normalizeRelayURL(url) {
|
||||||
let [host, ...qs] = url.split('?')
|
let [host, ...qs] = url.split('?')
|
||||||
@@ -88,10 +89,12 @@ export function relayConnect(url, onNotice) {
|
|||||||
let channel = data[1]
|
let channel = data[1]
|
||||||
let event = data[2]
|
let event = data[2]
|
||||||
|
|
||||||
if (await verifySignature(event)) {
|
if (
|
||||||
if (channels[channel]) {
|
(await verifySignature(event)) &&
|
||||||
channels[channel](event)
|
channels[channel] &&
|
||||||
}
|
matchFilters(openSubs[channel], event)
|
||||||
|
) {
|
||||||
|
channels[channel](event)
|
||||||
}
|
}
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user