Function verifyAndLogin

packages/server/src/enterprise/sso/SSOBase.ts:38–148

(
        app: express.Application,
        email: string,
        done: (err?: Error | null, user?: Express.User, info?: any) => void,
        profile: passport.Profile,
        accessToken: string | object,
        refreshToken: string
    )

    abstract initialize(): void
    abstract refreshToken(ssoRefreshToken: string): Promise<{ [key: string]: any }>
    async verifyAndLogin(
        app: express.Application,
        email: string,
        done: (err?: Error | null, user?: Express.User, info?: any) => void,
        profile: passport.Profile,
        accessToken: string | object,
        refreshToken: string
    ) {
        let queryRunner
        const ssoProviderName = this.getProviderName()
        try {
            queryRunner = getRunningExpressApp().AppDataSource.createQueryRunner()
            await queryRunner.connect()

            const userService = new UserService()
            const organizationService = new OrganizationService()
            const workspaceUserService = new WorkspaceUserService()

            let user: any = await userService.readUserByEmail(email, queryRunner)
            let wu: any = {}

            if (!user) {
                // In ENTERPRISE mode, we don't want to create a new user if the user is not found
                if (getRunningExpressApp().identityManager.getPlatformType() === Platform.ENTERPRISE) {
                    throw new InternalFlowiseError(StatusCodes.NOT_FOUND, UserErrorMessage.USER_NOT_FOUND)
                }
                // no user found, register the user
                const data: any = {
                    user: {
                        email: email,
                        name: profile.displayName || email,
                        status: UserStatus.ACTIVE,
                        credential: undefined
                    }
                }
                if (getRunningExpressApp().identityManager.getPlatformType() === Platform.CLOUD) {
                    const accountService = new AccountService()
                    const newAccount = await accountService.register(data)
                    wu = newAccount.workspaceUser
                    wu.workspace = newAccount.workspace
                    user = newAccount.user
                }
            } else {
                if (user.status === UserStatus.INVITED) {
                    const data: any = {
                        user: {
                            ...user,
                            email,
                            name: profile.displayName || '',
                            status: UserStatus.ACTIVE,
                            credential: undefined
                        }
                    }
                    const accountService = new AccountService()
                    const newAccount = await accountService.register(data)
                    user = newAccount.user
                }
                let wsUserOrUsers = await workspaceUserService.readWorkspaceUserByLastLogin(user?.id, queryRunner)