module Redis::Commands::Transactions

def discard
  send_command([:discard])
end

def exec
  send_command([:exec])
end

def multi(&block) # :nodoc:
  if block_given?
    if block&.arity == 0
      Pipeline.deprecation_warning("multi", Kernel.caller_locations(1, 5))
    end
    synchronize do |prior_client|
      pipeline = Pipeline::Multi.new(prior_client)
      pipelined_connection = PipelinedConnection.new(pipeline)
      yield pipelined_connection
      prior_client.call_pipeline(pipeline)
    end
  else
    send_command([:multi])
  end
end

def unwatch
  send_command([:unwatch])
end

def watch(*keys)
  synchronize do |client|
    res = client.call([:watch, *keys])
    if block_given?
      begin
        yield(self)
      rescue ConnectionError
        raise
      rescue StandardError
        unwatch
        raise
      end
    else
      res
    end
  end
end