aboutsummaryrefslogtreecommitdiffstats
path: root/rust/src/api_server.rs
diff options
context:
space:
mode:
authorBryan Newbold <bnewbold@robocracy.org>2018-09-06 15:02:57 -0700
committerBryan Newbold <bnewbold@robocracy.org>2018-09-06 15:02:59 -0700
commit0f229e57965901a1230dd346fb676e8caf67ec2e (patch)
tree4d8af9a9aa99dcd67ce8ce15fdfc7484d8b77856 /rust/src/api_server.rs
parent36a1fbe4ce13be3631e07a5ecfc84ffc87c74931 (diff)
downloadfatcat-0f229e57965901a1230dd346fb676e8caf67ec2e.tar.gz
fatcat-0f229e57965901a1230dd346fb676e8caf67ec2e.zip
skeleton create/delete endpoints for works
Other entities just stubs
Diffstat (limited to 'rust/src/api_server.rs')
-rw-r--r--rust/src/api_server.rs122
1 files changed, 122 insertions, 0 deletions
diff --git a/rust/src/api_server.rs b/rust/src/api_server.rs
index 7bf3122b..66c31f61 100644
--- a/rust/src/api_server.rs
+++ b/rust/src/api_server.rs
@@ -535,6 +535,19 @@ impl Server {
edit.into_model()
}
+ // XXX:
+ pub fn update_container_handler(
+ &self,
+ id: &Uuid,
+ entity: models::ContainerEntity,
+ conn: &DbConn,
+ ) -> Result<EntityEdit> {
+ unimplemented!()
+ }
+ pub fn delete_container_handler(&self, id: &Uuid, editgroup_id: Option<Uuid>, conn: &DbConn) -> Result<EntityEdit> {
+ unimplemented!()
+ }
+
pub fn create_creator_handler(
&self,
entity: models::CreatorEntity,
@@ -574,6 +587,19 @@ impl Server {
edit.into_model()
}
+ // XXX:
+ pub fn update_creator_handler(
+ &self,
+ id: &Uuid,
+ entity: models::CreatorEntity,
+ conn: &DbConn,
+ ) -> Result<EntityEdit> {
+ unimplemented!()
+ }
+ pub fn delete_creator_handler(&self, id: &Uuid, editgroup_id: Option<Uuid>, conn: &DbConn) -> Result<EntityEdit> {
+ unimplemented!()
+ }
+
pub fn create_file_handler(
&self,
entity: models::FileEntity,
@@ -654,6 +680,19 @@ impl Server {
edit.into_model()
}
+ // XXX:
+ pub fn update_file_handler(
+ &self,
+ id: &Uuid,
+ entity: models::FileEntity,
+ conn: &DbConn,
+ ) -> Result<EntityEdit> {
+ unimplemented!()
+ }
+ pub fn delete_file_handler(&self, id: &Uuid, editgroup_id: Option<Uuid>, conn: &DbConn) -> Result<EntityEdit> {
+ unimplemented!()
+ }
+
pub fn create_release_handler(
&self,
entity: models::ReleaseEntity,
@@ -829,6 +868,19 @@ impl Server {
edit.into_model()
}
+ // XXX:
+ pub fn update_release_handler(
+ &self,
+ id: &Uuid,
+ entity: models::ReleaseEntity,
+ conn: &DbConn,
+ ) -> Result<EntityEdit> {
+ unimplemented!()
+ }
+ pub fn delete_release_handler(&self, id: &Uuid, editgroup_id: Option<Uuid>, conn: &DbConn) -> Result<EntityEdit> {
+ unimplemented!()
+ }
+
pub fn create_work_handler(
&self,
entity: models::WorkEntity,
@@ -858,6 +910,76 @@ impl Server {
edit.into_model()
}
+ pub fn update_work_handler(
+ &self,
+ id: &Uuid,
+ entity: models::WorkEntity,
+ conn: &DbConn,
+ ) -> Result<EntityEdit> {
+ let editor_id = Uuid::parse_str("00000000-0000-0000-AAAA-000000000001")?; // TODO: auth
+ let editgroup_id = match entity.editgroup_id {
+ None => get_or_create_editgroup(editor_id, conn).expect("current editgroup"),
+ Some(param) => fcid2uuid(&param)?,
+ };
+
+ // TODO: refactor this into a check on WorkIdentRow
+ let current: WorkIdentRow = work_ident::table.find(id).first(conn)?;
+ if current.is_live != true {
+ // TODO: what if isn't live? 4xx not 5xx
+ bail!("can't delete an entity that doesn't exist yet");
+ }
+ if current.rev_id.is_none() {
+ // TODO: what if it's already deleted? 4xx not 5xx
+ bail!("entity was already deleted");
+ }
+
+ let edit: WorkEditRow =
+ diesel::sql_query(
+ "WITH rev AS ( INSERT INTO work_rev (extra_json)
+ VALUES ($1)
+ RETURNING id ),
+ INSERT INTO work_edit (editgroup_id, ident_id, rev_id, prev_rev) VALUES
+ ($2, $3, (SELECT rev.id FROM rev), $4)
+ RETURNING *",
+ ).bind::<diesel::sql_types::Nullable<diesel::sql_types::Json>, _>(entity.extra)
+ .bind::<diesel::sql_types::Uuid, _>(editgroup_id)
+ .bind::<diesel::sql_types::Uuid, _>(id)
+ .bind::<diesel::sql_types::Uuid, _>(current.rev_id.unwrap())
+ .get_result(conn)?;
+
+ edit.into_model()
+ }
+
+ pub fn delete_work_handler(&self, id: &Uuid, editgroup_id: Option<Uuid>, conn: &DbConn) -> Result<EntityEdit> {
+ let editor_id = Uuid::parse_str("00000000-0000-0000-AAAA-000000000001")?; // TODO: auth
+ let editgroup_id = match editgroup_id {
+ Some(egid) => egid,
+ None => get_or_create_editgroup(editor_id, conn)?
+ };
+
+ let current: WorkIdentRow = work_ident::table.find(id).first(conn)?;
+ if current.is_live != true {
+ // TODO: what if isn't live? 4xx not 5xx
+ bail!("can't delete an entity that doesn't exist yet");
+ }
+ if current.rev_id.is_none() {
+ // TODO: what if it's already deleted? 4xx not 5xx
+ bail!("entity was already deleted");
+ }
+ let edit: WorkEditRow = insert_into(work_edit::table)
+ .values((
+ work_edit::editgroup_id.eq(editgroup_id),
+ work_edit::ident_id.eq(id),
+ work_edit::rev_id.eq(None::<Uuid>),
+ work_edit::redirect_id.eq(None::<Uuid>),
+ work_edit::prev_rev.eq(current.rev_id),
+ //work_edit::extra_json.eq(extra),
+ ))
+ .get_result(conn)?;
+
+ edit.into_model()
+ }
+
pub fn accept_editgroup_handler(&self, id: &str, conn: &DbConn) -> Result<()> {
accept_editgroup(fcid2uuid(id)?, conn)?;
Ok(())