summaryrefslogtreecommitdiff
path: root/music.cpp
blob: 772ae9c264a2c4aa39687d7a7dea5dcd5eab5be3 (plain)
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
#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/filesystem/fstream.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 std::vector<std::string>& path) {
	// prefix path with our root_directory
	fs::path p = root_directory;
	
	for(std::vector<std::string>::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) {
	std::vector<std::string> path_vector;
	boost::algorithm::split(path_vector, path, boost::algorithm::is_any_of("/\\"));
	return get(path_vector);
}

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 MusicDirectory::render(HTTP::Connection::p req, HTTPResponse& res) {
	res.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());
		res.write(boost::str(boost::format("<a href=\"%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());
		res.write(boost::str(boost::format("<a href=\"%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, HTTPResponse& res) {
	res.add_header("content-type", "application/octet-stream");

	// tag test
	Tag *t = new ID3Tag(path.string());
	delete t;

	fs::ifstream is(path, std::ios::binary | std::ios::in);

	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(is, res, *d, *e);
		t.run();
		delete d;
		delete e;
	} else {
		is.seekg(0, std::ios::end);
		res.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);
			res.write(data, is.gcount());
		}
	}
}