Compare commits

..

2 Commits

Author SHA1 Message Date
fdb-hiroshima 6c73f993d0 unwrap when failling to open .env in plume
**this is a debug commit not expected to reach master, an actual fix will be needed**
2019-07-01 17:37:57 +02:00
fdb-hiroshima 777cbaa69d unwrap when failling to open .env in plm
**this is a debug commit not expected to reach master, an actual fix will be needed**
2019-07-01 17:36:21 +02:00
57 changed files with 11337 additions and 11570 deletions
Generated
+132 -341
View File
File diff suppressed because it is too large Load Diff
+5 -7
View File
@@ -8,7 +8,6 @@ repository = "https://github.com/Plume-org/Plume"
activitypub = "0.1.3" activitypub = "0.1.3"
askama_escape = "0.1" askama_escape = "0.1"
atom_syndication = "0.6" atom_syndication = "0.6"
clap = "2.33"
colored = "1.8" colored = "1.8"
dotenv = "0.14" dotenv = "0.14"
gettext = { git = "https://github.com/Plume-org/gettext/", rev = "294c54d74c699fbc66502b480a37cc66c1daa7f3" } gettext = { git = "https://github.com/Plume-org/gettext/", rev = "294c54d74c699fbc66502b480a37cc66c1daa7f3" }
@@ -18,21 +17,20 @@ guid-create = "0.1"
heck = "0.3.0" heck = "0.3.0"
lettre = { git = "https://github.com/lettre/lettre", rev = "c988b1760ad8179d9e7f3fb8594d2b86cf2a0a49" } lettre = { git = "https://github.com/lettre/lettre", rev = "c988b1760ad8179d9e7f3fb8594d2b86cf2a0a49" }
lettre_email = { git = "https://github.com/lettre/lettre", rev = "c988b1760ad8179d9e7f3fb8594d2b86cf2a0a49" } lettre_email = { git = "https://github.com/lettre/lettre", rev = "c988b1760ad8179d9e7f3fb8594d2b86cf2a0a49" }
num_cpus = "1.10" num_cpus = "1.0"
reqwest = "0.9"
rocket = "0.4.0" rocket = "0.4.0"
rocket_contrib = { version = "0.4.0", features = ["json"] } rocket_contrib = { version = "0.4.0", features = ["json"] }
rocket_i18n = { git = "https://github.com/Plume-org/rocket_i18n", rev = "e922afa7c366038b3433278c03b1456b346074f2" } rocket_i18n = { git = "https://github.com/Plume-org/rocket_i18n", rev = "e922afa7c366038b3433278c03b1456b346074f2" }
rpassword = "4.0" rpassword = "3.0"
runtime-fmt = "0.3.0" runtime-fmt = "0.3.0"
scheduled-thread-pool = "0.2.2" scheduled-thread-pool = "0.2.0"
serde = "1.0" serde = "1.0"
serde_json = "1.0" serde_json = "1.0"
serde_qs = "0.5" serde_qs = "0.4"
shrinkwraprs = "0.2.1" shrinkwraprs = "0.2.1"
validator = "0.8" validator = "0.8"
validator_derive = "0.8" validator_derive = "0.8"
webfinger = "0.4.1" webfinger = "0.3.1"
[[bin]] [[bin]]
name = "plume" name = "plume"
@@ -1,2 +0,0 @@
-- undo the adding of custom_domain column to blogs table.
ALTER TABLE blogs DROP COLUMN custom_domain;
@@ -1,2 +0,0 @@
--- Adding custom domain to Blog as an optional field
ALTER TABLE blogs ADD COLUMN custom_domain VARCHAR DEFAULT NULL UNIQUE;
@@ -1,56 +0,0 @@
-- undo the adding of "custom_domain" to blogs
CREATE TABLE IF NOT EXISTS "blogs_drop_custom_domain" (
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
actor_id VARCHAR NOT NULL,
title VARCHAR NOT NULL,
summary TEXT NOT NULL DEFAULT '',
outbox_url VARCHAR NOT NULL UNIQUE,
inbox_url VARCHAR NOT NULL UNIQUE,
instance_id INTEGER REFERENCES instances(id) ON DELETE CASCADE NOT NULL,
creation_date DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
ap_url text not null default '' UNIQUE,
private_key TEXT,
public_key TEXT NOT NULL DEFAULT '',
fqn TEXT NOT NULL DEFAULT '',
summary_html TEXT NOT NULL DEFAULT '',
icon_id INTEGER REFERENCES medias(id) ON DELETE SET NULL DEFAULT NULL,
banner_id INTEGER REFERENCES medias(id) ON DELETE SET NULL DEFAULT NULL,
CONSTRAINT blog_unique UNIQUE (actor_id, instance_id)
);
INSERT INTO blogs_drop_custom_domain (
id,
actor_id,
title,
summary,
outbox_url,
inbox_url,
instance_id,
creation_date,
ap_url,
private_key,
public_key,
fqn,
summary_html,
icon_id,
banner_id
) SELECT
id,
actor_id,
title,
summary,
outbox_url,
inbox_url,
instance_id,
creation_date,
ap_url,
private_key,
public_key,
fqn,
summary_html,
icon_id,
banner_id
FROM blogs;
DROP TABLE blogs;
ALTER TABLE "blogs_drop_custom_domain" RENAME to blogs;
@@ -1,57 +0,0 @@
-- add custom_domain to blogs
CREATE TABLE IF NOT EXISTS "blogs_add_custom_domain" (
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
actor_id VARCHAR NOT NULL,
title VARCHAR NOT NULL,
summary TEXT NOT NULL DEFAULT '',
outbox_url VARCHAR NOT NULL UNIQUE,
inbox_url VARCHAR NOT NULL UNIQUE,
instance_id INTEGER REFERENCES instances(id) ON DELETE CASCADE NOT NULL,
creation_date DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
ap_url text not null default '' UNIQUE,
private_key TEXT,
public_key TEXT NOT NULL DEFAULT '',
fqn TEXT NOT NULL DEFAULT '',
summary_html TEXT NOT NULL DEFAULT '',
icon_id INTEGER REFERENCES medias(id) ON DELETE SET NULL DEFAULT NULL,
banner_id INTEGER REFERENCES medias(id) ON DELETE SET NULL DEFAULT NULL,
custom_domain text default NULL UNIQUE,
CONSTRAINT blog_unique UNIQUE (actor_id, instance_id)
);
INSERT INTO blogs_add_custom_domain (
id,
actor_id,
title,
summary,
outbox_url,
inbox_url,
instance_id,
creation_date,
ap_url,
private_key,
public_key,
fqn,
summary_html,
icon_id,
banner_id
) SELECT
id,
actor_id,
title,
summary,
outbox_url,
inbox_url,
instance_id,
creation_date,
ap_url,
private_key,
public_key,
fqn,
summary_html,
icon_id,
banner_id
FROM blogs;
DROP TABLE blogs;
ALTER TABLE "blogs_add_custom_domain" RENAME to blogs;
+1 -1
View File
@@ -10,7 +10,7 @@ path = "src/main.rs"
[dependencies] [dependencies]
clap = "2.33" clap = "2.33"
dotenv = "0.14" dotenv = "0.14"
rpassword = "4.0" rpassword = "3.0"
[dependencies.diesel] [dependencies.diesel]
features = ["r2d2", "chrono"] features = ["r2d2", "chrono"]
+1 -5
View File
@@ -25,11 +25,7 @@ fn main() {
.subcommand(users::command()); .subcommand(users::command());
let matches = app.clone().get_matches(); let matches = app.clone().get_matches();
match dotenv::dotenv() { dotenv::dotenv().expect("error while reading .env");
Ok(path) => println!("Configuration read from {}", path.display()),
Err(ref e) if e.not_found() => eprintln!("no .env was found"),
e => e.map(|_| ()).unwrap(),
}
let conn = Conn::establish(CONFIG.database_url.as_str()); let conn = Conn::establish(CONFIG.database_url.as_str());
let _ = conn.as_ref().map(|conn| Instance::cache_local(conn)); let _ = conn.as_ref().map(|conn| Instance::cache_local(conn));
+3 -3
View File
@@ -5,13 +5,13 @@ authors = ["Plume contributors"]
[dependencies] [dependencies]
activitypub = "0.1.1" activitypub = "0.1.1"
activitystreams-derive = "0.1.1" activitystreams-derive = "0.1.0"
activitystreams-traits = "0.1.0" activitystreams-traits = "0.1.0"
array_tool = "1.0" array_tool = "1.0"
base64 = "0.10" base64 = "0.10"
heck = "0.3.0" heck = "0.3.0"
hex = "0.3" hex = "0.3"
hyper = "0.12.33" hyper = "0.12.28"
openssl = "0.10.22" openssl = "0.10.22"
rocket = "0.4.0" rocket = "0.4.0"
reqwest = "0.9" reqwest = "0.9"
@@ -19,7 +19,7 @@ serde = "1.0"
serde_derive = "1.0" serde_derive = "1.0"
serde_json = "1.0" serde_json = "1.0"
shrinkwraprs = "0.2.1" shrinkwraprs = "0.2.1"
tokio = "0.1.22" tokio = "0.1.21"
[dependencies.chrono] [dependencies.chrono]
features = ["serde"] features = ["serde"]
+2 -2
View File
@@ -4,8 +4,8 @@ version = "0.3.0"
authors = ["Plume contributors"] authors = ["Plume contributors"]
[dependencies] [dependencies]
stdweb = "=0.4.18" stdweb = "=0.4.14"
stdweb-internal-runtime = "=0.1.4" stdweb-internal-runtime = "=0.1.3"
gettext = { git = "https://github.com/Plume-org/gettext/", rev = "294c54d74c699fbc66502b480a37cc66c1daa7f3" } gettext = { git = "https://github.com/Plume-org/gettext/", rev = "294c54d74c699fbc66502b480a37cc66c1daa7f3" }
gettext-macros = { git = "https://github.com/Plume-org/gettext-macros/", rev = "a7c605f7edd6bfbfbfe7778026bfefd88d82db10" } gettext-macros = { git = "https://github.com/Plume-org/gettext-macros/", rev = "a7c605f7edd6bfbfbfe7778026bfefd88d82db10" }
gettext-utils = { git = "https://github.com/Plume-org/gettext-macros/", rev = "a7c605f7edd6bfbfbfe7778026bfefd88d82db10" } gettext-utils = { git = "https://github.com/Plume-org/gettext-macros/", rev = "a7c605f7edd6bfbfbfe7778026bfefd88d82db10" }
+6 -5
View File
@@ -7,7 +7,7 @@ authors = ["Plume contributors"]
activitypub = "0.1.1" activitypub = "0.1.1"
ammonia = "2.1.1" ammonia = "2.1.1"
askama_escape = "0.1" askama_escape = "0.1"
bcrypt = "0.5" bcrypt = "0.4"
guid-create = "0.1" guid-create = "0.1"
heck = "0.3.0" heck = "0.3.0"
itertools = "0.8.0" itertools = "0.8.0"
@@ -17,14 +17,15 @@ openssl = "0.10.22"
rocket = "0.4.0" rocket = "0.4.0"
rocket_i18n = { git = "https://github.com/Plume-org/rocket_i18n", rev = "e922afa7c366038b3433278c03b1456b346074f2" } rocket_i18n = { git = "https://github.com/Plume-org/rocket_i18n", rev = "e922afa7c366038b3433278c03b1456b346074f2" }
reqwest = "0.9" reqwest = "0.9"
scheduled-thread-pool = "0.2.2" scheduled-thread-pool = "0.2.0"
serde = "1.0" serde = "1.0"
serde_derive = "1.0" serde_derive = "1.0"
serde_json = "1.0" serde_json = "1.0"
tantivy = "0.10.1" tantivy = "0.9.1"
url = "2.1" url = "1.7"
webfinger = "0.4.1" webfinger = "0.3.1"
whatlang = "0.7.1" whatlang = "0.7.1"
shrinkwraprs = "0.2.1"
diesel-derive-newtype = "0.1.2" diesel-derive-newtype = "0.1.2"
[dependencies.chrono] [dependencies.chrono]
+1 -121
View File
@@ -7,11 +7,6 @@ use openssl::{
rsa::Rsa, rsa::Rsa,
sign::{Signer, Verifier}, sign::{Signer, Verifier},
}; };
use rocket::{
http::RawStr,
outcome::IntoOutcome,
request::{self, FromFormValue, FromRequest, Request},
};
use serde_json; use serde_json;
use url::Url; use url::Url;
use webfinger::*; use webfinger::*;
@@ -26,70 +21,11 @@ use posts::Post;
use safe_string::SafeString; use safe_string::SafeString;
use schema::blogs; use schema::blogs;
use search::Searcher; use search::Searcher;
use std::default::Default;
use std::fmt::{self, Display};
use std::ops::Deref;
use std::sync::RwLock;
use users::User; use users::User;
use {Connection, Error, PlumeRocket, Result}; use {Connection, Error, PlumeRocket, Result};
pub type CustomGroup = CustomObject<ApSignature, Group>; pub type CustomGroup = CustomObject<ApSignature, Group>;
#[derive(Clone, Debug, PartialEq, DieselNewType)]
pub struct Host(String);
impl Host {
pub fn new(host: impl ToString) -> Host {
Host(host.to_string())
}
}
impl Deref for Host {
type Target = str;
fn deref(&self) -> &str {
&self.0
}
}
impl Display for Host {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
write!(f, "{}", self.0)
}
}
impl AsRef<str> for Host {
fn as_ref(&self) -> &str {
&self.0
}
}
impl<'a, 'r> FromRequest<'a, 'r> for Host {
type Error = ();
fn from_request(request: &'a Request<'r>) -> request::Outcome<Host, ()> {
request
.headers()
.get_one("Host")
.and_then(|x| {
if Blog::list_custom_domains().contains(&x.to_string()) {
Some(Host::new(x))
} else {
None
}
})
.or_forward(())
}
}
impl<'v> FromFormValue<'v> for Host {
type Error = &'v RawStr;
fn from_form_value(form_value: &'v RawStr) -> std::result::Result<Host, &'v RawStr> {
let val = String::from_form_value(form_value)?;
Ok(Host::new(&val))
}
}
#[derive(Queryable, Identifiable, Clone, AsChangeset)] #[derive(Queryable, Identifiable, Clone, AsChangeset)]
#[changeset_options(treat_none_as_null = "true")] #[changeset_options(treat_none_as_null = "true")]
pub struct Blog { pub struct Blog {
@@ -108,7 +44,6 @@ pub struct Blog {
pub summary_html: SafeString, pub summary_html: SafeString,
pub icon_id: Option<i32>, pub icon_id: Option<i32>,
pub banner_id: Option<i32>, pub banner_id: Option<i32>,
pub custom_domain: Option<Host>,
} }
#[derive(Default, Insertable)] #[derive(Default, Insertable)]
@@ -126,15 +61,10 @@ pub struct NewBlog {
pub summary_html: SafeString, pub summary_html: SafeString,
pub icon_id: Option<i32>, pub icon_id: Option<i32>,
pub banner_id: Option<i32>, pub banner_id: Option<i32>,
pub custom_domain: Option<Host>,
} }
const BLOG_PREFIX: &str = "~"; const BLOG_PREFIX: &str = "~";
lazy_static! {
static ref CUSTOM_DOMAINS: RwLock<Vec<String>> = RwLock::new(vec![]);
}
impl Blog { impl Blog {
insert!(blogs, NewBlog, |inserted, conn| { insert!(blogs, NewBlog, |inserted, conn| {
let instance = inserted.get_instance(conn)?; let instance = inserted.get_instance(conn)?;
@@ -214,15 +144,8 @@ impl Blog {
} }
} }
pub fn find_by_host(c: &PlumeRocket, host: Host) -> Result<Blog> {
blogs::table
.filter(blogs::custom_domain.eq(host))
.first::<Blog>(&*c.conn)
.map_err(|_| Error::NotFound)
}
fn fetch_from_webfinger(c: &PlumeRocket, acct: &str) -> Result<Blog> { fn fetch_from_webfinger(c: &PlumeRocket, acct: &str) -> Result<Blog> {
resolve_with_prefix(Prefix::Group, acct.to_owned(), true)? resolve(acct.to_owned(), true)?
.links .links
.into_iter() .into_iter()
.find(|l| l.mime_type == Some(String::from("application/activity+json"))) .find(|l| l.mime_type == Some(String::from("application/activity+json")))
@@ -346,19 +269,6 @@ impl Blog {
}) })
} }
pub fn url(&self) -> String {
format!(
"https://{}",
self.custom_domain
.clone()
.unwrap_or_else(|| Host::new(format!(
"{}/~/{}",
Instance::get_local().unwrap().public_domain,
self.fqn,
)))
)
}
pub fn icon_url(&self, conn: &Connection) -> String { pub fn icon_url(&self, conn: &Connection) -> String {
self.icon_id self.icon_id
.and_then(|id| Media::get(conn, id).and_then(|m| m.url()).ok()) .and_then(|id| Media::get(conn, id).and_then(|m| m.url()).ok())
@@ -380,23 +290,6 @@ impl Blog {
.map(|_| ()) .map(|_| ())
.map_err(Error::from) .map_err(Error::from)
} }
pub fn list_custom_domains() -> Vec<String> {
CUSTOM_DOMAINS.read().unwrap().clone()
}
pub fn cache_custom_domains(conn: &Connection) {
*CUSTOM_DOMAINS.write().unwrap() = Blog::list_custom_domains_uncached(conn).unwrap();
}
pub fn list_custom_domains_uncached(conn: &Connection) -> Result<Vec<String>> {
blogs::table
.filter(blogs::custom_domain.is_not_null())
.select(blogs::custom_domain)
.load::<Option<String>>(conn)
.map_err(Error::from)
.map(|res| res.into_iter().map(Option::unwrap).collect::<Vec<_>>())
}
} }
impl IntoId for Blog { impl IntoId for Blog {
@@ -499,7 +392,6 @@ impl FromId<PlumeRocket> for Blog {
.summary_string() .summary_string()
.unwrap_or_default(), .unwrap_or_default(),
), ),
custom_domain: None,
}, },
) )
} }
@@ -549,7 +441,6 @@ impl NewBlog {
title: String, title: String,
summary: String, summary: String,
instance_id: i32, instance_id: i32,
custom_domain: Option<Host>,
) -> Result<NewBlog> { ) -> Result<NewBlog> {
let (pub_key, priv_key) = sign::gen_keypair(); let (pub_key, priv_key) = sign::gen_keypair();
Ok(NewBlog { Ok(NewBlog {
@@ -559,7 +450,6 @@ impl NewBlog {
instance_id, instance_id,
public_key: String::from_utf8(pub_key).or(Err(Error::Signature))?, public_key: String::from_utf8(pub_key).or(Err(Error::Signature))?,
private_key: Some(String::from_utf8(priv_key).or(Err(Error::Signature))?), private_key: Some(String::from_utf8(priv_key).or(Err(Error::Signature))?),
custom_domain,
..NewBlog::default() ..NewBlog::default()
}) })
} }
@@ -587,7 +477,6 @@ pub(crate) mod tests {
"Blog name".to_owned(), "Blog name".to_owned(),
"This is a small blog".to_owned(), "This is a small blog".to_owned(),
Instance::get_local().unwrap().id, Instance::get_local().unwrap().id,
None,
) )
.unwrap(), .unwrap(),
) )
@@ -599,7 +488,6 @@ pub(crate) mod tests {
"My blog".to_owned(), "My blog".to_owned(),
"Welcome to my blog".to_owned(), "Welcome to my blog".to_owned(),
Instance::get_local().unwrap().id, Instance::get_local().unwrap().id,
Some(Host::new("blog.myname.me")),
) )
.unwrap(), .unwrap(),
) )
@@ -611,7 +499,6 @@ pub(crate) mod tests {
"Why I like Plume".to_owned(), "Why I like Plume".to_owned(),
"In this blog I will explay you why I like Plume so much".to_owned(), "In this blog I will explay you why I like Plume so much".to_owned(),
Instance::get_local().unwrap().id, Instance::get_local().unwrap().id,
None,
) )
.unwrap(), .unwrap(),
) )
@@ -672,7 +559,6 @@ pub(crate) mod tests {
"Some name".to_owned(), "Some name".to_owned(),
"This is some blog".to_owned(), "This is some blog".to_owned(),
Instance::get_local().unwrap().id, Instance::get_local().unwrap().id,
Some(Host::new("some.blog.com")),
) )
.unwrap(), .unwrap(),
) )
@@ -701,7 +587,6 @@ pub(crate) mod tests {
"Some name".to_owned(), "Some name".to_owned(),
"This is some blog".to_owned(), "This is some blog".to_owned(),
Instance::get_local().unwrap().id, Instance::get_local().unwrap().id,
None,
) )
.unwrap(), .unwrap(),
) )
@@ -713,7 +598,6 @@ pub(crate) mod tests {
"Blog".to_owned(), "Blog".to_owned(),
"I've named my blog Blog".to_owned(), "I've named my blog Blog".to_owned(),
Instance::get_local().unwrap().id, Instance::get_local().unwrap().id,
Some(Host::new("named.example.blog")),
) )
.unwrap(), .unwrap(),
) )
@@ -806,7 +690,6 @@ pub(crate) mod tests {
"Some name".to_owned(), "Some name".to_owned(),
"This is some blog".to_owned(), "This is some blog".to_owned(),
Instance::get_local().unwrap().id, Instance::get_local().unwrap().id,
None,
) )
.unwrap(), .unwrap(),
) )
@@ -831,7 +714,6 @@ pub(crate) mod tests {
"Some name".to_owned(), "Some name".to_owned(),
"This is some blog".to_owned(), "This is some blog".to_owned(),
Instance::get_local().unwrap().id, Instance::get_local().unwrap().id,
Some(Host::new("some.blog.com")),
) )
.unwrap(), .unwrap(),
) )
@@ -870,7 +752,6 @@ pub(crate) mod tests {
"Some name".to_owned(), "Some name".to_owned(),
"This is some blog".to_owned(), "This is some blog".to_owned(),
Instance::get_local().unwrap().id, Instance::get_local().unwrap().id,
None,
) )
.unwrap(), .unwrap(),
) )
@@ -882,7 +763,6 @@ pub(crate) mod tests {
"Blog".to_owned(), "Blog".to_owned(),
"I've named my blog Blog".to_owned(), "I've named my blog Blog".to_owned(),
Instance::get_local().unwrap().id, Instance::get_local().unwrap().id,
Some(Host::new("my.blog.com")),
) )
.unwrap(), .unwrap(),
) )
-2
View File
@@ -10,8 +10,6 @@ extern crate bcrypt;
extern crate chrono; extern crate chrono;
#[macro_use] #[macro_use]
extern crate diesel; extern crate diesel;
#[macro_use]
extern crate diesel_derive_newtype;
extern crate guid_create; extern crate guid_create;
extern crate heck; extern crate heck;
extern crate itertools; extern crate itertools;
+76 -77
View File
@@ -1,17 +1,17 @@
table! { table! {
api_tokens (id) { api_tokens (id) {
id -> Integer, id -> Int4,
creation_date -> Timestamp, creation_date -> Timestamp,
value -> Text, value -> Text,
scopes -> Text, scopes -> Text,
app_id -> Integer, app_id -> Int4,
user_id -> Integer, user_id -> Int4,
} }
} }
table! { table! {
apps (id) { apps (id) {
id -> Integer, id -> Int4,
name -> Text, name -> Text,
client_id -> Text, client_id -> Text,
client_secret -> Text, client_secret -> Text,
@@ -23,71 +23,70 @@ table! {
table! { table! {
blog_authors (id) { blog_authors (id) {
id -> Integer, id -> Int4,
blog_id -> Integer, blog_id -> Int4,
author_id -> Integer, author_id -> Int4,
is_owner -> Bool, is_owner -> Bool,
} }
} }
table! { table! {
blogs (id) { blogs (id) {
id -> Integer, id -> Int4,
actor_id -> Text, actor_id -> Varchar,
title -> Text, title -> Varchar,
summary -> Text, summary -> Text,
outbox_url -> Text, outbox_url -> Varchar,
inbox_url -> Text, inbox_url -> Varchar,
instance_id -> Integer, instance_id -> Int4,
creation_date -> Timestamp, creation_date -> Timestamp,
ap_url -> Text, ap_url -> Text,
private_key -> Nullable<Text>, private_key -> Nullable<Text>,
public_key -> Text, public_key -> Text,
fqn -> Text, fqn -> Text,
summary_html -> Text, summary_html -> Text,
icon_id -> Nullable<Integer>, icon_id -> Nullable<Int4>,
banner_id -> Nullable<Integer>, banner_id -> Nullable<Int4>,
custom_domain -> Nullable<Text>,
}
}
table! {
comment_seers (id) {
id -> Integer,
comment_id -> Integer,
user_id -> Integer,
} }
} }
table! { table! {
comments (id) { comments (id) {
id -> Integer, id -> Int4,
content -> Text, content -> Text,
in_response_to_id -> Nullable<Integer>, in_response_to_id -> Nullable<Int4>,
post_id -> Integer, post_id -> Int4,
author_id -> Integer, author_id -> Int4,
creation_date -> Timestamp, creation_date -> Timestamp,
ap_url -> Nullable<Text>, ap_url -> Nullable<Varchar>,
sensitive -> Bool, sensitive -> Bool,
spoiler_text -> Text, spoiler_text -> Text,
public_visibility -> Bool, public_visibility -> Bool,
} }
} }
table! {
comment_seers (id) {
id -> Int4,
comment_id -> Int4,
user_id -> Int4,
}
}
table! { table! {
follows (id) { follows (id) {
id -> Integer, id -> Int4,
follower_id -> Integer, follower_id -> Int4,
following_id -> Integer, following_id -> Int4,
ap_url -> Text, ap_url -> Text,
} }
} }
table! { table! {
instances (id) { instances (id) {
id -> Integer, id -> Int4,
public_domain -> Text, public_domain -> Varchar,
name -> Text, name -> Varchar,
local -> Bool, local -> Bool,
blocked -> Bool, blocked -> Bool,
creation_date -> Timestamp, creation_date -> Timestamp,
@@ -95,50 +94,50 @@ table! {
short_description -> Text, short_description -> Text,
long_description -> Text, long_description -> Text,
default_license -> Text, default_license -> Text,
long_description_html -> Text, long_description_html -> Varchar,
short_description_html -> Text, short_description_html -> Varchar,
} }
} }
table! { table! {
likes (id) { likes (id) {
id -> Integer, id -> Int4,
user_id -> Integer, user_id -> Int4,
post_id -> Integer, post_id -> Int4,
creation_date -> Timestamp, creation_date -> Timestamp,
ap_url -> Text, ap_url -> Varchar,
} }
} }
table! { table! {
medias (id) { medias (id) {
id -> Integer, id -> Int4,
file_path -> Text, file_path -> Text,
alt_text -> Text, alt_text -> Text,
is_remote -> Bool, is_remote -> Bool,
remote_url -> Nullable<Text>, remote_url -> Nullable<Text>,
sensitive -> Bool, sensitive -> Bool,
content_warning -> Nullable<Text>, content_warning -> Nullable<Text>,
owner_id -> Integer, owner_id -> Int4,
} }
} }
table! { table! {
mentions (id) { mentions (id) {
id -> Integer, id -> Int4,
mentioned_id -> Integer, mentioned_id -> Int4,
post_id -> Nullable<Integer>, post_id -> Nullable<Int4>,
comment_id -> Nullable<Integer>, comment_id -> Nullable<Int4>,
} }
} }
table! { table! {
notifications (id) { notifications (id) {
id -> Integer, id -> Int4,
user_id -> Integer, user_id -> Int4,
creation_date -> Timestamp, creation_date -> Timestamp,
kind -> Text, kind -> Varchar,
object_id -> Integer, object_id -> Int4,
} }
} }
@@ -153,67 +152,67 @@ table! {
table! { table! {
post_authors (id) { post_authors (id) {
id -> Integer, id -> Int4,
post_id -> Integer, post_id -> Int4,
author_id -> Integer, author_id -> Int4,
} }
} }
table! { table! {
posts (id) { posts (id) {
id -> Integer, id -> Int4,
blog_id -> Integer, blog_id -> Int4,
slug -> Text, slug -> Varchar,
title -> Text, title -> Varchar,
content -> Text, content -> Text,
published -> Bool, published -> Bool,
license -> Text, license -> Varchar,
creation_date -> Timestamp, creation_date -> Timestamp,
ap_url -> Text, ap_url -> Varchar,
subtitle -> Text, subtitle -> Text,
source -> Text, source -> Text,
cover_id -> Nullable<Integer>, cover_id -> Nullable<Int4>,
} }
} }
table! { table! {
reshares (id) { reshares (id) {
id -> Integer, id -> Int4,
user_id -> Integer, user_id -> Int4,
post_id -> Integer, post_id -> Int4,
ap_url -> Text, ap_url -> Varchar,
creation_date -> Timestamp, creation_date -> Timestamp,
} }
} }
table! { table! {
tags (id) { tags (id) {
id -> Integer, id -> Int4,
tag -> Text, tag -> Text,
is_hashtag -> Bool, is_hashtag -> Bool,
post_id -> Integer, post_id -> Int4,
} }
} }
table! { table! {
users (id) { users (id) {
id -> Integer, id -> Int4,
username -> Text, username -> Varchar,
display_name -> Text, display_name -> Varchar,
outbox_url -> Text, outbox_url -> Varchar,
inbox_url -> Text, inbox_url -> Varchar,
is_admin -> Bool, is_admin -> Bool,
summary -> Text, summary -> Text,
email -> Nullable<Text>, email -> Nullable<Text>,
hashed_password -> Nullable<Text>, hashed_password -> Nullable<Text>,
instance_id -> Integer, instance_id -> Int4,
creation_date -> Timestamp, creation_date -> Timestamp,
ap_url -> Text, ap_url -> Text,
private_key -> Nullable<Text>, private_key -> Nullable<Text>,
public_key -> Text, public_key -> Text,
shared_inbox_url -> Nullable<Text>, shared_inbox_url -> Nullable<Varchar>,
followers_endpoint -> Text, followers_endpoint -> Varchar,
avatar_id -> Nullable<Integer>, avatar_id -> Nullable<Int4>,
last_fetched_date -> Timestamp, last_fetched_date -> Timestamp,
fqn -> Text, fqn -> Text,
summary_html -> Text, summary_html -> Text,
@@ -249,8 +248,8 @@ allow_tables_to_appear_in_same_query!(
apps, apps,
blog_authors, blog_authors,
blogs, blogs,
comment_seers,
comments, comments,
comment_seers,
follows, follows,
instances, instances,
likes, likes,
+1 -1
View File
@@ -707,7 +707,7 @@ impl User {
mime_type: None, mime_type: None,
href: None, href: None,
template: Some(format!( template: Some(format!(
"https://{}/remote_interact?{{uri}}", "{}/remote_interact?{{uri}}",
self.get_instance(conn)?.public_domain self.get_instance(conn)?.public_domain
)), )),
}, },
+490 -460
View File
File diff suppressed because it is too large Load Diff
+461 -434
View File
File diff suppressed because it is too large Load Diff
+476 -446
View File
File diff suppressed because it is too large Load Diff
+498 -468
View File
File diff suppressed because it is too large Load Diff
+501 -471
View File
File diff suppressed because it is too large Load Diff
+438 -411
View File
File diff suppressed because it is too large Load Diff
+443 -416
View File
File diff suppressed because it is too large Load Diff
+496 -466
View File
File diff suppressed because it is too large Load Diff
+515 -485
View File
File diff suppressed because it is too large Load Diff
+500 -470
View File
File diff suppressed because it is too large Load Diff
+474 -447
View File
File diff suppressed because it is too large Load Diff
+463 -436
View File
File diff suppressed because it is too large Load Diff
+499 -469
View File
File diff suppressed because it is too large Load Diff
+505 -475
View File
File diff suppressed because it is too large Load Diff
+518 -488
View File
File diff suppressed because it is too large Load Diff
+496 -466
View File
File diff suppressed because it is too large Load Diff
+426 -406
View File
File diff suppressed because it is too large Load Diff
+492 -462
View File
File diff suppressed because it is too large Load Diff
+463 -436
View File
File diff suppressed because it is too large Load Diff
+468 -438
View File
File diff suppressed because it is too large Load Diff
+499 -469
View File
File diff suppressed because it is too large Load Diff
+441 -414
View File
File diff suppressed because it is too large Load Diff
+438 -411
View File
File diff suppressed because it is too large Load Diff
+3 -65
View File
@@ -5,7 +5,6 @@ extern crate activitypub;
extern crate askama_escape; extern crate askama_escape;
extern crate atom_syndication; extern crate atom_syndication;
extern crate chrono; extern crate chrono;
extern crate clap;
extern crate colored; extern crate colored;
extern crate ctrlc; extern crate ctrlc;
extern crate diesel; extern crate diesel;
@@ -22,7 +21,6 @@ extern crate num_cpus;
extern crate plume_api; extern crate plume_api;
extern crate plume_common; extern crate plume_common;
extern crate plume_models; extern crate plume_models;
extern crate reqwest;
#[macro_use] #[macro_use]
extern crate rocket; extern crate rocket;
extern crate rocket_contrib; extern crate rocket_contrib;
@@ -40,24 +38,19 @@ extern crate validator;
extern crate validator_derive; extern crate validator_derive;
extern crate webfinger; extern crate webfinger;
use clap::App;
use diesel::r2d2::ConnectionManager; use diesel::r2d2::ConnectionManager;
use plume_models::{ use plume_models::{
blogs::Blog,
blogs::Host,
db_conn::{DbPool, PragmaForeignKey}, db_conn::{DbPool, PragmaForeignKey},
instance::Instance, instance::Instance,
migrations::IMPORTED_MIGRATIONS, migrations::IMPORTED_MIGRATIONS,
search::{Searcher as UnmanagedSearcher, SearcherError}, search::{Searcher as UnmanagedSearcher, SearcherError},
Connection, Error, CONFIG, Connection, Error, CONFIG,
}; };
use rocket::{fairing::AdHoc, http::ext::IntoOwned, http::uri::Origin};
use rocket_csrf::CsrfFairingBuilder; use rocket_csrf::CsrfFairingBuilder;
use scheduled_thread_pool::ScheduledThreadPool; use scheduled_thread_pool::ScheduledThreadPool;
use std::collections::HashMap;
use std::process::exit; use std::process::exit;
use std::sync::{Arc, Mutex}; use std::sync::{Arc, Mutex};
use std::time::{Duration, Instant}; use std::time::Duration;
init_i18n!( init_i18n!(
"plume", ar, bg, ca, cs, de, en, eo, es, fr, gl, hi, hr, it, ja, nb, pl, pt, ro, ru, sr, sk, sv "plume", ar, bg, ca, cs, de, en, eo, es, fr, gl, hi, hr, it, ja, nb, pl, pt, ro, ru, sr, sk, sv
@@ -80,11 +73,7 @@ compile_i18n!();
/// Initializes a database pool. /// Initializes a database pool.
fn init_pool() -> Option<DbPool> { fn init_pool() -> Option<DbPool> {
match dotenv::dotenv() { dotenv::dotenv().unwrap();
Ok(path) => println!("Configuration read from {}", path.display()),
Err(ref e) if e.not_found() => eprintln!("no .env was found"),
e => e.map(|_| ()).unwrap(),
}
let manager = ConnectionManager::<Connection>::new(CONFIG.database_url.as_str()); let manager = ConnectionManager::<Connection>::new(CONFIG.database_url.as_str());
let pool = DbPool::builder() let pool = DbPool::builder()
@@ -92,24 +81,10 @@ fn init_pool() -> Option<DbPool> {
.build(manager) .build(manager)
.ok()?; .ok()?;
Instance::cache_local(&pool.get().unwrap()); Instance::cache_local(&pool.get().unwrap());
Blog::cache_custom_domains(&pool.get().unwrap());
Some(pool) Some(pool)
} }
fn main() { fn main() {
App::new("Plume")
.bin_name("plume")
.version(env!("CARGO_PKG_VERSION"))
.about("Plume backend server")
.after_help(
r#"
The plume command should be run inside the directory
containing the `.env` configuration file and `static` directory.
See https://docs.joinplu.me/installation/config
and https://docs.joinplu.me/installation/init for more info.
"#,
)
.get_matches();
let dbpool = init_pool().expect("main: database pool initialization error"); let dbpool = init_pool().expect("main: database pool initialization error");
if IMPORTED_MIGRATIONS if IMPORTED_MIGRATIONS
.is_pending(&dbpool.get().unwrap()) .is_pending(&dbpool.get().unwrap())
@@ -181,42 +156,7 @@ Then try to restart Plume
println!("Please refer to the documentation to see how to configure it."); println!("Please refer to the documentation to see how to configure it.");
} }
let custom_domain_fairing = AdHoc::on_request("Custom Blog Domains", |req, _data| {
let host = req.guard::<Host>();
if host.is_success()
&& req
.uri()
.segments()
.next()
.map(|path| path != "static" && path != "api")
.unwrap_or(true)
{
let rewrite_uri = format!("/custom_domains/{}/{}", host.unwrap(), req.uri());
let uri = Origin::parse_owned(rewrite_uri).unwrap();
let uri = uri.to_normalized().into_owned();
req.set_uri(uri);
}
});
let valid_domains: HashMap<String, Instant> = HashMap::new();
let rocket = rocket::custom(CONFIG.rocket.clone().unwrap()) let rocket = rocket::custom(CONFIG.rocket.clone().unwrap())
.mount(
"/custom_domains/domain_validation/",
routes![routes::blogs::custom::domain_validation,],
)
.mount(
"/domain_validation/",
routes![routes::blogs::domain_validation,],
)
.mount(
"/custom_domains/",
routes![
routes::blogs::custom::details,
routes::posts::custom::details,
routes::blogs::custom::activity_details,
routes::search::custom::search,
],
)
.mount( .mount(
"/", "/",
routes![ routes![
@@ -329,7 +269,6 @@ Then try to restart Plume
.manage(dbpool) .manage(dbpool)
.manage(Arc::new(workpool)) .manage(Arc::new(workpool))
.manage(searcher) .manage(searcher)
.manage(Mutex::new(valid_domains))
.manage(include_i18n!()) .manage(include_i18n!())
.attach( .attach(
CsrfFairingBuilder::new() CsrfFairingBuilder::new()
@@ -356,8 +295,7 @@ Then try to restart Plume
]) ])
.finalize() .finalize()
.expect("main: csrf fairing creation error"), .expect("main: csrf fairing creation error"),
) );
.attach(custom_domain_fairing);
#[cfg(feature = "test")] #[cfg(feature = "test")]
let rocket = rocket.mount("/test", routes![test_routes::health,]); let rocket = rocket.mount("/test", routes![test_routes::health,]);
+12 -174
View File
@@ -2,14 +2,11 @@ use activitypub::collection::OrderedCollection;
use atom_syndication::{Entry, FeedBuilder}; use atom_syndication::{Entry, FeedBuilder};
use diesel::SaveChangesDsl; use diesel::SaveChangesDsl;
use rocket::{ use rocket::{
http::{ContentType, Status}, http::ContentType,
request::LenientForm, request::LenientForm,
response::{content::Content, Flash, Redirect}, response::{content::Content, Flash, Redirect},
State,
}; };
use rocket_i18n::I18n; use rocket_i18n::I18n;
use std::sync::Mutex;
use std::time::{Duration, Instant};
use std::{borrow::Cow, collections::HashMap}; use std::{borrow::Cow, collections::HashMap};
use validator::{Validate, ValidationError, ValidationErrors}; use validator::{Validate, ValidationError, ValidationErrors};
@@ -19,17 +16,14 @@ use plume_models::{
blog_authors::*, blogs::*, instance::Instance, medias::*, posts::Post, safe_string::SafeString, blog_authors::*, blogs::*, instance::Instance, medias::*, posts::Post, safe_string::SafeString,
users::User, Connection, PlumeRocket, users::User, Connection, PlumeRocket,
}; };
use reqwest::Client;
use routes::{errors::ErrorPage, Page, RespondOrRedirect}; use routes::{errors::ErrorPage, Page, RespondOrRedirect};
use template_utils::{IntoContext, Ructe}; use template_utils::{IntoContext, Ructe};
fn detail_guts( #[get("/~/<name>?<page>", rank = 2)]
blog: Blog, pub fn details(name: String, page: Option<Page>, rockets: PlumeRocket) -> Result<Ructe, ErrorPage> {
page: Option<Page>,
rockets: PlumeRocket,
) -> Result<RespondOrRedirect, ErrorPage> {
let page = page.unwrap_or_default(); let page = page.unwrap_or_default();
let conn = &*rockets.conn; let conn = &*rockets.conn;
let blog = Blog::find_by_fqn(&rockets, &name)?;
let posts = Post::blog_page(conn, &blog, page.limits())?; let posts = Post::blog_page(conn, &blog, page.limits())?;
let articles_count = Post::count_for_blog(conn, &blog)?; let articles_count = Post::count_for_blog(conn, &blog)?;
let authors = &blog.list_authors(conn)?; let authors = &blog.list_authors(conn)?;
@@ -41,43 +35,7 @@ fn detail_guts(
page.0, page.0,
Page::total(articles_count as i32), Page::total(articles_count as i32),
posts posts
)) )))
.into())
}
#[get("/~/<name>?<page>", rank = 2)]
pub fn details(
name: String,
page: Option<Page>,
rockets: PlumeRocket,
) -> Result<RespondOrRedirect, ErrorPage> {
let blog = Blog::find_by_fqn(&rockets, &name)?;
// check this first, and return early
// doing this prevents partially moving `blog` into the `match (tuple)`,
// which makes it impossible to reuse then.
if blog.custom_domain == None {
return detail_guts(blog, page, rockets);
}
match (blog.custom_domain, page) {
(Some(ref custom_domain), Some(ref page)) => {
Ok(Redirect::to(format!("https://{}/?page={}", custom_domain, page)).into())
}
(Some(ref custom_domain), _) => {
Ok(Redirect::to(format!("https://{}/", custom_domain)).into())
}
// we need this match arm, or the match won't compile
(None, _) => unreachable!("This code path should have already been handled!"),
}
}
pub fn activity_detail_guts(
blog: Blog,
rockets: PlumeRocket,
_ap: ApRequest,
) -> Option<ActivityStream<CustomGroup>> {
Some(ActivityStream::new(blog.to_activity(&*rockets.conn).ok()?))
} }
#[get("/~/<name>", rank = 1)] #[get("/~/<name>", rank = 1)]
@@ -87,7 +45,7 @@ pub fn activity_details(
_ap: ApRequest, _ap: ApRequest,
) -> Option<ActivityStream<CustomGroup>> { ) -> Option<ActivityStream<CustomGroup>> {
let blog = Blog::find_by_fqn(&rockets, &name).ok()?; let blog = Blog::find_by_fqn(&rockets, &name).ok()?;
activity_detail_guts(blog, rockets, _ap) Some(ActivityStream::new(blog.to_activity(&*rockets.conn).ok()?))
} }
#[get("/blogs/new")] #[get("/blogs/new")]
@@ -99,76 +57,6 @@ pub fn new(rockets: PlumeRocket, _user: User) -> Ructe {
)) ))
} }
// mounted as /domain_validation/
#[get("/<validation_id>")]
pub fn domain_validation(
validation_id: String,
valid_domains: State<Mutex<HashMap<String, Instant>>>,
) -> Status {
let mutex = valid_domains.inner().lock();
let mut validation_map = mutex.unwrap();
let validation_getter = validation_map.clone();
let value = validation_getter.get(&validation_id);
if value.is_none() {
// validation id not found
return Status::NotFound;
}
// we have valid id, now check the time
let valid_until = value.unwrap();
let now = Instant::now();
// nope, expired (410: gone)
if now.duration_since(*valid_until).as_secs() > 0 {
validation_map.remove(&validation_id);
// validation expired
return Status::Gone;
}
validation_map.remove(&validation_id);
Status::Ok
}
pub mod custom {
use plume_common::activity_pub::{ActivityStream, ApRequest};
use plume_models::{blogs::Blog, blogs::CustomGroup, blogs::Host, PlumeRocket};
use rocket::{http::Status, State};
use routes::{errors::ErrorPage, Page, RespondOrRedirect};
use std::collections::HashMap;
use std::sync::Mutex;
use std::time::Instant;
#[get("/<custom_domain>?<page>", rank = 2)]
pub fn details(
custom_domain: String,
page: Option<Page>,
rockets: PlumeRocket,
) -> Result<RespondOrRedirect, ErrorPage> {
let blog = Blog::find_by_host(&rockets, Host::new(custom_domain))?;
super::detail_guts(blog, page, rockets)
}
#[get("/<custom_domain>", rank = 1)]
pub fn activity_details(
custom_domain: String,
rockets: PlumeRocket,
_ap: ApRequest,
) -> Option<ActivityStream<CustomGroup>> {
let blog = Blog::find_by_host(&rockets, Host::new(custom_domain)).ok()?;
super::activity_detail_guts(blog, rockets, _ap)
}
// mounted as /custom_domains/domain_validation/
#[get("/<validation_id>")]
pub fn domain_validation(
validation_id: String,
valid_domains: State<Mutex<HashMap<String, Instant>>>,
) -> Status {
super::domain_validation(validation_id, valid_domains)
}
}
#[get("/blogs/new", rank = 2)] #[get("/blogs/new", rank = 2)]
pub fn new_auth(i18n: I18n) -> Flash<Redirect> { pub fn new_auth(i18n: I18n) -> Flash<Redirect> {
utils::requires_login( utils::requires_login(
@@ -184,7 +72,6 @@ pub fn new_auth(i18n: I18n) -> Flash<Redirect> {
pub struct NewBlogForm { pub struct NewBlogForm {
#[validate(custom(function = "valid_slug", message = "Invalid name"))] #[validate(custom(function = "valid_slug", message = "Invalid name"))]
pub title: String, pub title: String,
pub custom_domain: String,
} }
fn valid_slug(title: &str) -> Result<(), ValidationError> { fn valid_slug(title: &str) -> Result<(), ValidationError> {
@@ -196,43 +83,13 @@ fn valid_slug(title: &str) -> Result<(), ValidationError> {
} }
} }
fn valid_domain(domain: &str, valid_domains: State<Mutex<HashMap<String, Instant>>>) -> bool {
let mutex = valid_domains.inner().lock();
let mut validation_map = mutex.unwrap();
let random_id = utils::random_hex();
validation_map.insert(
random_id.clone(),
Instant::now().checked_add(Duration::new(60, 0)).unwrap(),
);
let client = Client::new();
let validation_uri = format!("https://{}/domain_validation/{}", domain, random_id);
match client.get(&validation_uri).send() {
Ok(resp) => resp.status().is_success(),
Err(_) => false,
}
}
#[post("/blogs/new", data = "<form>")] #[post("/blogs/new", data = "<form>")]
pub fn create( pub fn create(form: LenientForm<NewBlogForm>, rockets: PlumeRocket) -> RespondOrRedirect {
form: LenientForm<NewBlogForm>,
rockets: PlumeRocket,
valid_domains: State<Mutex<HashMap<String, Instant>>>,
) -> RespondOrRedirect {
let slug = utils::make_actor_id(&form.title); let slug = utils::make_actor_id(&form.title);
let conn = &*rockets.conn; let conn = &*rockets.conn;
let intl = &rockets.intl.catalog; let intl = &rockets.intl.catalog;
let user = rockets.user.clone().unwrap(); let user = rockets.user.clone().unwrap();
let (custom_domain, dns_ok) = if form.custom_domain.is_empty() {
(None, true)
} else {
let dns_check = valid_domain(&form.custom_domain.clone(), valid_domains);
(Some(Host::new(form.custom_domain.clone())), dns_check)
};
let mut errors = match form.validate() { let mut errors = match form.validate() {
Ok(_) => ValidationErrors::new(), Ok(_) => ValidationErrors::new(),
Err(e) => e, Err(e) => e,
@@ -264,7 +121,6 @@ pub fn create(
Instance::get_local() Instance::get_local()
.expect("blog::create: instance error") .expect("blog::create: instance error")
.id, .id,
custom_domain,
) )
.expect("blog::create: new local error"), .expect("blog::create: new local error"),
) )
@@ -280,19 +136,11 @@ pub fn create(
) )
.expect("blog::create: author error"); .expect("blog::create: author error");
if dns_ok { Flash::success(
Flash::success( Redirect::to(uri!(details: name = slug.clone(), page = _)),
Redirect::to(uri!(details: name = slug.clone(), page = _)), &i18n!(intl, "Your blog was successfully created!"),
&i18n!(intl, "Your blog was successfully created!"), )
) .into()
.into()
} else {
Flash::warning(
Redirect::to(uri!(details: name = slug.clone(), page = _)),
&i18n!(intl, "Your blog was successfully created, but the custom domain seems invalid. Please check it is correct from your blog's settings."),
)
.into()
}
} }
#[post("/~/<name>/delete")] #[post("/~/<name>/delete")]
@@ -333,7 +181,6 @@ pub struct EditForm {
pub summary: String, pub summary: String,
pub icon: Option<i32>, pub icon: Option<i32>,
pub banner: Option<i32>, pub banner: Option<i32>,
pub custom_domain: String,
} }
#[get("/~/<name>/edit")] #[get("/~/<name>/edit")]
@@ -351,10 +198,6 @@ pub fn edit(name: String, rockets: PlumeRocket) -> Result<Ructe, ErrorPage> {
.clone() .clone()
.expect("blogs::edit: User was None while it shouldn't"); .expect("blogs::edit: User was None while it shouldn't");
let medias = Media::for_user(conn, user.id).expect("Couldn't list media"); let medias = Media::for_user(conn, user.id).expect("Couldn't list media");
let custom_domain = match blog.custom_domain {
Some(ref c) => c.to_string(),
_ => String::from(""),
};
Ok(render!(blogs::edit( Ok(render!(blogs::edit(
&rockets.to_context(), &rockets.to_context(),
&blog, &blog,
@@ -364,7 +207,6 @@ pub fn edit(name: String, rockets: PlumeRocket) -> Result<Ructe, ErrorPage> {
summary: blog.summary.clone(), summary: blog.summary.clone(),
icon: blog.icon_id, icon: blog.icon_id,
banner: blog.banner_id, banner: blog.banner_id,
custom_domain: custom_domain,
}, },
ValidationErrors::default() ValidationErrors::default()
))) )))
@@ -476,10 +318,6 @@ pub fn update(
); );
blog.icon_id = form.icon; blog.icon_id = form.icon;
blog.banner_id = form.banner; blog.banner_id = form.banner;
if !form.custom_domain.is_empty() {
blog.custom_domain = Some(Host::new(form.custom_domain.clone()))
}
blog.save_changes::<Blog>(&*conn) blog.save_changes::<Blog>(&*conn)
.expect("Couldn't save blog changes"); .expect("Couldn't save blog changes");
Ok(Flash::success( Ok(Flash::success(
+4 -21
View File
@@ -1,6 +1,6 @@
use plume_models::{instance::Instance, Error, PlumeRocket}; use plume_models::{Error, PlumeRocket};
use rocket::{ use rocket::{
response::{self, Redirect, Responder}, response::{self, Responder},
Request, Request,
}; };
use template_utils::{IntoContext, Ructe}; use template_utils::{IntoContext, Ructe};
@@ -29,26 +29,9 @@ impl<'r> Responder<'r> for ErrorPage {
} }
#[catch(404)] #[catch(404)]
pub fn not_found(req: &Request) -> Result<Ructe, Redirect> { pub fn not_found(req: &Request) -> Ructe {
let rockets = req.guard::<PlumeRocket>().unwrap(); let rockets = req.guard::<PlumeRocket>().unwrap();
if req render!(errors::not_found(&rockets.to_context()))
.uri()
.segments()
.next()
.map(|path| path == "custom_domains")
.unwrap_or(false)
{
let path = req
.uri()
.segments()
.skip(2)
.collect::<Vec<&str>>()
.join("/");
let public_domain = Instance::get_local().unwrap().public_domain;
Err(Redirect::to(format!("https://{}/{}", public_domain, path)))
} else {
Ok(render!(errors::not_found(&rockets.to_context())))
}
} }
#[catch(422)] #[catch(422)]
+1 -8
View File
@@ -10,7 +10,6 @@ use rocket::{
response::{Flash, NamedFile, Redirect}, response::{Flash, NamedFile, Redirect},
Outcome, Outcome,
}; };
use std::fmt;
use std::path::{Path, PathBuf}; use std::path::{Path, PathBuf};
use template_utils::Ructe; use template_utils::Ructe;
@@ -53,15 +52,9 @@ impl From<Flash<Redirect>> for RespondOrRedirect {
} }
} }
#[derive(Debug, Shrinkwrap, Copy, Clone, UriDisplayQuery)] #[derive(Shrinkwrap, Copy, Clone, UriDisplayQuery)]
pub struct Page(i32); pub struct Page(i32);
impl fmt::Display for Page {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
write!(f, "{}", self.0)
}
}
impl<'v> FromFormValue<'v> for Page { impl<'v> FromFormValue<'v> for Page {
type Error = &'v RawStr; type Error = &'v RawStr;
fn from_form_value(form_value: &'v RawStr) -> Result<Page, &'v RawStr> { fn from_form_value(form_value: &'v RawStr) -> Result<Page, &'v RawStr> {
+21 -85
View File
@@ -31,14 +31,28 @@ use routes::{
}; };
use template_utils::{IntoContext, Ructe}; use template_utils::{IntoContext, Ructe};
fn detail_guts( #[get("/~/<blog>/<slug>?<responding_to>", rank = 4)]
blog: &Blog, pub fn details(
post: &Post, blog: String,
slug: String,
responding_to: Option<i32>, responding_to: Option<i32>,
rockets: &PlumeRocket, rockets: PlumeRocket,
) -> Result<RespondOrRedirect, ErrorPage> { ) -> Result<Ructe, ErrorPage> {
let conn = &*rockets.conn; let conn = &*rockets.conn;
let user = rockets.user.clone(); let user = rockets.user.clone();
let blog = Blog::find_by_fqn(&rockets, &blog)?;
let post = Post::find_by_slug(&*conn, &slug, blog.id)?;
if !(post.published
|| post
.get_authors(&*conn)?
.into_iter()
.any(|a| a.id == user.clone().map(|u| u.id).unwrap_or(0)))
{
return Ok(render!(errors::not_authorized(
&rockets.to_context(),
i18n!(rockets.intl.catalog, "This post isn't published yet.")
)));
}
let comments = CommentTree::from_post(&*conn, &post, user.as_ref())?; let comments = CommentTree::from_post(&*conn, &post, user.as_ref())?;
@@ -47,7 +61,7 @@ fn detail_guts(
Ok(render!(posts::details( Ok(render!(posts::details(
&rockets.to_context(), &rockets.to_context(),
post.clone(), post.clone(),
blog.clone(), blog,
&NewCommentForm { &NewCommentForm {
warning: previous.clone().map(|p| p.spoiler_text).unwrap_or_default(), warning: previous.clone().map(|p| p.spoiler_text).unwrap_or_default(),
content: previous.clone().and_then(|p| Some(format!( content: previous.clone().and_then(|p| Some(format!(
@@ -80,85 +94,7 @@ fn detail_guts(
user.clone().and_then(|u| u.has_reshared(&*conn, &post).ok()).unwrap_or(false), user.clone().and_then(|u| u.has_reshared(&*conn, &post).ok()).unwrap_or(false),
user.and_then(|u| u.is_following(&*conn, post.get_authors(&*conn).ok()?[0].id).ok()).unwrap_or(false), user.and_then(|u| u.is_following(&*conn, post.get_authors(&*conn).ok()?[0].id).ok()).unwrap_or(false),
post.get_authors(&*conn)?[0].clone() post.get_authors(&*conn)?[0].clone()
)).into()) )))
}
#[get("/~/<blog>/<slug>?<responding_to>", rank = 4)]
pub fn details(
blog: String,
slug: String,
responding_to: Option<i32>,
rockets: PlumeRocket,
) -> Result<RespondOrRedirect, ErrorPage> {
let conn = &*rockets.conn;
let user = rockets.user.clone();
let blog = Blog::find_by_fqn(&rockets, &blog)?;
let post = Post::find_by_slug(&*conn, &slug, blog.id)?;
if !(post.published
|| post
.get_authors(&*conn)?
.into_iter()
.any(|a| a.id == user.clone().map(|u| u.id).unwrap_or(0)))
{
return Ok(render!(errors::not_authorized(
&rockets.to_context(),
i18n!(rockets.intl.catalog, "This post isn't published yet.")
))
.into());
}
// check this first, and return early
// doing this prevents partially moving `blog` into the `match (tuple)`,
// which makes it impossible to reuse then.
if blog.custom_domain == None {
return detail_guts(&blog, &post, responding_to, &rockets);
}
match (blog.custom_domain, responding_to) {
(Some(ref custom_domain), Some(ref responding_to)) => Ok(Redirect::to(format!(
"https://{}/{}?responding_to={}",
custom_domain, slug, responding_to
))
.into()),
(Some(ref custom_domain), _) => {
Ok(Redirect::to(format!("https://{}/{}", custom_domain, slug)).into())
}
(None, _) => unreachable!("This code path should have already been handled!"),
}
}
pub mod custom {
use plume_models::{blogs::Blog, blogs::Host, posts::Post, PlumeRocket};
use routes::{errors::ErrorPage, RespondOrRedirect};
use template_utils::{IntoContext, Ructe};
#[get("/<custom_domain>/<slug>?<responding_to>", rank = 4)]
pub fn details(
custom_domain: String,
slug: String,
responding_to: Option<i32>,
rockets: PlumeRocket,
) -> Result<RespondOrRedirect, ErrorPage> {
let conn = &*rockets.conn;
let user = rockets.user.clone();
let blog = Blog::find_by_host(&rockets, Host::new(custom_domain))?;
let post = Post::find_by_slug(&*conn, &slug, blog.id)?;
if !(post.published
|| post
.get_authors(&*conn)?
.into_iter()
.any(|a| a.id == user.clone().map(|u| u.id).unwrap_or(0)))
{
return Ok(render!(errors::not_authorized(
&rockets.to_context(),
i18n!(rockets.intl.catalog, "This post isn't published yet.")
))
.into());
}
super::detail_guts(&blog, &post, responding_to, &rockets)
}
} }
#[get("/~/<blog>/<slug>", rank = 3)] #[get("/~/<blog>/<slug>", rank = 3)]
+2 -21
View File
@@ -49,7 +49,8 @@ macro_rules! param_to_query {
} }
} }
fn search_guts(query: Option<Form<SearchQuery>>, rockets: PlumeRocket) -> Ructe { #[get("/search?<query..>")]
pub fn search(query: Option<Form<SearchQuery>>, rockets: PlumeRocket) -> Ructe {
let conn = &*rockets.conn; let conn = &*rockets.conn;
let query = query.map(Form::into_inner).unwrap_or_default(); let query = query.map(Form::into_inner).unwrap_or_default();
let page = query.page.unwrap_or_default(); let page = query.page.unwrap_or_default();
@@ -82,23 +83,3 @@ fn search_guts(query: Option<Form<SearchQuery>>, rockets: PlumeRocket) -> Ructe
)) ))
} }
} }
#[get("/search?<query..>")]
pub fn search(query: Option<Form<SearchQuery>>, rockets: PlumeRocket) -> Ructe {
search_guts(query, rockets)
}
pub mod custom {
use plume_models::PlumeRocket;
use rocket::request::Form;
use template_utils::Ructe;
#[get("/<_custom_domain>/search?<query..>")]
pub fn search(
_custom_domain: String,
query: Option<Form<super::SearchQuery>>,
rockets: PlumeRocket,
) -> Ructe {
super::search_guts(query, rockets)
}
}
+11 -11
View File
@@ -48,16 +48,14 @@ impl Resolver<PlumeRocket> for WebfingerResolver {
CONFIG.base_url.as_str() CONFIG.base_url.as_str()
} }
fn find(prefix: Prefix, acct: String, ctx: PlumeRocket) -> Result<Webfinger, ResolverError> { fn find(acct: String, ctx: PlumeRocket) -> Result<Webfinger, ResolverError> {
match prefix { User::find_by_fqn(&ctx, &acct)
Prefix::Acct => User::find_by_fqn(&ctx, &acct) .and_then(|usr| usr.webfinger(&*ctx.conn))
.and_then(|usr| usr.webfinger(&*ctx.conn)) .or_else(|_| {
.or(Err(ResolverError::NotFound)), Blog::find_by_fqn(&ctx, &acct)
Prefix::Group => Blog::find_by_fqn(&ctx, &acct) .and_then(|blog| blog.webfinger(&*ctx.conn))
.and_then(|blog| blog.webfinger(&*ctx.conn)) .or(Err(ResolverError::NotFound))
.or(Err(ResolverError::NotFound)), })
Prefix::Custom(_) => Err(ResolverError::NotFound),
}
} }
} }
@@ -74,7 +72,9 @@ pub fn webfinger(resource: String, rockets: PlumeRocket) -> Content<String> {
"Invalid resource. Make sure to request an acct: URI" "Invalid resource. Make sure to request an acct: URI"
} }
ResolverError::NotFound => "Requested resource was not found", ResolverError::NotFound => "Requested resource was not found",
ResolverError::WrongDomain => "This is not the instance of the requested resource", ResolverError::WrongInstance => {
"This is not the instance of the requested resource"
}
}), }),
), ),
} }
+8 -108
View File
@@ -1,10 +1,7 @@
use plume_models::{notifications::*, users::User, Connection, PlumeRocket}; use plume_models::{notifications::*, users::User, Connection, PlumeRocket};
use rocket::http::hyper::header::{ETag, EntityTag}; use rocket::http::hyper::header::{ETag, EntityTag};
use rocket::http::{ use rocket::http::{Method, Status};
uri::{FromUriParam, Query},
Method, Status,
};
use rocket::request::Request; use rocket::request::Request;
use rocket::response::{self, content::Html as HtmlCt, Responder, Response}; use rocket::response::{self, content::Html as HtmlCt, Responder, Response};
use rocket_i18n::Catalog; use rocket_i18n::Catalog;
@@ -16,16 +13,6 @@ pub use askama_escape::escape;
pub static CACHE_NAME: &str = env!("CACHE_ID"); pub static CACHE_NAME: &str = env!("CACHE_ID");
pub struct NoValue; // workarround for missing FromUriParam implementation for Option
impl FromUriParam<Query, NoValue> for Option<i32> {
type Target = Option<i32>;
fn from_uri_param(_: NoValue) -> Self::Target {
None
}
}
pub type BaseContext<'a> = &'a ( pub type BaseContext<'a> = &'a (
&'a Connection, &'a Connection,
&'a Catalog, &'a Catalog,
@@ -159,7 +146,7 @@ pub fn avatar(
pub fn tabs(links: &[(&str, String, bool)]) -> Html<String> { pub fn tabs(links: &[(&str, String, bool)]) -> Html<String> {
let mut res = String::from(r#"<div class="tabs">"#); let mut res = String::from(r#"<div class="tabs">"#);
for (url, title, selected) in links { for (url, title, selected) in links {
res.push_str(r#"<a dir="auto" href=""#); res.push_str(r#"<a href=""#);
res.push_str(url); res.push_str(url);
if *selected { if *selected {
res.push_str(r#"" class="selected">"#); res.push_str(r#"" class="selected">"#);
@@ -189,7 +176,7 @@ pub fn paginate_param(
p p
}) })
.unwrap_or_default(); .unwrap_or_default();
res.push_str(r#"<div class="pagination" dir="auto">"#); res.push_str(r#"<div class="pagination">"#);
if page != 1 { if page != 1 {
res.push_str( res.push_str(
format!( format!(
@@ -252,13 +239,13 @@ macro_rules! input {
Html(format!( Html(format!(
r#" r#"
<label for="{name}" dir="auto"> <label for="{name}">
{label} {label}
{optional} {optional}
{details} {details}
</label> </label>
{error} {error}
<input type="{kind}" id="{name}" name="{name}" value="{val}" {props} dir="auto"/> <input type="{kind}" id="{name}" name="{name}" value="{val}" {props}/>
"#, "#,
name = stringify!($name), name = stringify!($name),
label = i18n!(cat, $label), label = i18n!(cat, $label),
@@ -277,7 +264,7 @@ macro_rules! input {
$err.errors().get(stringify!($name)) $err.errors().get(stringify!($name))
{ {
format!( format!(
r#"<p class="error" dir="auto">{}</p>"#, r#"<p class="error">{}</p>"#,
errs[0] errs[0]
.message .message
.clone() .clone()
@@ -345,8 +332,8 @@ macro_rules! input {
let cat = $catalog; let cat = $catalog;
Html(format!( Html(format!(
r#" r#"
<label for="{name}" dir="auto">{label}</label> <label for="{name}">{label}</label>
<input type="{kind}" id="{name}" name="{name}" {props} dir="auto"/> <input type="{kind}" id="{name}" name="{name}" {props}/>
"#, "#,
name = stringify!($name), name = stringify!($name),
label = i18n!(cat, $label), label = i18n!(cat, $label),
@@ -355,90 +342,3 @@ macro_rules! input {
)) ))
}}; }};
} }
/// This macro imitate rocket's uri!, but with support for custom domains
///
/// It takes one more argument, domain, which must appear first, and must be an Option<&str>
/// sample call :
/// assuming both take the same parameters
/// url!(custom_domain=Some("something.tld"), posts::details: slug = "title", responding_to = _, blog = "blogname"));
///
/// assuming posts::details take one more parameter than posts::custom::details
/// url!(custom_domain=Some("something.tld"), posts::details:
/// common=[slug = "title", responding_to = _],
/// normal=[blog = "blogname"]));
///
/// you can also provide custom=[] for custom-domain specific arguments
/// custom_domain can be changed to anything, indicating custom domain varname in the custom-domain
/// function (most likely custom_domain or _custom_domain)
macro_rules! url {
($custom_domain:ident=$domain:expr, $module:ident::$route:ident:
common=[$($common_args:tt = $common_val:expr),*],
normal=[$($normal_args:tt = $normal_val:expr),*],
custom=[$($custom_args:tt = $custom_val:expr),*]) => {{
let domain: &Option<plume_models::blogs::Host> = &$domain; //for type inference with None
$(
let $common_args = $common_val;
)*
if let Some(domain) = domain {
$(
let $custom_args = $custom_val;
)*
let origin = uri!(crate::routes::$module::custom::$route:
$custom_domain = domain.to_string(),
$($common_args = $common_args,)*
$($custom_args = $custom_args,)*
);
let path = origin
.segments()
.skip(1)// skip is <custom_domain> part
.map(|seg| format!("/{}", seg)).collect::<String>();
let query = origin.query()
.filter(|q| !q.is_empty())
.map(|q| format!("?{}", q))
.unwrap_or_default();
format!("https://{}{}{}", &domain, path, query)
} else {
$(
let $normal_args = $normal_val;
)*
url!($module::$route:
$($common_args = $common_args,)*
$($normal_args = $normal_args,)*)
.to_string()
}
}};
($cd:ident=$d:expr, $m:ident::$r:ident:
common=[$($tt:tt)*]) => {
url!($cd=$d, $m::$r: common=[$($tt)*], normal=[], custom=[])
};
($cd:ident=$d:expr, $m:ident::$r:ident:
normal=[$($tt:tt)*]) => {
url!($cd=$d, $m::$r: common=[], normal=[$($tt)*], custom=[])
};
($cd:ident=$d:expr, $m:ident::$r:ident:
custom=[$($tt:tt)*]) => {
url!($cd=$d, $m::$r: common=[], normal=[], custom=[$($tt)*])
};
($cd:ident=$d:expr, $m:ident::$r:ident:
common=[$($co:tt)*],
normal=[$($no:tt)*]) => {
url!($cd=$d, $m::$r: common=[$($co)*], normal=[$($no)*], custom=[])
};
($cd:ident=$d:expr, $m:ident::$r:ident:
common=[$($co:tt)*],
custom=[$($cu:tt)*]) => {
url!($cd=$d, $m::$r: common=[$($co)*], normal=[], custom=[$($cu)*])
};
($cd:ident=$d:expr, $m:ident::$r:ident:
normal=[$($no:tt)*],
custom=[$($cu:tt)*]) => {
url!($cd=$d, $m::$r: common=[], normal=[$($no)*], custom=[$($cu)*])
};
($custom_domain:ident=$domain:expr, $module:ident::$route:ident: $($common_args:tt)*) => {
url!($custom_domain=$domain, $module::$route: common=[$($common_args)*])
};
($module:ident::$route:ident: $($tt:tt)*) => {
uri!(crate::routes::$module::$route: $($tt)*)
};
}
+11 -11
View File
@@ -13,8 +13,8 @@
<meta content="120" property="og:image:width" /> <meta content="120" property="og:image:width" />
<meta content="120" property="og:image:height" /> <meta content="120" property="og:image:height" />
<meta content="summary" property="twitter:card" /> <meta content="summary" property="twitter:card" />
<meta content="@Instance::get_local().unwrap().name" property="og:site_name" /> <meta content="'@Instance::get_local().unwrap().name" property="og:site_name" />
<meta content="@blog.url()" property="og:url" /> <meta content="@blog.ap_url" property="og:url" />
<meta content="@blog.fqn" property="profile:username" /> <meta content="@blog.fqn" property="profile:username" />
<meta content="@blog.title" property="og:title" /> <meta content="@blog.title" property="og:title" />
<meta content="@blog.summary_html" name="description"> <meta content="@blog.summary_html" name="description">
@@ -24,7 +24,7 @@
<link href='@Instance::get_local().unwrap().compute_box("~", &blog.fqn, "atom.xml")' rel='alternate' type='application/atom+xml'> <link href='@Instance::get_local().unwrap().compute_box("~", &blog.fqn, "atom.xml")' rel='alternate' type='application/atom+xml'>
<link href='@blog.ap_url' rel='alternate' type='application/activity+json'> <link href='@blog.ap_url' rel='alternate' type='application/activity+json'>
}, { }, {
<a href="@url!(custom_domain = blog.custom_domain, blogs::details: common=[page = None], normal=[name = &blog.fqn])" dir="auto">@blog.title</a> <a href="@uri!(blogs::details: name = &blog.fqn, page = _)">@blog.title</a>
}, { }, {
<div class="hidden"> <div class="hidden">
@for author in authors { @for author in authors {
@@ -41,38 +41,38 @@
} }
<div class="h-card"> <div class="h-card">
<div class="user"> <div class="user">
<div class="flex wrap" dir="auto"> <div class="flex wrap">
<div class="avatar medium" style="background-image: url('@blog.icon_url(ctx.0)');" aria-label="@i18n!(ctx.1, "{}'s icon"; &blog.title)"></div> <div class="avatar medium" style="background-image: url('@blog.icon_url(ctx.0)');" aria-label="@i18n!(ctx.1, "{}'s icon"; &blog.title)"></div>
<img class="hidden u-photo" src="@blog.icon_url(ctx.0)"/> <img class="hidden u-photo" src="@blog.icon_url(ctx.0)"/>
<h1 class="grow flex vertical"> <h1 class="grow flex vertical">
<span class="p-name">@blog.title</span> <span class="p-name">@blog.title</span>
<small dir="auto">~@blog.fqn</small> <small>~@blog.fqn</small>
</h1> </h1>
@if ctx.2.clone().and_then(|u| u.is_author_in(ctx.0, &blog).ok()).unwrap_or(false) { @if ctx.2.clone().and_then(|u| u.is_author_in(ctx.0, &blog).ok()).unwrap_or(false) {
<a href="@uri!(posts::new: blog = &blog.fqn)" class="button" dir="auto">@i18n!(ctx.1, "New article")</a> <a href="@uri!(posts::new: blog = &blog.fqn)" class="button">@i18n!(ctx.1, "New article")</a>
<a href="@uri!(blogs::edit: name = &blog.fqn)" class="button" dir="auto">@i18n!(ctx.1, "Edit")</a> <a href="@uri!(blogs::edit: name = &blog.fqn)" class="button">@i18n!(ctx.1, "Edit")</a>
} }
</div> </div>
<main class="user-summary" dir="auto"> <main class="user-summary">
<p> <p>
@i18n!(ctx.1, "There's one author on this blog: ", "There are {0} authors on this blog: "; authors.len()) @i18n!(ctx.1, "There's one author on this blog: ", "There are {0} authors on this blog: "; authors.len())
@for (i, author) in authors.iter().enumerate() {@if i >= 1 {, } @for (i, author) in authors.iter().enumerate() {@if i >= 1 {, }
<a class="author p-author" href="@uri!(user::details: name = &author.fqn)" dir="auto">@author.name()</a>} <a class="author p-author" href="@uri!(user::details: name = &author.fqn)">@author.name()</a>}
</p> </p>
@Html(blog.summary_html.clone()) @Html(blog.summary_html.clone())
</main> </main>
</div> </div>
<section> <section>
<h2 dir="auto"> <h2>
@i18n!(ctx.1, "Latest articles") @i18n!(ctx.1, "Latest articles")
<small><a href="@uri!(blogs::atom_feed: name = &blog.fqn)" title="Atom feed">@icon!("rss")</a></small> <small><a href="@uri!(blogs::atom_feed: name = &blog.fqn)" title="Atom feed">@icon!("rss")</a></small>
</h2> </h2>
@if posts.is_empty() { @if posts.is_empty() {
<p dir="auto">@i18n!(ctx.1, "No posts to see here yet.")</p> <p>@i18n!(ctx.1, "No posts to see here yet.")</p>
} }
<div class="cards"> <div class="cards">
@for article in posts { @for article in posts {
-2
View File
@@ -23,8 +23,6 @@
<label for="summary">@i18n!(ctx.1, "Description")<small>@i18n!(ctx.1, "Markdown syntax is supported")</small></label> <label for="summary">@i18n!(ctx.1, "Description")<small>@i18n!(ctx.1, "Markdown syntax is supported")</small></label>
<textarea id="summary" name="summary" rows="20">@form.summary</textarea> <textarea id="summary" name="summary" rows="20">@form.summary</textarea>
@input!(ctx.1, custom_domain (optional text), "Custom Domain", form, errors, "")
<p> <p>
@i18n!(ctx.1, "You can upload images to your gallery, to use them as blog icons, or banners.") @i18n!(ctx.1, "You can upload images to your gallery, to use them as blog icons, or banners.")
<a href="@uri!(medias::new)">@i18n!(ctx.1, "Upload images")</a> <a href="@uri!(medias::new)">@i18n!(ctx.1, "Upload images")</a>
+3 -6
View File
@@ -7,12 +7,9 @@
@(ctx: BaseContext, form: &NewBlogForm, errors: ValidationErrors) @(ctx: BaseContext, form: &NewBlogForm, errors: ValidationErrors)
@:base(ctx, i18n!(ctx.1, "New Blog"), {}, {}, { @:base(ctx, i18n!(ctx.1, "New Blog"), {}, {}, {
<h1 dir="auto">@i18n!(ctx.1, "Create a blog")</h1> <h1>@i18n!(ctx.1, "Create a blog")</h1>
<form method="post" action="@uri!(blogs::create)"> <form method="post" action="@uri!(blogs::create)">
@input!(ctx.1, title (text), "Title", form, errors.clone(), "required minlength=\"1\"") @input!(ctx.1, title (text), "Title", form, errors, "required minlength=\"1\"")
<input type="submit" value="@i18n!(ctx.1, "Create blog")" dir="auto"/> <input type="submit" value="@i18n!(ctx.1, "Create blog")"/>
@input!(ctx.1, custom_domain (optional text), "Custom Domain", form, errors, "")
<input type="submit" value="@i18n!(ctx.1, "Make your blog available under a custom domain")" dir="auto"/>
</form> </form>
}) })
+2 -2
View File
@@ -9,7 +9,7 @@
<div class="comment u-comment h-cite" id="comment-@comm.id"> <div class="comment u-comment h-cite" id="comment-@comm.id">
<main class="content"> <main class="content">
<header> <header>
<a class="author u-author h-card" href="@uri!(user::details: name = &author.fqn)" dir="auto"> <a class="author u-author h-card" href="@uri!(user::details: name = &author.fqn)">
@avatar(ctx.0, &author, Size::Small, true, ctx.1) @avatar(ctx.0, &author, Size::Small, true, ctx.1)
<span class="display-name p-name">@author.name()</span> <span class="display-name p-name">@author.name()</span>
<small>@author.fqn</small> <small>@author.fqn</small>
@@ -27,7 +27,7 @@
<div class="text p-content"> <div class="text p-content">
@if comm.sensitive { @if comm.sensitive {
<details> <details>
<summary dir="auto">@comm.spoiler_text</summary> <summary>@comm.spoiler_text</summary>
} }
@Html(&comm.content) @Html(&comm.content)
@if comm.sensitive { @if comm.sensitive {
+1 -1
View File
@@ -6,7 +6,7 @@
@if !articles.is_empty() { @if !articles.is_empty() {
<div class="h-feed"> <div class="h-feed">
<h2 dir="auto"><span class="p-name">@title</span> &mdash; <a href="@link">@i18n!(ctx.1, "View all")</a></h2> <h2><span class="p-name">@title</span> &mdash; <a href="@link">@i18n!(ctx.1, "View all")</a></h2>
<div class="cards"> <div class="cards">
@for article in articles { @for article in articles {
@:post_card(ctx, article) @:post_card(ctx, article)
+2 -2
View File
@@ -3,7 +3,7 @@
@(ctx: BaseContext, id: &str, title: String, optional: bool, medias: Vec<Media>, selected: Option<i32>) @(ctx: BaseContext, id: &str, title: String, optional: bool, medias: Vec<Media>, selected: Option<i32>)
<label for="@id" dir="auto"> <label for="@id">
@title @title
@if optional { @if optional {
<small>@i18n!(ctx.1, "Optional")</small> <small>@i18n!(ctx.1, "Optional")</small>
@@ -13,7 +13,7 @@
<option value="none" @if selected.is_none() { selected }>@i18n!(ctx.1, "None")</option> <option value="none" @if selected.is_none() { selected }>@i18n!(ctx.1, "None")</option>
@for media in medias { @for media in medias {
@if media.category() == MediaCategory::Image { @if media.category() == MediaCategory::Image {
<option value="@media.id" @if selected.map(|c| c == media.id).unwrap_or(false) { selected } dir="auto"> <option value="@media.id" @if selected.map(|c| c == media.id).unwrap_or(false) { selected }>
@if !media.alt_text.is_empty() { @if !media.alt_text.is_empty() {
@media.alt_text @media.alt_text
} else { } else {
@@ -4,7 +4,7 @@
@(ctx: BaseContext, instance: Instance, n_users: i64, n_articles: i64) @(ctx: BaseContext, instance: Instance, n_users: i64, n_articles: i64)
<section class="split" dir="auto"> <section class="split">
<div class="presentation card"> <div class="presentation card">
<h2>@i18n!(ctx.1, "What is Plume?")</h2> <h2>@i18n!(ctx.1, "What is Plume?")</h2>
<main> <main>
+5 -4
View File
@@ -8,13 +8,13 @@
@if article.cover_id.is_some() { @if article.cover_id.is_some() {
<div class="cover" style="background-image: url('@Html(article.cover_url(ctx.0).unwrap_or_default())')"></div> <div class="cover" style="background-image: url('@Html(article.cover_url(ctx.0).unwrap_or_default())')"></div>
} }
<h3 class="p-name" dir="auto"> <h3 class="p-name">
<a class="u-url" href="@url!(custom_domain = article.get_blog(ctx.0).unwrap().custom_domain, posts::details: common=[ slug = &article.slug, responding_to = NoValue], normal=[blog = article.get_blog(ctx.0).unwrap().fqn])"> <a class="u-url" href="@uri!(posts::details: blog = article.get_blog(ctx.0).unwrap().fqn, slug = &article.slug, responding_to = _)">
@article.title @article.title
</a> </a>
</h3> </h3>
<main> <main>
<p class="p-summary" dir="auto">@article.subtitle</p> <p class="p-summary">@article.subtitle</p>
</main> </main>
<footer class="authors"> <footer class="authors">
@Html(i18n!(ctx.1, "By {0}"; format!( @Html(i18n!(ctx.1, "By {0}"; format!(
@@ -25,9 +25,10 @@
@if article.published { @if article.published {
<span class="dt-published" datetime="@article.creation_date.format("%F %T")">@article.creation_date.format("%B %e, %Y")</span> <span class="dt-published" datetime="@article.creation_date.format("%F %T")">@article.creation_date.format("%B %e, %Y")</span>
} }
<a href="@url!(custom_domain = article.get_blog(ctx.0).unwrap().custom_domain, blogs::details: common=[page = None], normal=[name = &article.get_blog(ctx.0).unwrap().fqn])">@article.get_blog(ctx.0).unwrap().title</a> <a href="@uri!(blogs::details: name = &article.get_blog(ctx.0).unwrap().fqn, page = _)">@article.get_blog(ctx.0).unwrap().title</a>
@if !article.published { @if !article.published {
⋅ @i18n!(ctx.1, "Draft") ⋅ @i18n!(ctx.1, "Draft")
} }
</footer> </footer>
</div> </div>
+13 -13
View File
@@ -17,10 +17,10 @@
@if article.cover_id.is_some() { @if article.cover_id.is_some() {
<meta property="og:image" content="@Html(article.cover_url(ctx.0).unwrap_or_default())"/> <meta property="og:image" content="@Html(article.cover_url(ctx.0).unwrap_or_default())"/>
} }
<meta property="og:url" content="@url!(custom_domain = blog.custom_domain, posts::details: common=[slug = &article.slug, responding_to = NoValue], normal=[blog = &blog.fqn])"/> <meta property="og:url" content="@uri!(posts::details: blog = &blog.fqn, slug = &article.slug, responding_to = _)"/>
<meta property="og:description" content="@article.subtitle"/> <meta property="og:description" content="@article.subtitle"/>
}, { }, {
<a href="@url!(custom_domain = &blog.custom_domain, blogs::details: common=[page = None], normal=[name = &blog.fqn])">@blog.title</a> <a href="@uri!(blogs::details: name = &blog.fqn, page = _)">@blog.title</a>
}, { }, {
<div class="h-entry"> <div class="h-entry">
<header <header
@@ -28,8 +28,8 @@
@if article.cover_id.is_some() { style="background-image: url('@article.cover_url(ctx.0).unwrap_or_default()'" } @if article.cover_id.is_some() { style="background-image: url('@article.cover_url(ctx.0).unwrap_or_default()'" }
> >
<div> <div>
<h1 class="article p-name" dir="auto">@article.title</h1> <h1 class="article p-name">@article.title</h1>
<div class="article-info" dir="auto"> <div class="article-info">
<span class="author"> <span class="author">
@Html(i18n!(ctx.1, "Written by {0}"; format!("<a href=\"{}\">{}</a>", @Html(i18n!(ctx.1, "Written by {0}"; format!("<a href=\"{}\">{}</a>",
uri!(user::details: name = &author.fqn), uri!(user::details: name = &author.fqn),
@@ -38,7 +38,7 @@
&mdash; &mdash;
<span class="date dt-published" datetime="@article.creation_date.format("%F %T")">@article.creation_date.format("%B %e, %Y")</span><a class="u-url" href="@article.ap_url"></a> <span class="date dt-published" datetime="@article.creation_date.format("%F %T")">@article.creation_date.format("%B %e, %Y")</span><a class="u-url" href="@article.ap_url"></a>
</div> </div>
<h2 class="article p-summary" dir="auto">@article.subtitle</h2> <h2 class="article p-summary">@article.subtitle</h2>
</div> </div>
@if article.cover_id.is_some() { @if article.cover_id.is_some() {
<div class="shadow"></div> <div class="shadow"></div>
@@ -46,21 +46,21 @@
} }
</header> </header>
<article class="e-content" dir="auto"> <article class="e-content">
@Html(&article.content) @Html(&article.content)
</article> </article>
<div class="article-meta"> <div class="article-meta">
<section class="split"> <section class="split">
<ul class="tags" dir="auto"> <ul class="tags">
@for tag in tags { @for tag in tags {
@if !tag.is_hashtag { @if !tag.is_hashtag {
<li><a class="p-category" href="@uri!(tags::tag: name = &tag.tag, page = None)">@tag.tag</a></li> <li><a class="p-category" href="@uri!(tags::tag: name = &tag.tag, page = _)">@tag.tag</a></li>
} else { } else {
<span class="hidden p-category">@tag.tag</span> <span class="hidden p-category">@tag.tag</span>
} }
} }
</ul> </ul>
<p class="right" dir="auto"> <p class="right">
@if article.license.is_empty() { @if article.license.is_empty() {
@i18n!(ctx.1, "All rights reserved."; &article.license) @i18n!(ctx.1, "All rights reserved."; &article.license)
} else { } else {
@@ -116,7 +116,7 @@
</section> </section>
} }
<section class="banner"> <section class="banner">
<div class="flex p-author h-card user" dir="auto"> <div class="flex p-author h-card user">
@avatar(ctx.0, &author, Size::Medium, true, ctx.1) @avatar(ctx.0, &author, Size::Medium, true, ctx.1)
<div class="grow"> <div class="grow">
<h2 class="p-name"> <h2 class="p-name">
@@ -132,7 +132,7 @@
} }
</div> </div>
</section> </section>
<section class="comments" dir="auto"> <section class="comments">
<h2>@i18n!(ctx.1, "Comments")</h2> <h2>@i18n!(ctx.1, "Comments")</h2>
@if ctx.2.is_some() { @if ctx.2.is_some() {
@@ -143,7 +143,7 @@
@if let Some(ref prev) = previous_comment { @if let Some(ref prev) = previous_comment {
<input type="hidden" name="responding_to" value="@prev.id"/> <input type="hidden" name="responding_to" value="@prev.id"/>
} }
<textarea id="plume-editor" name="content" dir="auto">@comment_form.content</textarea> <textarea id="plume-editor" name="content">@comment_form.content</textarea>
<input type="submit" value="@i18n!(ctx.1, "Submit comment")" /> <input type="submit" value="@i18n!(ctx.1, "Submit comment")" />
</form> </form>
} }
@@ -153,7 +153,7 @@
@:comment(ctx, &comm, Some(&article.ap_url), &blog.fqn, &article.slug) @:comment(ctx, &comm, Some(&article.ap_url), &blog.fqn, &article.slug)
} }
} else { } else {
<p class="center" dir="auto">@i18n!(ctx.1, "No comments yet. Be the first to react!")</p> <p class="center">@i18n!(ctx.1, "No comments yet. Be the first to react!")</p>
} }
</section> </section>
</div> </div>
+7 -7
View File
@@ -12,8 +12,8 @@
@(ctx: BaseContext, title: String, blog: Blog, editing: bool, form: &NewPostForm, is_draft: bool, article: Option<Post>, errors: ValidationErrors, medias: Vec<Media>, content_len: u64) @(ctx: BaseContext, title: String, blog: Blog, editing: bool, form: &NewPostForm, is_draft: bool, article: Option<Post>, errors: ValidationErrors, medias: Vec<Media>, content_len: u64)
@:base(ctx, title.clone(), {}, {}, { @:base(ctx, title.clone(), {}, {}, {
<h1 id="plume-editor-title" dir="auto">@title</h1> <h1 id="plume-editor-title">@title</h1>
<div id="plume-editor" style="display: none;" dir="auto"> <div id="plume-editor" style="display: none;">
<header> <header>
<button id="publish" class="button">@i18n!(ctx.1, "Publish")</button> <button id="publish" class="button">@i18n!(ctx.1, "Publish")</button>
<p id="char-count">@content_len</p> <p id="char-count">@content_len</p>
@@ -32,10 +32,10 @@
@format!(r#"<p class="error">{}</p>"#, errs[0].message.clone().unwrap_or_else(|| Cow::from("Unknown error"))) @format!(r#"<p class="error">{}</p>"#, errs[0].message.clone().unwrap_or_else(|| Cow::from("Unknown error")))
} }
<label for="editor-content" dir="auto">@i18n!(ctx.1, "Content")<small>@i18n!(ctx.1, "Markdown syntax is supported")</small></label> <label for="editor-content">@i18n!(ctx.1, "Content")<small>@i18n!(ctx.1, "Markdown syntax is supported")</small></label>
<textarea id="editor-content" name="content" rows="20" dir="auto">@Html(&form.content)</textarea> <textarea id="editor-content" name="content" rows="20">@Html(&form.content)</textarea>
<small id="editor-left" dir="auto">@content_len</small> <small id="editor-left">@content_len</small>
<p dir="auto"> <p>
@i18n!(ctx.1, "You can upload media to your gallery, and then copy their Markdown code into your articles to insert them.") @i18n!(ctx.1, "You can upload media to your gallery, and then copy their Markdown code into your articles to insert them.")
<a href="@uri!(medias::new)">@i18n!(ctx.1, "Upload media")</a> <a href="@uri!(medias::new)">@i18n!(ctx.1, "Upload media")</a>
</p> </p>
@@ -47,7 +47,7 @@
@:image_select(ctx, "cover", i18n!(ctx.1, "Illustration"), true, medias, form.cover) @:image_select(ctx, "cover", i18n!(ctx.1, "Illustration"), true, medias, form.cover)
@if is_draft { @if is_draft {
<label for="draft" dir="auto"> <label for="draft">
<input type="checkbox" name="draft" id="draft" checked> <input type="checkbox" name="draft" id="draft" checked>
@i18n!(ctx.1, "This is a draft, don't publish it yet.") @i18n!(ctx.1, "This is a draft, don't publish it yet.")
</label> </label>
+1 -1
View File
@@ -9,6 +9,6 @@
@(ctx: BaseContext, post: Post, login_form: LoginForm, login_errs: ValidationErrors, remote_form: RemoteForm, remote_errs: ValidationErrors) @(ctx: BaseContext, post: Post, login_form: LoginForm, login_errs: ValidationErrors, remote_form: RemoteForm, remote_errs: ValidationErrors)
@:remote_interact_base(ctx, i18n!(ctx.1, "Interact with {}"; post.title.clone()), i18n!(ctx.1, "Log in to interact"), i18n!(ctx.1, "Enter your full username to interact"), { @:remote_interact_base(ctx, i18n!(ctx.1, "Interact with {}"; post.title.clone()), i18n!(ctx.1, "Log in to interact"), i18n!(ctx.1, "Enter your full username to interact"), {
<h1 dir="auto">@i18n!(ctx.1, "Interact with {}"; post.title.clone())</h1> <h1>@i18n!(ctx.1, "Interact with {}"; post.title.clone())</h1>
@:post_card(ctx, post) @:post_card(ctx, post)
}, login_form, login_errs, remote_form, remote_errs) }, login_form, login_errs, remote_form, remote_errs)