Commitf04c643

authored and

committed

Pass event data from events to user defined functions

Additionally added the ability to have a custom message handler.Closes#4

1 parent5c1f12b commitf04c643Copy full SHA for f04c643

File tree

+11

-7

lines changed

+11

-7

lines changed

Lines changed: 11 additions & 7 deletions

Original file line number	Diff line number	Diff line change
`@@ -37,26 +37,30 @@ function init_websocket(me) {`
`37`	`37`	`constws=me.ws=newWS(me.url);`
`38`	`38`	`returnnewPromise((resolve,reject)=>{`
`39`	`39`	`letresolved=false`
`40`		`-ws.onmessage=(m)=>{handle_nostr_message(me,m)}`
`41`		`-ws.onclose=()=>{`
	`40`	`+ws.onmessage=(m)=>{`
	`41`	`+handle_nostr_message(me,m)`
	`42`	`+if(me.onfn.message)`
	`43`	`+me.onfn.message(m)`
	`44`	`+}`
	`45`	`+ws.onclose=(e)=>{`
`42`	`46`	`if(me.onfn.close)`
`43`		`-me.onfn.close()`
	`47`	`+me.onfn.close(e)`
`44`	`48`	`if(me.reconnecting)`
`45`	`49`	`returnreject(newError("close during reconnect"))`
`46`	`50`	`if(!me.manualClose&&me.opts.reconnect)`
`47`	`51`	`reconnect(me)`
`48`	`52`	`}`
`49`		`-ws.onerror=()=>{`
	`53`	`+ws.onerror=(e)=>{`
`50`	`54`	`if(me.onfn.error)`
`51`		`-me.onfn.error()`
	`55`	`+me.onfn.error(e)`
`52`	`56`	`if(me.reconnecting)`
`53`	`57`	`returnreject(newError("error during reconnect"))`
`54`	`58`	`if(me.opts.reconnect)`
`55`	`59`	`reconnect(me)`
`56`	`60`	`}`
`57`		`-ws.onopen=()=>{`
	`61`	`+ws.onopen=(e)=>{`
`58`	`62`	`if(me.onfn.open)`
`59`		`-me.onfn.open()`
	`63`	`+me.onfn.open(e)`
`60`	`64`
`61`	`65`	`if(resolved)return`
`62`	`66`

Comments

(0)