/usr/share/gocode/src/github.com/alicebob/miniredis/cmd_connection.go is in golang-github-alicebob-miniredis-dev 2.2.1-3.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 | // Commands from http://redis.io/commands#connection
package miniredis
import (
"strconv"
"github.com/alicebob/miniredis/server"
)
func commandsConnection(m *Miniredis) {
m.srv.Register("AUTH", m.cmdAuth)
m.srv.Register("ECHO", m.cmdEcho)
m.srv.Register("PING", m.cmdPing)
m.srv.Register("SELECT", m.cmdSelect)
m.srv.Register("QUIT", m.cmdQuit)
}
// PING
func (m *Miniredis) cmdPing(c *server.Peer, cmd string, args []string) {
if !m.handleAuth(c) {
return
}
c.WriteInline("PONG")
}
// AUTH
func (m *Miniredis) cmdAuth(c *server.Peer, cmd string, args []string) {
if len(args) != 1 {
setDirty(c)
c.WriteError(errWrongNumber(cmd))
return
}
pw := args[0]
m.Lock()
defer m.Unlock()
if m.password == "" {
c.WriteError("ERR Client sent AUTH, but no password is set")
return
}
if m.password != pw {
c.WriteError("ERR invalid password")
return
}
setAuthenticated(c)
c.WriteOK()
}
// ECHO
func (m *Miniredis) cmdEcho(c *server.Peer, cmd string, args []string) {
if len(args) != 1 {
setDirty(c)
c.WriteError(errWrongNumber(cmd))
return
}
if !m.handleAuth(c) {
return
}
msg := args[0]
c.WriteBulk(msg)
}
// SELECT
func (m *Miniredis) cmdSelect(c *server.Peer, cmd string, args []string) {
if len(args) != 1 {
setDirty(c)
c.WriteError(errWrongNumber(cmd))
return
}
if !m.handleAuth(c) {
return
}
id, err := strconv.Atoi(args[0])
if err != nil {
id = 0
}
m.Lock()
defer m.Unlock()
ctx := getCtx(c)
ctx.selectedDB = id
c.WriteOK()
}
// QUIT
func (m *Miniredis) cmdQuit(c *server.Peer, cmd string, args []string) {
// QUIT isn't transactionfied and accepts any arguments.
c.WriteOK()
c.Close()
}
|