1use 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
37pub 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 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 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
1156pub(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 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
1185fn 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}
1198macro_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
1586unsafe 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
1642static GLOBAL_API: std::sync::atomic::AtomicPtr<YogApi> =
1653 std::sync::atomic::AtomicPtr::new(std::ptr::null_mut());
1654
1655pub(crate) fn global_api() -> *mut YogApi {
1657 GLOBAL_API.load(std::sync::atomic::Ordering::Acquire)
1658}
1659
1660#[derive(Debug, Clone)]
1662pub struct ModInfo {
1663 pub source: String,
1665 pub id: String,
1666 pub name: String,
1667 pub version: String,
1668 pub authors: String,
1670 pub description: String,
1671}
1672
1673pub 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
1702pub 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
1713pub 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
1725pub 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
1744pub 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
1764unsafe impl Send for Registry {}
1766unsafe impl Sync for Registry {}
1767
1768impl Registry {
1769 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 fn leak<F: 'static>(f: F) -> *mut c_void {
1788 Box::into_raw(Box::new(f)) as *mut c_void
1789 }
1790
1791 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 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 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 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 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 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 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 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 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 pub fn register_item(&mut self, def: ItemDef) {
2107 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 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 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 pub fn register_book(&mut self, book: &Book) {
2218 let json = book.to_json();
2219 let id = YogStr::from_str(&book.id);
2220 let j = YogStr::from_str(&json);
2221 unsafe { ((*self.api).register_book)(self.ctx(), id, j) }
2222 }
2223
2224 pub fn register_dimension(&mut self, def: &YogDimensionDef) {
2239 let json = def.to_json();
2240 let id = YogStr::from_str(&def.id);
2241 let j = YogStr::from_str(&json);
2242 unsafe { ((*self.api).register_dimension_json)(self.ctx(), id, j) }
2243 }
2244
2245 pub fn register_chunk_generator<F>(&mut self, generator_type_id: &str, generator: F)
2257 where
2258 F: Fn(&ChunkWriter) + Send + Sync + 'static,
2259 {
2260 let ud = Self::leak(generator);
2261 let id = YogStr::from_str(generator_type_id);
2262 unsafe {
2263 ((*self.api).register_chunk_generator)(
2264 self.ctx(),
2265 id,
2266 ud,
2267 trampoline_chunk_generator::<F>,
2268 );
2269 }
2270 }
2271
2272 pub fn installed_mods(&self) -> Vec<ModInfo> {
2279 installed_mods()
2280 }
2281
2282 pub fn interop(&self) -> crate::Interop {
2287 crate::Interop::new(self.api)
2288 }
2289
2290 pub fn raw_api(&self) -> *const yog_abi::YogApi {
2293 self.api
2294 }
2295
2296 pub fn register_menu_entry(&mut self, label: &str, ui_id: &str) {
2297 let l = YogStr::from_str(label);
2298 let u = YogStr::from_str(ui_id);
2299 unsafe { ((*self.api).register_menu_entry)(self.ctx(), l, u) }
2300 }
2301
2302 pub fn register_ui<F, R>(&mut self, ui_id: &str, handler: F)
2311 where
2312 F: Fn(&str, &str) -> R + Send + Sync + 'static,
2313 R: UiHandled,
2314 {
2315 let ud = Self::leak(handler);
2316 let id = YogStr::from_str(ui_id);
2317 let empty = YogStr::from_str("{}");
2318 unsafe { ((*self.api).register_ui)(self.ctx(), id, empty, ud, trampoline_ui_event::<F, R>) }
2319 }
2320
2321 pub fn schedule_once<F>(&self, delay_ticks: u64, handler: F)
2324 where
2325 F: Fn(&dyn Server) + Send + Sync + 'static,
2326 {
2327 let ud = Self::leak(handler);
2328 unsafe {
2329 ((*self.api).schedule_once)(self.ctx(), delay_ticks, ud, trampoline_scheduled::<F>);
2330 }
2331 }
2332
2333 pub fn schedule_repeating<F>(&self, period_ticks: u64, handler: F)
2334 where
2335 F: Fn(&dyn Server) + Send + Sync + 'static,
2336 {
2337 let ud = Self::leak(handler);
2338 unsafe {
2339 ((*self.api).schedule_repeating)(
2340 self.ctx(),
2341 period_ticks,
2342 ud,
2343 trampoline_scheduled::<F>,
2344 );
2345 }
2346 }
2347
2348 pub fn on_client_tick<F>(&mut self, handler: F)
2352 where
2353 F: Fn(&ClientTickEvent) + Send + Sync + 'static,
2354 {
2355 let ud = Self::leak(handler);
2356 unsafe { ((*self.api).on_client_tick)(self.ctx(), ud, trampoline_client_tick::<F>) }
2357 }
2358
2359 pub fn on_ui_render<F>(&mut self, ui_id: &str, handler: F)
2368 where
2369 F: Fn(&GfxContext) + Send + Sync + 'static,
2370 {
2371 let ud = Self::leak(handler);
2372 let id = YogStr::from_str(ui_id);
2373 unsafe { ((*self.api).on_ui_render)(self.ctx(), id, ud, trampoline_hud_render::<F>) }
2374 }
2375
2376 pub fn on_hud_render<F>(&mut self, handler: F)
2381 where
2382 F: Fn(&GfxContext) + Send + Sync + 'static,
2383 {
2384 let ud = Self::leak(handler);
2385 unsafe { ((*self.api).on_hud_render)(self.ctx(), ud, trampoline_hud_render::<F>) }
2386 }
2387
2388 pub fn on_world_render<F>(&mut self, handler: F)
2394 where
2395 F: Fn(&GfxContext) + Send + Sync + 'static,
2396 {
2397 let ud = Self::leak(handler);
2398 unsafe { ((*self.api).on_world_render)(self.ctx(), ud, trampoline_world_render::<F>) }
2399 }
2400
2401 pub fn on_key_press<F>(&mut self, handler: F)
2404 where
2405 F: Fn(&KeyPressEvent) -> bool + Send + Sync + 'static,
2406 {
2407 let ud = Self::leak(handler);
2408 unsafe { ((*self.api).on_key_press)(self.ctx(), ud, trampoline_key_press::<F>) }
2409 }
2410
2411 pub fn on_screen_open<F>(&mut self, handler: F)
2413 where
2414 F: Fn(&ScreenEvent) + Send + Sync + 'static,
2415 {
2416 let ud = Self::leak(handler);
2417 unsafe { ((*self.api).on_screen_open)(self.ctx(), ud, trampoline_screen::<F>) }
2418 }
2419
2420 pub fn on_screen_close<F>(&mut self, handler: F)
2422 where
2423 F: Fn(&ScreenEvent) + Send + Sync + 'static,
2424 {
2425 let ud = Self::leak(handler);
2426 unsafe { ((*self.api).on_screen_close)(self.ctx(), ud, trampoline_screen::<F>) }
2427 }
2428}
2429
2430unsafe extern "C" fn trampoline_ui_event<F, R>(
2431 ud: *mut c_void,
2432 ui_id: yog_abi::YogStr,
2433 event_id: yog_abi::YogStr,
2434) where
2435 F: Fn(&str, &str) -> R + Send + Sync + 'static,
2436 R: UiHandled,
2437{
2438 let f = unsafe { &*(ud as *const F) };
2439 let ui = unsafe { ui_id.as_str() };
2440 let ev = unsafe { event_id.as_str() };
2441 if guard(false, || f(ui, ev).handled()) {
2442 let api = GLOBAL_API.load(std::sync::atomic::Ordering::Acquire);
2443 if !api.is_null() {
2444 unsafe { ((*api).ui_consume_event)((*api).ctx) }
2445 }
2446 }
2447}
2448
2449unsafe extern "C" fn trampoline_chunk_generator<F>(
2450 ud: *mut c_void,
2451 writer: *const yog_abi::YogChunkWriterApi,
2452) where
2453 F: Fn(&ChunkWriter) + Send + Sync + 'static,
2454{
2455 let f = unsafe { &*(ud as *const F) };
2456 let writer = unsafe { ChunkWriter::from_raw(writer) };
2457 guard((), || f(&writer));
2458}
2459
2460pub trait Mod {
2464 fn register(registry: &mut Registry);
2465}