1
0
mirror of https://github.com/redis/node-redis.git synced 2025-08-06 02:15:48 +03:00

Add support for JSON.MSET (#2605)

* Added MSET command

MSET command added. Requires all keys to have the same JSON Path, which might fit most use cases, but is a limitation.  Optionally we could make the path an array as well to support all use cases.

* change JSON.MSET signature, add to json command object, fix tests

* its `item.value`, not `item.json`..

* Update MSET.ts

Removed unused RedisCommandArguments

---------

Co-authored-by: Leibale Eidelman <me@leibale.com>
This commit is contained in:
Rowan Trollope
2023-09-18 14:39:23 -07:00
committed by GitHub
parent 26b9e6dc78
commit 5a108265da
3 changed files with 66 additions and 0 deletions

View File

@@ -0,0 +1,35 @@
import { strict as assert } from 'assert';
import testUtils, { GLOBAL } from '../test-utils';
import { transformArguments } from './MSET';
describe('MSET', () => {
it('transformArguments', () => {
assert.deepEqual(
transformArguments([{
key: '1',
path: '$',
value: 1
}, {
key: '2',
path: '$',
value: '2'
}]),
['JSON.MSET', '1', '$', '1', '2', '$', '"2"']
);
});
testUtils.testWithClient('client.json.mSet', async client => {
assert.deepEqual(
await client.json.mSet([{
key: '1',
path: '$',
value: 1
}, {
key: '2',
path: '$',
value: '2'
}]),
'OK'
);
}, GLOBAL.SERVERS.OPEN);
});

View File

@@ -0,0 +1,28 @@
import { RedisJSON, transformRedisJsonArgument } from '.';
import { RedisCommandArgument } from '@redis/client/dist/lib/commands';
export const FIRST_KEY_INDEX = 1;
interface JsonMSetItem {
key: RedisCommandArgument;
path: RedisCommandArgument;
value: RedisJSON;
}
export function transformArguments(items: Array<JsonMSetItem>): Array<string> {
const args = new Array(1 + items.length * 3);
args[0] = 'JSON.MSET';
let argsIndex = 1;
for (let i = 0; i < items.length; i++) {
const item = items[i];
args[argsIndex++] = item.key;
args[argsIndex++] = item.path;
args[argsIndex++] = transformRedisJsonArgument(item.value);
}
return args;
}
export declare function transformReply(): 'OK';

View File

@@ -9,6 +9,7 @@ import * as DEL from './DEL';
import * as FORGET from './FORGET'; import * as FORGET from './FORGET';
import * as GET from './GET'; import * as GET from './GET';
import * as MGET from './MGET'; import * as MGET from './MGET';
import * as MSET from './MSET';
import * as NUMINCRBY from './NUMINCRBY'; import * as NUMINCRBY from './NUMINCRBY';
import * as NUMMULTBY from './NUMMULTBY'; import * as NUMMULTBY from './NUMMULTBY';
import * as OBJKEYS from './OBJKEYS'; import * as OBJKEYS from './OBJKEYS';
@@ -42,6 +43,8 @@ export default {
get: GET, get: GET,
MGET, MGET,
mGet: MGET, mGet: MGET,
MSET,
mSet: MSET,
NUMINCRBY, NUMINCRBY,
numIncrBy: NUMINCRBY, numIncrBy: NUMINCRBY,
NUMMULTBY, NUMMULTBY,