nostr.js

function insert_event_sorted(evs, new_ev) {
    for (let i = 0; i < evs.length; i++) {
        const ev = evs[i]

        if (new_ev.id === ev.id) {
            return false
        }

        if (new_ev.created_at < ev.created_at) {
            evs.splice(i, 0, new_ev)
            return true
        }
    }

    evs.push(new_ev)
    return true
}


function Relay(relay, opts={})
{
   // console.log(relay)
    if (!(this instanceof Relay))
        return new Relay(relay, opts)

    this.relay = relay
    this.opts = opts

    const me = this
    return new Promise((resolve, reject) => {
        const ws = me.ws = new WebSocket(relay);
        let resolved = false
        ws.onmessage = (m) => { handle_nostr_message(me, m) }
        ws.onclose = () => { me.close && me.close() }
        ws.onerror = () => { me.error && me.error() }
        ws.onopen = () => {
            if (resolved) {
                me.open.bind(me)
                return
            }

            resolved = true
            resolve(me)
        }
    })
}

Relay.prototype.subscribe = function relay_subscribe(sub_id, ...filters) {
    const tosend = ["REQ", sub_id, ...filters]
    this.ws.send(JSON.stringify(tosend))
}

Relay.prototype.unsubscribe = function relay_unsubscribe(sub_id) {
    const tosend = ["CLOSE", sub_id]
    this.ws.send(JSON.stringify(tosend))
}

function handle_nostr_message(relay, msg)
{
    const data = JSON.parse(msg.data)
    if (data.length >= 2) {
        switch (data[0]) {
            case "EVENT":
                if (data.length < 3)
                    return
                return relay.event && relay.event(data[1], data[2])
            case "EOSE":
                return relay.eose && relay.eose(data[1])
            case "NOTICE":
                return relay.note && relay.note(...data.slice(1))
        }
    }
}