User: Register user, login, server side rendering current user with cookie, successful login redirect all working. Using a GraphQL mutation to create the user and passport to redirect.

Author: clintonwoo

.gitignore

@@ -1,6 +1,7 @@
 node_modules
 npm-debug.log
 logs
+coverage
 
 .next
 build/static

package.json

@@ -33,6 +33,7 @@
     "apollo-server-express": "^1.1.2",
     "babel-runtime": "^6.26.0",
     "body-parser": "^1.17.2",
+    "cookie": "^0.3.1",
     "cookie-parser": "^1.4.3",
     "debug": "^3.0.1",
     "dotenv": "^4.0.0",

src/data/HNDataAPI.js

@@ -47,7 +47,7 @@ export function fetchNewsItem(id) {
       }
       throw post;
     })
-    .catch(reason => logger(`Fetching news item failed: ${reason}`));
+    .catch(reason => logger(`Fetching post failed: ${reason}`));
 }
 
 export function fetchComment(id) {
@@ -77,7 +77,7 @@ export function getFeed(feedType) {
   logger(`Fetching /${feedType}stories.json`);
   return api.child(`${feedType}stories`).once('value')
     .then(feedSnapshot => feedSnapshot.val())
-    .then(feed => feed.filter(newsItem => newsItem !== undefined))
+    .then(feed => feed.filter(newsItem => newsItem !== undefined && newsItem !== null))
     .catch(reason => logger(`Fetching news feed failed: ${reason}`));
 }
 
@@ -87,7 +87,7 @@ const rebuildFeed = (feedType) => {
     .then(feed => Promise.all(feed.map(id => fetchNewsItem(id)))
       .then((newsItems) => {
         logger(newsItems);
-        Feed[`${feedType}NewsItems`] = newsItems;
+        Feed[`${feedType}NewsItems`] = newsItems.filter(newsItem => newsItem !== undefined && newsItem !== null);
         Feed[feedType] = feed;
         logger(`Updated ${feedType} ids`);
       }),

src/data/Schema.js

@@ -7,10 +7,14 @@ import {
 import {
   makeExecutableSchema,
 } from 'graphql-tools';
+import debug from 'debug';
 
 // Read the complete docs for graphql-tools here:
 // http://dev.apollodata.com/tools/graphql-tools/generate-schema.html
 
+const logger = debug('app:Schema');
+logger.log = console.log.bind(console);
+
 /*
   Schema properties are in following order:
     Alphabetical
@@ -161,7 +165,7 @@ const typeDefs = `
 
 `;
 
-const resolvers = {
+export const resolvers = {
 
   /*
     http://dev.apollodata.com/tools/graphql-tools/resolvers.html
@@ -193,7 +197,10 @@ const resolvers = {
       return context.Feed.getForType(type, limit, skip);
     },
 
-    me: (_, __, context) => context.userId && context.User.getUser(context.userId),
+    me: (_, __, context) => {
+      logger('Me: userId:', context.userId);
+      return context.userId && context.User.getUser(context.userId);
+    },
 
     newsItem: (_, { id }, context) => context.NewsItem.getNewsItem(id),
 

src/data/__mocks__/HNDataAPI.js

@@ -0,0 +1,39 @@
+import {
+  HN_API_URL,
+} from '../../config';
+
+import data from '../SampleData';
+
+// https://github.com/HackerNews/API
+
+/* BEGIN NEWS ITEMS */
+
+
+export function fetchNewsItem(id) {
+  return data.topStoriesCache.find(item => item.id === id);
+}
+
+export function fetchComment(id) {
+  return data.topStoriesCache[0].find(item => item.id === id);
+}
+
+// export function getFeed(feedType) {
+//   return data[feedType];
+// }
+
+// const rebuildFeed = (feedType) => {
+//   setTimeout(rebuildFeed, 1000 * 60 * 15, feedType);
+//   getFeed(feedType)
+//     .then(feed => Promise.all(feed.map(id => fetchNewsItem(id)))
+//       .then((newsItems) => {
+//         logger(newsItems);
+//         Feed[`${feedType}NewsItems`] = newsItems;
+//         Feed[feedType] = feed;
+//         logger(`Updated ${feedType} ids`);
+//       }),
+//     )
+//     .catch(reason => logger(`Error building feed: ${reason}`));
+};
+
+/* END NEWS ITEMS */
+

src/data/__tests__/Schema.js

@@ -1,50 +1,61 @@
-import data from '../../data/SampleData';
+import { resolvers } from '../Schema';
 
-const comment = data.topStoriesCache[0].comments[0];
+import data from '../../data/SampleData';
 
-describe('GraphQL', () => {
-  describe('Queries', () => {
-    it('returns expected data for Feed query', () => {
-      
-      expect(comment);
-    });
-    it('returns expected data for Comment query', () => {
-      
-      expect(comment);
-    });
-    it('returns expected data for Me query', () => {
-      
-      expect(comment);
-    });
-    it('returns expected data for News Item query', () => {
-      
-      expect(comment);
-    });
-    it('returns expected data for User query', () => {
-      
-      expect(comment);
-    });
-  });
+// const comment = data.topStoriesCache[0].comments[0];
 
-  describe('Mutations', () => {
-    it('returns data for upvoteNewsItem mutation', () => {
-      
-      expect(comment);
-    });
-    it('returns data for submitNewsItem mutation', () => {
-      
-      expect(comment);
-    });
-  });
 
-  describe('Property Resolvers', () => {
-    it('newsItem author is a user', () => {
-      
-      expect(comment);
-    });
-    it('newsItem comments are comments', () => {
-      
-      expect(comment);
+describe('GraphQL', () => {
+  describe('Resolvers', () => {
+    describe('Queries', () => {
+      it('returns expected data for query on Feed', () => {
+        expect(true);
+      });
+      it('returns expected data for query on Comment', () => {
+        const result = resolvers.Query.comment(
+          undefined,
+          { id: data.topStoriesCache[0].comments[0].id },
+          {
+            Comment: {
+              getComment: id => data.topStoriesCache[0].comments.find(comment => comment.id === id),
+            },
+          },
+        );
+        expect(result).toBeDefined();
+      });
+      it('returns expected data for query on Me', () => {
+        
+        expect(true);
+      });
+      it('returns expected data for News Item query', () => {
+        
+        expect(true);
+      });
+      it('returns expected data for User query', () => {
+        
+        expect(true);
+      });
+    });
+    describe('Mutations', () => {
+      it('returns data for upvoteNewsItem mutation', () => {
+        
+        expect(true);
+      });
+      it('returns data for submitNewsItem mutation', () => {
+        
+        expect(true);
+      });
+    });
+  
+    describe('Property Resolvers', () => {
+      it('newsItem author is a user', () => {
+        
+        expect(true);
+      });
+      it('newsItem comments are comments', () => {
+        
+        expect(true);
+      });
     });
   });
 });

src/helpers/initApollo.js

@@ -1,42 +1,49 @@
+import { ApolloClient, createNetworkInterface } from 'react-apollo';
 import fetch from 'isomorphic-fetch';
-import {
-  ApolloClient,
-  createNetworkInterface,
-} from 'react-apollo';
+import debug from 'debug';
+
 import {
   GRAPHQL_URL,
 } from '../config';
 
+const logger = debug('app:initApollo');
+logger.log = console.log.bind(console);
+
 let apolloClient = null;
 
 // Polyfill fetch() on the server (used by apollo-client)
 if (!process.browser) {
   global.fetch = fetch;
 }
 
-function create(initialState) {
+function create(initialState, { getToken }) {
   return new ApolloClient({
     initialState,
     ssrMode: !process.browser, // Disables forceFetch on the server (so queries are only run once)
     networkInterface: createNetworkInterface({
       uri: GRAPHQL_URL, // Server URL (must be absolute)
-      opts: { // Additional fetch() options like `credentials` or `headers`
+      opts: {
+        // Additional fetch() options like `credentials` or `headers`
         credentials: 'same-origin',
+        headers: {
+          // HTTP Header:  Cookie: <cookiename>=<cookievalue>
+          Cookie: `${'connect.sid'}=${getToken()['connect.sid']}`,
+        },
       },
     }),
   });
 }
 
-export default function initApollo(initialState) {
+export default function initApollo(initialState, options) {
   // Make sure to create a new client for every server-side request so that data
   // isn't shared between connections (which would be bad)
   if (!process.browser) {
-    return create(initialState);
+    return create(initialState, options);
   }
 
   // Reuse client on the client-side
   if (!apolloClient) {
-    apolloClient = create(initialState);
+    apolloClient = create(initialState, options);
   }
 
   return apolloClient;