Stripe In Practice Course

Author: Your Name

src/app/services/checkout.service.ts

@@ -3,6 +3,8 @@ import {HttpClient, HttpHeaders} from '@angular/common/http';
 import {Observable} from 'rxjs';
 import {CheckoutSession} from '../model/checkout-session.model';
 import {AngularFireAuth} from '@angular/fire/auth';
+import {AngularFirestore} from '@angular/fire/firestore';
+import {filter, first} from 'rxjs/operators';
 
 declare const Stripe;
 
@@ -15,7 +17,8 @@ export class CheckoutService {
     private jwtAuth:string;
 
     constructor(private http:HttpClient,
-                private afAuth: AngularFireAuth) {
+                private afAuth: AngularFireAuth,
+                private afs: AngularFirestore) {
 
         afAuth.idToken.subscribe(jwt => this.jwtAuth = jwt);
 
@@ -56,5 +59,22 @@ export class CheckoutService {
             sessionId: session.stripeCheckoutSessionId
         });
     }
+
+    waitForPurchaseCompleted(ongoingPurchaseSessionId: string):Observable<any> {
+        return this.afs.doc<any>(`purchaseSessions/${ongoingPurchaseSessionId}`)
+            .valueChanges()
+            .pipe(
+                filter(purchase => purchase.status == "completed"),
+                first()
+            )
+    }
 }
 
+
+
+
+
+
+
+
+

src/app/stripe-checkout/stripe-checkout.component.ts

@@ -1,5 +1,6 @@
 import { Component, OnInit } from '@angular/core';
 import {ActivatedRoute, Router} from '@angular/router';
+import {CheckoutService} from '../services/checkout.service';
 
 @Component({
   selector: 'stripe-checkout',
@@ -14,7 +15,8 @@ export class StripeCheckoutComponent implements OnInit {
 
   constructor(
     private route: ActivatedRoute,
-    private router: Router) {
+    private router: Router,
+    private checkout: CheckoutService) {
 
   }
 
@@ -24,6 +26,16 @@ export class StripeCheckoutComponent implements OnInit {
 
       if (result == "success") {
 
+          const ongoingPurchaseSessionId = this.route.snapshot.queryParamMap.get("ongoingPurchaseSessionId");
+
+          this.checkout.waitForPurchaseCompleted(ongoingPurchaseSessionId)
+              .subscribe(
+                  () => {
+                      this.waiting = false;
+                      this.message = "Purchase SUCCESSFUL, redirecting...";
+                      setTimeout(() => this.router.navigateByUrl("/courses"), 3000);
+                  })
+
       }
       else {
           this.waiting = false;