[add] Enable Go Modules. [fix] Fix tests for 2.0+ version.

Author: filipecosta90

.circleci/config.yml

@@ -45,7 +45,7 @@ jobs:
 
   build: # test with redisearch:edge
     docker:
-      - image: circleci/golang:1.9
+      - image: circleci/golang:1.12
       - image: redislabs/redisearch:edge
 
     working_directory: /go/src/github.com/RediSearch/redisearch-go
@@ -57,7 +57,7 @@ jobs:
 
   build_nightly: # test nightly with redisearch:edge
     docker:
-      - image: circleci/golang:1.9
+      - image: circleci/golang:1.12
       - image: redislabs/redisearch:edge
 
     working_directory: /go/src/github.com/RediSearch/redisearch-go

.gitignore

@@ -1,6 +1,8 @@
 *
 !/**/
 !**/*.go
+!**/go.mod
+!**/go.sum
 !.gitignore
 !.circleci/config.yml
 !/tests/*.bz2

Makefile

@@ -1,5 +1,6 @@
 # Go parameters
-GOCMD=go
+GOCMD=GO111MODULE=on go
+
 GOBUILD=$(GOCMD) build
 GOINSTALL=$(GOCMD) install
 GOCLEAN=$(GOCMD) clean

go.mod

@@ -0,0 +1,8 @@
+module github.com/RediSearch/redisearch-go
+
+go 1.12
+
+require (
+	github.com/gomodule/redigo v2.0.0+incompatible
+	github.com/stretchr/testify v1.6.1
+)

go.sum

@@ -0,0 +1,13 @@
+github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8=
+github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/gomodule/redigo v2.0.0+incompatible h1:K/R+8tc58AaqLkqG2Ol3Qk+DR/TlNuhuh457pBFPtt0=
+github.com/gomodule/redigo v2.0.0+incompatible/go.mod h1:B4C85qUVwatsJoIUNIfCRsp7qO0iAmpGFZ4EELWSbC4=
+github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/testify v1.6.1 h1:hDPOHmpOpP40lSULcqw7IrRb/u7w6RpDC9399XyoNd0=
+github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c h1:dUUwHk2QECo/6vqA44rthZ8ie2QXMNeKRTHCNY2nXvo=
+gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

redisearch/aggregate_test.go

@@ -5,17 +5,17 @@ import (
 	"compress/bzip2"
 	"encoding/json"
 	"fmt"
-	"github.com/gomodule/redigo/redis"
-	"github.com/stretchr/testify/assert"
 	"log"
 	"math/rand"
 	"os"
 	"reflect"
 	"strconv"
 	"strings"
 	"testing"
-)
 
+	"github.com/gomodule/redigo/redis"
+	"github.com/stretchr/testify/assert"
+)
 
 // Game struct which contains a Asin, a Description, a Title, a Price, and a list of categories
 // a type and a list of social links
@@ -30,7 +30,6 @@ type Game struct {
 	Categories  []string `json:"categories"`
 }
 
-
 func init() {
 	/* load test data */
 	value, exists := os.LookupEnv("REDISEARCH_RDB_LOADED")
@@ -43,7 +42,7 @@ func init() {
 
 		sc := NewSchema(DefaultOptions).
 			AddField(NewTextField("foo"))
-		c.Drop()
+		Flush(c)
 		if err := c.CreateIndex(sc); err != nil {
 			log.Fatal(err)
 		}
@@ -144,7 +143,7 @@ func Init() {
 		AddField(NewSortableNumericField("price")).
 		AddField(NewTagField("categories"))
 
-	c.Drop()
+	Flush(c)
 	c.CreateIndex(sc)
 
 	AddValues(c)
@@ -317,9 +316,9 @@ func TestCursor_Serialize(t *testing.T) {
 		fields fields
 		want   redis.Args
 	}{
-		{"TestCursor_Serialize_1", fields{1, 0, 0,}, redis.Args{"WITHCURSOR"}},
-		{"TestCursor_Serialize_2_MAXIDLE", fields{1, 0, 30000,}, redis.Args{"WITHCURSOR", "MAXIDLE", 30000}},
-		{"TestCursor_Serialize_3_COUNT_MAXIDLE", fields{1, 10, 30000,}, redis.Args{"WITHCURSOR", "COUNT", 10, "MAXIDLE", 30000}},
+		{"TestCursor_Serialize_1", fields{1, 0, 0}, redis.Args{"WITHCURSOR"}},
+		{"TestCursor_Serialize_2_MAXIDLE", fields{1, 0, 30000}, redis.Args{"WITHCURSOR", "MAXIDLE", 30000}},
+		{"TestCursor_Serialize_3_COUNT_MAXIDLE", fields{1, 10, 30000}, redis.Args{"WITHCURSOR", "COUNT", 10, "MAXIDLE", 30000}},
 	}
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
@@ -352,7 +351,7 @@ func TestGroupBy_AddFields(t *testing.T) {
 	}{
 		{"TestGroupBy_AddFields_1",
 			fields{[]string{}, nil, nil},
-			args{"a",},
+			args{"a"},
 			&GroupBy{[]string{"a"}, nil, nil},
 		},
 	}
@@ -651,8 +650,8 @@ func TestProcessAggResponse(t *testing.T) {
 		args args
 		want [][]string
 	}{
-		{"empty-reply", args{[]interface{}{}}, [][]string{},},
-		{"1-element-reply", args{[]interface{}{[]interface{}{"userFullName", "berge, julius", "count", "2783"}}}, [][]string{{"userFullName", "berge, julius", "count", "2783"}},},
+		{"empty-reply", args{[]interface{}{}}, [][]string{}},
+		{"1-element-reply", args{[]interface{}{[]interface{}{"userFullName", "berge, julius", "count", "2783"}}}, [][]string{{"userFullName", "berge, julius", "count", "2783"}}},
 	}
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {

redisearch/client.go

@@ -613,4 +613,4 @@ func (i *Client) AddHash(docId string, score float32, language string, replace b
 		args = args.Add("REPLACE")
 	}
 	return redis.String(conn.Do("FT.ADDHASH", args...))
-}
+}

redisearch/client_test.go

@@ -12,7 +12,7 @@ import (
 func TestClient_Get(t *testing.T) {
 
 	c := createClient("test-get")
-	c.Drop()
+	Flush(c)
 
 	sc := NewSchema(DefaultOptions).
 		AddField(NewTextField("foo"))
@@ -72,9 +72,8 @@ func TestClient_Get(t *testing.T) {
 }
 
 func TestClient_MultiGet(t *testing.T) {
-
 	c := createClient("test-get")
-	c.Drop()
+	Flush(c)
 
 	sc := NewSchema(DefaultOptions).
 		AddField(NewTextField("foo"))
@@ -135,8 +134,7 @@ func TestClient_MultiGet(t *testing.T) {
 
 func TestClient_DictAdd(t *testing.T) {
 	c := createClient("test-get")
-	_, err := c.pool.Get().Do("FLUSHALL")
-	assert.Nil(t, err)
+	Flush(c)
 
 	type fields struct {
 		pool ConnPool
@@ -179,8 +177,7 @@ func TestClient_DictAdd(t *testing.T) {
 func TestClient_DictDel(t *testing.T) {
 
 	c := createClient("test-get")
-	_, err := c.pool.Get().Do("FLUSHALL")
-	assert.Nil(t, err)
+	Flush(c)
 
 	terms := make([]string, 10)
 	for i := 0; i < 10; i++ {
@@ -228,8 +225,7 @@ func TestClient_DictDel(t *testing.T) {
 
 func TestClient_DictDump(t *testing.T) {
 	c := createClient("test-get")
-	_, err := c.pool.Get().Do("FLUSHALL")
-	assert.Nil(t, err)
+	Flush(c)
 
 	terms1 := make([]string, 10)
 	for i := 0; i < 10; i++ {
@@ -279,7 +275,7 @@ func TestClient_AliasAdd(t *testing.T) {
 	sc := NewSchema(DefaultOptions).
 		AddField(NewTextField("foo")).
 		AddField(NewTextField("bar"))
-	c.Drop()
+	Flush(c)
 	assert.Nil(t, c.CreateIndex(sc))
 
 	docs := make([]Document, 100)
@@ -326,7 +322,7 @@ func TestClient_AliasDel(t *testing.T) {
 	sc := NewSchema(DefaultOptions).
 		AddField(NewTextField("foo")).
 		AddField(NewTextField("bar"))
-	c.Drop()
+	Flush(c)
 	err := c.CreateIndex(sc)
 	assert.Nil(t, err)
 
@@ -375,13 +371,13 @@ func TestClient_AliasUpdate(t *testing.T) {
 	sc := NewSchema(DefaultOptions).
 		AddField(NewTextField("foo")).
 		AddField(NewTextField("bar"))
-	c.Drop()
+	Flush(c)
 	err := c.CreateIndex(sc)
 	assert.Nil(t, err)
 
 	docs := make([]Document, 100)
 	for i := 0; i < 100; i++ {
-		docs[i] = NewDocument(fmt.Sprintf("doc-alias-del-%d", i), 1).Set("foo", "hello world").Set("bar", "hello world foo bar baz")
+		docs[i] = NewDocument(fmt.Sprintf("doc-alias-update-%d", i), 1).Set("foo", "hello world").Set("bar", "hello world foo bar baz")
 	}
 	err = c.Index(docs...)
 
@@ -418,7 +414,7 @@ func TestClient_AliasUpdate(t *testing.T) {
 
 func TestClient_Config(t *testing.T) {
 	c := createClient("testconfigindex")
-
+	Flush(c)
 	ret, err := c.SetConfig("TIMEOUT", "100")
 	assert.Nil(t, err)
 	assert.Equal(t, "OK", ret)
@@ -453,7 +449,7 @@ func TestClient_GetTagVals(t *testing.T) {
 		AddField(NewTextField("name")).
 		AddField(NewTagField("tags"))
 
-	c.Drop()
+	Flush(c)
 	c.CreateIndex(sc)
 
 	docs := make([]Document, 1)
@@ -477,7 +473,7 @@ func TestClient_SynAdd(t *testing.T) {
 	sc := NewSchema(DefaultOptions).
 		AddField(NewTextField("name")).
 		AddField(NewTextField("addr"))
-	c.Drop()
+	Flush(c)
 	err := c.CreateIndex(sc)
 	assert.Nil(t, err)
 
@@ -495,7 +491,7 @@ func TestClient_SynDump(t *testing.T) {
 	sc := NewSchema(DefaultOptions).
 		AddField(NewTextField("name")).
 		AddField(NewTextField("addr"))
-	c.Drop()
+	Flush(c)
 	err := c.CreateIndex(sc)
 	assert.Nil(t, err)
 
@@ -519,24 +515,28 @@ func TestClient_AddHash(t *testing.T) {
 	sc := NewSchema(DefaultOptions).
 		AddField(NewTextField("name")).
 		AddField(NewTextField("addr"))
-	c.Drop()
+	Flush(c)
 	err := c.CreateIndex(sc)
 	assert.Nil(t, err)
 
 	// Add a hash key
 	c.pool.Get().Do("HMSET", "myhash", "field1", "Hello")
 
 	ret, err := c.AddHash("myhash", 1, "english", false)
-	assert.Nil(t, err)
-	assert.Equal(t, "OK", ret)
+	// Given that FT.ADDHASH is no longer valid for search2+ we assert it's error
+	if err != nil {
+		assert.Equal(t, "ERR unknown command `FT.ADDHASH`, with args beginning with: `testAddHash`, `myhash`, `1`, `LANGUAGE`, `english`, ", err.Error())
+	} else {
+		assert.Equal(t, "OK", ret)
+	}
 }
 
 func TestClient_AddField(t *testing.T) {
 	c := createClient("alterTest")
 	sc := NewSchema(DefaultOptions).
 		AddField(NewTextField("name")).
 		AddField(NewTextField("addr"))
-	c.Drop()
+	Flush(c)
 	err := c.CreateIndex(sc)
 	assert.Nil(t, err)
 	err = c.AddField(NewNumericField("age"))

redisearch/example_client_test.go

@@ -4,12 +4,13 @@ import (
 	"crypto/tls"
 	"crypto/x509"
 	"fmt"
-	"github.com/RediSearch/redisearch-go/redisearch"
-	"github.com/gomodule/redigo/redis"
 	"io/ioutil"
 	"log"
 	"os"
 	"time"
+
+	"github.com/RediSearch/redisearch-go/redisearch"
+	"github.com/gomodule/redigo/redis"
 )
 
 // exemplifies the NewClient function
@@ -33,7 +34,7 @@ func ExampleNewClient() {
 	}
 
 	// Create a document with an id and given score
-	doc := redisearch.NewDocument("doc1", 1.0)
+	doc := redisearch.NewDocument("ExampleNewClient:doc1", 1.0)
 	doc.Set("title", "Hello world").
 		Set("body", "foo bar").
 		Set("date", time.Now().Unix())
@@ -49,7 +50,7 @@ func ExampleNewClient() {
 		SetReturnFields("title"))
 
 	fmt.Println(docs[0].Id, docs[0].Properties["title"], total, err)
-	// Output: doc1 Hello world 1 <nil>
+	// Output: ExampleNewClient:doc1 Hello world 1 <nil>
 }
 
 // exemplifies the NewClientFromPool function
@@ -76,7 +77,7 @@ func ExampleNewClientFromPool() {
 	}
 
 	// Create a document with an id and given score
-	doc := redisearch.NewDocument("doc1", 1.0)
+	doc := redisearch.NewDocument("ExampleNewClientFromPool:doc2", 1.0)
 	doc.Set("title", "Hello world").
 		Set("body", "foo bar").
 		Set("date", time.Now().Unix())
@@ -92,7 +93,7 @@ func ExampleNewClientFromPool() {
 		SetReturnFields("title"))
 
 	fmt.Println(docs[0].Id, docs[0].Properties["title"], total, err)
-	// Output: doc1 Hello world 1 <nil>
+	// Output: ExampleNewClientFromPool:doc2 Hello world 1 <nil>
 }
 
 //Example of how to establish an SSL connection from your app to the RedisAI Server
@@ -163,7 +164,7 @@ func ExampleNewClientFromPool_ssl() {
 	}
 
 	// Create a document with an id and given score
-	doc := redisearch.NewDocument("doc1", 1.0)
+	doc := redisearch.NewDocument("ExampleNewClientFromPool_ssl:doc3", 1.0)
 	doc.Set("title", "Hello world").
 		Set("body", "foo bar").
 		Set("date", time.Now().Unix())

redisearch/example_schema_test.go

@@ -2,9 +2,10 @@ package redisearch_test
 
 import (
 	"fmt"
-	"github.com/RediSearch/redisearch-go/redisearch"
 	"log"
 	"time"
+
+	"github.com/RediSearch/redisearch-go/redisearch"
 )
 
 // exemplifies the CreateIndex function with a temporary index specification
@@ -25,7 +26,7 @@ func ExampleCreateIndex_temporary() {
 	}
 
 	// Create a document with an id and given score
-	doc := redisearch.NewDocument("doc1", 1.0)
+	doc := redisearch.NewDocument("ExampleCreateIndex_temporary:doc1", 1.0)
 	doc.Set("title", "Hello world").
 		Set("body", "foo bar").
 		Set("date", time.Now().Unix())
@@ -46,6 +47,6 @@ func ExampleCreateIndex_temporary() {
 	// Searching with limit and sorting
 	_, err = c.Info()
 	fmt.Println(err)
-	// Output: doc1 Hello world 1 <nil>
+	// Output: ExampleCreateIndex_temporary:doc1 Hello world 1 <nil>
 	// Unknown Index name
 }