"use strict";
|
Object.defineProperty(exports, "__esModule", { value: true });
|
const utils_1 = require("./utils");
|
const standard_as_callback_1 = require("standard-as-callback");
|
const pipeline_1 = require("./pipeline");
|
function addTransactionSupport(redis) {
|
redis.pipeline = function (commands) {
|
const pipeline = new pipeline_1.default(this);
|
if (Array.isArray(commands)) {
|
pipeline.addBatch(commands);
|
}
|
return pipeline;
|
};
|
const { multi } = redis;
|
redis.multi = function (commands, options) {
|
if (typeof options === "undefined" && !Array.isArray(commands)) {
|
options = commands;
|
commands = null;
|
}
|
if (options && options.pipeline === false) {
|
return multi.call(this);
|
}
|
const pipeline = new pipeline_1.default(this);
|
pipeline.multi();
|
if (Array.isArray(commands)) {
|
pipeline.addBatch(commands);
|
}
|
const exec = pipeline.exec;
|
pipeline.exec = function (callback) {
|
if (this._transactions > 0) {
|
exec.call(pipeline);
|
}
|
// Returns directly when the pipeline
|
// has been called multiple times (retries).
|
if (this.nodeifiedPromise) {
|
return exec.call(pipeline);
|
}
|
const promise = exec.call(pipeline);
|
return standard_as_callback_1.default(promise.then(function (result) {
|
const execResult = result[result.length - 1];
|
if (typeof execResult === "undefined") {
|
throw new Error("Pipeline cannot be used to send any commands when the `exec()` has been called on it.");
|
}
|
if (execResult[0]) {
|
execResult[0].previousErrors = [];
|
for (let i = 0; i < result.length - 1; ++i) {
|
if (result[i][0]) {
|
execResult[0].previousErrors.push(result[i][0]);
|
}
|
}
|
throw execResult[0];
|
}
|
return utils_1.wrapMultiResult(execResult[1]);
|
}), callback);
|
};
|
const { execBuffer } = pipeline;
|
pipeline.execBuffer = function (callback) {
|
if (this._transactions > 0) {
|
execBuffer.call(pipeline);
|
}
|
return pipeline.exec(callback);
|
};
|
return pipeline;
|
};
|
const { exec } = redis;
|
redis.exec = function (callback) {
|
return standard_as_callback_1.default(exec.call(this).then(function (results) {
|
if (Array.isArray(results)) {
|
results = utils_1.wrapMultiResult(results);
|
}
|
return results;
|
}), callback);
|
};
|
}
|
exports.addTransactionSupport = addTransactionSupport;
|
