🔨 build: installation cmd

Author: FJRG2007

.dmcodeignore

@@ -0,0 +1,46 @@
+# Compiled Python files.
+*.pyc
+*.pyo
+*.pyd
+
+# Python cache directories.
+__pycache__
+
+# Virtual environments.
+venv
+.venv
+env
+.env
+
+# Build and distribution directories.
+build
+dist
+*.egg-info
+
+# IDE and editor directories.
+.idea
+.vscode
+*.swp
+*.swo
+
+# Claude Code local configurations.
+.claude
+
+# Astro framework.
+.astro
+
+# Node.JS/npm directories.
+node_modules
+
+# Git directory.
+.git
+
+# Test and coverage.
+.pytest_cache
+.coverage
+htmlcov
+.tox
+
+# OS generated files.
+.DS_Store
+Thumbs.db

dymo-code.spec

@@ -97,6 +97,7 @@ hiddenimports = [
     'src.context_manager',
     'src.utils',
     'src.utils.basics',
+    'src.ignore_patterns',
     # Cloudscraper bypass modules
     'src.utils.bypasses',
     'src.utils.bypasses.cloudscraper',

requirements-dev.txt

@@ -7,4 +7,4 @@ pyinstaller>=6.0.0
 # Optional: for code quality
 # ruff>=0.1.0
 # black>=23.0.0
-# mypy>=1.0.0
+# mypy>=1.0.0

requirements.txt

@@ -7,6 +7,6 @@ rich>=13.0.0
 prompt_toolkit>=3.0.0
 questionary>=2.0.0
 certifi>=2023.0.0
-requests>=2.31.0
+requests>=2.32.5
 requests-toolbelt>=1.0.0
-brotli>=1.1.0
+brotli>=1.1.0

src/__init__.py

@@ -44,5 +44,5 @@
     "get_db_path",
     "get_history_directory",
     "get_logs_directory",
-    "ensure_directories",
+    "ensure_directories"
 ]

src/agents.py

@@ -231,8 +231,7 @@ def create_task(
         with self.lock:
             self.tasks[task_id] = task
 
-            if parent_task_id and parent_task_id in self.tasks:
-                self.tasks[parent_task_id].subtasks.append(task_id)
+            if parent_task_id and parent_task_id in self.tasks: self.tasks[parent_task_id].subtasks.append(task_id)
 
         return task
 
@@ -266,18 +265,17 @@ def execute_and_cleanup():
 
         if run_async:
             future = self.executor.submit(execute_and_cleanup)
-            with self.lock:
+            with self.lock: 
                 self.task_futures[task.id] = future
             return task.id
         else: return execute_and_cleanup()
 
     def _handle_progress(self, task: AgentTask):
         """Handle task progress updates"""
-        with self.lock:
+        with self.lock: 
             self.tasks[task.id] = task
 
-        if self.on_task_update:
-            self.on_task_update(task)
+        if self.on_task_update: self.on_task_update(task)
 
     def get_task(self, task_id: str) -> Optional[AgentTask]:
         """Get a task by ID"""
@@ -313,9 +311,8 @@ def cancel_task(self, task_id: str) -> bool:
                             worker.cancel()
                             break
 
-                    # Cancel future if exists
-                    if task_id in self.task_futures:
-                        self.task_futures[task_id].cancel()
+                    # Cancel future if exists.
+                    if task_id in self.task_futures: self.task_futures[task_id].cancel()
 
                     return True
         return False
@@ -324,8 +321,7 @@ def cancel_all_tasks(self):
         """Cancel all running and queued tasks"""
         with self.lock:
             for task in self.tasks.values():
-                if task.status in [AgentStatus.QUEUED, AgentStatus.RUNNING]:
-                    task.status = AgentStatus.CANCELLED
+                if task.status in [AgentStatus.QUEUED, AgentStatus.RUNNING]: task.status = AgentStatus.CANCELLED
 
             for worker in self.workers.values():
                 worker.cancel()
@@ -339,10 +335,8 @@ def wait_for_task(self, task_id: str, timeout: float = None) -> Optional[AgentTa
             future = self.task_futures.get(task_id)
 
         if future:
-            try:
-                future.result(timeout=timeout)
-            except Exception:
-                pass
+            try: future.result(timeout=timeout)
+            except Exception: pass
 
         return self.get_task(task_id)
 

src/api_key_manager.py

@@ -15,7 +15,6 @@
 
 from .logger import log_debug, log_error
 
-
 class KeyStatus(Enum):
     """Status of an API key"""
     ACTIVE = "active"
@@ -30,13 +29,11 @@ class RotationStrategy(Enum):
     SEQUENTIAL = "sequential"      # Use one key until limit, then switch
     LOAD_BALANCER = "load_balancer"  # Distribute requests across all keys
 
-
 # Callbacks for notifications
 _on_key_rotated: Optional[Callable[[str, str, str], None]] = None  # provider, old_key, new_key
 _on_model_fallback: Optional[Callable[[str, str, str], None]] = None  # provider, old_model, new_model
 _on_provider_exhausted: Optional[Callable[[str], None]] = None  # provider
 
-
 def set_rotation_callbacks(
     on_key_rotated: Optional[Callable] = None,
     on_model_fallback: Optional[Callable] = None,
@@ -48,7 +45,6 @@ def set_rotation_callbacks(
     _on_model_fallback = on_model_fallback
     _on_provider_exhausted = on_provider_exhausted
 
-
 @dataclass
 class APIKeyInfo:
     """Information about an API key"""
@@ -75,12 +71,9 @@ def display_name(self) -> str:
 
     def is_available(self) -> bool:
         """Check if key is currently available for use"""
-        if self.status == KeyStatus.INVALID:
-            return False
-        if self.status == KeyStatus.EXHAUSTED:
-            return False
-        if self.cooldown_until and datetime.now() < self.cooldown_until:
-            return False
+        if self.status == KeyStatus.INVALID: return False
+        if self.status == KeyStatus.EXHAUSTED: return False
+        if self.cooldown_until and datetime.now() < self.cooldown_until: return False
         return True