System Architecture

class DatasiteWatcherSyncer(BaseModelCallbackMixin):
    """Handles both pushing proposed file changes and pulling from datasite outboxes."""
    
    def on_file_change(self, relative_path: Path | str, content: str | None = None):
        """Queue file changes for syncing to peers"""
        
    def sync_down(self, peer_emails: list[str]):
        """Pull messages and datasets from peer outboxes"""

class DatasiteOwnerSyncer(BaseModelCallbackMixin):
    """Responsible for downloading files and checking permissions"""
    
    def sync(self, peer_emails: list[str], recompute_hashes: bool = True):
        """Pull proposed file changes and process them"""
        
    def check_write_permission(self, sender_email: str, path: str) -> bool:
        """Check if sender has write access to the given path"""
        
    def check_read_permissions(self, recipient_email: str, path: str) -> bool:
        """Check if recipient has read access to the given path"""

class FileChangeEvent(BaseModel):
    id: UUID
    path_in_datasite: Path
    datasite_email: str
    content: str | bytes | None  # None for deletions
    old_hash: str | None
    new_hash: str | None  # None for deletions
    is_deleted: bool
    submitted_timestamp: float
    timestamp: float

class JobClient:
    """Client for submitting jobs to SyftBox."""
    
    def submit_bash_job(self, user: str, script: str, job_name: str = "") -> Path:
        """Submit a bash job for a user"""
        
    def submit_python_job(self, user: str, code_path: str, job_name: str = "", 
                          dependencies: List[str] = None) -> Path:
        """Submit a Python job (wraps code in bash script)"""