"use strict";
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
Object.defineProperty(exports, "__esModule", { value: true });
const moment = require("moment");
const factory = require("../factory");
const transaction_1 = require("./mongoose/model/transaction");
/**
* 取引リポジトリー
*/
class MongoRepository {
constructor(connection) {
this.transactionModel = connection.model(transaction_1.default.modelName);
}
// tslint:disable-next-line:cyclomatic-complexity max-func-body-length
static CREATE_MONGO_CONDITIONS(params) {
const andConditions = [
{
typeOf: params.typeOf
}
];
// tslint:disable-next-line:no-single-line-block-comment
/* istanbul ignore else */
if (params.startFrom !== undefined) {
andConditions.push({
startDate: { $gt: params.startFrom }
});
}
// tslint:disable-next-line:no-single-line-block-comment
/* istanbul ignore else */
if (params.startThrough !== undefined) {
andConditions.push({
startDate: { $lt: params.startThrough }
});
}
// tslint:disable-next-line:no-single-line-block-comment
/* istanbul ignore else */
if (params.endFrom !== undefined) {
andConditions.push({
endDate: {
$exists: true,
$gte: params.endFrom
}
});
}
// tslint:disable-next-line:no-single-line-block-comment
/* istanbul ignore else */
if (params.endThrough !== undefined) {
andConditions.push({
endDate: {
$exists: true,
$lt: params.endThrough
}
});
}
// tslint:disable-next-line:no-single-line-block-comment
/* istanbul ignore else */
if (Array.isArray(params.ids)) {
andConditions.push({
_id: { $in: params.ids }
});
}
// tslint:disable-next-line:no-single-line-block-comment
/* istanbul ignore else */
if (Array.isArray(params.statuses)) {
andConditions.push({
status: { $in: params.statuses }
});
}
// tslint:disable-next-line:no-single-line-block-comment
/* istanbul ignore else */
if (params.agent !== undefined) {
if (Array.isArray(params.agent.ids)) {
andConditions.push({
'agent.id': { $in: params.agent.ids }
});
}
}
switch (params.typeOf) {
case factory.transactionType.CancelReservation:
break;
case factory.transactionType.Reserve:
break;
default:
}
return andConditions;
}
/**
* 取引を開始する
*/
start(params) {
return __awaiter(this, void 0, void 0, function* () {
return this.transactionModel.create(Object.assign({ typeOf: params.typeOf }, params, { status: factory.transactionStatusType.InProgress, startDate: new Date(), endDate: undefined, tasksExportationStatus: factory.transactionTasksExportationStatus.Unexported })).then((doc) => doc.toObject());
});
}
/**
* IDで取引を取得する
*/
findById(params) {
return __awaiter(this, void 0, void 0, function* () {
const doc = yield this.transactionModel.findOne({
_id: params.id,
typeOf: params.typeOf
}).exec();
if (doc === null) {
throw new factory.errors.NotFound('Transaction');
}
return doc.toObject();
});
}
/**
* 進行中の取引を取得する
*/
findInProgressById(params) {
return __awaiter(this, void 0, void 0, function* () {
const doc = yield this.transactionModel.findOne({
_id: params.id,
typeOf: params.typeOf,
status: factory.transactionStatusType.InProgress
}).exec();
if (doc === null) {
throw new factory.errors.NotFound('Transaction');
}
return doc.toObject();
});
}
/**
* 取引を確定する
*/
confirm(params) {
return __awaiter(this, void 0, void 0, function* () {
const doc = yield this.transactionModel.findOneAndUpdate({
_id: params.id,
typeOf: params.typeOf,
status: factory.transactionStatusType.InProgress
}, {
status: factory.transactionStatusType.Confirmed,
endDate: new Date(),
result: params.result,
potentialActions: params.potentialActions // resultを更新
}, { new: true }).exec();
// NotFoundであれば取引状態確認
if (doc === null) {
const transaction = yield this.findById({ typeOf: params.typeOf, id: params.id });
if (transaction.status === factory.transactionStatusType.Confirmed) {
// すでに確定済の場合
return transaction;
}
else if (transaction.status === factory.transactionStatusType.Expired) {
throw new factory.errors.Argument('Transaction id', 'Transaction already expired');
}
else if (transaction.status === factory.transactionStatusType.Canceled) {
throw new factory.errors.Argument('Transaction id', 'Transaction already canceled');
}
else {
throw new factory.errors.NotFound(this.transactionModel.modelName);
}
}
return doc.toObject();
});
}
/**
* タスク未エクスポートの取引をひとつ取得してエクスポートを開始する
*/
startExportTasks(params) {
return __awaiter(this, void 0, void 0, function* () {
return this.transactionModel.findOneAndUpdate({
typeOf: params.typeOf,
status: params.status,
tasksExportationStatus: factory.transactionTasksExportationStatus.Unexported
}, { tasksExportationStatus: factory.transactionTasksExportationStatus.Exporting }, { new: true }).exec().then((doc) => (doc === null) ? null : doc.toObject());
});
}
/**
* タスクエクスポートリトライ
* todo updatedAtを基準にしているが、タスクエクスポートトライ日時を持たせた方が安全か？
*/
reexportTasks(params) {
return __awaiter(this, void 0, void 0, function* () {
yield this.transactionModel.findOneAndUpdate({
tasksExportationStatus: factory.transactionTasksExportationStatus.Exporting,
updatedAt: { $lt: moment().add(-params.intervalInMinutes, 'minutes').toISOString() }
}, {
tasksExportationStatus: factory.transactionTasksExportationStatus.Unexported
}).exec();
});
}
/**
* set task status exported by transaction id
* IDでタスクをエクスポート済に変更する
*/
setTasksExportedById(params) {
return __awaiter(this, void 0, void 0, function* () {
yield this.transactionModel.findByIdAndUpdate(params.id, {
tasksExportationStatus: factory.transactionTasksExportationStatus.Exported,
tasksExportedAt: moment().toDate()
}).exec();
});
}
/**
* 取引を期限切れにする
*/
makeExpired() {
return __awaiter(this, void 0, void 0, function* () {
const endDate = moment().toDate();
// ステータスと期限を見て更新
yield this.transactionModel.update({
status: factory.transactionStatusType.InProgress,
expires: { $lt: endDate }
}, {
status: factory.transactionStatusType.Expired,
endDate: endDate
}, { multi: true }).exec();
});
}
/**
* 取引を中止する
*/
cancel(params) {
return __awaiter(this, void 0, void 0, function* () {
const endDate = moment().toDate();
// 進行中ステータスの取引を中止する
const doc = yield this.transactionModel.findOneAndUpdate({
typeOf: params.typeOf,
_id: params.id,
status: factory.transactionStatusType.InProgress
}, {
status: factory.transactionStatusType.Canceled,
endDate: endDate
}, { new: true }).exec();
// NotFoundであれば取引状態確認
if (doc === null) {
const transaction = yield this.findById(params);
if (transaction.status === factory.transactionStatusType.Canceled) {
// すでに中止済の場合
return transaction;
}
else if (transaction.status === factory.transactionStatusType.Expired) {
throw new factory.errors.Argument('Transaction id', 'Transaction already expired');
}
else if (transaction.status === factory.transactionStatusType.Confirmed) {
throw new factory.errors.Argument('Transaction id', 'Confirmed transaction unable to cancel');
}
else {
throw new factory.errors.NotFound(this.transactionModel.modelName);
}
}
return doc.toObject();
});
}
count(params) {
return __awaiter(this, void 0, void 0, function* () {
const conditions = MongoRepository.CREATE_MONGO_CONDITIONS(params);
return this.transactionModel.countDocuments({ $and: conditions }).setOptions({ maxTimeMS: 10000 })
.exec();
});
}
/**
* 取引を検索する
*/
search(params) {
return __awaiter(this, void 0, void 0, function* () {
const conditions = MongoRepository.CREATE_MONGO_CONDITIONS(params);
const query = this.transactionModel.find({ $and: conditions }, {
__v: 0,
createdAt: 0,
updatedAt: 0
});
// tslint:disable-next-line:no-single-line-block-comment
/* istanbul ignore else */
if (params.limit !== undefined && params.page !== undefined) {
query.limit(params.limit).skip(params.limit * (params.page - 1));
}
// tslint:disable-next-line:no-single-line-block-comment
/* istanbul ignore else */
if (params.sort !== undefined) {
query.sort(params.sort);
}
return query.setOptions({ maxTimeMS: 10000 }).exec().then((docs) => docs.map((doc) => doc.toObject()));
});
}
}
exports.MongoRepository = MongoRepository;