add job type/schema/resolver

Author: patinthehat

src/lib/resolver.ts

@@ -1,5 +1,6 @@
 import { MemoryCache } from '@/MemoryCache';
 import { getResolver as getCommentsResolver } from '@/resolvers/comments';
+import { getResolver as getJobsResolver } from '@/resolvers/jobs';
 import { getResolver as getStoriesResolver } from '@/resolvers/stories';
 import { getResolver as getStoryAuthorResolver } from '@/resolvers/Story/author';
 import { getResolver as getCommentCountResolver } from '@/resolvers/Story/commentCount';
@@ -8,15 +9,21 @@ import { getScalarType as getDateScalar } from '@/scalars/Date';
 
 const storyIds: number[] = [];
 const stories: Record<string, any>[] = [];
+const jobIds: number[] = [];
+const jobs: Record<string, any>[] = [];
 const cache = new MemoryCache();
 
 const dateScalar = getDateScalar();
 
 const resolvers = {
     query: {
         stories: getStoriesResolver(storyIds, stories, cache),
+        jobs: getJobsResolver(jobIds, jobs, cache),
         user: getUserResolver(cache),
     },
+    job: {
+        author: getStoryAuthorResolver(cache),
+    },
     story: {
         author: getStoryAuthorResolver(cache),
         comments: getCommentsResolver(cache),
@@ -30,9 +37,13 @@ const resolvers = {
 export default {
     Date: dateScalar,
     Query: {
+        jobs: resolvers.query.jobs,
         stories: resolvers.query.stories,
         user: resolvers.query.user,
     },
+    Job: {
+        author: resolvers.job.author,
+    },
     Story: {
         author: resolvers.story.author,
         comments: resolvers.story.comments,

src/lib/typedef.js

@@ -3,6 +3,7 @@ import { gql } from 'apollo-server-express';
 const typeDefs = gql`
     ${require('@/schemas/Comment.graphql')}
     ${require('@/schemas/Date.graphql')}
+    ${require('@/schemas/Job.graphql')}
     ${require('@/schemas/Query.graphql')}
     ${require('@/schemas/Story.graphql')}
     ${require('@/schemas/StoryType.graphql')}

src/resolvers/jobs.ts

@@ -0,0 +1,56 @@
+import { MemoryCache } from '@/MemoryCache';
+import axios from 'axios';
+
+export function getResolver(storyIds, stories, cache: MemoryCache): any {
+    const result = async (_, { first, skipText }) => {
+        const kind = 'job';
+
+        storyIds.splice(0, storyIds.length);
+        stories.splice(0, stories.length);
+
+        const ids: number[] = [];
+        const cacheKey = `jobstoryids:${first}-${skipText ? 'skipText' : 'dontSkipText'}`;
+
+        if (!cache.has(cacheKey)) {
+            const resp = await axios.get(`${process.env.HACKERNEWS_API_URL}/jobstories.json?limitToFirst=${first + 5}&orderBy="$key"`);
+            const data: number[] = resp.data;
+
+            cache.put(cacheKey, data, 600);
+            ids.push(...data);
+        }
+
+        const cacheData = cache.get(cacheKey);
+
+        ids.push(...cacheData);
+        ids.splice(first);
+
+        const storyDataPromises = ids
+            .map(id => {
+                if (cache.has(`${kind}story:${id}`)) {
+                    return null;
+                }
+
+                return axios.get(`${process.env.HACKERNEWS_API_URL}/item/${id}.json`);
+            })
+            .filter(item => item !== null);
+
+        (await Promise.all(storyDataPromises))
+            .map(resp => resp?.data)
+            .filter(item => item !== null)
+            .forEach(item => {
+                cache.put(`${kind}story:${item.id}`, item, 3600);
+            });
+
+        for (const id of ids) {
+            const storyItem = cache.get(`${kind}story:${id}`);
+
+            if (!storyItem.text || !skipText) {
+                stories.push(storyItem);
+            }
+        }
+
+        return new Promise(resolve => resolve(stories));
+    };
+
+    return result;
+}

src/schemas/Job.graphql

@@ -0,0 +1,11 @@
+type Job {
+  author: User
+  by: String
+  id: Int!
+  score: Int
+  text: String
+  time: Date
+  title: String
+  type: String
+  url: String
+}

src/schemas/Query.graphql

@@ -1,4 +1,5 @@
 type Query {
-  stories(first: Int!, kind: StoryType!): [Story]
-  user(id: String!): User
+    jobs(first: Int!, skipText: Boolean = True): [Job]!
+    stories(first: Int!, kind: StoryType!): [Story]!
+    user(id: String!): User
 }