[DEV] better dislay and view saison in files
This commit is contained in:
parent
9f72146bf2
commit
b6af117397
@ -46,30 +46,37 @@ appl::widget::ListViewer::~ListViewer() {
|
||||
}
|
||||
|
||||
void appl::widget::ListViewer::searchElements(std::string _filter) {
|
||||
if (_filter == "film") {
|
||||
searchElementsInternal("'type' == 'film' AND 'production-methode' == 'picture'");
|
||||
} else if (_filter == "annimation") {
|
||||
searchElementsInternal("'type' == 'film' AND 'production-methode' == 'draw'");
|
||||
} else if (_filter == "tv-show") {
|
||||
searchElementsInternal("'type' == 'tv-show' AND 'production-methode' == 'picture'", "series-name");
|
||||
} else if (_filter == "tv-annimation") {
|
||||
searchElementsInternal("'type' == 'tv-show' AND 'production-methode' == 'draw'", "series-name");
|
||||
} else if (_filter == "theater") {
|
||||
searchElementsInternal("'type' == 'theater'");
|
||||
} else if (_filter == "one-man") {
|
||||
searchElementsInternal("'type' == 'one-man'");
|
||||
} else if (_filter == "courses") {
|
||||
searchElementsInternal("'type' == 'courses'");
|
||||
} else {
|
||||
searchElementsInternal("*");
|
||||
}
|
||||
}
|
||||
|
||||
void appl::widget::ListViewer::searchElementsInternal(const std::string& _filter, const std::string& _group) {
|
||||
m_listElement.clear();
|
||||
m_listElementGroup.clear();
|
||||
m_listDisplay.clear();
|
||||
resetScrollOrigin();
|
||||
if (m_clientProp == nullptr) {
|
||||
APPL_ERROR("No client Availlable ...");
|
||||
return;
|
||||
}
|
||||
if (_filter == "film") {
|
||||
_filter = "'type' == 'film' AND 'production-methode' == 'picture'";
|
||||
} else if (_filter == "annimation") {
|
||||
_filter = "'type' == 'film' AND 'production-methode' == 'draw'";
|
||||
} else if (_filter == "tv-show") {
|
||||
_filter = "'type' == 'tv-show' AND 'production-methode' == 'picture'";
|
||||
} else if (_filter == "tv-annimation") {
|
||||
_filter = "'type' == 'tv-show' AND 'production-methode' == 'draw'";
|
||||
} else if (_filter == "theater") {
|
||||
_filter = "'type' == 'theater'";
|
||||
} else if (_filter == "one-man") {
|
||||
_filter = "'type' == 'one-man'";
|
||||
} else if (_filter == "courses") {
|
||||
_filter = "'type' == 'courses'";
|
||||
} else {
|
||||
_filter = "*";
|
||||
}
|
||||
|
||||
m_currentFilter = _filter;
|
||||
m_currentGroup = _group;
|
||||
markToRedraw();
|
||||
m_clientProp->connect();
|
||||
if (m_clientProp->connection.isAlive() == false) {
|
||||
APPL_ERROR("Conection is not alive anymore ...");
|
||||
@ -88,9 +95,32 @@ void appl::widget::ListViewer::searchElements(std::string _filter) {
|
||||
APPL_ERROR(" ==> Service does not exist : 'video'");
|
||||
return;
|
||||
}
|
||||
zeus::Future<std::vector<uint32_t>> listElem = remoteServiceVideo.getSQL(_filter).wait();
|
||||
if (m_currentGroup != "") {
|
||||
zeus::Future<std::vector<std::string>> listElem = remoteServiceVideo.getMetadataValuesWhere(m_currentGroup, m_currentFilter).wait();
|
||||
if (listElem.hasError() == true) {
|
||||
APPL_ERROR(" ==> Can not get element from video service <with fileter ! '" << _filter << "' : " << listElem.getErrorType() << " : " << listElem.getErrorHelp());
|
||||
APPL_ERROR(" ==> Can not get elements from video service <with fileter ! '" << m_currentFilter << "' : " << listElem.getErrorType() << " : " << listElem.getErrorHelp());
|
||||
return;
|
||||
}
|
||||
std::vector<std::string> returnValues = listElem.get();
|
||||
APPL_INFO("Get some Values: " << returnValues << "");
|
||||
if (returnValues.size() == 1) {
|
||||
// TODO : maybe something to do for series
|
||||
}
|
||||
for (auto &it : returnValues) {
|
||||
auto elem = ememory::makeShared<ElementPropertyGroup>();
|
||||
if (elem == nullptr) {
|
||||
APPL_ERROR("Can not allocate element... " << it);
|
||||
continue;
|
||||
}
|
||||
elem->m_id = 0;
|
||||
elem->m_title = it;
|
||||
//elem->m_thumb = remoteServiceVideo.mediaThumbGet(it, 128).wait().get();
|
||||
m_listElementGroup.push_back(elem);
|
||||
}
|
||||
} else {
|
||||
zeus::Future<std::vector<uint32_t>> listElem = remoteServiceVideo.getSQL(m_currentFilter).wait();
|
||||
if (listElem.hasError() == true) {
|
||||
APPL_ERROR(" ==> Can not get element from video service <with fileter ! '" << m_currentFilter << "' : " << listElem.getErrorType() << " : " << listElem.getErrorHelp());
|
||||
return;
|
||||
}
|
||||
std::vector<uint32_t> returnValues = listElem.get();
|
||||
@ -205,6 +235,7 @@ void appl::widget::ListViewer::searchElements(std::string _filter) {
|
||||
//elem->m_thumb = remoteServiceVideo.mediaThumbGet(it, 128).wait().get();
|
||||
m_listElement.push_back(elem);
|
||||
}
|
||||
}
|
||||
APPL_INFO("Request All is done");
|
||||
}
|
||||
|
||||
@ -230,7 +261,8 @@ void appl::widget::ListViewer::onRegenerateDisplay() {
|
||||
m_text.clear();
|
||||
// to know the size of one line :
|
||||
vec3 minSize = m_text.calculateSize(char32_t('A'));
|
||||
if (m_listElement.size() == 0) {
|
||||
if ( m_listElement.size() == 0
|
||||
&& m_listElementGroup.size() == 0) {
|
||||
int32_t paddingSize = 2;
|
||||
|
||||
vec2 tmpMax = propertyMaxSize->getPixel();
|
||||
@ -244,7 +276,7 @@ void appl::widget::ListViewer::onRegenerateDisplay() {
|
||||
|
||||
ivec2 localSize = m_minSize;
|
||||
|
||||
// no change for the text orogin :
|
||||
// no change for the text orogin:
|
||||
vec3 tmpTextOrigin((m_size.x() - m_minSize.x()) / 2.0,
|
||||
(m_size.y() - m_minSize.y()) / 2.0,
|
||||
0);
|
||||
@ -310,6 +342,11 @@ void appl::widget::ListViewer::onRegenerateDisplay() {
|
||||
} else {
|
||||
elem->m_property.reset();
|
||||
}
|
||||
if (offset + iii < m_listElementGroup.size()) {
|
||||
elem->m_propertyGroup = m_listElementGroup[offset + iii];
|
||||
} else {
|
||||
elem->m_propertyGroup.reset();
|
||||
}
|
||||
//switch(iii%6) {
|
||||
switch((offset + iii)%6) {
|
||||
case 0:
|
||||
@ -358,7 +395,7 @@ void appl::widget::ListViewer::onRegenerateDisplay() {
|
||||
startPos -= vec2(0, elementSize.y());
|
||||
}
|
||||
m_maxSize.setX(m_size.x());
|
||||
m_maxSize.setY((float)m_listElement.size()*elementSize.y());
|
||||
m_maxSize.setY(float(std::max(m_listElement.size(),m_listElementGroup.size()))*elementSize.y());
|
||||
// call the herited class...
|
||||
ewol::widget::WidgetScrolled::onRegenerateDisplay();
|
||||
}
|
||||
@ -377,7 +414,8 @@ void appl::ElementDisplayed::generateDisplay(vec2 _startPos, vec2 _size) {
|
||||
m_image.clear();
|
||||
m_text.clear();
|
||||
m_draw.clear();
|
||||
if (m_property == nullptr) {
|
||||
if ( m_property == nullptr
|
||||
&& m_propertyGroup == nullptr) {
|
||||
return;
|
||||
}
|
||||
//APPL_INFO("Regenrate size : " << _startPos << " " << _size);
|
||||
@ -398,8 +436,6 @@ void appl::ElementDisplayed::generateDisplay(vec2 _startPos, vec2 _size) {
|
||||
m_pos = _startPos;
|
||||
m_size = _size;
|
||||
|
||||
std::unique_lock<std::mutex> lock(m_property->m_mutex);
|
||||
|
||||
// --------------------------------------------
|
||||
// -- Display text...
|
||||
// --------------------------------------------
|
||||
@ -413,8 +449,11 @@ void appl::ElementDisplayed::generateDisplay(vec2 _startPos, vec2 _size) {
|
||||
//APPL_VERBOSE("[" << getId() << "] {" << errorString << "} display at pos : " << tmpTextOrigin);
|
||||
m_text.setTextAlignement(originText.x(), originText.x()+_size.x()-_size.y(), ewol::compositing::alignDisable);
|
||||
// TODO: m_text.setClipping(originText, vec2(originText.x()+_size.x()-_size.y(), _size.y()));
|
||||
std::string textToDisplay;
|
||||
if (m_property != nullptr) {
|
||||
std::unique_lock<std::mutex> lock(m_property->m_mutex);
|
||||
//m_text.setClipping(drawClippingPos, drawClippingSize);
|
||||
std::string textToDisplay = "<b>" + m_property->m_title + "</b><br/>";
|
||||
textToDisplay = "<b>" + m_property->m_title + "</b><br/>";
|
||||
bool newLine = false;
|
||||
if (m_property->m_serie != "") {
|
||||
textToDisplay += "<i>Serie: <b>" + m_property->m_serie + "</b></i><br/>";
|
||||
@ -438,11 +477,18 @@ void appl::ElementDisplayed::generateDisplay(vec2 _startPos, vec2 _size) {
|
||||
textToDisplay += "<br/>";
|
||||
}
|
||||
textToDisplay += "<i>" + m_property->m_description + "</i>";
|
||||
} else {
|
||||
std::unique_lock<std::mutex> lock(m_propertyGroup->m_mutex);
|
||||
//m_text.setClipping(drawClippingPos, drawClippingSize);
|
||||
textToDisplay = "<b>" + m_propertyGroup->m_title + "</b><br/>";
|
||||
}
|
||||
m_text.printDecorated(textToDisplay);
|
||||
|
||||
// --------------------------------------------
|
||||
// -- Display Image...
|
||||
// --------------------------------------------
|
||||
if (m_property != nullptr) {
|
||||
std::unique_lock<std::mutex> lock(m_property->m_mutex);
|
||||
if (etk::start_with(m_property->m_mineType, "video") == true) {
|
||||
m_image.setSource("DATA:Video.svg", 128);
|
||||
} else if (etk::start_with(m_property->m_mineType, "audio") == true) {
|
||||
@ -451,6 +497,10 @@ void appl::ElementDisplayed::generateDisplay(vec2 _startPos, vec2 _size) {
|
||||
APPL_INFO("Set image: Unknow type '" << m_property->m_mineType << "'");
|
||||
m_image.setSource("DATA:Home.svg", 128);
|
||||
}
|
||||
} else {
|
||||
std::unique_lock<std::mutex> lock(m_propertyGroup->m_mutex);
|
||||
m_image.setSource("DATA:Home.svg", 128);
|
||||
}
|
||||
m_image.setPos(_startPos+vec2(10,10));
|
||||
m_image.print(vec2(_size.y(), _size.y())-vec2(20,20));
|
||||
}
|
||||
@ -482,8 +532,11 @@ bool appl::widget::ListViewer::onEventInput(const ewol::event::Input& _event) {
|
||||
if (_event.getId() == 1) {
|
||||
if(_event.getStatus() == gale::key::status::pressSingle) {
|
||||
APPL_DEBUG("Select element : " << findId << " " << m_listDisplay[findId]->m_idCurentElement);
|
||||
if (m_listDisplay[findId]->m_property != nullptr) {
|
||||
ememory::SharedPtr<appl::ElementProperty> prop = m_listDisplay[findId]->m_property;
|
||||
if (prop != nullptr) {
|
||||
if (prop == nullptr) {
|
||||
return true;
|
||||
}
|
||||
std::string fullTitle;
|
||||
if (prop->m_serie != "") {
|
||||
fullTitle += prop->m_serie + "-";
|
||||
@ -497,6 +550,18 @@ bool appl::widget::ListViewer::onEventInput(const ewol::event::Input& _event) {
|
||||
fullTitle += prop->m_title;
|
||||
APPL_DEBUG("info element : " << prop->m_id << " title: " << fullTitle);
|
||||
signalSelect.emit(prop->m_id);
|
||||
} else if (m_listDisplay[findId]->m_propertyGroup != nullptr) {
|
||||
ememory::SharedPtr<appl::ElementPropertyGroup> prop = m_listDisplay[findId]->m_propertyGroup;
|
||||
if (prop == nullptr) {
|
||||
return true;
|
||||
}
|
||||
std::string newGroup = "";
|
||||
if (m_currentGroup == "series-name") {
|
||||
newGroup = "saison";
|
||||
} else if (m_currentGroup == "artist") {
|
||||
newGroup = "album";
|
||||
}
|
||||
searchElementsInternal(m_currentFilter + " AND '" + m_currentGroup + "' == '" + prop->m_title + "'", newGroup);
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
||||
@ -20,7 +20,7 @@ namespace appl {
|
||||
class ElementProperty {
|
||||
public:
|
||||
std::mutex m_mutex;
|
||||
uint32_t m_id; //!< Remote Id of the Media
|
||||
uint64_t m_id; //!< Remote Id of the Media
|
||||
bool m_metadataUpdated; //!< Check value to know when metadata is getted (like thumb ...)
|
||||
egami::Image m_thumb; //!< simple image describing the element
|
||||
std::string m_title; //!< Title of the Element
|
||||
@ -35,9 +35,16 @@ namespace appl {
|
||||
// TODO: int32_t m_countPersonalView; //!< number of view this media
|
||||
// TODO: int64_t m_globalPersonalView; //!< number of time this media has been viewed
|
||||
};
|
||||
class ElementPropertyGroup {
|
||||
public:
|
||||
std::mutex m_mutex;
|
||||
uint64_t m_id; //!< Remote Id of the Media
|
||||
std::string m_title; //!< Title of the Group
|
||||
};
|
||||
class ElementDisplayed {
|
||||
public:
|
||||
ememory::SharedPtr<appl::ElementProperty> m_property;
|
||||
ememory::SharedPtr<appl::ElementPropertyGroup> m_propertyGroup;
|
||||
int32_t m_idCurentElement;
|
||||
etk::Color<float> m_bgColor;
|
||||
vec2 m_pos;
|
||||
@ -75,6 +82,9 @@ namespace appl {
|
||||
ememory::SharedPtr<ClientProperty> m_clientProp; //!< Generic entrypoint on the Client
|
||||
protected:
|
||||
std::vector<ememory::SharedPtr<ElementProperty>> m_listElement; //!< list of all element getted in the remote access
|
||||
std::vector<ememory::SharedPtr<ElementPropertyGroup>> m_listElementGroup; //!< list of all element getted in the remote access
|
||||
std::string m_currentFilter;
|
||||
std::string m_currentGroup;
|
||||
std::vector<ememory::SharedPtr<ElementDisplayed>> m_listDisplay; //!< list of element in the current local display
|
||||
protected:
|
||||
//! @brief constructor
|
||||
@ -92,6 +102,7 @@ namespace appl {
|
||||
m_clientProp = _prop;
|
||||
}
|
||||
void searchElements(std::string _filter="");
|
||||
void searchElementsInternal(const std::string& _filter, const std::string& _group="");
|
||||
bool onEventInput(const ewol::event::Input& _event) override;
|
||||
};
|
||||
}
|
||||
|
||||
@ -8,14 +8,15 @@
|
||||
|
||||
#include <ewol/widget/Manager.hpp>
|
||||
|
||||
const float dotRadius = 6.0f;
|
||||
|
||||
appl::widget::VolumeBar::VolumeBar() :
|
||||
signalChange(this, "change", ""),
|
||||
propertyValue(this, "value",
|
||||
0.0f,
|
||||
"Value of the VolumeBar",
|
||||
&appl::widget::VolumeBar::onChangePropertyValue),
|
||||
propertyStep(this, "step",
|
||||
1.0f,
|
||||
"step value when change"),
|
||||
propertyMinimum(this, "min",
|
||||
-10.0f,
|
||||
"Minimum value",
|
||||
@ -45,7 +46,7 @@ appl::widget::VolumeBar::~VolumeBar() {
|
||||
void appl::widget::VolumeBar::calculateMinMaxSize() {
|
||||
vec2 minTmp = propertyMinSize->getPixel();
|
||||
m_minSize.setValue(std::max(minTmp.x(), 40.0f),
|
||||
std::max(minTmp.y(), dotRadius*2.0f) );
|
||||
std::max(minTmp.y(), std::max(minTmp.x(), 40.0f)) );
|
||||
markToRedraw();
|
||||
}
|
||||
|
||||
@ -60,32 +61,62 @@ void appl::widget::VolumeBar::onRegenerateDisplay() {
|
||||
// clean the object list ...
|
||||
m_draw.clear();
|
||||
m_draw.setColor(m_textColorFg);
|
||||
|
||||
// draw a line:
|
||||
m_draw.setPos(vec3(dotRadius, 0.0f, 0.0f));
|
||||
m_draw.rectangleWidth(vec3(m_size.x(), m_size.y()-dotRadius*2.0f, 0.0f));
|
||||
#if 0
|
||||
m_draw.setPos(vec2(0.0f, 0.0f));
|
||||
m_draw.rectangleWidth(vec2(m_size.x(), m_size.y()));
|
||||
#else
|
||||
m_draw.setThickness(4.0f);
|
||||
m_draw.setPos(vec2(0.0f, 0.0f));
|
||||
m_draw.lineRel(vec2(m_size.x(), 0.0f));
|
||||
m_draw.lineRel(vec2(0.0f, m_size.y()));
|
||||
m_draw.lineRel(vec2(-m_size.x(), 0.0f));
|
||||
m_draw.lineRel(vec2(0.0f, -m_size.y()));
|
||||
#endif
|
||||
// chaneg color whe soud became louder ...
|
||||
if (*propertyValue > 0.5f) {
|
||||
m_draw.setColor(m_textColorLoaded);
|
||||
} else {
|
||||
m_draw.setColor(m_textColorDone);
|
||||
}
|
||||
m_draw.setPos(vec3(m_size.x()*0.1f, dotRadius, 0.0f));
|
||||
m_draw.setPos(vec3(m_size.x()*0.1f, m_size.x()*0.1f, 0.0f));
|
||||
|
||||
float offset = (*propertyValue-*propertyMinimum)/(*propertyMaximum-*propertyMinimum);
|
||||
m_draw.rectangleWidth(vec3(m_size.x()*0.8f, offset*(m_size.y()-2.0f*dotRadius), 0.0f) );
|
||||
m_draw.rectangleWidth(vec3(m_size.x()*0.8f, offset*(m_size.y()-m_size.x()*0.2f), 0.0f) );
|
||||
|
||||
}
|
||||
|
||||
bool appl::widget::VolumeBar::onEventInput(const ewol::event::Input& _event) {
|
||||
vec2 relativePos = relativePosition(_event.getPos());
|
||||
//EWOL_DEBUG("Event on VolumeBar ..." << _event);
|
||||
if (1 == _event.getId()) {
|
||||
if( gale::key::status::pressSingle == _event.getStatus()
|
||||
|| gale::key::status::move == _event.getStatus()) {
|
||||
if (_event.getId() == 1) {
|
||||
if( _event.getStatus() == gale::key::status::pressSingle
|
||||
|| _event.getStatus() == gale::key::status::move) {
|
||||
// get the new position :
|
||||
EWOL_VERBOSE("Event on VolumeBar " << relativePos);
|
||||
float oldValue = *propertyValue;
|
||||
updateValue((float)(relativePos.y() - dotRadius) / (m_size.y()-2*dotRadius) * (*propertyMaximum-*propertyMinimum)+*propertyMinimum);
|
||||
updateValue((float)(relativePos.y() - m_size.x()*0.1f) / (m_size.y()-m_size.x()*0.2f) * (*propertyMaximum-*propertyMinimum)+*propertyMinimum);
|
||||
if (oldValue != *propertyValue) {
|
||||
EWOL_VERBOSE(" new value : " << *propertyValue << " in [" << *propertyMinimum << ".." << *propertyMaximum << "]");
|
||||
signalChange.emit(*propertyValue);
|
||||
}
|
||||
return true;
|
||||
}
|
||||
} else if (_event.getId() == 4) {
|
||||
if(_event.getStatus() == gale::key::status::pressSingle) {
|
||||
float oldValue = *propertyValue;
|
||||
updateValue(*propertyValue + *propertyStep);
|
||||
if (oldValue != *propertyValue) {
|
||||
EWOL_VERBOSE(" new value : " << *propertyValue << " in [" << *propertyMinimum << ".." << *propertyMaximum << "]");
|
||||
signalChange.emit(*propertyValue);
|
||||
}
|
||||
return true;
|
||||
}
|
||||
} else if (_event.getId() == 5) {
|
||||
if(_event.getStatus() == gale::key::status::pressSingle) {
|
||||
float oldValue = *propertyValue;
|
||||
updateValue(*propertyValue - *propertyStep);
|
||||
if (oldValue != *propertyValue) {
|
||||
EWOL_VERBOSE(" new value : " << *propertyValue << " in [" << *propertyMinimum << ".." << *propertyMaximum << "]");
|
||||
signalChange.emit(*propertyValue);
|
||||
|
||||
@ -26,6 +26,7 @@ namespace appl {
|
||||
public:
|
||||
//eproperty::Value<std::string> propertyShape; //!< name of the shape used
|
||||
eproperty::Value<float> propertyValue; //!< current value of the VolumeBar
|
||||
eproperty::Value<float> propertyStep; //!< Up and down step value
|
||||
eproperty::Value<float> propertyMinimum; //!< minimum value of the VolumeBar
|
||||
eproperty::Value<float> propertyMaximum; //!< maximum value of the VolumeBar
|
||||
protected:
|
||||
|
||||
@ -32,7 +32,7 @@
|
||||
<sizer mode="hori" fill="true" expand="true,false">
|
||||
<sizer mode="vert" fill="true" expand="false,true">
|
||||
<image src="DATA:Light.svg" size="8,8mm" />
|
||||
<appl_VolumeBar name="[{ID}]appl-player-light" expand="false,true" fill="true" step="1" value="100" min="0" max="100" mode="vert"/>
|
||||
<appl_VolumeBar name="[{ID}]appl-player-light" expand="false,true" fill="true" step="5" value="100" min="0" max="100" mode="vert"/>
|
||||
<label name="[{ID}]appl-player-label-light">100%</label>
|
||||
</sizer>
|
||||
<sizer mode="vert" fill="true" expand="true">
|
||||
@ -41,7 +41,7 @@
|
||||
</sizer>
|
||||
<sizer mode="vert" fill="true" expand="false,true">
|
||||
<image src="DATA:Volume.svg" size="8,8mm" />
|
||||
<appl_VolumeBar name="[{ID}]appl-player-volume" expand="false,true" fill="true" step="0.1" value="0" min="-60" max="6" mode="vert"/>
|
||||
<appl_VolumeBar name="[{ID}]appl-player-volume" expand="false,true" fill="true" step="0.3" value="0" min="-40" max="6" mode="vert"/>
|
||||
<label name="[{ID}]appl-player-label-volume">0dB</label>
|
||||
</sizer>
|
||||
</sizer>
|
||||
|
||||
@ -236,6 +236,7 @@ ememory::SharedPtr<appl::GateWayInterface> appl::Router::get(const std::string&
|
||||
APPL_INFO("New Child log in = " << logFile);
|
||||
}
|
||||
std::string delay = "--router-delay=" + etk::to_string(*propertyDelayToStop);
|
||||
APPL_INFO("execute: " << binary << " " << userConf << " --srv=all " << delay << " " << basePath << " " << logFile);
|
||||
int ret = execlp( binary.c_str(),
|
||||
binary.c_str(), // must repeate the binary name to have the name as first argument ...
|
||||
userConf.c_str(),
|
||||
|
||||
@ -212,12 +212,8 @@ namespace appl {
|
||||
}
|
||||
}
|
||||
|
||||
std::vector<uint32_t> getSQL(std::string _sqlLikeRequest) override {
|
||||
std::vector<uint32_t> out;
|
||||
if (_sqlLikeRequest == "") {
|
||||
throw std::invalid_argument("empty request");
|
||||
}
|
||||
std::vector<std::vector<std::string>> listAndParsed;
|
||||
std::vector<std::vector<std::string>> interpreteSQLRequest(const std::string& _sqlLikeRequest) {
|
||||
std::vector<std::vector<std::string>> out;
|
||||
if (_sqlLikeRequest != "*") {
|
||||
std::vector<std::string> listAnd = etk::split(_sqlLikeRequest, "AND");
|
||||
APPL_INFO("Find list AND : ");
|
||||
@ -237,56 +233,75 @@ namespace appl {
|
||||
throw std::invalid_argument("action invalid : '" + elements[1] + "' only availlable : [==,!=,<=,>=,<,>]");
|
||||
}
|
||||
APPL_INFO(" - '" << elements[0] << "' action='" << elements[1] << "' with='" << elements[2] << "'");
|
||||
listAndParsed.push_back(elements);
|
||||
out.push_back(elements);
|
||||
}
|
||||
}
|
||||
return out;
|
||||
}
|
||||
|
||||
bool isValid(const std::vector<std::vector<std::string>>& _listElement,
|
||||
const std::map<std::string, std::string>& _metadata) {
|
||||
for (auto &itCheck : _listElement) {
|
||||
// find matadataValue:
|
||||
auto itM = _metadata.find(itCheck[0]);
|
||||
if (itM == _metadata.end()) {
|
||||
// not find key ==> no check to do ...
|
||||
return false;
|
||||
}
|
||||
if (itCheck[1] == "==") {
|
||||
if (itM->second != itCheck[2]) {
|
||||
return false;
|
||||
}
|
||||
} else if (itCheck[1] == "!=") {
|
||||
if (itM->second == itCheck[2]) {
|
||||
return false;
|
||||
}
|
||||
} else if (itCheck[1] == "<=") {
|
||||
if (itM->second < itCheck[2]) {
|
||||
return false;
|
||||
}
|
||||
} else if (itCheck[1] == ">=") {
|
||||
if (itM->second > itCheck[2]) {
|
||||
return false;
|
||||
}
|
||||
} else if (itCheck[1] == "<") {
|
||||
if (itM->second <= itCheck[2]) {
|
||||
return false;
|
||||
}
|
||||
} else if (itCheck[1] == ">") {
|
||||
if (itM->second >= itCheck[2]) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
||||
std::string mapToString(const std::map<std::string, std::string>& _metadata) {
|
||||
std::string out = "{";
|
||||
for (auto &it : _metadata) {
|
||||
out += it.first + ":" + it.second + ",";
|
||||
}
|
||||
out += "}";
|
||||
return out;
|
||||
}
|
||||
|
||||
std::vector<uint32_t> getSQL(std::string _sqlLikeRequest) override {
|
||||
std::vector<uint32_t> out;
|
||||
if (_sqlLikeRequest == "") {
|
||||
throw std::invalid_argument("empty request");
|
||||
}
|
||||
APPL_INFO("check : " << _sqlLikeRequest);
|
||||
std::vector<std::vector<std::string>> listAndParsed = interpreteSQLRequest(_sqlLikeRequest);
|
||||
std::unique_lock<std::mutex> lock(g_mutex);
|
||||
for (auto &it : m_listFile) {
|
||||
if (it == nullptr) {
|
||||
continue;
|
||||
}
|
||||
bool isCorrectElement = true;
|
||||
for (auto &itCheck : listAndParsed) {
|
||||
// find matadataValue:
|
||||
auto itM = it->getMetadataDirect().find(itCheck[0]);
|
||||
if (itM == it->getMetadataDirect().end()) {
|
||||
// not find key ==> no check to do ...
|
||||
isCorrectElement = false;
|
||||
break;
|
||||
}
|
||||
if (itCheck[1] == "==") {
|
||||
if (itM->second != itCheck[2]) {
|
||||
isCorrectElement = false;
|
||||
break;
|
||||
}
|
||||
} else if (itCheck[1] == "!=") {
|
||||
if (itM->second == itCheck[2]) {
|
||||
isCorrectElement = false;
|
||||
break;
|
||||
}
|
||||
} else if (itCheck[1] == "<=") {
|
||||
if (itM->second < itCheck[2]) {
|
||||
isCorrectElement = false;
|
||||
break;
|
||||
}
|
||||
} else if (itCheck[1] == ">=") {
|
||||
if (itM->second > itCheck[2]) {
|
||||
isCorrectElement = false;
|
||||
break;
|
||||
}
|
||||
} else if (itCheck[1] == "<") {
|
||||
if (itM->second <= itCheck[2]) {
|
||||
isCorrectElement = false;
|
||||
break;
|
||||
}
|
||||
} else if (itCheck[1] == ">") {
|
||||
if (itM->second >= itCheck[2]) {
|
||||
isCorrectElement = false;
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
APPL_INFO(" [" << it->getUniqueId() << " list=" << mapToString(it->getMetadataDirect()));
|
||||
bool isCorrectElement = isValid(listAndParsed, it->getMetadataDirect());
|
||||
if (isCorrectElement == true) {
|
||||
APPL_INFO(" select");
|
||||
out.push_back(it->getUniqueId());
|
||||
}
|
||||
}
|
||||
@ -294,9 +309,36 @@ namespace appl {
|
||||
}
|
||||
|
||||
std::vector<std::string> getMetadataValuesWhere(std::string _keyName, std::string _sqlLikeRequest) override {
|
||||
std::unique_lock<std::mutex> lock(g_mutex);
|
||||
std::vector<std::string> out;
|
||||
// 'type' == 'film' AND 'production-methode' == 'picture'
|
||||
if (_sqlLikeRequest == "") {
|
||||
throw std::invalid_argument("empty request");
|
||||
}
|
||||
std::vector<std::vector<std::string>> listAndParsed = interpreteSQLRequest(_sqlLikeRequest);
|
||||
std::unique_lock<std::mutex> lock(g_mutex);
|
||||
for (auto &it : m_listFile) {
|
||||
if (it == nullptr) {
|
||||
continue;
|
||||
}
|
||||
bool isCorrectElement = isValid(listAndParsed, it->getMetadataDirect());
|
||||
if (isCorrectElement == false) {
|
||||
continue;
|
||||
}
|
||||
auto it2 = it->getMetadataDirect().find(_keyName);
|
||||
if (it2 == it->getMetadataDirect().end()) {
|
||||
continue;
|
||||
}
|
||||
std::string value = it2->second;
|
||||
isCorrectElement = false;
|
||||
for (auto &it2: out) {
|
||||
if (it2 == value) {
|
||||
isCorrectElement = true;
|
||||
break;
|
||||
}
|
||||
}
|
||||
if (isCorrectElement == false) {
|
||||
out.push_back(value);
|
||||
}
|
||||
}
|
||||
return out;
|
||||
}
|
||||
|
||||
|
||||
Loading…
Reference in New Issue
Block a user