code-health: update format for Call to 1.7

An incompatible change was introduced in
Tarantool 1.7 which was released in 2016.
This change is about a new binary protocol
command for CALL, which no more restricts
a function to returning an array of tuples
and allows returning an arbitrary MsgPack/JSON
result, including scalars, nil and void (nothing).

We should be in-line with tarantool here and
provide `Call17` as just `Call` and rename
current `Call` to `Call16`.

Closes #125

Author: AnaNek

CHANGELOG.md

@@ -25,6 +25,7 @@ Versioning](http://semver.org/spec/v2.0.0.html) except to the first release.
 
 ### Changed
 
+- Breaking change: rename `Call` to `Call16` and `Call17` to `Call` (#125)
 - Handle everything with `go test` (#115)
 - Use plain package instead of module for UUID submodule (#134)
 - Reset buffer if its average use size smaller than quater of capacity (#95)

connection.go

@@ -111,9 +111,9 @@ func (d defaultLogger) Report(event ConnLogKind, conn *Connection, v ...interfac
 //
 // ATTENTION: result argument for *Typed methods should deserialize from
 // msgpack array, cause Tarantool always returns result as an array.
-// For all space related methods and Call* (but not Call17*) methods Tarantool
+// For all space related methods and Call16* (but not Call*) methods Tarantool
 // always returns array of array (array of tuples for space related methods).
-// For Eval* and Call17* Tarantool always returns array, but does not forces
+// For Eval* and Call* Tarantool always returns array, but does not forces
 // array of arrays.
 type Connection struct {
 	addr  string

connection_pool/connection_pool.go

@@ -255,27 +255,27 @@ func (connPool *ConnectionPool) Upsert(space interface{}, tuple, ops interface{}
 	return conn.Upsert(space, tuple, ops)
 }
 
-// Call calls registered Tarantool function.
+// Call16 calls registered Tarantool function.
 // It uses request code for Tarantool 1.6, so result is converted to array of arrays.
-func (connPool *ConnectionPool) Call(functionName string, args interface{}, userMode Mode) (resp *tarantool.Response, err error) {
+func (connPool *ConnectionPool) Call16(functionName string, args interface{}, userMode Mode) (resp *tarantool.Response, err error) {
 	conn, err := connPool.getNextConnection(userMode)
 	if err != nil {
 		return nil, err
 	}
 
-	return conn.Call(functionName, args)
+	return conn.Call16(functionName, args)
 }
 
-// Call17 calls registered Tarantool function.
-// It uses request code for Tarantool 1.7, so result is not converted
+// Call calls registered Tarantool function.
+// It uses request code for Tarantool >= 1.7, so result is not converted
 // (though, keep in mind, result is always array).
-func (connPool *ConnectionPool) Call17(functionName string, args interface{}, userMode Mode) (resp *tarantool.Response, err error) {
+func (connPool *ConnectionPool) Call(functionName string, args interface{}, userMode Mode) (resp *tarantool.Response, err error) {
 	conn, err := connPool.getNextConnection(userMode)
 	if err != nil {
 		return nil, err
 	}
 
-	return conn.Call17(functionName, args)
+	return conn.Call(functionName, args)
 }
 
 // Eval passes lua expression for evaluation.
@@ -351,27 +351,27 @@ func (connPool *ConnectionPool) UpdateTyped(space, index interface{}, key, ops i
 	return conn.UpdateTyped(space, index, key, ops, result)
 }
 
-// CallTyped calls registered function.
+// Call16Typed calls registered function.
 // It uses request code for Tarantool 1.6, so result is converted to array of arrays.
-func (connPool *ConnectionPool) CallTyped(functionName string, args interface{}, result interface{}, userMode Mode) (err error) {
+func (connPool *ConnectionPool) Call16Typed(functionName string, args interface{}, result interface{}, userMode Mode) (err error) {
 	conn, err := connPool.getNextConnection(userMode)
 	if err != nil {
 		return err
 	}
 
-	return conn.CallTyped(functionName, args, result)
+	return conn.Call16Typed(functionName, args, result)
 }
 
-// Call17Typed calls registered function.
-// It uses request code for Tarantool 1.7, so result is not converted
+// CallTyped calls registered function.
+// It uses request code for Tarantool >= 1.7, so result is not converted
 // (though, keep in mind, result is always array).
-func (connPool *ConnectionPool) Call17Typed(functionName string, args interface{}, result interface{}, userMode Mode) (err error) {
+func (connPool *ConnectionPool) CallTyped(functionName string, args interface{}, result interface{}, userMode Mode) (err error) {
 	conn, err := connPool.getNextConnection(userMode)
 	if err != nil {
 		return err
 	}
 
-	return conn.Call17Typed(functionName, args, result)
+	return conn.CallTyped(functionName, args, result)
 }
 
 // EvalTyped passes lua expression for evaluation.
@@ -449,27 +449,27 @@ func (connPool *ConnectionPool) UpsertAsync(space interface{}, tuple interface{}
 	return conn.UpsertAsync(space, tuple, ops)
 }
 
-// CallAsync sends a call to registered Tarantool function and returns Future.
+// Call16Async sends a call to registered Tarantool function and returns Future.
 // It uses request code for Tarantool 1.6, so future's result is always array of arrays.
-func (connPool *ConnectionPool) CallAsync(functionName string, args interface{}, userMode Mode) *tarantool.Future {
+func (connPool *ConnectionPool) Call16Async(functionName string, args interface{}, userMode Mode) *tarantool.Future {
 	conn, err := connPool.getNextConnection(userMode)
 	if err != nil {
 		return tarantool.NewErrorFuture(err)
 	}
 
-	return conn.CallAsync(functionName, args)
+	return conn.Call16Async(functionName, args)
 }
 
-// Call17Async sends a call to registered Tarantool function and returns Future.
-// It uses request code for Tarantool 1.7, so future's result will not be converted
+// CallAsync sends a call to registered Tarantool function and returns Future.
+// It uses request code for Tarantool >= 1.7, so future's result will not be converted
 // (though, keep in mind, result is always array).
-func (connPool *ConnectionPool) Call17Async(functionName string, args interface{}, userMode Mode) *tarantool.Future {
+func (connPool *ConnectionPool) CallAsync(functionName string, args interface{}, userMode Mode) *tarantool.Future {
 	conn, err := connPool.getNextConnection(userMode)
 	if err != nil {
 		return tarantool.NewErrorFuture(err)
 	}
 
-	return conn.Call17Async(functionName, args)
+	return conn.CallAsync(functionName, args)
 }
 
 // EvalAsync sends a lua expression for evaluation and returns Future.
@@ -487,7 +487,7 @@ func (connPool *ConnectionPool) EvalAsync(expr string, args interface{}, userMod
 //
 
 func (connPool *ConnectionPool) getConnectionRole(conn *tarantool.Connection) (Role, error) {
-	resp, err := conn.Call17("box.info", []interface{}{})
+	resp, err := conn.Call("box.info", []interface{}{})
 	if err != nil {
 		return unknown, err
 	}
@@ -506,7 +506,7 @@ func (connPool *ConnectionPool) getConnectionRole(conn *tarantool.Connection) (R
 		return unknown, ErrIncorrectStatus
 	}
 
-	resp, err = conn.Call17("box.info", []interface{}{})
+	resp, err = conn.Call("box.info", []interface{}{})
 	if err != nil {
 		return unknown, err
 	}

connection_pool/connection_pool_test.go

@@ -219,7 +219,7 @@ func TestCall(t *testing.T) {
 	defer connPool.Close()
 
 	// PreferRO
-	resp, err := connPool.Call17("box.info", []interface{}{}, connection_pool.PreferRO)
+	resp, err := connPool.Call("box.info", []interface{}{}, connection_pool.PreferRO)
 	require.Nilf(t, err, "failed to Call")
 	require.NotNilf(t, resp, "response is nil after Call")
 	require.GreaterOrEqualf(t, len(resp.Data), 1, "response.Data is empty after Call")
@@ -230,7 +230,7 @@ func TestCall(t *testing.T) {
 	require.Truef(t, ro, "expected `true` with mode `PreferRO`")
 
 	// PreferRW
-	resp, err = connPool.Call17("box.info", []interface{}{}, connection_pool.PreferRW)
+	resp, err = connPool.Call("box.info", []interface{}{}, connection_pool.PreferRW)
 	require.Nilf(t, err, "failed to Call")
 	require.NotNilf(t, resp, "response is nil after Call")
 	require.GreaterOrEqualf(t, len(resp.Data), 1, "response.Data is empty after Call")
@@ -241,7 +241,7 @@ func TestCall(t *testing.T) {
 	require.Falsef(t, ro, "expected `false` with mode `PreferRW`")
 
 	// RO
-	resp, err = connPool.Call17("box.info", []interface{}{}, connection_pool.RO)
+	resp, err = connPool.Call("box.info", []interface{}{}, connection_pool.RO)
 	require.Nilf(t, err, "failed to Call")
 	require.NotNilf(t, resp, "response is nil after Call")
 	require.GreaterOrEqualf(t, len(resp.Data), 1, "response.Data is empty after Call")
@@ -252,7 +252,7 @@ func TestCall(t *testing.T) {
 	require.Truef(t, ro, "expected `true` with mode `RO`")
 
 	// RW
-	resp, err = connPool.Call17("box.info", []interface{}{}, connection_pool.RW)
+	resp, err = connPool.Call("box.info", []interface{}{}, connection_pool.RW)
 	require.Nilf(t, err, "failed to Call")
 	require.NotNilf(t, resp, "response is nil after Call")
 	require.GreaterOrEqualf(t, len(resp.Data), 1, "response.Data is empty after Call")

connection_pool/example_test.go

@@ -490,15 +490,15 @@ func ExampleConnectionPool_Update() {
 	// Data [[key1 new_value]]
 }
 
-func ExampleConnectionPool_Call17() {
+func ExampleConnectionPool_Call() {
 	pool, err := examplePool(testRoles)
 	if err != nil {
 		fmt.Println(err)
 	}
 	defer pool.Close()
 
 	// Call a function 'simple_incr' with arguments.
-	resp, err := pool.Call17("simple_incr", []interface{}{1}, connection_pool.PreferRW)
+	resp, err := pool.Call("simple_incr", []interface{}{1}, connection_pool.PreferRW)
 	fmt.Println("Call simple_incr()")
 	fmt.Println("Error", err)
 	fmt.Println("Code", resp.Code)

connector.go

@@ -14,8 +14,8 @@ type Connector interface {
 	Delete(space, index interface{}, key interface{}) (resp *Response, err error)
 	Update(space, index interface{}, key, ops interface{}) (resp *Response, err error)
 	Upsert(space interface{}, tuple, ops interface{}) (resp *Response, err error)
+	Call16(functionName string, args interface{}) (resp *Response, err error)
 	Call(functionName string, args interface{}) (resp *Response, err error)
-	Call17(functionName string, args interface{}) (resp *Response, err error)
 	Eval(expr string, args interface{}) (resp *Response, err error)
 
 	GetTyped(space, index interface{}, key interface{}, result interface{}) (err error)
@@ -24,8 +24,8 @@ type Connector interface {
 	ReplaceTyped(space interface{}, tuple interface{}, result interface{}) (err error)
 	DeleteTyped(space, index interface{}, key interface{}, result interface{}) (err error)
 	UpdateTyped(space, index interface{}, key, ops interface{}, result interface{}) (err error)
+	Call16Typed(functionName string, args interface{}, result interface{}) (err error)
 	CallTyped(functionName string, args interface{}, result interface{}) (err error)
-	Call17Typed(functionName string, args interface{}, result interface{}) (err error)
 	EvalTyped(expr string, args interface{}, result interface{}) (err error)
 
 	SelectAsync(space, index interface{}, offset, limit, iterator uint32, key interface{}) *Future
@@ -34,7 +34,7 @@ type Connector interface {
 	DeleteAsync(space, index interface{}, key interface{}) *Future
 	UpdateAsync(space, index interface{}, key, ops interface{}) *Future
 	UpsertAsync(space interface{}, tuple interface{}, ops interface{}) *Future
+	Call16Async(functionName string, args interface{}) *Future
 	CallAsync(functionName string, args interface{}) *Future
-	Call17Async(functionName string, args interface{}) *Future
 	EvalAsync(expr string, args interface{}) *Future
 }

const.go

@@ -6,11 +6,11 @@ const (
 	ReplaceRequest   = 3
 	UpdateRequest    = 4
 	DeleteRequest    = 5
-	CallRequest      = 6 /* call in 1.6 format */
+	Call16Request    = 6 /* call in 1.6 format */
 	AuthRequest      = 7
 	EvalRequest      = 8
 	UpsertRequest    = 9
-	Call17Request    = 10
+	CallRequest      = 10 /* call in >= 1.7 format */
 	PingRequest      = 64
 	SubscribeRequest = 66
 

example_custom_unpacking_test.go

@@ -117,7 +117,7 @@ func Example_customUnpacking() {
 	fmt.Println("Tuples (tuples2):", tuples2)
 
 	// Call a function "func_name" returning a table of custom tuples.
-	var tuples3 []Tuple3
+	var tuples3 [][]Tuple3
 	err = conn.CallTyped("func_name", []interface{}{}, &tuples3)
 	if err != nil {
 		log.Fatalf("Failed to CallTyped: %s", err.Error())
@@ -130,6 +130,6 @@ func Example_customUnpacking() {
 	// Code 0
 	// Tuples (tuples1) [{777 orig [{lol  1} {wut  3}]}]
 	// Tuples (tuples2): [{{} 777 orig [{lol  1} {wut  3}]}]
-	// Tuples (tuples3): [{{} 221  [{Moscow  34} {Minsk  23} {Kiev  31}]}]
+	// Tuples (tuples3): [[{{} 221  [{Moscow  34} {Minsk  23} {Kiev  31}]}]]
 
 }

example_test.go

@@ -253,12 +253,12 @@ func ExampleConnection_Update() {
 	// Data [[14 bye bla]]
 }
 
-func ExampleConnection_Call17() {
+func ExampleConnection_Call() {
 	conn := example_connect()
 	defer conn.Close()
 
 	// Call a function 'simple_incr' with arguments.
-	resp, err := conn.Call17("simple_incr", []interface{}{1})
+	resp, err := conn.Call("simple_incr", []interface{}{1})
 	fmt.Println("Call simple_incr()")
 	fmt.Println("Error", err)
 	fmt.Println("Code", resp.Code)

multi/multi.go

@@ -186,7 +186,7 @@ func (connMulti *ConnectionMulti) checker() {
 				continue
 			}
 			var resp [][]string
-			err := connMulti.Call17Typed(connMulti.opts.NodesGetFunctionName, []interface{}{}, &resp)
+			err := connMulti.CallTyped(connMulti.opts.NodesGetFunctionName, []interface{}{}, &resp)
 			if err != nil {
 				continue
 			}
@@ -321,18 +321,18 @@ func (connMulti *ConnectionMulti) Upsert(space interface{}, tuple, ops interface
 	return connMulti.getCurrentConnection().Upsert(space, tuple, ops)
 }
 
-// Call calls registered Tarantool function.
+// Call16 calls registered Tarantool function.
 // It uses request code for Tarantool 1.6, so result is converted to array of
 // arrays.
-func (connMulti *ConnectionMulti) Call(functionName string, args interface{}) (resp *tarantool.Response, err error) {
-	return connMulti.getCurrentConnection().Call(functionName, args)
+func (connMulti *ConnectionMulti) Call16(functionName string, args interface{}) (resp *tarantool.Response, err error) {
+	return connMulti.getCurrentConnection().Call16(functionName, args)
 }
 
-// Call17 calls registered Tarantool function.
-// It uses request code for Tarantool 1.7, so result is not converted
+// Call calls registered Tarantool function.
+// It uses request code for Tarantool >= 1.7, so result is not converted
 // (though, keep in mind, result is always array).
-func (connMulti *ConnectionMulti) Call17(functionName string, args interface{}) (resp *tarantool.Response, err error) {
-	return connMulti.getCurrentConnection().Call17(functionName, args)
+func (connMulti *ConnectionMulti) Call(functionName string, args interface{}) (resp *tarantool.Response, err error) {
+	return connMulti.getCurrentConnection().Call(functionName, args)
 }
 
 // Eval passes Lua expression for evaluation.
@@ -375,18 +375,18 @@ func (connMulti *ConnectionMulti) UpdateTyped(space, index interface{}, key, ops
 	return connMulti.getCurrentConnection().UpdateTyped(space, index, key, ops, result)
 }
 
-// CallTyped calls registered function.
+// Call16Typed calls registered function.
 // It uses request code for Tarantool 1.6, so result is converted to array of
 // arrays.
-func (connMulti *ConnectionMulti) CallTyped(functionName string, args interface{}, result interface{}) (err error) {
-	return connMulti.getCurrentConnection().CallTyped(functionName, args, result)
+func (connMulti *ConnectionMulti) Call16Typed(functionName string, args interface{}, result interface{}) (err error) {
+	return connMulti.getCurrentConnection().Call16Typed(functionName, args, result)
 }
 
-// Call17Typed calls registered function.
-// It uses request code for Tarantool 1.7, so result is not converted (though,
+// CallTyped calls registered function.
+// It uses request code for Tarantool >= 1.7, so result is not converted (though,
 // keep in mind, result is always array)
-func (connMulti *ConnectionMulti) Call17Typed(functionName string, args interface{}, result interface{}) (err error) {
-	return connMulti.getCurrentConnection().Call17Typed(functionName, args, result)
+func (connMulti *ConnectionMulti) CallTyped(functionName string, args interface{}, result interface{}) (err error) {
+	return connMulti.getCurrentConnection().CallTyped(functionName, args, result)
 }
 
 // EvalTyped passes Lua expression for evaluation.
@@ -429,18 +429,18 @@ func (connMulti *ConnectionMulti) UpsertAsync(space interface{}, tuple interface
 	return connMulti.getCurrentConnection().UpsertAsync(space, tuple, ops)
 }
 
-// CallAsync sends a call to registered Tarantool function and returns Future.
+// Call16Async sends a call to registered Tarantool function and returns Future.
 // It uses request code for Tarantool 1.6, so future's result is always array
 // of arrays.
-func (connMulti *ConnectionMulti) CallAsync(functionName string, args interface{}) *tarantool.Future {
-	return connMulti.getCurrentConnection().CallAsync(functionName, args)
+func (connMulti *ConnectionMulti) Call16Async(functionName string, args interface{}) *tarantool.Future {
+	return connMulti.getCurrentConnection().Call16Async(functionName, args)
 }
 
-// Call17Async sends a call to registered Tarantool function and returns Future.
-// It uses request code for Tarantool 1.7, so future's result will not be converted
+// CallAsync sends a call to registered Tarantool function and returns Future.
+// It uses request code for Tarantool >= 1.7, so future's result will not be converted
 // (though, keep in mind, result is always array).
-func (connMulti *ConnectionMulti) Call17Async(functionName string, args interface{}) *tarantool.Future {
-	return connMulti.getCurrentConnection().Call17Async(functionName, args)
+func (connMulti *ConnectionMulti) CallAsync(functionName string, args interface{}) *tarantool.Future {
+	return connMulti.getCurrentConnection().CallAsync(functionName, args)
 }
 
 // EvalAsync passes Lua expression for evaluation.

queue/queue.go

@@ -289,7 +289,7 @@ func (q *queue) Kick(count uint64) (uint64, error) {
 	resp, err := q.conn.Call(q.cmds.kick, []interface{}{count})
 	var id uint64
 	if err == nil {
-		id = resp.Data[0].([]interface{})[0].(uint64)
+		id = resp.Data[0].(uint64)
 	}
 	return id, err
 }
@@ -309,10 +309,7 @@ func (q *queue) Statistic() (interface{}, error) {
 	}
 
 	if len(resp.Data) != 0 {
-		data, ok := resp.Data[0].([]interface{})
-		if ok && len(data) != 0 {
-			return data[0], nil
-		}
+		return resp.Data[0], nil
 	}
 
 	return nil, nil