.-.-.-.-.-

import PullOperation from "./pulloperation";

/**
 * @class PullQueue
 */

export default class PullQueue
{
	#queue: Map<number>;
	#grid: BX.CRM.Kanban.Grid;
	#isProgress: boolean;
	#isFreeze: boolean;
	loadItemsTimer;

constructor(grid: BX.CRM.Kanban.Grid): void
	{
		this.#grid = grid;
		this.#queue = new Map();
		this.#isProgress = false;
		this.#isFreeze = false;
		this.loadItemsTimer = null;
	}

loadItem(isForce: boolean): void
	{
		if (this.loadItemsTimer)
		{
			return;
		}

this.loadItemsTimer = setTimeout(
			() => {
				isForce = (isForce || false);
				if (this.#isProgress && !isForce)
				{
					this.loadItemsTimer = null;
					return;
				}

if (document.hidden || this.isOverflow() || this.isFreezed())
				{
					this.loadItemsTimer = null;
					return;
				}

const items = this.popAllAsArray();
				if (items.length)
				{
					const ids = [];
					items.map(item => {
						ids.push(item.id);
						const data = item.data;
						const operation = PullOperation.createInstance({
							grid: this.#grid,
							itemId: data.id,
							action: data.action,
							actionParams: data.actionParams,
						});
						operation.execute();
					});

this.#isProgress = true;
					this.
						#grid
						.loadNew(ids, false, true, true)
						.then(loadNextOnSuccess, doNothingOnError)
					;
				}
			},
			5000
		);
	}

push(id: number, item: string): PullQueue
	{
		id = parseInt(id, 10);
		if (this.has(id))
		{
			this.delete(id);
		}

this.#queue.set(id, item);
		return this;
	}

popAllAsArray()
	{
		const items = Array.from(this.#queue, ([id, data]) => ({id, data}));
		this.#queue.clear();
		return items;
	}

popBatch(count: number)
	{
		if (count <= 0)
		{
			return [];
		}

const results = [];
		for (let i=0; i < count; i++)
		{
			const item = this.pop();

if (!item)
			{
				break;
			}

results.push(item);
		}

return results;
	}

pop(): number
	{
		const items = this.#queue.entries();
		const first = items.next();
		if (first.value)
		{
			this.#queue.delete(first.value[0]);
		}
		return first.value;
	}

peek(): number|null
	{
		const items = this.#queue.entries();
		const first = items.next();
		return (first.value ?? null);
	}

delete(id: number): void
	{
		this.#queue.delete(id);
	}

has(id: number): boolean
	{
		return this.#queue.has(id);
	}

clear(): void
	{
		this.#queue.clear();
	}

isOverflow(): boolean
	{
		const MAX_PENDING_ITEMS = 30;
		return (this.#queue.size > MAX_PENDING_ITEMS);
	}

freeze(): void
	{
		this.#isFreeze = true;
	}

unfreeze(): void
	{
		this.#isFreeze = false;
	}

isFreezed(): boolean
	{
		return this.#isFreeze;
	}
}

/var/www/axolotl/data/www/axolotl.ru/www/bitrix/js/crm/kanban/js/../src/pullqueue.js