1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
|
#include "music.h"
#include "decoder.h"
#include "encoder.h"
#include "transcode.h"
#include "tag.h"
#include "config.h"
#include <boost/format.hpp>
#include <boost/algorithm/string/predicate.hpp>
#include <boost/algorithm/string/classification.hpp>
#include <boost/algorithm/string/split.hpp>
#include <boost/cast.hpp>
#include <boost/filesystem/fstream.hpp>
#include <boost/foreach.hpp>
#include <soci/soci.h>
fs::path music::root_directory;
void music::init(std::string root) {
// remove trailing slash
if(boost::algorithm::ends_with(root, "/"))
root = root.substr(0, root.size()-1);
root_directory = root;
}
MusicListing::p music::get(const HTTP::Connection::PathList& path) {
// prefix path with our root_directory
fs::path p = root_directory;
for(HTTP::Connection::PathList::const_iterator it = path.begin(); it != path.end(); it++) {
// don't allow requests with /../ in the path
if(*it == "..") {
return MusicListing::p();
}
p /= *it;
}
if(fs::is_directory(p)) {
boost::shared_ptr<MusicListing> ml(new MusicDirectory(p));
return ml;
} else if(fs::is_regular_file(p)) {
boost::shared_ptr<MusicListing> ml(new MusicTrack(p));
return ml;
}
return MusicListing::p();
}
MusicListing::p music::get(const std::string& path) {
HTTP::Connection::PathList path_vector;
boost::algorithm::split(path_vector, path, boost::algorithm::is_any_of("/\\"));
return get(path_vector);
}
MusicDirectory::p music::get_directory(const std::string& path) {
MusicListing::p ml = get(path);
if(!ml || !fs::is_directory(ml->path)) {
return MusicDirectory::p();
}
MusicDirectory::p dir(boost::dynamic_pointer_cast<MusicDirectory>(ml));
return dir;
}
std::vector<MusicListing::p> music::find_artist(const std::string artist) {
soci::session sql(config::vm["audist.database"].as<std::string>());
soci::rowset<std::string> rs = (sql.prepare << "SELECT file_name FROM tracks WHERE artist_id IN (SELECT id FROM artists WHERE name LIKE :name)",
soci::use("%"+artist+"%"));
std::vector<MusicListing::p> results;
for(soci::rowset<std::string>::const_iterator it = rs.begin(); it != rs.end(); it++) {
boost::shared_ptr<MusicListing> ml(new MusicTrack(*it));
results.push_back(ml);
}
return results;
}
void music::begin_update(const std::string path) {
MusicDirectory::p dir = get_directory(path);
std::cout << boost::format("updater(%s) called") % path << std::endl;
if(dir) {
update(dir->path);
}
}
void music::update(const MusicDirectory& dir) {
BOOST_FOREACH(fs::path t, dir.tracks) {
std::cout << "track " << t << std::endl;
}
std::for_each(dir.directories.begin(), dir.directories.end(), update);
}
void MusicDirectory::render(HTTP::Connection::p req) {
req->add_header("content-type", "text/html");
for(PathListings::iterator it = directories.begin(); it != directories.end(); it++) {
std::string rel_path = it->string().substr(music::root_directory.string().size());
req->send_data(boost::str(boost::format("<a href=\"/files%s\">%s</a><br />") % rel_path % rel_path));
}
for(PathListings::iterator it = tracks.begin(); it != tracks.end(); it++) {
std::string rel_path = it->string().substr(music::root_directory.string().size());
req->send_data(boost::str(boost::format("<a href=\"/files%s\">%s</a><br />") % rel_path % rel_path));
}
}
MusicTrack::MusicTrack(const fs::path path) {
std::cout << path << std::endl;
this->path = path;
}
MusicDirectory::MusicDirectory(const fs::path root) {
this->path = root;
std::cout << this->path << std::endl;
fs::directory_iterator end_itr;
for(fs::directory_iterator it(this->path); it != end_itr; it++) {
if(fs::is_directory(it->status())) {
directories.push_back(it->path());
} else if(fs::is_regular_file(it->status())) {
tracks.push_back(it->path());
}
}
}
void MusicTrack::render(HTTP::Connection::p req) {
req->add_header("content-type", "application/octet-stream");
// tag test
Tag *t = new ID3Tag(path.string());
delete t;
if(req->args.count("decoder") && req->args.count("encoder")) {
DecoderBase *d = decoder::get_decoder(req->args["decoder"]);
EncoderBase *e = encoder::get_encoder(req->args["encoder"]);
Transcoder t(path.string(), req, *d, *e);
t.run();
delete d;
delete e;
} else {
fs::ifstream is(path, std::ios::in | std::ios::binary);
is.seekg(0, std::ios::end);
req->add_header("content-length", boost::str(boost::format("%d") % is.tellg()));
is.seekg(0, std::ios::beg);
char data[0x1000];
while(is.good()) {
is.read(data, 0x1000);
req->send_data(data, is.gcount());
}
}
}
|
