0xf8/pollymc
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Herp Derp Sync Durrrr

Browse Source
This commit is contained in:
Petr Mrazek 2013-07-05 00:57:20 +02:00
parent 8a66e61221
commit 030e03e134
1 changed files with 36 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

72
asset_test.cpp
View File

@ -77,6 +77,10 @@ public:
return QByteArray(); return QByteArray();
else return m_downloads[0]->data; else return m_downloads[0]->data;
} }
void add(DownloadablePtr dlable)
{
m_downloads.append(dlable);
}
private: private:
void emitStart() void emitStart()
{ {
@ -121,7 +125,10 @@ public:
void enqueue(DLJobPtr job) void enqueue(DLJobPtr job)
{ {
if(jobs.empty()) if(jobs.empty())
{
qDebug() << "NEXT JOB!";
QTimer::singleShot(0, this, SLOT(startNextJob())); QTimer::singleShot(0, this, SLOT(startNextJob()));
}
jobs.enqueue(job); jobs.enqueue(job);
} }
@ -145,14 +152,11 @@ public:
void startNextDownload() void startNextDownload()
{ {
// NO-OP... makes no sense, should be detected as error likely
if(!currentJob)
return;
// we finished the current job. Good job. // we finished the current job. Good job.
if(currentIndex >= currentJob->m_downloads.size()) if(currentIndex >= currentJob->m_downloads.size())
{ {
currentJob->emitFinish(); currentJob->emitFinish();
qDebug() << "NEXT JOB!";
QTimer::singleShot(0, this, SLOT(startNextJob())); QTimer::singleShot(0, this, SLOT(startNextJob()));
return; return;
} }
@ -191,7 +195,7 @@ public:
currentJob.clear(); currentJob.clear();
currentIndex = 0; currentIndex = 0;
QTimer::singleShot(0, this, SLOT(startNextJob())); QTimer::singleShot(0, this, SLOT(startNextJob()));
qDebug() << "NEXT JOB!";
return; return;
} }
if (!currentOutput.open(QIODevice::WriteOnly)) if (!currentOutput.open(QIODevice::WriteOnly))
@ -203,7 +207,7 @@ public:
currentJob.clear(); currentJob.clear();
currentIndex = 0; currentIndex = 0;
QTimer::singleShot(0, this, SLOT(startNextJob())); QTimer::singleShot(0, this, SLOT(startNextJob()));
qDebug() << "NEXT JOB!";
return; return;
} }
} }
@ -229,7 +233,7 @@ public:
dlable->status = Dl_Failed; dlable->status = Dl_Failed;
} }
void downloadFinished() void downloadFinished()
{ {
DownloadablePtr dlable = currentJob->m_downloads[currentIndex]; DownloadablePtr dlable = currentJob->m_downloads[currentIndex];
// if the download succeeded // if the download succeeded
@ -264,7 +268,7 @@ public:
} }
} }
} }
void downloadReadyRead() void downloadReadyRead()
{ {
DownloadablePtr dlable = currentJob->m_downloads[currentIndex]; DownloadablePtr dlable = currentJob->m_downloads[currentIndex];
if(dlable->m_save_to_file) if(dlable->m_save_to_file)
@ -300,9 +304,14 @@ class DlMachine : public QObject
{ {
Q_OBJECT Q_OBJECT
public slots: public slots:
void filesFinished()
{
qApp->quit();
}
void fetchFinished() void fetchFinished()
{ {
QByteArray ba = jptr->getFirstFileData(); QByteArray ba = index_job->getFirstFileData();
QString xmlErrorMsg; QString xmlErrorMsg;
QDomDocument doc; QDomDocument doc;
@ -314,6 +323,9 @@ public slots:
QRegExp etag_match(".*([a-f0-9]{32}).*"); QRegExp etag_match(".*([a-f0-9]{32}).*");
QDomNodeList contents = doc.elementsByTagName("Contents"); QDomNodeList contents = doc.elementsByTagName("Contents");
DLJob *job = new DLJob();
connect(job, SIGNAL(finished()), SLOT(filesFinished()));
for (int i = 0; i < contents.length(); i++) for (int i = 0; i < contents.length(); i++)
{ {
QDomElement element = contents.at(i).toElement(); QDomElement element = contents.at(i).toElement();
@ -338,49 +350,34 @@ public slots:
if (sizeStr == "0") if (sizeStr == "0")
continue; continue;
//TODO:Need to get ETag keys to be valid strings not "" "" QString trimmedEtag = etagStr.remove('"');
QString prefix("http://s3.amazonaws.com/Minecraft.Resources/");
QString fprefix("assets/");
Downloadable * d = new Downloadable(QUrl(prefix + keyStr),fprefix + keyStr, trimmedEtag);
qDebug() << keyStr << " " << lastModStr << " " << etagStr << sizeStr; job->add(DownloadablePtr(d));
//qDebug() << keyStr << " " << lastModStr << " " << etagStr << sizeStr;
} }
files_job.reset(job);
dl.enqueue(files_job);
} }
void fetchStarted() void fetchStarted()
{ {
qDebug() << "Started downloading!"; qDebug() << "Started downloading!";
} }
void googleFinished()
{
qDebug() << "yayayay google!";
qApp->quit();
}
void sadPanda()
{
qDebug() << "sad panda is sad :<";
qApp->quit();
}
public: public:
void start() void start()
{ {
DLJob *gjob = new DLJob();
gjob->append(QUrl("https://www.google.cz/"), "foo/bar/baz/index.html");
gjob->append(QUrl("https://www.google.cz/"), "foo/bar/baz/lol.html");
gjob->append(QUrl("https://www.google.cz/"), "foo/bar/baz/lolol.html");
connect(gjob, SIGNAL(started()), SLOT(fetchStarted()));
connect(gjob, SIGNAL(failed()), SLOT(sadPanda()));
connect(gjob, SIGNAL(finished()), SLOT(googleFinished()));
google_job_ptr.reset(gjob);
DLJob *job = new DLJob(QUrl("http://s3.amazonaws.com/Minecraft.Resources/")); DLJob *job = new DLJob(QUrl("http://s3.amazonaws.com/Minecraft.Resources/"));
connect(job, SIGNAL(finished()), SLOT(fetchFinished())); connect(job, SIGNAL(finished()), SLOT(fetchFinished()));
connect(job, SIGNAL(started()), SLOT(fetchStarted())); connect(job, SIGNAL(started()), SLOT(fetchStarted()));
jptr.reset(job); index_job.reset(job);
dl.enqueue(jptr); dl.enqueue(index_job);
dl.enqueue(google_job_ptr);
} }
Downloader dl; Downloader dl;
DLJobPtr jptr; DLJobPtr index_job;
DLJobPtr google_job_ptr; DLJobPtr files_job;
}; };
int main(int argc, char *argv[]) int main(int argc, char *argv[])
@ -392,4 +389,5 @@ int main(int argc, char *argv[])
return app.exec(); return app.exec();
} }
#include "asset_test.moc" #include "asset_test.moc"