/*
 * Copyright 2011-2015, Haiku, Inc. All Rights Reserved.
 * Distributed under the terms of the MIT License.
 *
 * Authors:
 *              Oliver Tappe <zooey@hirschkaefer.de>
 */


#include <package/Request.h>

#include <new>

#include <JobQueue.h>

#include <package/Context.h>


namespace BPackageKit {


using BSupportKit::BPrivate::JobQueue;


BRequest::BRequest(const BContext& context)
        :
        fContext(context),
        fJobQueue(new (std::nothrow) JobQueue())
{
        fInitStatus = fJobQueue == NULL ? B_NO_MEMORY : B_OK;
}


BRequest::~BRequest()
{
}


status_t
BRequest::InitCheck() const
{
        return fInitStatus;
}


BSupportKit::BJob*
BRequest::PopRunnableJob()
{
        if (fJobQueue == NULL)
                return NULL;

        return fJobQueue->Pop();
}


status_t
BRequest::Process(bool failIfCanceledOnly)
{
        status_t error = InitCheck();
        if (error != B_OK)
                return error;

        error = CreateInitialJobs();
        if (error != B_OK)
                return error;

        while (BSupportKit::BJob* job = PopRunnableJob()) {
                error = job->Run();
                delete job;
                if (error != B_OK) {
                        if (!failIfCanceledOnly || error == B_CANCELED)
                                return error;
                }
        }

        return B_OK;
}


status_t
BRequest::QueueJob(BSupportKit::BJob* job)
{
        if (fJobQueue == NULL)
                return B_NO_INIT;

        job->AddStateListener(this);
        job->AddStateListener(&fContext.JobStateListener());

        return fJobQueue->AddJob(job);
}


}       // namespace BPackageKit