Differential D3260 Diff 8135 src/attica/atticaprovider.cpp

Changeset View

Standalone View

View Options

src/attica/atticaprovider.cpp

Context not available.
17 17​
18#include "atticaprovider_p.h" 18​#include "atticaprovider_p.h"
19 19​
20#include <knewstuff_debug.h> 20​#include "question.h"
21​
22​#include <knewstuffcore_debug.h>
21#include <klocalizedstring.h> 23​#include <klocalizedstring.h>
22#include <kio/job.h> ​
23#include <kmessagebox.h> ​
24 24​
25#include <attica/providermanager.h> 25​#include <attica/providermanager.h>
26#include <attica/provider.h> 26​#include <attica/provider.h>
Context not available.
32 32​
33using namespace Attica; 33​using namespace Attica;
34 34​
35namespace KNS3 35​namespace KNSCore
36{ 36​{
37 37​
38AtticaProvider::AtticaProvider(const QStringList &categories) 38​AtticaProvider::AtticaProvider(const QStringList &categories)
Context not available.
65 return m_provider.baseUrl().toString(); 65​ return m_provider.baseUrl().toString();
66} 66​}
67 67​
68void AtticaProvider::authenticationCredentialsMissing(const KNS3::Provider &) 68​void AtticaProvider::authenticationCredentialsMissing(const KNSCore::Provider &)
69{ 69​{
70 qCDebug(KNEWSTUFF) << "Authentication missing!"; 70​ qCDebug(KNEWSTUFFCORE) << "Authentication missing!";
71 // FIXME Show autentication dialog 71​ // FIXME Show autentication dialog
72} 72​}
73 73​
Context not available.
79 79​
80 // FIXME this is quite ugly, repackaging the xml into a string 80​ // FIXME this is quite ugly, repackaging the xml into a string
81 QDomDocument doc(QStringLiteral("temp")); 81​ QDomDocument doc(QStringLiteral("temp"));
82 qCDebug(KNEWSTUFF) << "setting provider xml" << doc.toString(); 82​ qCDebug(KNEWSTUFFCORE) << "setting provider xml" << doc.toString();
83 83​
84 doc.appendChild(xmldata.cloneNode(true)); 84​ doc.appendChild(xmldata.cloneNode(true));
85 m_providerManager.addProviderFromXml(doc.toString()); 85​ m_providerManager.addProviderFromXml(doc.toString());
86 86​
87 if (!m_providerManager.providers().isEmpty()) { 87​ if (!m_providerManager.providers().isEmpty()) {
88 qCDebug(KNEWSTUFF) << "base url of attica provider:" << m_providerManager.providers().last().baseUrl().toString(); 88​ qCDebug(KNEWSTUFFCORE) << "base url of attica provider:" << m_providerManager.providers().last().baseUrl().toString();
89 } else { 89​ } else {
90 qCritical() << "Could not load provider."; 90​ qCritical() << "Could not load provider.";
91 return false; 91​ return false;
Context not available.
93 return true; 93​ return true;
94} 94​}
95 95​
96void AtticaProvider::setCachedEntries(const KNS3::EntryInternal::List &cachedEntries) 96​void AtticaProvider::setCachedEntries(const KNSCore::EntryInternal::List &cachedEntries)
97{ 97​{
98 mCachedEntries = cachedEntries; 98​ mCachedEntries = cachedEntries;
99} 99​}
Context not available.
101void AtticaProvider::providerLoaded(const Attica::Provider &provider) 101​void AtticaProvider::providerLoaded(const Attica::Provider &provider)
102{ 102​{
103 mName = provider.name(); 103​ mName = provider.name();
104 qCDebug(KNEWSTUFF) << "Added provider: " << provider.name(); 104​ qCDebug(KNEWSTUFFCORE) << "Added provider: " << provider.name();
105 105​
106 m_provider = provider; 106​ m_provider = provider;
107 107​
Context not available.
116 return; 116​ return;
117 } 117​ }
118 118​
119 qCDebug(KNEWSTUFF) << "loading categories: " << mCategoryMap.keys(); 119​ qCDebug(KNEWSTUFFCORE) << "loading categories: " << mCategoryMap.keys();
120 120​
121 Attica::ListJob<Attica::Category> *job = static_cast<Attica::ListJob<Attica::Category>*>(listJob); 121​ Attica::ListJob<Attica::Category> *job = static_cast<Attica::ListJob<Attica::Category>*>(listJob);
122 Category::List categoryList = job->itemList(); 122​ Category::List categoryList = job->itemList();
123 123​
124 foreach (const Category &category, categoryList) { 124​ foreach (const Category &category, categoryList) {
125 if (mCategoryMap.contains(category.name())) { 125​ if (mCategoryMap.contains(category.name())) {
126 qCDebug(KNEWSTUFF) << "Adding category: " << category.name(); 126​ qCDebug(KNEWSTUFFCORE) << "Adding category: " << category.name();
127 mCategoryMap[category.name()] = category; 127​ mCategoryMap[category.name()] = category;
128 } 128​ }
129 } 129​ }
Context not available.
131 bool correct = false; 131​ bool correct = false;
132 for(auto it = mCategoryMap.cbegin(), itEnd = mCategoryMap.cend(); it!=itEnd; ++it) { 132​ for(auto it = mCategoryMap.cbegin(), itEnd = mCategoryMap.cend(); it!=itEnd; ++it) {
133 if (!it.value().isValid()) { 133​ if (!it.value().isValid()) {
134 qCWarning(KNEWSTUFF) << "Could not find category" << it.key(); 134​ qCWarning(KNEWSTUFFCORE) << "Could not find category" << it.key();
135 } else { 135​ } else {
136 correct = true; 136​ correct = true;
137 } 137​ }
Context not available.
150 return mInitialized; 150​ return mInitialized;
151} 151​}
152 152​
153void AtticaProvider::loadEntries(const KNS3::Provider::SearchRequest &request) 153​void AtticaProvider::loadEntries(const KNSCore::Provider::SearchRequest &request)
154{ 154​{
155 if (mEntryJob) { 155​ if (mEntryJob) {
156 mEntryJob->abort(); 156​ mEntryJob->abort();
Context not available.
206 connect(job, &BaseJob::finished, this, &AtticaProvider::detailsLoaded); 206​ connect(job, &BaseJob::finished, this, &AtticaProvider::detailsLoaded);
207 m_updateJobs.insert(job); 207​ m_updateJobs.insert(job);
208 job->start(); 208​ job->start();
209 qCDebug(KNEWSTUFF) << "Checking for update: " << e.name(); 209​ qCDebug(KNEWSTUFFCORE) << "Checking for update: " << e.name();
210 } 210​ }
211} 211​}
212 212​
213void AtticaProvider::loadEntryDetails(const KNS3::EntryInternal &entry) 213​void AtticaProvider::loadEntryDetails(const KNSCore::EntryInternal &entry)
214{ 214​{
215 ItemJob<Content> *job = m_provider.requestContent(entry.uniqueId()); 215​ ItemJob<Content> *job = m_provider.requestContent(entry.uniqueId());
216 connect(job, &BaseJob::finished, this, &AtticaProvider::detailsLoaded); 216​ connect(job, &BaseJob::finished, this, &AtticaProvider::detailsLoaded);
Context not available.
224 Content content = contentJob->result(); 224​ Content content = contentJob->result();
225 EntryInternal entry = entryFromAtticaContent(content); 225​ EntryInternal entry = entryFromAtticaContent(content);
226 emit entryDetailsLoaded(entry); 226​ emit entryDetailsLoaded(entry);
227 qCDebug(KNEWSTUFF) << "check update finished: " << entry.name(); 227​ qCDebug(KNEWSTUFFCORE) << "check update finished: " << entry.name();
228 } 228​ }
229 229​
230 if (m_updateJobs.remove(job) && m_updateJobs.isEmpty()) { 230​ if (m_updateJobs.remove(job) && m_updateJobs.isEmpty()) {
231 qCDebug(KNEWSTUFF) << "check update finished."; 231​ qCDebug(KNEWSTUFFCORE) << "check update finished.";
232 QList<EntryInternal> updatable; 232​ QList<EntryInternal> updatable;
233 foreach (const EntryInternal &entry, mCachedEntries) { 233​ foreach (const EntryInternal &entry, mCachedEntries) {
234 if (entry.status() == Entry::Updateable) { 234​ if (entry.status() == KNS3::Entry::Updateable) {
235 updatable.append(entry); 235​ updatable.append(entry);
236 } 236​ }
237 } 237​ }
Context not available.
254 entries.append(entryFromAtticaContent(content)); 254​ entries.append(entryFromAtticaContent(content));
255 } 255​ }
256 256​
257 qCDebug(KNEWSTUFF) << "loaded: " << mCurrentRequest.hashForRequest() << " count: " << entries.size(); 257​ qCDebug(KNEWSTUFFCORE) << "loaded: " << mCurrentRequest.hashForRequest() << " count: " << entries.size();
258 emit loadingFinished(mCurrentRequest, entries); 258​ emit loadingFinished(mCurrentRequest, entries);
259 mEntryJob = 0; 259​ mEntryJob = 0;
260} 260​}
Context not available.
273 } 273​ }
274} 274​}
275 275​
276void AtticaProvider::loadPayloadLink(const KNS3::EntryInternal &entry, int linkId) 276​void AtticaProvider::loadPayloadLink(const KNSCore::EntryInternal &entry, int linkId)
277{ 277​{
278 Attica::Content content = mCachedContent.value(entry.uniqueId()); 278​ Attica::Content content = mCachedContent.value(entry.uniqueId());
279 const DownloadDescription desc = content.downloadUrlDescription(linkId); 279​ const DownloadDescription desc = content.downloadUrlDescription(linkId);
Context not available.
285 mDownloadLinkJobs[job] = qMakePair(entry, linkId); 285​ mDownloadLinkJobs[job] = qMakePair(entry, linkId);
286 job->start(); 286​ job->start();
287 287​
288 qCDebug(KNEWSTUFF) << "get account balance"; 288​ qCDebug(KNEWSTUFFCORE) << "get account balance";
289 } else { 289​ } else {
290 ItemJob<DownloadItem> *job = m_provider.downloadLink(entry.uniqueId(), QString::number(linkId)); 290​ ItemJob<DownloadItem> *job = m_provider.downloadLink(entry.uniqueId(), QString::number(linkId));
291 connect(job, &BaseJob::finished, this, &AtticaProvider::downloadItemLoaded); 291​ connect(job, &BaseJob::finished, this, &AtticaProvider::downloadItemLoaded);
292 mDownloadLinkJobs[job] = qMakePair(entry, linkId); 292​ mDownloadLinkJobs[job] = qMakePair(entry, linkId);
293 job->start(); 293​ job->start();
294 294​
295 qCDebug(KNEWSTUFF) << " link for " << entry.uniqueId(); 295​ qCDebug(KNEWSTUFFCORE) << " link for " << entry.uniqueId();
296 } 296​ }
297} 297​}
298 298​
Context not available.
309 EntryInternal entry(pair.first); 309​ EntryInternal entry(pair.first);
310 Content content = mCachedContent.value(entry.uniqueId()); 310​ Content content = mCachedContent.value(entry.uniqueId());
311 if (content.downloadUrlDescription(pair.second).priceAmount() < item.balance()) { 311​ if (content.downloadUrlDescription(pair.second).priceAmount() < item.balance()) {
312 qCDebug(KNEWSTUFF) << "Your balance is greater than the price." 312​ qCDebug(KNEWSTUFFCORE) << "Your balance is greater than the price."
313 << content.downloadUrlDescription(pair.second).priceAmount() << " balance: " << item.balance(); 313​ << content.downloadUrlDescription(pair.second).priceAmount() << " balance: " << item.balance();
314 if (KMessageBox::questionYesNo(0, 314​ Question question;
315 i18nc("the price of a download item, parameter 1 is the currency, 2 is the price", 315​ question.setQuestion(i18nc("the price of a download item, parameter 1 is the currency, 2 is the price",
316 "This item costs %1 %2.\nDo you want to buy it?", 316​ "This item costs %1 %2.\nDo you want to buy it?",
317 item.currency(), content.downloadUrlDescription(pair.second).priceAmount() 317​ item.currency(), content.downloadUrlDescription(pair.second).priceAmount()
318 )) == KMessageBox::Yes) { 318​ ));
319​ if(question.ask() == Question::YesResponse) {
martUnsubmitted
Not Done

if i understood correctly both qwidget and qml implementation implement a questionmanager that would render the dialog or whatever...

I wouldn't know how to do it differently, but would be possible to make this asyncronous in some way?

mart: if i understood correctly both qwidget and qml implementation implement a questionmanager that…
leinirAuthorUnsubmitted
Not Done

i was racking my brains to try and come up with other ways of doing it and just couldn't figure anything out... Making it asynchronous would be lovely, i just don't see how to do so... which, obviously, sucks, but... yeah.

leinir: i was racking my brains to try and come up with other ways of doing it and just couldn't figure…
319 ItemJob<DownloadItem> *job = m_provider.downloadLink(entry.uniqueId(), QString::number(pair.second)); 320​ ItemJob<DownloadItem> *job = m_provider.downloadLink(entry.uniqueId(), QString::number(pair.second));
320 connect(job, &BaseJob::finished, this, &AtticaProvider::downloadItemLoaded); 321​ connect(job, &BaseJob::finished, this, &AtticaProvider::downloadItemLoaded);
321 connect(job, SIGNAL(jobStarted(QNetworkReply*)), SLOT(atticaJobStarted(QNetworkReply*))); 322​ connect(job, SIGNAL(jobStarted(QNetworkReply*)), SLOT(atticaJobStarted(QNetworkReply*)));
Context not available.
325 return; 326​ return;
326 } 327​ }
327 } else { 328​ } else {
328 qCDebug(KNEWSTUFF) << "You don't have enough money on your account!" 329​ qCDebug(KNEWSTUFFCORE) << "You don't have enough money on your account!"
329 << content.downloadUrlDescription(0).priceAmount() << " balance: " << item.balance(); 330​ << content.downloadUrlDescription(0).priceAmount() << " balance: " << item.balance();
330 KMessageBox::information(0, i18n("Your account balance is too low:\nYour balance: %1\nPrice: %2", 331​ emit signalInformation(i18n("Your account balance is too low:\nYour balance: %1\nPrice: %2",
331 item.balance(), content.downloadUrlDescription(0).priceAmount())); 332​ item.balance(), content.downloadUrlDescription(0).priceAmount()));
332 } 333​ }
333} 334​}
334 335​
Context not available.
350{ 351​{
351 EntryInternal::List entries; 352​ EntryInternal::List entries;
352 foreach (const EntryInternal &entry, mCachedEntries) { 353​ foreach (const EntryInternal &entry, mCachedEntries) {
353 if (entry.status() == Entry::Installed || entry.status() == Entry::Updateable) { 354​ if (entry.status() == KNS3::Entry::Installed || entry.status() == KNS3::Entry::Updateable) {
354 entries.append(entry); 355​ entries.append(entry);
355 } 356​ }
356 } 357​ }
Context not available.
394 if (job->metadata().error() == Attica::Metadata::NoError) { 395​ if (job->metadata().error() == Attica::Metadata::NoError) {
395 return true; 396​ return true;
396 } 397​ }
397 qCDebug(KNEWSTUFF) << "job error: " << job->metadata().error() << " status code: " << job->metadata().statusCode() << job->metadata().message(); 398​ qCDebug(KNEWSTUFFCORE) << "job error: " << job->metadata().error() << " status code: " << job->metadata().statusCode() << job->metadata().message();
398 399​
399 if (job->metadata().error() == Attica::Metadata::NetworkError) { 400​ if (job->metadata().error() == Attica::Metadata::NetworkError) {
400 emit signalError(i18n("Network error. (%1)", job->metadata().statusCode())); 401​ emit signalError(i18n("Network error. (%1)", job->metadata().statusCode()));
Context not available.
423 if (index >= 0) { 424​ if (index >= 0) {
424 EntryInternal &cacheEntry = mCachedEntries[index]; 425​ EntryInternal &cacheEntry = mCachedEntries[index];
425 // check if updateable 426​ // check if updateable
426 if (((cacheEntry.status() == Entry::Installed) || (cacheEntry.status() == Entry::Updateable)) && 427​ if (((cacheEntry.status() == KNS3::Entry::Installed) || (cacheEntry.status() == KNS3::Entry::Updateable)) &&
427 ((cacheEntry.version() != entry.version()) || (cacheEntry.releaseDate() != entry.releaseDate()))) { 428​ ((cacheEntry.version() != entry.version()) || (cacheEntry.releaseDate() != entry.releaseDate()))) {
428 cacheEntry.setStatus(Entry::Updateable); 429​ cacheEntry.setStatus(KNS3::Entry::Updateable);
429 cacheEntry.setUpdateVersion(entry.version()); 430​ cacheEntry.setUpdateVersion(entry.version());
430 cacheEntry.setUpdateReleaseDate(entry.releaseDate()); 431​ cacheEntry.setUpdateReleaseDate(entry.releaseDate());
431 } 432​ }
Context not available.
459 author.setHomepage(content.attribute(QStringLiteral("profilepage"))); 460​ author.setHomepage(content.attribute(QStringLiteral("profilepage")));
460 entry.setAuthor(author); 461​ entry.setAuthor(author);
461 462​
462 entry.setSource(KNS3::EntryInternal::Online); 463​ entry.setSource(EntryInternal::Online);
463 entry.setSummary(content.description()); 464​ entry.setSummary(content.description());
464 entry.setShortSummary(content.summary()); 465​ entry.setShortSummary(content.summary());
465 entry.setChangelog(content.changelog()); 466​ entry.setChangelog(content.changelog());
Context not available.