e5ce3fe87a
While gitea is unreachable, propose-approved writes queue instead of being lost; on reconnect they replay in order. The hard requirement is no duplication. The mechanism is coalescing by axis. Every write targets one field of one issue (estimate / priority / assignee / milestone), so `issue:kind` is the axis identity. Queuing a second write to the same axis supersedes the first (moved to the tail), so a burst of edits replays as one final write — and replay is idempotent (the apply path no-ops a change already reflected server-side). - `enqueueWrite` (coalesce), `pendingWrites`, `coalesceKey`, `affectedIssues` (what a post-replay reconcile re-reads), and `replayQueue(queue, apply)` which drains through the same guarded write path and returns the writes that still failed so they stay queued. Never throws — a failure is data. Acceptance met: a burst of offline edits + reconnect lands the final state with a single apply per axis (not one per edit); still-failing writes stay queued. +4 core tests; typecheck green. Follow-up: persist the queue in main + trigger replay on the reconnect signal (the offline banner + disabled composer already exist) — the coalesce/replay core is the tested heart. Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
132 lines
3.7 KiB
TypeScript
132 lines
3.7 KiB
TypeScript
export {
|
|
ESTIMATE_LABELS,
|
|
PRIORITY_LABELS,
|
|
HARD_DEADLINE_LABEL,
|
|
extractLabelFacts,
|
|
isCommiteaLabel,
|
|
parseEstimateLabel,
|
|
parsePriorityLabel,
|
|
} from './labels/label-schema.js'
|
|
export type { EstimateLabel, LabelFacts, PriorityLabel } from './labels/label-schema.js'
|
|
|
|
export { createGiteaClient, normalizeIssue, normalizeMilestone, normalizeTimeline } from './gitea/client.js'
|
|
export type { GiteaClient, ListIssuesOptions } from './gitea/client.js'
|
|
export { GiteaApiError } from './gitea/types.js'
|
|
export type {
|
|
FetchLike,
|
|
GiteaConfig,
|
|
GiteaHttpResponse,
|
|
GiteaIssue,
|
|
GiteaLabel,
|
|
GiteaMilestone,
|
|
GiteaMilestoneRef,
|
|
GiteaRequestInit,
|
|
} from './gitea/types.js'
|
|
|
|
export { affectedIssues, coalesceKey, enqueueWrite, pendingWrites, replayQueue } from './queue/write-queue-v0.js'
|
|
export type { QueuedWrite } from './queue/write-queue-v0.js'
|
|
export { describeChange, isLabelChange, planIssueChange, proposalsFor, summarizeChange } from './changes/apply-changes-v0.js'
|
|
export type {
|
|
ChangeProposal,
|
|
IssueChange,
|
|
LabelChange,
|
|
LabelPlan,
|
|
ProposalContext,
|
|
ProposeChangeArgs,
|
|
} from './changes/apply-changes-v0.js'
|
|
|
|
export {
|
|
inferColumnV0,
|
|
inferLifecycle,
|
|
LIFECYCLE_COLUMNS,
|
|
workingDaysBetween,
|
|
} from './lifecycle/lifecycle-v0.js'
|
|
export type {
|
|
LifecycleColumn,
|
|
LifecycleEvent,
|
|
LifecycleEventType,
|
|
LifecycleInference,
|
|
LifecycleStages,
|
|
} from './lifecycle/lifecycle-v0.js'
|
|
|
|
export { DEFAULT_ESTIMATE_DAYS, schedule, selectFocus } from './scheduler/scheduler-v0.js'
|
|
export type {
|
|
DependencyEdge,
|
|
Focus,
|
|
SchedulableIssue,
|
|
ScheduledItem,
|
|
SchedulePlan,
|
|
} from './scheduler/scheduler-v0.js'
|
|
|
|
export { makespan, scheduleWithCapacity } from './scheduler/scheduler-capacity-v0.js'
|
|
export type { Worker } from './scheduler/scheduler-capacity-v0.js'
|
|
|
|
export { capacityPerWorkday, parseCapacityConfig } from './capacity/capacity-v0.js'
|
|
export type { CapacityMember } from './capacity/capacity-v0.js'
|
|
|
|
export {
|
|
COLD_START_PRIORS,
|
|
durationParams,
|
|
forecast,
|
|
nearestBucket,
|
|
PRIOR_BUCKETS,
|
|
priorForEstimate,
|
|
} from './forecast/forecast-v0.js'
|
|
export type {
|
|
BurnUpPoint,
|
|
DurationModel,
|
|
Forecast,
|
|
ForecastOptions,
|
|
LognormalPrior,
|
|
} from './forecast/forecast-v0.js'
|
|
|
|
export {
|
|
CALIBRATION_BUCKET_FLOOR,
|
|
calibrationCoverage,
|
|
calibrationSamples,
|
|
COLD_START_THRESHOLD,
|
|
fitCalibration,
|
|
toDurationModel,
|
|
} from './calibration/calibration-v0.js'
|
|
export type {
|
|
BucketFit,
|
|
CalibrationCoverage,
|
|
CalibrationModel,
|
|
CalibrationSample,
|
|
PersonBias,
|
|
} from './calibration/calibration-v0.js'
|
|
|
|
export { createChatClient } from './agent/chat-client.js'
|
|
export type { ChatClient, ChatMessage, CompletionResult, ModelConfig, OnToken, ToolCall, ToolDecl } from './agent/chat-client.js'
|
|
export { pickModel } from './agent/model-router.js'
|
|
export type { ModelRouter, TaskKind } from './agent/model-router.js'
|
|
export { runAgentTurn } from './agent/agent-loop.js'
|
|
export type { AgentStep, AgentTurn, ToolExecutor } from './agent/agent-loop.js'
|
|
export {
|
|
PROPOSE_CHANGE_TOOL,
|
|
QUERY_PROJECT_TOOL,
|
|
RECORD_DIRECTIVE_TOOL,
|
|
REGINALD_SYSTEM,
|
|
REGINALD_TOOLS,
|
|
} from './agent/agent-tools.js'
|
|
export { buildProjectView } from './agent/query-project.js'
|
|
export type { ProjectSnapshot, ProjectView, QueryFilters } from './agent/query-project.js'
|
|
export { CAPTURE_SYSTEM, captureWork, parseCaptureArgs, PROPOSE_ISSUES_TOOL } from './agent/capture-work.js'
|
|
export type { CaptureProposal, ProposedIssue } from './agent/capture-work.js'
|
|
|
|
export {
|
|
appendDirective,
|
|
makeDirectiveEntry,
|
|
parseDirectiveLog,
|
|
serializeDirective,
|
|
toDirectiveInput,
|
|
} from './directives/record-directive-v0.js'
|
|
export type {
|
|
DirectiveEntry,
|
|
DirectiveInput,
|
|
DirectiveKind,
|
|
DirectiveRecord,
|
|
DirectiveStatus,
|
|
DirectiveTarget,
|
|
} from './directives/record-directive-v0.js'
|