Shared from "Claude-Code" on Inkdown
The business logic layer — everything that isn't UI, tools, or the query loop.
services/analytics/)Tracks usage events and feature flags:
// Log an event
logEvent('tengu_started', { /* metadata */ })
// Events are queued until sinks are attached
// initSinks() drains the queue to:
// 1. Statsig (product analytics)
// 2. Internal logging (ant-only)
// 3. Local telemetryservices/analytics/growthbook.ts)Feature flag and A/B testing platform:
// Get feature value (cached, may be stale)
getFeatureValue_CACHED_MAY_BE_STALE('tengu_otk_slot_v1', false)
// Feature gate (compile-time elimination)
if (feature('COORDINATOR_MODE')) { ... }
// Refresh after auth change
refreshGrowthBookAfterAuthChange()Full OTel integration:
// Meter (metrics)
const meter = getMeter()
const sessionCounter = meter.createCounter('sessions')
// Tracer (distributed tracing)
const tracer = getTracerProvider()
// Event Logger (structured events)
const eventLogger = getEventLogger()Attributed counters track:
services/compact/)Summarizes old messages when context approaches the limit:
// Triggered in query.ts before API call
const compactionResult = await autocompact(
messagesForQuery,
toolUseContext,
{ systemPrompt, userContext, systemContext, ... },
querySource,
tracking,
snipTokensFreed
)Process:
Removes redundant tool_use/tool_result pairs:
const microcompactResult = await microcompact(
messagesForQuery,
toolUseContext,
querySource
)Triggered reactively when the API returns 413 (prompt too long):
const compacted = await tryReactiveCompact({
hasAttempted: hasAttemptedReactiveCompact,
querySource,
aborted,
messages,
cacheSafeParams: { ... }
})Removes the oldest messages:
const snipResult = snipCompactIfNeeded(messagesForQuery)
// Returns: { messages, tokensFreed, boundaryMessage? }services/contextCollapse/)A more aggressive context reduction strategy:
projectView() replays the commit log on every entry// Initialize
initContextCollapse()
// Apply collapses if needed
const result = await applyCollapsesIfNeeded(messages, toolUseContext, querySource)
// Recover from overflow by draining staged collapses
const drained = recoverFromOverflow(messages, querySource)services/SessionMemory/)Extracts and stores memories from conversations:
// Initialize
initSessionMemory()
// Hook: triggered on conversation changes
registerMemoryExtractionHook()
// Memories stored in .claude/ directoryservices/teamMemorySync/)Syncs memory across team members:
// Start watcher
startTeamMemoryWatcher()
// Syncs .claude/ memories to shared storageservices/settingsSync/)Uploads local settings to the cloud:
// Background upload
uploadUserSettingsInBackground()
// Only for interactive sessions
if (getIsInteractive()) { ... }services/lsp/)Language Server Protocol integration:
// Initialize manager
initializeLspServerManager()
// Recommendation shown once per session
hasShownLspRecommendationThisSession()services/PromptSuggestion/)Suggests prompts to the user:
// Check if enabled
shouldEnablePromptSuggestion()
// Shows suggestions in the UIservices/tips/)Contextual tips shown to users:
// Get relevant tips
getRelevantTips()
// Prefetched at startupservices/claudeAiLimits.ts)Tracks and displays rate limit status:
// Check quota
checkQuotaStatus()
// Hook for limit changes
registerClaudeAiLimitsHook()services/rateLimitMessages.ts)User-friendly messages for rate limits:
// Generate message based on limit type
getRateLimitMessage(limitType)services/rateLimitMocking.ts)For testing:
// Mock rate limits
mockRateLimits(config)services/autoDream/)Background processing feature:
// Auto-dream: process conversations in background
// Consolidation lock prevents concurrent dreamsservices/preventSleep.ts)Keeps the system awake during long operations:
// Prevent system sleep
preventSleep()
// Allow sleep again
allowSleep()services/notifier.ts)Notification system:
// Send notification
notify(message, options)
// Notifications shown in the UIservices/vcr.ts)Records and replays API interactions for testing:
// Record mode
recordVcr()
// Playback mode
playbackVcr()services/voice.ts)Voice input support:
// Voice processing
processVoiceInput()services/voiceKeyterms.ts)Domain-specific keyterms for voice:
// Get keyterms for project
getVoiceKeyterms(projectRoot)services/voiceStreamSTT.ts)Streaming speech-to-text:
// Stream audio to STT service
streamToSTT(audioStream)services/MagicDocs/)Auto-generates documentation:
// Generate docs for codebase
generateMagicDocs()services/diagnosticTracking.ts)Collects diagnostic information:
// Track diagnostics
trackDiagnostic(name, value)services/internalLogging.ts)Internal logging for debugging:
// Log permission context
logPermissionContextForAnts()services/awaySummary.ts)Summarizes what happened while the user was away:
// Generate away summary
generateAwaySummary()services/extractMemories/)Memory extraction from conversations:
// Extract memories from messages
extractMemories(messages)services/remoteManagedSettings/)Enterprise-managed settings:
// Load remote settings
loadRemoteManagedSettings()
// Refresh on changes
refreshRemoteManagedSettings()
// Security checks
securityCheck()services/policyLimits/)Enterprise policy enforcement:
// Load policy limits
loadPolicyLimits()
// Check if action is allowed
isPolicyAllowed(action)
// Refresh limits
refreshPolicyLimits()services/oauth/)OAuth authentication:
// OAuth flow
startOAuthFlow()
// Refresh token
refreshOAuthToken()services/plugins/)Plugin management:
// Plugin operations
installPlugin(name)
uninstallPlugin(name)
updatePlugin(name)
listPlugins()
// Plugin state in AppState
plugins: {
enabled: Set<string>
disabled: Set<string>
errors: PluginError[]
installationStatus: Map<string, InstallationStatus>
needsRefresh: boolean
}| Directory | Purpose |
|---|---|
services/analytics/ | Telemetry, GrowthBook, OTel |
services/api/ | Anthropic API client |
services/compact/ | Context compaction |
services/contextCollapse/ | Context collapse |
services/mcp/ | MCP servers |
services/tools/ | Tool orchestration |
services/SessionMemory/ | Session memory |
services/teamMemorySync/ | Team memory sync |
services/settingsSync/ | Settings sync |
services/lsp/ | LSP integration |
services/plugins/ | Plugin management |
services/policyLimits/ | Enterprise policies |
services/oauth/ | OAuth authentication |
services/remoteManagedSettings/ | Remote settings |
services/autoDream/ | Auto dream |
services/PromptSuggestion/ | Prompt suggestions |
services/tips/ | Tips |
services/voice.ts | Voice input |
services/vcr.ts | VCR recording/playback |
services/notifier.ts | Notifications |
services/rateLimitMessages.ts | Rate limit messages |
services/awaySummary.ts | Away summary |
services/diagnosticTracking.ts | Diagnostics |
services/internalLogging.ts | Internal logging |
services/MagicDocs/ | Auto documentation |
services/extractMemories/ | Memory extraction |
services/toolUseSummary/ | Tool use summaries |
services/tokenEstimation.ts | Token estimation |
services/claudeAiLimits.ts | Claude AI limits |
services/preventSleep.ts | Prevent system sleep |
services/mockRateLimits.ts | Rate limit mocking |
services/voiceKeyterms.ts | Voice keyterms |
services/voiceStreamSTT.ts | Voice STT |