src/main.rs

@@ -10,7 +10,6 @@ use actix_web::{
 };
 use actix_web_actors::ws;
 use log::error;
-use serde::Deserialize;
 use store::FileStore;
 use tokio::sync::RwLock;
 
@@ -18,25 +17,20 @@ const APP_NAME: &str = "transbeam";
 
 type AppData = web::Data<RwLock<FileStore>>;
 
-#[derive(Deserialize)]
-struct DownloadRequest {
-    code: String,
-}
-
-#[get("/download")]
+#[get("/download/{file_code}")]
 async fn handle_download(
     req: HttpRequest,
-    download: web::Query<DownloadRequest>,
+    path: web::Path<String>,
     data: AppData,
 ) -> actix_web::Result<HttpResponse> {
-    let code = &download.code;
-    if !store::is_valid_storage_code(code) {
+    let file_code = path.into_inner();
+    if !store::is_valid_storage_code(&file_code) {
         return Ok(HttpResponse::NotFound().finish());
     }
     let data = data.read().await;
-    let info = data.lookup_file(code);
+    let info = data.lookup_file(&file_code);
     if let Some(info) = info {
-        let storage_path = store::storage_dir().join(code);
+        let storage_path = store::storage_dir().join(file_code);
         let file = File::open(&storage_path)?;
         Ok(download::DownloadingFile {
             file,
@@ -61,9 +55,8 @@ async fn main() -> std::io::Result<()> {
     let data: AppData = web::Data::new(RwLock::new(FileStore::load().await?));
     start_reaper(data.clone());
 
-    let static_dir = PathBuf::from(
-        std::env::var("TRANSBEAM_STATIC_DIR").unwrap_or_else(|_| String::from("static")),
-    );
+    let static_dir =
+        PathBuf::from(std::env::var("TRANSBEAM_STATIC_DIR").unwrap_or_else(|_| String::from("static")));
     let port = std::env::var("TRANSBEAM_PORT")
         .ok()
         .and_then(|p| p.parse::<u16>().ok())

src/store.rs

@@ -1,10 +1,7 @@
 use std::{collections::HashMap, io::ErrorKind, path::PathBuf, str::FromStr};
 
 use log::{debug, error, info, warn};
-use rand::{
-    distributions::{Alphanumeric, DistString},
-    thread_rng, Rng,
-};
+use rand::{distributions::{Alphanumeric, DistString}, thread_rng, Rng};
 use serde::{Deserialize, Serialize};
 use time::OffsetDateTime;
 use tokio::{
@@ -15,9 +12,9 @@ use tokio::{
 const STATE_FILE_NAME: &str = "files.json";
 const DEFAULT_STORAGE_DIR: &str = "storage";
 const DEFAULT_MAX_LIFETIME: u32 = 30;
-const GIGA: u64 = 1024 * 1024 * 1024;
-const DEFAULT_MAX_UPLOAD_SIZE: u64 = 16 * GIGA;
-const DEFAULT_MAX_STORAGE_SIZE: u64 = 64 * GIGA;
+const GIGA: u64 = 1024*1024*1024;
+const DEFAULT_MAX_UPLOAD_SIZE: u64 = 16*GIGA;
+const DEFAULT_MAX_STORAGE_SIZE: u64 = 64*GIGA;
 
 pub fn gen_storage_code() -> String {
     if std::env::var("TRANSBEAM_MNEMONIC_CODES").as_deref() == Ok("false") {
@@ -28,23 +25,15 @@ pub fn gen_storage_code() -> String {
 }
 
 pub fn is_valid_storage_code(s: &str) -> bool {
-    s.as_bytes()
-        .iter()
-        .all(|c| c.is_ascii_alphanumeric() || c == &b'-')
+    s.as_bytes().iter().all(|c| c.is_ascii_alphanumeric() || c == &b'-')
 }
 
 pub(crate) fn storage_dir() -> PathBuf {
-    PathBuf::from(
-        std::env::var("TRANSBEAM_STORAGE_DIR")
-            .unwrap_or_else(|_| String::from(DEFAULT_STORAGE_DIR)),
-    )
+    PathBuf::from(std::env::var("TRANSBEAM_STORAGE_DIR").unwrap_or_else(|_| String::from(DEFAULT_STORAGE_DIR)))
 }
 
 fn parse_env_var<T: FromStr>(var: &str, default: T) -> T {
-    std::env::var(var)
-        .ok()
-        .and_then(|val| val.parse::<T>().ok())
-        .unwrap_or(default)
+    std::env::var(var).ok().and_then(|val| val.parse::<T>().ok()).unwrap_or(default)
 }
 
 pub(crate) fn max_lifetime() -> u32 {
@@ -205,9 +194,7 @@ impl FileStore {
     ) -> std::io::Result<Result<(), u64>> {
         let remaining_size = max_total_size().saturating_sub(self.total_size());
         let allowed_size = std::cmp::min(remaining_size, max_single_size());
-        if file.size > allowed_size {
-            return Ok(Err(allowed_size));
-        }
+        if file.size > allowed_size { return Ok(Err(allowed_size)); }
         self.0.insert(key, file);
         self.save().await.map(Ok)
     }
@@ -225,7 +212,7 @@ impl FileStore {
     pub(crate) async fn remove_expired_files(&mut self) -> std::io::Result<()> {
         info!("Checking for expired files");
         let now = OffsetDateTime::now_utc();
-        for (key, file) in std::mem::take(&mut self.0).into_iter() {
+        for (key, file) in std::mem::replace(&mut self.0, HashMap::new()).into_iter() {
             if file.expiry > now {
                 self.0.insert(key, file);
             } else {

src/upload.rs

@@ -9,7 +9,7 @@ use serde::{Deserialize, Serialize};
 use time::OffsetDateTime;
 use unicode_normalization::UnicodeNormalization;
 
-use crate::store::{self, storage_dir, StoredFile};
+use crate::store::{storage_dir, StoredFile, self};
 
 const MAX_FILES: usize = 256;
 const FILENAME_DATE_FORMAT: &[time::format_description::FormatItem] =
@@ -44,14 +44,14 @@ impl Error {
         match self {
             Self::Storage(_) => CloseCode::Error,
             Self::Parse(_)
-            | Self::UnexpectedMessageType
-            | Self::ClosedEarly(_)
-            | Self::UnexpectedExtraData => CloseCode::Invalid,
+                | Self::UnexpectedMessageType
+                | Self::ClosedEarly(_)
+                | Self::UnexpectedExtraData => CloseCode::Invalid,
             Self::DuplicateFilename
-            | Self::NoFiles
-            | Self::TooManyFiles
-            | Self::TooLong
-            | Self::TooBig(_) => CloseCode::Policy,
+                | Self::NoFiles
+                | Self::TooManyFiles
+                | Self::TooLong
+                | Self::TooBig(_) => CloseCode::Policy,
         }
     }
 }
@@ -132,15 +132,9 @@ enum ServerMessage {
 impl From<&Error> for ServerMessage {
     fn from(e: &Error) -> Self {
         match e {
-            Error::TooBig(max_size) => ServerMessage::TooBig {
-                max_size: *max_size,
-            },
-            Error::TooLong => ServerMessage::TooLong {
-                max_days: store::max_lifetime(),
-            },
-            _ => ServerMessage::Error {
-                details: e.to_string(),
-            },
+            Error::TooBig(max_size) => ServerMessage::TooBig { max_size: *max_size },
+            Error::TooLong => ServerMessage::TooLong { max_days: store::max_lifetime() },
+            _ => ServerMessage::Error { details: e.to_string() },
         }
     }
 }
@@ -197,17 +191,18 @@ impl Uploader {
         self.cleanup_after_error(ctx);
     }
 
-    fn handle_message(&mut self, msg: ws::Message, ctx: &mut Context) -> Result<bool, Error> {
+    fn handle_message(
+        &mut self,
+        msg: ws::Message,
+        ctx: &mut Context,
+    ) -> Result<bool, Error> {
         trace!("Websocket message: {:?}", msg);
         match msg {
             ws::Message::Text(text) => {
                 if self.writer.is_some() {
                     return Err(Error::UnexpectedMessageType);
                 }
-                let UploadManifest {
-                    files: raw_files,
-                    lifetime,
-                } = serde_json::from_slice(text.as_bytes())?;
+                let UploadManifest { files: raw_files, lifetime, } = serde_json::from_slice(text.as_bytes())?;
                 if lifetime > store::max_lifetime() {
                     return Err(Error::TooLong);
                 }
@@ -240,15 +235,19 @@ impl Uploader {
                     .write(true)
                     .create_new(true)
                     .open(&storage_path)?;
-                let (writer, name, size, modtime): (Box<dyn Write>, _, _, _) = if files.len() > 1 {
+                let (writer, name, size, modtime): (Box<dyn Write>,_,_,_) = if files.len() > 1 {
                     info!("Wrapping in zipfile generator");
                     let now = OffsetDateTime::now_utc();
                     let zip_writer = super::zip::ZipGenerator::new(files, writer);
                     let size = zip_writer.total_size();
-                    let download_filename = super::APP_NAME.to_owned()
-                        + &now.format(FILENAME_DATE_FORMAT).unwrap()
-                        + ".zip";
-                    (Box::new(zip_writer), download_filename, size, now)
+                    let download_filename =
+                        super::APP_NAME.to_owned() + &now.format(FILENAME_DATE_FORMAT).unwrap() + ".zip";
+                    (
+                        Box::new(zip_writer),
+                        download_filename,
+                        size,
+                        now,
+                    )
                 } else {
                     (
                         Box::new(writer),
@@ -262,29 +261,23 @@ impl Uploader {
                     name,
                     size,
                     modtime,
-                    expiry: OffsetDateTime::now_utc() + lifetime * time::Duration::DAY,
+                    expiry: OffsetDateTime::now_utc() + lifetime*time::Duration::DAY,
                 };
                 let data = self.app_data.clone();
                 let storage_filename = self.storage_filename.clone();
-                ctx.spawn(
-                    actix::fut::wrap_future(async move {
-                        debug!("Spawned future to add entry {} to state", storage_filename);
-                        data.write()
-                            .await
-                            .add_file(storage_filename, stored_file)
-                            .await
-                    })
-                    .map(|res, u: &mut Self, ctx: &mut Context| match res {
-                        Ok(Ok(())) => ctx.text(
-                            serde_json::to_string(&ServerMessage::Ready {
-                                code: u.storage_filename.clone(),
-                            })
-                            .unwrap(),
-                        ),
+                ctx.spawn(actix::fut::wrap_future(async move {
+                    debug!("Spawned future to add entry {} to state", storage_filename);
+                    data.write()
+                        .await
+                        .add_file(storage_filename, stored_file)
+                        .await
+                }).map(|res, u: &mut Self, ctx: &mut Context| {
+                    match res {
+                        Ok(Ok(())) => ctx.text(serde_json::to_string(&ServerMessage::Ready { code: u.storage_filename.clone() }).unwrap()),
                         Ok(Err(size)) => u.notify_error_and_cleanup(Error::TooBig(size), ctx),
-                        Err(e) => u.notify_error_and_cleanup(Error::from(e), ctx),
-                    }),
-                );
+                        Err(e) => u.notify_error_and_cleanup(Error::from(e), ctx)
+                    }
+                }));
             }
             ws::Message::Binary(data) | ws::Message::Continuation(Item::Last(data)) => {
                 let result = self.handle_data(data)?;

static/index.html

@@ -16,6 +16,9 @@
       <img src="images/site-icons/transbeam.svg" height="128">
       <h1>transbeam</h1>
     </div>
+
+    <noscript>This page requires Javascript :(</noscript>
+
     <div id="message"></div>
     <div id="upload_controls">
       <div>
@@ -33,11 +36,11 @@
         </label>
       </div>
     </div>
-    <div id="download_code_container">
-      <div id="download_code_main">
-        <div>Download code: <span id="download_code"></span></div><div class="copy_button"></div>
+    <div id="download_link_container">
+      <div id="download_link_main">
+        <div>Download link: <span id="download_link"></span></div><div class="copy_button"></div>
       </div>
-      <div id="copied_message">Link copied!</div>
+      <div id="copied_message">Copied!</div>
     </div>
     <div id="progress_container">
       <div id="progress"></div>
@@ -49,17 +52,6 @@
       <input type="file" multiple id="file_input"/>
       <span class="fake_button" id="file_input_message">Select files to upload...</span>
     </label>
-    <div id="download">
-      <form id="download_form" action="download" method="get">
-        <div>
-          <label>
-            <h4>Or enter a code to download files:</h4>
-            <input type="text" id="download_code_input" name="code" placeholder="Download code"/>
-          </label>
-        </div>
-        <input id="download_button" type="submit" value="Download"/>
-      </form>
-    </div>
     <div id="footer">
       <h5>(c) 2022 xenofem, MIT licensed</h5>
       <h5><a target="_blank" href="https://git.xeno.science/xenofem/transbeam">source</a></h5>

static/states.css

@@ -24,7 +24,7 @@ body.error #message {
 body.selecting #upload_controls { display: revert; }
 body.no_files #upload_controls { display: none; }
 
-body.selecting #download_code_container { display: none; }
+body.selecting #download_link_container { display: none; }
 
 #progress_container { display: none; }
 body.uploading #progress_container { display: revert; }
@@ -37,6 +37,3 @@ body.selecting .delete_button { display: revert; }
 
 #file_input_container { display: none; }
 body.selecting #file_input_container { display: revert; }
-
-#download { display: none; }
-body.no_files #download { display: revert; }

static/transbeam.css

@@ -31,7 +31,7 @@ body {
     background-size: 0;
 }
 
-#download_code_container {
+#download_link_container {
     border: 1px solid #ddd;
     border-radius: 4px;
     padding: 10px;
@@ -41,11 +41,11 @@ body {
     position: relative;
 }
 
-#download_code_container:hover {
+#download_link_container:hover {
     border-color: #777;
 }
 
-#download_code_main {
+#download_link_main {
     display: flex;
     align-items: center;
     gap: 10px;
@@ -60,7 +60,7 @@ body {
     mask-repeat: no-repeat;
 }
 
-#download_code_container:hover .copy_button {
+#download_link_container:hover .copy_button {
     background-color: #000;
 }
 
@@ -74,10 +74,10 @@ body {
     height: fit-content;
     display: none;
 }
-#download_code_container.copied #copied_message {
+#download_link_container.copied #copied_message {
     display: revert;
 }
-#download_code_container.copied #download_code_main {
+#download_link_container.copied #download_link_main {
     visibility: hidden;
 }
 
@@ -128,7 +128,7 @@ input[type="file"] {
     display: none;
 }
 
-button, .fake_button, input[type="submit"] {
+button, .fake_button {
     font-size: 18px;
     color: #000;
     background-color: #ccc;
@@ -138,11 +138,11 @@ button, .fake_button, input[type="submit"] {
     cursor: pointer;
 }
 
-button:hover, .fake_button:hover, input[type="submit"]:hover {
+button:hover, .fake_button:hover {
     background-color: #aaa;
 }
 
-button:disabled, input:disabled + .fake_button, input[type="submit"]:disabled {
+button:disabled, input:disabled + .fake_button {
     color: #666;
     background-color: #eee;
     border-color: #ddd;
@@ -153,15 +153,6 @@ button:disabled, input:disabled + .fake_button, input[type="submit"]:disabled {
     margin-top: 10px;
 }
 
-#download {
-    margin-top: 40px;
-}
-
-#download_code_input {
-    font-size: 18px;
-    margin-bottom: 10px;
-}
-
 #footer {
     margin-top: 30px;
 }

static/transbeam.js

@@ -16,7 +16,7 @@ let fileInput;
 let fileList;
 let uploadButton;
 let lifetimeInput;
-let downloadCode;
+let downloadLink;
 let progress;
 let progressBar;
 
@@ -26,7 +26,7 @@ document.addEventListener('DOMContentLoaded', () => {
     fileList = document.getElementById('file_list');
     uploadButton = document.getElementById('upload');
     lifetimeInput = document.getElementById('lifetime');
-    downloadCode = document.getElementById('download_code');
+    downloadLink = document.getElementById('download_link');
     progress = document.getElementById('progress');
     progressBar = document.getElementById('progress_bar');
 
@@ -38,38 +38,13 @@ document.addEventListener('DOMContentLoaded', () => {
 
     uploadButton.addEventListener('click', beginUpload);
 
-    const downloadCodeContainer = document.getElementById('download_code_container');
-    downloadCodeContainer.addEventListener('click', () => {
-        const downloadUrl = new URL(`download?code=${downloadCode.textContent}`, window.location);
-        navigator.clipboard.writeText(downloadUrl.href);
-        downloadCodeContainer.className = 'copied';
+    const downloadLinkContainer = document.getElementById('download_link_container');
+    downloadLinkContainer.addEventListener('click', () => {
+        navigator.clipboard.writeText(downloadLink.textContent);
+        downloadLinkContainer.className = 'copied';
     });
-    downloadCodeContainer.addEventListener('mouseleave', () => {
-        downloadCodeContainer.className = '';
-    });
-
-    const downloadCodeInput = document.getElementById('download_code_input');
-    const downloadButton = document.getElementById('download_button');
-    const downloadForm = document.getElementById('download_form');
-    downloadCodeInput.addEventListener('beforeinput', (e) => {
-        if (/^[a-zA-Z0-9-]+$/.test(e.data)) { return; }
-        e.preventDefault();
-        if (e.data === ' ') {
-            downloadCodeInput.value += '-';
-        }
-    });
-    const disableEnableDownload = () => { downloadButton.disabled = (downloadCodeInput.value === ''); };
-    disableEnableDownload();
-    downloadCodeInput.addEventListener('input', disableEnableDownload);
-    downloadForm.addEventListener('submit', (e) => {
-        if (downloadCodeInput.value === '') {
-            e.preventDefault();
-        } else {
-            setTimeout(() => {
-                downloadCodeInput.value = '';
-                downloadButton.disabled = true;
-            }, 0);
-        }
+    downloadLinkContainer.addEventListener('mouseleave', () => {
+        downloadLinkContainer.className = '';
     });
 
     updateFiles();
@@ -147,9 +122,7 @@ function beginUpload() {
     byteIndex = 0;
     bytesSent = 0;
 
-    let websocketUrl = new URL('upload', window.location);
-    websocketUrl.protocol = (window.location.protocol === 'http:') ? 'ws:' : 'wss:';
-    socket = new WebSocket(websocketUrl);
+    socket = new WebSocket(`${window.location.protocol === 'http:' ? 'ws' : 'wss'}://${window.location.host}/upload`);
     socket.addEventListener('open', sendManifest);
     socket.addEventListener('message', handleMessage);
     socket.addEventListener('close', handleClose);
@@ -177,7 +150,7 @@ function handleMessage(msg) {
             return;
         }
         if (reply.type === 'ready') {
-            downloadCode.textContent = reply.code;
+            downloadLink.textContent = `${window.location.origin}/download/${reply.code}`;
             updateProgress();
             document.body.className = 'uploading';
             sendData();
@@ -279,7 +252,7 @@ function handleClose(e) {
 
 function finishSending() {
     if (socket.bufferedAmount > 0) {
-        setTimeout(finishSending, 1000);
+        window.setTimeout(finishSending, 1000);
         return;
     }
     socket.close();