module WolfCore::InMemoryStorageOperations

def acquire_lock(key:, value:, expiry:)
  WolfCore::InMemoryStorageDataSource.acquire_lock(key: key, value: value, expiry: expiry)
end

def add_unique_to_non_exp_lock_array(key:, value:)
  arr = check_lock_json(key: key)
  arr << value unless arr.include?(value)
  set_non_exp_lock(key: key, value: arr)
end

def check_lock(key:)
  WolfCore::InMemoryStorageDataSource.check_lock(key: key)
end

def check_lock_json(key:)
  arr = check_lock(key: key)
  return JSON.parse(arr) if arr.is_a?(String)
  arr || []
end

def release_lock(key:)
  WolfCore::InMemoryStorageDataSource.release_lock(key: key)
end

def set_non_exp_lock(key:, value:)
  WolfCore::InMemoryStorageDataSource.set_non_exp_lock(key: key, value: value)
end