#include "php_redis.h"

#ifdef HAVE_CONFIG_H

#include "config.h"

#endif

#include "common.h"

#include "php_network.h"

#include <sys/types.h>

#ifdef HAVE_REDIS_IGBINARY

#include "igbinary/igbinary.h"

#endif

#ifdef HAVE_REDIS_MSGPACK

#include "msgpack/php_msgpack.h"

#endif

#ifdef HAVE_REDIS_LZF

#include <lzf.h>

#ifndef LZF_MARGIN

#define LZF_MARGIN 128

#endif

#endif

#ifdef HAVE_REDIS_ZSTD

#include <zstd.h>

#endif

#ifdef HAVE_REDIS_LZ4

#include <lz4.h>

#include <lz4hc.h>

/* uint8_t crf + int length */

#define REDIS_LZ4_HDR_SIZE (sizeof(uint8_t) + sizeof(int))

#if defined(LZ4HC_CLEVEL_MAX)

/* version >= 1.7.5 */

#define REDIS_LZ4_MAX_CLEVEL LZ4HC_CLEVEL_MAX

#elif defined (LZ4HC_MAX_CLEVEL)

/* version >= 1.7.3 */

#define REDIS_LZ4_MAX_CLEVEL LZ4HC_MAX_CLEVEL

#else

/* older versions */

#define REDIS_LZ4_MAX_CLEVEL 12

#endif

#endif

#include <zend_exceptions.h>

#include "php_redis.h"

#include "library.h"

#include "redis_commands.h"

#ifdef HAVE_REDIS_JSON

#include <ext/json/php_json.h>

#endif

#include <ext/standard/php_rand.h>

#include <ext/hash/php_hash.h>

#define UNSERIALIZE_NONE 0

#define UNSERIALIZE_KEYS 1

#define UNSERIALIZE_VALS 2

#define UNSERIALIZE_ALL 3

#define SCORE_DECODE_NONE 0

#define SCORE_DECODE_INT 1

#define SCORE_DECODE_DOUBLE 2

/* PhpRedis often returns either FALSE or NULL depending on whether we have

* an option set, so this macro just wraps that often repeated logic */

#define REDIS_ZVAL_NULL(sock_, zv_) \

do { \

if ((sock_)->null_mbulk_as_null) { \

ZVAL_NULL((zv_)); \

} else { \

ZVAL_FALSE((zv_)); \

} \

} while (0)

#ifndef PHP_WIN32

#include <netinet/tcp.h> /* TCP_NODELAY */

#include <sys/socket.h> /* SO_KEEPALIVE */

#else

#include <winsock.h>

#endif

extern zend_class_entry *redis_ce;

extern zend_class_entry *redis_exception_ce;

extern int le_redis_pconnect;

static int redis_mbulk_reply_zipped_raw_variant(RedisSock *redis_sock, zval *zret, int count);

/* Register a persistent resource in a a way that works for every PHP 7 version. */

void redis_register_persistent_resource(zend_string *id, void *ptr, int le_id) {

#if PHP_VERSION_ID < 70300

zend_resource res;

res.type = le_id;

res.ptr = ptr;

zend_hash_str_update_mem(&EG(persistent_list), ZSTR_VAL(id), ZSTR_LEN(id), &res, sizeof(res));

#else

zend_register_persistent_resource(ZSTR_VAL(id), ZSTR_LEN(id), ptr, le_id);

#endif

}

static ConnectionPool *

redis_sock_get_connection_pool(RedisSock *redis_sock)

{

ConnectionPool *pool;

zend_resource *le;

zend_string *persistent_id;

/* Generate our unique pool id depending on configuration */

persistent_id = redis_pool_spprintf(redis_sock, INI_STR("redis.pconnect.pool_pattern"));

/* Return early if we can find the pool */

if ((le = zend_hash_find_ptr(&EG(persistent_list), persistent_id))) {

zend_string_release(persistent_id);

return le->ptr;

}

/* Create the pool and store it in our persistent list */

pool = pecalloc(1, sizeof(*pool), 1);

zend_llist_init(&pool->list, sizeof(php_stream *), NULL, 1);

redis_register_persistent_resource(persistent_id, pool, le_redis_pconnect);

zend_string_release(persistent_id);

return pool;

}

/* Helper to reselect the proper DB number when we reconnect */

static int reselect_db(RedisSock *redis_sock) {

char *cmd, *response;

int cmd_len, response_len;

cmd_len = redis_spprintf(redis_sock, NULL, &cmd, "SELECT", "d",

redis_sock->dbNumber);

if (redis_sock_write(redis_sock, cmd, cmd_len) < 0) {

efree(cmd);

return -1;

}

efree(cmd);

if ((response = redis_sock_read(redis_sock, &response_len)) == NULL) {

return -1;

}

if (strncmp(response, "+OK", 3)) {

efree(response);

return -1;

}

efree(response);

return 0;

}

/* Append an AUTH command to a smart string if neccessary. This will either

* append the new style AUTH <user> <password>, old style AUTH <password>, or

* append no command at all. Function returns 1 if we appended a command

* and 0 otherwise. */

static int redis_sock_append_auth(RedisSock *redis_sock, smart_string *str) {

/* We need a password at least */

if (redis_sock->pass == NULL)

return 0;

REDIS_CMD_INIT_SSTR_STATIC(str, !!redis_sock->user + !!redis_sock->pass, "AUTH");

if (redis_sock->user)

redis_cmd_append_sstr_zstr(str, redis_sock->user);

redis_cmd_append_sstr_zstr(str, redis_sock->pass);

/* We appended a command */

return 1;

}

PHP_REDIS_API void

redis_sock_set_auth(RedisSock *redis_sock, zend_string *user, zend_string *pass)

{

/* Release existing user/pass */

redis_sock_free_auth(redis_sock);

/* Set new user/pass */

redis_sock->user = user ? zend_string_copy(user) : NULL;

redis_sock->pass = pass ? zend_string_copy(pass) : NULL;

}

PHP_REDIS_API void

redis_sock_set_auth_zval(RedisSock *redis_sock, zval *zv) {

zend_string *user, *pass;

if (redis_extract_auth_info(zv, &user, &pass) == FAILURE)

return;

redis_sock_set_auth(redis_sock, user, pass);

if (user) zend_string_release(user);

if (pass) zend_string_release(pass);

}

PHP_REDIS_API void

redis_sock_free_auth(RedisSock *redis_sock) {

if (redis_sock->user) {

zend_string_release(redis_sock->user);

redis_sock->user = NULL;

}

if (redis_sock->pass) {

zend_string_release(redis_sock->pass);

redis_sock->pass = NULL;

}

}

PHP_REDIS_API char *

redis_sock_auth_cmd(RedisSock *redis_sock, int *cmdlen) {

char *cmd;

/* AUTH requires at least a password */

if (redis_sock->pass == NULL)

return NULL;

if (redis_sock->user) {

*cmdlen = redis_spprintf(redis_sock, NULL, &cmd, "AUTH", "SS", redis_sock->user, redis_sock->pass);

} else {

*cmdlen = redis_spprintf(redis_sock, NULL, &cmd, "AUTH", "S", redis_sock->pass);

}

return cmd;

}

/* Send Redis AUTH and process response */

PHP_REDIS_API int redis_sock_auth(RedisSock *redis_sock) {

char *cmd, inbuf[4096];

int cmdlen;

size_t len;

if ((cmd = redis_sock_auth_cmd(redis_sock, &cmdlen)) == NULL)

return SUCCESS;

if (redis_sock_write(redis_sock, cmd, cmdlen) < 0) {

efree(cmd);

return FAILURE;

}

efree(cmd);

if (redis_sock_gets(redis_sock, inbuf, sizeof(inbuf) - 1, &len) < 0 || strncmp(inbuf, "+OK", 3)) {

return FAILURE;

}

return SUCCESS;

}

/* Helper function and macro to test a RedisSock error prefix. */

#define REDIS_SOCK_ERRCMP_STATIC(rs, s) redis_sock_errcmp(rs, s, sizeof(s)-1)

static int redis_sock_errcmp(RedisSock *redis_sock, const char *err, size_t errlen) {

return ZSTR_LEN(redis_sock->err) >= errlen &&

memcmp(ZSTR_VAL(redis_sock->err), err, errlen) == 0;

}

/* Helper function that will throw an exception for a small number of ERR codes

* returned by Redis. Typically we just return FALSE to the caller in the event

* of an ERROR reply, but for the following error types:

* 1) MASTERDOWN

* 2) AUTH

* 3) LOADING

*/

static void

redis_error_throw(RedisSock *redis_sock)

{

/* Short circuit if we have no redis_sock or any error */

if (redis_sock == NULL || redis_sock->err == NULL)

return;

/* Redis 6 decided to add 'ERR AUTH' which has a normal 'ERR' prefix

* but is actually an authentication error that we will want to throw

* an exception for, so just short circuit if this is any other 'ERR'

* prefixed error. */

if (REDIS_SOCK_ERRCMP_STATIC(redis_sock, "ERR") &&

!REDIS_SOCK_ERRCMP_STATIC(redis_sock, "ERR AUTH")) return;

/* We may want to flip this logic and check for MASTERDOWN, AUTH,

* and LOADING but that may have side effects (esp for things like

* Disque) */

if (!REDIS_SOCK_ERRCMP_STATIC(redis_sock, "NOSCRIPT") &&

!REDIS_SOCK_ERRCMP_STATIC(redis_sock, "NOQUORUM") &&

!REDIS_SOCK_ERRCMP_STATIC(redis_sock, "NOGOODSLAVE") &&

!REDIS_SOCK_ERRCMP_STATIC(redis_sock, "WRONGTYPE") &&

!REDIS_SOCK_ERRCMP_STATIC(redis_sock, "BUSYGROUP") &&

!REDIS_SOCK_ERRCMP_STATIC(redis_sock, "NOGROUP"))

{

REDIS_THROW_EXCEPTION(ZSTR_VAL(redis_sock->err), 0);

}

}

static int

read_mbulk_header(RedisSock *redis_sock, int *nelem)

{

char line[4096];

size_t len;

/* Throws exception on failure */

if (redis_sock_gets(redis_sock, line, sizeof(line) - 1, &len) < 0) {

return FAILURE;

}

if (*line != TYPE_MULTIBULK) {

if (*line == TYPE_ERR) {

redis_sock_set_err(redis_sock, line + 1, len - 1);

}

return FAILURE;

}

*nelem = atoi(line + 1);

return SUCCESS;

}

PHP_REDIS_API int

redis_check_eof(RedisSock *redis_sock, zend_bool no_retry, zend_bool no_throw)

{

unsigned int retry_index;

char *errmsg;

if (!redis_sock || !redis_sock->stream || redis_sock->status == REDIS_SOCK_STATUS_FAILED) {

if (!no_throw) {

REDIS_THROW_EXCEPTION( "Connection closed", 0);

}

return -1;

}

/* NOITCE: set errno = 0 here

*

* There is a bug in php socket stream to check liveness of a connection:

* if (0 >= recv(sock->socket, &buf, sizeof(buf), MSG_PEEK) && php_socket_errno() != EWOULDBLOCK) {

* alive = 0;

* }

* If last errno is EWOULDBLOCK and recv returns 0 because of connection closed, alive would not be

* set to 0. However, the connection is close indeed. The php_stream_eof is not reliable. This will

* cause a "read error on connection" exception when use a closed persistent connection.

*

* We work around this by set errno = 0 first.

*

* Bug fix of php: https://github.com/php/php-src/pull/1456

* */

errno = 0;

if (php_stream_eof(redis_sock->stream) == 0) {

/* Success */

return 0;

} else if (redis_sock->mode == MULTI || redis_sock->watching) {

errmsg = "Connection lost and socket is in MULTI/watching mode";

} else {

errmsg = "Connection lost";

redis_backoff_reset(&redis_sock->backoff);

for (retry_index = 0; !no_retry && retry_index < redis_sock->max_retries; ++retry_index) {

/* close existing stream before reconnecting */

if (redis_sock->stream) {

redis_sock_disconnect(redis_sock, 1);

}

/* Sleep based on our backoff algorithm */

zend_ulong delay = redis_backoff_compute(&redis_sock->backoff, retry_index);

if (delay != 0)

usleep(delay);

/* reconnect */

if (redis_sock_connect(redis_sock) == 0) {

/* check for EOF again. */

errno = 0;

if (php_stream_eof(redis_sock->stream) == 0) {

if (redis_sock_auth(redis_sock) != SUCCESS) {

errmsg = "AUTH failed while reconnecting";

break;

}

redis_sock->status = REDIS_SOCK_STATUS_AUTHENTICATED;

/* If we're using a non-zero db, reselect it */

if (redis_sock->dbNumber && reselect_db(redis_sock) != 0) {

errmsg = "SELECT failed while reconnecting";

break;

}

redis_sock->status = REDIS_SOCK_STATUS_READY;

/* Success */

return 0;

}

}

}

}

/* close stream and mark socket as failed */

redis_sock_disconnect(redis_sock, 1);

redis_sock->status = REDIS_SOCK_STATUS_FAILED;

if (!no_throw) {

REDIS_THROW_EXCEPTION( errmsg, 0);

}

return -1;

}

PHP_REDIS_API int

redis_sock_read_scan_reply(INTERNAL_FUNCTION_PARAMETERS, RedisSock *redis_sock,

REDIS_SCAN_TYPE type, zend_long *iter)

{

REDIS_REPLY_TYPE reply_type;

long reply_info;

char err[4096], *p_iter;

size_t errlen;

/* Our response should have two multibulk replies */

if(redis_read_reply_type(redis_sock, &reply_type, &reply_info)<0

|| reply_type != TYPE_MULTIBULK || reply_info != 2)

{

if (reply_type == TYPE_ERR) {

if (redis_sock_gets(redis_sock, err, sizeof(err), &errlen) == 0) {

redis_sock_set_err(redis_sock, err, errlen);

}

}

return -1;

}

/* The BULK response iterator */

if(redis_read_reply_type(redis_sock, &reply_type, &reply_info)<0

|| reply_type != TYPE_BULK)

{

return -1;

}

/* Attempt to read the iterator */

if(!(p_iter = redis_sock_read_bulk_reply(redis_sock, reply_info))) {

return -1;

}

/* Push the iterator out to the caller */

*iter = atol(p_iter);

efree(p_iter);

/* Read our actual keys/members/etc differently depending on what kind of

scan command this is. They all come back in slightly different ways */

switch(type) {

case TYPE_SCAN:

return redis_mbulk_reply_raw(INTERNAL_FUNCTION_PARAM_PASSTHRU,

redis_sock, NULL, NULL);

case TYPE_SSCAN:

return redis_sock_read_multibulk_reply(

INTERNAL_FUNCTION_PARAM_PASSTHRU, redis_sock, NULL, NULL);

case TYPE_ZSCAN:

return redis_mbulk_reply_zipped_keys_dbl(INTERNAL_FUNCTION_PARAM_PASSTHRU,

redis_sock, NULL, NULL);

case TYPE_HSCAN:

return redis_mbulk_reply_zipped_vals(INTERNAL_FUNCTION_PARAM_PASSTHRU,

redis_sock, NULL, NULL);

default:

return -1;

}

}

PHP_REDIS_API int

redis_pubsub_response(INTERNAL_FUNCTION_PARAMETERS,

RedisSock *redis_sock, zval *z_tab, void *ctx)

{

if (ctx == NULL) {

return redis_long_response(INTERNAL_FUNCTION_PARAM_PASSTHRU, redis_sock, z_tab, NULL);

} else if (ctx == PHPREDIS_CTX_PTR) {

return redis_read_variant_reply(INTERNAL_FUNCTION_PARAM_PASSTHRU, redis_sock, z_tab, NULL);

} else if (ctx == PHPREDIS_CTX_PTR + 1) {

return redis_mbulk_reply_zipped_keys_int(INTERNAL_FUNCTION_PARAM_PASSTHRU, redis_sock, z_tab, NULL);

} else {

ZEND_ASSERT(!"memory corruption?");

return FAILURE;

}

}

static void

ht_free_subs(zval *data)

{

efree(Z_PTR_P(data));

}

PHP_REDIS_API int redis_subscribe_response(INTERNAL_FUNCTION_PARAMETERS,

RedisSock *redis_sock, zval *z_tab,

void *ctx)

{

HashTable *subs;

subscribeCallback *cb;

subscribeContext *sctx = (subscribeContext*)ctx;

zval *z_tmp, z_resp;

int i;

ALLOC_HASHTABLE(subs);

zend_hash_init(subs, 0, NULL, ht_free_subs, 0);

// Consume response(s) from subscribe, which will vary on argc

while(sctx->argc--) {

ZVAL_NULL(&z_resp);

if (!redis_sock_read_multibulk_reply_zval(redis_sock, &z_resp)) {

goto error;

}

// We'll need to find the command response

if ((z_tmp = zend_hash_index_find(Z_ARRVAL(z_resp), 0)) == NULL) {

goto error;

}

// Make sure the command response matches the command we called

if(strcasecmp(Z_STRVAL_P(z_tmp), sctx->kw) !=0) {

goto error;

}

if ((z_tmp = zend_hash_index_find(Z_ARRVAL(z_resp), 1)) == NULL) {

goto error;

}

zend_hash_str_update_mem(subs, Z_STRVAL_P(z_tmp), Z_STRLEN_P(z_tmp),

&sctx->cb, sizeof(sctx->cb));

zval_dtor(&z_resp);

}

if (strcasecmp(sctx->kw, "ssubscribe") == 0) {

i = REDIS_SSUBSCRIBE_IDX;

} else if (strcasecmp(sctx->kw, "psubscribe") == 0) {

i = REDIS_PSUBSCRIBE_IDX;

} else {

i = REDIS_SUBSCRIBE_IDX;

}

efree(sctx);

if (redis_sock->subs[i]) {

zend_string *zkey;

ZEND_HASH_FOREACH_STR_KEY_PTR(subs, zkey, cb) {

zend_hash_update_mem(redis_sock->subs[i], zkey, cb, sizeof(*cb));

} ZEND_HASH_FOREACH_END();

zend_hash_destroy(subs);

efree(subs);

RETVAL_TRUE;

return SUCCESS;

}

redis_sock->subs[i] = subs;

/* Multibulk response, {[pattern], type, channel, payload } */

while (redis_sock->subs[i]) {

zval z_ret, z_args[4], *z_type, *z_chan, *z_pat = NULL, *z_data;

HashTable *ht_tab;

int tab_idx = 1, is_pmsg = 0;

ZVAL_NULL(&z_resp);

if (!redis_sock_read_multibulk_reply_zval(redis_sock, &z_resp)) {

goto failure;

}

ht_tab = Z_ARRVAL(z_resp);

if ((z_type = zend_hash_index_find(ht_tab, 0)) == NULL ||

Z_TYPE_P(z_type) != IS_STRING

) {

goto failure;

}

// Check for message or pmessage

if (zend_string_equals_literal_ci(Z_STR_P(z_type), "message") ||

zend_string_equals_literal_ci(Z_STR_P(z_type), "pmessage") ||

zend_string_equals_literal_ci(Z_STR_P(z_type), "smessage")

) {

is_pmsg = *Z_STRVAL_P(z_type)=='p';

} else {

zval_dtor(&z_resp);

continue;

}

// Extract pattern if it's a pmessage

if(is_pmsg) {

if ((z_pat = zend_hash_index_find(ht_tab, tab_idx++)) == NULL) {

goto failure;

}

}

// Extract channel and data

if ((z_chan = zend_hash_index_find(ht_tab, tab_idx++)) == NULL ||

(z_data = zend_hash_index_find(ht_tab, tab_idx++)) == NULL

) {

goto failure;

}

if ((cb = zend_hash_str_find_ptr(redis_sock->subs[i], Z_STRVAL_P(z_chan), Z_STRLEN_P(z_chan))) == NULL) {

goto failure;

}

// Different args for SUBSCRIBE and PSUBSCRIBE

z_args[0] = *getThis();

if(is_pmsg) {

z_args[1] = *z_pat;

z_args[2] = *z_chan;

z_args[3] = *z_data;

} else {

z_args[1] = *z_chan;

z_args[2] = *z_data;

}

// Set arg count

cb->fci.param_count = tab_idx;

cb->fci.retval = &z_ret;

cb->fci.params = z_args;

// Execute callback

if (zend_call_function(&cb->fci, &cb->fci_cache) != SUCCESS) {

goto failure;

}

// If we have a return value free it

zval_ptr_dtor(&z_ret);

zval_dtor(&z_resp);

}

RETVAL_TRUE;

return SUCCESS;

// This is an error state, clean up

error:

efree(sctx);

zend_hash_destroy(subs);

efree(subs);

failure:

zval_dtor(&z_resp);

RETVAL_FALSE;

return FAILURE;

}

PHP_REDIS_API int redis_unsubscribe_response(INTERNAL_FUNCTION_PARAMETERS,

RedisSock *redis_sock, zval *z_tab,

void *ctx)

{

subscribeContext *sctx = (subscribeContext*)ctx;

zval *z_chan, z_ret, z_resp;

int i;

if (strcasecmp(sctx->kw, "sunsubscribe") == 0) {

i = REDIS_SSUBSCRIBE_IDX;

} else if (strcasecmp(sctx->kw, "punsubscribe") == 0) {

i = REDIS_PSUBSCRIBE_IDX;

} else {

i = REDIS_SUBSCRIBE_IDX;

}

if (!sctx->argc && redis_sock->subs[i]) {

sctx->argc = zend_hash_num_elements(redis_sock->subs[i]);

}

array_init(&z_ret);

while (sctx->argc--) {

ZVAL_NULL(&z_resp);

if (!redis_sock_read_multibulk_reply_zval(redis_sock, &z_resp) ||

(z_chan = zend_hash_index_find(Z_ARRVAL(z_resp), 1)) == NULL

) {

efree(sctx);

zval_dtor(&z_resp);

zval_dtor(&z_ret);

RETVAL_FALSE;

return FAILURE;

}

if (!redis_sock->subs[i] ||

!zend_hash_str_exists(redis_sock->subs[i], Z_STRVAL_P(z_chan), Z_STRLEN_P(z_chan))

) {

add_assoc_bool_ex(&z_ret, Z_STRVAL_P(z_chan), Z_STRLEN_P(z_chan), 0);

} else {

zend_hash_str_del(redis_sock->subs[i], Z_STRVAL_P(z_chan), Z_STRLEN_P(z_chan));

add_assoc_bool_ex(&z_ret, Z_STRVAL_P(z_chan), Z_STRLEN_P(z_chan), 1);

}

zval_dtor(&z_resp);

}

efree(sctx);

if (redis_sock->subs[i] && !zend_hash_num_elements(redis_sock->subs[i])) {

zend_hash_destroy(redis_sock->subs[i]);

efree(redis_sock->subs[i]);

redis_sock->subs[i] = NULL;

}

RETVAL_ZVAL(&z_ret, 0, 1);

return SUCCESS;

}

PHP_REDIS_API zval *

redis_sock_read_multibulk_reply_zval(RedisSock *redis_sock, zval *z_tab)

{

int numElems;

if (read_mbulk_header(redis_sock, &numElems) < 0) {

ZVAL_NULL(z_tab);

return NULL;

}

array_init(z_tab);

redis_mbulk_reply_loop(redis_sock, z_tab, numElems, UNSERIALIZE_ALL);

return z_tab;

}

/**

* redis_sock_read_bulk_reply

*/

PHP_REDIS_API char *

redis_sock_read_bulk_reply(RedisSock *redis_sock, int bytes)

{

int offset = 0, nbytes;

char *reply;

ssize_t got;

if (-1 == bytes || -1 == redis_check_eof(redis_sock, 1, 0)) {

return NULL;

}

/* + 2 for \r\n */

nbytes = bytes + 2;

/* Allocate memory for string */

reply = emalloc(nbytes);

/* Consume bulk string */

while (offset < nbytes) {

got = redis_sock_read_raw(redis_sock, reply + offset, nbytes - offset);

if (got < 0 || (got == 0 && php_stream_eof(redis_sock->stream)))

break;

offset += got;

}

/* Protect against reading too few bytes */

if (offset < nbytes) {

/* Error or EOF */

REDIS_THROW_EXCEPTION("socket error on read socket", 0);

efree(reply);

return NULL;

}

/* Null terminate reply string */

reply[bytes] = '\0';

return reply;

}

/**

* redis_sock_read

*/

PHP_REDIS_API char *

redis_sock_read(RedisSock *redis_sock, int *buf_len)

{

char inbuf[4096];

size_t len;

*buf_len = 0;

if (redis_sock_gets(redis_sock, inbuf, sizeof(inbuf) - 1, &len) < 0) {

return NULL;

}

switch(inbuf[0]) {

case '-':

redis_sock_set_err(redis_sock, inbuf+1, len);

/* Filter our ERROR through the few that should actually throw */

redis_error_throw(redis_sock);

return NULL;

case '$':

*buf_len = atoi(inbuf + 1);

return redis_sock_read_bulk_reply(redis_sock, *buf_len);

case '*':

/* For null multi-bulk replies (like timeouts from brpoplpush): */

if(memcmp(inbuf + 1, "-1", 2) == 0) {

return NULL;

}

REDIS_FALLTHROUGH;

case '+':

case ':':

/* Single Line Reply */

/* +OK or :123 */

if (len > 1) {

*buf_len = len;

return estrndup(inbuf, *buf_len);

}

REDIS_FALLTHROUGH;

default:

zend_throw_exception_ex(redis_exception_ce, 0,

"protocol error, got '%c' as reply type byte\n",

inbuf[0]

);

}

return NULL;

}

/* A simple union to store the various arg types we might handle in our

* redis_spprintf command formatting function */

union resparg {

char *str;

zend_string *zstr;

zval *zv;

int ival;

long lval;

double dval;

};

static zend_string *redis_hash_auth(zend_string *user, zend_string *pass) {

zend_string *algo, *hex;

smart_str salted = {0};

const php_hash_ops *ops;

unsigned char *digest;

void *ctx;

/* No op if there is not username/password */

if (user == NULL && pass == NULL)

return NULL;

/* Theoretically inpossible but check anyway */

algo = zend_string_init("sha256", sizeof("sha256") - 1, 0);

if ((ops = redis_hash_fetch_ops(algo)) == NULL) {

zend_string_release(algo);

return NULL;

}

/* Hash username + password with our salt global */

smart_str_alloc(&salted, 256, 0);

if (user) smart_str_append_ex(&salted, user, 0);

if (pass) smart_str_append_ex(&salted, pass, 0);

smart_str_appendl_ex(&salted, REDIS_G(salt), sizeof(REDIS_G(salt)), 0);

ctx = emalloc(ops->context_size);

#if PHP_VERSION_ID >= 80100

ops->hash_init(ctx,NULL);

#else

ops->hash_init(ctx);

#endif

ops->hash_update(ctx, (const unsigned char *)ZSTR_VAL(salted.s), ZSTR_LEN(salted.s));

digest = emalloc(ops->digest_size);

ops->hash_final(digest, ctx);

efree(ctx);

hex = zend_string_safe_alloc(ops->digest_size, 2, 0, 0);

php_hash_bin2hex(ZSTR_VAL(hex), digest, ops->digest_size);

ZSTR_VAL(hex)[2 * ops->digest_size] = 0;

efree(digest);

zend_string_release(algo);

smart_str_free(&salted);

return hex;

}

static void append_auth_hash(smart_str *dst, zend_string *user, zend_string *pass) {

zend_string *s;

if ((s = redis_hash_auth(user, pass)) != NULL) {

smart_str_appendc(dst, ':');

smart_str_append_ex(dst, s, 0);

zend_string_release(s);

}

}

/* A printf like function to generate our connection pool hash value. */

PHP_REDIS_API zend_string *

redis_pool_spprintf(RedisSock *redis_sock, char *fmt, ...) {

smart_str str = {0};

smart_str_alloc(&str, 128, 0);

/* We always include phpredis_<host>:<port> */

smart_str_appendl(&str, "phpredis_", sizeof("phpredis_") - 1);

smart_str_append_ex(&str, redis_sock->host, 0);

smart_str_appendc(&str, ':');

smart_str_append_long(&str, (zend_long)redis_sock->port);

/* Short circuit if we don't have a pattern */

if (fmt == NULL) {

smart_str_0(&str);

return str.s;

}

while (*fmt) {

switch (*fmt) {

case 'i':

if (redis_sock->persistent_id) {

smart_str_appendc(&str, ':');

smart_str_append_ex(&str, redis_sock->persistent_id, 0);

}

break;

case 'u':

smart_str_appendc(&str, ':');

if (redis_sock->user) {

smart_str_append_ex(&str, redis_sock->user, 0);

}

break;

case 'p':

append_auth_hash(&str, NULL, redis_sock->pass);

break;

case 'a':

append_auth_hash(&str, redis_sock->user, redis_sock->pass);

break;

default:

/* Maybe issue a php_error_docref? */

break;

}

fmt++;

}

smart_str_0(&str);

return str.s;

}

/* A printf like method to construct a Redis RESP command. It has been extended

* to take a few different format specifiers that are convenient to phpredis.

*

* s - C string followed by length as a

* S - Pointer to a zend_string

* k - Same as 's' but the value will be prefixed if phpredis is set up do do

* that and the working slot will be set if it has been passed.

* v - A z_val which will be serialized if phpredis is configured to serialize.

* f - A double value

* F - Alias to 'f'

* i - An integer

* d - Alias to 'i'

* l - A long

* L - Alias to 'l'

*/

PHP_REDIS_API int

redis_spprintf(RedisSock *redis_sock, short *slot, char **ret, char *kw, char *fmt, ...) {

smart_string cmd = {0};

va_list ap;

union resparg arg;

char *dup;

int argfree;

size_t arglen;

va_start(ap, fmt);

/* Header */

redis_cmd_init_sstr(&cmd, strlen(fmt), kw, strlen(kw));

while (*fmt) {

switch (*fmt) {

case 's':

arg.str = va_arg(ap, char*);

arglen = va_arg(ap, size_t);

redis_cmd_append_sstr(&cmd, arg.str, arglen);

break;

case 'S':

arg.zstr = va_arg(ap, zend_string*);

redis_cmd_append_sstr(&cmd, ZSTR_VAL(arg.zstr), ZSTR_LEN(arg.zstr));

break;

case 'k':

arg.str = va_arg(ap, char*);

arglen = va_arg(ap, size_t);

argfree = redis_key_prefix(redis_sock, &arg.str, &arglen);

redis_cmd_append_sstr(&cmd, arg.str, arglen);

if (slot) *slot = cluster_hash_key(arg.str, arglen);

if (argfree) efree(arg.str);

break;

case 'v':

arg.zv = va_arg(ap, zval*);

argfree = redis_pack(redis_sock, arg.zv, &dup, &arglen);

redis_cmd_append_sstr(&cmd, dup, arglen);

if (argfree) efree(dup);

break;

case 'f':

case 'F':

arg.dval = va_arg(ap, double);

redis_cmd_append_sstr_dbl(&cmd, arg.dval);

break;

case 'i':

case 'd':

arg.ival = va_arg(ap, int);

redis_cmd_append_sstr_int(&cmd, arg.ival);

break;

case 'l':

case 'L':

arg.lval = va_arg(ap, long);

redis_cmd_append_sstr_long(&cmd, arg.lval);

break;

}

fmt++;

}

/* varargs cleanup */

va_end(ap);

/* Null terminate */

smart_string_0(&cmd);

/* Push command string, return length */

*ret = cmd.c;

return cmd.len;

}