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
|
#pragma once
#include "country.hpp"
#include "index.hpp"
#include "../platform/http_request.hpp"
#include "../std/vector.hpp"
#include "../std/map.hpp"
#include "../std/list.hpp"
#include "../std/string.hpp"
#include "../std/set.hpp"
#include "../std/function.hpp"
#include "../std/scoped_ptr.hpp"
namespace storage
{
/// Used in GUI
enum TStatus
{
EOnDisk = 0,
ENotDownloaded,
EDownloadFailed,
EDownloading,
EInQueue,
EUnknown,
EOnDiskOutOfDate
};
/// Can be used to store local maps and/or maps available for download
class Storage
{
/// We support only one simultaneous request at the moment
scoped_ptr<downloader::HttpRequest> m_request;
/// stores timestamp for update checks
int64_t m_currentVersion;
CountriesContainerT m_countries;
/// store queue for downloading
typedef list<TIndex> TQueue;
TQueue m_queue;
/// stores countries which download has failed recently
typedef set<TIndex> TCountriesSet;
TCountriesSet m_failedCountries;
/// used to correctly calculate total country download progress with more than 1 file
/// <current, total>
downloader::HttpRequest::ProgressT m_countryProgress;
/// @name Communicate with GUI
//@{
typedef function<void (TIndex const &)> TChangeCountryFunction;
typedef function<void (TIndex const &, pair<int64_t, int64_t> const &)> TProgressFunction;
int m_currentSlotId;
struct CountryObservers
{
TChangeCountryFunction m_changeCountryFn;
TProgressFunction m_progressFn;
int m_slotId;
};
typedef list<CountryObservers> ObserversContT;
ObserversContT m_observers;
//@}
/// @name Communicate with Framework
//@{
typedef function<void (string const &)> TUpdateAfterDownload;
TUpdateAfterDownload m_updateAfterDownload;
//@}
void DownloadNextCountryFromQueue();
void LoadCountriesFile(bool forceReload);
void ReportProgress(TIndex const & index, pair<int64_t, int64_t> const & p);
public:
Storage();
void Init(TUpdateAfterDownload const & updateFn);
/// @name Called from DownloadManager
//@{
void OnServerListDownloaded(downloader::HttpRequest & request);
void OnMapDownloadFinished(downloader::HttpRequest & request);
void OnMapDownloadProgress(downloader::HttpRequest & request);
//@}
/// @name Current impl supports only one observer
//@{
/// @return unique identifier that should be used with Unsubscribe function
int Subscribe(TChangeCountryFunction const & change,
TProgressFunction const & progress);
void Unsubscribe(int slotId);
//@}
Country const & CountryByIndex(TIndex const & index) const;
TIndex FindIndexByFile(string const & name) const;
void GetGroupAndCountry(TIndex const & index, string & group, string & country) const;
size_t CountriesCount(TIndex const & index) const;
string const & CountryName(TIndex const & index) const;
string const & CountryFlag(TIndex const & index) const;
LocalAndRemoteSizeT CountrySizeInBytes(TIndex const & index) const;
TStatus CountryStatus(TIndex const & index) const;
//m2::RectD CountryBounds(TIndex const & index) const;
void DownloadCountry(TIndex const & index);
bool DeleteFromDownloader(TIndex const & index);
void NotifyStatusChanged(TIndex const & index) const;
string GetFileDownloadUrl(string const & baseUrl, string const & fName) const;
};
}
|
