mirror of
https://github.com/outline/outline.git
synced 2026-06-13 03:14:59 +03:00
1a893b0e45
Adds group sync from external authentication providers, allowing team group memberships to be automatically managed based on provider data on sign-in in the future.
215 lines
5.1 KiB
TypeScript
215 lines
5.1 KiB
TypeScript
import type {
|
|
InferAttributes,
|
|
InferCreationAttributes,
|
|
Transaction,
|
|
} from "sequelize";
|
|
import { Op } from "sequelize";
|
|
import {
|
|
BeforeDestroy,
|
|
BelongsTo,
|
|
Column,
|
|
CreatedAt,
|
|
DataType,
|
|
Default,
|
|
ForeignKey,
|
|
HasMany,
|
|
Table,
|
|
IsUUID,
|
|
PrimaryKey,
|
|
Scopes,
|
|
} from "sequelize-typescript";
|
|
import type { AuthenticationProviderSettings } from "@shared/types";
|
|
import AuthenticationHelper from "@server/models/helpers/AuthenticationHelper";
|
|
import Model from "@server/models/base/Model";
|
|
import { ValidationError } from "../errors";
|
|
import Team from "./Team";
|
|
import UserAuthentication from "./UserAuthentication";
|
|
import Fix from "./decorators/Fix";
|
|
import Length from "./validators/Length";
|
|
|
|
// TODO: Avoid this hardcoding of plugins
|
|
import AzureClient from "plugins/azure/server/azure";
|
|
import GoogleClient from "plugins/google/server/google";
|
|
import OIDCClient from "plugins/oidc/server/oidc";
|
|
import type { APIContext } from "@server/types";
|
|
import type { DestroyOptions } from "sequelize";
|
|
|
|
@Scopes(() => ({
|
|
withUserAuthentication: (userId: string) => ({
|
|
include: [
|
|
{
|
|
model: UserAuthentication,
|
|
as: "userAuthentications",
|
|
required: true,
|
|
where: {
|
|
userId,
|
|
},
|
|
},
|
|
],
|
|
}),
|
|
}))
|
|
@Table({
|
|
tableName: "authentication_providers",
|
|
modelName: "authentication_provider",
|
|
updatedAt: false,
|
|
})
|
|
@Fix
|
|
class AuthenticationProvider extends Model<
|
|
InferAttributes<AuthenticationProvider>,
|
|
Partial<InferCreationAttributes<AuthenticationProvider>>
|
|
> {
|
|
@IsUUID(4)
|
|
@PrimaryKey
|
|
@Default(DataType.UUIDV4)
|
|
@Column(DataType.UUID)
|
|
id: string;
|
|
|
|
@Length({
|
|
max: 255,
|
|
msg: "name must be 255 characters or less",
|
|
})
|
|
@Column
|
|
name: string;
|
|
|
|
@Default(true)
|
|
@Column
|
|
enabled: boolean;
|
|
|
|
@Length({
|
|
max: 255,
|
|
msg: "providerId must be 255 characters or less",
|
|
})
|
|
@Column
|
|
providerId: string;
|
|
|
|
/** Provider-specific settings such as group sync configuration. */
|
|
@Column(DataType.JSONB)
|
|
settings: AuthenticationProviderSettings | null;
|
|
|
|
@CreatedAt
|
|
createdAt: Date;
|
|
|
|
// associations
|
|
|
|
@BelongsTo(() => Team, "teamId")
|
|
team: Team;
|
|
|
|
@ForeignKey(() => Team)
|
|
@Column(DataType.UUID)
|
|
teamId: string;
|
|
|
|
@HasMany(() => UserAuthentication, "authenticationProviderId")
|
|
userAuthentications: UserAuthentication[];
|
|
|
|
// instance methods
|
|
|
|
/**
|
|
* The human-readable display name for this provider, resolved from the
|
|
* plugin registry. Falls back to the raw provider name.
|
|
*/
|
|
get displayName(): string {
|
|
return (
|
|
AuthenticationHelper.providers.find((p) => p.value.id === this.name)
|
|
?.name ?? this.name
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Create an OAuthClient for this provider, if possible.
|
|
*
|
|
* @returns A configured OAuthClient instance
|
|
*/
|
|
get oauthClient() {
|
|
switch (this.name) {
|
|
case "google":
|
|
return new GoogleClient();
|
|
case "azure":
|
|
return new AzureClient();
|
|
case "oidc":
|
|
return new OIDCClient();
|
|
default:
|
|
return undefined;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Check if this provider can be disabled or destroyed.
|
|
* Throws an error if this is the last enabled authentication provider.
|
|
*
|
|
* @param transaction - Database transaction to use for the check.
|
|
* @throws ValidationError if disabling is not allowed.
|
|
*/
|
|
private async checkCanBeDisabled(
|
|
transaction?: Transaction | null
|
|
): Promise<void> {
|
|
// Check if email sign-in is enabled for the team first
|
|
const team = await Team.findByPk(this.teamId, {
|
|
transaction,
|
|
lock: transaction?.LOCK.SHARE,
|
|
});
|
|
if (team?.emailSigninEnabled) {
|
|
return;
|
|
}
|
|
|
|
const otherEnabledProviders = await (
|
|
this.constructor as typeof AuthenticationProvider
|
|
).findAll({
|
|
transaction,
|
|
lock: transaction?.LOCK.SHARE,
|
|
where: {
|
|
teamId: this.teamId,
|
|
enabled: true,
|
|
id: {
|
|
[Op.ne]: this.id,
|
|
},
|
|
},
|
|
limit: 1,
|
|
});
|
|
|
|
if (otherEnabledProviders.length === 0) {
|
|
throw ValidationError("At least one authentication provider is required");
|
|
}
|
|
}
|
|
|
|
@BeforeDestroy
|
|
static async checkBeforeDestroy(
|
|
instance: AuthenticationProvider,
|
|
options: DestroyOptions
|
|
) {
|
|
if (instance.enabled) {
|
|
await instance.checkCanBeDisabled(options.transaction);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Disable this authentication provider after ensuring it's allowed.
|
|
*
|
|
* @param ctx - API context containing the transaction.
|
|
* @returns The updated AuthenticationProvider instance.
|
|
* @throws ValidationError if disabling is not allowed.
|
|
*/
|
|
disable: (ctx: APIContext) => Promise<AuthenticationProvider> = async (
|
|
ctx
|
|
) => {
|
|
const { transaction } = ctx.state;
|
|
await this.checkCanBeDisabled(transaction);
|
|
|
|
return this.updateWithCtx(ctx, {
|
|
enabled: false,
|
|
});
|
|
};
|
|
|
|
/**
|
|
* Enable this authentication provider.
|
|
*
|
|
* @param ctx - API context containing the transaction.
|
|
* @returns The updated AuthenticationProvider instance.
|
|
*/
|
|
enable: (ctx: APIContext) => Promise<AuthenticationProvider> = async (ctx) =>
|
|
this.updateWithCtx(ctx, {
|
|
enabled: true,
|
|
});
|
|
}
|
|
|
|
export default AuthenticationProvider;
|