Phase 10~11 전체 구현: 킬러 피처 5종 + 수익화 시스템
Phase 10 킬러 피처: - MemoService: 태그 CRUD + 마크다운 내보내기 (memo_tags DB) - VoiceCommandService: 키워드→명령어 매칭, 프리셋 4종 - ScreenContextService: PowerShell 활성 윈도우 + Ctrl+C 선택 텍스트 - ChainService: LLM 명령어 순차 실행 파이프라인 - CaptionService: 6초 청크 연속 전사 + 시스템 오디오 루프백 VoiceModeService 파이프라인 통합: - 녹음 시작 → 컨텍스트 캡처 → STT → 키워드 매칭 → LLM(체인/컨텍스트 주입) → 삽입 시스템 오디오 캡처: - setDisplayMediaRequestHandler + audio: 'loopback' (IPC 브릿지) - electron-audio-loopback 패키지 contextIsolation 호환 불가 → 직접 구현 Phase 11 수익화: - LicenseService: Free/Pro/Pro+ 3티어, LemonSqueezy API - Feature Gate: requireFeature/checkFeature/consumeFeature - 일일 쿼터: Free dictation 20/일, LLM 10/일 (SQLite daily_usage) - LicenseModal, ProBadge, UpgradePromptModal UI 디자인 보강: - d3roTypo(13종), d3roShadow(10종), d3roRadius(7종) 토큰 시스템 - ScreenPanel, ButtonGroup DS 컴포넌트 신규 - PhosphorText 4→13종 변형, MetalDial conic-gradient 광택 - 공유 컴포넌트: EmptyStateCard, SearchInput, PageHeader, HistoryEntryCard 기타: - 자막 핫키 SSOT 전체 연동 (Config→Hotkey→VoiceMode→Caption→Settings) - StatusBar 자막 LED + 효과음, 자막 로딩 UI - LLM 상태 이벤트 전파 수정 (폴링 제거 → onStatusChanged) - 커맨드 팝업 "선택 해제" 항목 추가
This commit is contained in:
Yun Chan
parent
36d77ca224
commit
a31f96bbb8
97 changed files with 11853 additions and 1143 deletions
259
src/main/services/ChainService.ts
Normal file
259
src/main/services/ChainService.ts
Normal file
|
|
@ -0,0 +1,259 @@
|
|||
// src/main/services/ChainService.ts
|
||||
// Phase 10.4: Multi-LLM Chain 서비스.
|
||||
// LLMChain을 electron-store에 저장하고, 체인을 순차 실행한다.
|
||||
|
||||
import { nanoid } from 'nanoid'
|
||||
import { getLogger } from './LoggerService'
|
||||
import { configGet } from './ConfigService'
|
||||
import { getCustomInstructionService } from './CustomInstructionService'
|
||||
import { getLocalLLMService } from './LocalLLMService'
|
||||
import { getMainWindow } from '../windows/WindowManager'
|
||||
import { IPC_CHANNELS } from '@shared/ipc-channels'
|
||||
import { D3ROError, ErrorCode } from '@shared/errors'
|
||||
import type {
|
||||
LLMChain,
|
||||
ChainStep,
|
||||
CreateChainParams,
|
||||
UpdateChainParams,
|
||||
ChainProgress,
|
||||
ChainExecutionResult
|
||||
} from '@shared/types'
|
||||
|
||||
const logger = getLogger('chain-service')
|
||||
|
||||
// ============================================================
|
||||
// 저장소 (electron-store, CustomInstructionService 패턴)
|
||||
// ============================================================
|
||||
|
||||
let chains: LLMChain[] = []
|
||||
let initialized = false
|
||||
|
||||
function loadChains(): LLMChain[] {
|
||||
try {
|
||||
const stored = configGet('llmChains' as never) as LLMChain[] | undefined
|
||||
if (Array.isArray(stored) && stored.length > 0) {
|
||||
return stored
|
||||
}
|
||||
} catch {
|
||||
// 첫 실행 시 키가 없을 수 있음
|
||||
}
|
||||
return []
|
||||
}
|
||||
|
||||
function saveChains(): void {
|
||||
try {
|
||||
// eslint-disable-next-line @typescript-eslint/no-require-imports
|
||||
const { configSet } = require('./ConfigService') as {
|
||||
configSet: (key: never, value: never) => void
|
||||
}
|
||||
configSet('llmChains' as never, chains as never)
|
||||
} catch (error) {
|
||||
logger.warn(
|
||||
`Failed to save chains: ${error instanceof Error ? error.message : String(error)}`
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
/** 메인 윈도우 렌더러에 IPC 이벤트 전송 */
|
||||
function sendProgressToRenderer(progress: ChainProgress): void {
|
||||
const win = getMainWindow()
|
||||
if (win && !win.isDestroyed()) {
|
||||
win.webContents.send(IPC_CHANNELS.CHAIN.PROGRESS, progress)
|
||||
}
|
||||
}
|
||||
|
||||
// ============================================================
|
||||
// ChainService
|
||||
// ============================================================
|
||||
|
||||
class ChainService {
|
||||
private _cancelRequested = false
|
||||
|
||||
initialize(): void {
|
||||
if (initialized) return
|
||||
chains = loadChains()
|
||||
initialized = true
|
||||
logger.info(`ChainService initialized (${chains.length} chains)`)
|
||||
}
|
||||
|
||||
getAll(): LLMChain[] {
|
||||
return [...chains]
|
||||
}
|
||||
|
||||
getById(id: string): LLMChain | null {
|
||||
return chains.find((c) => c.id === id) ?? null
|
||||
}
|
||||
|
||||
create(params: CreateChainParams): LLMChain {
|
||||
const now = Date.now()
|
||||
const chain: LLMChain = {
|
||||
id: nanoid(),
|
||||
name: params.name,
|
||||
steps: params.steps,
|
||||
createdAt: now,
|
||||
updatedAt: now
|
||||
}
|
||||
|
||||
chains.push(chain)
|
||||
saveChains()
|
||||
logger.info(`Chain created: "${chain.name}" (${chain.steps.length} steps)`)
|
||||
return chain
|
||||
}
|
||||
|
||||
update(params: UpdateChainParams): LLMChain {
|
||||
const index = chains.findIndex((c) => c.id === params.id)
|
||||
if (index === -1) {
|
||||
throw new D3ROError(ErrorCode.ChainNotFound, `Chain not found: ${params.id}`)
|
||||
}
|
||||
|
||||
const existing = chains[index]
|
||||
const updated: LLMChain = {
|
||||
...existing,
|
||||
name: params.name ?? existing.name,
|
||||
steps: params.steps ?? existing.steps,
|
||||
updatedAt: Date.now()
|
||||
}
|
||||
|
||||
chains[index] = updated
|
||||
saveChains()
|
||||
logger.info(`Chain updated: "${updated.name}"`)
|
||||
return updated
|
||||
}
|
||||
|
||||
delete(id: string): void {
|
||||
const index = chains.findIndex((c) => c.id === id)
|
||||
if (index === -1) {
|
||||
throw new D3ROError(ErrorCode.ChainNotFound, `Chain not found: ${id}`)
|
||||
}
|
||||
|
||||
const removed = chains.splice(index, 1)[0]
|
||||
saveChains()
|
||||
logger.info(`Chain deleted: "${removed.name}"`)
|
||||
}
|
||||
|
||||
/**
|
||||
* 체인을 순차 실행한다.
|
||||
* 각 단계마다 CustomInstruction의 프롬프트로 LLM을 호출하고,
|
||||
* 이전 단계 결과를 다음 단계의 입력으로 전달한다.
|
||||
*/
|
||||
async execute(chainId: string, inputText: string): Promise<ChainExecutionResult> {
|
||||
const chain = this.getById(chainId)
|
||||
if (!chain) {
|
||||
throw new D3ROError(ErrorCode.ChainNotFound, `Chain not found: ${chainId}`)
|
||||
}
|
||||
|
||||
if (chain.steps.length === 0) {
|
||||
throw new D3ROError(ErrorCode.ChainExecutionFailed, 'Chain has no steps')
|
||||
}
|
||||
|
||||
this._cancelRequested = false
|
||||
const startTime = Date.now()
|
||||
const stepResults: Array<{ instructionId: string; output: string; durationMs: number }> = []
|
||||
let previousOutput = inputText
|
||||
|
||||
const llm = getLocalLLMService()
|
||||
const instructionService = getCustomInstructionService()
|
||||
|
||||
logger.info(
|
||||
`Executing chain "${chain.name}" (${chain.steps.length} steps) with input length ${inputText.length}`
|
||||
)
|
||||
|
||||
for (let i = 0; i < chain.steps.length; i++) {
|
||||
// 취소 확인
|
||||
if (this._cancelRequested) {
|
||||
logger.info(`Chain execution cancelled at step ${i + 1}/${chain.steps.length}`)
|
||||
throw new D3ROError(ErrorCode.ChainCancelled, 'Chain execution cancelled')
|
||||
}
|
||||
|
||||
const step: ChainStep = chain.steps[i]
|
||||
const instruction = instructionService.getById(step.instructionId)
|
||||
|
||||
if (!instruction) {
|
||||
throw new D3ROError(
|
||||
ErrorCode.ChainStepFailed,
|
||||
`Instruction not found for step ${i + 1}: ${step.instructionId}`
|
||||
)
|
||||
}
|
||||
|
||||
// 입력 소스 결정
|
||||
const stepInput = step.inputSource === 'original' ? inputText : previousOutput
|
||||
|
||||
// 진행 상황 전송
|
||||
const progress: ChainProgress = {
|
||||
chainId,
|
||||
currentStep: i + 1,
|
||||
totalSteps: chain.steps.length,
|
||||
stepName: instruction.name,
|
||||
intermediateText: previousOutput
|
||||
}
|
||||
sendProgressToRenderer(progress)
|
||||
|
||||
// LLM 호출
|
||||
const stepStart = Date.now()
|
||||
try {
|
||||
const result = await llm.processText(stepInput, 'custom', undefined, instruction.prompt)
|
||||
const stepDuration = Date.now() - stepStart
|
||||
|
||||
stepResults.push({
|
||||
instructionId: step.instructionId,
|
||||
output: result,
|
||||
durationMs: stepDuration
|
||||
})
|
||||
previousOutput = result
|
||||
|
||||
logger.info(
|
||||
`Chain step ${i + 1}/${chain.steps.length} ("${instruction.name}") completed in ${stepDuration}ms`
|
||||
)
|
||||
} catch (error) {
|
||||
if (error instanceof D3ROError && error.code === ErrorCode.ChainCancelled) {
|
||||
throw error
|
||||
}
|
||||
const msg =
|
||||
error instanceof Error ? error.message : String(error)
|
||||
throw new D3ROError(
|
||||
ErrorCode.ChainStepFailed,
|
||||
`Step ${i + 1} ("${instruction.name}") failed: ${msg}`
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
const totalDuration = Date.now() - startTime
|
||||
logger.info(`Chain "${chain.name}" completed in ${totalDuration}ms`)
|
||||
|
||||
return {
|
||||
chainId,
|
||||
finalText: previousOutput,
|
||||
steps: stepResults,
|
||||
totalDurationMs: totalDuration
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 진행 중인 체인 실행을 취소한다.
|
||||
* 현재 단계가 완료된 후 다음 단계 시작 전에 중단된다.
|
||||
*/
|
||||
cancelExecution(): void {
|
||||
this._cancelRequested = true
|
||||
// LLM 생성도 취소
|
||||
getLocalLLMService().cancelGeneration()
|
||||
logger.info('Chain execution cancel requested')
|
||||
}
|
||||
|
||||
dispose(): void {
|
||||
this._cancelRequested = true
|
||||
logger.info('ChainService disposed')
|
||||
}
|
||||
}
|
||||
|
||||
// ============================================================
|
||||
// 싱글톤
|
||||
// ============================================================
|
||||
|
||||
let instance: ChainService | null = null
|
||||
|
||||
export function getChainService(): ChainService {
|
||||
if (!instance) {
|
||||
instance = new ChainService()
|
||||
}
|
||||
return instance
|
||||
}
|
||||
Loading…
Add table
Add a link
Reference in a new issue