Compare commits

..

No commits in common. "32d70daab2c6227d2d2d17f4b57764992e3af39f" and "fc46c4874a394a30504aa100b88a7d3ac6eb8b01" have entirely different histories.

12 changed files with 23 additions and 73 deletions

View File

@ -5,6 +5,5 @@ mod store;
pub use models::*;
pub use repository::GpodderRepository;
pub use store::{
AuthErr, GpodderAuthStore, GpodderDeviceStore, GpodderEpisodeActionStore, GpodderStore,
GpodderSubscriptionStore,
AuthErr, AuthStore, DeviceRepository, EpisodeActionRepository, Store, SubscriptionRepository,
};

View File

@ -6,18 +6,18 @@ use rand::{Rng, rngs::OsRng};
use crate::{
models,
store::{AuthErr, GpodderStore},
store::{AuthErr, Store},
};
const MAX_SESSION_AGE: i64 = 60 * 60 * 24 * 7;
#[derive(Clone)]
pub struct GpodderRepository {
store: Arc<dyn GpodderStore + Send + Sync>,
store: Arc<dyn Store + Send + Sync>,
}
impl GpodderRepository {
pub fn new(store: impl GpodderStore + Send + Sync + 'static) -> Self {
pub fn new(store: impl Store + Send + Sync + 'static) -> Self {
Self {
store: Arc::new(store),
}

View File

@ -24,18 +24,17 @@ impl Display for AuthErr {
impl std::error::Error for AuthErr {}
/// API abstraction providing methods for serving the Gpodder API
pub trait GpodderStore:
GpodderAuthStore + GpodderDeviceStore + GpodderSubscriptionStore + GpodderEpisodeActionStore
pub trait Store:
AuthStore + DeviceRepository + SubscriptionRepository + EpisodeActionRepository
{
}
impl<T> GpodderStore for T where
T: GpodderAuthStore + GpodderDeviceStore + GpodderSubscriptionStore + GpodderEpisodeActionStore
impl<T> Store for T where
T: AuthStore + DeviceRepository + SubscriptionRepository + EpisodeActionRepository
{
}
pub trait GpodderAuthStore {
pub trait AuthStore {
/// Retrieve the session with the given session ID
fn get_session(&self, session_id: i64) -> Result<Option<Session>, AuthErr>;
@ -64,7 +63,7 @@ pub trait GpodderAuthStore {
fn remove_old_sessions(&self, min_last_seen: DateTime<Utc>) -> Result<usize, AuthErr>;
}
pub trait GpodderDeviceStore {
pub trait DeviceRepository {
/// Return all devices associated with the user
fn devices_for_user(&self, user: &User) -> Result<Vec<Device>, AuthErr>;
@ -109,7 +108,7 @@ pub trait GpodderDeviceStore {
) -> Result<(Vec<String>, Vec<Vec<String>>), AuthErr>;
}
pub trait GpodderSubscriptionStore {
pub trait SubscriptionRepository {
/// Return the subscriptions for the given device
fn subscriptions_for_device(
&self,
@ -150,7 +149,7 @@ pub trait GpodderSubscriptionStore {
) -> Result<(Vec<Subscription>, Vec<Subscription>), AuthErr>;
}
pub trait GpodderEpisodeActionStore {
pub trait EpisodeActionRepository {
/// Insert the given episode actions into the datastore.
fn add_episode_actions(
&self,

View File

@ -22,7 +22,7 @@ impl From<User> for gpodder::User {
}
}
impl gpodder::GpodderAuthStore for SqliteRepository {
impl gpodder::AuthStore for SqliteRepository {
fn get_user(&self, username: &str) -> Result<Option<gpodder::models::User>, AuthErr> {
Ok(users::table
.select(User::as_select())

View File

@ -38,7 +38,7 @@ impl From<gpodder::DeviceType> for DeviceType {
}
}
impl gpodder::GpodderDeviceStore for SqliteRepository {
impl gpodder::DeviceRepository for SqliteRepository {
fn devices_for_user(
&self,
user: &gpodder::User,

View File

@ -71,7 +71,7 @@ fn to_gpodder_action(
}
}
impl gpodder::GpodderEpisodeActionStore for SqliteRepository {
impl gpodder::EpisodeActionRepository for SqliteRepository {
fn add_episode_actions(
&self,
user: &gpodder::User,

View File

@ -172,7 +172,7 @@ pub fn update_subscriptions_for_single_device(
Ok(())
}
impl gpodder::GpodderSubscriptionStore for SqliteRepository {
impl gpodder::SubscriptionRepository for SqliteRepository {
fn subscriptions_for_user(
&self,
user: &gpodder::User,

View File

@ -22,11 +22,6 @@ const SESSION_ID_COOKIE: &str = "sessionid";
pub fn router(ctx: Context) -> Router<Context> {
Router::new()
.route("/sessions", get(get_sessions))
.route_layer(axum::middleware::from_fn_with_state(
ctx.clone(),
auth_web_middleware,
))
.route("/", get(get_index))
// .layer(middleware::from_fn_with_state(
// ctx.clone(),
@ -166,14 +161,3 @@ pub async fn auth_web_middleware(
Err(err) => err.into_response(),
}
}
pub async fn get_sessions(
State(ctx): State<Context>,
headers: HeaderMap,
) -> TemplateResponse<Page<View>> {
View::Sessions(Vec::new())
.page(&headers)
.headers(&headers)
.authenticated(true)
.response(&ctx.tera)
}

View File

@ -79,10 +79,6 @@ pub fn initialize_tera() -> tera::Result<tera::Tera> {
View::Login.template(),
include_str!("templates/views/login.html"),
),
(
View::Sessions(Vec::new()).template(),
include_str!("templates/views/sessions.html"),
),
])?;
Ok(tera)

View File

@ -21,12 +21,12 @@ a:hover {
</li>
</ul>
<ul>
{% if authenticated %}
<li><a hx-get="/sessions" hx-target="#inner" hx-push-url="true">Sessions</a></li>
<li><a hx-post="/logout" hx-target="#inner">Logout</a></li>
{% else %}
<li><a hx-get="/login" hx-target="#inner" hx-push-url="true">Login</a></li>
{% endif %}
<li>
{% if authenticated %}
<a hx-post="/logout" hx-target="#inner">Logout</a>
{% else %}
<a hx-get="/login" hx-target="#inner" hx-push-url="true">Login</a>
{% endif %}
</li>
</ul>
</nav>

View File

@ -1,18 +0,0 @@
<h1>Sessions</h1>
<table>
<thead>
<tr>
<th>User Agent</th>
<th>Last seen</th>
<th>Action</th>
</tr>
</thead>
<tbody>
<tr>
<th>Firefox</th>
<th>yesterday</th>
<th>Remove</th>
</tr>
</tbody>
</table>

View File

@ -3,7 +3,6 @@ use super::Template;
pub enum View {
Index,
Login,
Sessions(Vec<gpodder::Session>),
}
impl Template for View {
@ -11,19 +10,10 @@ impl Template for View {
match self {
Self::Index => "views/index.html",
Self::Login => "views/login.html",
Self::Sessions(_) => "views/sessions.html",
}
}
fn render(&self, tera: &tera::Tera) -> tera::Result<String> {
let mut ctx = tera::Context::new();
// match self {
// Self::Sessions(sessions) => {
// ctx.insert("sessions", sessions);
// }
// };
tera.render(self.template(), &ctx)
tera.render(self.template(), &tera::Context::new())
}
}