server/models/AuthenticationProvider.ts

Rama main · réplica de lectura del repositorio original.

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 Length from "./validators/Length";

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,
})
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(DataType.STRING)
  name: string;

  @Default(true)
  @Column(DataType.BOOLEAN)
  enabled: boolean;

  @Length({
    max: 255,
    msg: "providerId must be 255 characters or less",
  })
  @Column(DataType.STRING)
  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() {
    return AuthenticationHelper.providers
      .find((p) => p.value.id === this.name)
      ?.value.oauthClient?.();
  }

  /**
   * 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;