surrealpatch/src/net/key.rs

use crate::dbs::Session;
use crate::err::Error;
use crate::net::conf;
use crate::net::head;
use crate::net::output;
use crate::net::DB;
use crate::sql::value::Value;
use bytes::Bytes;
use serde::Deserialize;
use std::str;
use warp::path;
use warp::Filter;

#[derive(Default, Deserialize, Debug, Clone)]
pub struct Query {
	pub limit: Option<String>,
	pub start: Option<String>,
}

pub fn config() -> impl Filter<Extract = impl warp::Reply, Error = warp::Rejection> + Clone {
	// ------------------------------
	// Routes for OPTIONS
	// ------------------------------

	let base = warp::path("key");
	// Set opts method
	let opts = base.and(warp::options()).map(warp::reply);

	// ------------------------------
	// Routes for a table
	// ------------------------------

	// All methods
	let base = warp::any();
	// Get session config
	let base = base.and(conf::build());
	// Get content type header
	let base = base.and(warp::header::<String>(http::header::CONTENT_TYPE.as_str()));
	// Set base path for all
	let base = base.and(path!("key" / String).and(warp::path::end()));
	// Set select method
	let select = base.and(warp::get()).and(warp::query()).and_then(select_all);
	// Set create method
	let create = base
		.and(warp::post())
		.and(warp::body::content_length_limit(1024 * 1024 * 1)) // 1MiB
		.and(warp::body::bytes())
		.and_then(create_all);
	// Set delete method
	let delete = base.and(warp::delete()).and_then(delete_all);
	// Specify route
	let all = select.or(create).or(delete);

	// ------------------------------
	// Routes for a thing
	// ------------------------------

	// All methods
	let base = warp::any();
	// Get session config
	let base = base.and(conf::build());
	// Get content type header
	let base = base.and(warp::header::<String>(http::header::CONTENT_TYPE.as_str()));
	// Set base path for one
	let base = base.and(path!("key" / String / String).and(warp::path::end()));
	// Set select method
	let select = base.and(warp::get()).and_then(select_one);
	// Set create method
	let create = base
		.and(warp::post())
		.and(warp::body::content_length_limit(1024 * 1024 * 1)) // 1MiB
		.and(warp::body::bytes())
		.and_then(create_one);
	// Set update method
	let update = base
		.and(warp::put())
		.and(warp::body::content_length_limit(1024 * 1024 * 1)) // 1MiB
		.and(warp::body::bytes())
		.and_then(update_one);
	// Set modify method
	let modify = base
		.and(warp::patch())
		.and(warp::body::content_length_limit(1024 * 1024 * 1)) // 1MiB
		.and(warp::body::bytes())
		.and_then(modify_one);
	// Set delete method
	let delete = base.and(warp::delete()).and_then(delete_one);
	// Specify route
	let one = select.or(create).or(update).or(modify).or(delete);

	// ------------------------------
	// All routes
	// ------------------------------

	// Specify route
	opts.or(all).or(one).with(head::cors())
}

// ------------------------------
// Routes for a table
// ------------------------------

async fn select_all(
	session: Session,
	output: String,
	table: String,
	query: Query,
) -> Result<impl warp::Reply, warp::Rejection> {
	let db = DB.get().unwrap().clone();
	let sql = format!(
		"SELECT * FROM type::table($table) LIMIT {l} START {s}",
		l = query.limit.unwrap_or(String::from("100")),
		s = query.start.unwrap_or(String::from("0")),
	);
	let vars = hmap! {
		String::from("table") => Value::from(table),
	};
	match crate::dbs::execute(db, sql.as_str(), session, Some(vars)).await {
		Ok(ref res) => match output.as_ref() {
			"application/json" => Ok(output::json(res)),
			"application/cbor" => Ok(output::cbor(res)),
			"application/msgpack" => Ok(output::pack(&res)),
			_ => Err(warp::reject::not_found()),
		},
		Err(err) => Err(warp::reject::custom(err)),
	}
}

async fn create_all(
	session: Session,
	output: String,
	table: String,
	body: Bytes,
) -> Result<impl warp::Reply, warp::Rejection> {
	let db = DB.get().unwrap().clone();
	let data = str::from_utf8(&body).unwrap();
	match crate::sql::value::json(data) {
		Ok((_, data)) => {
			let sql = "CREATE type::table($table) CONTENT $data";
			let vars = hmap! {
				String::from("table") => Value::from(table),
				String::from("data") => Value::from(data),
			};
			match crate::dbs::execute(db, sql, session, Some(vars)).await {
				Ok(res) => match output.as_ref() {
					"application/json" => Ok(output::json(&res)),
					"application/cbor" => Ok(output::cbor(&res)),
					"application/msgpack" => Ok(output::pack(&res)),
					_ => Err(warp::reject::not_found()),
				},
				Err(err) => Err(warp::reject::custom(err)),
			}
		}
		Err(_) => Err(warp::reject::custom(Error::RequestError)),
	}
}

async fn delete_all(
	session: Session,
	output: String,
	table: String,
) -> Result<impl warp::Reply, warp::Rejection> {
	let db = DB.get().unwrap().clone();
	let sql = "DELETE type::table($table)";
	let vars = hmap! {
		String::from("table") => Value::from(table),
	};
	match crate::dbs::execute(db, sql, session, Some(vars)).await {
		Ok(res) => match output.as_ref() {
			"application/json" => Ok(output::json(&res)),
			"application/cbor" => Ok(output::cbor(&res)),
			"application/msgpack" => Ok(output::pack(&res)),
			_ => Err(warp::reject::not_found()),
		},
		Err(err) => Err(warp::reject::custom(err)),
	}
}

// ------------------------------
// Routes for a thing
// ------------------------------

async fn select_one(
	session: Session,
	output: String,
	table: String,
	id: String,
) -> Result<impl warp::Reply, warp::Rejection> {
	let db = DB.get().unwrap().clone();
	let sql = "SELECT * FROM type::thing($table, $id)";
	let vars = hmap! {
		String::from("table") => Value::from(table),
		String::from("id") => Value::from(id),
	};
	match crate::dbs::execute(db, sql, session, Some(vars)).await {
		Ok(res) => match output.as_ref() {
			"application/json" => Ok(output::json(&res)),
			"application/cbor" => Ok(output::cbor(&res)),
			"application/msgpack" => Ok(output::pack(&res)),
			_ => Err(warp::reject::not_found()),
		},
		Err(err) => Err(warp::reject::custom(err)),
	}
}

async fn create_one(
	session: Session,
	output: String,
	table: String,
	id: String,
	body: Bytes,
) -> Result<impl warp::Reply, warp::Rejection> {
	let db = DB.get().unwrap().clone();
	let data = str::from_utf8(&body).unwrap();
	match crate::sql::value::json(data) {
		Ok((_, data)) => {
			let sql = "CREATE type::thing($table, $id) CONTENT $data";
			let vars = hmap! {
				String::from("table") => Value::from(table),
				String::from("id") => Value::from(id),
				String::from("data") => Value::from(data),
			};
			match crate::dbs::execute(db, sql, session, Some(vars)).await {
				Ok(res) => match output.as_ref() {
					"application/json" => Ok(output::json(&res)),
					"application/cbor" => Ok(output::cbor(&res)),
					"application/msgpack" => Ok(output::pack(&res)),
					_ => Err(warp::reject::not_found()),
				},
				Err(err) => Err(warp::reject::custom(err)),
			}
		}
		Err(_) => Err(warp::reject::custom(Error::RequestError)),
	}
}

async fn update_one(
	session: Session,
	output: String,
	table: String,
	id: String,
	body: Bytes,
) -> Result<impl warp::Reply, warp::Rejection> {
	let db = DB.get().unwrap().clone();
	let data = str::from_utf8(&body).unwrap();
	match crate::sql::value::json(data) {
		Ok((_, data)) => {
			let sql = "UPDATE type::thing($table, $id) CONTENT $data";
			let vars = hmap! {
				String::from("table") => Value::from(table),
				String::from("id") => Value::from(id),
				String::from("data") => Value::from(data),
			};
			match crate::dbs::execute(db, sql, session, Some(vars)).await {
				Ok(res) => match output.as_ref() {
					"application/json" => Ok(output::json(&res)),
					"application/cbor" => Ok(output::cbor(&res)),
					"application/msgpack" => Ok(output::pack(&res)),
					_ => Err(warp::reject::not_found()),
				},
				Err(err) => Err(warp::reject::custom(err)),
			}
		}
		Err(_) => Err(warp::reject::custom(Error::RequestError)),
	}
}

async fn modify_one(
	session: Session,
	output: String,
	table: String,
	id: String,
	body: Bytes,
) -> Result<impl warp::Reply, warp::Rejection> {
	let db = DB.get().unwrap().clone();
	let data = str::from_utf8(&body).unwrap();
	match crate::sql::value::json(data) {
		Ok((_, data)) => {
			let sql = "UPDATE type::thing($table, $id) MERGE $data";
			let vars = hmap! {
				String::from("table") => Value::from(table),
				String::from("id") => Value::from(id),
				String::from("data") => Value::from(data),
			};
			match crate::dbs::execute(db, sql, session, Some(vars)).await {
				Ok(res) => match output.as_ref() {
					"application/json" => Ok(output::json(&res)),
					"application/cbor" => Ok(output::cbor(&res)),
					"application/msgpack" => Ok(output::pack(&res)),
					_ => Err(warp::reject::not_found()),
				},
				Err(err) => Err(warp::reject::custom(err)),
			}
		}
		Err(_) => Err(warp::reject::custom(Error::RequestError)),
	}
}

async fn delete_one(
	session: Session,
	output: String,
	table: String,
	id: String,
) -> Result<impl warp::Reply, warp::Rejection> {
	let db = DB.get().unwrap().clone();
	let sql = "DELETE type::thing($table, $id)";
	let vars = hmap! {
		String::from("table") => Value::from(table),
		String::from("id") => Value::from(id),
	};
	match crate::dbs::execute(db, sql, session, Some(vars)).await {
		Ok(res) => match output.as_ref() {
			"application/json" => Ok(output::json(&res)),
			"application/cbor" => Ok(output::cbor(&res)),
			"application/msgpack" => Ok(output::pack(&res)),
			_ => Err(warp::reject::not_found()),
		},
		Err(err) => Err(warp::reject::custom(err)),
	}
}