File: cache.cpp

package info (click to toggle)
mpdas 0.4.5-1
  • links: PTS, VCS
  • area: main
  • in suites: bookworm, bullseye, buster, forky, sid, trixie
  • size: 188 kB
  • sloc: cpp: 1,455; makefile: 34
file content (114 lines) | stat: -rw-r--r-- 2,234 bytes parent folder | download
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
#include "mpdas.h"

CCache* Cache = 0;

void CCache::SaveCache()
{
	std::string path = getenv("HOME");
	path.append("/.mpdascache");
	remove(path.c_str());
	std::ofstream ofs(path.c_str());
	if(!_entries.size()) {
		remove(path.c_str());
		return;
	}

	for(unsigned int i = 0; i < _entries.size(); i++) {
		CacheEntry* entry = _entries[i];
		ofs << *entry;

		if(i+1 == _entries.size())
			ofs.flush();
		else
			ofs << std::endl;
	}
	ofs.close();
}

void CCache::LoadCache()
{
	int length;
	std::string path = getenv("HOME");
	path.append("/.mpdascache");
	std::ifstream ifs(path.c_str(), std::ios::in|std::ios::binary);

	ifs.seekg (0, std::ios::end);
	length = ifs.tellg();
	ifs.seekg (0, std::ios::beg);


	while(ifs.good()) {
		if(length == ifs.tellg())
			break;

		CacheEntry *entry = new CacheEntry();
		ifs >> *entry;
		_entries.push_back(entry);
	}

	ifs.close();
	remove(path.c_str());
}

void CCache::WorkCache()
{
	if(_failtime && time(NULL) - _failtime < 300) {
		return;
	}
	_failtime = 0;
	while(_entries.size()) {
		if(AudioScrobbler->Scrobble(*_entries.front())) {
			delete _entries.front();
			_entries.erase(_entries.begin());
		}
		else {
			eprintf("%s", "Error scrobbling. Trying again in 5 minutes.");
			_failtime = time(NULL);
			AudioScrobbler->Failure();
			break;
		}
		sleep(1);
	}
	SaveCache();
}

void CCache::AddToCache(const Song& song, time_t starttime)
{
	CacheEntry *entry = new CacheEntry(song, starttime);

	_entries.push_back(entry);
	SaveCache();
}

std::ofstream& operator <<(std::ofstream& outstream, const CacheEntry& inobj)
{
	Song song = inobj.getSong();
	outstream << song.getArtist() << std::endl
			  << song.getTitle() << std::endl
			  << song.getAlbum() << std::endl
			  << song.getDuration() << std::endl
			  << inobj.getStartTime();

	return outstream;
}

std::ifstream& operator >>(std::ifstream& instream, CacheEntry& outobj)
{
	std::string artist, title, album;
	int duration;
	time_t starttime;

	getline(instream, artist);
	getline(instream, title);
	getline(instream, album);

	instream >> duration;
	instream.ignore(1);
	instream >> starttime;
	instream.ignore(1);

	Song song(artist, title, album, duration);
	outobj = CacheEntry(song, starttime);

	return instream;
}