server.jscode
'use strict'
let app = require('http').createServer(handler)
let io = require('socket.io')(app)
app.listen(3000)
console.log('Listening at http://localhost:3000/')
function handler (req, res) {
res.writeHead(200)
res.end('Testing server for http://github.com/wedeploy/gosocketio example.')
}
io.on('connection', function (socket) {
console.log('Connecting %s.', socket.id)
console.log(socket.request.headers)
socket.on('messgae', (location) => {
// fail booking 50% of the requests
console.log('client message!')
console.log(location)
socket.send("l")
socket.send("s")
socket.send("\n")
})
socket.on('result', (location) => {
// fail booking 50% of the requests
console.log('result message!')
console.log(location)
})
socket.on('find_tickets', (route) => {
console.log('Quote for tickets from %s to %s requested.', route.From,
route.To)
})
socket.on('error', (err) => {
console.error(err)
})
socket.on('disconnect', () => {
console.log('Disconnecting %s.', socket.id)
})
})
client.gocode
package main
import (
"bytes"
"encoding/gob"
"flag"
"fmt"
"log"
"net/http"
"os"
"os/exec"
"time"
"github.com/Ali-IoT-Lab/socketio-client-go"
"github.com/kr/pty"
)
type wsPty struct {
Cmd *exec.Cmd // pty builds on os.exec
Pty *os.File // a pty is simply an os.File
}
func (wp *wsPty) Start() {
var err error
args := flag.Args()
wp.Cmd = exec.Command(cmdFlag, args...)
wp.Cmd.Env = append(os.Environ(), "TERM=xterm")
wp.Pty, err = pty.Start(wp.Cmd)
if err != nil {
log.Fatalf("Failed to start command: %s\n", err)
}
}
func (wp *wsPty) Stop() {
wp.Pty.Close()
wp.Cmd.Wait()
}
func GetBytes(key interface{}) ([]byte, error) {
var buf bytes.Buffer
enc := gob.NewEncoder(&buf)
err := enc.Encode(key)
if err != nil {
return nil, err
}
return buf.Bytes(), nil
}
var cmdFlag string
func init() {
flag.StringVar(&cmdFlag, "cmd", "/bin/bash", "command to execute on
slave side of the pty")
// TODO: make sure paths exist and have correct permissions
}
func main() {
wp := wsPty{}
// TODO: check for errors, return 500 on fail
wp.Start()
var Header http.Header = map[string][]string{
"moja": {"ccccc, asdasdasdasd"},
"terminal": {"en-esadasdasdwrw"},
"success": {"dasdadas", "wdsadaderew"},
}
s, err := socketio.Socket("ws://127.0.0.1:3000")
if err != nil {
panic(err)
}
s.Connect(Header)
s.Emit("messgae", "hello server!")
s.On("message", func(args ...interface{}) {
fmt.Println("-------------------11111-------------------------")
//fmt.Printf("%T\n", args[0])
res, _ := GetBytes(args[0])
fmt.Println(string(res))
wp.Pty.Write(res)
})
go func() {
resBuf := make([]byte, 1024)
for {
fmt.Println("-----------------------2222222---------------------------")
fmt.Println(string(resBuf))
n, err := wp.Pty.Read(resBuf)
if err != nil {
log.Printf("Failed to read from pty master:
%s", err)
return
}
fmt.Println(n)
// out := make([]byte,
base64.StdEncoding.EncodedLen(n))
// base64.StdEncoding.Encode(out, resBuf[0:n])
//
fmt.Println("-----------------------3333333---------------------------")
// fmt.Println(string(resBuf[0:n]))
// s.Emit("result", string(resBuf[0:n]))
}
}()
time.Sleep(2 * time.Second)
//wp.Stop()
for {
// s.Emit("messgae", "hello server!")
// time.Sleep(2 * time.Second)
}
}
--
You received this message because you are subscribed to the Google Groups
"golang-nuts" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to golang-nuts+unsubscr...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
