Support for the "command" command.

This is a simple addition that allows a client to call any given
Redis command by sending the command name followed by a list of
arguments.

This is useful for the cases where there are new commands in Redis
that have not yet been specifically implemented in phpredis, or
if you want to use phpredis as a pass-through where the commands
and arguments are coming from somewhere else (e.g. monitor logs, etc).

Author: michael-grunder

php_redis.h

@@ -206,6 +206,8 @@ PHP_METHOD(Redis, isConnected);
 PHP_METHOD(Redis, getPersistentID);
 PHP_METHOD(Redis, getAuth);
 
+PHP_METHOD(Redis, command);
+
 #ifdef PHP_WIN32
 #define PHP_REDIS_API __declspec(dllexport)
 #else

redis.c

@@ -270,6 +270,9 @@ static zend_function_entry redis_functions[] = {
      /* slowlog */
      PHP_ME(Redis, slowlog, NULL, ZEND_ACC_PUBLIC)
 
+     /* Send a raw command and read raw results */
+     PHP_ME(Redis, command, NULL, ZEND_ACC_PUBLIC)
+
      /* introspection */
      PHP_ME(Redis, getHost, NULL, ZEND_ACC_PUBLIC)
      PHP_ME(Redis, getPort, NULL, ZEND_ACC_PUBLIC)
@@ -6100,6 +6103,49 @@ PHP_METHOD(Redis, slowlog) {
     REDIS_PROCESS_RESPONSE(redis_read_variant_reply);
 }
 
+/* {{{ proto Redis::command(string cmd, arg, arg, arg, ...) }}} */
+PHP_METHOD(Redis, command) {
+    zval **z_args;
+    RedisSock *redis_sock;
+    int argc = ZEND_NUM_ARGS(), i;
+    smart_str cmd = {0};
+
+    /* We need at least one argument */
+    z_args = emalloc(argc * sizeof(zval*));
+    if (argc < 1 || zend_get_parameters_array(ht, argc, z_args) == FAILURE) {
+        efree(z_args);
+        RETURN_FALSE;
+    }
+
+    if (redis_sock_get(getThis(), &redis_sock TSRMLS_CC, 0) < 0) {
+        efree(z_args);
+        RETURN_FALSE;
+    }
+
+    /* Initialize the command we'll send */
+    convert_to_string(z_args[0]);
+    redis_cmd_init_sstr(&cmd,argc-1,Z_STRVAL_P(z_args[0]),Z_STRLEN_P(z_args[0]));
+
+    /* Iterate over the remainder of our arguments, appending */
+    for (i = 1; i < argc; i++) {
+        convert_to_string(z_args[i]);
+        redis_cmd_append_sstr(&cmd, Z_STRVAL_P(z_args[i]), Z_STRLEN_P(z_args[i])); 
+    }
+
+    efree(z_args);
+
+    /* Kick off our request and read response or enqueue handler */
+    REDIS_PROCESS_REQUEST(redis_sock, cmd.c, cmd.len);
+    IF_ATOMIC() {
+        if (redis_read_variant_reply(INTERNAL_FUNCTION_PARAM_PASSTHRU, 
+                                     redis_sock, NULL) < 0)
+        {
+            RETURN_FALSE;
+        }
+    }
+    REDIS_PROCESS_RESPONSE(redis_read_variant_reply);
+}
+
 /* {{{ proto Redis::wait(int num_slaves, int ms) }}}
  */
 PHP_METHOD(Redis, wait) {