tile38/controller/client.go

233 lines
5.2 KiB
Go
Raw Normal View History

2016-04-01 02:25:47 +03:00
package controller
import (
"errors"
"fmt"
2016-04-01 02:25:47 +03:00
"net"
"sort"
"strings"
2016-04-01 02:25:47 +03:00
"time"
"github.com/tidwall/resp"
"github.com/tidwall/tile38/controller/server"
2016-04-01 02:25:47 +03:00
)
2016-04-03 05:16:36 +03:00
// Conn represents a simple resp connection.
2016-04-01 02:25:47 +03:00
type Conn struct {
conn net.Conn
rd *resp.Reader
wr *resp.Writer
}
2016-04-03 05:16:36 +03:00
// DialTimeout dials a resp server.
2016-04-01 02:25:47 +03:00
func DialTimeout(address string, timeout time.Duration) (*Conn, error) {
tcpconn, err := net.DialTimeout("tcp", address, timeout)
if err != nil {
return nil, err
}
conn := &Conn{
conn: tcpconn,
rd: resp.NewReader(tcpconn),
wr: resp.NewWriter(tcpconn),
}
return conn, nil
}
2016-04-03 05:16:36 +03:00
// Close closes the connection.
2016-04-01 02:25:47 +03:00
func (conn *Conn) Close() error {
conn.wr.WriteMultiBulk("quit")
return conn.conn.Close()
}
2016-04-03 05:16:36 +03:00
// Do performs a command and returns a resp value.
2016-04-01 02:25:47 +03:00
func (conn *Conn) Do(commandName string, args ...interface{}) (val resp.Value, err error) {
if err := conn.wr.WriteMultiBulk(commandName, args...); err != nil {
return val, err
}
val, _, err = conn.rd.ReadValue()
return val, err
}
type byID []*clientConn
func (arr byID) Len() int {
return len(arr)
}
func (arr byID) Less(a, b int) bool {
return arr[a].id < arr[b].id
}
func (arr byID) Swap(a, b int) {
arr[a], arr[b] = arr[b], arr[a]
}
func (c *Controller) cmdClient(msg *server.Message, conn *server.Conn) (string, error) {
start := time.Now()
if len(msg.Values) == 1 {
return "", errInvalidNumberOfArguments
}
switch strings.ToLower(msg.Values[1].String()) {
default:
return "", errors.New("Syntax error, try CLIENT " +
"(LIST | KILL | GETNAME | SETNAME)")
case "list":
if len(msg.Values) != 2 {
return "", errInvalidNumberOfArguments
}
var list []*clientConn
for _, cc := range c.conns {
list = append(list, cc)
}
sort.Sort(byID(list))
now := time.Now()
var buf []byte
for _, cc := range list {
buf = append(buf,
fmt.Sprintf("id=%d addr=%s name=%s age=%d idle=%d\n",
cc.id, cc.conn.RemoteAddr().String(), cc.name,
now.Sub(cc.opened)/time.Second,
now.Sub(cc.last)/time.Second,
)...,
)
}
switch msg.OutputType {
case server.JSON:
return `{"ok":true,"list":` + jsonString(string(buf)) + `,"elapsed":"` + time.Now().Sub(start).String() + "\"}", nil
case server.RESP:
data, err := resp.BytesValue(buf).MarshalRESP()
if err != nil {
return "", err
}
return string(data), nil
}
return "", nil
case "getname":
if len(msg.Values) != 2 {
return "", errInvalidNumberOfArguments
}
name := ""
if cc, ok := c.conns[conn]; ok {
name = cc.name
}
switch msg.OutputType {
case server.JSON:
return `{"ok":true,"name":` + jsonString(name) + `,"elapsed":"` + time.Now().Sub(start).String() + "\"}", nil
case server.RESP:
data, err := resp.StringValue(name).MarshalRESP()
if err != nil {
return "", err
}
return string(data), nil
}
case "setname":
if len(msg.Values) != 3 {
return "", errInvalidNumberOfArguments
}
name := msg.Values[2].String()
for i := 0; i < len(name); i++ {
if name[i] < '!' || name[i] > '~' {
return "", errors.New("Client names cannot contain spaces, newlines or special characters.")
}
}
if cc, ok := c.conns[conn]; ok {
cc.name = name
}
switch msg.OutputType {
case server.JSON:
return `{"ok":true,"elapsed":"` + time.Now().Sub(start).String() + "\"}", nil
case server.RESP:
return "+OK\r\n", nil
}
case "kill":
if len(msg.Values) < 3 {
return "", errInvalidNumberOfArguments
}
var useAddr bool
var addr string
var useID bool
var id string
for i := 2; i < len(msg.Values); i++ {
arg := msg.Values[i].String()
if strings.Contains(arg, ":") {
addr = arg
useAddr = true
break
}
switch strings.ToLower(arg) {
default:
return "", errors.New("No such client")
case "addr":
i++
if i == len(msg.Values) {
return "", errors.New("syntax error")
}
addr = msg.Values[i].String()
useAddr = true
case "id":
i++
if i == len(msg.Values) {
return "", errors.New("syntax error")
}
id = msg.Values[i].String()
useID = true
}
}
var cclose *clientConn
for _, cc := range c.conns {
if useID && fmt.Sprintf("%d", cc.id) == id {
cclose = cc
break
} else if useAddr && cc.conn.RemoteAddr().String() == addr {
cclose = cc
break
}
}
if cclose == nil {
return "", errors.New("No such client")
}
var res string
switch msg.OutputType {
case server.JSON:
res = `{"ok":true,"elapsed":"` + time.Now().Sub(start).String() + "\"}"
case server.RESP:
res = "+OK\r\n"
}
if cclose.conn == conn {
// closing self, return response now
cclose.conn.Write([]byte(res))
}
cclose.conn.Close()
return res, nil
}
return "", errors.New("invalid output type")
}
/*
func (c *Controller) cmdClientList(msg *server.Message) (string, error) {
var ok bool
var key string
if vs, key, ok = tokenval(vs); !ok || key == "" {
return "", errInvalidNumberOfArguments
}
col := c.getCol(key)
if col == nil {
if msg.OutputType == server.RESP {
return "+none\r\n", nil
}
return "", errKeyNotFound
}
typ := "hash"
switch msg.OutputType {
case server.JSON:
return `{"ok":true,"type":` + string(typ) + `,"elapsed":"` + time.Now().Sub(start).String() + "\"}", nil
case server.RESP:
return "+" + typ + "\r\n", nil
}
return "", nil
}
*/