feat: get subscription portal url api

Author: marian2js

apps/api/src/users/resolvers/user.resolver.ts

@@ -146,4 +146,15 @@ export class UserResolver extends BaseResolver(User, {
 
     return { success: true }
   }
+
+  @Query(() => GraphQLString)
+  @UseGuards(GraphqlGuard)
+  async subscriptionPortalUrl(@UserId() userId: Types.ObjectId): Promise<string> {
+    const user = await this.userService.findOne({ _id: userId })
+    if (!user) {
+      throw new Error('User not found')
+    }
+    const url = await this.subscriptionService.getSubscriptionPortal(user)
+    return url
+  }
 }

generated/graphql.ts

@@ -1725,6 +1725,7 @@ export interface UserDatabaseConnection {
 export interface IQuery {
     user(id: string): User | Promise<User>;
     viewer(): User | Promise<User>;
+    subscriptionPortalUrl(): string | Promise<string>;
     viewerContact(): ViewerContact | Promise<ViewerContact>;
     accountCredential(id: string): AccountCredential | Promise<AccountCredential>;
     accountCredentials(paging?: Nullable<CursorPaging>, filter?: Nullable<AccountCredentialFilter>, sorting?: Nullable<AccountCredentialSort[]>): AccountCredentialConnection | Promise<AccountCredentialConnection>;

generated/schema.graphql

@@ -1175,6 +1175,7 @@ type Query {
     id: ID!
   ): User!
   viewer: User!
+  subscriptionPortalUrl: String!
   viewerContact: ViewerContact!
   accountCredential(
     """The id of the record to find."""

libs/common/src/subscriptions/subscription.service.ts

@@ -100,4 +100,19 @@ export class SubscriptionService {
   async getSubscription(subscriptionId: string): Promise<Stripe.Subscription> {
     return this.stripe.subscriptions.retrieve(subscriptionId)
   }
+
+  async getSubscriptionPortal(user: User): Promise<string> {
+    if (!user.stripeCustomerId) {
+      throw new Error('You do not have an active subscription')
+    }
+    const customer = await this.stripe.customers.retrieve(user.stripeCustomerId)
+    if (!customer) {
+      throw new Error(`Customer ${user.stripeCustomerId} not found`)
+    }
+    const portalSession = await this.stripe.billingPortal.sessions.create({
+      customer: user.stripeCustomerId,
+      return_url: 'https://chainjet.io/dashboard',
+    })
+    return portalSession.url
+  }
 }