DbAndBinaryJob.java

package com.proalpha.pds.gitutils.external;
 
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
 
import org.eclipse.core.resources.IProject;
import org.eclipse.core.runtime.IProgressMonitor;
import org.eclipse.core.runtime.IStatus;
import org.eclipse.core.runtime.Status;
import org.eclipse.core.runtime.SubMonitor;
import org.eclipse.core.runtime.jobs.Job;
import org.eclipse.egit.core.internal.util.ProjectUtil;
import org.eclipse.egit.ui.JobFamilies;
import org.eclipse.jgit.lib.Repository;
import org.eclipse.ui.PlatformUI;
 
import com.proalpha.pds.gitutils.mylyn.ActionResult;
import com.proalpha.pds.gitutils.mylyn.ActionResultDialog;
import com.proalpha.pds.gitutils.mylyn.ReconcileActionSettings;
import com.proalpha.pds.paconnector.Activator;
 
@SuppressWarnings("restriction")
public class DbAndBinaryJob extends Job {
 
    private final DbAndBinaryOperation operation;
    private final ReconcileActionSettings recoSettings;
    private final Repository repository;
 
    public DbAndBinaryJob(Repository repository, ReconcileActionSettings recoSettings) {
        super("Running database reconcile and update of binaries");
        this.operation = new DbAndBinaryOperation(repository, recoSettings);
        this.recoSettings = recoSettings;
        this.repository = repository;
    }
 
    @Override
    protected IStatus run(IProgressMonitor monitor) {
        SubMonitor progressMonitor = SubMonitor.convert(monitor, "checking for relevant updates on current branch...",
                1);
 
        // collect all affected projects which include the repository
        IProject[] projects = ProjectUtil.getProjects(repository);
        ArrayList<IProject> openedProjects = new ArrayList<>(Arrays.asList(projects));
        SubMonitor subMonitorArtifacts = SubMonitor.convert(monitor, "database reconcile and artifact update",
                recoSettings.getPaUpdateStages().size());
 
        if (recoSettings.isLoadDf())
            Activator.getDefault().getProjectManager().closeProjects(openedProjects, subMonitorArtifacts);
 
        operation.setProgressMonitor(progressMonitor);
        operation.execute();
 
        if (recoSettings.isLoadDf())
            Activator.getDefault().getProjectManager().openProjects(openedProjects, subMonitorArtifacts);
        showResultDialog(operation.getActionResults());
        return Status.OK_STATUS;
 
    }
 
    @Override
    public boolean belongsTo(Object family) {
        if (JobFamilies.CHECKOUT.equals(family))
            return true;
        return super.belongsTo(family);
    }
 
    private void showResultDialog(List<ActionResult> results) {
        PlatformUI.getWorkbench().getDisplay().asyncExec(
                () -> new ActionResultDialog(PlatformUI.getWorkbench().getActiveWorkbenchWindow().getShell(), results)
                        .open());
    }
 
}