mirror of
https://github.com/nbd-wtf/nostr-tools.git
synced 2025-12-09 00:28:51 +00:00
Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
84e4fb1f92 |
1
.gitignore
vendored
1
.gitignore
vendored
@@ -2,4 +2,3 @@ node_modules
|
|||||||
dist
|
dist
|
||||||
yarn.lock
|
yarn.lock
|
||||||
package-lock.json
|
package-lock.json
|
||||||
nostr.js
|
|
||||||
|
|||||||
17
README.md
17
README.md
@@ -70,20 +70,3 @@ pool.addRelay('<url>')
|
|||||||
All functions expect bytearrays as hex strings and output bytearrays as hex strings.
|
All functions expect bytearrays as hex strings and output bytearrays as hex strings.
|
||||||
|
|
||||||
For other utils please read the source (for now).
|
For other utils please read the source (for now).
|
||||||
|
|
||||||
### Using from the browser (if you don't want to use a bundler)
|
|
||||||
|
|
||||||
You can import nostr-tools as an ES module. Just add a script tag like this:
|
|
||||||
|
|
||||||
```html
|
|
||||||
<script type="module">
|
|
||||||
import {generatePrivateKey} from 'https://unpkg.com/nostr-tools/nostr.js'
|
|
||||||
console.log(generatePrivateKey())
|
|
||||||
</script>
|
|
||||||
```
|
|
||||||
|
|
||||||
And import whatever function you would import from `"nostr-tools"` in a bundler.
|
|
||||||
|
|
||||||
## License
|
|
||||||
|
|
||||||
Public domain.
|
|
||||||
|
|||||||
25
build.js
25
build.js
@@ -1,25 +0,0 @@
|
|||||||
#!/usr/bin/env node
|
|
||||||
|
|
||||||
const esbuild = require('esbuild')
|
|
||||||
const alias = require('esbuild-plugin-alias')
|
|
||||||
const nodeGlobals = require('@esbuild-plugins/node-globals-polyfill').default
|
|
||||||
|
|
||||||
const buildOptions = {
|
|
||||||
entryPoints: ['index.js'],
|
|
||||||
outfile: 'nostr.js',
|
|
||||||
bundle: true,
|
|
||||||
format: 'esm',
|
|
||||||
plugins: [
|
|
||||||
alias({
|
|
||||||
stream: require.resolve('readable-stream')
|
|
||||||
}),
|
|
||||||
nodeGlobals({buffer: true})
|
|
||||||
],
|
|
||||||
define: {
|
|
||||||
window: 'self',
|
|
||||||
global: 'self'
|
|
||||||
},
|
|
||||||
loader: {'.js': 'jsx'}
|
|
||||||
}
|
|
||||||
|
|
||||||
esbuild.build(buildOptions).then(() => console.log('build success.'))
|
|
||||||
6
event.js
6
event.js
@@ -52,7 +52,7 @@ export function verifySignature(event) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export async function signEvent(event, key) {
|
export async function signEvent(event, key) {
|
||||||
return Buffer.from(
|
return Buffer.from(secp256k1.schnorr.sign(getEventHash(event), key)).toString(
|
||||||
await secp256k1.schnorr.sign(getEventHash(event), key)
|
'hex'
|
||||||
).toString('hex')
|
)
|
||||||
}
|
}
|
||||||
|
|||||||
1
keys.js
1
keys.js
@@ -1,5 +1,4 @@
|
|||||||
import * as secp256k1 from '@noble/secp256k1'
|
import * as secp256k1 from '@noble/secp256k1'
|
||||||
import {Buffer} from 'buffer'
|
|
||||||
|
|
||||||
export function generatePrivateKey() {
|
export function generatePrivateKey() {
|
||||||
return Buffer.from(secp256k1.utils.randomPrivateKey()).toString('hex')
|
return Buffer.from(secp256k1.utils.randomPrivateKey()).toString('hex')
|
||||||
|
|||||||
6
nip05.js
6
nip05.js
@@ -15,7 +15,11 @@ export async function searchDomain(domain, query = '') {
|
|||||||
export async function queryName(fullname) {
|
export async function queryName(fullname) {
|
||||||
try {
|
try {
|
||||||
let [name, domain] = fullname.split('@')
|
let [name, domain] = fullname.split('@')
|
||||||
if (!domain) return null
|
|
||||||
|
if (!domain) {
|
||||||
|
domain = name
|
||||||
|
name = '_'
|
||||||
|
}
|
||||||
|
|
||||||
let res = await (
|
let res = await (
|
||||||
await fetch(`https://${domain}/.well-known/nostr.json?name=${name}`)
|
await fetch(`https://${domain}/.well-known/nostr.json?name=${name}`)
|
||||||
|
|||||||
12
package.json
12
package.json
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "nostr-tools",
|
"name": "nostr-tools",
|
||||||
"version": "0.23.4",
|
"version": "0.22.0",
|
||||||
"description": "Tools for making a Nostr client.",
|
"description": "Tools for making a Nostr client.",
|
||||||
"repository": {
|
"repository": {
|
||||||
"type": "git",
|
"type": "git",
|
||||||
@@ -30,15 +30,7 @@
|
|||||||
"client"
|
"client"
|
||||||
],
|
],
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"@esbuild-plugins/node-globals-polyfill": "^0.1.1",
|
|
||||||
"esbuild": "^0.14.38",
|
|
||||||
"esbuild-plugin-alias": "^0.2.1",
|
|
||||||
"eslint": "^8.5.0",
|
"eslint": "^8.5.0",
|
||||||
"eslint-plugin-babel": "^5.3.1",
|
"eslint-plugin-babel": "^5.3.1"
|
||||||
"events": "^3.3.0",
|
|
||||||
"readable-stream": "^3.6.0"
|
|
||||||
},
|
|
||||||
"scripts": {
|
|
||||||
"prepublish": "node build.js"
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
20
pool.js
20
pool.js
@@ -26,42 +26,32 @@ export function relayPool() {
|
|||||||
|
|
||||||
const activeSubscriptions = {}
|
const activeSubscriptions = {}
|
||||||
|
|
||||||
const sub = ({cb, filter, beforeSend}, id) => {
|
const sub = ({cb, filter}, id = Math.random().toString().slice(2)) => {
|
||||||
if (!id) id = Math.random().toString().slice(2)
|
|
||||||
|
|
||||||
const subControllers = Object.fromEntries(
|
const subControllers = Object.fromEntries(
|
||||||
Object.values(relays)
|
Object.values(relays)
|
||||||
.filter(({policy}) => policy.read)
|
.filter(({policy}) => policy.read)
|
||||||
.map(({relay}) => [
|
.map(({relay}) => [
|
||||||
relay.url,
|
relay.url,
|
||||||
relay.sub({cb: event => cb(event, relay.url), filter, beforeSend}, id)
|
relay.sub({filter, cb: event => cb(event, relay.url)}, id)
|
||||||
])
|
])
|
||||||
)
|
)
|
||||||
|
|
||||||
const activeCallback = cb
|
const activeCallback = cb
|
||||||
const activeFilters = filter
|
const activeFilters = filter
|
||||||
const activeBeforeSend = beforeSend
|
|
||||||
|
|
||||||
const unsub = () => {
|
const unsub = () => {
|
||||||
Object.values(subControllers).forEach(sub => sub.unsub())
|
Object.values(subControllers).forEach(sub => sub.unsub())
|
||||||
delete activeSubscriptions[id]
|
delete activeSubscriptions[id]
|
||||||
}
|
}
|
||||||
const sub = ({
|
const sub = ({cb = activeCallback, filter = activeFilters}) => {
|
||||||
cb = activeCallback,
|
|
||||||
filter = activeFilters,
|
|
||||||
beforeSend = activeBeforeSend
|
|
||||||
}) => {
|
|
||||||
Object.entries(subControllers).map(([relayURL, sub]) => [
|
Object.entries(subControllers).map(([relayURL, sub]) => [
|
||||||
relayURL,
|
relayURL,
|
||||||
sub.sub({cb: event => cb(event, relayURL), filter, beforeSend}, id)
|
sub.sub({cb, filter}, id)
|
||||||
])
|
])
|
||||||
return activeSubscriptions[id]
|
return activeSubscriptions[id]
|
||||||
}
|
}
|
||||||
const addRelay = relay => {
|
const addRelay = relay => {
|
||||||
subControllers[relay.url] = relay.sub(
|
subControllers[relay.url] = relay.sub({cb, filter}, id)
|
||||||
{cb: event => cb(event, relay.url), filter, beforeSend},
|
|
||||||
id
|
|
||||||
)
|
|
||||||
return activeSubscriptions[id]
|
return activeSubscriptions[id]
|
||||||
}
|
}
|
||||||
const removeRelay = relayURL => {
|
const removeRelay = relayURL => {
|
||||||
|
|||||||
20
relay.js
20
relay.js
@@ -119,10 +119,7 @@ export function relayConnect(url, onNotice = () => {}, onError = () => {}) {
|
|||||||
ws.send(msg)
|
ws.send(msg)
|
||||||
}
|
}
|
||||||
|
|
||||||
const sub = (
|
const sub = ({cb, filter}, channel = Math.random().toString().slice(2)) => {
|
||||||
{cb, filter, beforeSend},
|
|
||||||
channel = Math.random().toString().slice(2)
|
|
||||||
) => {
|
|
||||||
var filters = []
|
var filters = []
|
||||||
if (Array.isArray(filter)) {
|
if (Array.isArray(filter)) {
|
||||||
filters = filter
|
filters = filter
|
||||||
@@ -130,25 +127,16 @@ export function relayConnect(url, onNotice = () => {}, onError = () => {}) {
|
|||||||
filters.push(filter)
|
filters.push(filter)
|
||||||
}
|
}
|
||||||
|
|
||||||
if (beforeSend) {
|
|
||||||
const beforeSendResult = beforeSend({filter, relay: url, channel})
|
|
||||||
filters = beforeSendResult.filter
|
|
||||||
}
|
|
||||||
|
|
||||||
trySend(['REQ', channel, ...filters])
|
trySend(['REQ', channel, ...filters])
|
||||||
channels[channel] = cb
|
channels[channel] = cb
|
||||||
openSubs[channel] = filters
|
openSubs[channel] = filters
|
||||||
|
|
||||||
const activeCallback = cb
|
const activeCallback = cb
|
||||||
const activeFilters = filters
|
const activeFilters = filters
|
||||||
const activeBeforeSend = beforeSend
|
|
||||||
|
|
||||||
return {
|
return {
|
||||||
sub: ({
|
sub: ({cb = activeCallback, filter = activeFilters}) =>
|
||||||
cb = activeCallback,
|
sub({cb, filter}, channel),
|
||||||
filter = activeFilters,
|
|
||||||
beforeSend = activeBeforeSend
|
|
||||||
}) => sub({cb, filter, beforeSend}, channel),
|
|
||||||
unsub: () => {
|
unsub: () => {
|
||||||
delete openSubs[channel]
|
delete openSubs[channel]
|
||||||
delete channels[channel]
|
delete channels[channel]
|
||||||
@@ -172,7 +160,7 @@ export function relayConnect(url, onNotice = () => {}, onError = () => {}) {
|
|||||||
unsub()
|
unsub()
|
||||||
clearTimeout(willUnsub)
|
clearTimeout(willUnsub)
|
||||||
},
|
},
|
||||||
filter: {ids: [event.id]}
|
filter: {id: event.id}
|
||||||
},
|
},
|
||||||
`monitor-${event.id.slice(0, 5)}`
|
`monitor-${event.id.slice(0, 5)}`
|
||||||
)
|
)
|
||||||
|
|||||||
Reference in New Issue
Block a user