initial import of future v2

sockjs/.gitignore

@@ -0,0 +1,3 @@
+*.swp
+profile.out
+*.coverprofile

sockjs/doc.go

@@ -1,6 +1 @@
-/*
-Package gosockjs is an concurrent safe implementation of a SockJS server. The core design principles are described
-here http://blog.igormihalik.com/2012/12/sockjs-for-go.html and source code can be found on github https://github.com/igm/sockjs-go
-
-*/
 package sockjs

sockjs/example_test.go

@@ -0,0 +1,41 @@
+package sockjs_test
+
+import (
+	"net/http"
+
+	"sockjs-go.v3/sockjs"
+)
+
+func ExampleNewHandler_simple() {
+	handler := sockjs.NewHandler("/echo", sockjs.DefaultOptions, func(con sockjs.Conn) {
+		var msg string
+		var err error
+		for {
+			if msg, err = con.Recv(); err != nil {
+				break
+			}
+			if err = con.Send(msg); err != nil {
+				break
+			}
+		}
+	})
+	http.ListenAndServe(":8080", handler)
+}
+
+func ExampleNewHandler_defaultMux() {
+	handler := sockjs.NewHandler("/echo", sockjs.DefaultOptions, func(con sockjs.Conn) {
+		var msg string
+		var err error
+		for {
+			if msg, err = con.Recv(); err != nil {
+				break
+			}
+			if err = con.Send(msg); err != nil {
+				break
+			}
+		}
+	})
+	// need to provide path prefix for http.Mux
+	http.Handle("/echo/", handler)
+	http.ListenAndServe(":8080", nil)
+}

sockjs/frame.go

@@ -0,0 +1,11 @@
+package sockjs
+
+import (
+	"encoding/json"
+	"fmt"
+)
+
+func closeFrame(status uint32, reason string) string {
+	bytes, _ := json.Marshal([]interface{}{status, reason})
+	return fmt.Sprintf("c%s", string(bytes))
+}

sockjs/frame_test.go

@@ -0,0 +1,10 @@
+package sockjs
+
+import "testing"
+
+func TestCloseFrame(t *testing.T) {
+	cf := closeFrame(1024, "some close text")
+	if cf != "c[1024,\"some close text\"]" {
+		t.Errorf("Wrong close frame generated '%s'", cf)
+	}
+}