Add fix for subs data

Author: brh55

final/nosql-products/package.json

@@ -25,13 +25,14 @@
     "@apollo/server": "^4.0.0",
     "@apollo/subgraph": "latest",
     "apollo-datasource-mongodb": "^0.5.4",
-    "graphql": "latest",
-    "graphql-tag": "latest",
-    "mongodb": "^4.12.1",
     "body-parser": "^1.20.2",
     "cors": "^2.8.5",
     "express": "^4.18.2",
+    "graphql": "latest",
+    "graphql-subscriptions": "^2.0.0",
+    "graphql-tag": "latest",
     "graphql-ws": "^5.12.1",
+    "mongodb": "^4.12.1",
     "ws": "^8.13.0"
   },
   "devDependencies": {

final/nosql-products/src/index.js

@@ -1,5 +1,3 @@
-const { MongoClient } = require("mongodb");
-
 const cors = require("cors");
 const bodyParser = require("body-parser");
 const json = bodyParser;
@@ -9,7 +7,6 @@ const gql = require("graphql-tag");
 const { readFileSync } = require("fs");
 const { ApolloServer } = require("@apollo/server");
 const { buildSubgraphSchema } = require("@apollo/subgraph");
-const { startStandaloneServer } = require("@apollo/server/standalone");
 const { ApolloServerPluginInlineTrace } = require("@apollo/server/plugin/inlineTrace");
 
 const {  ApolloServerPluginDrainHttpServer } = require("@apollo/server/plugin/drainHttpServer");
@@ -18,25 +15,20 @@ const { createServer } = require("http");
 const { WebSocketServer } = require("ws");
 const { useServer } = require("graphql-ws/lib/use/ws");
 
+const { dbCollection } = require("./mongoClient");
 const resolvers = require("./resolvers");
 const ProductsAPI = require("./datasources/products-api");
 const port = process.env.PORT ?? 4001;
 const subgraphName = require("../package.json").name;
 
-const client = new MongoClient(
-  'mongodb+srv://workshop-user:[email protected]/?retryWrites=true&w=majority'
-);
-client.connect();
-
-
 class ContextValue {
   constructor({ req, server }) {
     const { cache } = server;
     this.dataSources = {
       productsAPI: new ProductsAPI({ 
         cache,
         contextValue: this,
-        collection: client.db("ecommerce").collection("products")
+        collection: dbCollection
       })
     }
   }
@@ -62,6 +54,7 @@ async function main() {
   const server = new ApolloServer({
     schema,
     plugins: [
+      ApolloServerPluginInlineTrace,
       ApolloServerPluginDrainHttpServer({ httpServer }),
         {
           async serverWillStart() {

final/nosql-products/src/mongoClient.js

@@ -0,0 +1,12 @@
+const { MongoClient } = require("mongodb");
+
+const client = new MongoClient(
+    'mongodb+srv://workshop-user:[email protected]/?retryWrites=true&w=majority'
+);
+  
+const collection = client.db("ecommerce").collection("products");  
+
+client.connect();
+
+module.exports.dbClient = client;
+module.exports.dbCollection = collection;

final/nosql-products/src/resolvers/index.js

@@ -1,4 +1,11 @@
 const { Query } = require("./Query");
+const { dbCollection } = require("../mongoClient");
+const ProductsAPI = require("../datasources/products-api");
+
+const API = new ProductsAPI({ 
+  collection: dbCollection
+});
+
 
 const reviews = [
   {
@@ -102,7 +109,14 @@ const resolvers = {
         let count = 0;
         while (true) {
           const review = reviews[count++];
-          yield { reviewAdded: review };
+          const product = await API.getProduct({id: review.product.id});
+
+          yield { 
+            reviewAdded: {
+              ...review,
+              product
+            }
+          };
           await new Promise((resolve) => setTimeout(resolve, 3000));
           if (count === reviews.length) count = 0;
         }