natxocc/sigpro
1
1
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

ok

Browse Source
This commit is contained in:
Natxo
2026-04-08 00:25:48 +02:00
parent 3d2aca2b1f
commit d632526597
1 changed files with 210 additions and 219 deletions
Download Patch File Download Diff File Expand all files Collapse all files

245
sigwork.js
View File

@@ -1,66 +1,79 @@
// ---------------------------
// SigPro v2
// ---------------------------
/*
* SigPro
*/
// --- Scheduler ---
// --- Scheduler (Ciclo Completo) ---
let isScheduled = false;
const queue = new Set();
const flushQueue = () => {
const tick = () => {
while (queue.size) {
const runs = [...queue];
queue.clear();
runs.forEach(fn => fn());
}
isScheduled = false;
};
// --- Core State & Ownership ---
// --- Estado Global y Contexto ---
let activeEffect = null;
let currentOwner = null;
let currentContext = null;
const nodeContexts = new WeakMap();
// --- Security ---
// --- Seguridad ---
const DANGEROUS = /^(javascript|data|vbscript):/i;
const sanitize = v => DANGEROUS.test(String(v)) ? '#' : v;
// --- Effect System ---
export const Effect = (fn) => {
const owner = currentOwner;
// --- Sistema de Efectos con Scope ---
export const Effect = (fn, is_scope = false) => {
let cleanup = null;
const runner = () => {
cleanup();
const prevOwner = currentOwner;
stop();
const prevContext = currentContext;
const prevEffect = activeEffect;
currentOwner = owner;
activeEffect = runner;
runner.cleanupFns = [];
try { fn(); }
finally { currentOwner = prevOwner; activeEffect = prevEffect; }
};
const cleanup = () => {
runner.deps?.forEach(dep => dep.delete(runner));
runner.cleanupFns?.forEach(f => f());
runner.deps?.clear();
};
runner.deps = new Set();
runner.cleanupFns = [];
owner?.cleanups.add(cleanup);
runner();
return cleanup;
cleanup = fn();
activeEffect = prevEffect;
currentContext = prevContext;
};
// --- Signals ---
const stop = () => {
runner.deps?.forEach(subs => subs.delete(runner));
runner.deps?.clear();
if (typeof cleanup === 'function') cleanup();
runner.cleanups?.forEach(f => f());
runner.cleanups = [];
};
runner.deps = new Set();
runner.cleanups = [];
if (activeEffect) activeEffect.cleanups.push(stop);
else if (currentContext) currentContext.cleanups.add(stop);
runner();
return stop;
};
// --- Signals & Reactividad ---
export const Signal = (value) => {
const subs = new Set();
return {
_isSig: true,
get value() {
if (activeEffect) { subs.add(activeEffect); activeEffect.deps.add(subs); }
if (activeEffect) {
subs.add(activeEffect);
activeEffect.deps.add(subs);
}
return value;
},
set value(v) {
if (v === value) return;
value = v;
subs.forEach(fn => queue.add(fn));
if (!isScheduled) { isScheduled = true; queueMicrotask(flushQueue); }
if (!isScheduled) {
isScheduled = true;
queueMicrotask(tick);
}
}
};
};
@@ -74,73 +87,11 @@ export const Computed = (fn) => {
export const Storage = (key, val) => {
const saved = localStorage.getItem(key);
const s = Signal(saved !== null ? JSON.parse(saved) : val);
Effect(() => {
localStorage.setItem(key, JSON.stringify(s.value));
});
Effect(() => localStorage.setItem(key, JSON.stringify(s.value)));
return s;
};
const reactiveCache = new WeakMap();
export const Reactive = (obj) => {
if (!obj || typeof obj !== 'object') return obj;
if (reactiveCache.has(obj)) return reactiveCache.get(obj);
const subs = {};
const proxy = new Proxy(obj, {
get(t, k) {
if (!subs[k]) subs[k] = new Set();
if (activeEffect) { subs[k].add(activeEffect); activeEffect.deps.add(subs[k]); }
const val = t[k];
return val && typeof val === 'object' ? Reactive(val) : val;
},
set(t, k, v) {
if (t[k] === v) return true;
t[k] = v;
subs[k]?.forEach(fn => queue.add(fn));
if (!isScheduled) { isScheduled = true; queueMicrotask(flushQueue); }
return true;
}
});
reactiveCache.set(obj, proxy);
return proxy;
};
// --- Watch with cleanup ---
export const Watch = (source, cb, options = {}) => {
let oldValue, firstRun = true, lastCleanup = null;
const stop = Effect(() => {
const newValue = typeof source === 'function' ? source() : source.value;
if (!firstRun || options.immediate) {
if (lastCleanup) { lastCleanup(); lastCleanup = null; }
const prevEffect = activeEffect;
activeEffect = null;
try { cb(newValue, oldValue, (fn) => { lastCleanup = fn; }); }
finally { activeEffect = prevEffect; }
}
oldValue = newValue;
firstRun = false;
});
return () => { stop(); if (lastCleanup) lastCleanup(); };
};
// --- Lifecycle ---
export const onMount = (fn) => currentContext?.mount.push(fn);
export const onUnmount = (fn) => currentContext?.unmount.push(fn);
export const Share = (key, value) => { if (currentContext) currentContext.Share[key] = value; };
export const Use = (key, def) => {
let ctx = currentContext;
while (ctx) {
if (ctx.Share[key] !== undefined) return ctx.Share[key];
ctx = ctx.parent;
}
return def;
};
// --- Renderer ---
// --- Renderer Core (Diffing Avanzado y SVG) ---
const isNode = v => v instanceof Node;
export const destroy = (node) => {
@@ -158,82 +109,113 @@ export const destroy = (node) => {
const append = (parent, child) => {
if (child == null) return;
if (typeof child === 'function') {
const marker = document.createTextNode('');
parent.appendChild(marker);
const anchor = document.createTextNode('');
parent.appendChild(anchor);
let nodes = [];
Effect(() => {
const raw = child();
const next = [raw].flat(Infinity)
.map(n => typeof n === 'function' ? n() : n)
.flat(Infinity)
.filter(n => n != null)
.map(n => isNode(n) ? n : document.createTextNode(String(n)));
const nextSet = new Set(next);
nodes.forEach(n => { if (!nextSet.has(n)) destroy(n); });
next.forEach((n, i) => {
if (nodes[i] !== n) marker.parentNode.insertBefore(n, nodes[i] || marker);
// Diffing Bidireccional (Estilo Sigwork)
const oldNodes = nodes.filter(n => {
const keep = next.includes(n);
if (!keep) destroy(n);
return keep;
});
const oldIdxs = new Map(oldNodes.map((n, i) => [n, i]));
let p = oldNodes.length - 1;
for (let i = next.length - 1; i >= 0; i--) {
const node = next[i];
const ref = next[i + 1] || anchor;
if (!oldIdxs.has(node)) {
parent.insertBefore(node, ref);
} else if (oldNodes[p] !== node) {
parent.insertBefore(node, ref);
} else {
p--;
}
}
nodes = next;
});
}, true);
} else {
parent.appendChild(isNode(child) ? child : document.createTextNode(String(child)));
}
};
export const h = (tag, props = {}, ...children) => {
props = props || {};
const flatChildren = children.flat(Infinity);
// 4. Fragments (Tag nulo o vacío)
if (!tag) return () => flatChildren;
// 1. Componentes (Funciones)
if (typeof tag === 'function') {
const context = { mount: [], unmount: [], Share: {}, parent: currentContext, cleanups: new Set() };
const prevCtx = currentContext;
const context = { mount: [], unmount: [], Share: {}, parent: prevCtx, cleanups: new Set() };
currentContext = context;
const prevOwner = currentOwner;
currentOwner = context;
const el = tag(props, { children: children.flat(Infinity) });
const el = tag(props, { children: flatChildren });
if (isNode(el)) nodeContexts.set(el, context);
currentContext = prevCtx;
currentOwner = prevOwner;
queueMicrotask(() => context.mount.forEach(fn => fn()));
return el;
}
const el = document.createElement(tag);
// 1. Soporte SVG
let el;
const isSVG = tag === 'svg' || tag === 'path' || tag === 'circle' || tag === 'rect' || tag === 'g';
if (isSVG) {
el = document.createElementNS("http://www.w3.org/2000/svg", tag);
} else {
el = document.createElement(tag);
}
for (const key in props) {
const val = props[key];
if (key.startsWith('on')) {
el.addEventListener(key.slice(2).toLowerCase(), val);
}
// 2. Soporte para Refs
else if (key === 'ref') {
if (typeof val === 'function') val(el);
else if (val && val._isSig) val.value = el;
}
else if (typeof val === 'function' || (val && val._isSig)) {
Effect(() => {
const v = typeof val === 'function' ? val() : val.value;
el[key] = (key === 'href' || key === 'src') ? sanitize(v) : v;
const attr = (key === 'href' || key === 'src') ? sanitize(v) : v;
if (!isSVG && key in el) el[key] = attr; else el.setAttribute(key, attr);
});
} else {
el[key] = (key === 'href' || key === 'src') ? sanitize(val) : val;
const attr = (key === 'href' || key === 'src') ? sanitize(val) : val;
if (!isSVG && key in el) el[key] = attr; else el.setAttribute(key, attr);
}
}
children.flat(Infinity).forEach(c => append(el, c));
flatChildren.forEach(c => append(el, c));
return el;
};
// --- Conditionals & Loops ---
// --- Helpers ---
export const If = (cond, a, b) => () => cond() ? a() : (b ? b() : null);
export const For = (list, key, render) => {
let cache = new Map();
return () => {
const items = list();
const items = typeof list === 'function' ? list() : list.value;
const nextCache = new Map();
const nodes = items.map((item, i) => {
const k = key ? key(item, i) : i;
const k = key ? key(item, i) : (item.id || i);
let node = cache.get(k);
if (!node) node = render(item, i);
nextCache.set(k, node);
return node;
});
cache.forEach((n, k) => { if (!nextCache.has(k)) destroy(n); });
cache = nextCache;
return nodes;
};
@@ -243,20 +225,19 @@ export const For = (list, key, render) => {
export const Router = (routes) => {
const path = Signal(window.location.hash.replace(/^#/, '') || '/');
window.addEventListener('hashchange', () => path.value = window.location.hash.replace(/^#/, '') || '/');
let view = null;
const outlet = h('div', { class: 'router-outlet' });
let currentView = null;
Effect(() => {
const route = routes.find(r => r.path === path.value) || routes.find(r => r.path === '*');
if (view) destroy(view);
if (currentView) destroy(currentView);
if (route) {
view = route.component();
outlet.appendChild(view);
currentView = route.component();
outlet.appendChild(currentView);
}
});
return outlet;
};
// --- Mounting ---
export const Mount = (root, target) => {
const container = typeof target === 'string' ? document.querySelector(target) : target;
const el = typeof root === 'function' ? root() : root;
@@ -264,6 +245,16 @@ export const Mount = (root, target) => {
return () => destroy(el);
};
// --- Export API ---
export default { Signal, Computed, Storage, Effect, Reactive, Watch, h, If, For, Router, Mount, Share, Use, onMount, onUnmount };
export { h as jsx, h as jsxs, h as Fragment };
export const onMount = (fn) => currentContext?.mount.push(fn);
export const onUnmount = (fn) => currentContext?.unmount.push(fn);
export const Share = (key, value) => { if (currentContext) currentContext.Share[key] = value; };
export const Use = (key, def) => {
let ctx = currentContext;
while (ctx) {
if (ctx.Share[key] !== undefined) return ctx.Share[key];
ctx = ctx.parent;
}
return def;
};
export default { Signal, Computed, Storage, Effect, h, If, For, Router, Mount, Share, Use, onMount, onUnmount };