summaryrefslogtreecommitdiff
path: root/dichroism/src/repo
diff options
context:
space:
mode:
Diffstat (limited to 'dichroism/src/repo')
-rw-r--r--dichroism/src/repo/entities/mod.rs36
-rw-r--r--dichroism/src/repo/mod.rs28
2 files changed, 64 insertions, 0 deletions
diff --git a/dichroism/src/repo/entities/mod.rs b/dichroism/src/repo/entities/mod.rs
new file mode 100644
index 0000000..2cff899
--- /dev/null
+++ b/dichroism/src/repo/entities/mod.rs
@@ -0,0 +1,36 @@
+use crate::models;
+use crate::schema::products;
+
+#[derive(Debug, Clone, Identifiable, Queryable, Serialize)]
+pub struct Product {
+ pub id: i32,
+ pub name: String,
+ pub description: String,
+ pub quantity: i32,
+ pub cents: i32,
+ pub featured: i32,
+ pub original: String,
+ pub fullsize: String,
+ pub base: String,
+ pub thumbnail: String,
+}
+
+impl Into<models::Product> for Product {
+ fn into(self) -> models::Product {
+ models::Product {
+ id: self.id as u32,
+ name: self.name,
+ description: self.description,
+ quantity: self.quantity as u32,
+ cents: self.cents as u32,
+ featured: self.featured != 0, // TODO: is this safe?
+ category: String::new(), // TODO: real category
+ photo_set: models::PhotoSet::from_photos(
+ models::Photo::from_filename(self.original),
+ models::Photo::from_filename(self.fullsize),
+ models::Photo::from_filename(self.base),
+ models::Photo::from_filename(self.thumbnail),
+ ),
+ }
+ }
+}
diff --git a/dichroism/src/repo/mod.rs b/dichroism/src/repo/mod.rs
new file mode 100644
index 0000000..0df8aad
--- /dev/null
+++ b/dichroism/src/repo/mod.rs
@@ -0,0 +1,28 @@
+use crate::models;
+use crate::schema::*;
+use diesel::prelude::*;
+use diesel::result::Error;
+
+mod entities;
+
+type DBConn = SqliteConnection;
+
+pub fn read_products(conn: &DBConn) -> Result<Vec<models::Product>, Error> {
+ let query = products::table.inner_join(photo_sets::table).select((
+ products::id,
+ products::name,
+ products::description,
+ products::quantity,
+ products::cents,
+ products::featured,
+ photo_sets::original,
+ photo_sets::fullsize,
+ photo_sets::base,
+ photo_sets::thumbnail,
+ ));
+ Ok(query
+ .load::<entities::Product>(conn)?
+ .into_iter()
+ .map(|p| p.into())
+ .collect::<Vec<models::Product>>())
+}