client-libraries/clojure/src/redis/tests/internal.clj

   1 (ns redis.tests.internal
   2   (:require [redis.internal :as redis])
   3   (:use [clojure.contrib.test-is])
   4   (:import [java.io StringReader BufferedReader]))
   5
   6
   7
   8
   9
  10
  11
  12 ;;
  13 ;; Helpers
  14 ;;
  15
  16 (defn- wrap-in-reader
  17   [#^String s]
  18   (let [reader (BufferedReader. (StringReader. s))]
  19     reader))
  20
  21 (defn- read-reply
  22   [#^String s]
  23   (redis/read-reply (wrap-in-reader s)))
  24
  25
  26 ;;
  27 ;; Command generation
  28 ;;
  29 (deftest inline-command
  30   (is (= "FOO\r\n"
  31          (redis/inline-command "FOO")))
  32   (is (= "FOO bar\r\n"
  33          (redis/inline-command "FOO" "bar")))
  34   (is (= "FOO bar baz\r\n"
  35          (redis/inline-command "FOO" "bar" "baz"))))
  36
  37 (deftest bulk-command
  38   (is (= "FOO 3\r\nbar\r\n"
  39          (redis/bulk-command "FOO" "bar")))
  40   (is (= "SET foo 3\r\nbar\r\n"
  41          (redis/bulk-command "SET" "foo" "bar")))
  42   (is (= "SET foo bar 3\r\nbaz\r\n"
  43          (redis/bulk-command "SET" "foo" "bar" "baz"))))
  44
  45 (deftest sort-command
  46   (is (= "SORT key\r\n"
  47          (redis/sort-command "SORT" "key")))
  48   (is (= "SORT key BY pattern\r\n"
  49          (redis/sort-command "SORT" "key" :by "pattern")))
  50   (is (= "SORT key LIMIT 0 10\r\n"
  51          (redis/sort-command "SORT" "key" :limit 0 10)))
  52   (is (= "SORT key ASC\r\n"
  53          (redis/sort-command "SORT" "key" :asc)))
  54   (is (= "SORT key DESC\r\n"
  55          (redis/sort-command "SORT" "key" :desc)))
  56   (is (= "SORT key ALPHA\r\n"
  57          (redis/sort-command "SORT" "key" :alpha)))
  58   (is (= "SORT key GET object_* GET object2_*\r\n"
  59          (redis/sort-command "SORT" "key" :get "object_*" :get "object2_*")))
  60   (is (= "SORT key BY weight_* LIMIT 0 10 GET object_* ALPHA DESC\r\n"
  61          (redis/sort-command "SORT" "key"
  62                              :by "weight_*"
  63                              :limit 0 10
  64                              :get "object_*"
  65                              :alpha
  66                              :desc))))
  67
  68
  69 ;;
  70 ;; Reply parsing
  71 ;;
  72 (deftest read-crlf
  73   (is (thrown? Exception
  74                (redis/read-crlf (wrap-in-reader "\n"))))
  75   (is (thrown? Exception
  76                (redis/read-crlf (wrap-in-reader ""))))
  77   (is (thrown? Exception
  78                (redis/read-crlf (wrap-in-reader "\r1"))))
  79   (is (= nil
  80          (redis/read-crlf (wrap-in-reader "\r\n")))))
  81
  82 ;; (deftest read-newline-crlf
  83 ;;   (is (thrown? Exception
  84 ;;                (redis/read-line-crlf (wrap-in-reader "")))))
  85
  86 ;;
  87 ;; Reply parsing
  88 ;;
  89 (deftest reply
  90   (is (thrown? Exception
  91                (read-reply "")))
  92   (is (thrown? Exception
  93                (read-reply "\r\n"))))
  94
  95
  96 (deftest error-reply
  97   (is (thrown?
  98          Exception
  99          (read-reply "-\r\n")))
 100   (is (thrown-with-msg?
 101          Exception #".*Test"
 102          (read-reply "-Test\r\n"))))
 103
 104 (deftest simple-reply
 105   (is (thrown? Exception
 106                (read-reply "+")))
 107   (is (= ""
 108          (read-reply "+\r\n")))
 109   (is (= "foobar"
 110          (read-reply "+foobar\r\n"))))
 111
 112 (deftest integer-reply
 113   (is (thrown? Exception
 114                (read-reply ":\r\n")))
 115   (is (= 0
 116          (read-reply ":0\r\n")))
 117   (is (= 42
 118          (read-reply ":42\r\n")))
 119   (is (= 42
 120          (read-reply ":  42  \r\n")))
 121   (is (= 429348754
 122          (read-reply ":429348754\r\n"))))
 123
 124 (deftest bulk-reply
 125   (is (thrown? Exception
 126                (read-reply "$\r\n")))
 127   (is (thrown? Exception
 128                (read-reply "$2\r\n1\r\n")))
 129   (is (thrown? Exception
 130                (read-reply "$3\r\n1\r\n")))
 131   (is (= nil
 132          (read-reply "$-1\r\n")))
 133   (is (= "foobar"
 134          (read-reply "$6\r\nfoobar\r\n")))
 135   (is (= "foo\r\nbar"
 136          (read-reply "$8\r\nfoo\r\nbar\r\n"))))
 137
 138 (deftest multi-bulk-reply
 139   (is (thrown? Exception
 140                (read-reply "*1\r\n")))
 141   (is (thrown? Exception
 142                (read-reply "*4\r\n:0\r\n:0\r\n:0\r\n")))
 143   (is (= nil
 144          (read-reply "*-1\r\n")))
 145   (is (= [1]
 146          (read-reply "*1\r\n:1\r\n")))
 147   (is (= ["foo" "bar"]
 148          (read-reply "*2\r\n+foo\r\n+bar\r\n")))
 149   (is (= [1 "foo" "foo\r\nbar"]
 150          (read-reply "*3\r\n:1\r\n+foo\r\n$8\r\nfoo\r\nbar\r\n"))))
 151
 152
 153
 154
 155
 156