From 3a5c2bc62c5dc45f06d1d4135deed17a701803bb Mon Sep 17 00:00:00 2001 From: Gavin Stark Date: Tue, 14 Jun 2022 00:20:50 -0400 Subject: [PATCH] updates lita to use pipelined command --- lib/lita/room.rb | 6 +++--- lib/lita/user.rb | 10 +++++----- 2 files changed, 8 insertions(+), 8 deletions(-) diff --git a/lib/lita/room.rb b/lib/lita/room.rb index 538c4779..e3a5bd06 100644 --- a/lib/lita/room.rb +++ b/lib/lita/room.rb @@ -96,9 +96,9 @@ def hash def save ensure_name_metadata_set - redis.pipelined do - redis.hmset("id:#{id}", *metadata.to_a.flatten) - redis.set("name:#{name}", id) + redis.pipelined do |pipeline| + pipeline.hmset("id:#{id}", *metadata.to_a.flatten) + pipeline.set("name:#{name}", id) end end diff --git a/lib/lita/user.rb b/lib/lita/user.rb index 0a4660cb..dda3ec21 100644 --- a/lib/lita/user.rb +++ b/lib/lita/user.rb @@ -116,11 +116,11 @@ def save redis_keys = redis.hkeys("id:#{id}") delete_keys = (redis_keys - current_keys) - redis.pipelined do - redis.hdel("id:#{id}", *delete_keys) if delete_keys.any? - redis.hmset("id:#{id}", *metadata.to_a.flatten) - redis.set("name:#{name}", id) - redis.set("mention_name:#{mention_name}", id) if mention_name + redis.pipelined do |pipeline| + pipeline.hdel("id:#{id}", *delete_keys) if delete_keys.any? + pipeline.hmset("id:#{id}", *metadata.to_a.flatten) + pipeline.set("name:#{name}", id) + pipeline.set("mention_name:#{mention_name}", id) if mention_name end end