mirror of
https://github.com/kennethnym/aris.git
synced 2026-03-20 00:51:20 +00:00
Compare commits
1 Commits
feat/feed-
...
feat/feed-
| Author | SHA1 | Date | |
|---|---|---|---|
|
cc0193536e
|
42
.github/workflows/build-waitlist-website.yml
vendored
42
.github/workflows/build-waitlist-website.yml
vendored
@@ -1,42 +0,0 @@
|
|||||||
name: Build waitlist website
|
|
||||||
|
|
||||||
on:
|
|
||||||
push:
|
|
||||||
branches: [master]
|
|
||||||
paths:
|
|
||||||
- apps/waitlist-website/**
|
|
||||||
- .github/workflows/build-waitlist-website.yml
|
|
||||||
|
|
||||||
workflow_dispatch:
|
|
||||||
|
|
||||||
env:
|
|
||||||
REGISTRY: cr.nym.sh
|
|
||||||
IMAGE_NAME: aelis-waitlist-website
|
|
||||||
|
|
||||||
jobs:
|
|
||||||
build:
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
|
|
||||||
steps:
|
|
||||||
- uses: actions/checkout@v4
|
|
||||||
|
|
||||||
- name: Log in to container registry
|
|
||||||
uses: docker/login-action@v3
|
|
||||||
with:
|
|
||||||
registry: ${{ env.REGISTRY }}
|
|
||||||
username: ${{ secrets.REGISTRY_USERNAME }}
|
|
||||||
password: ${{ secrets.REGISTRY_PASSWORD }}
|
|
||||||
|
|
||||||
- name: Set up Docker Buildx
|
|
||||||
uses: docker/setup-buildx-action@v3
|
|
||||||
|
|
||||||
- name: Build and push
|
|
||||||
uses: docker/build-push-action@v6
|
|
||||||
with:
|
|
||||||
context: apps/waitlist-website
|
|
||||||
push: true
|
|
||||||
tags: |
|
|
||||||
${{ env.REGISTRY }}/${{ env.IMAGE_NAME }}:latest
|
|
||||||
${{ env.REGISTRY }}/${{ env.IMAGE_NAME }}:${{ github.sha }}
|
|
||||||
cache-from: type=gha
|
|
||||||
cache-to: type=gha,mode=max
|
|
||||||
2
.github/workflows/test.yml
vendored
2
.github/workflows/test.yml
vendored
@@ -21,4 +21,4 @@ jobs:
|
|||||||
run: bun install --frozen-lockfile
|
run: bun install --frozen-lockfile
|
||||||
|
|
||||||
- name: Run tests
|
- name: Run tests
|
||||||
run: bun run test
|
run: bun test
|
||||||
|
|||||||
@@ -15,7 +15,6 @@
|
|||||||
"@aelis/source-location": "workspace:*",
|
"@aelis/source-location": "workspace:*",
|
||||||
"@aelis/source-tfl": "workspace:*",
|
"@aelis/source-tfl": "workspace:*",
|
||||||
"@aelis/source-weatherkit": "workspace:*",
|
"@aelis/source-weatherkit": "workspace:*",
|
||||||
"@nym.sh/jrx": "^0.2.0",
|
|
||||||
"@openrouter/sdk": "^0.9.11",
|
"@openrouter/sdk": "^0.9.11",
|
||||||
"arktype": "^2.1.29",
|
"arktype": "^2.1.29",
|
||||||
"better-auth": "^1",
|
"better-auth": "^1",
|
||||||
|
|||||||
@@ -1,7 +0,0 @@
|
|||||||
import type { FeedItemRenderer } from "@aelis/core"
|
|
||||||
|
|
||||||
import { renderCalDavFeedItem } from "@aelis/source-caldav"
|
|
||||||
|
|
||||||
export const CALDAV_SOURCE_ID = "aelis.caldav"
|
|
||||||
|
|
||||||
export const calDavRenderer: FeedItemRenderer = renderCalDavFeedItem as FeedItemRenderer
|
|
||||||
@@ -1,19 +1,10 @@
|
|||||||
import type {
|
import type { ActionDefinition, ContextEntry, FeedItem, FeedSource } from "@aelis/core"
|
||||||
ActionDefinition,
|
|
||||||
ContextEntry,
|
|
||||||
FeedItem,
|
|
||||||
FeedItemRenderer,
|
|
||||||
FeedSource,
|
|
||||||
} from "@aelis/core"
|
|
||||||
import type { Spec } from "@json-render/core"
|
|
||||||
|
|
||||||
import { contextKey } from "@aelis/core"
|
import { contextKey } from "@aelis/core"
|
||||||
import { JRX_NODE } from "@nym.sh/jrx"
|
|
||||||
import { describe, expect, test } from "bun:test"
|
import { describe, expect, test } from "bun:test"
|
||||||
import { Hono } from "hono"
|
import { Hono } from "hono"
|
||||||
|
|
||||||
import { mockAuthSessionMiddleware } from "../auth/session-middleware.ts"
|
import { mockAuthSessionMiddleware } from "../auth/session-middleware.ts"
|
||||||
import { FeedRenderer } from "../session/feed-renderer.ts"
|
|
||||||
import { UserSessionManager } from "../session/index.ts"
|
import { UserSessionManager } from "../session/index.ts"
|
||||||
import { registerFeedHttpHandlers } from "./http.ts"
|
import { registerFeedHttpHandlers } from "./http.ts"
|
||||||
|
|
||||||
@@ -28,17 +19,6 @@ interface FeedResponse {
|
|||||||
errors: Array<{ sourceId: string; error: string }>
|
errors: Array<{ sourceId: string; error: string }>
|
||||||
}
|
}
|
||||||
|
|
||||||
interface RenderedFeedResponse {
|
|
||||||
items: Array<{
|
|
||||||
id: string
|
|
||||||
type: string
|
|
||||||
timestamp: string
|
|
||||||
data: Record<string, unknown>
|
|
||||||
ui: Spec
|
|
||||||
}>
|
|
||||||
errors: Array<{ sourceId: string; error: string }>
|
|
||||||
}
|
|
||||||
|
|
||||||
function createStubSource(
|
function createStubSource(
|
||||||
id: string,
|
id: string,
|
||||||
items: FeedItem[] = [],
|
items: FeedItem[] = [],
|
||||||
@@ -170,168 +150,6 @@ describe("GET /api/feed", () => {
|
|||||||
})
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
describe("GET /api/feed?render=json-render", () => {
|
|
||||||
const stubRenderer: FeedItemRenderer = (item) => ({
|
|
||||||
$$typeof: JRX_NODE,
|
|
||||||
type: "FeedCard",
|
|
||||||
props: {},
|
|
||||||
children: [
|
|
||||||
{
|
|
||||||
$$typeof: JRX_NODE,
|
|
||||||
type: "SansSerifText",
|
|
||||||
props: { content: `Rendered: ${item.data.value}` },
|
|
||||||
children: [],
|
|
||||||
key: undefined,
|
|
||||||
visible: undefined,
|
|
||||||
on: undefined,
|
|
||||||
repeat: undefined,
|
|
||||||
watch: undefined,
|
|
||||||
},
|
|
||||||
],
|
|
||||||
key: undefined,
|
|
||||||
visible: undefined,
|
|
||||||
on: undefined,
|
|
||||||
repeat: undefined,
|
|
||||||
watch: undefined,
|
|
||||||
})
|
|
||||||
|
|
||||||
const rendererProvider = {
|
|
||||||
feedRendererForUser: () => new FeedRenderer({ "test-source": stubRenderer }),
|
|
||||||
}
|
|
||||||
|
|
||||||
test("returns rendered items with ui field as Spec", async () => {
|
|
||||||
const items: FeedItem[] = [
|
|
||||||
{
|
|
||||||
id: "item-1",
|
|
||||||
sourceId: "test-source",
|
|
||||||
type: "renderable",
|
|
||||||
timestamp: new Date("2025-01-01T00:00:00.000Z"),
|
|
||||||
data: { value: "hello" },
|
|
||||||
},
|
|
||||||
]
|
|
||||||
const manager = new UserSessionManager({
|
|
||||||
providers: [() => createStubSource("test", items)],
|
|
||||||
rendererProvider,
|
|
||||||
})
|
|
||||||
const app = buildTestApp(manager, "user-1")
|
|
||||||
|
|
||||||
const res = await app.request("/api/feed?render=json-render")
|
|
||||||
|
|
||||||
expect(res.status).toBe(200)
|
|
||||||
const body = (await res.json()) as RenderedFeedResponse
|
|
||||||
expect(body.items).toHaveLength(1)
|
|
||||||
expect(body.items[0]!.id).toBe("item-1")
|
|
||||||
expect(body.items[0]!.ui).toBeDefined()
|
|
||||||
expect(body.items[0]!.ui.root).toBeDefined()
|
|
||||||
expect(body.items[0]!.ui.elements).toBeDefined()
|
|
||||||
})
|
|
||||||
|
|
||||||
test("drops items without a renderer", async () => {
|
|
||||||
const items: FeedItem[] = [
|
|
||||||
{
|
|
||||||
id: "renderable-1",
|
|
||||||
sourceId: "test-source",
|
|
||||||
type: "renderable",
|
|
||||||
timestamp: new Date("2025-01-01T00:00:00.000Z"),
|
|
||||||
data: { value: "yes" },
|
|
||||||
},
|
|
||||||
{
|
|
||||||
id: "unrenderable-1",
|
|
||||||
sourceId: "other-source",
|
|
||||||
type: "no-renderer",
|
|
||||||
timestamp: new Date("2025-01-01T00:00:00.000Z"),
|
|
||||||
data: { value: "no" },
|
|
||||||
},
|
|
||||||
]
|
|
||||||
const manager = new UserSessionManager({
|
|
||||||
providers: [() => createStubSource("test", items)],
|
|
||||||
rendererProvider,
|
|
||||||
})
|
|
||||||
const app = buildTestApp(manager, "user-1")
|
|
||||||
|
|
||||||
const res = await app.request("/api/feed?render=json-render")
|
|
||||||
|
|
||||||
expect(res.status).toBe(200)
|
|
||||||
const body = (await res.json()) as RenderedFeedResponse
|
|
||||||
expect(body.items).toHaveLength(1)
|
|
||||||
expect(body.items[0]!.id).toBe("renderable-1")
|
|
||||||
})
|
|
||||||
|
|
||||||
test("returns empty items when no renderers match", async () => {
|
|
||||||
const items: FeedItem[] = [
|
|
||||||
{
|
|
||||||
id: "item-1",
|
|
||||||
sourceId: "other-source",
|
|
||||||
type: "no-renderer",
|
|
||||||
timestamp: new Date("2025-01-01T00:00:00.000Z"),
|
|
||||||
data: { value: 42 },
|
|
||||||
},
|
|
||||||
]
|
|
||||||
const manager = new UserSessionManager({
|
|
||||||
providers: [() => createStubSource("test", items)],
|
|
||||||
rendererProvider,
|
|
||||||
})
|
|
||||||
const app = buildTestApp(manager, "user-1")
|
|
||||||
|
|
||||||
const res = await app.request("/api/feed?render=json-render")
|
|
||||||
|
|
||||||
expect(res.status).toBe(200)
|
|
||||||
const body = (await res.json()) as RenderedFeedResponse
|
|
||||||
expect(body.items).toHaveLength(0)
|
|
||||||
})
|
|
||||||
|
|
||||||
test("returns 400 for unknown render format", async () => {
|
|
||||||
const manager = new UserSessionManager({
|
|
||||||
providers: [() => createStubSource("test")],
|
|
||||||
rendererProvider,
|
|
||||||
})
|
|
||||||
const app = buildTestApp(manager, "user-1")
|
|
||||||
|
|
||||||
const res = await app.request("/api/feed?render=unknown")
|
|
||||||
|
|
||||||
expect(res.status).toBe(400)
|
|
||||||
const body = (await res.json()) as { error: string }
|
|
||||||
expect(body.error).toContain("unknown")
|
|
||||||
})
|
|
||||||
|
|
||||||
test("returns 500 when renderer is not available", async () => {
|
|
||||||
const manager = new UserSessionManager({
|
|
||||||
providers: [() => createStubSource("test")],
|
|
||||||
})
|
|
||||||
const app = buildTestApp(manager, "user-1")
|
|
||||||
|
|
||||||
const res = await app.request("/api/feed?render=json-render")
|
|
||||||
|
|
||||||
expect(res.status).toBe(500)
|
|
||||||
const body = (await res.json()) as { error: string }
|
|
||||||
expect(body.error).toContain("not available")
|
|
||||||
})
|
|
||||||
|
|
||||||
test("without render param returns raw items (no ui field)", async () => {
|
|
||||||
const items: FeedItem[] = [
|
|
||||||
{
|
|
||||||
id: "item-1",
|
|
||||||
sourceId: "test-source",
|
|
||||||
type: "renderable",
|
|
||||||
timestamp: new Date("2025-01-01T00:00:00.000Z"),
|
|
||||||
data: { value: 42 },
|
|
||||||
},
|
|
||||||
]
|
|
||||||
const manager = new UserSessionManager({
|
|
||||||
providers: [() => createStubSource("test", items)],
|
|
||||||
rendererProvider,
|
|
||||||
})
|
|
||||||
const app = buildTestApp(manager, "user-1")
|
|
||||||
|
|
||||||
const res = await app.request("/api/feed")
|
|
||||||
|
|
||||||
expect(res.status).toBe(200)
|
|
||||||
const body = (await res.json()) as FeedResponse
|
|
||||||
expect(body.items).toHaveLength(1)
|
|
||||||
expect(body.items[0]!).not.toHaveProperty("ui")
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
describe("GET /api/context", () => {
|
describe("GET /api/context", () => {
|
||||||
const weatherKey = contextKey("aelis.weather", "weather")
|
const weatherKey = contextKey("aelis.weather", "weather")
|
||||||
const weatherData = { temperature: 20, condition: "Clear" }
|
const weatherData = { temperature: 20, condition: "Clear" }
|
||||||
|
|||||||
@@ -1,7 +1,6 @@
|
|||||||
import type { Context, Hono } from "hono"
|
import type { Context, Hono } from "hono"
|
||||||
|
|
||||||
import { contextKey } from "@aelis/core"
|
import { contextKey } from "@aelis/core"
|
||||||
import { render } from "@nym.sh/jrx"
|
|
||||||
import { createMiddleware } from "hono/factory"
|
import { createMiddleware } from "hono/factory"
|
||||||
|
|
||||||
import type { AuthSessionMiddleware } from "../auth/session-middleware.ts"
|
import type { AuthSessionMiddleware } from "../auth/session-middleware.ts"
|
||||||
@@ -38,31 +37,6 @@ async function handleGetFeed(c: Context<Env>) {
|
|||||||
|
|
||||||
const feed = await session.feed()
|
const feed = await session.feed()
|
||||||
|
|
||||||
const renderParam = c.req.query("render")
|
|
||||||
|
|
||||||
if (renderParam !== undefined) {
|
|
||||||
if (renderParam !== "json-render") {
|
|
||||||
return c.json({ error: `Unknown render format: "${renderParam}"` }, 400)
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!session.renderer) {
|
|
||||||
return c.json({ error: "Rendering is not available" }, 500)
|
|
||||||
}
|
|
||||||
|
|
||||||
const renderedItems = session.renderer.render(feed.items).map((item) => ({
|
|
||||||
...item,
|
|
||||||
ui: render(item.ui),
|
|
||||||
}))
|
|
||||||
|
|
||||||
return c.json({
|
|
||||||
items: renderedItems,
|
|
||||||
errors: feed.errors.map((e) => ({
|
|
||||||
sourceId: e.sourceId,
|
|
||||||
error: e.error.message,
|
|
||||||
})),
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
return c.json({
|
return c.json({
|
||||||
items: feed.items,
|
items: feed.items,
|
||||||
errors: feed.errors.map((e) => ({
|
errors: feed.errors.map((e) => ({
|
||||||
|
|||||||
@@ -3,13 +3,11 @@ import { Hono } from "hono"
|
|||||||
|
|
||||||
import { registerAuthHandlers } from "./auth/http.ts"
|
import { registerAuthHandlers } from "./auth/http.ts"
|
||||||
import { mockAuthSessionMiddleware, requireSession } from "./auth/session-middleware.ts"
|
import { mockAuthSessionMiddleware, requireSession } from "./auth/session-middleware.ts"
|
||||||
import { CALDAV_SOURCE_ID, calDavRenderer } from "./caldav/renderer-provider.ts"
|
|
||||||
import { registerFeedHttpHandlers } from "./engine/http.ts"
|
|
||||||
import { createFeedEnhancer } from "./enhancement/enhance-feed.ts"
|
import { createFeedEnhancer } from "./enhancement/enhance-feed.ts"
|
||||||
import { createLlmClient } from "./enhancement/llm-client.ts"
|
import { createLlmClient } from "./enhancement/llm-client.ts"
|
||||||
|
import { registerFeedHttpHandlers } from "./engine/http.ts"
|
||||||
import { registerLocationHttpHandlers } from "./location/http.ts"
|
import { registerLocationHttpHandlers } from "./location/http.ts"
|
||||||
import { FeedRenderer, UserSessionManager } from "./session/index.ts"
|
import { UserSessionManager } from "./session/index.ts"
|
||||||
import { TFL_SOURCE_ID, tflRenderer } from "./tfl/renderer-provider.ts"
|
|
||||||
import { WeatherSourceProvider } from "./weather/provider.ts"
|
import { WeatherSourceProvider } from "./weather/provider.ts"
|
||||||
|
|
||||||
function main() {
|
function main() {
|
||||||
@@ -26,11 +24,6 @@ function main() {
|
|||||||
console.warn("[enhancement] OPENROUTER_API_KEY not set — feed enhancement disabled")
|
console.warn("[enhancement] OPENROUTER_API_KEY not set — feed enhancement disabled")
|
||||||
}
|
}
|
||||||
|
|
||||||
const allRenderers = {
|
|
||||||
[TFL_SOURCE_ID]: tflRenderer,
|
|
||||||
[CALDAV_SOURCE_ID]: calDavRenderer,
|
|
||||||
}
|
|
||||||
|
|
||||||
const sessionManager = new UserSessionManager({
|
const sessionManager = new UserSessionManager({
|
||||||
providers: [
|
providers: [
|
||||||
() => new LocationSource(),
|
() => new LocationSource(),
|
||||||
@@ -43,9 +36,6 @@ function main() {
|
|||||||
},
|
},
|
||||||
}),
|
}),
|
||||||
],
|
],
|
||||||
rendererProvider: {
|
|
||||||
feedRendererForUser: (_userId) => new FeedRenderer(allRenderers),
|
|
||||||
},
|
|
||||||
feedEnhancer,
|
feedEnhancer,
|
||||||
})
|
})
|
||||||
|
|
||||||
|
|||||||
@@ -1,30 +0,0 @@
|
|||||||
import type { FeedItem, FeedItemRenderer, RenderedFeedItem } from "@aelis/core"
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Renders feed items using registered renderers.
|
|
||||||
*
|
|
||||||
* Constructed with a map of source ID to renderer function.
|
|
||||||
* Items whose source has no renderer are silently dropped.
|
|
||||||
*/
|
|
||||||
export class FeedRenderer {
|
|
||||||
private readonly renderers: Map<string, FeedItemRenderer>
|
|
||||||
|
|
||||||
constructor(renderers: Record<string, FeedItemRenderer>) {
|
|
||||||
this.renderers = new Map(Object.entries(renderers))
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Renders an array of feed items. Items whose sourceId has no
|
|
||||||
* registered renderer are silently dropped from the result.
|
|
||||||
*/
|
|
||||||
render(items: FeedItem[]): RenderedFeedItem[] {
|
|
||||||
const result: RenderedFeedItem[] = []
|
|
||||||
for (const item of items) {
|
|
||||||
const renderer = this.renderers.get(item.sourceId)
|
|
||||||
if (renderer) {
|
|
||||||
result.push({ ...item, ui: renderer(item) })
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return result
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -3,7 +3,5 @@ export type {
|
|||||||
FeedSourceProviderFn,
|
FeedSourceProviderFn,
|
||||||
FeedSourceProviderInput,
|
FeedSourceProviderInput,
|
||||||
} from "./feed-source-provider.ts"
|
} from "./feed-source-provider.ts"
|
||||||
export { FeedRenderer } from "./feed-renderer.ts"
|
|
||||||
export type { FeedRendererProvider } from "./renderer-provider.ts"
|
|
||||||
export { UserSession } from "./user-session.ts"
|
export { UserSession } from "./user-session.ts"
|
||||||
export { UserSessionManager } from "./user-session-manager.ts"
|
export { UserSessionManager } from "./user-session-manager.ts"
|
||||||
|
|||||||
@@ -1,5 +0,0 @@
|
|||||||
import type { FeedRenderer } from "./feed-renderer.ts"
|
|
||||||
|
|
||||||
export interface FeedRendererProvider {
|
|
||||||
feedRendererForUser(userId: string): FeedRenderer
|
|
||||||
}
|
|
||||||
@@ -1,24 +1,20 @@
|
|||||||
import type { FeedEnhancer } from "../enhancement/enhance-feed.ts"
|
import type { FeedEnhancer } from "../enhancement/enhance-feed.ts"
|
||||||
import type { FeedSourceProviderInput } from "./feed-source-provider.ts"
|
import type { FeedSourceProviderInput } from "./feed-source-provider.ts"
|
||||||
import type { FeedRendererProvider } from "./renderer-provider.ts"
|
|
||||||
|
|
||||||
import { UserSession } from "./user-session.ts"
|
import { UserSession } from "./user-session.ts"
|
||||||
|
|
||||||
export interface UserSessionManagerConfig {
|
export interface UserSessionManagerConfig {
|
||||||
providers: FeedSourceProviderInput[]
|
providers: FeedSourceProviderInput[]
|
||||||
rendererProvider?: FeedRendererProvider | null
|
|
||||||
feedEnhancer?: FeedEnhancer | null
|
feedEnhancer?: FeedEnhancer | null
|
||||||
}
|
}
|
||||||
|
|
||||||
export class UserSessionManager {
|
export class UserSessionManager {
|
||||||
private sessions = new Map<string, UserSession>()
|
private sessions = new Map<string, UserSession>()
|
||||||
private readonly providers: FeedSourceProviderInput[]
|
private readonly providers: FeedSourceProviderInput[]
|
||||||
private readonly rendererProvider: FeedRendererProvider | null
|
|
||||||
private readonly feedEnhancer: FeedEnhancer | null
|
private readonly feedEnhancer: FeedEnhancer | null
|
||||||
|
|
||||||
constructor(config: UserSessionManagerConfig) {
|
constructor(config: UserSessionManagerConfig) {
|
||||||
this.providers = config.providers
|
this.providers = config.providers
|
||||||
this.rendererProvider = config.rendererProvider ?? null
|
|
||||||
this.feedEnhancer = config.feedEnhancer ?? null
|
this.feedEnhancer = config.feedEnhancer ?? null
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -28,11 +24,7 @@ export class UserSessionManager {
|
|||||||
const sources = this.providers.map((p) =>
|
const sources = this.providers.map((p) =>
|
||||||
typeof p === "function" ? p(userId) : p.feedSourceForUser(userId),
|
typeof p === "function" ? p(userId) : p.feedSourceForUser(userId),
|
||||||
)
|
)
|
||||||
session = new UserSession({
|
session = new UserSession(sources, this.feedEnhancer)
|
||||||
sources,
|
|
||||||
enhancer: this.feedEnhancer,
|
|
||||||
renderer: this.rendererProvider?.feedRendererForUser(userId) ?? null,
|
|
||||||
})
|
|
||||||
this.sessions.set(userId, session)
|
this.sessions.set(userId, session)
|
||||||
}
|
}
|
||||||
return session
|
return session
|
||||||
|
|||||||
@@ -1,16 +1,8 @@
|
|||||||
import type {
|
import type { ActionDefinition, ContextEntry, FeedItem, FeedSource } from "@aelis/core"
|
||||||
ActionDefinition,
|
|
||||||
ContextEntry,
|
|
||||||
FeedItem,
|
|
||||||
FeedItemRenderer,
|
|
||||||
FeedSource,
|
|
||||||
} from "@aelis/core"
|
|
||||||
|
|
||||||
import { LocationSource } from "@aelis/source-location"
|
import { LocationSource } from "@aelis/source-location"
|
||||||
import { JRX_NODE } from "@nym.sh/jrx"
|
|
||||||
import { describe, expect, test } from "bun:test"
|
import { describe, expect, test } from "bun:test"
|
||||||
|
|
||||||
import { FeedRenderer } from "./feed-renderer.ts"
|
|
||||||
import { UserSession } from "./user-session.ts"
|
import { UserSession } from "./user-session.ts"
|
||||||
|
|
||||||
function createStubSource(id: string, items: FeedItem[] = []): FeedSource {
|
function createStubSource(id: string, items: FeedItem[] = []): FeedSource {
|
||||||
@@ -33,9 +25,7 @@ function createStubSource(id: string, items: FeedItem[] = []): FeedSource {
|
|||||||
|
|
||||||
describe("UserSession", () => {
|
describe("UserSession", () => {
|
||||||
test("registers sources and starts engine", async () => {
|
test("registers sources and starts engine", async () => {
|
||||||
const session = new UserSession({
|
const session = new UserSession([createStubSource("test-a"), createStubSource("test-b")])
|
||||||
sources: [createStubSource("test-a"), createStubSource("test-b")],
|
|
||||||
})
|
|
||||||
|
|
||||||
const result = await session.engine.refresh()
|
const result = await session.engine.refresh()
|
||||||
|
|
||||||
@@ -44,7 +34,7 @@ describe("UserSession", () => {
|
|||||||
|
|
||||||
test("getSource returns registered source", () => {
|
test("getSource returns registered source", () => {
|
||||||
const location = new LocationSource()
|
const location = new LocationSource()
|
||||||
const session = new UserSession({ sources: [location] })
|
const session = new UserSession([location])
|
||||||
|
|
||||||
const result = session.getSource<LocationSource>("aelis.location")
|
const result = session.getSource<LocationSource>("aelis.location")
|
||||||
|
|
||||||
@@ -52,13 +42,13 @@ describe("UserSession", () => {
|
|||||||
})
|
})
|
||||||
|
|
||||||
test("getSource returns undefined for unknown source", () => {
|
test("getSource returns undefined for unknown source", () => {
|
||||||
const session = new UserSession({ sources: [createStubSource("test")] })
|
const session = new UserSession([createStubSource("test")])
|
||||||
|
|
||||||
expect(session.getSource("unknown")).toBeUndefined()
|
expect(session.getSource("unknown")).toBeUndefined()
|
||||||
})
|
})
|
||||||
|
|
||||||
test("destroy stops engine and clears sources", () => {
|
test("destroy stops engine and clears sources", () => {
|
||||||
const session = new UserSession({ sources: [createStubSource("test")] })
|
const session = new UserSession([createStubSource("test")])
|
||||||
|
|
||||||
session.destroy()
|
session.destroy()
|
||||||
|
|
||||||
@@ -67,7 +57,7 @@ describe("UserSession", () => {
|
|||||||
|
|
||||||
test("engine.executeAction routes to correct source", async () => {
|
test("engine.executeAction routes to correct source", async () => {
|
||||||
const location = new LocationSource()
|
const location = new LocationSource()
|
||||||
const session = new UserSession({ sources: [location] })
|
const session = new UserSession([location])
|
||||||
|
|
||||||
await session.engine.executeAction("aelis.location", "update-location", {
|
await session.engine.executeAction("aelis.location", "update-location", {
|
||||||
lat: 51.5,
|
lat: 51.5,
|
||||||
@@ -92,7 +82,7 @@ describe("UserSession.feed", () => {
|
|||||||
data: { value: 42 },
|
data: { value: 42 },
|
||||||
},
|
},
|
||||||
]
|
]
|
||||||
const session = new UserSession({ sources: [createStubSource("test", items)] })
|
const session = new UserSession([createStubSource("test", items)])
|
||||||
|
|
||||||
const result = await session.feed()
|
const result = await session.feed()
|
||||||
|
|
||||||
@@ -113,7 +103,7 @@ describe("UserSession.feed", () => {
|
|||||||
const enhancer = async (feedItems: FeedItem[]) =>
|
const enhancer = async (feedItems: FeedItem[]) =>
|
||||||
feedItems.map((item) => ({ ...item, data: { ...item.data, enhanced: true } }))
|
feedItems.map((item) => ({ ...item, data: { ...item.data, enhanced: true } }))
|
||||||
|
|
||||||
const session = new UserSession({ sources: [createStubSource("test", items)], enhancer })
|
const session = new UserSession([createStubSource("test", items)], enhancer)
|
||||||
|
|
||||||
const result = await session.feed()
|
const result = await session.feed()
|
||||||
|
|
||||||
@@ -137,7 +127,7 @@ describe("UserSession.feed", () => {
|
|||||||
return feedItems.map((item) => ({ ...item, data: { ...item.data, enhanced: true } }))
|
return feedItems.map((item) => ({ ...item, data: { ...item.data, enhanced: true } }))
|
||||||
}
|
}
|
||||||
|
|
||||||
const session = new UserSession({ sources: [createStubSource("test", items)], enhancer })
|
const session = new UserSession([createStubSource("test", items)], enhancer)
|
||||||
|
|
||||||
const result1 = await session.feed()
|
const result1 = await session.feed()
|
||||||
expect(result1.items[0]!.data.enhanced).toBe(true)
|
expect(result1.items[0]!.data.enhanced).toBe(true)
|
||||||
@@ -172,7 +162,7 @@ describe("UserSession.feed", () => {
|
|||||||
}))
|
}))
|
||||||
}
|
}
|
||||||
|
|
||||||
const session = new UserSession({ sources: [source], enhancer })
|
const session = new UserSession([source], enhancer)
|
||||||
|
|
||||||
// First feed triggers refresh + enhancement
|
// First feed triggers refresh + enhancement
|
||||||
const result1 = await session.feed()
|
const result1 = await session.feed()
|
||||||
@@ -215,7 +205,7 @@ describe("UserSession.feed", () => {
|
|||||||
throw new Error("enhancement exploded")
|
throw new Error("enhancement exploded")
|
||||||
}
|
}
|
||||||
|
|
||||||
const session = new UserSession({ sources: [createStubSource("test", items)], enhancer })
|
const session = new UserSession([createStubSource("test", items)], enhancer)
|
||||||
|
|
||||||
const result = await session.feed()
|
const result = await session.feed()
|
||||||
|
|
||||||
@@ -224,81 +214,3 @@ describe("UserSession.feed", () => {
|
|||||||
expect(result.items[0]!.data.value).toBe(42)
|
expect(result.items[0]!.data.value).toBe(42)
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
describe("FeedRenderer", () => {
|
|
||||||
const stubRenderer: FeedItemRenderer = (item) => ({
|
|
||||||
$$typeof: JRX_NODE,
|
|
||||||
type: "FeedCard",
|
|
||||||
props: { content: item.data.value },
|
|
||||||
children: [],
|
|
||||||
key: undefined,
|
|
||||||
visible: undefined,
|
|
||||||
on: undefined,
|
|
||||||
repeat: undefined,
|
|
||||||
watch: undefined,
|
|
||||||
})
|
|
||||||
|
|
||||||
function makeItem(sourceId: string): FeedItem {
|
|
||||||
return {
|
|
||||||
id: `item-${sourceId}`,
|
|
||||||
sourceId,
|
|
||||||
type: "some-type",
|
|
||||||
timestamp: new Date("2025-01-01T00:00:00.000Z"),
|
|
||||||
data: { value: 42 },
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
test("renders items with matching sourceId", () => {
|
|
||||||
const renderer = new FeedRenderer({ "test-source": stubRenderer })
|
|
||||||
|
|
||||||
const result = renderer.render([makeItem("test-source")])
|
|
||||||
|
|
||||||
expect(result).toHaveLength(1)
|
|
||||||
expect(result[0]!.ui).toBeDefined()
|
|
||||||
expect(result[0]!.id).toBe("item-test-source")
|
|
||||||
})
|
|
||||||
|
|
||||||
test("drops items without a matching renderer", () => {
|
|
||||||
const renderer = new FeedRenderer({ "test-source": stubRenderer })
|
|
||||||
|
|
||||||
const result = renderer.render([makeItem("unknown-source")])
|
|
||||||
|
|
||||||
expect(result).toHaveLength(0)
|
|
||||||
})
|
|
||||||
|
|
||||||
test("filters mixed items", () => {
|
|
||||||
const renderer = new FeedRenderer({ "test-source": stubRenderer })
|
|
||||||
|
|
||||||
const result = renderer.render([makeItem("test-source"), makeItem("unknown-source")])
|
|
||||||
|
|
||||||
expect(result).toHaveLength(1)
|
|
||||||
expect(result[0]!.id).toBe("item-test-source")
|
|
||||||
})
|
|
||||||
|
|
||||||
test("renders empty array for empty input", () => {
|
|
||||||
const renderer = new FeedRenderer({ "test-source": stubRenderer })
|
|
||||||
|
|
||||||
expect(renderer.render([])).toHaveLength(0)
|
|
||||||
})
|
|
||||||
|
|
||||||
test("renders with no renderers registered", () => {
|
|
||||||
const renderer = new FeedRenderer({})
|
|
||||||
|
|
||||||
expect(renderer.render([makeItem("test-source")])).toHaveLength(0)
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
describe("UserSession.renderer", () => {
|
|
||||||
test("exposes renderer when provided", () => {
|
|
||||||
const renderer = new FeedRenderer({})
|
|
||||||
const session = new UserSession({ sources: [createStubSource("test")], renderer })
|
|
||||||
|
|
||||||
expect(session.renderer).toBe(renderer)
|
|
||||||
})
|
|
||||||
|
|
||||||
test("renderer is null when not provided", () => {
|
|
||||||
const session = new UserSession({ sources: [createStubSource("test")] })
|
|
||||||
|
|
||||||
expect(session.renderer).toBeNull()
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|||||||
@@ -1,17 +1,9 @@
|
|||||||
import { FeedEngine, type FeedItem, type FeedResult, type FeedSource } from "@aelis/core"
|
import { FeedEngine, type FeedItem, type FeedResult, type FeedSource } from "@aelis/core"
|
||||||
|
|
||||||
import type { FeedEnhancer } from "../enhancement/enhance-feed.ts"
|
import type { FeedEnhancer } from "../enhancement/enhance-feed.ts"
|
||||||
import type { FeedRenderer } from "./feed-renderer.ts"
|
|
||||||
|
|
||||||
export interface UserSessionOptions {
|
|
||||||
sources: FeedSource[]
|
|
||||||
enhancer?: FeedEnhancer | null
|
|
||||||
renderer?: FeedRenderer | null
|
|
||||||
}
|
|
||||||
|
|
||||||
export class UserSession {
|
export class UserSession {
|
||||||
readonly engine: FeedEngine
|
readonly engine: FeedEngine
|
||||||
readonly renderer: FeedRenderer | null
|
|
||||||
private sources = new Map<string, FeedSource>()
|
private sources = new Map<string, FeedSource>()
|
||||||
private readonly enhancer: FeedEnhancer | null
|
private readonly enhancer: FeedEnhancer | null
|
||||||
private enhancedItems: FeedItem[] | null = null
|
private enhancedItems: FeedItem[] | null = null
|
||||||
@@ -20,11 +12,10 @@ export class UserSession {
|
|||||||
private enhancingPromise: Promise<void> | null = null
|
private enhancingPromise: Promise<void> | null = null
|
||||||
private unsubscribe: (() => void) | null = null
|
private unsubscribe: (() => void) | null = null
|
||||||
|
|
||||||
constructor(options: UserSessionOptions) {
|
constructor(sources: FeedSource[], enhancer?: FeedEnhancer | null) {
|
||||||
this.engine = new FeedEngine()
|
this.engine = new FeedEngine()
|
||||||
this.enhancer = options.enhancer ?? null
|
this.enhancer = enhancer ?? null
|
||||||
this.renderer = options.renderer ?? null
|
for (const source of sources) {
|
||||||
for (const source of options.sources) {
|
|
||||||
this.sources.set(source.id, source)
|
this.sources.set(source.id, source)
|
||||||
this.engine.register(source)
|
this.engine.register(source)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,7 +0,0 @@
|
|||||||
import type { FeedItemRenderer } from "@aelis/core"
|
|
||||||
|
|
||||||
import { renderTflAlert } from "@aelis/source-tfl"
|
|
||||||
|
|
||||||
export const TFL_SOURCE_ID = "aelis.tfl"
|
|
||||||
|
|
||||||
export const tflRenderer: FeedItemRenderer = renderTflAlert as FeedItemRenderer
|
|
||||||
11
bun.lock
11
bun.lock
@@ -6,7 +6,7 @@
|
|||||||
"name": "aelis",
|
"name": "aelis",
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"@json-render/core": "^0.12.1",
|
"@json-render/core": "^0.12.1",
|
||||||
"@nym.sh/jrx": "^0.2.0",
|
"@nym.sh/jrx": "^0.1.0",
|
||||||
"@types/bun": "latest",
|
"@types/bun": "latest",
|
||||||
"oxfmt": "^0.24.0",
|
"oxfmt": "^0.24.0",
|
||||||
"oxlint": "^1.39.0",
|
"oxlint": "^1.39.0",
|
||||||
@@ -25,7 +25,6 @@
|
|||||||
"@aelis/source-location": "workspace:*",
|
"@aelis/source-location": "workspace:*",
|
||||||
"@aelis/source-tfl": "workspace:*",
|
"@aelis/source-tfl": "workspace:*",
|
||||||
"@aelis/source-weatherkit": "workspace:*",
|
"@aelis/source-weatherkit": "workspace:*",
|
||||||
"@nym.sh/jrx": "^0.2.0",
|
|
||||||
"@openrouter/sdk": "^0.9.11",
|
"@openrouter/sdk": "^0.9.11",
|
||||||
"arktype": "^2.1.29",
|
"arktype": "^2.1.29",
|
||||||
"better-auth": "^1",
|
"better-auth": "^1",
|
||||||
@@ -153,7 +152,6 @@
|
|||||||
"name": "@aelis/source-caldav",
|
"name": "@aelis/source-caldav",
|
||||||
"version": "0.0.0",
|
"version": "0.0.0",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@aelis/components": "workspace:*",
|
|
||||||
"@aelis/core": "workspace:*",
|
"@aelis/core": "workspace:*",
|
||||||
"ical.js": "^2.1.0",
|
"ical.js": "^2.1.0",
|
||||||
"tsdav": "^2.1.7",
|
"tsdav": "^2.1.7",
|
||||||
@@ -179,15 +177,10 @@
|
|||||||
"name": "@aelis/source-tfl",
|
"name": "@aelis/source-tfl",
|
||||||
"version": "0.0.0",
|
"version": "0.0.0",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@aelis/components": "workspace:*",
|
|
||||||
"@aelis/core": "workspace:*",
|
"@aelis/core": "workspace:*",
|
||||||
"@aelis/source-location": "workspace:*",
|
"@aelis/source-location": "workspace:*",
|
||||||
"arktype": "^2.1.0",
|
"arktype": "^2.1.0",
|
||||||
},
|
},
|
||||||
"peerDependencies": {
|
|
||||||
"@json-render/core": "*",
|
|
||||||
"@nym.sh/jrx": "*",
|
|
||||||
},
|
|
||||||
},
|
},
|
||||||
"packages/aelis-source-weatherkit": {
|
"packages/aelis-source-weatherkit": {
|
||||||
"name": "@aelis/source-weatherkit",
|
"name": "@aelis/source-weatherkit",
|
||||||
@@ -698,7 +691,7 @@
|
|||||||
|
|
||||||
"@nolyfill/is-core-module": ["@nolyfill/is-core-module@1.0.39", "", {}, "sha512-nn5ozdjYQpUCZlWGuxcJY/KpxkWQs4DcbMCmKojjyrYDEAGy4Ce19NN4v5MduafTwJlbKc99UA8YhSVqq9yPZA=="],
|
"@nolyfill/is-core-module": ["@nolyfill/is-core-module@1.0.39", "", {}, "sha512-nn5ozdjYQpUCZlWGuxcJY/KpxkWQs4DcbMCmKojjyrYDEAGy4Ce19NN4v5MduafTwJlbKc99UA8YhSVqq9yPZA=="],
|
||||||
|
|
||||||
"@nym.sh/jrx": ["@nym.sh/jrx@0.2.0", "", { "peerDependencies": { "@json-render/core": ">=0.10.0" } }, "sha512-jd7Z1Q6T21366MtSUnwCFiu6Yl1AdNc9s5m6HxeUg265P+0enZCiyyxOuHsFwvpUcSEs/2DVBsqfMptdca44lA=="],
|
"@nym.sh/jrx": ["@nym.sh/jrx@0.1.0", "", { "peerDependencies": { "@json-render/core": ">=0.10.0" } }, "sha512-mu6fkAP/TI9FuP8A4WMCrcucpUtWF5xBTcETnrjOtvEED9i+7sQKuoOyhJeF6QaSuUkAA/8t3Xx3kYUjcAPFbw=="],
|
||||||
|
|
||||||
"@oclif/core": ["@oclif/core@4.8.4", "", { "dependencies": { "ansi-escapes": "^4.3.2", "ansis": "^3.17.0", "clean-stack": "^3.0.1", "cli-spinners": "^2.9.2", "debug": "^4.4.3", "ejs": "^3.1.10", "get-package-type": "^0.1.0", "indent-string": "^4.0.0", "is-wsl": "^2.2.0", "lilconfig": "^3.1.3", "minimatch": "^10.2.4", "semver": "^7.7.3", "string-width": "^4.2.3", "supports-color": "^8", "tinyglobby": "^0.2.14", "widest-line": "^3.1.0", "wordwrap": "^1.0.0", "wrap-ansi": "^7.0.0" } }, "sha512-UTAqwXJJyRvLBvosL+1uPZYSpr8lEHgUb/EVGbPXo5WZqUIBHfJ0sR2bkBEsrj00/ar4IegKxx4YK0wn2c8SQg=="],
|
"@oclif/core": ["@oclif/core@4.8.4", "", { "dependencies": { "ansi-escapes": "^4.3.2", "ansis": "^3.17.0", "clean-stack": "^3.0.1", "cli-spinners": "^2.9.2", "debug": "^4.4.3", "ejs": "^3.1.10", "get-package-type": "^0.1.0", "indent-string": "^4.0.0", "is-wsl": "^2.2.0", "lilconfig": "^3.1.3", "minimatch": "^10.2.4", "semver": "^7.7.3", "string-width": "^4.2.3", "supports-color": "^8", "tinyglobby": "^0.2.14", "widest-line": "^3.1.0", "wordwrap": "^1.0.0", "wrap-ansi": "^7.0.0" } }, "sha512-UTAqwXJJyRvLBvosL+1uPZYSpr8lEHgUb/EVGbPXo5WZqUIBHfJ0sR2bkBEsrj00/ar4IegKxx4YK0wn2c8SQg=="],
|
||||||
|
|
||||||
|
|||||||
@@ -15,7 +15,7 @@
|
|||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"@json-render/core": "^0.12.1",
|
"@json-render/core": "^0.12.1",
|
||||||
"@nym.sh/jrx": "^0.2.0",
|
"@nym.sh/jrx": "^0.1.0",
|
||||||
"@types/bun": "latest",
|
"@types/bun": "latest",
|
||||||
"oxfmt": "^0.24.0",
|
"oxfmt": "^0.24.0",
|
||||||
"oxlint": "^1.39.0"
|
"oxlint": "^1.39.0"
|
||||||
|
|||||||
@@ -9,7 +9,6 @@
|
|||||||
"test:live": "bun run scripts/test-live.ts"
|
"test:live": "bun run scripts/test-live.ts"
|
||||||
},
|
},
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@aelis/components": "workspace:*",
|
|
||||||
"@aelis/core": "workspace:*",
|
"@aelis/core": "workspace:*",
|
||||||
"ical.js": "^2.1.0",
|
"ical.js": "^2.1.0",
|
||||||
"tsdav": "^2.1.7"
|
"tsdav": "^2.1.7"
|
||||||
|
|||||||
@@ -1,7 +1,6 @@
|
|||||||
export { CalDavCalendarKey, type CalendarContext } from "./calendar-context.ts"
|
export { CalDavCalendarKey, type CalendarContext } from "./calendar-context.ts"
|
||||||
export { CalDavSource, type CalDavSourceOptions } from "./caldav-source.ts"
|
export { CalDavSource, type CalDavSourceOptions } from "./caldav-source.ts"
|
||||||
export { parseICalEvents, type ICalTimeRange } from "./ical-parser.ts"
|
export { parseICalEvents, type ICalTimeRange } from "./ical-parser.ts"
|
||||||
export { renderCalDavFeedItem } from "./renderer.tsx"
|
|
||||||
export {
|
export {
|
||||||
AttendeeRole,
|
AttendeeRole,
|
||||||
AttendeeStatus,
|
AttendeeStatus,
|
||||||
|
|||||||
@@ -1,74 +0,0 @@
|
|||||||
/** @jsxImportSource @nym.sh/jrx */
|
|
||||||
|
|
||||||
import type { FeedItemRenderer } from "@aelis/core"
|
|
||||||
|
|
||||||
import { FeedCard, SansSerifText, SerifText } from "@aelis/components"
|
|
||||||
|
|
||||||
import type { CalDavEventData } from "./types.ts"
|
|
||||||
|
|
||||||
import { CalDavEventStatus } from "./types.ts"
|
|
||||||
|
|
||||||
function formatTime(date: Date): string {
|
|
||||||
const hours = date.getHours()
|
|
||||||
const minutes = date.getMinutes()
|
|
||||||
const period = hours >= 12 ? "PM" : "AM"
|
|
||||||
const h = hours % 12 || 12
|
|
||||||
const m = minutes.toString().padStart(2, "0")
|
|
||||||
return `${h}:${m} ${period}`
|
|
||||||
}
|
|
||||||
|
|
||||||
function formatTimeRange(data: CalDavEventData): string {
|
|
||||||
if (data.isAllDay) {
|
|
||||||
return "All day"
|
|
||||||
}
|
|
||||||
return `${formatTime(data.startDate)} – ${formatTime(data.endDate)}`
|
|
||||||
}
|
|
||||||
|
|
||||||
function formatStatus(status: CalDavEventData["status"]): string | null {
|
|
||||||
if (status === CalDavEventStatus.Cancelled) return "Cancelled"
|
|
||||||
if (status === CalDavEventStatus.Tentative) return "Tentative"
|
|
||||||
return null
|
|
||||||
}
|
|
||||||
|
|
||||||
export const renderCalDavFeedItem: FeedItemRenderer<"caldav-event", CalDavEventData> = (item) => {
|
|
||||||
const { data, slots } = item
|
|
||||||
const statusLabel = formatStatus(data.status)
|
|
||||||
const attendeeCount = data.attendees.length
|
|
||||||
|
|
||||||
return (
|
|
||||||
<FeedCard>
|
|
||||||
{statusLabel ? <SansSerifText content={statusLabel} style="text-xs uppercase" /> : null}
|
|
||||||
|
|
||||||
<SerifText content={data.title} style="text-lg" />
|
|
||||||
|
|
||||||
<SansSerifText content={formatTimeRange(data)} style="text-sm" />
|
|
||||||
|
|
||||||
{data.calendarName ? (
|
|
||||||
<SansSerifText content={data.calendarName} style="text-sm text-secondary" />
|
|
||||||
) : null}
|
|
||||||
|
|
||||||
{data.location ? (
|
|
||||||
<SansSerifText content={data.location} style="text-sm text-secondary" />
|
|
||||||
) : null}
|
|
||||||
|
|
||||||
{attendeeCount > 0 ? (
|
|
||||||
<SansSerifText
|
|
||||||
content={`${attendeeCount} attendee${attendeeCount === 1 ? "" : "s"}`}
|
|
||||||
style="text-sm text-secondary"
|
|
||||||
/>
|
|
||||||
) : null}
|
|
||||||
|
|
||||||
{slots?.insight?.content ? (
|
|
||||||
<SansSerifText content={slots.insight.content} style="text-sm" />
|
|
||||||
) : null}
|
|
||||||
|
|
||||||
{slots?.preparation?.content ? (
|
|
||||||
<SansSerifText content={slots.preparation.content} style="text-sm" />
|
|
||||||
) : null}
|
|
||||||
|
|
||||||
{slots?.crossSource?.content ? (
|
|
||||||
<SansSerifText content={slots.crossSource.content} style="text-sm" />
|
|
||||||
) : null}
|
|
||||||
</FeedCard>
|
|
||||||
)
|
|
||||||
}
|
|
||||||
@@ -1,7 +0,0 @@
|
|||||||
{
|
|
||||||
"extends": "../../tsconfig.json",
|
|
||||||
"compilerOptions": {
|
|
||||||
"jsxImportSource": "@nym.sh/jrx"
|
|
||||||
},
|
|
||||||
"include": ["src"]
|
|
||||||
}
|
|
||||||
@@ -10,12 +10,7 @@
|
|||||||
},
|
},
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@aelis/core": "workspace:*",
|
"@aelis/core": "workspace:*",
|
||||||
"@aelis/components": "workspace:*",
|
|
||||||
"@aelis/source-location": "workspace:*",
|
"@aelis/source-location": "workspace:*",
|
||||||
"arktype": "^2.1.0"
|
"arktype": "^2.1.0"
|
||||||
},
|
|
||||||
"peerDependencies": {
|
|
||||||
"@json-render/core": "*",
|
|
||||||
"@nym.sh/jrx": "*"
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -11,4 +11,3 @@ export {
|
|||||||
type TflLineStatus,
|
type TflLineStatus,
|
||||||
type TflSourceOptions,
|
type TflSourceOptions,
|
||||||
} from "./types.ts"
|
} from "./types.ts"
|
||||||
export { renderTflAlert } from "./renderer.tsx"
|
|
||||||
|
|||||||
@@ -1,103 +0,0 @@
|
|||||||
/** @jsxImportSource @nym.sh/jrx */
|
|
||||||
import { render } from "@nym.sh/jrx"
|
|
||||||
import { describe, expect, test } from "bun:test"
|
|
||||||
|
|
||||||
import type { TflAlertFeedItem } from "./types.ts"
|
|
||||||
|
|
||||||
import { renderTflAlert } from "./renderer.tsx"
|
|
||||||
|
|
||||||
function makeItem(overrides: Partial<TflAlertFeedItem["data"]> = {}): TflAlertFeedItem {
|
|
||||||
return {
|
|
||||||
id: "tfl-alert-northern-minor-delays",
|
|
||||||
type: "tfl-alert",
|
|
||||||
timestamp: new Date("2026-01-15T12:00:00Z"),
|
|
||||||
data: {
|
|
||||||
line: "northern",
|
|
||||||
lineName: "Northern",
|
|
||||||
severity: "minor-delays",
|
|
||||||
description: "Minor delays due to signal failure",
|
|
||||||
closestStationDistance: null,
|
|
||||||
...overrides,
|
|
||||||
},
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
describe("renderTflAlert", () => {
|
|
||||||
test("renders a FeedCard with title and description", () => {
|
|
||||||
const node = renderTflAlert(makeItem())
|
|
||||||
const spec = render(node)
|
|
||||||
|
|
||||||
const root = spec.elements[spec.root]!
|
|
||||||
expect(root.type).toBe("FeedCard")
|
|
||||||
expect(root.children!.length).toBeGreaterThanOrEqual(2)
|
|
||||||
|
|
||||||
const title = spec.elements[root.children![0]!]!
|
|
||||||
expect(title.type).toBe("SansSerifText")
|
|
||||||
expect(title.props.content).toBe("Northern · Minor delays")
|
|
||||||
|
|
||||||
const body = spec.elements[root.children![1]!]!
|
|
||||||
expect(body.type).toBe("SansSerifText")
|
|
||||||
expect(body.props.content).toBe("Minor delays due to signal failure")
|
|
||||||
})
|
|
||||||
|
|
||||||
test("shows nearest station distance when available", () => {
|
|
||||||
const node = renderTflAlert(makeItem({ closestStationDistance: 0.35 }))
|
|
||||||
const spec = render(node)
|
|
||||||
|
|
||||||
const root = spec.elements[spec.root]!
|
|
||||||
expect(root.children).toHaveLength(3)
|
|
||||||
|
|
||||||
const caption = spec.elements[root.children![2]!]!
|
|
||||||
expect(caption.type).toBe("SansSerifText")
|
|
||||||
expect(caption.props.content).toBe("Nearest station: 350m away")
|
|
||||||
})
|
|
||||||
|
|
||||||
test("formats distance in km when >= 1km", () => {
|
|
||||||
const node = renderTflAlert(makeItem({ closestStationDistance: 2.456 }))
|
|
||||||
const spec = render(node)
|
|
||||||
|
|
||||||
const root = spec.elements[spec.root]!
|
|
||||||
const caption = spec.elements[root.children![2]!]!
|
|
||||||
expect(caption.props.content).toBe("Nearest station: 2.5km away")
|
|
||||||
})
|
|
||||||
|
|
||||||
test("formats near-1km boundary as km not meters", () => {
|
|
||||||
const node = renderTflAlert(makeItem({ closestStationDistance: 0.9999 }))
|
|
||||||
const spec = render(node)
|
|
||||||
|
|
||||||
const root = spec.elements[spec.root]!
|
|
||||||
const caption = spec.elements[root.children![2]!]!
|
|
||||||
expect(caption.props.content).toBe("Nearest station: 1.0km away")
|
|
||||||
})
|
|
||||||
|
|
||||||
test("omits station distance when null", () => {
|
|
||||||
const node = renderTflAlert(makeItem({ closestStationDistance: null }))
|
|
||||||
const spec = render(node)
|
|
||||||
|
|
||||||
const root = spec.elements[spec.root]!
|
|
||||||
// Title + body only, no caption (empty fragment doesn't produce a child)
|
|
||||||
const children = root.children!.filter((key) => {
|
|
||||||
const el = spec.elements[key]
|
|
||||||
return el && el.type !== "Fragment"
|
|
||||||
})
|
|
||||||
expect(children).toHaveLength(2)
|
|
||||||
})
|
|
||||||
|
|
||||||
test("renders closure severity label", () => {
|
|
||||||
const node = renderTflAlert(makeItem({ severity: "closure", lineName: "Central" }))
|
|
||||||
const spec = render(node)
|
|
||||||
|
|
||||||
const root = spec.elements[spec.root]!
|
|
||||||
const title = spec.elements[root.children![0]!]!
|
|
||||||
expect(title.props.content).toBe("Central · Closed")
|
|
||||||
})
|
|
||||||
|
|
||||||
test("renders major delays severity label", () => {
|
|
||||||
const node = renderTflAlert(makeItem({ severity: "major-delays", lineName: "Jubilee" }))
|
|
||||||
const spec = render(node)
|
|
||||||
|
|
||||||
const root = spec.elements[spec.root]!
|
|
||||||
const title = spec.elements[root.children![0]!]!
|
|
||||||
expect(title.props.content).toBe("Jubilee · Major delays")
|
|
||||||
})
|
|
||||||
})
|
|
||||||
@@ -1,40 +0,0 @@
|
|||||||
/** @jsxImportSource @nym.sh/jrx */
|
|
||||||
import type { FeedItemRenderer } from "@aelis/core"
|
|
||||||
|
|
||||||
import { FeedCard, SansSerifText } from "@aelis/components"
|
|
||||||
|
|
||||||
import type { TflAlertData } from "./types.ts"
|
|
||||||
|
|
||||||
import { TflAlertSeverity } from "./types.ts"
|
|
||||||
|
|
||||||
const SEVERITY_LABEL: Record<TflAlertSeverity, string> = {
|
|
||||||
[TflAlertSeverity.Closure]: "Closed",
|
|
||||||
[TflAlertSeverity.MajorDelays]: "Major delays",
|
|
||||||
[TflAlertSeverity.MinorDelays]: "Minor delays",
|
|
||||||
}
|
|
||||||
|
|
||||||
function formatDistance(km: number): string {
|
|
||||||
const meters = Math.round(km * 1000)
|
|
||||||
if (meters < 1000) {
|
|
||||||
return `${meters}m away`
|
|
||||||
}
|
|
||||||
return `${(meters / 1000).toFixed(1)}km away`
|
|
||||||
}
|
|
||||||
|
|
||||||
export const renderTflAlert: FeedItemRenderer<"tfl-alert", TflAlertData> = (item) => {
|
|
||||||
const { lineName, severity, description, closestStationDistance } = item.data
|
|
||||||
const severityLabel = SEVERITY_LABEL[severity]
|
|
||||||
|
|
||||||
return (
|
|
||||||
<FeedCard>
|
|
||||||
<SansSerifText content={`${lineName} · ${severityLabel}`} style="text-base font-semibold" />
|
|
||||||
<SansSerifText content={description} style="text-sm" />
|
|
||||||
{closestStationDistance !== null ? (
|
|
||||||
<SansSerifText
|
|
||||||
content={`Nearest station: ${formatDistance(closestStationDistance)}`}
|
|
||||||
style="text-xs text-stone-500"
|
|
||||||
/>
|
|
||||||
) : null}
|
|
||||||
</FeedCard>
|
|
||||||
)
|
|
||||||
}
|
|
||||||
@@ -1,7 +0,0 @@
|
|||||||
{
|
|
||||||
"extends": "../../tsconfig.json",
|
|
||||||
"compilerOptions": {
|
|
||||||
"jsxImportSource": "@nym.sh/jrx"
|
|
||||||
},
|
|
||||||
"include": ["src"]
|
|
||||||
}
|
|
||||||
Reference in New Issue
Block a user