却从未好好整理过我们的收藏夹", - "url": "https://xiaoshuapp.com/" - }, - { - "title": "探索者小舒", - "logo": "https://xiaoshuapp.com/explorer/icon.svg", - "color": "#665cd5", - "des": "以最轻松快捷的方式在侧栏切换搜索", - "slogan": "专业的操作不需要那么痛苦", - "url": "https://xiaoshuapp.com/explorer/" - }, - { - "title": "漫游云野", - "logo": "https://i.dawnlab.me/50929d62d1850bcc95495ff522ee127c.th.png/nexmoe", - "color": "#f04e45", - "des": "轻松随意地与你朋友分享你的宝藏，发现互联网上的秘宝", - "slogan": "让你的收藏不再是孤岛", - "url": "https://roam.mixcm.com" - }, + "configCard": "project", + "api": [ { - "title": "Monitor Pro", - "logo": "https://i.dawnlab.me/b49f4dc77408b1e5446ad667323e7eda.png", - "color": "#ff5454", - "des": "监控一切你在意的资源信息", - "slogan": "专业的操作不需要那么痛苦", - "url": "https://marketplace.visualstudio.com/items?itemName=nexmoe.monitor-pro" + "url": "http://localhost:3000/project.json", + "adapter": "roam_space" } ] }, { "homepage": "https://nex.xlog.app", + "title": "文章", "api": [ { "adapter": "rsshub_json", @@ -53,8 +26,7 @@ "adapter": "rsshub_json", "url": "https://nex.xlog.app/feed?format=json" } - ], - "title": "文章" + ] }, { "homepage": "https://github.com/nexmoe", @@ -65,7 +37,7 @@ } ], "title": "最近贡献", - "noTitle": true + "configNoTitle": true }, { "homepage": "https://www.xiaohongshu.com/user/profile/64ddaa5200000000010069c5", @@ -94,7 +66,7 @@ } ], "title": "社交媒体", - "noTitle": true + "configNoTitle": true }, { "homepage": "https://juejin.cn/column/7287241187447308345", @@ -119,7 +91,7 @@ } ], "title": "听歌总榜", - "card": "list", - "noContent": true + "configCard": "list", + "configNoContent": true } -] +] \ No newline at end of file diff --git a/env.d.ts b/env.d.ts new file mode 100644 index 0000000..3cf216b --- /dev/null +++ b/env.d.ts @@ -0,0 +1,7 @@ +// for svgo +declare module '*.svg' { + import type { DefineComponent } from 'vue' + + const component: DefineComponent + export default component +} diff --git a/eslint.config.js b/eslint.config.js index 15062d6..3dbb978 100644 --- a/eslint.config.js +++ b/eslint.config.js @@ -1,11 +1,8 @@ -// eslint.config.js -import antfu from '@antfu/eslint-config' +const antfu = require('@antfu/eslint-config').default -export default antfu({ +module.exports = antfu({ stylistic: { indent: 'tab', }, - // typescript: { - // tsconfigPath: 'tsconfig.json', - // }, + ignores: ['dist', '**/dist/**', 'public', '**/public/**', 'auto-imports.d.ts', '**/auto-imports.d.ts/**', 'components.d.ts', '**/components.d.ts/**', '.output', '**/.output/**', 'node_modules', '**/node_modules/**'], }) diff --git a/layouts/default.vue b/layouts/default.vue new file mode 100644 index 0000000..75af928 --- /dev/null +++ b/layouts/default.vue @@ -0,0 +1,34 @@ + + + + +
+
+
+
diff --git a/pages/index.vue b/pages/index.vue
index 9fe231e..73523b0 100644
--- a/pages/index.vue
+++ b/pages/index.vue
@@ -1,5 +1,21 @@
-
-
-
-
-
-
- (event)
- const name = decodeURI(getRouterParam(event, 'name') || '')
- const { flow: flows, config } = useConfig()
- const flow = flows.find(f => f.title === name)
- if (!flow || !flow.api) {
- setResponseStatus(event, 404)
- return {
- code: -1,
- message: 'Flow not found or flow is empty',
- data: [],
- ts: Date.now(),
- }
- }
-
- const tasks = flow.api.map((api) => {
- return (async () => {
- let apiUrlRetry = api.url
- let originIndex = 0
- while (originIndex < config.rsshub.origin.length) {
- apiUrlRetry = apiUrlRetry.includes('{rsshub}') ? apiUrlRetry.replace('{rsshub}', config.rsshub.origin[originIndex]) : apiUrlRetry
-
- try {
- consola.info(originIndex === 0 ? 'Fetching' : 'Retry fetching', apiUrlRetry)
- const res = await $fetch>(apiUrlRetry, {
- method: 'GET',
- parseResponse: JSON.parse,
- })
- consola.success('Success fetching', apiUrlRetry)
-
- return useAdapter(api.adapter, res).slice(0, 8)
- }
- catch (error) {
- consola.error('Error fetching', apiUrlRetry)
- consola.error(error)
- if (apiUrlRetry.includes('{rsshub}'))
- originIndex++
- else
- break
- }
- }
- throw new Error('All retry attempts failed')
- })()
- })
-
- const res = await Promise.allSettled(tasks)
-
- const response = res.flatMap(r => (r.status === 'fulfilled' ? [r.value] : []))
- const final = flow.api.length > 0 ? response.reduce(mergeArrays, []) : response
-
- // // store to supabase
- // const { error } = await supabase
- // .from('module')
- // .insert(final)
- // .select()
- // console.error(error)
-
- return {
- code: 0,
- message: 'ok',
- data: final,
- ts: Date.now(),
- }
-})
diff --git a/server/api/flow/flowing.get.ts b/server/api/flow/flowing.get.ts
new file mode 100644
index 0000000..990bb1c
--- /dev/null
+++ b/server/api/flow/flowing.get.ts
@@ -0,0 +1,7 @@
+import type { H3Event } from 'h3'
+import { flowing } from '~/server/flowing'
+
+export default eventHandler(async () => {
+ await flowing()
+ return 'yes'
+})
diff --git a/server/api/flow/import.get.ts b/server/api/flow/import.get.ts
new file mode 100644
index 0000000..e5b1ad9
--- /dev/null
+++ b/server/api/flow/import.get.ts
@@ -0,0 +1,20 @@
+import type { H3Event } from 'h3'
+import flowJson from '~/config/flow.json'
+
+export default eventHandler(async (event: H3Event) => {
+ const prisma = event.context.prisma
+ for (const flow of flowJson) {
+ await prisma.flow.create({
+ data: {
+ ...flow,
+ api: {
+ create: flow.api,
+ },
+ },
+ include: {
+ api: true,
+ },
+ })
+ }
+ return 'yes'
+})
diff --git a/server/api/flow/index.ts b/server/api/flow/index.ts
new file mode 100644
index 0000000..af474b5
--- /dev/null
+++ b/server/api/flow/index.ts
@@ -0,0 +1,23 @@
+import type { H3Event } from 'h3'
+import { flowingByFlowId } from '~/server/flowing'
+
+export default eventHandler(async (event: H3Event) => {
+ const prisma = event.context.prisma
+
+ const flows = await prisma.flow.findMany({
+ include: {
+ module: {
+ take: 9,
+ orderBy: { date: 'desc' },
+ },
+ },
+ orderBy: { index: 'asc' },
+ })
+
+ for (const flow of flows) {
+ if (flow.module.length === 0 && flow.id)
+ flowingByFlowId(flow.id)
+ }
+
+ return flows
+})
diff --git a/server/api/healthz.get.ts b/server/api/healthz.get.ts
new file mode 100644
index 0000000..57ae981
--- /dev/null
+++ b/server/api/healthz.get.ts
@@ -0,0 +1,23 @@
+import type { H3Event } from 'h3'
+
+const startupTime = new Date()
+
+const handler = eventHandler(async (event: H3Event) => {
+ const prisma = event.context.prisma
+ try {
+ await prisma.$queryRaw`SELECT 1;`
+ }
+ catch (error) {
+ throw createError({ statusCode: 500, statusMessage: 'DB failed initialization check' })
+ }
+
+ return {
+ status: 'healthy',
+ time: new Date(),
+ startupTime,
+ nuxtAppVersion: useRuntimeConfig().version || 'unknown',
+ }
+})
+
+export type HealthCheckData = Awaited>
+export default handler
diff --git a/server/api/module/[id].get.ts b/server/api/module/[id].get.ts
new file mode 100644
index 0000000..dd9c12f
--- /dev/null
+++ b/server/api/module/[id].get.ts
@@ -0,0 +1,10 @@
+import type { H3Event } from 'h3'
+
+export default eventHandler(async (event: H3Event) => {
+ const prisma = event.context.prisma
+ const { params } = event.context
+
+ return await prisma.module.findFirst({
+ where: { id: params?.id },
+ })
+})
diff --git a/server/api/space/[id].get.ts b/server/api/space/[id].get.ts
new file mode 100644
index 0000000..0b868ef
--- /dev/null
+++ b/server/api/space/[id].get.ts
@@ -0,0 +1,23 @@
+import type { H3Event } from 'h3'
+
+export default eventHandler(async (event: H3Event) => {
+ const prisma = event.context.prisma
+ const { params } = event.context
+
+ const space = prisma.space.findUnique({
+ where: { id: params?.id },
+ include: {
+ flow: {
+ orderBy: { index: "asc" },
+ include: {
+ module: {
+ take: 9,
+ orderBy: { date: "desc" },
+ },
+ },
+ },
+ },
+ })
+
+ return space
+})
diff --git a/server/flowing.ts b/server/flowing.ts
new file mode 100644
index 0000000..c770009
--- /dev/null
+++ b/server/flowing.ts
@@ -0,0 +1,152 @@
+import { consola } from 'consola'
+import { type API, type Flow, PrismaClient } from '@prisma/client'
+import type { NModule } from '~/composables/adapter/types'
+import useAdapter from '~/composables/adapter/useAdapter'
+import config from '~/config/config.json'
+
+const prisma = new PrismaClient()
+
+/**
+ * Calculate the Levenshtein distance between two strings.
+ *
+ * @param {string} a - the first string
+ * @param {string} b - the second string
+ * @return {number} the Levenshtein distance between the two strings
+ */
+function levenshteinDistance(a: string, b: string): number {
+ if (a.length === 0)
+ return b.length
+ if (b.length === 0)
+ return a.length
+
+ const matrix = Array.from(Array(a.length + 1), () =>
+ Array(b.length + 1).fill(0))
+
+ for (let i = 0; i <= a.length; i++)
+ matrix[i][0] = i
+
+ for (let j = 0; j <= b.length; j++)
+ matrix[0][j] = j
+
+ for (let i = 1; i <= a.length; i++) {
+ for (let j = 1; j <= b.length; j++) {
+ const cost = a[i - 1] === b[j - 1] ? 0 : 1
+ matrix[i][j] = Math.min(
+ matrix[i - 1][j] + 1,
+ matrix[i][j - 1] + 1,
+ matrix[i - 1][j - 1] + cost,
+ )
+ }
+ }
+
+ return matrix[a.length][b.length]
+}
+
+/**
+ * Merge two arrays of modules, ensuring uniqueness and updating platform information.
+ *
+ * @param {NModule[]} a - the first array of modules
+ * @param {NModule[]} b - the second array of modules
+ * @return {NModule[]} the merged array of modules
+ */
+function mergeArrays(a: NModule[], b: NModule[]): NModule[] {
+ for (const ele of b) {
+ const item = a.find((v) => {
+ const similarity = 1 - levenshteinDistance(v.title, ele.title) / Math.max(v.title.length, ele.title.length)
+ return similarity >= 0.9 // 设置相似度阈值为90%
+ })
+ if (!item) {
+ a.push(ele)
+ }
+ else if (Array.isArray(ele.platform)) {
+ for (const platform of ele.platform) {
+ if (!item.platform?.includes(platform)) {
+ if (!item.platform)
+ item.platform = [] as string[]
+ item.platform.push(platform)
+ }
+ }
+ }
+ }
+
+ a.sort((a, b) => {
+ const dateA = new Date(a.date).valueOf()
+ const dateB = new Date(b.date).valueOf()
+ return dateB - dateA
+ })
+
+ return a
+}
+
+export async function flowingByFlowId(flowId: string) {
+ const flow = await prisma.flow.findUnique({
+ where: { id: flowId },
+ include: {
+ api: true,
+ },
+ })
+ if (flow)
+ await flowingByFlow(flow)
+}
+
+async function flowingByFlow(flow: Flow) {
+ const tasks = flow.api.map((api: API) => {
+ return (async () => {
+ let originIndex = 0
+ while (originIndex < config.rsshub.origin.length) {
+ api.url = api.url.includes('{rsshub}') ? api.url.replace('{rsshub}', config.rsshub.origin[originIndex]) : api.url
+
+ try {
+ consola.info(originIndex === 0 ? 'Fetching' : 'Retry fetching', api.url)
+
+ const adapter = await useAdapter(api)
+ consola.success('Success fetching', api.url)
+
+ return adapter
+ }
+ catch (error) {
+ consola.error('Error fetching', api.url)
+ consola.error(error)
+ if (api.url.includes('{rsshub}'))
+ originIndex++
+ else
+ break
+ }
+ }
+ throw new Error('All retry attempts failed')
+ })()
+ })
+
+ const res = await Promise.allSettled(tasks)
+
+ const response = res.flatMap(r => (r.status === 'fulfilled' ? [r.value] : []))
+ const final = flow.api.length > 0 ? response.reduce(mergeArrays, []) : []
+
+ try {
+ for (const ele of final) {
+ await prisma.module.create({
+ data: {
+ ...ele,
+ date: ele.date || new Date().toISOString(),
+ flowId: flow.id,
+ },
+ })
+ }
+ }
+ catch (error) {
+ consola.error(error)
+ }
+}
+
+export async function flowing() {
+ consola.info('Flowing started')
+ const flows = await prisma.flow.findMany({
+ include: {
+ api: true,
+ },
+ })
+ for (const flow of flows)
+ await flowingByFlow(flow)
+
+ consola.success('Flowing end')
+}
diff --git a/server/middleware/0.prisma.ts b/server/middleware/0.prisma.ts
new file mode 100644
index 0000000..d61e767
--- /dev/null
+++ b/server/middleware/0.prisma.ts
@@ -0,0 +1,15 @@
+import { PrismaClient } from '@prisma/client'
+
+let prisma: PrismaClient
+declare module 'h3' {
+ interface H3EventContext {
+ prisma: PrismaClient
+ }
+}
+
+export default eventHandler((event) => {
+ if (!prisma)
+ prisma = new PrismaClient()
+
+ event.context.prisma = prisma
+})
diff --git a/server/plugins/scheduler.ts b/server/plugins/scheduler.ts
new file mode 100644
index 0000000..95c85f0
--- /dev/null
+++ b/server/plugins/scheduler.ts
@@ -0,0 +1,15 @@
+import { useScheduler } from '#scheduler'
+import { flowing } from '~/server/flowing'
+
+export default defineNitroPlugin(() => {
+ startScheduler()
+})
+
+function startScheduler() {
+ const scheduler = useScheduler()
+
+ // fetch every 1 hour
+ scheduler.run(async () => {
+ await flowing()
+ }).everyHours(1)
+}
diff --git a/server/tsconfig.json b/server/tsconfig.json
deleted file mode 100644
index d1dabed..0000000
--- a/server/tsconfig.json
+++ /dev/null
@@ -1,3 +0,0 @@
-{
- "extends": "../.nuxt/tsconfig.server.json"
-}
diff --git a/tailwind.config.ts b/tailwind.config.ts
deleted file mode 100644
index 9346770..0000000
--- a/tailwind.config.ts
+++ /dev/null
@@ -1,8 +0,0 @@
-import type { Config } from 'tailwindcss'
-
-// Default are on https://tailwindcss.nuxtjs.org/tailwind/config#default-configuration
-export default >{
- theme: {},
- plugins: [],
- content: [`composables/**/*.{js,ts,json}`],
-}
diff --git a/tests/app.test.ts b/tests/app.test.ts
new file mode 100644
index 0000000..f1863c3
--- /dev/null
+++ b/tests/app.test.ts
@@ -0,0 +1,24 @@
+import { describe, expect, it } from 'vitest'
+import { $fetch, setup } from '@nuxt/test-utils'
+import { expectNoClientErrors } from './utils'
+
+await setup({
+ server: true,
+ browser: true,
+})
+
+describe('app', () => {
+ it('renders welcome page', async () => {
+ const html = await $fetch('/')
+
+ // Shows expected text
+ expect(html).toContain('is the productive Nuxt 3 stack')
+
+ // Contains data from healthcheck endpoint
+ expect(html).toContain('Server v0.0.1 initialized')
+ expect(html).toContain('Started at ')
+ expect(html).toContain('Last checked at ')
+
+ await expectNoClientErrors('/')
+ })
+})
diff --git a/tests/server/api/example.test.ts b/tests/server/api/example.test.ts
new file mode 100644
index 0000000..b7e9493
--- /dev/null
+++ b/tests/server/api/example.test.ts
@@ -0,0 +1,100 @@
+import { beforeEach, describe, expect, it } from 'vitest'
+import { $fetch, setup } from '@nuxt/test-utils'
+import { faker } from '@faker-js/faker'
+import type { Prisma } from '@prisma/client'
+import { resetDatabase } from '~/prisma/utils'
+
+await setup({
+ server: true,
+ browser: false,
+})
+
+beforeEach(() => {
+ resetDatabase()
+})
+
+describe('/api/example/', () => {
+ it('gET returns an empty list when no examples exist', async () => {
+ const result = await $fetch('/api/example')
+ expect(result).toStrictEqual([])
+ })
+})
+
+describe('/api/example/:id', () => {
+ it('gET returns 404 when id does not exist', async () => {
+ const result = await $fetch('/api/example/1', {}).catch(error => error.data)
+ expect(result).toStrictEqual({
+ message: 'Failed to find example with id 1',
+ stack: '',
+ statusCode: 404,
+ statusMessage: 'Failed to find example with id 1',
+ url: '/api/example/1',
+ })
+ })
+
+ it('pUT creates an entity, then GET allows to fetch it', async () => {
+ // 1. Create the entity and assert that it has the correct shape & values
+ const exampleToCreate: Prisma.ExampleCreateInput = {
+ description: faker.lorem.paragraph(),
+ details: faker.lorem.paragraphs(),
+ }
+
+ const exampleAfterUpsert = await $fetch(`/api/example/${faker.datatype.uuid()}`, {
+ method: 'PUT',
+ body: exampleToCreate,
+ })
+
+ expect(Object.keys(exampleAfterUpsert).sort()).toEqual(['id', 'description', 'details'].sort())
+ expect(exampleAfterUpsert.details).toBe(exampleToCreate.details)
+ expect(exampleAfterUpsert.description).toBe(exampleToCreate.description)
+
+ // 2. Fetch the entity from the GET endpoint
+ const exampleFromGet = await $fetch(`/api/example/${exampleAfterUpsert.id}`)
+
+ expect(exampleFromGet).toStrictEqual(exampleAfterUpsert)
+ })
+
+ it('pUT creates and entity if none exists, then updates it on a second call', async () => {
+ // 1. Create the entity and assert that it has the correct shape & values
+ const exampleToCreate: Prisma.ExampleCreateInput = {
+ description: faker.lorem.paragraph(),
+ details: faker.lorem.paragraphs(),
+ }
+
+ const exampleAfterUpsert = await $fetch(`/api/example/${faker.datatype.uuid()}`, {
+ method: 'PUT',
+ body: exampleToCreate,
+ })
+
+ expect(Object.keys(exampleAfterUpsert).sort()).toEqual(['id', 'description', 'details'].sort())
+ expect(exampleAfterUpsert.details).toBe(exampleToCreate.details)
+ expect(exampleAfterUpsert.description).toBe(exampleToCreate.description)
+
+ // 2. Update the entity and check if the value has changed
+ const updatePayload: Prisma.ExampleUpdateInput = { description: faker.lorem.paragraphs(), details: faker.lorem.paragraphs() }
+ const exampleAfterUpdate = await $fetch(`/api/example/${faker.datatype.uuid()}`, {
+ method: 'PUT',
+ body: updatePayload,
+ })
+
+ expect(exampleAfterUpdate.description).toBe(updatePayload.description)
+ expect(exampleAfterUpdate.details).toBe(updatePayload.details)
+ })
+
+ it('pUT throws errors for invalid data', async () => {
+ // 1. Create the entity and assert that it has the correct shape & values
+ const exampleToCreate: Prisma.ExampleCreateInput = {
+ description: faker.lorem.paragraph(),
+ details: faker.lorem.paragraphs(),
+ }
+
+ const exampleAfterUpsert = await $fetch('/api/example/1', {
+ method: 'PUT',
+ body: exampleToCreate,
+ })
+
+ expect(Object.keys(exampleAfterUpsert).sort()).toEqual(['id', 'description', 'details'].sort())
+ expect(exampleAfterUpsert.details).toBe(exampleToCreate.details)
+ expect(exampleAfterUpsert.description).toBe(exampleToCreate.description)
+ })
+})
diff --git a/tests/server/api/healthz.test.ts b/tests/server/api/healthz.test.ts
new file mode 100644
index 0000000..267b7a5
--- /dev/null
+++ b/tests/server/api/healthz.test.ts
@@ -0,0 +1,22 @@
+import { describe, expect, it } from 'vitest'
+import { $fetch, setup } from '@nuxt/test-utils'
+import dayjs from 'dayjs'
+
+await setup({
+ server: true,
+ browser: false,
+})
+
+describe('gET /api/healthz', () => {
+ it('should return the current health status', async () => {
+ const response = await $fetch('/api/healthz')
+ expect(Object.keys(response).sort()).toEqual(['nuxtAppVersion', 'startupTime', 'status', 'time'].sort())
+
+ expect(response.nuxtAppVersion).toEqual('0.0.1')
+ expect(response.status).toEqual('healthy')
+
+ expect(dayjs(response.startupTime).isValid()).toBe(true)
+ expect(dayjs(response.time).isValid()).toBe(true)
+ expect(dayjs(response.startupTime) < dayjs(response.time))
+ })
+})
diff --git a/tests/setupSqliteDbEnv.ts b/tests/setupSqliteDbEnv.ts
new file mode 100644
index 0000000..ebf7f93
--- /dev/null
+++ b/tests/setupSqliteDbEnv.ts
@@ -0,0 +1,11 @@
+import { setAbsoluteSqliteDatabaseUrlForPrisma } from '../prisma/utils'
+
+/**
+ * Setup the database environment.
+ *
+ * This is necessary for the vanilla `sqlite` setup, as it depends on a file that is in an absolute place.
+ *
+ * As soon as the user adds a `.env` file overwriting `DATABASE_URL` or export `DATABSE_URL` themselves we do not want to set the database url manually any longer.
+ *
+ */
+export const setup = () => setAbsoluteSqliteDatabaseUrlForPrisma()
diff --git a/tests/utils.ts b/tests/utils.ts
new file mode 100644
index 0000000..90c12fd
--- /dev/null
+++ b/tests/utils.ts
@@ -0,0 +1,69 @@
+// from: https://github.com/nuxt/framework/blob/main/test/utils.ts
+import { expect } from 'vitest'
+import type { Page } from 'playwright'
+import { createPage, getBrowser, url, useTestContext } from '@nuxt/test-utils'
+
+export async function renderPage(path = '/') {
+ const ctx = useTestContext()
+ if (!ctx.options.browser)
+ throw new Error('`renderPage` require `options.browser` to be set')
+
+ const browser = await getBrowser()
+ const page = await browser.newPage({})
+ const pageErrors: Error[] = []
+ const consoleLogs: { type: string, text: string }[] = []
+
+ page.on('console', (message) => {
+ consoleLogs.push({
+ type: message.type(),
+ text: message.text(),
+ })
+ })
+ page.on('pageerror', (err) => {
+ pageErrors.push(err)
+ })
+
+ if (path)
+ await page.goto(url(path), { waitUntil: 'networkidle' })
+
+ return {
+ page,
+ pageErrors,
+ consoleLogs,
+ }
+}
+
+export async function expectNoClientErrors(path: string) {
+ const ctx = useTestContext()
+ if (!ctx.options.browser)
+ return
+
+ const { pageErrors, consoleLogs } = (await renderPage(path))!
+
+ const consoleLogErrors = consoleLogs.filter(i => i.type === 'error')
+ const consoleLogWarnings = consoleLogs.filter(i => i.type === 'warning')
+
+ expect(pageErrors).toEqual([])
+ expect(consoleLogErrors).toEqual([])
+ expect(consoleLogWarnings).toEqual([])
+}
+
+export async function withLogs(callback: (page: Page, logs: string[]) => Promise) {
+ let done = false
+ const page = await createPage()
+ const logs: string[] = []
+ page.on('console', (msg) => {
+ const text = msg.text()
+ if (done)
+ throw new Error('Test finished prematurely')
+
+ logs.push(text)
+ })
+
+ try {
+ await callback(page, logs)
+ }
+ finally {
+ done = true
+ }
+}
diff --git a/utils/parse.js b/utils/parse.js
index 655bda8..c701cbc 100644
--- a/utils/parse.js
+++ b/utils/parse.js
@@ -1,17 +1,9 @@
-export function getFirstImageSrc(html) {
- if (!html)
- return
- // 匹配第一个 ![]()
标签的 src 属性内容
- const regex = /]+src="([^">]+)"/
- const match = html.match(regex)
-
- // 如果匹配成功，则返回第一个匹配结果的 src 属性内容
- if (match && match.length > 1)
- return match[1].replace('http://', 'https://')
-
- // 如果没有匹配结果，则返回空字符串
-}
-
+/**
+ * Extracts text from HTML content and returns the first 300 characters.
+ *
+ * @param {string} html - The HTML content to extract text from
+ * @return {string} The extracted text, up to 300 characters
+ */
export function extractTextFromHTML(html) {
if (!html)
return
diff --git a/vitest.config.ts b/vitest.config.ts
new file mode 100644
index 0000000..194f7bc
--- /dev/null
+++ b/vitest.config.ts
@@ -0,0 +1,50 @@
+import path from 'node:path'
+import { defineConfig } from 'vitest/config'
+import vue from '@vitejs/plugin-vue'
+import svgLoader from 'vite-svg-loader'
+import Components from 'unplugin-vue-components/vite'
+import { NaiveUiResolver } from 'unplugin-vue-components/resolvers'
+import AutoImport from 'unplugin-auto-import/vite'
+
+const include = [/\.vue$/, /\.vue\?vue/, /\.stories\.ts$/, /\.[tj]s$/]
+
+export default defineConfig({
+ resolve: {
+ alias: {
+ '~': path.resolve(__dirname),
+ },
+ },
+ plugins: [
+ vue(),
+ Components({
+ dirs: ['~/components'],
+ directoryAsNamespace: true,
+ resolvers: [NaiveUiResolver()],
+ include,
+ }),
+ AutoImport({
+ include,
+ imports: ['vue', '@vueuse/head'],
+ dirs: ['~/composables'],
+ vueTemplate: true,
+ }),
+ svgLoader(),
+ ],
+ test: {
+ globalSetup: ['./tests/setupSqliteDbEnv'],
+ globals: true,
+ environment: 'jsdom',
+ threads: false,
+ coverage: {
+ enabled: true,
+ // We want to catch all js/ts/... files, not only the ones imported in some tests
+ // see https://github.com/bcoe/c8#checking-for-full-source-coverage-using---all
+ all: true,
+ include: [
+ // Nuxt 3 framework folders and files sources from directory structure here: https://nuxt.com/docs/guide/directory-structure/nuxt
+ 'components',
+ 'composables',
+ ],
+ },
+ },
+})
-
-
-
-
-
+
+
+
-
+
+
+
+
+
+
+
+
+
+
diff --git a/pages/space/[id].vue b/pages/space/[id].vue
new file mode 100644
index 0000000..375fb33
--- /dev/null
+++ b/pages/space/[id].vue
@@ -0,0 +1,40 @@
+
+
+
+ + {{ module.title }} +
+
+
+
+
+
+ {{ formatDateTime(module.date) }}
+
+
+
+
+
+
+
+
+
+