Callback for xadd

[mikeslim7]

Hello,

Is there a way to have a callback for xadd something like:

redisClient.xadd(streamName, '*',....,function(err,resp){
console.log(resp);
});

I tried and had errors.

Thanks!
Mike

[stockholmux]

@mikeslim7 this exists. Can you please post real code (instead ....) as I think it might just be an small error.

[protectedvar]

I have an error than call

redisClient.xadd('mystream', '*', 'field1', 'm1', function (err) {
});

{ ReplyError: ERR unknown command `xadd`, with args beginning with: `mystream`, `*`, `field1`, `m1`, 
    at parseError (/home/work/node_modules/redis-parser/lib/parser.js:193:12)
    at parseType (/home/work/node_modules/redis-parser/lib/parser.js:303:14)
  command: 'XADD',
  args: [ 'mystream', '*', 'field1', 'm1' ],
  code: 'ERR' }

[stockholmux]

@protectedvar You have a version of Redis that doesn't support streams (unrelated to this issue).

[gcobcqwe]

@stockholmux Does v2.8.0 support xadd callback?

[stockholmux]

@gcobcqwe Yes.

[hbel]

I have the same problem with the latest version node_redis (2.8.0?). I also tried to directly use the master branch, with throws the same error.

The following code does not run.

const rdb = redis.createClient("redis://localhost:6379");
const send = promisify(rdb.sendCommand).bind(rdb);
const n = {forename: "foo", lastname: "bar"};
send(`XADD nameStream * ${JSON.stringify(n)}`).catch(e => console.error(e));

ReplyError: ERR unknown command xadd namestream * {"forename":"foo","lastname":"bar"}, with args beginning with:
at parseError (/Users/hendrik/git/ownprojects/databroker/node_modules/redis-parser/lib/parser.js:193:12)
at parseType (/Users/hendrik/git/ownprojects/databroker/node_modules/redis-parser/lib/parser.js:303:14) {
command: 'XADD NAMESTREAM * {"FORENAME":"FOO","LASTNAME":"BAR"}',
code: 'ERR'
}

[gcobcqwe]

Hey, @hbel. I think your format is incorrect.
XADD mystream * field1 value1 field2 value2 field3 value3
https://redis.io/commands/xadd

[BridgeAR]

The error posted here indicates the error came directly from the Redis server, not from the client. Thus, I am closing this issue.

[dannoshepard]

For anyone who might be reading this and saying wtf...

The first argument to the send command functions need to be the command by its self. In the case of @hbel the Redis server literally thought the command was xadd namestream * {"forename":"foo","lastname":"bar"}.. instead he should have wrote send( "XADD", [nameStream "*", JSON.stringify(n)] ).catch(e => console.error(e));