cloud-control-panel/gorilla.go

// Copyright 2015 The Gorilla WebSocket Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

package main

import "log"
import "net/url"
import "time"

import "github.com/gorilla/websocket"

import "github.com/golang/protobuf/proto"
import pb "git.wit.com/wit/witProtobuf"

var gorillaConn *websocket.Conn

func gorillaReadProtobuf(conn *websocket.Conn) {
	for {
		log.Println("gorilla START gorillaReadProtobuf()", time.Now())
		mytype, message, err := conn.ReadMessage()
		if err != nil {
			log.Println("read:", err)
			return
		}
		if (mytype == websocket.BinaryMessage) {
			protobufMsg := new(pb.Event)
			err = proto.Unmarshal(message, protobufMsg)
			if (err != nil) {
				log.Printf("readConn() something fucked up happened in Unmarshal")
			}
			log.Printf("gorillaReadProtobuf() successfully read protobuf from gorilla websocket")
			addEvent(protobufMsg)
		} else {
			log.Printf("recv: %s", message)
			// log.Printf("type, err = ", mytype, err)
		}
		time.Sleep(time.Second)
		log.Println("gorilla END gorillaReadProtobuf()", time.Now())
	}
}

func gorillaSendProtobuf(msg *pb.Event) {
	log.Println("gorillaSendProtobuf() START", time.Now())
	if (gorillaConn == nil) {
		log.Println("gorillaSendProtobuf() gorillaConn == nil")
		log.Println("Need to re-open connection here")
		return
	}
	/*
	msg := pb.CreateSampleEvent()
	msg.Name = "test echo over gorilla websocket"
	*/
	data, _ := proto.Marshal(msg)
	err2 := gorillaConn.WriteMessage(websocket.BinaryMessage, data)
	if err2 != nil {
		log.Println("write:", err2)
		gorillaConn = nil
		return
	}
	log.Println("gorillaSendProtobuf() END OK", time.Now())
}

func closeGorillaConn() {
	if gorillaConn == nil {
		log.Println("gorillaConn already was nil")
		return
	}

	// Cleanly close the connection by sending a close message and then
	// waiting (with timeout) for the server to close the connection.
	err := gorillaConn.WriteMessage(websocket.CloseMessage, websocket.FormatCloseMessage(websocket.CloseNormalClosure, ""))
	if err != nil {
		log.Println("write close:", err)
		return
	}

	// this must be called or set to be called with defer
	gorillaConn.Close()
	gorillaConn = nil
	log.Println("closeGorillaConn() END OK", time.Now())
}

func gorillaDial(hostname string) {
	// var addr = flag.String("addr", "v000185.testing.com.customers.wprod.wit.com:9000", "http service address")

	for {
		// u := url.URL{Scheme: "ws", Host: *addr, Path: "/event"}
		u := url.URL{Scheme: "ws", Host: hostname, Path: "/event"}
		log.Printf("connecting to %s", u.String())

		conn, _, err := websocket.DefaultDialer.Dial(u.String(), nil)
		if err != nil {
			log.Println("gorilla Dial failed", err)
		} else {
			gorillaConn = conn

			// handle inbound messages on the channel
			gorillaReadProtobuf(conn)
			closeGorillaConn()
		}

		time.Sleep(time.Second * 5) // try every 5 seconds
	}
}