kdeng00
105 lines
3.4 KiB
C++
105 lines
3.4 KiB
C++
#ifndef SONGCONTROLLER_H_
|
|
#define SONGCONTROLLER_H_
|
|
|
|
#include <iostream>
|
|
#include <limits>
|
|
#include <string>
|
|
#include <memory>
|
|
#include <vector>
|
|
|
|
#include "oatpp/core/macro/codegen.hpp"
|
|
#include "oatpp/core/macro/component.hpp"
|
|
#include "oatpp/web/mime/multipart/InMemoryPartReader.hpp"
|
|
#include "oatpp/web/mime/multipart/Reader.hpp"
|
|
#include "oatpp/web/server/api/ApiController.hpp"
|
|
|
|
#include "database/songRepository.h"
|
|
#include "../dto/songDto.hpp"
|
|
#include "managers/song_manager.h"
|
|
#include "managers/token_manager.h"
|
|
#include "models/models.h"
|
|
#include "types/scopes.h"
|
|
|
|
class songController : public oatpp::web::server::api::ApiController
|
|
{
|
|
public:
|
|
songController(std::string p, OATPP_COMPONENT(std::shared_ptr<ObjectMapper>, objectMapper))
|
|
: oatpp::web::server::api::ApiController(objectMapper), exe_path(p)
|
|
{ }
|
|
|
|
#include OATPP_CODEGEN_BEGIN(ApiController)
|
|
|
|
// endpoint for uploading a song
|
|
ENDPOINT("POST", "/api/v1/song/data", songUpload,
|
|
REQUEST(std::shared_ptr<IncomingRequest>, request))
|
|
{
|
|
auto authHeader = request->getHeader("Authorization");
|
|
|
|
OATPP_ASSERT_HTTP(authHeader, Status::CODE_403, "Nope");
|
|
|
|
auto auth = authHeader->std_str();
|
|
|
|
token_manager tok;
|
|
OATPP_ASSERT_HTTP(tok.is_token_valid(auth, Scope::upload), Status::CODE_403, "Not allowed");
|
|
|
|
auto mp = std::make_shared<oatpp::web::mime::multipart::Multipart>(request->getHeaders());
|
|
|
|
oatpp::web::mime::multipart::Reader mp_reader(mp.get());
|
|
|
|
mp_reader.setPartReader("file", oatpp::web::mime::multipart::createInMemoryPartReader(dataSize));
|
|
|
|
request->transferBody(&mp_reader);
|
|
|
|
auto file = mp->getNamedPart("file");
|
|
|
|
OATPP_ASSERT_HTTP(file, Status::CODE_400, "file is null");
|
|
|
|
auto stream = file->getInputStream();
|
|
auto buff = std::unique_ptr<char>(new char[file->getKnownSize()]);
|
|
auto buffSize = stream->read(buff.get(), file->getKnownSize());
|
|
|
|
std::vector<unsigned char> data(buff.get(), buff.get() + buffSize);
|
|
|
|
Song sng;
|
|
sng.data = std::move(data);
|
|
|
|
song_manager s_mgr(exe_path);
|
|
s_mgr.saveSong(sng);
|
|
|
|
return createResponse(Status::CODE_200, "OK");
|
|
}
|
|
|
|
// endpoint for retrieving all song records in json format
|
|
ENDPOINT("GET", "/api/v1/song", songRecords,
|
|
REQUEST(std::shared_ptr<IncomingRequest>, request))
|
|
{
|
|
std::cout << "starting process of retrieving songs" << std::endl;
|
|
songRepository songRepo(exe_path);
|
|
auto songsDb = songRepo.retrieveRecords();
|
|
auto songs = oatpp::data::mapping::type::List<songDto::ObjectWrapper>::createShared();
|
|
|
|
std::cout << "creating object to send" << std::endl;
|
|
for (auto& songDb : songsDb) {
|
|
auto song = songDto::createShared();
|
|
song->id = songDb.id;
|
|
song->title = songDb.title.c_str();
|
|
song->artist = songDb.artist.c_str();
|
|
song->album = songDb.album.c_str();
|
|
song->genre = songDb.genre.c_str();
|
|
song->year = songDb.year;
|
|
song->duration = songDb.duration;
|
|
|
|
songs->pushBack(song);
|
|
}
|
|
|
|
return createDtoResponse(Status::CODE_200, songs);
|
|
}
|
|
|
|
#include OATPP_CODEGEN_END(ApiController)
|
|
private:
|
|
std::string exe_path;
|
|
const long dataSize = std::numeric_limits<long long int>::max();
|
|
};
|
|
|
|
#endif
|