package jadx.gui.jobs;

import java.util.concurrent.Future;

import javax.swing.JOptionPane;
import javax.swing.SwingUtilities;
import javax.swing.SwingWorker;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import jadx.gui.ui.ProgressPanel;
import jadx.gui.utils.CacheObject;
import jadx.gui.utils.NLS;
import jadx.gui.utils.UiUtils;
import jadx.gui.utils.search.TextSearchIndex;

/**
 * Deprecated. Use {@link BackgroundExecutor} instead.
 */
public class BackgroundWorker extends SwingWorker<Void, Void> {
	private static final Logger LOG = LoggerFactory.getLogger(BackgroundWorker.class);

	private final CacheObject cache;
	private final ProgressPanel progressPane;

	public BackgroundWorker(CacheObject cacheObject, ProgressPanel progressPane) {
		this.cache = cacheObject;
		this.progressPane = progressPane;
	}

	public void exec() {
		if (isDone()) {
			return;
		}
		SwingUtilities.invokeLater(() -> progressPane.setVisible(true));
		addPropertyChangeListener(progressPane);
		execute();
	}

	public void stop() {
		if (isDone()) {
			return;
		}
		LOG.debug("Canceling background jobs ...");
		cancel(false);
	}

	@Override
	protected Void doInBackground() {
		try {
			System.gc();
			LOG.debug("Memory usage: Before decompile: {}", UiUtils.memoryInfo());
			runJob(cache.getDecompileJob());
			LOG.debug("Memory usage: After decompile: {}", UiUtils.memoryInfo());

			if (cache.getUnloadJob() != null) {
				LOG.info("Memory usage: Before unload: {}", UiUtils.memoryInfo());
				long start = System.nanoTime();
				runJob(cache.getUnloadJob());
				cache.setUnloadJob(null);
				LOG.info("Memory usage: After unload: {}, unload took {} ms", UiUtils.memoryInfo(), (System.nanoTime() - start) / 1000000);
			}

			if (cache.getRefreshJob() != null) {
				LOG.info("Memory usage: Before refresh: {}", UiUtils.memoryInfo());
				long start = System.nanoTime();
				runJob(cache.getRefreshJob());
				cache.setRefreshJob(null);
				LOG.info("Memory usage: After refresh: {}, refresh took {} ms", UiUtils.memoryInfo(),
						(System.nanoTime() - start) / 1000000);
			}

			LOG.debug("Memory usage: Before index: {}", UiUtils.memoryInfo());
			runJob(cache.getIndexJob());
			LOG.debug("Memory usage: After index: {}", UiUtils.memoryInfo());

			System.gc();
			LOG.debug("Memory usage: After gc: {}", UiUtils.memoryInfo());

			TextSearchIndex searchIndex = cache.getTextIndex();
			if (searchIndex != null && searchIndex.getSkippedCount() > 0) {
				LOG.warn("Indexing of some classes skipped, count: {}, low memory: {}",
						searchIndex.getSkippedCount(), UiUtils.memoryInfo());
				String msg = NLS.str("message.indexingClassesSkipped", searchIndex.getSkippedCount());
				JOptionPane.showMessageDialog(null, msg);
			}
		} catch (Exception e) {
			LOG.error("Exception in background worker", e);
		}
		return null;
	}

	private void runJob(BackgroundJob job) {
		if (isCancelled() || job == null) {
			return;
		}
		progressPane.changeLabel(this, job.getInfoString());
		Future<Boolean> future = job.process();
		while (!future.isDone()) {
			try {
				setProgress(job.getProgress());
				if (isCancelled()) {
					future.cancel(false);
				}
				Thread.sleep(500);
			} catch (Exception e) {
				LOG.error("Background worker error", e);
			}
		}
	}

	@Override
	protected void done() {
		progressPane.setVisible(false);
	}
}