update

Author: chenjie199234

README.md

@@ -18,17 +18,25 @@
 	Web framework,this contains protobuf plugin to generate code from proto file
 ## cgrpc
 	grpc framework,this contains protobuf plugin to generate code from proto file
-## stream
-	stream connection framework,use websocket's frame format,so this can support rawtcp and websocket at the same time on same port
 ## crpc
 	a new rpc framework(20-30% fast then grpc),this contains protobuf plugin to generate code from proto file
-## id
-	snow flake
-## log
-	log and trace log
-## pool
-	sync.Pool for []byte and bufio.Reader and bufio.Writer
+## pbex
+    protobuf extension for message validate,this is used in the web/crpc/cgrpc framework
+## stream
+	stream connection framework,use websocket's frame format,so this can support rawtcp and websocket at the same time on same port
+## ws
+    a simple ws handshake and message recv and send framework
 ## container
 	some useful struct
+## monitor
+    Promethus support
+## mysql
+    mysql driver wraper,add trace support and read write seprate
+## mongo
+    mongodb driver wraper,add trace support
+## redis
+    redis driver wraper,add trace support and some useful function(bloom filter,rate limiter,message queue,verify code check)
+## email
+    simple email client used to send email
 ## superd
 	fork child process to exec some other program,like supervisor

id/id.go container/id/id.go

@@ -36,10 +36,8 @@ func (op OPCode) IsControl() bool {
 var ErrNotWS = errors.New("not a websocket connection")
 var ErrRequestLineFormat = errors.New("http request line format wrong")
 var ErrResponseLineFormat = errors.New("http response line format wrong")
-var ErrHttpVersion = errors.New("http version wrong")
-var ErrHttpMethod = errors.New("http method wrong")
 var ErrHeaderLineFormat = errors.New("http header line format wrong")
-var ErrSign = errors.New("sign error")
+var ErrAcceptSign = errors.New("accept sign wrong")
 
 var ErrMsgLarge = errors.New("message too large")
 var ErrMsgFin = errors.New("message must be fin")

id/id_test.go container/id/id_test.go

@@ -99,10 +99,6 @@ func Cupgrade(reader *bufio.Reader, writer net.Conn, host, path string) (header
 				e = ErrResponseLineFormat
 				return
 			}
-			if !bytes.Equal(pieces[0], []byte{'H', 'T', 'T', 'P', '/', '1', '.', '1'}) {
-				e = ErrHttpVersion
-				return
-			}
 			if !bytes.Equal(pieces[1], []byte{'1', '0', '1'}) {
 				e = ErrResponseLineFormat
 				return
@@ -142,7 +138,7 @@ func Cupgrade(reader *bufio.Reader, writer net.Conn, host, path string) (header
 				h.Write(nonce)
 				h.Write([]byte{'2', '5', '8', 'E', 'A', 'F', 'A', '5', '-', 'E', '9', '1', '4', '-', '4', '7', 'D', 'A', '-', '9', '5', 'C', 'A', '-', 'C', '5', 'A', 'B', '0', 'D', 'C', '8', '5', 'B', '1', '1'})
 				if base64.StdEncoding.EncodeToString(h.Sum(nil)) != common.BTS(pieces[1]) {
-					e = ErrSign
+					e = ErrAcceptSign
 					return
 				}
 			case "sec-websocket-version":

ws/const.go

@@ -76,14 +76,6 @@ func Supgrade(reader *bufio.Reader, writer net.Conn) (path string, header http.H
 				e = ErrRequestLineFormat
 				return
 			}
-			if !bytes.Equal(pieces[0], []byte{'G', 'E', 'T'}) {
-				e = ErrHttpMethod
-				return
-			}
-			if !bytes.Equal(pieces[2], []byte{'H', 'T', 'T', 'P', '/', '1', '.', '1'}) {
-				e = ErrHttpVersion
-				return
-			}
 			if len(pieces[1]) == 0 {
 				path = "/"
 			} else if pieces[1][0] != '/' {