1 files changed, 122 insertions, 0 deletions

diff --git a/src/handlers.rs b/src/handlers.rs
new file mode 100644
index 0000000..51c7b63
--- /dev/null
+++ b/src/handlers.rs
@@ -0,0 +1,122 @@
+// API handlers, the ends of each filter chain
+
+use log::debug;
+use std::convert::Infallible;
+use warp::{http::StatusCode, reply};
+
+use crate::schema::{Db, Transaction}; // `Block` coming later
+
+// PROPOSE Transaction
+// POST /transaction
+pub async fn propose_transaction(
+    new_transaction: Transaction,
+    db: Db,
+) -> Result<impl warp::Reply, warp::Rejection> {
+    debug!("new transaction request {:?}", new_transaction);
+
+    let mut transactions = db.lock().await;
+
+    transactions.push(new_transaction);
+
+    Ok(StatusCode::CREATED)
+}
+
+// GET Transaction List
+// GET /transaction
+// Returns JSON array of transactions
+// Cannot fail?
+pub async fn list_transactions(db: Db) -> Result<impl warp::Reply, Infallible> {
+    debug!("list all transactions");
+
+    let transactions = db.lock().await;
+
+    let transactions: Vec<Transaction> = transactions.clone().into_iter().collect();
+
+    Ok(reply::with_status(
+        reply::json(&transactions),
+        StatusCode::OK,
+    ))
+}
+
+// PROPOSE Block
+// POST /block
+
+// `GET /games`
+// Returns JSON array of todos
+// Allows pagination, for example: `GET /games?offset=10&limit=5`
+// pub async fn list_games(options: ListOptions, db: Db) -> Result<impl Reply, Infallible> {
+//     debug!("list all games");
+
+//     let games = db.lock().await;
+//     let games: Vec<Game> = games
+//         .clone()
+//         .into_iter()
+//         .skip(options.offset.unwrap_or(0))
+//         .take(options.limit.unwrap_or(std::usize::MAX))
+//         .collect();
+
+//     Ok(warp::reply::json(&games))
+// }
+
+// `POST /games`
+// Create new game entry with JSON body
+// pub async fn create_game(new_game: Game, db: Db) -> Result<impl Reply, Infallible> {
+//     debug!("create new game: {:?}", new_game);
+
+//     let mut games = db.lock().await;
+
+//     match games.iter().find(|game| game.id == new_game.id) {
+//         Some(game) => {
+//             debug!("game of given id already exists: {}", game.id);
+
+//             Ok(StatusCode::BAD_REQUEST)
+//         }
+//         None => {
+//             games.push(new_game);
+//             Ok(StatusCode::CREATED)
+//         }
+//     }
+// }
+
+// `PUT /games/:id`
+// pub async fn update_game(id: u64, updated_game: Game, db: Db) -> Result<impl Reply, Infallible> {
+//     debug!("update existing game: id={}, game={:?}", id, updated_game);
+
+//     let mut games = db.lock().await;
+
+//     match games.iter_mut().find(|game| game.id == id) {
+//         Some(game) => {
+//             *game = updated_game;
+
+//             Ok(StatusCode::OK)
+//         }
+//         None => {
+//             debug!("game of given id not found");
+
+//             Ok(StatusCode::NOT_FOUND)
+//         }
+//     }
+// }
+
+// `DELETE /games/:id`
+// pub async fn delete_game(id: u64, db: Db) -> Result<impl Reply, Infallible> {
+//     debug!("delete game: id={}", id);
+
+//     let mut games = db.lock().await;
+
+//     let len = games.len();
+
+//     // Removes all games with given id
+//     games.retain(|game| game.id != id);
+
+//     // If games length was smaller that means specyfic game was found and removed
+//     let deleted = games.len() != len;
+
+//     if deleted {
+//         Ok(StatusCode::NO_CONTENT)
+//     } else {
+//         debug!("game of given id not found");
+
+//         Ok(StatusCode::NOT_FOUND)
+//     }
+// }