Class HnDatabase

server/database/database.ts:14–227

// https://github.com/HackerNews/API

export class HnDatabase {
  db: DatabaseReference;
  cache: HnCache;

  constructor(db: DatabaseReference, cache: HnCache) {
    this.db = db;
    this.cache = cache;
  }

  async fetchNewsItem(id: number): Promise<NewsItemModel | void> {
    logger('Fetching post:', `${HN_API_URL}/item/${id}.json`);

    return get(child(this.db, `item/${id}`))
      .then((postSnapshot) => {
        const post = postSnapshot.val();

        if (post !== null) {
          const newsItem = new NewsItemModel({
            id: post.id,
            creationTime: post.time * 1000,
            commentCount: post.descendants,
            comments: post.kids,
            submitterId: post.by,
            title: post.title,
            upvoteCount: post.score,
            url: post.url,
          });

          this.cache.setNewsItem(newsItem.id, newsItem);
          logger('Created Post:', post.id);

          return newsItem;
        }

        throw post;
      })
      .catch((reason) => logger('Fetching post failed:', reason));
  }

  async fetchComment(id: number): Promise<CommentModel | void> {
    logger('Fetching comment:', `${HN_API_URL}/item/${id}.json`);

    return get(child(this.db, `item/${id}`))
      .then((itemSnapshot) => {
        const item = itemSnapshot.val();

        if (item !== null && !item.deleted && !item.dead) {
          const comment = new CommentModel({
            comments: item.kids,
            creationTime: item.time * 1000,
            id: item.id,
            parent: item.parent,
            submitterId: item.by,
            text: item.text,
          });

          this.cache.setComment(comment.id, comment);
          logger('Created Comment:', item.id);