shivam-880 commented 6 years ago

Redis Data

I have a redis key content with following data:

127.0.0.1:6379> lrange content 0 -1
1) "{\"source\": \"output1.txt\", \"col1\": \"water_pressure\", \"col2\": \"sunday\", \"col3\": \"december\"}"
2) "{\"source\": \"output1.txt\", \"col1\": \"air_pressure\", \"col2\": \"saturday\", \"col3\": \"november\"}"
3) "{\"source\": \"output2.txt\", \"col1\": \"voltage\", \"col2\": \"saturday\", \"col3\": \"october\"}"

Executing script

When I execute the lua script testsc.lua I get appropriate response as below: redis-cli --eval testsc.lua "content" returns (integer) 1

Utilising scala-redis

But executing StudioRedis.scala returns following exception:

Exception in thread "main" java.lang.Exception: Protocol error: Got (:,[B@1189dd52) as initial reply byte
    at com.redis.Reply$$anonfun$8.applyOrElse(RedisProtocol.scala:120)

Can anyone please explain where am I getting wrong here? Also could someone please point me to the API documentation or WIKI for this project?

Versions

scala-redis: latest

redis-server --version
Redis server v=3.2.6 sha=00000000:0 malloc=jemalloc-4.0.3 bits=64 build=af85f436129f4de0

redis-cli --version
redis-cli 3.2.6

StudioRedis.scala

import com.redis.RedisClient

object StudioRedis extends App {
  val luaCode = """
            if redis.call("EXISTS", KEYS[1]) == 1 then
              local res = {}

              local payload = redis.call("lrange", KEYS[1], 0, -1)
              local row = cjson.decode(payload[1])
              res[1] = row["source"]

              return #res
            else
              return -1
            end
            """

  val r = new RedisClient("localhost", 6379)

  val res = r.evalBulk(luaCode, List("content"), List())
  print(res)

  r.disconnect
}

testsc.lua

if redis.call("EXISTS", KEYS[1]) == 1 then
    local res = {}

    local payload = redis.call("lrange", KEYS[1], 0, -1)
    local row = cjson.decode(payload[1])
    res[1] = row["source"]

    return #res
else
    return -1
end