@accounts/oauth/lib/accounts-oauth.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
var tslib_1 = require("tslib");
var server_1 = require("@accounts/server");
var AccountsOauth = /** @class */ (function () {
    function AccountsOauth(options) {
        this.serviceName = 'oauth';
        this.options = options;
    }
    AccountsOauth.prototype.setStore = function (store) {
        this.db = store;
    };
    AccountsOauth.prototype.authenticate = function (params) {
        return tslib_1.__awaiter(this, void 0, void 0, function () {
            var userProvider, oauthUser, user, userId, e_1;
            return tslib_1.__generator(this, function (_a) {
                switch (_a.label) {
                    case 0:
                        if (!params.provider || !this.options[params.provider]) {
                            throw new Error('Invalid provider');
                        }
                        userProvider = this.options[params.provider];
                        if (typeof userProvider.authenticate !== 'function') {
                            throw new Error('Invalid provider');
                        }
                        return [4 /*yield*/, userProvider.authenticate(params)];
                    case 1:
                        oauthUser = _a.sent();
                        return [4 /*yield*/, this.db.findUserByServiceId(params.provider, oauthUser.id)];
                    case 2:
                        user = _a.sent();
                        if (!(!user && oauthUser.email)) return [3 /*break*/, 4];
                        return [4 /*yield*/, this.db.findUserByEmail(oauthUser.email)];
                    case 3:
                        user = _a.sent();
                        _a.label = 4;
                    case 4:
                        if (!!user) return [3 /*break*/, 13];
                        _a.label = 5;
                    case 5:
                        _a.trys.push([5, 10, , 13]);
                        return [4 /*yield*/, this.db.createUser({
                                email: oauthUser.email,
                            })];
                    case 6:
                        userId = _a.sent();
                        return [4 /*yield*/, this.db.findUserById(userId)];
                    case 7:
                        user = (_a.sent());
                        if (!this.server) return [3 /*break*/, 9];
                        return [4 /*yield*/, this.server.getHooks().emit(server_1.ServerHooks.CreateUserSuccess, user)];
                    case 8:
                        _a.sent();
                        _a.label = 9;
                    case 9: return [3 /*break*/, 13];
                    case 10:
                        e_1 = _a.sent();
                        if (!this.server) return [3 /*break*/, 12];
                        return [4 /*yield*/, this.server.getHooks().emit(server_1.ServerHooks.CreateUserError, user)];
                    case 11:
                        _a.sent();
                        _a.label = 12;
                    case 12: throw e_1;
                    case 13: return [4 /*yield*/, this.db.setService(user.id, params.provider, oauthUser)];
                    case 14:
                        _a.sent();
                        return [2 /*return*/, user];
                }
            });
        });
    };
    AccountsOauth.prototype.unlink = function (userId, provider) {
        return tslib_1.__awaiter(this, void 0, void 0, function () {
            return tslib_1.__generator(this, function (_a) {
                switch (_a.label) {
                    case 0:
                        if (!provider || !this.options[provider]) {
                            throw new Error('Invalid provider');
                        }
                        return [4 /*yield*/, this.db.setService(userId, provider, null)];
                    case 1:
                        _a.sent();
                        return [2 /*return*/];
                }
            });
        });
    };
    return AccountsOauth;
}());
exports.AccountsOauth = AccountsOauth;
//# sourceMappingURL=accounts-oauth.js.map