D-Net

package eu.dnetlib.msro.worker.nodes;

import eu.dnetlib.common.ifaces.ProgressProvider;

public abstract class ProgressBlackboardJobNode<T extends ProgressProvider> extends BlackboardJobNode<T> implements ProgressJobNode {

	private boolean progressInaccurate = true;

	private int progressTotal = 0;

	private int progressPosition = 0;

	@Override

	public void onSuccess(final T t) {

		super.onSuccess(t);

		this.progressInaccurate = t.isProgressInaccurate();

		this.progressTotal = t.getProgressTotal();

		this.progressPosition = t.getProgressPosition();

	}

	@Override

	public void onOngoing(final T t) {

		super.onOngoing(t);

		this.progressInaccurate = t.isProgressInaccurate();

		this.progressTotal = t.getProgressTotal();

		this.progressPosition = t.getProgressPosition();

	}

	@Override

	public ProgressProvider getProgressProvider() {

		return new ProgressProvider() {

			@Override

			public int getProgressTotal() {

				return progressTotal;

			}

			@Override

			public int getProgressPosition() {

				return progressPosition;

			}

			@Override

			public boolean isProgressInaccurate() {

				return progressInaccurate;

			}

		};

	}

}