[endpoints] Adding new endpoint /films and Get Post handler for it. A…

…dding new sql raw script for film database creating

docs/postgres.md

@@ -1,5 +1,5 @@
 ## commands:
 
-CREATE DATABASE Filmoteka;
+CREATE DATABASE filmoteka;
 
-sudo -u postgres psql -d Filmoteka
+sudo -u postgres psql -d filmoteka

docs/sql/CreateFilmTable.sql

@@ -0,0 +1,8 @@
+CREATE TABLE film (
+    id SERIAL PRIMARY KEY,
+    title VARCHAR(150) NOT NULL,
+    description TEXT,
+    release_date DATE,
+    rating INT,
+    actors INT[]
+);

src/server/endpoints/endpoints.cc

@@ -42,4 +42,34 @@ response EndPointsHandler::GetActors() {
   return {200, response.dump(4)};
 }
 
+response EndPointsHandler::AddFilm(const Film& film) {
+  json response;
+  response["message"] = "Successfully adding a new user " + film.title;
+  const char *paramValues[5] = {film.title.c_str(), film.description.c_str(), film.release_date.c_str(), film.rating.c_str(), film.ids.c_str()};
+
+  prepare(database, "insert_query", "INSERT INTO film (title, description, release_date, rating, actors) VALUES ($1, $2, $3, $4, $5)", 5, nullptr);
+  execPrepared(database, "insert_query", 5, paramValues);
+
+  return {200, response.dump(4)};
+}
+
+response EndPointsHandler::GetFilms() {
+  json response;
+
+  PGresult* res = executeQuery(database, "SELECT * FROM film");
+
+  int32_t rows = PQntuples(res);
+  int32_t cols = PQnfields(res);
+  for (int32_t i = 0; i < rows; ++i) {
+    json part;
+    for (int32_t j = 0; j < cols; ++j) {
+      part[PQfname(res, j)] = PQgetvalue(res, i, j);
+    }
+    response += part;
+  }
+  PQclear(res);
+
+  return {200, response.dump(4)};
+}
+
 }  // namespace fm

src/server/endpoints/endpoints.h

@@ -16,18 +16,20 @@ struct Actor {
 };
 
 struct Film {
-  std::string id;
   std::string title;
   std::string description;
+  std::string release_date;
   std::string rating;
-  std::vector<std::string> ids;  // of actors
+  std::string ids;  // of actors
 };
 
 class EndPointsHandler {
  public:
   EndPointsHandler();
   response AddActor(const Actor& actor);
   response GetActors();
+  response AddFilm(const Film& film);
+  response GetFilms();
  private:
   PGConnection database;
 };

src/server/server.cc

@@ -38,16 +38,35 @@ void Server::Actors() {
   });
 
   CROW_ROUTE(app, "/actors").methods(crow::HTTPMethod::Post)([&](const crow::request& request) {
-        json req = json::parse(request.body);
+    json req = json::parse(request.body);
 
-        Actor actor{req["name"], req["gender"], req["date"]};
-        auto [code, body] = endpointsHandler.AddActor(actor);
+    Actor actor{req["name"], req["gender"], req["date"]};
+    auto [code, body] = endpointsHandler.AddActor(actor);
 
-        crow::response response(code, body);
-        response.set_header("Content-Type", "application/json");
-        return response;
-      });
+    crow::response response(code, body);
+    response.set_header("Content-Type", "application/json");
+    return response;
+  });
+}
+void Server::Films() {
+  CROW_ROUTE(app, "/films").methods(crow::HTTPMethod::Get)([&]() {
+    auto [code, body] = endpointsHandler.GetFilms();
+
+    crow::response response(code, body);
+    response.set_header("Content-Type", "application/json");
+    return response;
+  });
+
+  CROW_ROUTE(app, "/films").methods(crow::HTTPMethod::Post)([&](const crow::request& request) {
+    json req = json::parse(request.body);
+
+    Film film{req["title"], req["desription"], req["date"], req["rating"], req["actors"]};
+    auto [code, body] = endpointsHandler.AddFilm(film);
+
+    crow::response response(code, body);
+    response.set_header("Content-Type", "application/json");
+    return response;
+  });
 }
-void Server::Films(){/* TODO */};
 
 }  // namespace fm