Scrum4Me/stores/backlog-store.ts
Janpeter Visser 6375ed6949
End-to-end smoke-test: PBI/Story/Task verschijnen zonder refresh (#57)
* fix(backlog-store): make INSERT handlers idempotent to prevent duplicate entries on duplicate SSE-events

* docs(realtime-smoke): add manual smoke-checklist for PBI/Story/Task realtime end-to-end verification

---------

Co-authored-by: Scrum4Me Agent <30029041+madhura68@users.noreply.github.com>
2026-05-02 21:09:37 +02:00

142 lines
4.2 KiB
TypeScript

import { create } from 'zustand'
import type { PbiStatusApi } from '@/lib/task-status'
export interface BacklogPbi {
id: string
code: string | null
title: string
priority: number
description?: string | null
created_at: Date
status: PbiStatusApi
}
export interface BacklogStory {
id: string
code: string | null
title: string
description: string | null
acceptance_criteria: string | null
priority: number
status: string
pbi_id: string
created_at: Date
}
export interface BacklogTask {
id: string
title: string
description: string | null
priority: number
status: string
sort_order: number
story_id: string
created_at: Date
}
type Entity = 'pbi' | 'story' | 'task'
type Op = 'I' | 'U' | 'D'
interface InitialData {
pbis: BacklogPbi[]
storiesByPbi: Record<string, BacklogStory[]>
tasksByStory: Record<string, BacklogTask[]>
}
interface BacklogStore extends InitialData {
setInitialData: (data: InitialData) => void
applyChange: (entity: Entity, op: Op, data: Record<string, unknown>) => void
}
export const useBacklogStore = create<BacklogStore>((set) => ({
pbis: [],
storiesByPbi: {},
tasksByStory: {},
setInitialData: (data) => set(data),
applyChange: (entity, op, data) =>
set((state) => {
if (entity === 'pbi') {
const id = data.id as string
if (op === 'D') {
return { pbis: state.pbis.filter((p) => p.id !== id) }
}
if (op === 'U') {
return {
pbis: state.pbis.map((p) =>
p.id === id ? { ...p, ...(data as Partial<BacklogPbi>) } : p
),
}
}
// I — idempotent: skip if already present (optimistic update may have arrived first)
if (state.pbis.some((p) => p.id === id)) return {}
return { pbis: [...state.pbis, data as unknown as BacklogPbi] }
}
if (entity === 'story') {
const id = data.id as string
if (op === 'D') {
const storiesByPbi = { ...state.storiesByPbi }
for (const pbiId of Object.keys(storiesByPbi)) {
storiesByPbi[pbiId] = storiesByPbi[pbiId].filter((s) => s.id !== id)
}
return { storiesByPbi }
}
if (op === 'U') {
const storiesByPbi = { ...state.storiesByPbi }
for (const pbiId of Object.keys(storiesByPbi)) {
const idx = storiesByPbi[pbiId].findIndex((s) => s.id === id)
if (idx !== -1) {
storiesByPbi[pbiId] = storiesByPbi[pbiId].map((s) =>
s.id === id ? { ...s, ...(data as Partial<BacklogStory>) } : s
)
break
}
}
return { storiesByPbi }
}
// I — idempotent: skip if already present
const pbiId = data.pbi_id as string
if ((state.storiesByPbi[pbiId] ?? []).some((s) => s.id === id)) return {}
return {
storiesByPbi: {
...state.storiesByPbi,
[pbiId]: [...(state.storiesByPbi[pbiId] ?? []), data as unknown as BacklogStory],
},
}
}
// task
const id = data.id as string
if (op === 'D') {
const tasksByStory = { ...state.tasksByStory }
for (const storyId of Object.keys(tasksByStory)) {
tasksByStory[storyId] = tasksByStory[storyId].filter((t) => t.id !== id)
}
return { tasksByStory }
}
if (op === 'U') {
const tasksByStory = { ...state.tasksByStory }
for (const storyId of Object.keys(tasksByStory)) {
const idx = tasksByStory[storyId].findIndex((t) => t.id === id)
if (idx !== -1) {
tasksByStory[storyId] = tasksByStory[storyId].map((t) =>
t.id === id ? { ...t, ...(data as Partial<BacklogTask>) } : t
)
break
}
}
return { tasksByStory }
}
// I — idempotent: skip if already present
const storyId = data.story_id as string
if ((state.tasksByStory[storyId] ?? []).some((t) => t.id === id)) return {}
return {
tasksByStory: {
...state.tasksByStory,
[storyId]: [...(state.tasksByStory[storyId] ?? []), data as unknown as BacklogTask],
},
}
}),
}))