063a5aa · favela-peer · pear-git-v3

Changed files (5) +97 -78

.pgh-lock.json +43 -43

…	…	@@ -1,9 +1,9 @@
1	1	{
2	2	"name": "favela-peer",
3		"version": "0.0.41",
	3	"version": "0.0.42",
4	4	"runtime": "bare",
5		"rootTreeHash": "5e5291250d721374a84f3649ebfe79da2535bd06c0edd4a7a4f2c8733e9daa60",
6		"publishedAt": "2026-09-08T18:37:47.228Z",
	5	"rootTreeHash": "ef10bb20c36ea5e78eb287b295cc60fb037d05879b97033bd36aec1901b2f9a7",
	6	"publishedAt": "2026-09-08T18:44:13.359Z",
7	7	"deps": [
8	8	{
9	9	"name": "@hyperswarm/secret-stream",
…	…	@@ -3016,8 +3016,8 @@
3016	3016	"tree": "c5f18b3620514f54714aeb351f074adface216a335242e323e33d28d261376fe"
3017	3017	}
3018	3018	],
3019		"reason": "version-splits only: dry-run reports 0 code-differs",
3020		"acceptedAt": "2026-09-08T18:37:47.243Z"
	3019	"reason": "version-splits only: 0 code-differs",
	3020	"acceptedAt": "2026-09-08T18:44:13.372Z"
3021	3021	},
3022	3022	{
3023	3023	"type": "VERSION_CONFLICT",
…	…	@@ -3066,8 +3066,8 @@
3066	3066	"tree": "6bb5233025d1c30e4f181e29b6ab5af549d8909c7070c7b4438b30f1a4e76ce2"
3067	3067	}
3068	3068	],
3069		"reason": "version-splits only: dry-run reports 0 code-differs",
3070		"acceptedAt": "2026-09-08T18:37:47.243Z"
	3069	"reason": "version-splits only: 0 code-differs",
	3070	"acceptedAt": "2026-09-08T18:44:13.372Z"
3071	3071	},
3072	3072	{
3073	3073	"type": "VERSION_CONFLICT",
…	…	@@ -3081,8 +3081,8 @@
3081	3081	"tree": "58c0bf8698af19464d0ee8354a77ed1ac96d3a5fa18aa4e794686cfbbf080e5d"
3082	3082	}
3083	3083	],
3084		"reason": "version-splits only: dry-run reports 0 code-differs",
3085		"acceptedAt": "2026-09-08T18:37:47.243Z"
	3084	"reason": "version-splits only: 0 code-differs",
	3085	"acceptedAt": "2026-09-08T18:44:13.372Z"
3086	3086	},
3087	3087	{
3088	3088	"type": "VERSION_CONFLICT",
…	…	@@ -3106,8 +3106,8 @@
3106	3106	"tree": "bdebba5a532ce4846b49f1e5ffad774becfc44182d0c3737f7e441ab42f4c43d"
3107	3107	}
3108	3108	],
3109		"reason": "version-splits only: dry-run reports 0 code-differs",
3110		"acceptedAt": "2026-09-08T18:37:47.243Z"
	3109	"reason": "version-splits only: 0 code-differs",
	3110	"acceptedAt": "2026-09-08T18:44:13.372Z"
3111	3111	},
3112	3112	{
3113	3113	"type": "VERSION_CONFLICT",
…	…	@@ -3141,8 +3141,8 @@
3141	3141	"tree": "b799e6ba8726aa951b45f12cc7ecffe5f4e9ee1e8adf09a34d026d9d5658828a"
3142	3142	}
3143	3143	],
3144		"reason": "version-splits only: dry-run reports 0 code-differs",
3145		"acceptedAt": "2026-09-08T18:37:47.243Z"
	3144	"reason": "version-splits only: 0 code-differs",
	3145	"acceptedAt": "2026-09-08T18:44:13.372Z"
3146	3146	},
3147	3147	{
3148	3148	"type": "VERSION_CONFLICT",
…	…	@@ -3156,8 +3156,8 @@
3156	3156	"tree": "e92100a4f821a638ac99c1407e4c7e784f8eb9661e6d9119ecbec4faae77cc7e"
3157	3157	}
3158	3158	],
3159		"reason": "version-splits only: dry-run reports 0 code-differs",
3160		"acceptedAt": "2026-09-08T18:37:47.243Z"
	3159	"reason": "version-splits only: 0 code-differs",
	3160	"acceptedAt": "2026-09-08T18:44:13.372Z"
3161	3161	},
3162	3162	{
3163	3163	"type": "VERSION_CONFLICT",
…	…	@@ -3171,8 +3171,8 @@
3171	3171	"tree": "1f5de2daa08643a5cb8bce2153ca4d55d4504fb366f1f1ef80bca1700ec085f7"
3172	3172	}
3173	3173	],
3174		"reason": "version-splits only: dry-run reports 0 code-differs",
3175		"acceptedAt": "2026-09-08T18:37:47.243Z"
	3174	"reason": "version-splits only: 0 code-differs",
	3175	"acceptedAt": "2026-09-08T18:44:13.372Z"
3176	3176	},
3177	3177	{
3178	3178	"type": "VERSION_CONFLICT",
…	…	@@ -3186,8 +3186,8 @@
3186	3186	"tree": "579bdc1eaabbca726d3916f1fc74cfd4986653f6748632db586817a2a8caabea"
3187	3187	}
3188	3188	],
3189		"reason": "version-splits only: dry-run reports 0 code-differs",
3190		"acceptedAt": "2026-09-08T18:37:47.243Z"
	3189	"reason": "version-splits only: 0 code-differs",
	3190	"acceptedAt": "2026-09-08T18:44:13.372Z"
3191	3191	},
3192	3192	{
3193	3193	"type": "VERSION_CONFLICT",
…	…	@@ -3201,8 +3201,8 @@
3201	3201	"tree": "967cf214778dbacd7cc7cc3850ffdff6a6f145b4bd73de741d0938d7d84d33d5"
3202	3202	}
3203	3203	],
3204		"reason": "version-splits only: dry-run reports 0 code-differs",
3205		"acceptedAt": "2026-09-08T18:37:47.243Z"
	3204	"reason": "version-splits only: 0 code-differs",
	3205	"acceptedAt": "2026-09-08T18:44:13.372Z"
3206	3206	},
3207	3207	{
3208	3208	"type": "VERSION_CONFLICT",
…	…	@@ -3231,8 +3231,8 @@
3231	3231	"tree": "35b214bfbf85f8bbcb9f1926470e77f4e240d9b5045b07f81ce83fec24c1380c"
3232	3232	}
3233	3233	],
3234		"reason": "version-splits only: dry-run reports 0 code-differs",
3235		"acceptedAt": "2026-09-08T18:37:47.243Z"
	3234	"reason": "version-splits only: 0 code-differs",
	3235	"acceptedAt": "2026-09-08T18:44:13.372Z"
3236	3236	},
3237	3237	{
3238	3238	"type": "VERSION_CONFLICT",
…	…	@@ -3246,8 +3246,8 @@
3246	3246	"tree": "67c4c05f69061f65a2548595c43282be2da8e0934e6ce347afa034b29cc40c81"
3247	3247	}
3248	3248	],
3249		"reason": "version-splits only: dry-run reports 0 code-differs",
3250		"acceptedAt": "2026-09-08T18:37:47.243Z"
	3249	"reason": "version-splits only: 0 code-differs",
	3250	"acceptedAt": "2026-09-08T18:44:13.372Z"
3251	3251	},
3252	3252	{
3253	3253	"type": "VERSION_CONFLICT",
…	…	@@ -3276,8 +3276,8 @@
3276	3276	"tree": "4ef8a03ba96b1488cb7ee35dc582b14d096ae4b3fab5481186c94516d434fe18"
3277	3277	}
3278	3278	],
3279		"reason": "version-splits only: dry-run reports 0 code-differs",
3280		"acceptedAt": "2026-09-08T18:37:47.243Z"
	3279	"reason": "version-splits only: 0 code-differs",
	3280	"acceptedAt": "2026-09-08T18:44:13.372Z"
3281	3281	},
3282	3282	{
3283	3283	"type": "VERSION_CONFLICT",
…	…	@@ -3306,8 +3306,8 @@
3306	3306	"tree": "5fc49d698f6ddfd653b3cdaa72ec572d6804293e2e9c3e98303f69417115e903"
3307	3307	}
3308	3308	],
3309		"reason": "version-splits only: dry-run reports 0 code-differs",
3310		"acceptedAt": "2026-09-08T18:37:47.243Z"
	3309	"reason": "version-splits only: 0 code-differs",
	3310	"acceptedAt": "2026-09-08T18:44:13.372Z"
3311	3311	},
3312	3312	{
3313	3313	"type": "VERSION_CONFLICT",
…	…	@@ -3321,8 +3321,8 @@
3321	3321	"tree": "d0099e1743480f28a08c7374d20ad5048088475180ab606626b63acd59e365a5"
3322	3322	}
3323	3323	],
3324		"reason": "version-splits only: dry-run reports 0 code-differs",
3325		"acceptedAt": "2026-09-08T18:37:47.243Z"
	3324	"reason": "version-splits only: 0 code-differs",
	3325	"acceptedAt": "2026-09-08T18:44:13.372Z"
3326	3326	},
3327	3327	{
3328	3328	"type": "VERSION_CONFLICT",
…	…	@@ -3336,8 +3336,8 @@
3336	3336	"tree": "60429c7756f039ec2b3e5240f702dee450c1da19ad6de06900a3877c6c72bb52"
3337	3337	}
3338	3338	],
3339		"reason": "version-splits only: dry-run reports 0 code-differs",
3340		"acceptedAt": "2026-09-08T18:37:47.243Z"
	3339	"reason": "version-splits only: 0 code-differs",
	3340	"acceptedAt": "2026-09-08T18:44:13.372Z"
3341	3341	},
3342	3342	{
3343	3343	"type": "VERSION_CONFLICT",
…	…	@@ -3366,8 +3366,8 @@
3366	3366	"tree": "6fc80ad1ccbfb046613f36299032f21a4752e2614ff8d88a7a5bd7ce66fc1293"
3367	3367	}
3368	3368	],
3369		"reason": "version-splits only: dry-run reports 0 code-differs",
3370		"acceptedAt": "2026-09-08T18:37:47.243Z"
	3369	"reason": "version-splits only: 0 code-differs",
	3370	"acceptedAt": "2026-09-08T18:44:13.372Z"
3371	3371	},
3372	3372	{
3373	3373	"type": "VERSION_CONFLICT",
…	…	@@ -3386,8 +3386,8 @@
3386	3386	"tree": "92424acff1a50468df203528e41739f44f602904abc4beb34500ce172c6d0ad2"
3387	3387	}
3388	3388	],
3389		"reason": "version-splits only: dry-run reports 0 code-differs",
3390		"acceptedAt": "2026-09-08T18:37:47.243Z"
	3389	"reason": "version-splits only: 0 code-differs",
	3390	"acceptedAt": "2026-09-08T18:44:13.372Z"
3391	3391	},
3392	3392	{
3393	3393	"type": "VERSION_CONFLICT",
…	…	@@ -3411,8 +3411,8 @@
3411	3411	"tree": "36d01631ddee74ac2ce62971abd7c0ac30562da8dfd6495480da56c534eb80b7"
3412	3412	}
3413	3413	],
3414		"reason": "version-splits only: dry-run reports 0 code-differs",
3415		"acceptedAt": "2026-09-08T18:37:47.243Z"
	3414	"reason": "version-splits only: 0 code-differs",
	3415	"acceptedAt": "2026-09-08T18:44:13.372Z"
3416	3416	},
3417	3417	{
3418	3418	"type": "VERSION_CONFLICT",
…	…	@@ -3426,8 +3426,8 @@
3426	3426	"tree": "bba869f5c85b11bce5671d57a87cd2793b490588867cd07fbe94cad796114970"
3427	3427	}
3428	3428	],
3429		"reason": "version-splits only: dry-run reports 0 code-differs",
3430		"acceptedAt": "2026-09-08T18:37:47.243Z"
	3429	"reason": "version-splits only: 0 code-differs",
	3430	"acceptedAt": "2026-09-08T18:44:13.372Z"
3431	3431	},
3432	3432	{
3433	3433	"type": "VERSION_CONFLICT",
…	…	@@ -3441,8 +3441,8 @@
3441	3441	"tree": "2ecc91a8c3595dda5dfc86ace62a70875520adc4e588a2ac14945dbc4313c450"
3442	3442	}
3443	3443	],
3444		"reason": "version-splits only: dry-run reports 0 code-differs",
3445		"acceptedAt": "2026-09-08T18:37:47.243Z"
	3444	"reason": "version-splits only: 0 code-differs",
	3445	"acceptedAt": "2026-09-08T18:44:13.372Z"
3446	3446	}
3447	3447	]
3448	3448	}

lib/mirror.js +40 -32

…	…	@@ -46,7 +46,31 @@ export function createMirror ({ feeds, concurrency = DEFAULT_CONCURRENCY, deboun
46	46	// If `append` and `connection` stay at zero while `stale` climbs, the events are dead, and that
47	47	// is a fact anyone can read rather than infer from how long something took.
48	48	const fired = { append: 0, connection: 0, stale: 0, boot: 0 }
49		const watched = []
	49	const bases = []
	50	const hooked = new Map()
	51
	52	// Attach an 'append' listener to every writer core we have not already hooked. A hypercore emits
	53	// append when blocks land, INCLUDING replicated ones — the earliest honest signal someone else
	54	// wrote something. Idempotent, so calling it every pass is free after the first.
	55	function rehook (onAppend) {
	56	for (const base of bases) {
	57	let writers
	58	try { writers = base.writers } catch { continue }
	59	if (!writers) continue
	60	try {
	61	for (const w of writers) {
	62	const core = w && w.core
	63	if (!core \|\| typeof core.on !== 'function') continue
	64	// ⛔ Keyed on the CORE OBJECT, not on core.id or core.key. Keying on an identifier meant
	65	// a core that had not yet exposed one was silently skipped — and "silently skipped" is
	66	// precisely the failure this whole trigger has already had three times.
	67	if (hooked.has(core)) continue
	68	core.on('append', onAppend)
	69	hooked.set(core, onAppend)
	70	}
	71	} catch { /* a writer set mid-change is not a failure of the pass */ }
	72	}
	73	}
50	74
51	75	async function mirrorFeed (key, feed) {
52	76	// ⛔ `pointers()` and not `list()` or `unresolved()`. Both of those RESOLVE every record, which
…	…	@@ -108,6 +132,9 @@ export function createMirror ({ feeds, concurrency = DEFAULT_CONCURRENCY, deboun
108	132	async pass () {
109	133	if (stopped \|\| running) return { fetched: 0, failed: 0 }
110	134	running = true
	135	// Hook whatever writers exist NOW. On the first pass a remote feed usually has none; by the
	136	// second it does, and from then on every remote append triggers a sweep of its own.
	137	rehook(() => this.schedule('append'))
111	138	let fetched = 0
112	139	let failed = 0
113	140	try {
…	…	@@ -151,34 +178,14 @@ export function createMirror ({ feeds, concurrency = DEFAULT_CONCURRENCY, deboun
151	178	*/
152	179	watch (base) {
153	180	if (!base) return () => {}
154		const onAppend = () => this.schedule()
155
156		// ⛔ THE WRITER CORES, not the autobee. autobee emits no "view advanced" event: its whole
157		// surface is interrupt / error / rotate-local-writer / move-to, and the one `emit('update')`
158		// fires inside _onError on an INTERRUPT. 0.0.40 subscribed to it and therefore never fired —
159		// caught only by an end-to-end run, because a fake emitter emits whatever you tell it to.
160		//
161		// A hypercore emits 'append' when blocks land, INCLUDING replicated ones, which is the
162		// earliest honest signal that someone else wrote something.
163		//
164		// ⚠ Writers admitted later are not hooked until the next boot. The periodic sweep below is
165		// what stops that being a hole.
166		let hooked = 0
167		try {
168		for (const w of (base.writers \|\| [])) {
169		if (!w \|\| !w.core \|\| typeof w.core.on !== 'function') continue
170		w.core.on('append', onAppend)
171		watched.push([w.core, onAppend])
172		hooked++
173		}
174		} catch (err) {
175		log({ msg: 'mirror: could not watch writer cores', error: err.message })
176		}
177		if (!hooked) log({ msg: 'mirror: no writer cores to watch — relying on the periodic sweep' })
178		return () => {
179		for (const [c, fn] of watched) { try { c.off('append', fn) } catch {} }
180		watched.length = 0
181		}
	181	bases.push(base)
	182	// ⛔ REGISTERED, NOT HOOKED — hooking happens in every pass. `base.writers` is an
	183	// ActiveWriters whose `active` map is EMPTY when a freshly-opened remote feed returns from
	184	// hold(): writers are only added once the system core has replicated. Hooking once here
	185	// therefore attached to NOTHING, silently, and that is the third time in this feature that
	186	// doing a thing once at open time ran before the data it needed existed. Re-hooking per pass
	187	// costs a Map lookup and cannot be early.
	188	return () => { bases.length = 0 }
182	189	},
183	190
184	191	/**
…	…	@@ -213,14 +220,15 @@ export function createMirror ({ feeds, concurrency = DEFAULT_CONCURRENCY, deboun
213	220	},
214	221
215	222	/** Which trigger has actually been firing. `stale` climbing alone means the events are dead. */
216		stats () { return { ...fired, lastPassAt } },
	223	stats () { return { ...fired, hooked: hooked.size, bases: bases.length, lastPassAt } },
217	224
218	225	stop () {
219	226	stopped = true
220	227	if (timer) { clearTimeout(timer); timer = null }
221	228	if (interval) { clearInterval(interval); interval = null }
222		for (const [c, fn] of watched) { try { c.off('append', fn) } catch {} }
223		watched.length = 0
	229	for (const [c, fn] of hooked) { try { c.off('append', fn) } catch {} }
	230	hooked.clear()
	231	bases.length = 0
224	232	}
225	233	}
226	234	}

lib/rpc.js +7 -0

…	…	@@ -415,6 +415,13 @@ export async function dispatch (node, cmd, a) {
415	415	// ⚠ Reported, never folded into a listing: a record we hold a pointer for and cannot read is
416	416	// not an absent record, and the CLI must be able to say which.
417	417	case 'unresolved': return peer.unresolved()
	418
	419	// ⛔ WHICH TRIGGER IS ACTUALLY FIRING. Built because three fixes in a row shipped a mirror
	420	// trigger that never fired, and nothing on a running node could say so — each time the only
	421	// evidence was how LONG a record took to appear, which is inference, not measurement. If
	422	// `append` and `connection` stay at zero while `stale` climbs, the events are dead. That is now
	423	// a fact you can read.
	424	case 'mirror-stats': return node._mirror ? node._mirror.stats() : { mirror: 'not running' }
418	425	default:
419	426	throw new Error('unknown command: ' + cmd)
420	427	}

package.json +1 -1

…	…	@@ -1,6 +1,6 @@
1	1	{
2	2	"name": "favela-peer",
3		"version": "0.0.42",
	3	"version": "0.0.43",
4	4	"description": "The favela daemon — feeds and documents of markdown records over Hypercore. No atproto, no ActivityPub.",
5	5	"type": "module",
6	6	"scripts": {

test/mirror.test.js +6 -2

…	…	@@ -171,8 +171,9 @@ test('★★ a log that advances AFTER the boot pass still gets mirrored', async
171	171	const m = createMirror({ feeds: () => [{ key: 'f1', feed }], debounceMs: 10, log: () => {} })
172	172	m.watch(base)
173	173
174		await m.pass()
	174	await m.pass() // the boot pass: finds nothing, and attaches the append hooks
175	175	t.is(fetched.length, 0, 'boot pass finds nothing — the log has not arrived')
	176	t.is(m.stats().hooked, 1, 'but it DID hook the writer core — the thing 0.0.42 silently did not')
176	177
177	178	names = ['late'] // the log replicates
178	179	base.emit() // autobee says the view advanced
…	…	@@ -191,10 +192,12 @@ test('★ a burst of updates coalesces into one pass', async (t) => {
191	192
192	193	const m = createMirror({ feeds: () => [{ key: 'f1', feed }], debounceMs: 20, log: () => {} })
193	194	m.watch(base)
	195	await m.pass() // ⛔ hooks attach during a PASS, not at watch() — writers do not exist yet at open
	196	const after = passes
194	197	for (let i = 0; i < 10; i++) base.emit()
195	198	await new Promise((r) => setTimeout(r, 80))
196	199
197		t.is(passes, 1, 'ten view changes, one sweep — autobee emits far more often than records arrive')
	200	t.is(passes - after, 1, 'ten appends, one sweep — a core appends far more often than records land')
198	201	})
199	202
200	203	test('★ stop() detaches the watcher', async (t) => {
…	…	@@ -298,6 +301,7 @@ test('★★ the staleness ceiling skips itself when events are alive', async (t
298	301	m.every(40)
299	302	const base = fakeBase()
300	303	m.watch(base)
	304	await m.pass() // attaches the hooks
301	305
302	306	// Keep events flowing faster than the ceiling.
303	307	for (let i = 0; i < 5; i++) { base.emit(); await new Promise((r) => setTimeout(r, 20)) }

favela-peer commits / 063a5aa

Changed files (5) +97 -78