diff --git a/lib/backend.js b/lib/backend.js index bd5eee0..3763c03 100755 --- a/lib/backend.js +++ b/lib/backend.js @@ -145,7 +145,7 @@ var str2int = function (string) { }; var pattern = function (string) { - string = string.replace(/[+{($^|.\\]/g, '\\' + '$0'); + string = string.replace(/([+{($^|.\\])/g, '\\' + '$1'); string = string.replace(/(^|[^\\])([*?])/g, '$1.$2'); string = '^' + string + '$'; diff --git a/test.js b/test.js index ada5c8d..2eab1bb 100755 --- a/test.js +++ b/test.js @@ -457,7 +457,7 @@ process.stdout.write('testing fakeredis ...\n\n'); sub3 = fake.createClient("pubsub-1"), data = [ 0, [], [], [] ], - tcb1 = test("PUBSUB basics", null, [ 4, [ 'mych-alpha', 'mych-beta', 'mych-omega' ], [ 'mych-alpha', 'mych-beta' ], [ 'mych-alpha', 'mych-beta', 'what-what', 'mych-omega' ] ]), + tcb1 = test("PUBSUB basics", null, [ 4, [ 'my.ch-alpha', 'my.ch-beta', 'my.ch-omega' ], [ 'my.ch-alpha', 'my.ch-beta' ], [ 'my.ch-alpha', 'my.ch-beta', 'what-what', 'my.ch-omega' ] ]), ord = [], tcb2 = test("PUBSUB normal / sequence", null, [ 1, '*ch', 'pun', 1 ]), @@ -469,9 +469,9 @@ process.stdout.write('testing fakeredis ...\n\n'); ord.push(data); }); - sub1.SUBSCRIBE("mych"); + sub1.SUBSCRIBE("my.ch"); sub2.PSUBSCRIBE("*ch"); - sub3.PSUBSCRIBE("my*", "what"); + sub3.PSUBSCRIBE("my.*", "what"); try { sub3.PUBLISH('fail', 'fail'); @@ -485,7 +485,7 @@ process.stdout.write('testing fakeredis ...\n\n'); data[1].push(channel + '-' + message); if (message === 'alpha') - pub.PUBLISH('mych', 'beta', test('PUB2', null, 3)); + pub.PUBLISH('my.ch', 'beta', test('PUB2', null, 3)); }); sub2.on('pmessage', function (pattern, channel, message) { @@ -508,7 +508,7 @@ process.stdout.write('testing fakeredis ...\n\n'); }); sub2.PUBLISH('hello', 'world', test('PUB4 ignored', null, 0)); - sub2.PUBLISH('mych', 'omega', test('PUB5 unsubed', null, 2)); + sub2.PUBLISH('my.ch', 'omega', test('PUB5 unsubed', null, 2)); }); sub3.on('pmessage', function (pattern, channel, message) { @@ -518,7 +518,7 @@ process.stdout.write('testing fakeredis ...\n\n'); var start = function (ch) { data [ 0 ] ++; if (data [ 0 ] === 4) { - pub.PUBLISH('mych', 'alpha', test('PUB1', null, 3)); + pub.PUBLISH('my.ch', 'alpha', test('PUB1', null, 3)); } if (ch === '*ch')