Datasites

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 from peers"""
        for peer_email in peer_emails:
            msg = self.pull_and_process_next_proposed_filechange(peer_email)
            if msg:
                self.handle_proposed_filechange_events_message(peer_email, msg)
    
    def check_write_permission(self, sender_email: str, path: str) -> bool:
        """Check if sender has write access to the given path"""
        self.perm_context._reload()
        return self.perm_context.open(path).has_write_access(sender_email)
    
    def handle_proposed_filechange_events_message(
        self, sender_email: str, proposed_events_message: ProposedFileChangesMessage
    ):
        # Filter to only changes sender has permission to make
        allowed_changes = [
            change for change in proposed_events_message.proposed_file_changes
            if self.check_write_permission(sender_email, str(change.path_in_datasite))
        ]
        
        if allowed_changes:
            # Process and accept allowed changes
            self.event_cache.process_proposed_events_message(...)

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, process_now=True
    ):
        """Queue file change for syncing to peer"""
        relative_path = Path(relative_path)
        self.queue.put((relative_path, content))
        if process_now:
            self.process_file_changes_queue()
    
    def sync_down(self, peer_emails: list[str]):
        """Pull messages and datasets from peer outboxes"""
        for peer_email in peer_emails:
            # Sync messages with parallel download
            self.datasite_watcher_cache.sync_down_parallel(
                peer_email,
                self._executor,
                self.download_events_message_with_new_connection,
            )

from syft_job import get_client

client = get_client("/path/to/syftbox", "[email protected]")

# Submit bash job to data owner
script = """
#!/bin/bash
set -e
python analysis.py
"""

job_dir = client.submit_bash_job(
    user="[email protected]",
    script=script,
    job_name="My Analysis"
)
print(f"Job submitted to: {job_dir}")