Class UserResolver

apps/api/src/users/resolvers/user.resolver.ts:20–160

@UseGuards(GraphqlGuard)
@UseInterceptors(AuthorizerInterceptor(User))
export class UserResolver extends BaseResolver(User, {
  guards: [GraphqlGuard],
  UpdateDTOClass: UpdateUserInput,
  read: { many: { disabled: true } },
  create: { disabled: true },
  update: { many: { disabled: true } },
  delete: { disabled: true },
}) {
  private readonly logger = new Logger(UserResolver.name)

  constructor(
    protected readonly userService: UserService,
    protected readonly subscriptionService: SubscriptionService,
  ) {
    super(userService)
  }

  @Query(() => User)
  @UseGuards(GraphqlGuard)
  viewer(@UserId() userId: Types.ObjectId): Promise<User | null> {
    return this.userService.findOne({ _id: userId })
  }

  @Mutation(() => UserCheckoutSessionPayload)
  async createCheckoutSession(
    @UserId() userId: ObjectId,
    @Args({ name: 'priceId', type: () => GraphQLString }) priceId: string,
  ): Promise<{ sessionId: string }> {
    if (!userId) {
      throw new Error('Not logged in')
    }
    const user = await this.userService.findOne({ _id: userId })
    if (!user) {
      throw new Error('User not found')
    }
    this.logger.log(`Creating checkout session for user ${user.id} with price ${priceId}`)
    const successUrl = `${process.env.FRONTEND_ENDPOINT}/dashboard`
    const cancelUrl = `${process.env.FRONTEND_ENDPOINT}/dashboard`
    const sessionId = await this.subscriptionService.createCheckoutSession(user, priceId, successUrl, cancelUrl)
    return { sessionId }
  }

  @Mutation(() => ResultPayload)
  async resumeSubscription(@UserId() userId: ObjectId): Promise<{ success: boolean }> {
    if (!userId) {
      throw new Error('Not logged in')
    }
    const user = await this.userService.findOne({ _id: userId })
    if (!user) {
      throw new Error('User not found')
    }
    this.logger.log(`Resuming subscription ${user.stripeSubscriptionId} for user ${user.id}`)
    await this.subscriptionService.resumeSubscription(user)
    await this.userService.updateOneNative({ _id: user._id }, { $unset: { nextPlan: 'free' } })
    return { success: true }
  }

  @Mutation(() => ResultPayload)