Add a button to increase peer timeouts

crates/librqbit/src/http_api.rs

@@ -12,12 +12,14 @@ use librqbit_core::torrent_metainfo::TorrentMetaV1Info;
 use serde::{Deserialize, Serialize};
 use std::net::SocketAddr;
 use std::sync::Arc;
+use std::time::Duration;
 use tokio::sync::mpsc::UnboundedSender;
 use tracing::{info, warn};
 
 use axum::Router;
 
 use crate::http_api_error::{ApiError, ApiErrorExt};
+use crate::peer_connection::PeerConnectionOptions;
 use crate::session::{
     AddTorrent, AddTorrentOptions, AddTorrentResponse, ListOnlyResponse, Session, TorrentId,
 };
@@ -322,13 +324,15 @@ impl<'de> Deserialize<'de> for OnlyFiles {
     }
 }
 
-#[derive(Serialize, Deserialize)]
+#[derive(Serialize, Deserialize, Default)]
 pub struct TorrentAddQueryParams {
     pub overwrite: Option<bool>,
     pub output_folder: Option<String>,
     pub sub_folder: Option<String>,
     pub only_files_regex: Option<String>,
     pub only_files: Option<OnlyFiles>,
+    pub peer_connect_timeout: Option<u64>,
+    pub peer_read_write_timeout: Option<u64>,
     pub list_only: Option<bool>,
 }
 
@@ -341,6 +345,11 @@ impl TorrentAddQueryParams {
             output_folder: self.output_folder,
             sub_folder: self.sub_folder,
             list_only: self.list_only.unwrap_or(false),
+            peer_opts: Some(PeerConnectionOptions {
+                connect_timeout: self.peer_connect_timeout.map(Duration::from_secs),
+                read_write_timeout: self.peer_read_write_timeout.map(Duration::from_secs),
+                ..Default::default()
+            }),
             ..Default::default()
         }
     }

crates/librqbit/src/http_api_client.rs

@@ -91,6 +91,7 @@ impl HttpApiClient {
             output_folder: opts.output_folder,
             sub_folder: opts.sub_folder,
             list_only: Some(opts.list_only),
+            ..Default::default()
         };
         let qs = serde_urlencoded::to_string(&params).unwrap();
         let url = format!("{}torrents?{}", &self.base_url, qs);

crates/librqbit/webui/dist/manifest.json

@@ -4,7 +4,7 @@
     "src": "assets/logo.svg"
   },
   "index.html": {
-    "file": "assets/index-1c38bddb.js",
+    "file": "assets/index-b3c336f4.js",
     "isEntry": true,
     "src": "index.html"
   }

crates/librqbit/webui/src/api.ts

@@ -147,7 +147,7 @@ export const API = {
     },
 
     uploadTorrent: (data: string | File, opts?: {
-        listOnly?: boolean, selectedFiles?: Array<number>
+        listOnly?: boolean, selectedFiles?: Array<number>, unpopularTorrent?: boolean,
     }): Promise<AddTorrentResponse> => {
         opts = opts || {};
         let url = '/torrents?&overwrite=true';
@@ -157,6 +157,9 @@ export const API = {
         if (opts.selectedFiles != null) {
             url += `&only_files=${opts.selectedFiles.join(',')}`;
         }
+        if (opts.unpopularTorrent) {
+            url += '&peer_connect_timeout=20&peer_read_write_timeout=60';
+        }
         return makeRequest('POST', url, data)
     },
 

crates/librqbit/webui/src/index.tsx

@@ -438,7 +438,7 @@ const MagnetInput = () => {
     };
 
     return (
-        <UploadButton variant='primary' buttonText="Add Torrent from Magnet Link" onClick={onClick} data={magnet} resetData={() => setMagnet(null)} />
+        <UploadButton variant='primary' buttonText="Add Torrent from Magnet / URL" onClick={onClick} data={magnet} resetData={() => setMagnet(null)} />
     );
 };
 
@@ -481,6 +481,7 @@ const FileSelectionModal = (props: {
     const [selectedFiles, setSelectedFiles] = useState([]);
     const [uploading, setUploading] = useState(false);
     const [uploadError, setUploadError] = useState<Error>(null);
+    const [unpopularTorrent, setUnpopularTorrent] = useState(false);
     const ctx = useContext(AppContext);
 
     useEffect(() => {
@@ -504,7 +505,7 @@ const FileSelectionModal = (props: {
 
     const handleUpload = async () => {
         setUploading(true);
-        API.uploadTorrent(data, { selectedFiles }).then(
+        API.uploadTorrent(data, { selectedFiles, unpopularTorrent }).then(
             () => {
                 onHide();
                 ctx.refreshTorrents();
@@ -518,24 +519,43 @@ const FileSelectionModal = (props: {
     return (
         <Modal show={show} onHide={clear} size='lg'>
             <Modal.Header closeButton>
-                {!!fileListError || <Modal.Title>Select Files</Modal.Title>}
+                {!!fileListError || <Modal.Title>Add torrent</Modal.Title>}
             </Modal.Header>
             <Modal.Body>
-                {fileListLoading ? <Spinner />
-                    : fileListError ? <ErrorComponent error={fileListError}></ErrorComponent> :
-                        <Form>
-                            {fileList.map((file, index) => (
-                                <Form.Group key={index} controlId={`check-${index}`}>
-                                    <Form.Check
-                                        type="checkbox"
-                                        label={`${file.name}  (${formatBytes(file.length)})`}
-                                        checked={selectedFiles.includes(index)}
-                                        onChange={() => handleToggleFile(index)}>
-                                    </Form.Check>
-                                </Form.Group>
-                            ))}
-                        </Form>
-                }
+                <Form>
+                    <fieldset className='mb-5'>
+                        <legend>Pick the files to download</legend>
+                        {fileListLoading ? <Spinner />
+                            : fileListError ? <ErrorComponent error={fileListError}></ErrorComponent> :
+                                <>
+                                    {fileList.map((file, index) => (
+                                        <Form.Group key={index} controlId={`check-${index}`}>
+                                            <Form.Check
+                                                type="checkbox"
+                                                label={`${file.name}  (${formatBytes(file.length)})`}
+                                                checked={selectedFiles.includes(index)}
+                                                onChange={() => handleToggleFile(index)}>
+                                            </Form.Check>
+                                        </Form.Group>
+                                    ))}
+                                </>
+                        }
+                    </fieldset>
+                    <fieldset>
+                        <legend>Other options</legend>
+
+                        <Form.Group controlId='unpopular-torrent'>
+                            <Form.Check
+                                type="checkbox"
+                                label="Increase timeouts"
+                                checked={unpopularTorrent}
+                                onChange={() => setUnpopularTorrent(!unpopularTorrent)}>
+                            </Form.Check>
+                            <small id="emailHelp" className="form-text text-muted">This might be useful for unpopular torrents with few peers.</small>
+                        </Form.Group>
+                    </fieldset>
+
+                </Form>
                 <ErrorComponent error={uploadError} />
             </Modal.Body>
             <Modal.Footer>