Skip to main content

yog_api/
registry.rs

1//! Registration hub and mod entry-point trait.
2//!
3//! [`Registry`] wraps the [`YogApi`] C table passed to `yog_mod_register` and
4//! provides an ergonomic Rust API over it.  All closures registered here are
5//! boxed on the heap and their raw pointers handed to the runtime; the runtime
6//! then drives them via C function-pointer calls.  Closures are intentionally
7//! leaked (never freed) — they live for the entire process lifetime, which is
8//! correct for a game server.
9
10use std::os::raw::c_void;
11
12use yog_abi::{
13    YogAdvancementEvent, YogApi, YogAttackEntityEvent, YogBlockBreakEvent, YogBlockDef,
14    YogChatEvent, YogCommandEvent, YogContainerCloseEvent, YogContainerOpenEvent, YogCraftEvent,
15    YogEntityDamageEvent, YogEntityDeathEvent, YogEntityInteractEvent, YogEntitySpawnEvent,
16    YogExplosionEvent, YogGfxApi, YogInventoryDef, YogItemDef, YogItemPickupEvent,
17    YogKeyPressEvent, YogPacketEvent, YogPlaceBlockEvent, YogPlayerDeathEvent, YogPlayerEvent,
18    YogPlayerMoveEvent, YogPlayerRespawnEvent, YogProjectileHitEvent, YogServer,
19    YogStartupGrantDef, YogStr, YogUseBlockEvent, YogUseItemEvent,
20};
21use yog_book::Book;
22use yog_command::CommandContext;
23use yog_core::Server;
24use yog_dimensions::{ChunkWriter, YogDimensionDef};
25use yog_event::{
26    AdvancementEvent, AttackEntityEvent, BlockBreakEvent, ChatEvent, ClientTickEvent,
27    ContainerCloseEvent, ContainerOpenEvent, CraftEvent, EntityDamageEvent, EntityDeathEvent,
28    EntityInteractEvent, EntitySpawnEvent, EventPhase, ExplosionEvent, ItemPickupEvent,
29    KeyPressEvent, PlaceBlockEvent, PlayerDeathEvent, PlayerJoinEvent, PlayerLeaveEvent,
30    PlayerMoveEvent, PlayerRespawnEvent, ProjectileHitEvent, ScreenEvent, UseBlockEvent,
31    UseItemEvent,
32};
33use yog_gfx::GfxContext;
34use yog_network::{Packet, PacketEvent};
35use yog_registry::{BlockDef, FurnaceRecipe, ItemDef, ShapedRecipe, ShapelessRecipe, StartupGrant};
36
37// ── CServer — implements Server via the YogServer function table ──────────────
38
39/// A handle to the runtime's server actions, backed by [`YogServer`] fn pointers.
40/// Given to every handler as `&dyn Server`.
41pub struct CServer(pub *const YogServer);
42
43unsafe impl Send for CServer {}
44unsafe impl Sync for CServer {}
45
46macro_rules! srv {
47    ($self:ident) => {
48        unsafe { &*$self.0 }
49    };
50}
51
52impl Server for CServer {
53    fn broadcast(&self, message: &str) {
54        let s = srv!(self);
55        unsafe { (s.broadcast)(s.ctx, YogStr::from_str(message)) }
56    }
57
58    fn get_block(&self, dimension: &str, pos: yog_core::BlockPos) -> Option<String> {
59        let s = srv!(self);
60        let owned = unsafe {
61            (s.get_block)(
62                s.ctx,
63                YogStr::from_str(dimension),
64                yog_abi::YogBlockPos {
65                    x: pos.x,
66                    y: pos.y,
67                    z: pos.z,
68                },
69            )
70        };
71
72        take_owned(s.free_str, owned)
73    }
74
75    fn set_block(&self, dimension: &str, pos: yog_core::BlockPos, block_id: &str) -> bool {
76        let s = srv!(self);
77        unsafe {
78            (s.set_block)(
79                s.ctx,
80                YogStr::from_str(dimension),
81                yog_abi::YogBlockPos {
82                    x: pos.x,
83                    y: pos.y,
84                    z: pos.z,
85                },
86                YogStr::from_str(block_id),
87            )
88        }
89    }
90
91    fn give_item(&self, player: &str, item_id: &str, count: u32) -> bool {
92        let s = srv!(self);
93        unsafe {
94            (s.give_item)(
95                s.ctx,
96                YogStr::from_str(player),
97                YogStr::from_str(item_id),
98                count,
99            )
100        }
101    }
102
103    fn teleport(&self, player: &str, x: f64, y: f64, z: f64) -> bool {
104        let s = srv!(self);
105        unsafe {
106            (s.player_teleport)(
107                s.ctx,
108                YogStr::from_str(player),
109                yog_abi::YogVec3 { x, y, z },
110            )
111        }
112    }
113
114    fn send_to_player(&self, player: &str, channel: &str, payload: &[u8]) -> bool {
115        let s = srv!(self);
116        unsafe {
117            (s.send_to_player)(
118                s.ctx,
119                YogStr::from_str(player),
120                YogStr::from_str(channel),
121                payload.as_ptr(),
122                payload.len() as u32,
123            )
124        }
125    }
126
127    fn send_to_server(&self, channel: &str, payload: &[u8]) -> bool {
128        let s = srv!(self);
129        unsafe {
130            (s.send_to_server)(
131                s.ctx,
132                YogStr::from_str(channel),
133                payload.as_ptr(),
134                payload.len() as u32,
135            )
136        }
137    }
138
139    fn entity_teleport(&self, uuid: &str, x: f64, y: f64, z: f64) -> bool {
140        let s = srv!(self);
141        unsafe { (s.entity_teleport)(s.ctx, YogStr::from_str(uuid), yog_abi::YogVec3 { x, y, z }) }
142    }
143
144    fn entity_position(&self, uuid: &str) -> Option<(f64, f64, f64)> {
145        let s = srv!(self);
146        let mut out = yog_abi::YogVec3 {
147            x: 0.0,
148            y: 0.0,
149            z: 0.0,
150        };
151        if unsafe { (s.entity_position)(s.ctx, YogStr::from_str(uuid), &mut out) } {
152            Some((out.x, out.y, out.z))
153        } else {
154            None
155        }
156    }
157
158    fn entity_health(&self, uuid: &str) -> Option<f32> {
159        let s = srv!(self);
160        let mut hp = 0f32;
161        if unsafe { (s.entity_health)(s.ctx, YogStr::from_str(uuid), &mut hp) } {
162            Some(hp)
163        } else {
164            None
165        }
166    }
167
168    fn entity_set_health(&self, uuid: &str, health: f32) -> bool {
169        let s = srv!(self);
170        unsafe { (s.entity_set_health)(s.ctx, YogStr::from_str(uuid), health) }
171    }
172
173    fn entity_kill(&self, uuid: &str) -> bool {
174        let s = srv!(self);
175        unsafe { (s.entity_kill)(s.ctx, YogStr::from_str(uuid)) }
176    }
177
178    fn spawn_entity(
179        &self,
180        entity_type: &str,
181        dimension: &str,
182        x: f64,
183        y: f64,
184        z: f64,
185    ) -> Option<String> {
186        let s = srv!(self);
187        let owned = unsafe {
188            (s.spawn_entity)(
189                s.ctx,
190                YogStr::from_str(entity_type),
191                YogStr::from_str(dimension),
192                yog_abi::YogVec3 { x, y, z },
193            )
194        };
195
196        take_owned(s.free_str, owned)
197    }
198
199    fn entity_add_effect(
200        &self,
201        uuid: &str,
202        effect_id: &str,
203        duration_ticks: i32,
204        amplifier: u8,
205        show_particles: bool,
206    ) -> bool {
207        let s = srv!(self);
208        unsafe {
209            (s.entity_add_effect)(
210                s.ctx,
211                YogStr::from_str(uuid),
212                YogStr::from_str(effect_id),
213                duration_ticks,
214                amplifier,
215                show_particles,
216            )
217        }
218    }
219
220    fn entity_remove_effect(&self, uuid: &str, effect_id: &str) -> bool {
221        let s = srv!(self);
222        unsafe {
223            (s.entity_remove_effect)(s.ctx, YogStr::from_str(uuid), YogStr::from_str(effect_id))
224        }
225    }
226
227    fn entity_clear_effects(&self, uuid: &str) -> bool {
228        let s = srv!(self);
229        unsafe { (s.entity_clear_effects)(s.ctx, YogStr::from_str(uuid)) }
230    }
231
232    fn drop_loot(&self, table_id: &str, dimension: &str, x: f64, y: f64, z: f64) -> bool {
233        let s = srv!(self);
234        unsafe {
235            (s.drop_loot)(
236                s.ctx,
237                YogStr::from_str(table_id),
238                YogStr::from_str(dimension),
239                yog_abi::YogVec3 { x, y, z },
240            )
241        }
242    }
243
244    fn has_item_tag(&self, item_id: &str, tag_id: &str) -> bool {
245        let s = srv!(self);
246        unsafe { (s.has_item_tag)(s.ctx, YogStr::from_str(item_id), YogStr::from_str(tag_id)) }
247    }
248
249    fn has_block_tag(&self, block_id: &str, tag_id: &str) -> bool {
250        let s = srv!(self);
251        unsafe { (s.has_block_tag)(s.ctx, YogStr::from_str(block_id), YogStr::from_str(tag_id)) }
252    }
253
254    fn world_time(&self, dimension: &str) -> Option<i64> {
255        let s = srv!(self);
256        let mut t = 0i64;
257        if unsafe { (s.world_time)(s.ctx, YogStr::from_str(dimension), &mut t) } {
258            Some(t)
259        } else {
260            None
261        }
262    }
263
264    fn world_set_time(&self, dimension: &str, time: i64) -> bool {
265        let s = srv!(self);
266        unsafe { (s.set_time)(s.ctx, YogStr::from_str(dimension), time) }
267    }
268
269    fn world_is_raining(&self, dimension: &str) -> bool {
270        let s = srv!(self);
271        unsafe { (s.is_raining)(s.ctx, YogStr::from_str(dimension)) }
272    }
273
274    fn world_set_weather(&self, dimension: &str, raining: bool, duration_ticks: i32) -> bool {
275        let s = srv!(self);
276        unsafe { (s.set_weather)(s.ctx, YogStr::from_str(dimension), raining, duration_ticks) }
277    }
278
279    fn entity_velocity(&self, uuid: &str) -> Option<(f64, f64, f64)> {
280        let s = srv!(self);
281        let mut v = yog_abi::YogVec3 {
282            x: 0.0,
283            y: 0.0,
284            z: 0.0,
285        };
286        if unsafe { (s.entity_velocity)(s.ctx, YogStr::from_str(uuid), &mut v) } {
287            Some((v.x, v.y, v.z))
288        } else {
289            None
290        }
291    }
292
293    fn entity_set_velocity(&self, uuid: &str, vx: f64, vy: f64, vz: f64) -> bool {
294        let s = srv!(self);
295        unsafe {
296            (s.entity_set_velocity)(
297                s.ctx,
298                YogStr::from_str(uuid),
299                yog_abi::YogVec3 {
300                    x: vx,
301                    y: vy,
302                    z: vz,
303                },
304            )
305        }
306    }
307
308    fn entity_add_velocity(&self, uuid: &str, vx: f64, vy: f64, vz: f64) -> bool {
309        let s = srv!(self);
310        unsafe {
311            (s.entity_add_velocity)(
312                s.ctx,
313                YogStr::from_str(uuid),
314                yog_abi::YogVec3 {
315                    x: vx,
316                    y: vy,
317                    z: vz,
318                },
319            )
320        }
321    }
322
323    fn scoreboard_get(&self, objective: &str, player: &str) -> Option<i32> {
324        let s = srv!(self);
325        let mut score = 0i32;
326        if unsafe {
327            (s.scoreboard_get)(
328                s.ctx,
329                YogStr::from_str(objective),
330                YogStr::from_str(player),
331                &mut score,
332            )
333        } {
334            Some(score)
335        } else {
336            None
337        }
338    }
339
340    fn scoreboard_set(&self, objective: &str, player: &str, score: i32) -> bool {
341        let s = srv!(self);
342        unsafe {
343            (s.scoreboard_set)(
344                s.ctx,
345                YogStr::from_str(objective),
346                YogStr::from_str(player),
347                score,
348            )
349        }
350    }
351
352    fn scoreboard_add(&self, objective: &str, player: &str, delta: i32) -> Option<i32> {
353        let s = srv!(self);
354        let mut new_score = 0i32;
355        if unsafe {
356            (s.scoreboard_add)(
357                s.ctx,
358                YogStr::from_str(objective),
359                YogStr::from_str(player),
360                delta,
361                &mut new_score,
362            )
363        } {
364            Some(new_score)
365        } else {
366            None
367        }
368    }
369
370    fn game_dir(&self) -> String {
371        let s = srv!(self);
372        let owned = unsafe { (s.game_dir)(s.ctx) };
373        take_owned(s.free_str, owned).unwrap_or_default()
374    }
375
376    fn play_sound(
377        &self,
378        dimension: &str,
379        x: f64,
380        y: f64,
381        z: f64,
382        sound_id: &str,
383        volume: f32,
384        pitch: f32,
385    ) -> bool {
386        let s = srv!(self);
387        unsafe {
388            (s.play_sound)(
389                s.ctx,
390                YogStr::from_str(dimension),
391                yog_abi::YogVec3 { x, y, z },
392                YogStr::from_str(sound_id),
393                volume,
394                pitch,
395            )
396        }
397    }
398
399    fn play_sound_to_player(&self, player: &str, sound_id: &str, volume: f32, pitch: f32) -> bool {
400        let s = srv!(self);
401        unsafe {
402            (s.play_sound_player)(
403                s.ctx,
404                YogStr::from_str(player),
405                YogStr::from_str(sound_id),
406                volume,
407                pitch,
408            )
409        }
410    }
411
412    fn send_title(
413        &self,
414        player: &str,
415        title: &str,
416        subtitle: &str,
417        fadein: i32,
418        stay: i32,
419        fadeout: i32,
420    ) -> bool {
421        let s = srv!(self);
422        unsafe {
423            (s.send_title)(
424                s.ctx,
425                YogStr::from_str(player),
426                YogStr::from_str(title),
427                YogStr::from_str(subtitle),
428                fadein,
429                stay,
430                fadeout,
431            )
432        }
433    }
434
435    fn entity_rotation(&self, uuid: &str) -> Option<(f32, f32)> {
436        let s = srv!(self);
437        let mut out = yog_abi::YogVec3 {
438            x: 0.0,
439            y: 0.0,
440            z: 0.0,
441        };
442        let ok = unsafe { (s.entity_rotation)(s.ctx, YogStr::from_str(uuid), &mut out) };
443        if ok {
444            Some((out.x as f32, out.y as f32))
445        } else {
446            None
447        }
448    }
449
450    fn send_actionbar(&self, player: &str, message: &str) -> bool {
451        let s = srv!(self);
452        unsafe { (s.send_actionbar)(s.ctx, YogStr::from_str(player), YogStr::from_str(message)) }
453    }
454
455    fn kick_player(&self, player: &str, reason: &str) -> bool {
456        let s = srv!(self);
457        unsafe { (s.kick_player)(s.ctx, YogStr::from_str(player), YogStr::from_str(reason)) }
458    }
459
460    fn set_gamemode(&self, player: &str, gamemode: &str) -> bool {
461        let s = srv!(self);
462        unsafe { (s.set_gamemode)(s.ctx, YogStr::from_str(player), YogStr::from_str(gamemode)) }
463    }
464
465    fn bossbar_create(&self, id: &str, title: &str, color: &str, style: &str) -> bool {
466        let s = srv!(self);
467        unsafe {
468            (s.bossbar_create)(
469                s.ctx,
470                YogStr::from_str(id),
471                YogStr::from_str(title),
472                YogStr::from_str(color),
473                YogStr::from_str(style),
474            )
475        }
476    }
477
478    fn bossbar_remove(&self, id: &str) -> bool {
479        let s = srv!(self);
480        unsafe { (s.bossbar_remove)(s.ctx, YogStr::from_str(id)) }
481    }
482
483    fn bossbar_set_title(&self, id: &str, title: &str) -> bool {
484        let s = srv!(self);
485        unsafe { (s.bossbar_set_title)(s.ctx, YogStr::from_str(id), YogStr::from_str(title)) }
486    }
487
488    fn bossbar_set_progress(&self, id: &str, progress: f32) -> bool {
489        let s = srv!(self);
490        unsafe { (s.bossbar_set_progress)(s.ctx, YogStr::from_str(id), progress) }
491    }
492
493    fn bossbar_set_color(&self, id: &str, color: &str) -> bool {
494        let s = srv!(self);
495        unsafe { (s.bossbar_set_color)(s.ctx, YogStr::from_str(id), YogStr::from_str(color)) }
496    }
497
498    fn bossbar_add_player(&self, id: &str, player: &str) -> bool {
499        let s = srv!(self);
500        unsafe { (s.bossbar_add_player)(s.ctx, YogStr::from_str(id), YogStr::from_str(player)) }
501    }
502
503    fn bossbar_remove_player(&self, id: &str, player: &str) -> bool {
504        let s = srv!(self);
505        unsafe { (s.bossbar_remove_player)(s.ctx, YogStr::from_str(id), YogStr::from_str(player)) }
506    }
507
508    fn bossbar_set_visible(&self, id: &str, visible: bool) -> bool {
509        let s = srv!(self);
510        unsafe { (s.bossbar_set_visible)(s.ctx, YogStr::from_str(id), visible) }
511    }
512
513    fn online_players(&self) -> Vec<String> {
514        let s = srv!(self);
515        let owned = unsafe { (s.online_players)(s.ctx) };
516        let Some(text) = take_owned(s.free_str, owned) else {
517            return Vec::new();
518        };
519        if text.is_empty() {
520            Vec::new()
521        } else {
522            text.lines().map(str::to_owned).collect()
523        }
524    }
525
526    fn get_block_nbt(&self, dimension: &str, pos: yog_core::BlockPos) -> Option<String> {
527        let s = srv!(self);
528        let owned = unsafe {
529            (s.get_block_nbt)(
530                s.ctx,
531                YogStr::from_str(dimension),
532                yog_abi::YogBlockPos {
533                    x: pos.x,
534                    y: pos.y,
535                    z: pos.z,
536                },
537            )
538        };
539
540        take_owned(s.free_str, owned)
541    }
542
543    fn set_block_nbt(&self, dimension: &str, pos: yog_core::BlockPos, snbt: &str) -> bool {
544        let s = srv!(self);
545        unsafe {
546            (s.set_block_nbt)(
547                s.ctx,
548                YogStr::from_str(dimension),
549                yog_abi::YogBlockPos {
550                    x: pos.x,
551                    y: pos.y,
552                    z: pos.z,
553                },
554                YogStr::from_str(snbt),
555            )
556        }
557    }
558
559    fn get_inventory_slot(
560        &self,
561        dimension: &str,
562        pos: yog_core::BlockPos,
563        slot: u32,
564    ) -> Option<(String, u32, String)> {
565        let s = srv!(self);
566        let owned = unsafe {
567            (s.get_inventory_slot)(
568                s.ctx,
569                YogStr::from_str(dimension),
570                yog_abi::YogBlockPos {
571                    x: pos.x,
572                    y: pos.y,
573                    z: pos.z,
574                },
575                slot,
576            )
577        };
578        let text = take_owned(s.free_str, owned)?;
579        let mut it = text.splitn(3, '\t');
580        let item_id = it.next()?.to_owned();
581        let count = it.next()?.parse().ok()?;
582        let snbt = it.next().unwrap_or("{}").to_owned();
583        Some((item_id, count, snbt))
584    }
585
586    fn set_inventory_slot(
587        &self,
588        dimension: &str,
589        pos: yog_core::BlockPos,
590        slot: u32,
591        item_id: &str,
592        count: u32,
593        snbt: &str,
594    ) -> bool {
595        // The ABI's item id carries the SNBT after a tab.
596        let item = if snbt.is_empty() { item_id.to_string() } else { format!("{item_id}\t{snbt}") };
597        let s = srv!(self);
598        unsafe {
599            (s.set_inventory_slot)(
600                s.ctx,
601                YogStr::from_str(dimension),
602                yog_abi::YogBlockPos {
603                    x: pos.x,
604                    y: pos.y,
605                    z: pos.z,
606                },
607                slot,
608                YogStr::from_str(&item),
609                count,
610            )
611        }
612    }
613
614    fn player_inventory(&self, player: &str) -> Vec<(u32, String, u32)> {
615        let s = srv!(self);
616        let owned = unsafe { (s.player_inventory)(s.ctx, YogStr::from_str(player)) };
617        let Some(text) = take_owned(s.free_str, owned) else {
618            return Vec::new();
619        };
620        text.lines()
621            .filter_map(|line| {
622                let mut it = line.split('\t');
623                let slot: u32 = it.next()?.parse().ok()?;
624                let item_id = it.next()?.to_owned();
625                let count: u32 = it.next()?.parse().ok()?;
626                Some((slot, item_id, count))
627            })
628            .collect()
629    }
630
631    fn player_set_slot(&self, player: &str, slot: u32, item_id: &str, count: u32) -> bool {
632        let s = srv!(self);
633        unsafe {
634            (s.player_set_slot)(
635                s.ctx,
636                YogStr::from_str(player),
637                slot,
638                YogStr::from_str(item_id),
639                count,
640            )
641        }
642    }
643
644    fn teleport_to_dim(&self, player: &str, dimension: &str, x: f64, y: f64, z: f64) -> bool {
645        let s = srv!(self);
646        unsafe {
647            (s.player_teleport_dim)(
648                s.ctx,
649                YogStr::from_str(player),
650                YogStr::from_str(dimension),
651                yog_abi::YogVec3 { x, y, z },
652            )
653        }
654    }
655
656    fn entity_teleport_to_dim(&self, uuid: &str, dimension: &str, x: f64, y: f64, z: f64) -> bool {
657        let s = srv!(self);
658        unsafe {
659            (s.entity_teleport_dim)(
660                s.ctx,
661                YogStr::from_str(uuid),
662                YogStr::from_str(dimension),
663                yog_abi::YogVec3 { x, y, z },
664            )
665        }
666    }
667
668    fn world_entity_count(&self, dimension: &str, entity_type: &str) -> i32 {
669        let s = srv!(self);
670        unsafe {
671            (s.world_entity_count)(
672                s.ctx,
673                YogStr::from_str(dimension),
674                YogStr::from_str(entity_type),
675            )
676        }
677    }
678
679    fn entity_get_nbt(&self, uuid: &str) -> Option<String> {
680        let s = srv!(self);
681        let owned = unsafe { (s.entity_get_nbt)(s.ctx, YogStr::from_str(uuid)) };
682
683        take_owned(s.free_str, owned)
684    }
685
686    fn entity_set_nbt(&self, uuid: &str, snbt: &str) -> bool {
687        let s = srv!(self);
688        unsafe { (s.entity_set_nbt)(s.ctx, YogStr::from_str(uuid), YogStr::from_str(snbt)) }
689    }
690
691    fn spawn_particles(
692        &self,
693        dimension: &str,
694        x: f64,
695        y: f64,
696        z: f64,
697        particle_type: &str,
698        count: i32,
699        dx: f64,
700        dy: f64,
701        dz: f64,
702        speed: f64,
703    ) -> bool {
704        let s = srv!(self);
705        unsafe {
706            (s.spawn_particles)(
707                s.ctx,
708                YogStr::from_str(dimension),
709                yog_abi::YogVec3 { x, y, z },
710                YogStr::from_str(particle_type),
711                count,
712                dx,
713                dy,
714                dz,
715                speed,
716            )
717        }
718    }
719
720    fn entity_attribute_get(&self, uuid: &str, attribute_id: &str) -> Option<f64> {
721        let s = srv!(self);
722        let v = unsafe {
723            (s.entity_attribute_get)(
724                s.ctx,
725                YogStr::from_str(uuid),
726                YogStr::from_str(attribute_id),
727            )
728        };
729        if v.is_nan() { None } else { Some(v) }
730    }
731
732    fn entity_attribute_set(&self, uuid: &str, attribute_id: &str, value: f64) -> bool {
733        let s = srv!(self);
734        unsafe {
735            (s.entity_attribute_set)(
736                s.ctx,
737                YogStr::from_str(uuid),
738                YogStr::from_str(attribute_id),
739                value,
740            )
741        }
742    }
743
744    fn get_held_item_nbt(&self, player: &str) -> Option<String> {
745        let s = srv!(self);
746        let owned = unsafe { (s.get_held_item_nbt)(s.ctx, YogStr::from_str(player)) };
747
748        take_owned(s.free_str, owned)
749    }
750
751    fn set_held_item_nbt(&self, player: &str, snbt: &str) -> bool {
752        let s = srv!(self);
753        unsafe { (s.set_held_item_nbt)(s.ctx, YogStr::from_str(player), YogStr::from_str(snbt)) }
754    }
755
756    fn get_offhand_item_nbt(&self, player: &str) -> Option<String> {
757        let s = srv!(self);
758        let owned = unsafe { (s.get_offhand_item_nbt)(s.ctx, YogStr::from_str(player)) };
759
760        take_owned(s.free_str, owned)
761    }
762
763    fn set_offhand_item_nbt(&self, player: &str, snbt: &str) -> bool {
764        let s = srv!(self);
765        unsafe { (s.set_offhand_item_nbt)(s.ctx, YogStr::from_str(player), YogStr::from_str(snbt)) }
766    }
767
768    fn get_slot_item(&self, player: &str, slot: u32) -> Option<(String, u32, String)> {
769        let s = srv!(self);
770        let owned = unsafe { (s.get_slot_item)(s.ctx, YogStr::from_str(player), slot) };
771        let text = take_owned(s.free_str, owned)?;
772        let mut it = text.splitn(3, '\t');
773        let item_id = it.next()?.to_owned();
774        let count: u32 = it.next()?.parse().ok()?;
775        let nbt = it.next().unwrap_or("{}").to_owned();
776        Some((item_id, count, nbt))
777    }
778
779    fn set_slot_item(
780        &self,
781        player: &str,
782        slot: u32,
783        item_id: &str,
784        count: u32,
785        snbt: &str,
786    ) -> bool {
787        let s = srv!(self);
788        unsafe {
789            (s.set_slot_item)(
790                s.ctx,
791                YogStr::from_str(player),
792                slot,
793                YogStr::from_str(item_id),
794                count,
795                YogStr::from_str(snbt),
796            )
797        }
798    }
799
800    // ── world queries & effects (ABI minor 1) ────────────────────────────────
801
802    fn entity_info(&self, uuid: &str) -> Option<yog_core::EntityInfo> {
803        let s = srv!(self);
804        let owned = unsafe { (s.entity_info)(s.ctx, YogStr::from_str(uuid)) };
805        take_owned(s.free_str, owned).and_then(|l| yog_core::EntityInfo::decode(&l))
806    }
807
808    fn entities_in_box(
809        &self,
810        dimension: &str,
811        min: (f64, f64, f64),
812        max: (f64, f64, f64),
813    ) -> Vec<String> {
814        let s = srv!(self);
815        let owned =
816            unsafe { (s.entities_in_box)(s.ctx, YogStr::from_str(dimension), v3(min), v3(max)) };
817        take_owned(s.free_str, owned)
818            .map(|t| {
819                t.lines()
820                    .filter(|l| !l.is_empty())
821                    .map(str::to_owned)
822                    .collect()
823            })
824            .unwrap_or_default()
825    }
826
827    fn raycast_block(
828        &self,
829        dimension: &str,
830        from: (f64, f64, f64),
831        to: (f64, f64, f64),
832    ) -> Option<yog_core::BlockHit> {
833        let s = srv!(self);
834        let owned =
835            unsafe { (s.raycast_block)(s.ctx, YogStr::from_str(dimension), v3(from), v3(to)) };
836        take_owned(s.free_str, owned).and_then(|l| yog_core::BlockHit::decode(&l))
837    }
838
839    fn raycast_entity(
840        &self,
841        dimension: &str,
842        from: (f64, f64, f64),
843        to: (f64, f64, f64),
844        exclude: &str,
845    ) -> Option<String> {
846        let s = srv!(self);
847        let owned = unsafe {
848            (s.raycast_entity)(
849                s.ctx,
850                YogStr::from_str(dimension),
851                v3(from),
852                v3(to),
853                YogStr::from_str(exclude),
854            )
855        };
856        take_owned(s.free_str, owned).filter(|u| !u.is_empty())
857    }
858
859    fn block_info(&self, dimension: &str, pos: yog_core::BlockPos) -> Option<yog_core::BlockInfo> {
860        let s = srv!(self);
861        let owned = unsafe { (s.block_info)(s.ctx, YogStr::from_str(dimension), bp(pos)) };
862        take_owned(s.free_str, owned).and_then(|l| yog_core::BlockInfo::decode(&l))
863    }
864
865    fn break_block(
866        &self,
867        dimension: &str,
868        pos: yog_core::BlockPos,
869        drop: bool,
870        breaker: &str,
871    ) -> bool {
872        let s = srv!(self);
873        unsafe {
874            (s.break_block)(
875                s.ctx,
876                YogStr::from_str(dimension),
877                bp(pos),
878                drop,
879                YogStr::from_str(breaker),
880            )
881        }
882    }
883
884    fn place_block_from_slot(
885        &self,
886        player: &str,
887        slot: u32,
888        dimension: &str,
889        pos: yog_core::BlockPos,
890    ) -> bool {
891        let s = srv!(self);
892        unsafe {
893            (s.place_block_from_slot)(
894                s.ctx,
895                YogStr::from_str(player),
896                slot,
897                YogStr::from_str(dimension),
898                bp(pos),
899            )
900        }
901    }
902
903    fn bonemeal(&self, dimension: &str, pos: yog_core::BlockPos) -> bool {
904        let s = srv!(self);
905        unsafe { (s.bonemeal)(s.ctx, YogStr::from_str(dimension), bp(pos)) }
906    }
907
908    fn explode(
909        &self,
910        dimension: &str,
911        x: f64,
912        y: f64,
913        z: f64,
914        power: f32,
915        fire: bool,
916        source: &str,
917    ) -> bool {
918        let s = srv!(self);
919        unsafe {
920            (s.explode)(
921                s.ctx,
922                YogStr::from_str(dimension),
923                v3((x, y, z)),
924                power,
925                fire,
926                YogStr::from_str(source),
927            )
928        }
929    }
930
931    fn tellraw(&self, player: &str, json: &str) -> bool {
932        let s = srv!(self);
933        unsafe { (s.tellraw)(s.ctx, YogStr::from_str(player), YogStr::from_str(json)) }
934    }
935
936    fn entity_damage(&self, uuid: &str, amount: f32, damage_type: &str, attacker: &str) -> bool {
937        let s = srv!(self);
938        unsafe {
939            (s.entity_damage)(
940                s.ctx,
941                YogStr::from_str(uuid),
942                amount,
943                YogStr::from_str(damage_type),
944                YogStr::from_str(attacker),
945            )
946        }
947    }
948
949    fn entity_set_fire_ticks(&self, uuid: &str, ticks: i32) -> bool {
950        let s = srv!(self);
951        unsafe { (s.entity_set_fire_ticks)(s.ctx, YogStr::from_str(uuid), ticks) }
952    }
953
954    fn player_add_xp(&self, player: &str, amount: i32) -> bool {
955        let s = srv!(self);
956        unsafe { (s.player_add_xp)(s.ctx, YogStr::from_str(player), amount) }
957    }
958
959    fn player_set_may_fly(&self, player: &str, may_fly: bool) -> bool {
960        let s = srv!(self);
961        unsafe { (s.player_set_may_fly)(s.ctx, YogStr::from_str(player), may_fly) }
962    }
963
964    fn player_info(&self, player: &str) -> Option<yog_core::PlayerInfo> {
965        let s = srv!(self);
966        let owned = unsafe { (s.player_info)(s.ctx, YogStr::from_str(player)) };
967        take_owned(s.free_str, owned).and_then(|l| yog_core::PlayerInfo::decode(&l))
968    }
969
970    fn spawn_item(
971        &self,
972        dimension: &str,
973        pos: (f64, f64, f64),
974        vel: (f64, f64, f64),
975        item_id: &str,
976        count: u32,
977        snbt: &str,
978    ) -> Option<String> {
979        let s = srv!(self);
980        let owned = unsafe {
981            (s.spawn_item)(
982                s.ctx,
983                YogStr::from_str(dimension),
984                v3(pos),
985                v3(vel),
986                YogStr::from_str(item_id),
987                count,
988                YogStr::from_str(snbt),
989            )
990        };
991        take_owned(s.free_str, owned).filter(|u| !u.is_empty())
992    }
993
994    fn item_entity_stack(&self, uuid: &str) -> Option<(String, u32, String)> {
995        let s = srv!(self);
996        let owned = unsafe { (s.item_entity_stack)(s.ctx, YogStr::from_str(uuid)) };
997        let text = take_owned(s.free_str, owned)?;
998        let mut it = text.splitn(3, '\t');
999        let item_id = it.next()?.to_owned();
1000        let count = it.next()?.parse().ok()?;
1001        let nbt = it.next().unwrap_or("{}").to_owned();
1002        Some((item_id, count, nbt))
1003    }
1004
1005    fn item_entity_set_stack(&self, uuid: &str, item_id: &str, count: u32, snbt: &str) -> bool {
1006        let s = srv!(self);
1007        unsafe {
1008            (s.item_entity_set_stack)(
1009                s.ctx,
1010                YogStr::from_str(uuid),
1011                YogStr::from_str(item_id),
1012                count,
1013                YogStr::from_str(snbt),
1014            )
1015        }
1016    }
1017
1018    fn actionbar_json(&self, player: &str, json: &str) -> bool {
1019        let s = srv!(self);
1020        unsafe { (s.actionbar_json)(s.ctx, YogStr::from_str(player), YogStr::from_str(json)) }
1021    }
1022
1023    fn use_item_on_block(
1024        &self,
1025        dimension: &str,
1026        pos: yog_core::BlockPos,
1027        face: yog_core::Face,
1028        item_id: &str,
1029        player: &str,
1030    ) -> bool {
1031        let s = srv!(self);
1032        unsafe {
1033            (s.use_item_on_block)(
1034                s.ctx,
1035                YogStr::from_str(dimension),
1036                bp(pos),
1037                face.index(),
1038                YogStr::from_str(item_id),
1039                YogStr::from_str(player),
1040            )
1041        }
1042    }
1043
1044    fn pour_fluid(&self, dimension: &str, pos: yog_core::BlockPos, bucket_item_id: &str) -> bool {
1045        let s = srv!(self);
1046        unsafe {
1047            (s.pour_fluid)(
1048                s.ctx,
1049                YogStr::from_str(dimension),
1050                bp(pos),
1051                YogStr::from_str(bucket_item_id),
1052            )
1053        }
1054    }
1055
1056    fn has_entity_tag(&self, entity_type: &str, tag_id: &str) -> bool {
1057        let s = srv!(self);
1058        unsafe {
1059            (s.has_entity_tag)(
1060                s.ctx,
1061                YogStr::from_str(entity_type),
1062                YogStr::from_str(tag_id),
1063            )
1064        }
1065    }
1066
1067    fn item_block(&self, item_id: &str) -> Option<String> {
1068        let s = srv!(self);
1069        let owned = unsafe { (s.item_block)(s.ctx, YogStr::from_str(item_id)) };
1070        take_owned(s.free_str, owned).filter(|b| !b.is_empty())
1071    }
1072
1073    fn place_feature(&self, dimension: &str, pos: yog_core::BlockPos, feature_id: &str) -> bool {
1074        let s = srv!(self);
1075        unsafe {
1076            (s.place_feature)(
1077                s.ctx,
1078                YogStr::from_str(dimension),
1079                bp(pos),
1080                YogStr::from_str(feature_id),
1081            )
1082        }
1083    }
1084
1085    fn set_item_cooldown(&self, player: &str, item_id: &str, ticks: u32) -> bool {
1086        let s = srv!(self);
1087        unsafe { (s.set_item_cooldown)(s.ctx, YogStr::from_str(player), YogStr::from_str(item_id), ticks.min(i32::MAX as u32) as i32) }
1088    }
1089
1090    fn entity_teleport_with_passengers(&self, uuid: &str, dimension: &str, x: f64, y: f64, z: f64) -> bool {
1091        let s = srv!(self);
1092        unsafe {
1093            (s.entity_teleport_with_passengers)(
1094                s.ctx,
1095                YogStr::from_str(uuid),
1096                YogStr::from_str(dimension),
1097                yog_abi::YogVec3 { x, y, z },
1098            )
1099        }
1100    }
1101
1102    fn redstone_power(&self, dimension: &str, pos: yog_core::BlockPos) -> Option<u8> {
1103        let s = srv!(self);
1104        let p = unsafe { (s.redstone_power)(s.ctx, YogStr::from_str(dimension), bp(pos)) };
1105        (0..=15).contains(&p).then_some(p as u8)
1106    }
1107
1108    fn set_redstone_output(&self, dimension: &str, pos: yog_core::BlockPos, level: u8) -> bool {
1109        let s = srv!(self);
1110        unsafe { (s.set_redstone_output)(s.ctx, YogStr::from_str(dimension), bp(pos), level.min(15) as i32) }
1111    }
1112
1113    fn get_block_state(&self, dimension: &str, pos: yog_core::BlockPos) -> Option<String> {
1114        let s = srv!(self);
1115        let owned = unsafe { (s.get_block_state)(s.ctx, YogStr::from_str(dimension), bp(pos)) };
1116        take_owned(s.free_str, owned).filter(|b| !b.is_empty())
1117    }
1118
1119    fn set_block_state(&self, dimension: &str, pos: yog_core::BlockPos, state: &str) -> bool {
1120        let s = srv!(self);
1121        unsafe { (s.set_block_state)(s.ctx, YogStr::from_str(dimension), bp(pos), YogStr::from_str(state)) }
1122    }
1123
1124    fn world_is_thundering(&self, dimension: &str) -> bool {
1125        let s = srv!(self);
1126        unsafe { (s.world_is_thundering)(s.ctx, YogStr::from_str(dimension)) }
1127    }
1128
1129    fn world_set_thunder(&self, dimension: &str, thundering: bool, duration_ticks: i32) -> bool {
1130        let s = srv!(self);
1131        unsafe { (s.world_set_thunder)(s.ctx, YogStr::from_str(dimension), thundering, duration_ticks) }
1132    }
1133
1134    fn fill_region(&self, dimension: &str, from: yog_core::BlockPos, to: yog_core::BlockPos, state: &str) -> Option<u32> {
1135        let s = srv!(self);
1136        let n = unsafe { (s.fill_region)(s.ctx, YogStr::from_str(dimension), bp(from), bp(to), YogStr::from_str(state)) };
1137        u32::try_from(n).ok()
1138    }
1139
1140    fn scan_region(&self, dimension: &str, from: yog_core::BlockPos, to: yog_core::BlockPos) -> Vec<(yog_core::BlockPos, String)> {
1141        let s = srv!(self);
1142        let owned = unsafe { (s.scan_region)(s.ctx, YogStr::from_str(dimension), bp(from), bp(to)) };
1143        let Some(text) = take_owned(s.free_str, owned) else {
1144            return Vec::new();
1145        };
1146        text.lines()
1147            .filter_map(|line| {
1148                let mut it = line.splitn(4, ' ');
1149                let (x, y, z) = (it.next()?.parse().ok()?, it.next()?.parse().ok()?, it.next()?.parse().ok()?);
1150                Some((yog_core::BlockPos { x, y, z }, it.next()?.to_string()))
1151            })
1152            .collect()
1153    }
1154}
1155
1156/// Copy a runtime-owned string out and free it; `None` for NONE.
1157pub(crate) fn take_owned(
1158    free_str: unsafe extern "C" fn(ptr: *mut u8, len: u32),
1159    owned: yog_abi::YogOwnedStr,
1160) -> Option<String> {
1161    if owned.is_none() {
1162        return None;
1163    }
1164    // SAFETY: a non-NONE owned string is `len` valid bytes until freed.
1165    let text = unsafe {
1166        String::from_utf8_lossy(std::slice::from_raw_parts(owned.ptr, owned.len as usize))
1167            .into_owned()
1168    };
1169    unsafe { free_str(owned.ptr, owned.len) };
1170    Some(text)
1171}
1172
1173fn v3((x, y, z): (f64, f64, f64)) -> yog_abi::YogVec3 {
1174    yog_abi::YogVec3 { x, y, z }
1175}
1176
1177fn bp(pos: yog_core::BlockPos) -> yog_abi::YogBlockPos {
1178    yog_abi::YogBlockPos {
1179        x: pos.x,
1180        y: pos.y,
1181        z: pos.z,
1182    }
1183}
1184
1185// ── Trampoline helpers ────────────────────────────────────────────────────────
1186//
1187// A panic must never unwind out of a trampoline: the runtime calls them
1188// through `extern "C"`, so it would abort the whole game. `guard` stops it
1189// at the boundary — the panic message is already in the log — and the
1190// event goes on as if the mod hadn't handled it.
1191
1192fn guard<R>(fallback: R, call: impl FnOnce() -> R) -> R {
1193    std::panic::catch_unwind(std::panic::AssertUnwindSafe(call)).unwrap_or_else(|_| {
1194        crate::error!("a mod's callback panicked (see above); carrying on without it");
1195        fallback
1196    })
1197}
1198//
1199// Each trampoline is a `unsafe extern "C" fn` that:
1200//   1. Casts `ud` back to the original boxed closure.
1201//   2. Converts ABI C structs to Rust event types.
1202//   3. Builds a `CServer` from the `*const YogServer`.
1203//   4. Calls the closure.
1204//
1205// Closures are Box::into_raw'd in Registry methods — they are INTENTIONALLY
1206// leaked and live for the process lifetime.
1207
1208// ── Trampoline helpers ────────────────────────────────────────────────────────
1209//
1210// All phased event trampolines share the same pattern:
1211//   `phase: u8`  0 = EventPhase::Pre, 1 = EventPhase::Post
1212//   Return value is meaningful only in Pre phase.
1213
1214macro_rules! trampoline_phased {
1215    ($name:ident, $abi_ev:ty, $rust_ev:ty, |$ev:ident| $build:expr_2021) => {
1216        unsafe extern "C" fn $name<F>(
1217            ud: *mut c_void,
1218            srv: *const YogServer,
1219            ev: *const $abi_ev,
1220            phase: u8,
1221        ) -> bool
1222        where
1223            F: Fn(&$rust_ev, EventPhase, &dyn Server) -> bool + Send + Sync,
1224        {
1225            unsafe {
1226                let f = &*(ud as *const F);
1227                let $ev = &*ev;
1228                let rust_ev = $build;
1229                let p = if phase == 0 {
1230                    EventPhase::Pre
1231                } else {
1232                    EventPhase::Post
1233                };
1234                guard(true, || f(&rust_ev, p, &CServer(srv)))
1235            }
1236        }
1237    };
1238}
1239
1240trampoline_phased!(
1241    trampoline_block_break,
1242    YogBlockBreakEvent,
1243    BlockBreakEvent,
1244    |ev| BlockBreakEvent {
1245        player_name: ev.player.as_str().to_owned(),
1246        block_id: ev.block.as_str().to_owned(),
1247        pos: yog_core::BlockPos {
1248            x: ev.pos.x,
1249            y: ev.pos.y,
1250            z: ev.pos.z
1251        },
1252        dimension: ev.dimension.as_str().to_owned(),
1253    }
1254);
1255
1256trampoline_phased!(trampoline_chat, YogChatEvent, ChatEvent, |ev| ChatEvent {
1257    player_name: ev.player.as_str().to_owned(),
1258    message: ev.message.as_str().to_owned(),
1259    dimension: ev.dimension.as_str().to_owned(),
1260});
1261
1262trampoline_phased!(
1263    trampoline_player_join,
1264    YogPlayerEvent,
1265    PlayerJoinEvent,
1266    |ev| PlayerJoinEvent {
1267        player_name: ev.player.as_str().to_owned(),
1268        uuid: ev.uuid.as_str().to_owned(),
1269        dimension: ev.dimension.as_str().to_owned(),
1270    }
1271);
1272
1273trampoline_phased!(
1274    trampoline_player_leave,
1275    YogPlayerEvent,
1276    PlayerLeaveEvent,
1277    |ev| PlayerLeaveEvent {
1278        player_name: ev.player.as_str().to_owned(),
1279        uuid: ev.uuid.as_str().to_owned(),
1280        dimension: ev.dimension.as_str().to_owned(),
1281    }
1282);
1283
1284trampoline_phased!(trampoline_use_item, YogUseItemEvent, UseItemEvent, |ev| {
1285    UseItemEvent {
1286        player_name: ev.player.as_str().to_owned(),
1287        item_id: ev.item.as_str().to_owned(),
1288        sneaking: ev.sneaking,
1289        dimension: ev.dimension.as_str().to_owned(),
1290    }
1291});
1292
1293trampoline_phased!(
1294    trampoline_use_block,
1295    YogUseBlockEvent,
1296    UseBlockEvent,
1297    |ev| UseBlockEvent {
1298        player_name: ev.player.as_str().to_owned(),
1299        block_id: ev.block.as_str().to_owned(),
1300        pos: yog_core::BlockPos {
1301            x: ev.pos.x,
1302            y: ev.pos.y,
1303            z: ev.pos.z
1304        },
1305        dimension: ev.dimension.as_str().to_owned(),
1306    }
1307);
1308
1309trampoline_phased!(
1310    trampoline_attack_entity,
1311    YogAttackEntityEvent,
1312    AttackEntityEvent,
1313    |ev| AttackEntityEvent {
1314        player_name: ev.player.as_str().to_owned(),
1315        target_type: ev.target_type.as_str().to_owned(),
1316        target_uuid: ev.target_uuid.as_str().to_owned(),
1317        dimension: ev.dimension.as_str().to_owned(),
1318    }
1319);
1320
1321trampoline_phased!(
1322    trampoline_entity_damage,
1323    YogEntityDamageEvent,
1324    EntityDamageEvent,
1325    |ev| EntityDamageEvent {
1326        entity_type: ev.entity_type.as_str().to_owned(),
1327        uuid: ev.uuid.as_str().to_owned(),
1328        amount: ev.amount,
1329        source: ev.source.as_str().to_owned(),
1330        dimension: ev.dimension.as_str().to_owned(),
1331    }
1332);
1333
1334trampoline_phased!(
1335    trampoline_entity_death,
1336    YogEntityDeathEvent,
1337    EntityDeathEvent,
1338    |ev| EntityDeathEvent {
1339        entity_type: ev.entity_type.as_str().to_owned(),
1340        uuid: ev.uuid.as_str().to_owned(),
1341        source: ev.source.as_str().to_owned(),
1342        dimension: ev.dimension.as_str().to_owned(),
1343    }
1344);
1345
1346trampoline_phased!(
1347    trampoline_entity_spawn,
1348    YogEntitySpawnEvent,
1349    EntitySpawnEvent,
1350    |ev| EntitySpawnEvent {
1351        entity_type: ev.entity_type.as_str().to_owned(),
1352        uuid: ev.uuid.as_str().to_owned(),
1353        dimension: ev.dimension.as_str().to_owned(),
1354    }
1355);
1356
1357trampoline_phased!(
1358    trampoline_place_block,
1359    YogPlaceBlockEvent,
1360    PlaceBlockEvent,
1361    |ev| PlaceBlockEvent {
1362        player_name: ev.player.as_str().to_owned(),
1363        block_id: ev.block.as_str().to_owned(),
1364        pos: yog_core::BlockPos {
1365            x: ev.pos.x,
1366            y: ev.pos.y,
1367            z: ev.pos.z
1368        },
1369        dimension: ev.dimension.as_str().to_owned(),
1370    }
1371);
1372
1373trampoline_phased!(
1374    trampoline_player_death,
1375    YogPlayerDeathEvent,
1376    PlayerDeathEvent,
1377    |ev| PlayerDeathEvent {
1378        player_name: ev.player.as_str().to_owned(),
1379        uuid: ev.uuid.as_str().to_owned(),
1380        source: ev.source.as_str().to_owned(),
1381        dimension: ev.dimension.as_str().to_owned(),
1382    }
1383);
1384
1385trampoline_phased!(
1386    trampoline_player_respawn,
1387    YogPlayerRespawnEvent,
1388    PlayerRespawnEvent,
1389    |ev| PlayerRespawnEvent {
1390        player_name: ev.player.as_str().to_owned(),
1391        uuid: ev.uuid.as_str().to_owned(),
1392        at_anchor: ev.at_anchor,
1393        dimension: ev.dimension.as_str().to_owned(),
1394    }
1395);
1396
1397trampoline_phased!(
1398    trampoline_advancement,
1399    YogAdvancementEvent,
1400    AdvancementEvent,
1401    |ev| AdvancementEvent {
1402        player_name: ev.player.as_str().to_owned(),
1403        uuid: ev.uuid.as_str().to_owned(),
1404        advancement_id: ev.advancement.as_str().to_owned(),
1405        dimension: ev.dimension.as_str().to_owned(),
1406    }
1407);
1408
1409trampoline_phased!(
1410    trampoline_entity_interact,
1411    YogEntityInteractEvent,
1412    EntityInteractEvent,
1413    |ev| EntityInteractEvent {
1414        player_name: ev.player.as_str().to_owned(),
1415        player_uuid: ev.player_uuid.as_str().to_owned(),
1416        entity_type: ev.entity_type.as_str().to_owned(),
1417        entity_uuid: ev.entity_uuid.as_str().to_owned(),
1418        hand: ev.hand.as_str().to_owned(),
1419        dimension: ev.dimension.as_str().to_owned(),
1420    }
1421);
1422
1423trampoline_phased!(trampoline_craft, YogCraftEvent, CraftEvent, |ev| {
1424    CraftEvent {
1425        player_name: ev.player.as_str().to_owned(),
1426        player_uuid: ev.player_uuid.as_str().to_owned(),
1427        result_item: ev.result_item.as_str().to_owned(),
1428        result_count: ev.result_count,
1429        dimension: ev.dimension.as_str().to_owned(),
1430    }
1431});
1432
1433trampoline_phased!(
1434    trampoline_explosion,
1435    YogExplosionEvent,
1436    ExplosionEvent,
1437    |ev| ExplosionEvent {
1438        dimension: ev.dimension.as_str().to_owned(),
1439        x: ev.x,
1440        y: ev.y,
1441        z: ev.z,
1442        power: ev.power,
1443        cause_uuid: ev.cause_uuid.as_str().to_owned(),
1444    }
1445);
1446
1447trampoline_phased!(
1448    trampoline_item_pickup,
1449    YogItemPickupEvent,
1450    ItemPickupEvent,
1451    |ev| ItemPickupEvent {
1452        player_name: ev.player.as_str().to_owned(),
1453        player_uuid: ev.player_uuid.as_str().to_owned(),
1454        item_id: ev.item_id.as_str().to_owned(),
1455        item_count: ev.item_count,
1456        entity_uuid: ev.entity_uuid.as_str().to_owned(),
1457        dimension: ev.dimension.as_str().to_owned(),
1458    }
1459);
1460
1461trampoline_phased!(
1462    trampoline_player_move,
1463    YogPlayerMoveEvent,
1464    PlayerMoveEvent,
1465    |ev| PlayerMoveEvent {
1466        player_name: ev.player.as_str().to_owned(),
1467        player_uuid: ev.player_uuid.as_str().to_owned(),
1468        x: ev.x,
1469        y: ev.y,
1470        z: ev.z,
1471        yaw: ev.yaw,
1472        pitch: ev.pitch,
1473        dimension: ev.dimension.as_str().to_owned(),
1474    }
1475);
1476
1477trampoline_phased!(
1478    trampoline_container_open,
1479    YogContainerOpenEvent,
1480    ContainerOpenEvent,
1481    |ev| ContainerOpenEvent {
1482        player_name: ev.player.as_str().to_owned(),
1483        player_uuid: ev.player_uuid.as_str().to_owned(),
1484        container_type: ev.container_type.as_str().to_owned(),
1485        dimension: ev.dimension.as_str().to_owned(),
1486    }
1487);
1488
1489trampoline_phased!(
1490    trampoline_container_close,
1491    YogContainerCloseEvent,
1492    ContainerCloseEvent,
1493    |ev| ContainerCloseEvent {
1494        player_name: ev.player.as_str().to_owned(),
1495        player_uuid: ev.player_uuid.as_str().to_owned(),
1496        dimension: ev.dimension.as_str().to_owned(),
1497    }
1498);
1499
1500trampoline_phased!(
1501    trampoline_projectile_hit,
1502    YogProjectileHitEvent,
1503    ProjectileHitEvent,
1504    |ev| ProjectileHitEvent {
1505        projectile_type: ev.projectile_type.as_str().to_owned(),
1506        projectile_uuid: ev.projectile_uuid.as_str().to_owned(),
1507        shooter_uuid: ev.shooter_uuid.as_str().to_owned(),
1508        hit_type: ev.hit_type.as_str().to_owned(),
1509        hit_entity_uuid: ev.hit_entity_uuid.as_str().to_owned(),
1510        x: ev.x,
1511        y: ev.y,
1512        z: ev.z,
1513        dimension: ev.dimension.as_str().to_owned(),
1514    }
1515);
1516
1517unsafe extern "C" fn trampoline_server_fn<F>(ud: *mut c_void, srv: *const YogServer)
1518where
1519    F: Fn(&dyn Server) + Send + Sync,
1520{
1521    unsafe {
1522        let f = &*(ud as *const F);
1523        guard((), || f(&CServer(srv)));
1524    }
1525}
1526
1527unsafe extern "C" fn trampoline_packet<F>(
1528    ud: *mut c_void,
1529    srv: *const YogServer,
1530    ev: *const YogPacketEvent,
1531) where
1532    F: Fn(&PacketEvent, &dyn Server) + Send + Sync,
1533{
1534    unsafe {
1535        let f = &*(ud as *const F);
1536        let ev = &*ev;
1537        let rust_ev = PacketEvent {
1538            channel: ev.channel.as_str().to_owned(),
1539            player: ev.player.as_str().to_owned(),
1540            payload: std::slice::from_raw_parts(ev.payload, ev.payload_len as usize).to_vec(),
1541        };
1542        guard((), || f(&rust_ev, &CServer(srv)));
1543    }
1544}
1545
1546unsafe extern "C" fn trampoline_command<F>(
1547    ud: *mut c_void,
1548    srv: *const YogServer,
1549    ev: *const YogCommandEvent,
1550    reply_buf: *mut u8,
1551    reply_cap: u32,
1552    reply_len: *mut u32,
1553) where
1554    F: Fn(&CommandContext, &dyn Server) -> Option<String> + Send + Sync,
1555{
1556    unsafe {
1557        let f = &*(ud as *const F);
1558        let ev = &*ev;
1559        let ctx = CommandContext {
1560            name: ev.name.as_str().to_owned(),
1561            args: ev.args.as_str().to_owned(),
1562            source: ev.source.as_str().to_owned(),
1563            uuid: ev.uuid.as_str().to_owned(),
1564            dimension: ev.dimension.as_str().to_owned(),
1565        };
1566        *reply_len = 0;
1567        if let Some(reply) = guard(None, || f(&ctx, &CServer(srv))) {
1568            let bytes = reply.as_bytes();
1569            let n = bytes.len().min(reply_cap as usize);
1570            std::ptr::copy_nonoverlapping(bytes.as_ptr(), reply_buf, n);
1571            *reply_len = n as u32;
1572        }
1573    }
1574}
1575
1576unsafe extern "C" fn trampoline_scheduled<F>(ud: *mut c_void, srv: *const YogServer)
1577where
1578    F: Fn(&dyn Server) + Send + Sync,
1579{
1580    unsafe {
1581        let f = &*(ud as *const F);
1582        guard((), || f(&CServer(srv)));
1583    }
1584}
1585
1586// ── ABI minor 10 — client-side trampolines ────────────────────────────────────
1587
1588unsafe extern "C" fn trampoline_client_tick<F>(ud: *mut c_void)
1589where
1590    F: Fn(&ClientTickEvent) + Send + Sync,
1591{
1592    unsafe {
1593        let f = &*(ud as *const F);
1594        guard((), || f(&ClientTickEvent {}));
1595    }
1596}
1597
1598unsafe extern "C" fn trampoline_hud_render<F>(ud: *mut c_void, gfx: *const YogGfxApi)
1599where
1600    F: Fn(&GfxContext) + Send + Sync,
1601{
1602    unsafe {
1603        let f = &*(ud as *const F);
1604        guard((), || f(&GfxContext::from_raw(gfx)));
1605    }
1606}
1607
1608unsafe extern "C" fn trampoline_world_render<F>(ud: *mut c_void, gfx: *const YogGfxApi)
1609where
1610    F: Fn(&GfxContext) + Send + Sync,
1611{
1612    unsafe {
1613        let f = &*(ud as *const F);
1614        guard((), || f(&GfxContext::from_raw(gfx)));
1615    }
1616}
1617
1618unsafe extern "C" fn trampoline_key_press<F>(ud: *mut c_void, ev: *const YogKeyPressEvent) -> bool
1619where
1620    F: Fn(&KeyPressEvent) -> bool + Send + Sync,
1621{
1622    unsafe {
1623        let f = &*(ud as *const F);
1624        let e = &*ev;
1625        let ev = KeyPressEvent { key_code: e.key_code, scan_code: e.scan_code, action: e.action, modifiers: e.modifiers };
1626        guard(false, || f(&ev))
1627    }
1628}
1629
1630unsafe extern "C" fn trampoline_screen<F>(ud: *mut c_void, screen_class: YogStr) -> bool
1631where
1632    F: Fn(&ScreenEvent) + Send + Sync,
1633{
1634    unsafe {
1635        let f = &*(ud as *const F);
1636        let ev = ScreenEvent { screen_class: screen_class.as_str().to_owned() };
1637        guard((), || f(&ev));
1638        true
1639    }
1640}
1641
1642// ── Registry ─────────────────────────────────────────────────────────────────
1643
1644/// Wraps the [`YogApi`] table and provides an ergonomic registration API.
1645///
1646/// Obtained inside `yog_mod_register` via `export_mod!`.  Closures registered
1647/// here are boxed and leaked — they live as long as the process (which is the
1648/// correct lifetime for a server mod).
1649/// Pointer to the runtime's `YogApi` table (a process-lifetime static in the
1650/// runtime), captured when the mod registers. Lets free functions like
1651/// [`installed_mods`] work outside of `register()` — e.g. in UI handlers.
1652static GLOBAL_API: std::sync::atomic::AtomicPtr<YogApi> =
1653    std::sync::atomic::AtomicPtr::new(std::ptr::null_mut());
1654
1655/// The runtime's `YogApi` table, null before this mod registered.
1656pub(crate) fn global_api() -> *mut YogApi {
1657    GLOBAL_API.load(std::sync::atomic::Ordering::Acquire)
1658}
1659
1660/// Metadata of an installed mod, as reported by the loader.
1661#[derive(Debug, Clone)]
1662pub struct ModInfo {
1663    /// `"yog"` for .yog mods, `"platform"` for loader (Java) mods.
1664    pub source: String,
1665    pub id: String,
1666    pub name: String,
1667    pub version: String,
1668    /// Comma-separated author list (may be empty).
1669    pub authors: String,
1670    pub description: String,
1671}
1672
1673/// All installed mods known to the loader: .yog mods plus, where the host
1674/// exposes them, platform (Java) mods. Callable at any time after this mod's
1675/// `register()` ran — including client-side UI handlers. Note that during
1676/// `register()` mods that load after this one are not in the list yet; query
1677/// lazily (e.g. on first render) for a complete view.
1678pub fn installed_mods() -> Vec<ModInfo> {
1679    let api = GLOBAL_API.load(std::sync::atomic::Ordering::Acquire);
1680    if api.is_null() {
1681        return Vec::new();
1682    }
1683    let owned = unsafe { ((*api).mods_list)((*api).ctx) };
1684    let Some(text) = take_owned(unsafe { (*api).free_str }, owned) else {
1685        return Vec::new();
1686    };
1687    text.lines()
1688        .filter_map(|line| {
1689            let mut f = line.split('\t');
1690            Some(ModInfo {
1691                source: f.next()?.to_string(),
1692                id: f.next()?.to_string(),
1693                name: f.next().unwrap_or_default().to_string(),
1694                version: f.next().unwrap_or_default().to_string(),
1695                authors: f.next().unwrap_or_default().to_string(),
1696                description: f.next().unwrap_or_default().to_string(),
1697            })
1698        })
1699        .collect()
1700}
1701
1702/// Open the Yog UI registered as `ui_id` (client side; no-op on dedicated
1703/// servers). `modal` blocks game input, `pause` pauses singleplayer. Callable
1704/// from any handler after registration — e.g. an `on_client_packet` handler.
1705pub fn open_ui(ui_id: &str, modal: bool, pause: bool) {
1706    let api = GLOBAL_API.load(std::sync::atomic::Ordering::Acquire);
1707    if api.is_null() {
1708        return;
1709    }
1710    unsafe { ((*api).ui_open)((*api).ctx, YogStr::from_str(ui_id), modal, pause) }
1711}
1712
1713/// Close the Yog UI screen showing `ui_id` — e.g. from that screen's own
1714/// "Done" button. Does nothing when another screen is open. Deferred onto the
1715/// render thread, so the handler that calls it finishes first. Client side;
1716/// a no-op on dedicated servers.
1717pub fn close_ui(ui_id: &str) {
1718    let api = GLOBAL_API.load(std::sync::atomic::Ordering::Acquire);
1719    if api.is_null() {
1720        return;
1721    }
1722    unsafe { ((*api).ui_close)((*api).ctx, YogStr::from_str(ui_id)) }
1723}
1724
1725/// What a [`Registry::register_ui`] handler returns: `()` (never marks
1726/// events as used) or `bool` (`true` = the handler used this `key:`/`char:`
1727/// event — the host then doesn't, e.g. Esc doesn't close the screen).
1728pub trait UiHandled {
1729    fn handled(self) -> bool;
1730}
1731
1732impl UiHandled for () {
1733    fn handled(self) -> bool {
1734        false
1735    }
1736}
1737
1738impl UiHandled for bool {
1739    fn handled(self) -> bool {
1740        self
1741    }
1742}
1743
1744/// Handle to the runtime's server-action table, usable from any handler after
1745/// registration — including client-side ones that don't receive `&dyn Server`
1746/// (UI event handlers, client tick). Server-world actions are no-ops client
1747/// side, but networking (`send_to_server`) and similar client-safe calls work.
1748pub fn server() -> Option<CServer> {
1749    let api = GLOBAL_API.load(std::sync::atomic::Ordering::Acquire);
1750    if api.is_null() {
1751        return None;
1752    }
1753    let srv = unsafe { (*api).server };
1754    if srv.is_null() {
1755        return None;
1756    }
1757    Some(CServer(srv))
1758}
1759
1760pub struct Registry {
1761    api: *const YogApi,
1762}
1763
1764// SAFETY: `api` is a static provided by the runtime, valid for process lifetime.
1765unsafe impl Send for Registry {}
1766unsafe impl Sync for Registry {}
1767
1768impl Registry {
1769    /// Build from the pointer passed by the runtime. Only called by `export_mod!`.
1770    ///
1771    /// # Safety
1772    ///
1773    /// `api` must point to the runtime's `YogApi` table, valid for the rest of
1774    /// the process.
1775    pub unsafe fn from_raw(api: *const YogApi) -> Self {
1776        GLOBAL_API.store(api as *mut YogApi, std::sync::atomic::Ordering::Release);
1777        Self { api }
1778    }
1779
1780    #[inline]
1781    fn ctx(&self) -> *mut c_void {
1782        unsafe { (*self.api).ctx }
1783    }
1784
1785    // ── helpers ──────────────────────────────────────────────────────────────
1786
1787    fn leak<F: 'static>(f: F) -> *mut c_void {
1788        Box::into_raw(Box::new(f)) as *mut c_void
1789    }
1790
1791    // ── events ───────────────────────────────────────────────────────────────
1792    //
1793    // All handlers receive `(event, EventPhase, &dyn Server) -> bool`.
1794    // In `Pre` phase, returning `false` cancels the action.
1795    // In `Post` phase, the return value is ignored.
1796    // A single registration fires for BOTH phases.
1797
1798    pub fn on_block_break<F>(&mut self, handler: F)
1799    where
1800        F: Fn(&BlockBreakEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1801    {
1802        let ud = Self::leak(handler);
1803        unsafe { ((*self.api).on_block_break)(self.ctx(), ud, trampoline_block_break::<F>) }
1804    }
1805
1806    pub fn on_chat<F>(&mut self, handler: F)
1807    where
1808        F: Fn(&ChatEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1809    {
1810        let ud = Self::leak(handler);
1811        unsafe { ((*self.api).on_chat)(self.ctx(), ud, trampoline_chat::<F>) }
1812    }
1813
1814    pub fn on_player_join<F>(&mut self, handler: F)
1815    where
1816        F: Fn(&PlayerJoinEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1817    {
1818        let ud = Self::leak(handler);
1819        unsafe { ((*self.api).on_player_join)(self.ctx(), ud, trampoline_player_join::<F>) }
1820    }
1821
1822    pub fn on_player_leave<F>(&mut self, handler: F)
1823    where
1824        F: Fn(&PlayerLeaveEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1825    {
1826        let ud = Self::leak(handler);
1827        unsafe { ((*self.api).on_player_leave)(self.ctx(), ud, trampoline_player_leave::<F>) }
1828    }
1829
1830    pub fn on_use_item<F>(&mut self, handler: F)
1831    where
1832        F: Fn(&UseItemEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1833    {
1834        let ud = Self::leak(handler);
1835        unsafe { ((*self.api).on_use_item)(self.ctx(), ud, trampoline_use_item::<F>) }
1836    }
1837
1838    pub fn on_use_block<F>(&mut self, handler: F)
1839    where
1840        F: Fn(&UseBlockEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1841    {
1842        let ud = Self::leak(handler);
1843        unsafe { ((*self.api).on_use_block)(self.ctx(), ud, trampoline_use_block::<F>) }
1844    }
1845
1846    pub fn on_attack_entity<F>(&mut self, handler: F)
1847    where
1848        F: Fn(&AttackEntityEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1849    {
1850        let ud = Self::leak(handler);
1851        unsafe { ((*self.api).on_attack_entity)(self.ctx(), ud, trampoline_attack_entity::<F>) }
1852    }
1853
1854    pub fn on_entity_damage<F>(&mut self, handler: F)
1855    where
1856        F: Fn(&EntityDamageEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1857    {
1858        let ud = Self::leak(handler);
1859        unsafe { ((*self.api).on_entity_damage)(self.ctx(), ud, trampoline_entity_damage::<F>) }
1860    }
1861
1862    pub fn on_entity_death<F>(&mut self, handler: F)
1863    where
1864        F: Fn(&EntityDeathEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1865    {
1866        let ud = Self::leak(handler);
1867        unsafe { ((*self.api).on_entity_death)(self.ctx(), ud, trampoline_entity_death::<F>) }
1868    }
1869
1870    pub fn on_entity_spawn<F>(&mut self, handler: F)
1871    where
1872        F: Fn(&EntitySpawnEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1873    {
1874        let ud = Self::leak(handler);
1875        unsafe { ((*self.api).on_entity_spawn)(self.ctx(), ud, trampoline_entity_spawn::<F>) }
1876    }
1877
1878    pub fn on_player_place_block<F>(&mut self, handler: F)
1879    where
1880        F: Fn(&PlaceBlockEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1881    {
1882        let ud = Self::leak(handler);
1883        unsafe { ((*self.api).on_player_place_block)(self.ctx(), ud, trampoline_place_block::<F>) }
1884    }
1885
1886    pub fn on_player_death<F>(&mut self, handler: F)
1887    where
1888        F: Fn(&PlayerDeathEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1889    {
1890        let ud = Self::leak(handler);
1891        unsafe { ((*self.api).on_player_death)(self.ctx(), ud, trampoline_player_death::<F>) }
1892    }
1893
1894    pub fn on_player_respawn<F>(&mut self, handler: F)
1895    where
1896        F: Fn(&PlayerRespawnEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1897    {
1898        let ud = Self::leak(handler);
1899        unsafe { ((*self.api).on_player_respawn)(self.ctx(), ud, trampoline_player_respawn::<F>) }
1900    }
1901
1902    pub fn on_advancement<F>(&mut self, handler: F)
1903    where
1904        F: Fn(&AdvancementEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1905    {
1906        let ud = Self::leak(handler);
1907        unsafe { ((*self.api).on_advancement)(self.ctx(), ud, trampoline_advancement::<F>) }
1908    }
1909
1910    pub fn on_entity_interact<F>(&mut self, handler: F)
1911    where
1912        F: Fn(&EntityInteractEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1913    {
1914        let ud = Self::leak(handler);
1915        unsafe { ((*self.api).on_entity_interact)(self.ctx(), ud, trampoline_entity_interact::<F>) }
1916    }
1917
1918    pub fn on_item_craft<F>(&mut self, handler: F)
1919    where
1920        F: Fn(&CraftEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1921    {
1922        let ud = Self::leak(handler);
1923        unsafe { ((*self.api).on_item_craft)(self.ctx(), ud, trampoline_craft::<F>) }
1924    }
1925
1926    pub fn on_explosion<F>(&mut self, handler: F)
1927    where
1928        F: Fn(&ExplosionEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1929    {
1930        let ud = Self::leak(handler);
1931        unsafe { ((*self.api).on_explosion)(self.ctx(), ud, trampoline_explosion::<F>) }
1932    }
1933
1934    pub fn on_item_pickup<F>(&mut self, handler: F)
1935    where
1936        F: Fn(&ItemPickupEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1937    {
1938        let ud = Self::leak(handler);
1939        unsafe { ((*self.api).on_item_pickup)(self.ctx(), ud, trampoline_item_pickup::<F>) }
1940    }
1941
1942    pub fn on_player_move<F>(&mut self, handler: F)
1943    where
1944        F: Fn(&PlayerMoveEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1945    {
1946        let ud = Self::leak(handler);
1947        unsafe { ((*self.api).on_player_move)(self.ctx(), ud, trampoline_player_move::<F>) }
1948    }
1949
1950    pub fn on_container_open<F>(&mut self, handler: F)
1951    where
1952        F: Fn(&ContainerOpenEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1953    {
1954        let ud = Self::leak(handler);
1955        unsafe { ((*self.api).on_container_open)(self.ctx(), ud, trampoline_container_open::<F>) }
1956    }
1957
1958    pub fn on_container_close<F>(&mut self, handler: F)
1959    where
1960        F: Fn(&ContainerCloseEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1961    {
1962        let ud = Self::leak(handler);
1963        unsafe { ((*self.api).on_container_close)(self.ctx(), ud, trampoline_container_close::<F>) }
1964    }
1965
1966    pub fn on_projectile_hit<F>(&mut self, handler: F)
1967    where
1968        F: Fn(&ProjectileHitEvent, EventPhase, &dyn Server) -> bool + Send + Sync + 'static,
1969    {
1970        let ud = Self::leak(handler);
1971        unsafe { ((*self.api).on_projectile_hit)(self.ctx(), ud, trampoline_projectile_hit::<F>) }
1972    }
1973
1974    pub fn on_tick<F>(&mut self, listener: F)
1975    where
1976        F: Fn(&dyn Server) + Send + Sync + 'static,
1977    {
1978        let ud = Self::leak(listener);
1979        unsafe { ((*self.api).on_server_tick)(self.ctx(), ud, trampoline_server_fn::<F>) }
1980    }
1981
1982    pub fn on_server_started<F>(&mut self, listener: F)
1983    where
1984        F: Fn(&dyn Server) + Send + Sync + 'static,
1985    {
1986        let ud = Self::leak(listener);
1987        unsafe { ((*self.api).on_server_started)(self.ctx(), ud, trampoline_server_fn::<F>) }
1988    }
1989
1990    pub fn on_server_stopping<F>(&mut self, listener: F)
1991    where
1992        F: Fn(&dyn Server) + Send + Sync + 'static,
1993    {
1994        let ud = Self::leak(listener);
1995        unsafe { ((*self.api).on_server_stopping)(self.ctx(), ud, trampoline_server_fn::<F>) }
1996    }
1997
1998    // ── commands ─────────────────────────────────────────────────────────────
1999
2000    pub fn on_command<F>(&mut self, name: impl AsRef<str>, handler: F)
2001    where
2002        F: Fn(&CommandContext, &dyn Server) -> Option<String> + Send + Sync + 'static,
2003    {
2004        let name_ys = YogStr::from_str(name.as_ref());
2005        let ud = Self::leak(handler);
2006        unsafe { ((*self.api).register_command)(self.ctx(), name_ys, ud, trampoline_command::<F>) }
2007    }
2008
2009    /// Register a command with Brigadier-typed arguments.
2010    ///
2011    /// `schema` is a space-separated list of argument types:
2012    /// `int`, `float`, `word`, `string` (greedy, must be last), `player`, `blockpos`.
2013    ///
2014    /// In the handler use `ctx.arg_int(0)`, `ctx.arg_blockpos(1)`, etc.
2015    pub fn on_typed_command<F>(
2016        &mut self,
2017        name: impl AsRef<str>,
2018        schema: impl AsRef<str>,
2019        handler: F,
2020    ) where
2021        F: Fn(&CommandContext, &dyn Server) -> Option<String> + Send + Sync + 'static,
2022    {
2023        let name_ys = YogStr::from_str(name.as_ref());
2024        let schema_ys = YogStr::from_str(schema.as_ref());
2025        let ud = Self::leak(handler);
2026        unsafe {
2027            ((*self.api).register_typed_command)(
2028                self.ctx(),
2029                name_ys,
2030                schema_ys,
2031                ud,
2032                trampoline_command::<F>,
2033            );
2034        }
2035    }
2036
2037    // ── networking ───────────────────────────────────────────────────────────
2038
2039    pub fn on_packet<F>(&mut self, channel: impl AsRef<str>, handler: F)
2040    where
2041        F: Fn(&PacketEvent, &dyn Server) + Send + Sync + 'static,
2042    {
2043        let ch = YogStr::from_str(channel.as_ref());
2044        let ud = Self::leak(handler);
2045        unsafe { ((*self.api).on_packet)(self.ctx(), ch, ud, trampoline_packet::<F>) }
2046    }
2047
2048    pub fn on_client_packet<F>(&mut self, channel: impl AsRef<str>, handler: F)
2049    where
2050        F: Fn(&PacketEvent, &dyn Server) + Send + Sync + 'static,
2051    {
2052        let ch = YogStr::from_str(channel.as_ref());
2053        let ud = Self::leak(handler);
2054        unsafe { ((*self.api).on_client_packet)(self.ctx(), ch, ud, trampoline_packet::<F>) }
2055    }
2056
2057    /// Register a typed-packet handler.
2058    ///
2059    /// The payload is decoded from raw bytes using `P`'s [`Packet`] impl.
2060    /// Malformed payloads are silently dropped.
2061    pub fn on_typed_packet<P, F>(&mut self, channel: impl AsRef<str>, handler: F)
2062    where
2063        P: Packet + Send + Sync + 'static,
2064        F: Fn(&P, &dyn Server) + Send + Sync + 'static,
2065    {
2066        self.on_packet(channel, move |ev, srv| {
2067            if let Some(pkt) = P::decode(&ev.payload) {
2068                handler(&pkt, srv);
2069            }
2070        });
2071    }
2072
2073    // ── recipes ──────────────────────────────────────────────────────────────
2074
2075    fn recipe(&mut self, ns: &str, name: &str, json: &str) {
2076        unsafe {
2077            ((*self.api).register_recipe_json)(
2078                self.ctx(),
2079                YogStr::from_str(ns),
2080                YogStr::from_str(name),
2081                YogStr::from_str(json),
2082            );
2083        }
2084    }
2085
2086    /// Register a shaped crafting recipe.
2087    pub fn add_shaped_recipe(&mut self, recipe: ShapedRecipe) {
2088        let (ns, name) = recipe.ns_name();
2089        self.recipe(ns, name, &recipe.to_json());
2090    }
2091
2092    /// Register a shapeless crafting recipe.
2093    pub fn add_shapeless_recipe(&mut self, recipe: ShapelessRecipe) {
2094        let (ns, name) = recipe.ns_name();
2095        self.recipe(ns, name, &recipe.to_json());
2096    }
2097
2098    /// Register a furnace smelting recipe.
2099    pub fn add_furnace_recipe(&mut self, recipe: FurnaceRecipe) {
2100        let (ns, name) = recipe.ns_name();
2101        self.recipe(ns, name, &recipe.to_json());
2102    }
2103
2104    // ── content ──────────────────────────────────────────────────────────────
2105
2106    pub fn register_item(&mut self, def: ItemDef) {
2107        // Build a C-compatible YogItemDef whose YogStr fields point into `def`'s
2108        // String storage.  We then call register_item which must copy the data
2109        // before returning (the runtime stores owned Strings).
2110        let food_nutrition = def.food.as_ref().map_or(0, |f| f.nutrition);
2111        let food_saturation = def.food.as_ref().map_or(0.0, |f| f.saturation);
2112        let food_always_eat = def.food.as_ref().is_some_and(|f| f.can_always_eat);
2113        let c = YogItemDef {
2114            id: YogStr::from_str(&def.id),
2115            max_stack: def.max_stack as u32,
2116            name: def
2117                .name
2118                .as_deref()
2119                .map(YogStr::from_str)
2120                .unwrap_or(YogStr::EMPTY),
2121            tooltip: def
2122                .tooltip
2123                .as_deref()
2124                .map(YogStr::from_str)
2125                .unwrap_or(YogStr::EMPTY),
2126            max_damage: def.max_damage,
2127            fire_resistant: def.fire_resistant,
2128            fuel_ticks: def.fuel_ticks,
2129            food_nutrition,
2130            food_saturation,
2131            food_always_eat,
2132        };
2133        unsafe { ((*self.api).register_item)(self.ctx(), &c) }
2134    }
2135
2136    pub fn register_block(&mut self, def: BlockDef) {
2137        let shape = def.shape.unwrap_or([0.0; 6]);
2138        let groups_joined = def.connect_groups.join(",");
2139        let c = YogBlockDef {
2140            id: YogStr::from_str(&def.id),
2141            hardness: def.hardness,
2142            resistance: def.resistance,
2143            name: def
2144                .name
2145                .as_deref()
2146                .map(YogStr::from_str)
2147                .unwrap_or(YogStr::EMPTY),
2148            light_level: def.light_level,
2149            sound: def
2150                .sound
2151                .as_deref()
2152                .map(YogStr::from_str)
2153                .unwrap_or(YogStr::EMPTY),
2154            requires_tool: def.requires_tool,
2155            no_collision: def.no_collision,
2156            slipperiness: def.slipperiness,
2157            shape,
2158            connects: def.connects,
2159            connect_groups: YogStr::from_str(&groups_joined),
2160            inventory_id: def
2161                .inventory_id
2162                .as_deref()
2163                .map(YogStr::from_str)
2164                .unwrap_or(YogStr::EMPTY),
2165            redstone_source: def.redstone_source,
2166        };
2167        unsafe { ((*self.api).register_block)(self.ctx(), &c) }
2168    }
2169
2170    /// Register a real Container/Menu inventory screen — see
2171    /// `yog_inventory::InventoryDef`. Attach it to a block via
2172    /// `BlockDef::inventory(id)`.
2173    pub fn register_inventory(&mut self, def: yog_inventory::InventoryDef) {
2174        let layout = yog_inventory::encode_layout(&def.resolved_layout());
2175        let c = YogInventoryDef {
2176            id: YogStr::from_str(&def.id),
2177            slot_count: def.slot_count as u32,
2178            layout: YogStr::from_str(&layout),
2179            include_player_inventory: def.include_player_inventory,
2180            player_inv_x: def.player_inv_offset.0,
2181            player_inv_y: def.player_inv_offset.1,
2182            background_texture: def
2183                .background_texture
2184                .as_deref()
2185                .map(YogStr::from_str)
2186                .unwrap_or(YogStr::EMPTY),
2187            title: YogStr::from_str(&def.title),
2188            background_w: def.background_size.map(|(w, _)| w).unwrap_or(0.0),
2189            background_h: def.background_size.map(|(_, h)| h).unwrap_or(0.0),
2190        };
2191        unsafe { ((*self.api).register_inventory)(self.ctx(), &c) }
2192    }
2193
2194    // ── startup grants ───────────────────────────────────────────────────────
2195
2196    /// Register a startup grant: items/books to give once when a player first joins.
2197    pub fn register_startup_grant(&mut self, grant: StartupGrant) {
2198        let items_str = grant.items.join("|");
2199        let c = YogStartupGrantDef {
2200            id: YogStr::from_str(&grant.id),
2201            items: YogStr::from_str(&items_str),
2202            book: grant
2203                .book
2204                .as_deref()
2205                .map(YogStr::from_str)
2206                .unwrap_or(YogStr::EMPTY),
2207            command: grant
2208                .command
2209                .as_deref()
2210                .map(YogStr::from_str)
2211                .unwrap_or(YogStr::EMPTY),
2212        };
2213        unsafe { ((*self.api).register_startup_grant)(self.ctx(), &c) }
2214    }
2215
2216    /// Register a book with its JSON-serialized content.
2217    pub fn register_book(&mut self, book: &Book) {
2218        self.register_book_json(&book.id, &book.to_json());
2219    }
2220
2221    /// Register a book from its JSON (what `yog build` makes of a
2222    /// `content/**/*.ybook`).
2223    pub fn register_book_json(&mut self, id: &str, json: &str) {
2224        unsafe { ((*self.api).register_book)(self.ctx(), YogStr::from_str(id), YogStr::from_str(json)) }
2225    }
2226
2227    /// Register (or patch) a dimension's *type* (sky, lighting, physics, ...).
2228    ///
2229    /// `def.id` need not be a new custom id — pass a vanilla id
2230    /// (`"minecraft:overworld"`, `"minecraft:the_nether"`,
2231    /// `"minecraft:the_end"`) to patch that dimension's type/generator
2232    /// instead of creating a new one (e.g. to replace the overworld's
2233    /// terrain with your own generator type).
2234    ///
2235    /// Must be called from `register()` — the same mod-init window as
2236    /// blocks/items — so the host can declare/patch the dimension before
2237    /// Minecraft's registries freeze. See the `yog-dimensions` crate docs;
2238    /// set `def.generator_type` (via [`YogDimensionDef::generator_type`]) to
2239    /// pick a generator type registered with
2240    /// [`Registry::register_chunk_generator`].
2241    pub fn register_dimension(&mut self, def: &YogDimensionDef) {
2242        let json = def.to_json();
2243        let id = YogStr::from_str(&def.id);
2244        let j = YogStr::from_str(&json);
2245        unsafe { ((*self.api).register_dimension_json)(self.ctx(), id, j) }
2246    }
2247
2248    /// Register a named, reusable chunk-generator type under
2249    /// `generator_type_id` (e.g. `"mymod:custom_terrain"`) — analogous to
2250    /// how Biomes O'Plenty registers selectable world-type presets. Any
2251    /// dimension (custom or vanilla) can opt into this generator via
2252    /// [`YogDimensionDef::generator_type`]; the platform host may also list
2253    /// registered generator type ids as options on the world-creation screen.
2254    ///
2255    /// `generator` is called once per chunk column that needs generating in
2256    /// any dimension using this type — write whatever terrain logic you want
2257    /// using the [`ChunkWriter`] handle (combine as many noise layers as you
2258    /// like; this crate doesn't prescribe a generation style).
2259    pub fn register_chunk_generator<F>(&mut self, generator_type_id: &str, generator: F)
2260    where
2261        F: Fn(&ChunkWriter) + Send + Sync + 'static,
2262    {
2263        let ud = Self::leak(generator);
2264        let id = YogStr::from_str(generator_type_id);
2265        unsafe {
2266            ((*self.api).register_chunk_generator)(
2267                self.ctx(),
2268                id,
2269                ud,
2270                trampoline_chunk_generator::<F>,
2271            );
2272        }
2273    }
2274
2275    /// Register a menu entry — the host renders a button on vanilla screens
2276    /// (TitleScreen on Fabric, ModListScreen on Forge/NeoForge) that opens `ui_id`.
2277    /// `label` is the human-readable button text (e.g. "Yog Mods").
2278    /// `ui_id` is the UI to open when clicked (e.g. "example:menu").
2279    /// See [`installed_mods`]. During `register()` the list only contains
2280    /// mods loaded before this one.
2281    pub fn installed_mods(&self) -> Vec<ModInfo> {
2282        installed_mods()
2283    }
2284
2285    /// Access the inter-mod communication layer.
2286    ///
2287    /// Allows exporting function pointers from this mod and importing
2288    /// function pointers from other mods.
2289    pub fn interop(&self) -> crate::Interop {
2290        crate::Interop::new(self.api)
2291    }
2292
2293    /// Raw `YogApi` pointer — for passing to interop-imported functions
2294    /// that register content through the C ABI table directly.
2295    pub fn raw_api(&self) -> *const yog_abi::YogApi {
2296        self.api
2297    }
2298
2299    pub fn register_menu_entry(&mut self, label: &str, ui_id: &str) {
2300        let l = YogStr::from_str(label);
2301        let u = YogStr::from_str(ui_id);
2302        unsafe { ((*self.api).register_menu_entry)(self.ctx(), l, u) }
2303    }
2304
2305    /// Register a UI tree with an event callback.
2306    /// `ui_id` is the unique identifier (e.g. "mymod:menu").
2307    /// `handler` receives `(ui_id, event)` for the screen's input: `click:X:Y`,
2308    /// `drag:X:Y`, `release:X:Y`, `scroll:DY`, `key:KEY:MODS` (GLFW key code
2309    /// and modifier bits, on press and repeat) and `char:CODEPOINT` (a typed
2310    /// character). It returns `()` or a `bool`: `true` marks a `key:`/`char:`
2311    /// event as used, so the host skips its default handling of the key
2312    /// (Esc closing the screen, ...) — see [`UiHandled`].
2313    pub fn register_ui<F, R>(&mut self, ui_id: &str, handler: F)
2314    where
2315        F: Fn(&str, &str) -> R + Send + Sync + 'static,
2316        R: UiHandled,
2317    {
2318        let ud = Self::leak(handler);
2319        let id = YogStr::from_str(ui_id);
2320        let empty = YogStr::from_str("{}");
2321        unsafe { ((*self.api).register_ui)(self.ctx(), id, empty, ud, trampoline_ui_event::<F, R>) }
2322    }
2323
2324    // ── scheduler ────────────────────────────────────────────────────────────
2325
2326    pub fn schedule_once<F>(&self, delay_ticks: u64, handler: F)
2327    where
2328        F: Fn(&dyn Server) + Send + Sync + 'static,
2329    {
2330        let ud = Self::leak(handler);
2331        unsafe {
2332            ((*self.api).schedule_once)(self.ctx(), delay_ticks, ud, trampoline_scheduled::<F>);
2333        }
2334    }
2335
2336    pub fn schedule_repeating<F>(&self, period_ticks: u64, handler: F)
2337    where
2338        F: Fn(&dyn Server) + Send + Sync + 'static,
2339    {
2340        let ud = Self::leak(handler);
2341        unsafe {
2342            ((*self.api).schedule_repeating)(
2343                self.ctx(),
2344                period_ticks,
2345                ud,
2346                trampoline_scheduled::<F>,
2347            );
2348        }
2349    }
2350
2351    // ── client-side hooks (ABI minor 10) ─────────────────────────────────────
2352
2353    /// Register a handler called every client tick (render thread, no server).
2354    pub fn on_client_tick<F>(&mut self, handler: F)
2355    where
2356        F: Fn(&ClientTickEvent) + Send + Sync + 'static,
2357    {
2358        let ud = Self::leak(handler);
2359        unsafe { ((*self.api).on_client_tick)(self.ctx(), ud, trampoline_client_tick::<F>) }
2360    }
2361
2362    /// Register a render callback for a specific UI screen (`ui_id`).
2363    ///
2364    /// Called from `YogUIScreen.render()` — i.e. AFTER `renderBackground()` darkens
2365    /// the screen — so your UI draws on top of the dimmed world view.
2366    /// Use this instead of `on_hud_render` for book/inventory screens.
2367    ///
2368    /// Clicks are forwarded as `"click:X:Y"` via the `register_ui` handler so you
2369    /// can do hit-testing on your own stored layout.
2370    pub fn on_ui_render<F>(&mut self, ui_id: &str, handler: F)
2371    where
2372        F: Fn(&GfxContext) + Send + Sync + 'static,
2373    {
2374        let ud = Self::leak(handler);
2375        let id = YogStr::from_str(ui_id);
2376        unsafe { ((*self.api).on_ui_render)(self.ctx(), id, ud, trampoline_hud_render::<F>) }
2377    }
2378
2379    /// Register a handler called every frame when the HUD is rendered.
2380    ///
2381    /// `gfx` provides full GPU pipeline access plus 2D convenience draw calls.
2382    /// `view_proj` and `camera_pos` are zero in HUD context; use `gfx.draw2d()` for HUD elements.
2383    pub fn on_hud_render<F>(&mut self, handler: F)
2384    where
2385        F: Fn(&GfxContext) + Send + Sync + 'static,
2386    {
2387        let ud = Self::leak(handler);
2388        unsafe { ((*self.api).on_hud_render)(self.ctx(), ud, trampoline_hud_render::<F>) }
2389    }
2390
2391    /// Register a handler called every frame at the end of world rendering.
2392    ///
2393    /// `gfx.view_proj()` is the combined projection × view matrix (camera-relative).
2394    /// `gfx.camera_pos()` is the camera world position.
2395    /// To render at world position P, translate by `P - camera_pos` before drawing.
2396    pub fn on_world_render<F>(&mut self, handler: F)
2397    where
2398        F: Fn(&GfxContext) + Send + Sync + 'static,
2399    {
2400        let ud = Self::leak(handler);
2401        unsafe { ((*self.api).on_world_render)(self.ctx(), ud, trampoline_world_render::<F>) }
2402    }
2403
2404    /// Register a handler for keyboard input (client-side).
2405    /// Return `false` to prevent Minecraft from processing the key.
2406    pub fn on_key_press<F>(&mut self, handler: F)
2407    where
2408        F: Fn(&KeyPressEvent) -> bool + Send + Sync + 'static,
2409    {
2410        let ud = Self::leak(handler);
2411        unsafe { ((*self.api).on_key_press)(self.ctx(), ud, trampoline_key_press::<F>) }
2412    }
2413
2414    /// Register a handler called when a GUI screen is opened.
2415    pub fn on_screen_open<F>(&mut self, handler: F)
2416    where
2417        F: Fn(&ScreenEvent) + Send + Sync + 'static,
2418    {
2419        let ud = Self::leak(handler);
2420        unsafe { ((*self.api).on_screen_open)(self.ctx(), ud, trampoline_screen::<F>) }
2421    }
2422
2423    /// Register a handler called when a GUI screen is closed.
2424    pub fn on_screen_close<F>(&mut self, handler: F)
2425    where
2426        F: Fn(&ScreenEvent) + Send + Sync + 'static,
2427    {
2428        let ud = Self::leak(handler);
2429        unsafe { ((*self.api).on_screen_close)(self.ctx(), ud, trampoline_screen::<F>) }
2430    }
2431}
2432
2433unsafe extern "C" fn trampoline_ui_event<F, R>(
2434    ud: *mut c_void,
2435    ui_id: yog_abi::YogStr,
2436    event_id: yog_abi::YogStr,
2437) where
2438    F: Fn(&str, &str) -> R + Send + Sync + 'static,
2439    R: UiHandled,
2440{
2441    let f = unsafe { &*(ud as *const F) };
2442    let ui = unsafe { ui_id.as_str() };
2443    let ev = unsafe { event_id.as_str() };
2444    if guard(false, || f(ui, ev).handled()) {
2445        let api = GLOBAL_API.load(std::sync::atomic::Ordering::Acquire);
2446        if !api.is_null() {
2447            unsafe { ((*api).ui_consume_event)((*api).ctx) }
2448        }
2449    }
2450}
2451
2452unsafe extern "C" fn trampoline_chunk_generator<F>(
2453    ud: *mut c_void,
2454    writer: *const yog_abi::YogChunkWriterApi,
2455) where
2456    F: Fn(&ChunkWriter) + Send + Sync + 'static,
2457{
2458    let f = unsafe { &*(ud as *const F) };
2459    let writer = unsafe { ChunkWriter::from_raw(writer) };
2460    guard((), || f(&writer));
2461}
2462
2463// ── Mod trait ─────────────────────────────────────────────────────────────────
2464
2465/// Implemented by every Yog mod. Called once at startup to register handlers.
2466pub trait Mod {
2467    fn register(registry: &mut Registry);
2468}