Bump version to 0.3.0 for release

Author: san-tekart

examples/05_stock_monitor_ui.py

@@ -0,0 +1,203 @@
+import asyncio
+import random
+import time
+from dataclasses import dataclass
+from typing import Dict, Optional
+from tsignal import t_with_signals, t_signal, t_slot, t_with_worker
+import logging
+
+logger = logging.getLogger(__name__)
+
+
+@dataclass
+class StockPrice:
+    code: str
+    price: float
+    change: float
+    timestamp: float
+
+
+@t_with_worker
+class StockService:
+    """가상의 주식 시세 데이터를 생성하고 전달하는 서비스"""
+
+    def __init__(self):
+        self.prices: Dict[str, float] = {
+            "AAPL": 180.0,
+            "GOOGL": 140.0,
+            "MSFT": 370.0,
+        }
+        self.last_prices = self.prices.copy()
+        self._running = False
+        super().__init__()
+
+    @t_signal
+    def price_updated(self):
+        """주식 시세가 업데이트될 때 발생하는 시그널"""
+        pass
+
+    async def initialize(self):
+        """워커 초기화"""
+        logging.debug("StockService 초기화 시작")
+        self._running = True
+        await self.update_prices()
+        logging.debug("StockService 초기화 완료")
+
+    async def finalize(self):
+        """워커 종료"""
+        logging.debug("StockService 종료 시작")
+        self._running = False
+        logging.debug("StockService 종료 완료")
+
+    async def update_prices(self):
+        """주기적으로 시세 업데이트"""
+        logging.debug("주식 가격 업데이트 시작")
+        while self._running:
+            for code in self.prices:
+                # 이전 가격 저장
+                self.last_prices[code] = self.prices[code]
+
+                # 가격 변동 시뮬레이션 (-1% ~ +1%)
+                change_pct = random.uniform(-0.01, 0.01)
+                self.prices[code] *= 1 + change_pct
+
+                # 시세 데이터 생성 및 시그널 발생
+                price_data = StockPrice(
+                    code=code,
+                    price=self.prices[code],
+                    change=((self.prices[code] / self.last_prices[code]) - 1) * 100,
+                    timestamp=time.time(),
+                )
+                logging.debug(
+                    f"{code} 가격 업데이트: {price_data.price:.2f} (변동: {price_data.change:.2f}%)"
+                )
+                self.price_updated.emit(price_data)
+
+            await asyncio.sleep(1)  # 1초마다 업데이트
+
+
+@t_with_worker
+class StockProcessor:
+    """시세 데이터를 처리하고 알림 조건을 체크하는 프로세서"""
+
+    def __init__(self):
+        self.price_alerts: Dict[str, tuple[Optional[float], Optional[float]]] = {}
+        super().__init__()
+
+    @t_signal
+    def alert_triggered(self):
+        """가격 알림 조건이 충족되면 발생하는 시그널"""
+        pass
+
+    @t_signal
+    def price_processed(self):
+        """시세 데이터 처리가 완료되면 발생하는 시그널"""
+        pass
+
+    async def initialize(self):
+        """워커 초기화"""
+        pass
+
+    async def finalize(self):
+        """워커 종료"""
+        self.price_alerts.clear()
+
+    @t_slot
+    async def on_price_updated(self, price_data: StockPrice):
+        """StockService로부터 시세 업데이트를 수신"""
+        # 알림 조건 체크 태스크 큐잉
+        await self.queue_task(self.process_price(price_data))
+
+    async def process_price(self, price_data: StockPrice):
+        """시세 데이터 처리"""
+        logging.debug(f"{price_data.code} 가격 처리: {price_data.price:.2f}")
+        # 알림 조건 체크
+        if price_data.code in self.price_alerts:
+            lower, upper = self.price_alerts[price_data.code]
+            if lower and price_data.price <= lower:
+                logging.debug(
+                    f"{price_data.code} 가격 알림 트리거: LOW ({price_data.price:.2f})"
+                )
+                self.alert_triggered.emit(price_data.code, "LOW", price_data.price)
+            if upper and price_data.price >= upper:
+                logging.debug(
+                    f"{price_data.code} 가격 알림 트리거: HIGH ({price_data.price:.2f})"
+                )
+                self.alert_triggered.emit(price_data.code, "HIGH", price_data.price)
+
+        # 처리된 데이터 전달
+        self.price_processed.emit(price_data)
+
+    def set_price_alert(
+        self, code: str, lower: Optional[float] = None, upper: Optional[float] = None
+    ):
+        """가격 알림 설정"""
+        self.price_alerts[code] = (lower, upper)
+
+
+@t_with_signals
+class StockViewModel:
+    """UI 상태를 관리하는 뷰모델"""
+
+    def __init__(self):
+        self.current_prices: Dict[str, StockPrice] = {}
+        self.alerts: list[tuple[str, str, float]] = []
+
+    @t_signal
+    def prices_updated(self):
+        """시세 데이터가 업데이트되면 발생하는 시그널"""
+        pass
+
+    @t_signal
+    def alert_added(self):
+        """새로운 알림이 추가되면 발생하는 시그널"""
+        pass
+
+    @t_slot
+    def on_price_processed(self, price_data: StockPrice):
+        """StockProcessor로부터 처리된 시세 데이터를 수신"""
+        self.current_prices[price_data.code] = price_data
+        self.prices_updated.emit(dict(self.current_prices))
+
+    @t_slot
+    def on_alert_triggered(self, code: str, alert_type: str, price: float):
+        """StockProcessor로부터 알림 트리거를 수신"""
+        self.alerts.append((code, alert_type, price))
+        self.alert_added.emit(code, alert_type, price)
+
+
+async def main():
+    """테스트를 위한 메인 함수"""
+
+    root = logging.getLogger()
+    default_level = logging.DEBUG
+    root.setLevel(default_level)
+
+    # 컴포넌트 생성
+    service = StockService()
+    processor = StockProcessor()
+    viewmodel = StockViewModel()
+
+    # 시그널 연결
+    service.price_updated.connect(processor, processor.on_price_updated)
+    processor.price_processed.connect(viewmodel, viewmodel.on_price_processed)
+    processor.alert_triggered.connect(viewmodel, viewmodel.on_alert_triggered)
+
+    # 워커 시작
+    service.start()
+    processor.start()
+
+    # 알림 설정 예시
+    processor.set_price_alert("AAPL", lower=175.0, upper=185.0)
+
+    try:
+        # 테스트를 위해 잠시 실행
+        await asyncio.sleep(10)
+    finally:
+        # 워커 종료
+        service.stop()
+        processor.stop()
+
+
+if __name__ == "__main__":
+    asyncio.run(main())

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "tsignal"
-version = "0.2.1"
+version = "0.3.0"
 description = "A Python Signal-Slot library inspired by Qt"
 readme = "README.md"
 requires-python = ">=3.10"