enh: support ws endpoint

taosWS/connection.go

@@ -51,7 +51,7 @@ func newTaosConn(cfg *config) (*taosConn, error) {
 	endpointUrl := &url.URL{
 		Scheme: cfg.net,
 		Host:   fmt.Sprintf("%s:%d", cfg.addr, cfg.port),
-		Path:   "/rest/ws",
+		Path:   "/ws",
 	}
 	if cfg.token != "" {
 		endpointUrl.RawQuery = fmt.Sprintf("token=%s", cfg.token)

ws/schemaless/schemaless.go

@@ -44,8 +44,8 @@ func NewSchemaless(config *Config) (*Schemaless, error) {
 	if wsUrl.Scheme != "ws" && wsUrl.Scheme != "wss" {
 		return nil, errors.New("config url scheme error")
 	}
-	if len(wsUrl.Path) == 0 || wsUrl.Path != "/rest/schemaless" {
-		wsUrl.Path = "/rest/schemaless"
+	if len(wsUrl.Path) == 0 || wsUrl.Path != "/ws" {
+		wsUrl.Path = "/ws"
 	}
 	ws, _, err := common.DefaultDialer.Dial(wsUrl.String(), nil)
 	if err != nil {

ws/schemaless/schemaless_test.go

@@ -59,7 +59,7 @@ func TestSchemaless_Insert(t *testing.T) {
 	}
 	defer func() { _ = after() }()
 
-	s, err := NewSchemaless(NewConfig("ws://localhost:6041/rest/schemaless", 1,
+	s, err := NewSchemaless(NewConfig("ws://localhost:6041/ws", 1,
 		SetDb("test_schemaless_ws"),
 		SetReadTimeout(10*time.Second),
 		SetWriteTimeout(10*time.Second),

ws/stmt/stmt_test.go

@@ -155,7 +155,7 @@ func TestStmt(t *testing.T) {
 	}
 	defer cleanEnv()
 	now := time.Now()
-	config := NewConfig("ws://127.0.0.1:6041/rest/stmt", 0)
+	config := NewConfig("ws://127.0.0.1:6041/ws", 0)
 	config.SetConnectUser("root")
 	config.SetConnectPass("taosdata")
 	config.SetConnectDB("test_ws_stmt")