Function createStore

src/index.js:18–125

(worker)

 *	let store = createStore(new StoreWorker)
 */
export default function createStore(worker) {
	let listeners = [],
		state = {},
		sendQueue = [],
		initialized = false;
	
	function handleMessage({ data }) {
		if (typeof data!=='object') {}
		else if ('pop' in data) {
			if (data.length===1) {
				process(data[0]);
			}
			else {
				for (let i=0; i<data.length; i++) process(data[i]);
			}
		}
		else {
			process(data);
		}
	}

	function process(data) {
		let { type, overwrite, update, action, initial, partial } = data;

		if (type==='@@STATE') {
			if (partial===true) {
				update = applyUpdate(state, update);
				overwrite = true;
			}

			setState(update, overwrite===true, action, false);

			if (initial) {
				initialized = true;
				processSendQueue();
			}
		}
	}


	worker.addEventListener('message', handleMessage);

	function setState(update, overwrite, action, replicate) {
		let oldState = state;
		state = assign(overwrite ? {} : assign({}, state), update);
		if (replicate) {
			let update = overwrite ? state : diff(state, oldState);
			send({ type: '@@STATE', overwrite, update, action, partial: !overwrite });
			// send({ type: '@@STATE', overwrite, update, action });
		}
		let currentListeners = listeners;
		for (let i=0; i<currentListeners.length; i++) currentListeners[i](state, action);
	}

	function send(opts) {
		if (sendQueue.push(opts)===1) {
			setTimeout(processSendQueue);
		}