Compare commits
4 commits
1cc4a67b04
...
f894373861
Author | SHA1 | Date | |
---|---|---|---|
f894373861 | |||
ffeff8a51b | |||
67be18f228 | |||
91655b22ed |
14 changed files with 131 additions and 1204 deletions
1079
Cargo.lock
generated
1079
Cargo.lock
generated
File diff suppressed because it is too large
Load diff
19
Cargo.toml
19
Cargo.toml
|
@ -27,15 +27,6 @@ bincode = "1.3.3"
|
|||
chrono = { version = "0.4.24", features = ["serde"] }
|
||||
futures = "0.3.28"
|
||||
headers = "0.4.0"
|
||||
leptos = { version = "0.6.14", features = [
|
||||
"ssr",
|
||||
"nightly",
|
||||
"tracing",
|
||||
"default-tls",
|
||||
"experimental-islands",
|
||||
] }
|
||||
leptos_meta = { version = "0.6.14", features = ["ssr"] }
|
||||
leptos_router = { version = "0.6.14", features = ["ssr"] }
|
||||
rand = { version = "0.8.5", features = ["small_rng"] }
|
||||
reqwest = { version = "0.12.7", features = ["json", "native-tls", "blocking"] }
|
||||
sanitize-filename-reader-friendly = "2.2.1"
|
||||
|
@ -47,5 +38,11 @@ tower = { version = "0.5.0", features = ["util"] }
|
|||
tower-http = { version = "0.5.0", features = ["fs", "trace", "limit"] }
|
||||
tracing = "0.1.37"
|
||||
tracing-subscriber = { version = "0.3.16", features = ["env-filter"] }
|
||||
askama = { version = "0.12.1", features = ["with-axum"] }
|
||||
askama_axum = "0.4.0"
|
||||
|
||||
# I want to use askama's block feature, this requires unreleased 0.13
|
||||
[dependencies.askama]
|
||||
git = "https://github.com/djc/askama.git"
|
||||
features = ["with-axum"]
|
||||
|
||||
[dependencies.askama_axum]
|
||||
git = "https://github.com/djc/askama.git"
|
||||
|
|
|
@ -1,7 +1,7 @@
|
|||
use axum::{
|
||||
extract::{ConnectInfo, Request},
|
||||
middleware::{self, Next},
|
||||
response::{Html, IntoResponse},
|
||||
response::IntoResponse,
|
||||
routing::get,
|
||||
Router,
|
||||
};
|
||||
|
@ -12,7 +12,7 @@ use std::{io, net::SocketAddr};
|
|||
|
||||
use nyazoom::*;
|
||||
|
||||
use util::{headers::ForwardedFor, logging, ssr, sweeper};
|
||||
use util::{headers::ForwardedFor, logging, sweeper};
|
||||
|
||||
#[tokio::main]
|
||||
async fn main() -> io::Result<()> {
|
||||
|
|
|
@ -6,7 +6,7 @@ use axum::{
|
|||
};
|
||||
use reqwest::StatusCode;
|
||||
|
||||
use crate::{util::ssr, AppState, AsyncRemoveRecord, DownloadLinkPage};
|
||||
use crate::{askama::DownloadLinkTemplate, AppState, AsyncRemoveRecord};
|
||||
|
||||
pub fn get_link_router() -> Router<AppState> {
|
||||
// Link pages
|
||||
|
@ -18,7 +18,7 @@ pub fn get_link_router() -> Router<AppState> {
|
|||
async fn link(
|
||||
axum::extract::Path(id): axum::extract::Path<String>,
|
||||
State(mut state): State<AppState>,
|
||||
) -> Result<Html<String>, Redirect> {
|
||||
) -> Result<impl IntoResponse, Redirect> {
|
||||
{
|
||||
let mut records = state.records.lock().await;
|
||||
|
||||
|
@ -26,10 +26,10 @@ async fn link(
|
|||
.get_mut(&id)
|
||||
.filter(|record| record.can_be_downloaded())
|
||||
{
|
||||
return Ok(Html(ssr::render({
|
||||
let record = record.clone();
|
||||
|| leptos::view! { <DownloadLinkPage id record /> }
|
||||
})));
|
||||
return Ok(DownloadLinkTemplate {
|
||||
id,
|
||||
record: record.clone(),
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
|
|
|
@ -1,12 +1,6 @@
|
|||
use axum::{
|
||||
extract::State,
|
||||
response::{Html, IntoResponse},
|
||||
routing::get,
|
||||
Json, Router,
|
||||
};
|
||||
use leptos::CollectView;
|
||||
use axum::{extract::State, response::IntoResponse, routing::get, Json, Router};
|
||||
|
||||
use crate::{util::ssr, AppState, HtmxPage};
|
||||
use crate::{askama::LinkListTemplate, AppState};
|
||||
|
||||
pub fn get_records_router() -> Router<AppState> {
|
||||
// Records views
|
||||
|
@ -24,34 +18,6 @@ pub(crate) async fn records(State(state): State<AppState>) -> impl IntoResponse
|
|||
pub async fn records_links(State(state): State<AppState>) -> impl IntoResponse {
|
||||
let records = state.records.lock().await.clone();
|
||||
|
||||
let records_list_view = records
|
||||
.keys()
|
||||
.map(|key| {
|
||||
leptos::view! {
|
||||
<li class="link-wrapper">
|
||||
<a href="/link/{key}">{key}</a>
|
||||
<button
|
||||
style="margin-left: 1em;"
|
||||
hx-target="closest .link-wrapper"
|
||||
hx-swap="outerHTML"
|
||||
hx-delete="/link/{key}"
|
||||
>
|
||||
"X"
|
||||
</button>
|
||||
</li>
|
||||
}
|
||||
})
|
||||
.collect_view();
|
||||
|
||||
Html(ssr::render(move || {
|
||||
leptos::view! {
|
||||
<HtmxPage>
|
||||
<div class="form-wrapper">
|
||||
<div class="column-container">
|
||||
<ul>{records_list_view}</ul>
|
||||
</div>
|
||||
</div>
|
||||
</HtmxPage>
|
||||
}
|
||||
}))
|
||||
let record_keys: Vec<String> = records.keys().cloned().collect();
|
||||
LinkListTemplate { record_keys }
|
||||
}
|
||||
|
|
|
@ -1,5 +1,6 @@
|
|||
use std::path::Path;
|
||||
|
||||
use askama::Template;
|
||||
use async_zip::{base::write::ZipFileWriter, Compression, ZipEntryBuilder};
|
||||
use axum::{
|
||||
extract::{DefaultBodyLimit, Multipart, State},
|
||||
|
@ -14,11 +15,7 @@ use tokio::io;
|
|||
use tokio_util::{compat::FuturesAsyncWriteCompatExt, io::StreamReader};
|
||||
use tower_http::limit::RequestBodyLimitLayer;
|
||||
|
||||
use crate::{
|
||||
cache,
|
||||
util::{self, ssr},
|
||||
AppState, LinkView, UploadRecord,
|
||||
};
|
||||
use crate::{askama::DownloadLinkFragment, cache, util, AppState, UploadRecord};
|
||||
|
||||
pub fn get_upload_router() -> Router<AppState> {
|
||||
// Upload needs a subrouter to increase the body limit
|
||||
|
@ -92,7 +89,7 @@ async fn upload_to_zip(
|
|||
.status(200)
|
||||
.header("Content-Type", "text/html")
|
||||
.header("HX-Push-Url", format!("/link/{}", &id))
|
||||
.body(ssr::render(|| leptos::view! { <LinkView id record /> }))
|
||||
.body(DownloadLinkFragment { id, record }.render().unwrap())
|
||||
.unwrap();
|
||||
|
||||
Ok(response)
|
||||
|
|
|
@ -1,6 +1,5 @@
|
|||
pub mod headers;
|
||||
pub mod logging;
|
||||
pub mod ssr;
|
||||
pub mod sweeper;
|
||||
|
||||
use rand::{
|
||||
|
|
|
@ -1,7 +0,0 @@
|
|||
pub fn render<F, N>(f: F) -> String
|
||||
where
|
||||
F: FnOnce() -> N + 'static,
|
||||
N: leptos::IntoView,
|
||||
{
|
||||
leptos::ssr::render_to_string(f).to_string()
|
||||
}
|
|
@ -1,5 +1,7 @@
|
|||
use askama_axum::Template;
|
||||
|
||||
use crate::{link::get_remaining_text, UploadRecord};
|
||||
|
||||
#[derive(Template)]
|
||||
#[template(path = "welcome.html")]
|
||||
pub struct WelcomeTemplate {
|
||||
|
@ -11,3 +13,38 @@ impl WelcomeTemplate {
|
|||
WelcomeTemplate { fact }
|
||||
}
|
||||
}
|
||||
|
||||
#[derive(Template)]
|
||||
#[template(path = "link.html")]
|
||||
pub struct DownloadLinkTemplate {
|
||||
pub id: String,
|
||||
pub record: UploadRecord,
|
||||
}
|
||||
|
||||
impl DownloadLinkTemplate {
|
||||
fn get_downloads_remaining_text(record: &UploadRecord) -> String {
|
||||
let downloads_remaining = record.max_downloads - record.downloads;
|
||||
get_remaining_text(downloads_remaining)
|
||||
}
|
||||
}
|
||||
|
||||
#[derive(Template)]
|
||||
#[template(path = "link.html", block = "content")]
|
||||
pub struct DownloadLinkFragment {
|
||||
pub id: String,
|
||||
pub record: UploadRecord,
|
||||
}
|
||||
|
||||
impl DownloadLinkFragment {
|
||||
fn get_downloads_remaining_text(record: &UploadRecord) -> String {
|
||||
let downloads_remaining = record.max_downloads - record.downloads;
|
||||
get_remaining_text(downloads_remaining)
|
||||
}
|
||||
}
|
||||
|
||||
#[derive(Template)]
|
||||
#[template(path = "linklist.html")]
|
||||
pub struct LinkListTemplate {
|
||||
pub record_keys: Vec<String>,
|
||||
}
|
||||
|
||||
|
|
|
@ -1,26 +0,0 @@
|
|||
use leptos::{component, view, Children, IntoView};
|
||||
|
||||
#[component]
|
||||
pub fn HtmxPage(children: Children) -> impl IntoView {
|
||||
view! {
|
||||
<head>
|
||||
<title>"Nyazoom"</title>
|
||||
<meta charset="UTF-8" />
|
||||
<meta name="viewport" content="width=device-width, initial-scale=1" />
|
||||
<link href="/css/main.css" rel="stylesheet" />
|
||||
<link href="/css/link.css" rel="stylesheet" />
|
||||
<script src="/scripts/file_label.js" />
|
||||
<script src="/scripts/link.js" />
|
||||
<script
|
||||
src="https://unpkg.com/htmx.org@2.0.2"
|
||||
integrity="sha384-Y7hw+L/jvKeWIRRkqWYfPcvVxHzVzn5REgzbawhxAuQGwX1XWe70vji+VSeHOThJ"
|
||||
crossorigin="anonymous"
|
||||
></script>
|
||||
</head>
|
||||
|
||||
<body>
|
||||
<h1>"NyaZoom"<sup>"2"</sup></h1>
|
||||
{children()}
|
||||
</body>
|
||||
}
|
||||
}
|
|
@ -1,47 +0,0 @@
|
|||
use leptos::{component, view, IntoView};
|
||||
|
||||
use crate::link::get_remaining_text;
|
||||
use crate::state::UploadRecord;
|
||||
use crate::HtmxPage;
|
||||
|
||||
// <link href="../dist/css/link.css" rel="stylesheet" />
|
||||
// #TODO: Handle pushing cleaner
|
||||
#[component]
|
||||
pub fn DownloadLinkPage(id: String, record: UploadRecord) -> impl IntoView {
|
||||
view! {
|
||||
<HtmxPage>
|
||||
<div class="form-wrapper">
|
||||
<LinkView id record />
|
||||
</div>
|
||||
</HtmxPage>
|
||||
}
|
||||
}
|
||||
|
||||
#[component]
|
||||
pub fn LinkView(id: String, record: UploadRecord) -> impl IntoView {
|
||||
let downloads_remaining = record.max_downloads - record.downloads;
|
||||
view! {
|
||||
<div class="column-container">
|
||||
<div class="link-wrapper">
|
||||
<a id="link" href="/download/{id}">
|
||||
"Download Now!"
|
||||
</a>
|
||||
</div>
|
||||
|
||||
<div
|
||||
class="link-wrapper"
|
||||
hx-get="/link/{id}/remaining"
|
||||
hx-trigger="click from:#link delay:0.2s, every 10s"
|
||||
>
|
||||
{get_remaining_text(downloads_remaining)}
|
||||
</div>
|
||||
<button class="return-button" onclick="clipboard()">
|
||||
Copy to Clipboard
|
||||
</button>
|
||||
|
||||
<a href="/" class="return-button">
|
||||
"Return to home"
|
||||
</a>
|
||||
</div>
|
||||
}
|
||||
}
|
|
@ -2,11 +2,6 @@ use futures::TryFutureExt;
|
|||
use serde::Deserialize;
|
||||
|
||||
pub mod askama;
|
||||
pub mod base_page;
|
||||
pub mod links;
|
||||
|
||||
pub use base_page::*;
|
||||
pub use links::*;
|
||||
|
||||
#[derive(Debug, Deserialize)]
|
||||
pub struct CatFact {
|
||||
|
|
24
templates/link.html
Normal file
24
templates/link.html
Normal file
|
@ -0,0 +1,24 @@
|
|||
{% extends "base.html" %}
|
||||
|
||||
{% block content %}
|
||||
<div class="form-wrapper">
|
||||
<div class="column-container">
|
||||
<div class="link-wrapper">
|
||||
<a id="link" href="/download/{{id}}"> "Download Now!" </a>
|
||||
</div>
|
||||
|
||||
<div
|
||||
class="link-wrapper"
|
||||
hx-get="/link/{{id}}/remaining"
|
||||
hx-trigger="click from:#link delay:0.2s, every 10s"
|
||||
>
|
||||
{{Self::get_downloads_remaining_text(record)}}
|
||||
</div>
|
||||
<button class="return-button" onclick="clipboard()">
|
||||
Copy to Clipboard
|
||||
</button>
|
||||
|
||||
<a href="/" class="return-button"> "Return to home" </a>
|
||||
</div>
|
||||
</div>
|
||||
{% endblock content %}
|
23
templates/linklist.html
Normal file
23
templates/linklist.html
Normal file
|
@ -0,0 +1,23 @@
|
|||
{% extends "base.html" %}
|
||||
|
||||
{% block content %}
|
||||
<div class="form-wrapper">
|
||||
<div class="column-container">
|
||||
<ul>
|
||||
{% for key in record_keys %}
|
||||
<li class="link-wrapper">
|
||||
<a href="/link/{{ key }}">{{ key }}</a>
|
||||
<button
|
||||
style="margin-left: 1em;"
|
||||
hx-target="closest .link-wrapper"
|
||||
hx-swap="outerHTML"
|
||||
hx-delete="/link/{{ key }}"
|
||||
>
|
||||
"X"
|
||||
</button>
|
||||
</li>
|
||||
{% endfor %}
|
||||
</ul>
|
||||
</div>
|
||||
</div>
|
||||
{% endblock content %}
|
Loading…
Reference in a new issue