deka-dom-el/examples/components/3rd-party.js

import { style, el, O, isObservable } from '../exports.js';
const className= style.host(thirdParty).css`
	:host {
		color: green;
	}
`;

const store_adapter= {
	read(){ return (new URL(location)).searchParams; },
	write(data){ console.log(data); history.replaceState("", "", "?"+(new URLSearchParams(data)).toString()); }
};
export function thirdParty(){
	const store= O({
		value: O("initial")
	}, {
		set(key, value){
			const p=  this.value[key] || O();
			p(value);
			this.value[key]= p;
		}
	});
	// Array.from((new URL(location)).searchParams.entries())
	// 	.forEach(([ key, value ])=> O.action(store, "set", key, value));
	// O.on(store, data=> history.replaceState("", "", "?"+(new URLSearchParams(JSON.parse(JSON.stringify(data)))).toString()));
	useStore(store_adapter, {
		onread(data){
			Array.from(data.entries())
				.forEach(([ key, value ])=> O.action(store, "set", key, value));
			return store;
		}
	})();
	return el("input", {
		className,
		value: store().value(),
		type: "text",
		onchange: ev=> O.action(store, "set", "value", ev.target.value)
	});
}

function useStore(adapter_in, { onread, onbeforewrite }= {}){
	const adapter= typeof adapter_in === "function" ? { read: adapter_in } : adapter_in;
	if(!onread) onread= O;
	if(!onbeforewrite) onbeforewrite= data=> JSON.parse(JSON.stringify(data));
	return function useStoreInner(data_read){
		const observable= onread(adapter.read(data_read)); //TODO OK as synchronous
		if(adapter.write && isObservable(observable))
			O.on(observable, data=> adapter.write(onbeforewrite(data)));
		return observable;
	};
}