@@ -109,6 +111,18 @@ class RDFDatasetDownloader:
             raise
         self.console = console or Console()
 
+    def _get_protocol(self, url: str) -> str:

@@ -211,1 +213,3 @@
-            else:
+
+            elif protocol == "ftp":
+                self.console.print(f"[cyan]Using FTP protocol for: {dataset_info.url}[/cyan]")

@@ -213,0 +220,4 @@
+
+            else:
+                self.console.print(f"[red]Unsupported protocol: {protocol}://[/red]")
+                self.console.print(f"[yellow]Supported: http://, https://, ftp://, file://[/yellow]")

@@ -218,1 +231,3 @@
-            if "Name or service not known" in error_msg or "Errno -2" in error_msg:
+            # Enhanced error context including FTP errors
+            if "unsupported protocol" in error_msg.lower():
+                self.console.print(f"[yellow]→ Protocol '{protocol}://' is not supported[/yellow]")

@@ -321,0 +347,4 @@
+                            if server_size > 0:
+                                if partial_size >= server_size:
+                                    # File is already complete!
+                                    self.console.print(f"[green]✓ File already complete ({partial_size / (1024**2):.2f} MB)[/green]")

@@ -321,0 +351,4 @@
+                                    return  # Exit successfully
+                                else:
+                                    # File incomplete, server doesn't support resume
+                                    self.console.print(f"[yellow]Server doesn't support resume. Have {partial_size / (1024**2):.2f} MB, need {server_size / (1024**2):.2f} MB[/yellow]")

@@ -321,0 +352,4 @@
+                                else:
+                                    # File incomplete, server doesn't support resume
+                                    self.console.print(f"[yellow]Server doesn't support resume. Have {partial_size / (1024**2):.2f} MB, need {server_size / (1024**2):.2f} MB[/yellow]")
+                                    self.console.print("[yellow]Deleting partial file and restarting...[/yellow]")

@@ -321,0 +354,4 @@
+                                    self.console.print(f"[yellow]Server doesn't support resume. Have {partial_size / (1024**2):.2f} MB, need {server_size / (1024**2):.2f} MB[/yellow]")
+                                    self.console.print("[yellow]Deleting partial file and restarting...[/yellow]")
+                                    destination.unlink()
+                                    # Force retry by raising exception that IS caught by retry loop

@@ -321,0 +355,4 @@
+                                    self.console.print("[yellow]Deleting partial file and restarting...[/yellow]")
+                                    destination.unlink()
+                                    # Force retry by raising exception that IS caught by retry loop
+                                    raise httpx.NetworkError("Restarting download without resume")

@@ -321,0 +359,4 @@
+
+                            # Case 2: No Content-Length header, assume file is complete
+                            else:
+                                self.console.print(f"[green]✓ File exists ({partial_size / (1024**2):.2f} MB), assuming complete[/green]")

@@ -321,0 +360,4 @@
+                            # Case 2: No Content-Length header, assume file is complete
+                            else:
+                                self.console.print(f"[green]✓ File exists ({partial_size / (1024**2):.2f} MB), assuming complete[/green]")
+                                self.console.print("[dim]Use --force to re-download if needed.[/dim]")

@@ -380,6 +424,131 @@ class RDFDatasetDownloader:
                 self.console.print(f"[red]Unexpected error during download: {e}[/red]")
                 raise
 
+    def _download_file_ftp(self, url: str, destination: Path, max_retries: int = 3) -> None:

@@ -383,0 +441,4 @@
+        while retry_count <= max_retries:
+            try:
+                if destination.exists():
+                    self.console.print("[yellow]FTP doesn't support resume - starting fresh download[/yellow]")

@@ -383,0 +464,4 @@
+                            total_size = int(response.headers['Content-Length'])
+                            progress.update(task, total=total_size)
+                        else:
+                            self.console.print("[yellow]FTP server didn't provide file size - progress will be indeterminate[/yellow]")

@@ -383,0 +482,4 @@
+                                chunk_count += 1
+
+                                if chunk_count % 100 == 0:
+                                    f.flush()

@@ -383,0 +486,4 @@
+
+                            f.flush()
+
+                self.console.print(f"[green]✓ Downloaded {downloaded / (1024**2):.2f} MB via FTP[/green]")

@@ -383,0 +490,4 @@
+                return
+
+            except urllib.error.URLError as e:
+                retry_count += 1

@@ -383,0 +496,4 @@
+                    reason = str(e.reason)
+
+                    if '530' in reason or 'Login incorrect' in reason:
+                        self.console.print(f"[red]FTP authentication failed: {url}[/red]")

@@ -383,0 +497,4 @@
+
+                    if '530' in reason or 'Login incorrect' in reason:
+                        self.console.print(f"[red]FTP authentication failed: {url}[/red]")
+                        self.console.print("[yellow]The server rejected anonymous login[/yellow]")

@@ -383,0 +501,4 @@
+                        raise
+
+                    elif '550' in reason or 'No such file' in reason:
+                        self.console.print(f"[red]File not found on FTP server: {url}[/red]")

@@ -383,0 +502,4 @@
+
+                    elif '550' in reason or 'No such file' in reason:
+                        self.console.print(f"[red]File not found on FTP server: {url}[/red]")
+                        self.console.print("[yellow]The file may have been moved or removed[/yellow]")

@@ -383,0 +508,4 @@
+                    elif 'timed out' in reason.lower():
+                        if retry_count <= max_retries:
+                            self.console.print(
+                                f"[yellow]FTP timeout. Retrying {retry_count}/{max_retries}...[/yellow]"

@@ -383,0 +513,4 @@
+                            time.sleep(min(2**retry_count, 30))
+                            continue
+                        else:
+                            self.console.print(f"[red]FTP download failed after {max_retries} retries[/red]")

@@ -383,0 +519,4 @@
+                    else:
+                        if retry_count <= max_retries:
+                            self.console.print(
+                                f"[yellow]FTP error: {reason}. Retrying {retry_count}/{max_retries}...[/yellow]"

@@ -383,0 +532,4 @@
+                retry_count += 1
+                if retry_count <= max_retries:
+                    self.console.print(
+                        f"[yellow]FTP connection timeout. Retrying {retry_count}/{max_retries}...[/yellow]"

@@ -383,0 +536,4 @@
+                    )
+                    time.sleep(min(2**retry_count, 30))
+                else:
+                    self.console.print(f"[red]FTP download failed after {max_retries} retries[/red]")