#12 Added examples

examples/stream/README.md

@@ -0,0 +1,75 @@
+# Stream - Прослушивание уведомлений
+
+Примеры работы с SSE (Server-Sent Events) потоком уведомлений в реальном времени.
+
+## Подготовка
+
+1. Установите зависимости:
+```bash
+pip install -r ../../requirements.txt
+```
+
+2. Получите cookies с `refresh_token` (см. [главный README](../README.md))
+
+3. Запускайте примеры из корня проекта или из папки `examples/stream/`
+
+## Примеры
+
+### basic_stream.py
+Базовое прослушивание всех уведомлений.
+
+```bash
+python basic_stream.py
+```
+
+Показывает все входящие уведомления в реальном времени.
+
+### stop_stream.py
+Программная остановка потока через `client.stop_stream()`.
+
+```bash
+python stop_stream.py
+```
+
+Полезно для интеграции в многопоточные приложения.
+
+### filter_notifications.py
+Фильтрация уведомлений по типу.
+
+```bash
+python filter_notifications.py
+```
+
+Показывает только выбранные типы (like, follow, comment). Настраивается через `SHOW_TYPES`.
+
+### notification_logger.py
+Логирование всех уведомлений в JSON файл.
+
+```bash
+python notification_logger.py
+```
+
+Создает файл `notifications_YYYYMMDD_HHMMSS.log` с полной историей событий.
+
+## Типы уведомлений
+
+- **like** - Лайк на пост
+- **follow** - Новый подписчик
+- **wall_post** - Пост на вашей стене
+- **comment** - Комментарий к посту
+- **reply** - Ответ на комментарий
+- **repost** - Репост вашего поста
+
+## Особенности
+
+- ✅ Автоматическое переподключение при разрыве
+- ✅ Автоматическое обновление токена (при использовании cookies)
+- ✅ Обработка всех типов уведомлений
+- ✅ Graceful shutdown по Ctrl+C
+
+## API Reference
+
+Подробная документация по методам и моделям:
+- [Основной README](../../README.md) - Общая информация об SDK
+- [itd/client.py](../../itd/client.py) - Метод `stream_notifications()`
+- [itd/models/event.py](../../itd/models/event.py) - Модели `StreamConnect` и `StreamNotification`

examples/stream/basic_stream.py

@@ -0,0 +1,37 @@
+"""
+Базовый пример прослушивания SSE потока уведомлений
+"""
+import sys
+from pathlib import Path
+sys.path.insert(0, str(Path(__file__).parent.parent.parent))
+
+from itd import ITDClient, StreamConnect, StreamNotification
+
+def main():
+    cookies = 'YOUR_COOKIES_HERE'
+    
+    if cookies == 'YOUR_COOKIES_HERE':
+        print('! Укажите cookies в переменной cookies')
+        print('   См. examples/README.md для инструкций')
+        return
+    
+    client = ITDClient(cookies=cookies)
+    
+    print('-- Подключение к SSE...')
+    
+    try:
+        for event in client.stream_notifications():
+            if isinstance(event, StreamConnect):
+                print(f'-- Подключено! User ID: {event.user_id}')
+                print('-- Ожидание уведомлений...\n')
+            else:
+                print(f'* {event.type.value}: {event.actor.username}')
+                if event.preview:
+                    preview = event.preview[:50] + '...' if len(event.preview) > 50 else event.preview
+                    print(f'   {preview}')
+                    
+    except KeyboardInterrupt:
+        print(f'\n! Отключение...')
+
+if __name__ == '__main__':
+    main()

examples/stream/filter_notifications.py

@@ -0,0 +1,54 @@
+"""
+Пример фильтрации уведомлений по типу
+"""
+import sys
+from pathlib import Path
+sys.path.insert(0, str(Path(__file__).parent.parent.parent))
+
+from itd import ITDClient, StreamConnect, StreamNotification
+from itd.enums import NotificationType
+
+def main():
+    cookies = 'YOUR_COOKIES_HERE'
+    
+    if cookies == 'YOUR_COOKIES_HERE':
+        print('! Укажите cookies в переменной cookies')
+        print('   См. examples/README.md для инструкций')
+        return
+    
+    client = ITDClient(cookies=cookies)
+    
+    # Настройка: какие типы уведомлений показывать
+    SHOW_TYPES = {
+        NotificationType.LIKE,
+        NotificationType.FOLLOW,
+        NotificationType.COMMENT,
+    }
+    
+    print('-- Подключение к SSE...')
+    print(f'-- Фильтр: {", ".join(t.value for t in SHOW_TYPES)}\n')
+    
+    try:
+        for event in client.stream_notifications():
+            if isinstance(event, StreamConnect):
+                print(f'✅ Подключено! User ID: {event.user_id}\n')
+                continue
+            
+            if event.type not in SHOW_TYPES:
+                continue
+            
+            # Обработка разных типов
+            if event.type == NotificationType.LIKE:
+                print(f'❤️  {event.actor.display_name} лайкнул ваш пост')
+                
+            elif event.type == NotificationType.FOLLOW:
+                print(f'👤 {event.actor.display_name} подписался на вас')
+                
+            elif event.type == NotificationType.COMMENT:
+                print(f'💬 {event.actor.display_name}: {event.preview}')
+                
+    except KeyboardInterrupt:
+        print(f'\n! Отключение...')
+
+if __name__ == '__main__':
+    main()

examples/stream/notification_logger.py

@@ -0,0 +1,60 @@
+"""
+Пример логирования уведомлений в файл
+"""
+import sys
+from pathlib import Path
+sys.path.insert(0, str(Path(__file__).parent.parent.parent))
+
+from itd import ITDClient, StreamConnect, StreamNotification
+from datetime import datetime
+import json
+
+def main():
+    cookies = 'YOUR_COOKIES_HERE'
+    
+    if cookies == 'YOUR_COOKIES_HERE':
+        print('! Укажите cookies в переменной cookies')
+        print('   См. examples/README.md для инструкций')
+        return
+    
+    client = ITDClient(cookies=cookies)
+    log_file = f'notifications_{datetime.now().strftime("%Y%m%d_%H%M%S")}.log'
+    
+    print(f'-- Подключение к SSE...')
+    print(f'-- Логирование в: {log_file}\n')
+    
+    try:
+        with open(log_file, 'w', encoding='utf-8') as f:
+            for event in client.stream_notifications():
+                timestamp = datetime.now().isoformat()
+                
+                if isinstance(event, StreamConnect):
+                    log_entry = {
+                        'timestamp': timestamp,
+                        'type': 'connect',
+                        'user_id': str(event.user_id)
+                    }
+                    print(f'-- Подключено! User ID: {event.user_id}')
+                else:
+                    log_entry = {
+                        'timestamp': timestamp,
+                        'type': event.type.value,
+                        'id': str(event.id),
+                        'actor': {
+                            'username': event.actor.username,
+                            'display_name': event.actor.display_name
+                        },
+                        'preview': event.preview,
+                        'target_type': event.target_type.value if event.target_type else None,
+                        'target_id': str(event.target_id) if event.target_id else None
+                    }
+                    print(f'* {event.type.value}: {event.actor.username}')
+                
+                f.write(json.dumps(log_entry, ensure_ascii=False) + '\n')
+                f.flush()
+                
+    except KeyboardInterrupt:
+        print(f'\n! Отключение... Лог сохранен в {log_file}')
+
+if __name__ == '__main__':
+    main()

examples/stream/stop_stream.py

@@ -0,0 +1,47 @@
+"""
+Пример остановки SSE потока из кода
+"""
+import sys
+from pathlib import Path
+sys.path.insert(0, str(Path(__file__).parent.parent.parent))
+
+import threading
+import time
+from itd import ITDClient, StreamConnect, StreamNotification
+
+def main():
+    cookies = 'YOUR_COOKIES_HERE' 
+    
+    if cookies == 'YOUR_COOKIES_HERE':
+        print('! Укажите cookies в переменной cookies')
+        return
+    
+    client = ITDClient(cookies=cookies)
+    
+    # Функция для прослушивания в отдельном потоке
+    def listen():
+        print('! Начинаем прослушивание...')
+        try:
+            for event in client.stream_notifications():
+                if isinstance(event, StreamConnect):
+                    print(f'-- Подключено! User ID: {event.user_id}')
+                else:
+                    print(f'🔔 {event.type.value}: {event.actor.username}')
+        except Exception as e:
+            print(f'! Ошибка: {e}')
+    
+    # В отдельном потоке
+    thread = threading.Thread(target=listen, daemon=True)
+    thread.start()
+    
+    print('Прослушивание запущено. Нажмите Enter для остановки...')
+    input()
+    
+    print('!! Останавливаем прослушивание...')
+    client.stop_stream()
+    
+    thread.join(timeout=5)
+    print('! Остановлено')
+
+if __name__ == '__main__':
+    main()