2b:null 2c:["$","title",null,{"children":"GraphWorld | Bob Kerns | Observable"}] 31:T1012,chart = { const P = graphParams; try { const graph = mutable graph = view.graph(); const nodes = graph.nodes; const links = graph.links; const svg = d3.create("svg") .attr("viewBox", [0, 0, width, height]); const border = svg.append('rect') .attr("stroke", "#000000") .attr("fill", '#fff0f0') .attr("stroke-opacity", 1.0) .attr("stroke-width", 2.0) .attr('x', 0) .attr('y', 0) .attr('width', width) .attr('height', height); const defs = svg.append("defs"); addDropShadow(defs, "dropShadow", P.nodes.dropShadow); addDropShadow(defs, "dropShadowText", P.nodes.text.dropShadow); const link = svg.append("g") .attr("stroke", "#fff") .attr("stroke-opacity", P.links.opacity || 1.0) .selectAll("line") .data(links) .join("line") .attr("stroke", l => l.style.background) .attr("stroke-width", d => d.style.thickness || P.lines.thickness || 1); const node = svg.append("svg") .selectAll("rect") .data(nodes) .join("svg"); const layout = new DynamicLayout({link: link, node: node, x: 0, y: 0, width: width, height: height}, P.layout); node .append("rect") .attr("filter", "url(#dropShadow)") .attr("rx", P.nodes.corners.x) .attr("ry", P.nodes.corners.y) .attr("width", 70) .attr("height", 20) .attr("fill", d => d.style.background) .attr("stroke", d => d.style.foreground) .attr("stroke-width", d => d.style.thickness) .attr("opacity", P.nodes.opacity); const text = node.append("text") .attr("filter", "url(#dropShadowText)") .attr("text-anchor", "middle") .attr("font-size", P.nodes.text.fontSize) .attr("stroke", d => d.style.foreground) .attr("stroke-width", P.nodes.text.thickness) .text(d => d.name || d.id); const ready = Promises.delay(0) .then(() => new Promise(done => node .each(function doGetBBox(d) { const top = d3.select(this); top .selectAll('text') .each(function doGetBBox2() { const text = d3.select(this); const bbox = this.getBBox(); const width = d.width = bbox.width + + P.nodes.margin.left + P.nodes.margin.right; const height = d.height = bbox.height + P.nodes.margin.top + P.nodes.margin.bottom; const centerx = d.centerx = width / 2; const centery = d.centery = height / 2; top .attr('width', width + P.nodes.dropShadow.x + 2) .attr('height', height + P.nodes.dropShadow.y + 2) .selectAll('rect') .attr('width', width) .attr('height', height); text .attr("x", centerx) .attr("y", centery + P.nodes.textLineOffset); }); }) .call(done) )); node.append("title") .text(d => d.name || d.id); node.on("mouseover", function () { d3.select(this).selectAll('rect') .attr("stroke-width", 3) .attr("stroke", "#000000"); }) .on("mouseout", function () { d3.select(this).selectAll('rect') .attr("stroke", d => d.style.foreground) .attr("stroke-width", P.nodes.text.thickness); }) .on("click", function () { mutable selected = d3.select(this).data(); }); link.on("mouseover", function () { d3.select(this).selectAll('line') .attr("stroke-width", 3) .attr("stroke", "#000000"); }) .on("mouseout", function () { d3.select(this).selectAll('rect') .attr("stroke", d => d.style.background) .attr("stroke-width", d => d.style.thickness || P.lines.thickness || 1); }) .on("click", function () { mutable selected = d3.select(this).data(); }); ready.then(() => { const simulation = layout.layout(graph); invalidation.then(() => simulation.stop()); }); return svg.node(); } catch (e) { return e; } }32:T6f7,class Layout { constructor(viewport, spec) { const id = IdGenerator.id(this.constructor.name); Layout.id = (Layout.id || 0) + 1; this.viewport = viewport; this.link = viewport.link; this.node = viewport.node; this.width = viewport.width; this.height = viewport.height; this.spec = spec; this.startTime = 0; this.iterationCount = 0; this.runtime = 0; this.name = `${id} ${viewport.x},${viewport.y} ${viewport.width}x${viewport.height}`; this.status = 'idle'; this.monitor = layoutMonitor.add(new LayoutMonitor()); } layout(graph) { this.startTime = Date.now(); this.iterationCount = 0; this.runtime = 0; this.status = 'running'; try { const value = this.doLayout(graph); return value; } catch (e) { this.status = 'error'; this.error = e; } finally { this.updateTime(); this.layoutExit(); } } layoutExit() { this.layoutComplete(); } layoutComplete() { this.status = 'done'; this.updateTime(); Promises.delay(10) .then(() => this.monitor.end()); } tick() { this.iterationCount++; this.updateTime(); } updateTime() { this.runtime = Date.now() - this.startTime; this.monitor.notify(this); } getStartTime() { const pad2 = s => `0${s}`.slice(-2); const pad3 = s => `00${s}`.slice(-3); const t = new Date(this.startTime); const year = t.getFullYear(); const month = pad2(t.getMonth() + 1); const day = pad2(t.getDate()); const hour = pad2(t.getHours()); const minute = pad2(t.getMinutes()); const sec = pad2(t.getSeconds()); const milli = pad3(t.getMilliseconds()) return `${year}-${month}-${month} ${hour}:${minute}:${sec}.${milli}`; } }33:T8b5,class DynamicLayout extends Layout { constructor(viewport, spec) { super(viewport, spec); } layoutExit() { // Not complete until simulation finishes. } doLayout(graph) { const layout = this.spec; const width = this.width; const height = this.height; const nodes = graph.nodes; const links = graph.links; let i = 0; const count = nodes.length; const cols = Math.floor(Math.sqrt(count) / 4); const rows = Math.ceil(count / cols); const xdelta = width / cols; const ydelta = height / rows; graph.cols = cols; graph.rows = rows; graph.xdelta = xdelta; graph.ydelta = ydelta; const node = this.node; const link = this.link; node .each(function (d) { const col = d.col = i % cols; const row = d.row = Math.floor(i / cols); d3.select(this) .attr("x", d => d.x = xdelta * col) .attr("y", d => d.y = ydelta * row); d.i = i++; }); const simulation = d3.forceSimulation(nodes) .force("link", d3.forceLink(links) .id(d => d.id) .distance(layout.link.distance) .strength(layout.link.strength)) .force("charge", d3.forceManyBody() .distanceMin(layout.charge.distanceMin || 1) .distanceMax(layout.charge.distanceMax || 9999999999) .strength(layout.charge.strength)) .force("collide", d3.forceCollide() .strength(layout.collide.strength) .iterations(layout.collide.iterations) .radius(d => Math.sqrt(d.width * d.width + d.height + d.height))) .force("center", d3.forceCenter(width / 2, height / 2)) .on("tick", () => { this.tick(); node .each(function (d) { d3.select(this) .attr("x", d => d.x) .attr("y", d => d.y); }); link .attr("x1", d => d.source.centerx + d.source.x) .attr("y1", d => d.source.centery + d.source.y) .attr("x2", d => d.target.centerx + d.target.x) .attr("y2", d => d.target.centery + d.target.y); }) .on("end", () => this.layoutComplete()); invalidation.then(() => simulation.stop()); node.call(drag(simulation)); return simulation; } }34:T421,function makeStyle(r, g, b, params) { params = params || {}; const opp = (r, g, b) => { const scaleFactor = 255 / Math.max(Math.abs(128 - r), Math.abs(128 - g), Math.abs(128 - b)); const scale = v => { const rv = Math.round(scaleFactor * (128 - v)) return Math.min(Math.max(0, rv), 255); }; return [scale(r), scale(g), scale(b)]; }; const [or, og, ob] = opp(r, g, b); const s = 255*255.0; const s3 = Math.sqrt(3); const whiteness = Math.sqrt(r*r/s + g*g/s + b*b/s)/s3; const blackness = Math.sqrt((255-r)*(255-r)/s + (255-g)*(255-g)/s + (255-b)*(255-b)/s)/s3; const avg = (r + g + b)/3; const grayness = 1 - Math.sqrt((avg-r)*(avg-r)/s + (avg-g)*(avg-g)/s + (avg-b)*(avg-b)/s)/s3; if (params.force || (grayness < 0.95 && whiteness < 0.9 && blackness < 0.9)) { const nparams = Object.create(params); delete nparams.force; return new Style({ ...nparams, background: `#${hex(r)}${hex(g)}${hex(b)}`, foreground: `#${hex(or)}${hex(og)}${hex(ob)}`, rgb: {r, g, b} }); } }35:T6a2,class World { constructor(...itemList) { this.index = new Index(...itemList); this.nodes = Object.values(this.index.nodes); this.links = Object.values(this.index.links); } id(id) { return this.index.id[id]; } name(name) { return this.index.name[name]; } filter(f) { const links = []; this.links.forEach(l => f(l) && links.push(l)); return new World(links); } clone() { return new World(this.nodes.map(Object.create), this.links.map(Object.create)); } graph() { const nodeMap = {}; const nodes = this.nodes.map(n => nodeMap[n.id] = { id: n.id, name: n.name ||n.id, style: n.style, data: n }); const links = this.links.map(l => ({ id: l.id, name: l.name, style: l.style, source: nodeMap[l.source.id], target: nodeMap[l.target.id], data: l })); return { links: links, nodes: nodes, world: this }; } static nodeFilter(source, target, link) { const f = (typeof source === 'function') ? source : () => source; const g = (typeof target === 'function') ? target : target === undefined ? f : () => target; return l => (l.source && f(l.source) && l.target && g(l.target) && (!link || link(l))); } static not(f) { return t => !f(t); } static or(...filters) { return t => { for (const f of filters) { if (f(t)) { return true; } } return false; }; } static and(...filters) { return t => { for (const f of filters) { if (!f(t)) { return false; } } return true; }; } }36:T406,class EventQueue { constructor() { this.done = false; this.newPromise(); this.notifyCount = 0; this.watcherCount = 0; this.readCount = 0; this.waitCount = 0; } newPromise() { this.promise = new Promise(accept => this.accept = accept) .then(v => { this.newPromise(); return v; }); } async next() { try { this.waitCount++; const v = this.last = await this.promise; this.readCount++; return { value: v, done: this.done }; } finally { --this.waitCount; } } notify(v) { this.lastNotify = v; this.notifyCount++; this.accept && this.accept(v); } end() { this.done = true; this.notify(); } watcher() { this.watcherCount++; const eq = this; const w = async function* () { while (!eq.done) { const v = await eq.next(); if (v.done) { eq.done = true; } else { yield v.value; } } } return w(); } }37:T7b7,class RecentMonitor { constructor(max, ...monitors) { this.max = max; this.nextId = 0; monitors.forEach(m => m.monitorId = this.nextId++); this.queue = new MultiMonitor(...monitors); this._history = new Map(); this._done = new Map(); this.results = new EventQueue(); const watcher = this.queue.watcher(); Promise.resolve() .then(async () => { while (!this.ended) { const v = await watcher.next(); if (v.value && v.value.terminated) { this.ended = true; this.results.end(); } else if (v.value && v.value.done) { this._done.set(v.value.monitor.monitorId, v.value); if (this._done.size > this.max) { [...this._done.keys()].slice(0, this._done.size - this.max) .forEach(k => { this._done.delete(k); this._history.delete(k); }); } this.results.notify(this._history); } else { this._history.delete(v.value.monitor.monitorId); this._history.set(v.value.monitor.monitorId, {...v.value, id: v.value.monitor.monitorId}); const historyList = this._history.values(); if (this._history.length > this.max) { const nhistory = new Map(); let ndone = 0; for (const h of this._history) { if (!h.done && !h.terminated) { nhistory.set(h.monitor.monitorId, h); } else if (++ndone <= this.max) { nhistory.set(h.monitor.monitorId, h); } } this._history = nhistory; } this.results.notify(this._history); } } }); } add(monitor) { monitor.monitorId = this.nextId++; return this.queue.add(monitor); } history() { return [...this._history.values()]; } watcher() { return this.results.watcher(); } end() { this.queue.end(); } }38:[] 2f:{"id":"8146f5e7809c05cd","slug":"graphworld","title":"GraphWorld","thumbnail":"be4554a7d291f66b58c3d5eb5b238afcdc29c3de057c5188c1688f2e9f740e54","access_level":"public","create_time":"$D2019-10-10T06:55:58.263Z","update_time":"$D2019-10-26T19:29:38.401Z","view_time":null,"first_public_time":"$D2019-10-26T16:02:45.286Z","fork":false,"stars":0,"starred":false,"owner":{"type":"team","id":"a2a391e81ef70f60","login":"bobkerns","name":"Bob Kerns","avatar_url":"https://avatars-next.observableusercontent.com/d3d634f0561198d48f6c5a897f4009b95f14b0014fb7d85f3b6cc5415336b639","tier":"starter_2024"},"version":1908,"publish_version":1908,"role":null,"authored":false,"authors":[{"type":"individual","id":"c30fe465bb675dbe","login":"bobkerns","name":"Bob Kerns","avatar_url":"https://avatars-next.observableusercontent.com/d3d634f0561198d48f6c5a897f4009b95f14b0014fb7d85f3b6cc5415336b639","tier":null}],"members":[{"type":"individual","id":"c30fe465bb675dbe","login":"bobkerns","name":"Bob Kerns","avatar_url":"https://avatars-next.observableusercontent.com/d3d634f0561198d48f6c5a897f4009b95f14b0014fb7d85f3b6cc5415336b639","tier":null,"role":"editor"}],"comments":[],"custom_thumbnail":false,"trashed":false,"subscribed":null,"forks":0,"collection":null,"type":"notebook","body":{"title":"GraphWorld","cells":[{"id":0,"value":"md`# GraphWorld`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1871,"value":"md`#### These file inputs aren't currently in use, but are here to make it easy for me to load local data`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":214,"value":"viewof thoughtsFile = html``","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":4,"value":"viewof linksFile = html``","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1868,"value":"md`## This is the data to be presented`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":943,"value":"view = world.filter(World.or(World.nodeFilter(n => n.type && n.type.name === 'Person', true),\n World.nodeFilter(true, n => n.type && n.type.name === 'Person')));","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1077,"value":"graphParams = ({\n width: width,\n height: height,\n nodes: {\n textLineOffset: 4,\n margin: {left: 4, right: 4, top: 4, bottom: 4},\n corners: {x: 12, y: 6},\n dropShadow: {x: 5, y: 5, mode: \"normal\"},\n opacity: 0.5,\n text: {fontSize: 14, stroke: \"#000000\", opacity: 1.0, thickness: 0.3,\n dropShadow: {x: 0.75, y: 0.75, mode: \"soft-light\"}}\n },\n links: {\n thickness: 1.7,\n opacity: .5\n },\n layout: {\n type: \"force\",\n link: {distance: 25, strength: 2},\n charge: {distanceMax: 1000, distanceMin: 2, strength: -0.5},\n collide: {strength: 3, iterations: 2},\n center: {}\n }\n});","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1385,"value":"md``","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1858,"value":"md`## The graph should appear below once the data is loaded.`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":169,"value":"$31","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":462,"value":"html`

${(selected || []).map(sel => html`

ID: ${sel.id}
Name: ${sel.name}
Type: ${sel.type ? `${sel.type.name} (${sel.type.id})` : ''}
ACType: ${sel.brain && sel.brain.ACType}
Kind: ${sel.brain && sel.brain.Kind}
Color:\n ${sel.style.foreground} / ${sel.style.background}

`)}

`;","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1862,"value":"md`### Selected items appear below`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":447,"value":"mutable selected = [];","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1865,"value":"md`This monitors the time required for layout, once the data is loaded.`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1331,"value":"{\n const dom = html`

Active and Last ${layoutMonitor.max} layout activities

`\n const loc = d3.select(dom).select('.layout-list');\n \n const watcher = layoutMonitor.watcher();\n const cmp = (a, b) => (b.id < a.id) ? -1 : ((a.id) === b.id ? 0 : 1);\n while (true) {\n const history = [...layoutMonitor.history()]\n .sort(cmp)\n .map(h => h.value);\n const recs = loc.selectAll('.layout-record')\n .remove();\n [...history]\n .forEach(h => loc.insert(d => h));\n yield dom;\n await Promise.all([watcher.next(), Promises.delay(500)]);\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1876,"value":"md`### This captures some data from the layout process for inspection`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1269,"value":"mutable graph = null;","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1312,"value":"$32","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1313,"value":"$33","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1777,"value":"class IdGenerator {\n static *idGenerator(start = 0) {\n let id = start;\n while (true) yield id++;\n }\n static id(prefix = \"\") {\n const gens = IdGenerator.gens = (IdGenerator.gens || {});\n const gen = gens[prefix]|| (gens[prefix] = IdGenerator.idGenerator());\n const num = gen.next().value;\n if (prefix) {\n return `${prefix}-${num}`;\n }\n return num;\n }\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1546,"value":"layoutMonitor = new RecentMonitor(4, new MultiMonitor());","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":225,"value":"height = 800","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1013,"value":"function addDropShadow(defs, id, spec) {\n const filter = defs.append(\"filter\")\n .attr(\"id\", id)\n .attr(\"x\", 0)\n .attr(\"y\", 0)\n .attr(\"width\", \"200%\")\n .attr(\"height\", \"200%\");\n const feOffset = filter.append(\"feOffset\")\n .attr(\"result\", \"offOut\")\n .attr(\"in\", \"SourceGraphic\")\n .attr(\"dx\", spec.x)\n .attr(\"dy\", spec.y);\n const feColorMatrix = filter.append(\"feColorMatrix\")\n .attr(\"result\", \"matrixOut\")\n .attr(\"in\", \"offOut\")\n .attr(\"type\", \"matrix\")\n .attr(\"values\", \"0.2 0 0 0 0 0 0.2 0 0 0 0 0 0.2 0 0 0 0 0 1 0\");\n const feGausianBlur = filter.append(\"feGausianBlur\")\n .attr(\"result\", \"blurOut\")\n .attr(\"in\", \"matrixOut\")\n .attr(\"stdDeviation\", 10);\n const feBlend = filter.append(\"feBlend\")\n .attr(\"in\", \"SourceGraphic\")\n .attr(\"in2\", \"blurOut\")\n .attr(\"mode\", spec.mode || \"color\");\n return defs;\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":778,"value":"styles = ({});","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":766,"value":"class Style {\n constructor(opts) {\n Object.assign(this, opts);\n this.thickness = this.thickness || 1.7;\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":813,"value":"INIT_STYLES = {\n Style.styles = {};\n function* styleSeq() {\n let run = invalidation.then(() => run = false);\n // let i = 0;\n // let sel = (scheme) => scheme[i++ % scheme.length];\n const rand = () => Math.floor(Math.random()*255.999);\n\n\n let trials = 0;\n while (run) {\n const style = makeStyle(rand(), rand(), rand());\n if (style) {\n trials = 0;\n yield style;\n } else if (++trials > 400) {\n trials = 0;\n yield new Style(255, 255, 255);\n }\n }\n }\n Style.styleSeq = styleSeq;\n Style.seq = styleSeq();\n Style.style = function style(type) {\n if (Style.styles[type]) {\n return Style.styles[type];\n }\n return Style.styles[type] = Style.seq.next().value;\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":770,"value":"$34","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":657,"value":"hex = v => {\n const s = v.toString(16);\n return (s.length === 2) ? s : `0${s}`;\n };","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":222,"value":"drag = simulation => {\n \n function dragstarted(d) {\n if (!d3.event.active) simulation.alphaTarget(0.3).restart();\n d.fx = d.x;\n d.fy = d.y;\n }\n \n function dragged(d) {\n d.fx = d3.event.x;\n d.fy = d3.event.y;\n }\n \n function dragended(d) {\n if (!d3.event.active) simulation.alphaTarget(0);\n d.fx = null;\n d.fy = null;\n }\n \n return d3.drag()\n .on(\"start\", dragstarted)\n .on(\"drag\", dragged)\n .on(\"end\", dragended);\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":8,"value":"async function* loadJSON(f) {\n try {\n const text = await d3.text(f, {mode: \"cors\"});\n for (const l of text.split('\\n')) {\n if (l) {\n yield JSON.parse(l);\n }\n }\n return false;\n } catch (e) {\n return e;\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":19,"value":"loader = R.map(k => k.Id) // R.reduceBy((acc, t) => t, {}, t => t.Id)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1881,"value":"md`## The data is loaded here`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":73,"value":"thoughts = collect(flatten(NULL_NODE, collect(loadJSON(\"https://raw.githubusercontent.com/BobKerns/trumpist/master/brain/thoughts.json\"), graphNode)))","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":216,"value":"links = collect(loadJSON(\"https://raw.githubusercontent.com/BobKerns/trumpist/master/brain/links.json\", removeNULL), graphLink)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":411,"value":"thoughtsTable = {\n const table = {}\n thoughts.forEach(t => table[t.id] = t);\n Entry.getThought = id => table[id];\n let f;\n while (f = deferred.pop()) {\n f();\n }\n return table;\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":991,"value":"class Index {\n constructor(...itemList) {\n const id = {};\n const name = {};\n const nodes = {};\n const links = {};\n const addItem = t => {\n id[t.id] = t;\n if (t.name) {\n const ent = (name[t.name] || []);\n ent.push(t);\n name[t.name] = ent;\n }\n if (t.source && t.target) {\n addItem(t.source);\n addItem(t.target);\n links[t.id] = t;\n } else {\n nodes[t.id] = t;\n }\n };\n itemList.forEach(items => items.forEach(addItem));\n this.id = id;\n this.name = name;\n this.nodes = nodes;\n this.links = links;\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":715,"value":"world = new World(links);","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":926,"value":"deferred = [];","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":736,"value":"class Entry {\n constructor(id, name, typeId, style, brain) {\n const setType = () => {\n if (typeId) {\n if (Entry.getThought) {\n this.type = Entry.getThought(typeId);\n } else {\n deferred.push(() => this.type = Entry.getThought(typeId));\n }\n }\n }\n this.id = id;\n if (name) {\n this.name = name;\n }\n setType();\n this.style = style;\n if (brain) {\n this.brain = brain;\n }\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":740,"value":"class Node extends Entry {\n constructor(id, name, typeId, brain) {\n super(id, name, typeId, Style.style(typeId), brain);\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":744,"value":"class Link extends Entry {\n constructor(id, name, typeId, source, target, brain) {\n super(id, name, typeId, linkStyle(typeId, source, target), brain);\n this.source = source;\n this.target = target;\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":720,"value":"$35","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1905,"value":"md`## Event and monitor code`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1433,"value":"$36","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1481,"value":"class EventMonitor {\n constructor() {\n this.queue = new EventQueue();\n this.done = false;\n this.notifyCount = 0;\n this.watcherCount = 0;\n this.readCount = 0;\n this.waitCount = 0;\n }\n notify(v) {\n this.notifyCount++;\n return this.queue.notify(v);\n }\n async transform(v) {\n return v;\n }\n async next() {\n try {\n this.waitCount++;\n let n = await this.queue.next();\n this.done = this.done || n.done;\n const v = this.last = await n.value;\n this.readCount++;\n return {\n value: !n.done && (this.lastX = await this.transform(v)),\n done: n.done\n };\n } finally {\n --this.waitCount;\n }\n }\n\n end() {\n this.done = true;\n this.queue.end();\n }\n\n watcher() {\n this.watcherCount++;\n const em = this;\n const w = async function* () {\n while (!em.done) {\n let n = await em.next();\n if (n.done) {\n return n.value;\n }\n yield await n.value;\n }\n };\n return w();\n }\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1486,"value":"class LayoutMonitor extends EventMonitor {\n async transform(l) {\n return html`\n

\n ${l.name} ${l.getStartTime()}\n

\n Iterations: ${l.iterationCount}, time: ${l.runtime / 1000.0}s\n

\n Status: ${l.status} ${l.error || ''} \n

\n `;\n }\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1492,"value":"class MultiMonitor {\n constructor(...monitors) {\n this.queue = new EventQueue();\n this.ended = false;\n monitors.forEach(m => this.add(m));\n console.log(\"MultiMonitor created.\");\n }\n \n add(monitor) {\n Promise.resolve().then(async () => {\n const w = monitor.watcher();\n let done = false;\n while (!done && !this.ended) {\n const v = await w.next();\n if (v.done) {\n done = true;\n } else {\n this.queue.notify({monitor: monitor, value: v.value});\n }\n }\n if (done) {\n this.queue.notify({monitor: monitor, done: true});\n } else {\n this.queue.notify({monitor: this, terminated: true});\n }\n });\n return monitor;\n }\n \n watcher() {\n return this.queue.watcher();\n }\n \n end() {\n this.ended = true;\n }\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1651,"value":"$37","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1900,"value":"md`### Utility routines`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":306,"value":"async function* flatten(...gens) {\n try {\n for await (const g of gens) {\n if (g[Symbol.asyncIterator]) {\n for await (const gg of g) {\n yield* gg\n }\n } else {\n yield g\n }\n }\n } catch (e) {\n yield e\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":177,"value":"async function* collect(l, f) {\n let result = []\n for await (const x of l) {\n result.push(f ? f(x) : x)\n }\n yield result\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":134,"value":"graphNode = (n) => new Node(n.Id, n.Name, n.TypeId, n);","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":269,"value":"mutable linkId = 0","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":229,"value":"graphLink = x => {\n try {\n return new Link(x.Id || \"LINK\" + mutable linkId++,\n x.Name,\n x.TypeId || NULL,\n thoughtsTable[x.ThoughtIdA],\n thoughtsTable[x.ThoughtIdB],\n x);\n } catch(e) {\n throw new Error(`${e.message} in link ${JSON.stringify(x)}`)\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":678,"value":"linkStyle = (type, source, target) => {\n const existing = Style.styles[type];\n if (existing) {\n return existing;\n }\n if (!target || !source) {\n throw new Error(`Missing source/target for link type ${type}`);\n }\n if (!source.style) {\n throw new Error(`Missing style for link source ${source.id}`);\n }\n if (!target.style) {\n throw new Error(`Missing style for link target ${target.id}`);\n }\n const r = Math.floor((target.style.rgb.r * 2 + source.style.rgb.r) / 3);\n const g = Math.floor((target.style.rgb.g * 2 + source.style.rgb.g) / 3);\n const b = Math.floor((target.style.rgb.b * 2 + source.style.rgb.b) / 3);\n const newStyle = makeStyle(r, g, b, {force: true});\n return Style.styles[type] = newStyle;\n};","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":232,"value":"NULL = '00000000-0000-0000-0000-000000000000'","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":373,"value":"NULL_NODE = INIT_STYLES, new Node(NULL, \"NULL\", NULL, null);","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":235,"value":"removeNULL = R.filter(n => !!n.Id && !!n.ThoughtIdA && n.ThoughtIdA !==NULL && !!n.ThoughtIdB && n.ThoughtIdB !== NULL)","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1895,"value":"md`## Imports`","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":33,"value":"R = require('ramda@0.25.0/dist/ramda.min.js')","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":163,"value":"d3 = require(\"https://cdn.jsdelivr.net/npm/d3@5.12.0/dist/d3.js\")","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1497,"value":"mm = new MultiMonitor();","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1897,"value":"md`### Test/Debug Sandbox`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1654,"value":"rm = new RecentMonitor(3, em, em2, em3, em4);","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1659,"value":"rm.history();","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1503,"value":"em = mm.add(new EventMonitor());","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1533,"value":"em2 = mm.add(new EventMonitor())","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1535,"value":"em3 = mm.add(new EventMonitor())","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1537,"value":"em4 = mm.add(new EventMonitor())","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1517,"value":"em.notify(458732)","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1540,"value":"em2.notify('em2x')","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1685,"value":"em3.notify('em3')","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1680,"value":"em4.notify(\"em4\")","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1683,"value":"em4.end()","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1687,"value":"em3.end()","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1689,"value":"em2.end()","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1691,"value":"em.end()","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1693,"value":"rm._done.size","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":1697,"value":"[...rm._done.keys()]\n//rm._done.keys().slice(rm.max - rm._done.size)","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"}],"files":"$W38","stdlib":"1","titling":"auto"}} 30:"$2f:body"