Method runTask

MediaLibrary/animescrapingtask.cpp:15–108

}

TaskStatus AnimeScrapingTask::runTask()
{
    auto script = GlobalObjects::scriptManager->getScript(curMatch.scriptId).staticCast<LibraryScript>();
    if (!script)
    {
        Logger::logger()->log(Logger::Script, QString("Match [%1] has Invalid ScriptId: %2").arg(curMatch.name, curMatch.scriptId));
        return TaskStatus::Failed;
    }
    AnimeLite ab;
    ab.name = curMatch.name;
    ab.scriptId = curMatch.scriptId;
    ab.scriptData = curMatch.scriptData;

    Anime *nAnime = new Anime;
    ScriptState state;
    int waitTimes = 0;
    const int maxWaitTimes = 10;
    setInfo(tr("Fetching Anime Info[%1]...").arg(curMatch.name), NM_HIDE);
    while (true)
    {
        if (_cancelFlag)
        {
            setInfo(tr("Task Canceled"), NM_ERROR | NM_HIDE);
            delete nAnime;
            return TaskStatus::Cancelled;
        }
        state = script->getDetail(ab, nAnime);
        if (state.isBusy())
        {
            if (waitTimes > maxWaitTimes)
            {
                delete nAnime;
                Logger::logger()->log(Logger::Script, QString("Match [%1] ScriptId: %2 wait timeout").arg(curMatch.name, curMatch.scriptId));
                return TaskStatus::Failed;
            }
            ++waitTimes;
            QThread::sleep(6);
        }
        else
        {
            break;
        }
    }
    if (!state)
    {
        delete nAnime;
        Logger::logger()->log(Logger::Script, QString("Match [%1:%2] ScriptId: %3 failed: %4").arg(curMatch.name, curMatch.ep.toString(), curMatch.scriptId, state.info));
        return TaskStatus::Failed;
    }

    QString animeName = AnimeWorker::instance()->addAnime(curAnime, nAnime);
    Anime *tAnime = AnimeWorker::instance()->getAnime(animeName);
    if (!tAnime)
    {
        setInfo(tr("Fetching Tags[%1] Failed").arg(animeName), NM_ERROR | NM_HIDE);
        return TaskStatus::Finished;
    }