Commite73a57d

Eric Jiang

committed

feat(): example client/server

1 parent92c1d88 commite73a57dCopy full SHA for e73a57d

File tree

+37

-0

lines changed

+37

-0

lines changed

Lines changed: 12 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,12 @@`
	`1`	`+constSocket=require('simple-websocket')`
	`2`	`+const{ Protocol}=require('./')`
	`3`	`+`
	`4`	`+constsocket=newSocket('ws://localhost:3000')`
	`5`	`+`
	`6`	`+socket.on('connect',()=>{`
	`7`	`+global.alice=newProtocol({connect:()=>socket})`
	`8`	`+`
	`9`	`+alice.call('hey joe!',['argument'],(message)=>{`
	`10`	`+console.log('got response!',message)`
	`11`	`+})`
	`12`	`+})`

Lines changed: 13 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,13 @@`
	`1`	`+constServer=require('simple-websocket/server')`
	`2`	`+const{ Protocol}=require('./')`
	`3`	`+`
	`4`	`+constserver=newServer({port:3000})`
	`5`	`+`
	`6`	`+server.on('connection',(socket)=>{`
	`7`	`+global.bob=newProtocol({connect:()=>socket})`
	`8`	`+`
	`9`	`+bob.command('hey joe!',(command,reply)=>{`
	`10`	`+console.log('got command',command)`
	`11`	`+reply(null,['results1','results2'])`
	`12`	`+})`
	`13`	`+})`

Lines changed: 11 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -2,11 +2,22 @@ const { Duplex } = require('readable-stream')`
`2`	`2`	`constmessages=require('./messages')`
`3`	`3`	`constcrypto=require('crypto')`
`4`	`4`	`constvarint=require('varint')`
	`5`	`+constpump=require('pump')`
`5`	`6`
`6`	`7`	`classProtocolextendsDuplex{`
`7`	`8`	`constructor(opts){`
`8`	`9`	`super()`
	`10`	`+if('function'!==typeofopts.connect){`
	`11`	`+thrownewTypeError('Connection expects a opts.connect(...) factory')`
	`12`	`+}`
	`13`	`+`
`9`	`14`	`this.pending={}`
	`15`	`+this.createConnection=opts.connect`
	`16`	`+`
	`17`	`+constwire=this.createConnection(this)`
	`18`	`+if(wire){`
	`19`	`+pump(wire,this,wire)`
	`20`	`+}`
`10`	`21`	`}`
`11`	`22`
`12`	`23`	`_read(size){`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -24,6 +24,7 @@`
`24`	`24`	`"homepage":"https://github.com/secure-local-node/remote-protocol-stream#readme",`
`25`	`25`	`"dependencies": {`
`26`	`26`	`"protocol-buffers-encodings":"^1.1.0",`
	`27`	`+"pump":"^3.0.0",`
`27`	`28`	`"readable-stream":"^3.3.0",`
`28`	`29`	`"varint":"^5.0.0"`
`29`	`30`	`},`

Comments

(0)