Broadcasting section

src/lib/articleContent/articleContentListing.ts

@@ -0,0 +1,58 @@
+import { readdir, readFile } from 'fs'
+import { promisify } from 'util'
+import { basename } from 'path'
+import { pipe, prop, sortBy, reverse, filter } from 'ramda'
+import fm from 'front-matter'
+import marked from 'marked'
+import {
+  filterAndCount,
+  type PaginationQuery,
+} from '$lib/pagination/pagination'
+import type { ArticleAttributes } from './articleContent'
+
+export interface ArticlePreviewAttributes extends ArticleAttributes {
+  preview: string
+}
+
+const { NODE_ENV } = process.env
+export async function getBlogListing(paginationQuery: PaginationQuery) {
+  const files = await promisify(readdir)(`_posts/blog/`, 'utf-8')
+  const filteredFiles = filterDevelopmentFiles(files)
+
+  const contents = await Promise.all(
+    filteredFiles.map(async (file) => {
+      const fileContent = await promisify(readFile)(
+        `_posts/blog/${file}`,
+        'utf-8'
+      )
+      const parsedAttributes = fm<ArticleAttributes>(fileContent)
+
+      const lineOfTextRegExp = /^(?:\w|\[).+/gm
+      const lines = parsedAttributes.body
+        .match(lineOfTextRegExp)
+        .slice(0, 2)
+        .join('\n')
+
+      const preview = marked(lines)
+      return {
+        ...parsedAttributes.attributes,
+        preview,
+        slug: basename(file, '.md'),
+      }
+    })
+  )
+  const filteredContents = pipe(
+    sortBy<ArticlePreviewAttributes>(prop('date')),
+    (items) => reverse(items),
+    filter<(typeof contents)[0]>((article) => article.published),
+    filterAndCount(paginationQuery)
+  )(contents)
+
+  return filteredContents
+}
+
+function filterDevelopmentFiles(files: string[]) {
+  return NODE_ENV !== 'production'
+    ? files
+    : files.filter((file) => !file.startsWith('dev-'))
+}