@accounts/redis/lib/redis.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
var tslib_1 = require("tslib");
var shortid = require("shortid");
var lodash_1 = require("lodash");
var defaultOptions = {
    userCollectionName: 'users',
    sessionCollectionName: 'sessions',
    timestamps: {
        createdAt: 'createdAt',
        updatedAt: 'updatedAt',
    },
    idProvider: function () { return shortid.generate(); },
    dateProvider: function (date) { return (date ? date.getTime() : Date.now()); },
};
var RedisSessions = /** @class */ (function () {
    function RedisSessions(db, options) {
        this.options = lodash_1.merge(tslib_1.__assign({}, defaultOptions), options);
        if (!db) {
            throw new Error('A database connection is required');
        }
        this.db = db;
    }
    RedisSessions.prototype.createSession = function (userId, token, connection, extraData) {
        if (connection === void 0) { connection = {}; }
        return tslib_1.__awaiter(this, void 0, void 0, function () {
            var sessionId, pipeline;
            var _a;
            return tslib_1.__generator(this, function (_b) {
                switch (_b.label) {
                    case 0:
                        sessionId = this.options.idProvider();
                        pipeline = this.db.pipeline();
                        pipeline.hmset(this.options.sessionCollectionName + ":" + sessionId, (_a = {
                                userId: userId,
                                token: token,
                                userAgent: connection.userAgent,
                                ip: connection.ip,
                                valid: true
                            },
                            _a[this.options.timestamps.createdAt] = this.options.dateProvider(),
                            _a[this.options.timestamps.updatedAt] = this.options.dateProvider(),
                            _a));
                        // Push the sessionId inside the userId
                        pipeline.sadd(this.options.sessionCollectionName + ":" + this.options.userCollectionName + ":" + userId, sessionId);
                        // Link the session token to the sessionId
                        pipeline.set(this.options.sessionCollectionName + ":token:" + token, sessionId);
                        return [4 /*yield*/, pipeline.exec()];
                    case 1:
                        _b.sent();
                        return [2 /*return*/, sessionId];
                }
            });
        });
    };
    RedisSessions.prototype.updateSession = function (sessionId, connection) {
        return tslib_1.__awaiter(this, void 0, void 0, function () {
            var _a;
            return tslib_1.__generator(this, function (_b) {
                switch (_b.label) {
                    case 0: return [4 /*yield*/, this.db.exists(this.options.sessionCollectionName + ":" + sessionId)];
                    case 1:
                        if (!_b.sent()) return [3 /*break*/, 3];
                        return [4 /*yield*/, this.db.hmset(this.options.sessionCollectionName + ":" + sessionId, (_a = {
                                    userAgent: connection.userAgent,
                                    ip: connection.ip
                                },
                                _a[this.options.timestamps.updatedAt] = this.options.dateProvider(),
                                _a))];
                    case 2:
                        _b.sent();
                        _b.label = 3;
                    case 3: return [2 /*return*/];
                }
            });
        });
    };
    RedisSessions.prototype.invalidateSession = function (sessionId) {
        return tslib_1.__awaiter(this, void 0, void 0, function () {
            var _a;
            return tslib_1.__generator(this, function (_b) {
                switch (_b.label) {
                    case 0: return [4 /*yield*/, this.db.exists(this.options.sessionCollectionName + ":" + sessionId)];
                    case 1:
                        if (!_b.sent()) return [3 /*break*/, 3];
                        return [4 /*yield*/, this.db.hmset(this.options.sessionCollectionName + ":" + sessionId, (_a = {
                                    valid: false
                                },
                                _a[this.options.timestamps.updatedAt] = this.options.dateProvider(),
                                _a))];
                    case 2:
                        _b.sent();
                        _b.label = 3;
                    case 3: return [2 /*return*/];
                }
            });
        });
    };
    RedisSessions.prototype.invalidateAllSessions = function (userId) {
        return tslib_1.__awaiter(this, void 0, void 0, function () {
            var sessionIds;
            var _this = this;
            return tslib_1.__generator(this, function (_a) {
                switch (_a.label) {
                    case 0: return [4 /*yield*/, this.db.exists(this.options.sessionCollectionName + ":" + this.options.userCollectionName + ":" + userId)];
                    case 1:
                        if (!_a.sent()) return [3 /*break*/, 4];
                        return [4 /*yield*/, this.db.smembers(this.options.sessionCollectionName + ":" + this.options.userCollectionName + ":" + userId)];
                    case 2:
                        sessionIds = _a.sent();
                        return [4 /*yield*/, sessionIds.map(function (sessionId) { return _this.invalidateSession(sessionId); })];
                    case 3:
                        _a.sent();
                        _a.label = 4;
                    case 4: return [2 /*return*/];
                }
            });
        });
    };
    RedisSessions.prototype.findSessionByToken = function (token) {
        return tslib_1.__awaiter(this, void 0, void 0, function () {
            var sessionId;
            return tslib_1.__generator(this, function (_a) {
                switch (_a.label) {
                    case 0: return [4 /*yield*/, this.db.exists(this.options.sessionCollectionName + ":token:" + token)];
                    case 1:
                        if (!_a.sent()) return [3 /*break*/, 3];
                        return [4 /*yield*/, this.db.get(this.options.sessionCollectionName + ":token:" + token)];
                    case 2:
                        sessionId = _a.sent();
                        if (sessionId) {
                            return [2 /*return*/, this.findSessionById(sessionId)];
                        }
                        _a.label = 3;
                    case 3: return [2 /*return*/, null];
                }
            });
        });
    };
    RedisSessions.prototype.findSessionById = function (sessionId) {
        return tslib_1.__awaiter(this, void 0, void 0, function () {
            var session;
            return tslib_1.__generator(this, function (_a) {
                switch (_a.label) {
                    case 0: return [4 /*yield*/, this.db.exists(this.options.sessionCollectionName + ":" + sessionId)];
                    case 1:
                        if (!_a.sent()) return [3 /*break*/, 3];
                        return [4 /*yield*/, this.db.hgetall(this.options.sessionCollectionName + ":" + sessionId)];
                    case 2:
                        session = _a.sent();
                        return [2 /*return*/, this.formatSession(sessionId, session)];
                    case 3: return [2 /*return*/, null];
                }
            });
        });
    };
    /**
     * We need to format the session to have an object the server can understand.
     */
    RedisSessions.prototype.formatSession = function (sessionId, session) {
        // Redis doesn't store boolean values, so we need turn this string into a boolean
        session.valid = session.valid === 'true';
        return tslib_1.__assign({ id: sessionId }, session);
    };
    return RedisSessions;
}());
exports.RedisSessions = RedisSessions;
//# sourceMappingURL=redis.js.map