1use std::collections::HashMap;
16use std::num::NonZeroU32;
17use std::os::raw::c_void;
18use std::path::{Path, PathBuf};
19use std::sync::{Mutex, OnceLock};
20
21use glow::HasContext;
22use jni::objects::{JByteArray, JClass, JFloatArray, JObject, JString, JValue};
23use jni::sys::{jdouble, jfloat, jint, jstring};
24use jni::{JNIEnv, JavaVM};
25use libloading::{Library, Symbol};
26
27use yog_abi::{
28 ABI_VERSION, YogAdvancementEvent, YogAdvancementFn, YogApi, YogAttackEntityFn,
29 YogBlockBreakFn, YogBlockDef, YogBlockPos, YogChatFn, YogClientFn, YogCommandFn,
30 YogContainerCloseEvent, YogContainerCloseFn, YogContainerOpenEvent, YogContainerOpenFn,
31 YogCraftEvent, YogCraftFn, YogEntityDamageFn, YogEntityDeathFn, YogEntityInteractEvent,
32 YogEntityInteractFn, YogEntitySpawnFn, YogExplosionEvent, YogExplosionFn,
33 YogGfxApi, YogHudRenderFn, YogItemDef, YogItemPickupEvent, YogItemPickupFn,
34 YogKeyPressFn, YogKeyPressEvent, YogOwnedStr, YogPacketFn, YogPlaceBlockEvent,
35 YogPlaceBlockFn, YogPlayerDeathEvent, YogPlayerDeathFn, YogPlayerFn, YogPlayerMoveEvent,
36 YogPlayerMoveFn, YogPlayerRespawnEvent, YogPlayerRespawnFn, YogProjectileHitEvent,
37 YogProjectileHitFn, YogScheduledFn, YogScreenFn, YogServer, YogServerFn, YogStr, YogStartupGrantDef,
38 YogUseBlockFn, YogUseItemFn, YogVec3, YogWorldRenderFn,
39};
40use yog_registry::{BlockDef, FoodDef, ItemDef};
41
42static JAVA_VM: OnceLock<JavaVM> = OnceLock::new();
46static LOADED_MODS: Mutex<Vec<Library>> = Mutex::new(Vec::new());
48static MOD_INFOS: Mutex<Vec<[String; 5]>> = Mutex::new(Vec::new());
50static SERVER: OnceLock<YogServer> = OnceLock::new();
52static HANDLERS: OnceLock<RuntimeHandlers> = OnceLock::new();
54
55struct GlCtx(glow::Context);
58unsafe impl Send for GlCtx {}
59unsafe impl Sync for GlCtx {}
60
61static GL: OnceLock<GlCtx> = OnceLock::new();
63
64static GL_GET_PROGRAM_BINARY: OnceLock<Option<usize>> = OnceLock::new();
68static GL_PROGRAM_BINARY: OnceLock<Option<usize>> = OnceLock::new();
69static GL_GET_PROGRAM_IV: OnceLock<Option<usize>> = OnceLock::new();
70
71#[derive(Debug, Clone)]
74pub struct UiLayer {
75 pub id: String,
76 pub parent: Option<String>,
77 pub modal: bool,
78 pub pause_game: bool,
79 pub visible: bool,
80 pub enabled: bool,
81 pub z_index: i32,
82}
83
84struct RuntimeHandlers {
85 block_break: Vec<(*mut c_void, YogBlockBreakFn)>,
86 chat: Vec<(*mut c_void, YogChatFn)>,
87 player_join: Vec<(*mut c_void, YogPlayerFn)>,
88 player_leave: Vec<(*mut c_void, YogPlayerFn)>,
89 use_item: Vec<(*mut c_void, YogUseItemFn)>,
90 use_block: Vec<(*mut c_void, YogUseBlockFn)>,
91 attack_entity: Vec<(*mut c_void, YogAttackEntityFn)>,
92 entity_damage: Vec<(*mut c_void, YogEntityDamageFn)>,
93 entity_death: Vec<(*mut c_void, YogEntityDeathFn)>,
94 entity_spawn: Vec<(*mut c_void, YogEntitySpawnFn)>,
95 player_place_block: Vec<(*mut c_void, YogPlaceBlockFn)>,
96 player_death: Vec<(*mut c_void, YogPlayerDeathFn)>,
97 player_respawn: Vec<(*mut c_void, YogPlayerRespawnFn)>,
98 advancement: Vec<(*mut c_void, YogAdvancementFn)>,
99 entity_interact: Vec<(*mut c_void, YogEntityInteractFn)>,
100 item_craft: Vec<(*mut c_void, YogCraftFn)>,
101 explosion: Vec<(*mut c_void, YogExplosionFn)>,
102 item_pickup: Vec<(*mut c_void, YogItemPickupFn)>,
103 player_move: Vec<(*mut c_void, YogPlayerMoveFn)>,
104 container_open: Vec<(*mut c_void, YogContainerOpenFn)>,
105 container_close: Vec<(*mut c_void, YogContainerCloseFn)>,
106 projectile_hit: Vec<(*mut c_void, YogProjectileHitFn)>,
107 client_tick: Vec<(*mut c_void, YogClientFn)>,
108 hud_render: Vec<(*mut c_void, YogHudRenderFn)>,
109 world_render: Vec<(*mut c_void, YogWorldRenderFn)>,
110 key_press: Vec<(*mut c_void, YogKeyPressFn)>,
111 screen_open: Vec<(*mut c_void, YogScreenFn)>,
112 screen_close: Vec<(*mut c_void, YogScreenFn)>,
113 server_tick: Vec<(*mut c_void, YogServerFn)>,
114 server_started: Vec<(*mut c_void, YogServerFn)>,
115 server_stopping: Vec<(*mut c_void, YogServerFn)>,
116 commands: HashMap<String, (*mut c_void, YogCommandFn)>,
117 typed_schemas: HashMap<String, String>,
118 recipes: Vec<(String, String, String)>,
119 packets: HashMap<String, (*mut c_void, YogPacketFn)>,
120 client_packets: HashMap<String, (*mut c_void, YogPacketFn)>,
121 items: Vec<ItemDef>,
122 blocks: Vec<BlockDef>,
123 books: HashMap<String, String>,
124 book_renderers: Mutex<HashMap<String, yog_book::BookRenderer>>,
125 ui_handlers: HashMap<String, (*mut c_void, yog_abi::YogUIEventFn)>,
126 ui_render_handlers: HashMap<String, Vec<(*mut c_void, YogHudRenderFn)>>,
127 menu_entries: Vec<(String, String)>, pub active_uis: Mutex<Vec<UiLayer>>,
129 startup_grants: Vec<yog_registry::StartupGrant>,
130 startup_granted: Mutex<HashMap<String, bool>>,
131 pending_grants: Mutex<Vec<(String, String, u32)>>,
135 scheduler: Mutex<SchedulerState>,
136}
137
138unsafe impl Send for RuntimeHandlers {}
140unsafe impl Sync for RuntimeHandlers {}
141
142impl RuntimeHandlers {
143 fn new() -> Self {
144 Self {
145 block_break: Vec::new(), chat: Vec::new(),
146 player_join: Vec::new(), player_leave: Vec::new(),
147 use_item: Vec::new(), use_block: Vec::new(),
148 attack_entity: Vec::new(), entity_damage: Vec::new(),
149 entity_death: Vec::new(), entity_spawn: Vec::new(),
150 player_place_block: Vec::new(),
151 player_death: Vec::new(), player_respawn: Vec::new(), advancement: Vec::new(),
152 entity_interact: Vec::new(), item_craft: Vec::new(), explosion: Vec::new(),
153 item_pickup: Vec::new(), player_move: Vec::new(),
154 container_open: Vec::new(), container_close: Vec::new(),
155 projectile_hit: Vec::new(),
156 client_tick: Vec::new(), hud_render: Vec::new(), world_render: Vec::new(),
157 key_press: Vec::new(),
158 screen_open: Vec::new(), screen_close: Vec::new(),
159 server_tick: Vec::new(), server_started: Vec::new(), server_stopping: Vec::new(),
160 commands: HashMap::new(), typed_schemas: HashMap::new(),
161 recipes: Vec::new(), packets: HashMap::new(),
162 client_packets: HashMap::new(), items: Vec::new(),
163 ui_handlers: HashMap::new(), ui_render_handlers: HashMap::new(),
164 menu_entries: Vec::new(),
165 active_uis: Mutex::new(Vec::new()), startup_grants: Vec::new(),
166 blocks: Vec::new(), books: HashMap::new(),
167 book_renderers: Mutex::new(HashMap::new()),
168 startup_granted: Mutex::new(HashMap::new()),
169 pending_grants: Mutex::new(Vec::new()),
170 scheduler: Mutex::new(SchedulerState::new()),
171 }
172 }
173}
174
175struct SchedulerState {
176 once_tasks: Vec<OnceTask>,
177 repeating_tasks: Vec<RepeatingTask>,
178}
179
180struct OnceTask { delay_remaining: u64, ud: *mut c_void, f: YogScheduledFn }
181struct RepeatingTask { period: u64, ticks_left: u64, ud: *mut c_void, f: YogScheduledFn }
182
183unsafe impl Send for SchedulerState {}
184unsafe impl Sync for SchedulerState {}
185unsafe impl Send for OnceTask {}
186unsafe impl Send for RepeatingTask {}
187
188impl SchedulerState {
189 fn new() -> Self { Self { once_tasks: Vec::new(), repeating_tasks: Vec::new() } }
190}
191
192fn handlers() -> &'static RuntimeHandlers {
193 HANDLERS.get().expect("yog: nativeInit not called yet")
194}
195
196fn guard(label: &str, f: impl FnOnce()) {
199 if std::panic::catch_unwind(std::panic::AssertUnwindSafe(f)).is_err() {
200 yog_logging::error!("a mod panicked handling `{}` (ignored)", label);
201 }
202}
203
204macro_rules! jstr {
205 ($env:expr, $s:expr) => {
206 match $env.get_string(&$s) { Ok(s) => String::from(s), Err(_) => return }
207 };
208}
209
210unsafe fn ys_to_java<'l>(env: &mut JNIEnv<'l>, s: YogStr)
212 -> Option<jni::objects::JString<'l>>
213{
214 env.new_string(s.as_str()).ok()
215}
216
217fn get_env() -> Option<jni::AttachGuard<'static>> {
218 JAVA_VM.get()?.attach_current_thread().ok()
219}
220
221unsafe extern "C" fn yog_free_str(ptr: *mut u8, len: u32) {
224 if !ptr.is_null() {
225 drop(Box::from_raw(std::slice::from_raw_parts_mut(ptr, len as usize)));
226 }
227}
228
229fn jstring_to_owned(env: &mut JNIEnv, obj: jni::objects::JObject) -> YogOwnedStr {
230 if obj.as_raw().is_null() { return YogOwnedStr::NONE; }
231 match env.get_string(&JString::from(obj)) {
232 Ok(s) => YogOwnedStr::from_string(String::from(s)),
233 Err(_) => YogOwnedStr::NONE,
234 }
235}
236
237unsafe extern "C" fn srv_broadcast(_ctx: *mut c_void, msg: YogStr) {
242 let Some(mut env) = get_env() else { return };
243 if let Some(jmsg) = ys_to_java(&mut env, msg) {
244 let _ = env.call_static_method("dev/yog/NativeBridge", "broadcast",
245 "(Ljava/lang/String;)V", &[JValue::Object(&jmsg)]);
246 }
247}
248
249unsafe extern "C" fn srv_get_block(_ctx: *mut c_void, dim: YogStr, pos: YogBlockPos) -> YogOwnedStr {
250 let Some(mut env) = get_env() else { return YogOwnedStr::NONE };
251 let (Some(jd), ) = (ys_to_java(&mut env, dim),) else { return YogOwnedStr::NONE };
252 let ret = env.call_static_method("dev/yog/NativeBridge", "getBlock",
253 "(Ljava/lang/String;III)Ljava/lang/String;",
254 &[JValue::Object(&jd), JValue::Int(pos.x), JValue::Int(pos.y), JValue::Int(pos.z)]);
255 match ret.and_then(|v| v.l()) {
256 Ok(obj) => jstring_to_owned(&mut env, obj),
257 _ => YogOwnedStr::NONE,
258 }
259}
260
261unsafe extern "C" fn srv_set_block(_ctx: *mut c_void, dim: YogStr, pos: YogBlockPos, block: YogStr) -> bool {
262 let Some(mut env) = get_env() else { return false };
263 let (Some(jd), Some(jb)) = (ys_to_java(&mut env, dim), ys_to_java(&mut env, block)) else { return false };
264 env.call_static_method("dev/yog/NativeBridge", "setBlock",
265 "(Ljava/lang/String;IIILjava/lang/String;)Z",
266 &[JValue::Object(&jd), JValue::Int(pos.x), JValue::Int(pos.y), JValue::Int(pos.z), JValue::Object(&jb)])
267 .and_then(|v| v.z()).unwrap_or(false)
268}
269
270unsafe extern "C" fn srv_world_time(_ctx: *mut c_void, dim: YogStr, out: *mut i64) -> bool {
271 let Some(mut env) = get_env() else { return false };
272 let Some(jd) = ys_to_java(&mut env, dim) else { return false };
273 match env.call_static_method("dev/yog/NativeBridge", "worldTime",
274 "(Ljava/lang/String;)J", &[JValue::Object(&jd)]).and_then(|v| v.j()) {
275 Ok(v) if v != i64::MIN => { *out = v; true }
276 _ => false,
277 }
278}
279
280unsafe extern "C" fn srv_set_time(_ctx: *mut c_void, dim: YogStr, time: i64) -> bool {
281 let Some(mut env) = get_env() else { return false };
282 let Some(jd) = ys_to_java(&mut env, dim) else { return false };
283 env.call_static_method("dev/yog/NativeBridge", "worldSetTime",
284 "(Ljava/lang/String;J)Z", &[JValue::Object(&jd), JValue::Long(time)])
285 .and_then(|v| v.z()).unwrap_or(false)
286}
287
288unsafe extern "C" fn srv_is_raining(_ctx: *mut c_void, dim: YogStr) -> bool {
289 let Some(mut env) = get_env() else { return false };
290 let Some(jd) = ys_to_java(&mut env, dim) else { return false };
291 env.call_static_method("dev/yog/NativeBridge", "worldIsRaining",
292 "(Ljava/lang/String;)Z", &[JValue::Object(&jd)])
293 .and_then(|v| v.z()).unwrap_or(false)
294}
295
296unsafe extern "C" fn srv_set_weather(_ctx: *mut c_void, dim: YogStr, raining: bool, dur: i32) -> bool {
297 let Some(mut env) = get_env() else { return false };
298 let Some(jd) = ys_to_java(&mut env, dim) else { return false };
299 env.call_static_method("dev/yog/NativeBridge", "worldSetWeather",
300 "(Ljava/lang/String;ZI)Z",
301 &[JValue::Object(&jd), JValue::Bool(raining as u8), JValue::Int(dur)])
302 .and_then(|v| v.z()).unwrap_or(false)
303}
304
305unsafe extern "C" fn srv_give_item(_ctx: *mut c_void, player: YogStr, item: YogStr, count: u32) -> bool {
306 let Some(mut env) = get_env() else { return false };
307 let (Some(jp), Some(ji)) = (ys_to_java(&mut env, player), ys_to_java(&mut env, item)) else { return false };
308 env.call_static_method("dev/yog/NativeBridge", "giveItem",
309 "(Ljava/lang/String;Ljava/lang/String;I)Z",
310 &[JValue::Object(&jp), JValue::Object(&ji), JValue::Int(count as i32)])
311 .and_then(|v| v.z()).unwrap_or(false)
312}
313
314unsafe extern "C" fn srv_player_teleport(_ctx: *mut c_void, player: YogStr, pos: YogVec3) -> bool {
315 let Some(mut env) = get_env() else { return false };
316 let Some(jp) = ys_to_java(&mut env, player) else { return false };
317 env.call_static_method("dev/yog/NativeBridge", "teleport",
318 "(Ljava/lang/String;DDD)Z",
319 &[JValue::Object(&jp), JValue::Double(pos.x), JValue::Double(pos.y), JValue::Double(pos.z)])
320 .and_then(|v| v.z()).unwrap_or(false)
321}
322
323unsafe extern "C" fn srv_send_to_player(_ctx: *mut c_void, player: YogStr, channel: YogStr, data: *const u8, len: u32) -> bool {
324 let Some(mut env) = get_env() else { return false };
325 let (Some(jp), Some(jc)) = (ys_to_java(&mut env, player), ys_to_java(&mut env, channel)) else { return false };
326 let payload = std::slice::from_raw_parts(data, len as usize);
327 let Ok(jdata) = env.byte_array_from_slice(payload) else { return false };
328 env.call_static_method("dev/yog/NativeBridge", "sendToPlayer",
329 "(Ljava/lang/String;Ljava/lang/String;[B)Z",
330 &[JValue::Object(&jp), JValue::Object(&jc), JValue::Object(&jdata)])
331 .and_then(|v| v.z()).unwrap_or(false)
332}
333
334unsafe extern "C" fn srv_send_to_server(_ctx: *mut c_void, channel: YogStr, data: *const u8, len: u32) -> bool {
335 let Some(mut env) = get_env() else { return false };
336 let Some(jc) = ys_to_java(&mut env, channel) else { return false };
337 let payload = std::slice::from_raw_parts(data, len as usize);
338 let Ok(jdata) = env.byte_array_from_slice(payload) else { return false };
339 let result = env.call_static_method("dev/yog/YogClient", "sendToServer",
340 "(Ljava/lang/String;[B)Z", &[JValue::Object(&jc), JValue::Object(&jdata)]);
341 let _ = env.exception_clear();
342 result.and_then(|v| v.z()).unwrap_or(false)
343}
344
345unsafe extern "C" fn srv_kick_player(_ctx: *mut c_void, player: YogStr, reason: YogStr) -> bool {
346 let Some(mut env) = get_env() else { return false };
347 let (Some(jp), Some(jr)) = (ys_to_java(&mut env, player), ys_to_java(&mut env, reason)) else { return false };
348 env.call_static_method("dev/yog/NativeBridge", "kickPlayer",
349 "(Ljava/lang/String;Ljava/lang/String;)Z", &[JValue::Object(&jp), JValue::Object(&jr)])
350 .and_then(|v| v.z()).unwrap_or(false)
351}
352
353unsafe extern "C" fn srv_set_gamemode(_ctx: *mut c_void, player: YogStr, mode: YogStr) -> bool {
354 let Some(mut env) = get_env() else { return false };
355 let (Some(jp), Some(jg)) = (ys_to_java(&mut env, player), ys_to_java(&mut env, mode)) else { return false };
356 env.call_static_method("dev/yog/NativeBridge", "setGamemode",
357 "(Ljava/lang/String;Ljava/lang/String;)Z", &[JValue::Object(&jp), JValue::Object(&jg)])
358 .and_then(|v| v.z()).unwrap_or(false)
359}
360
361unsafe extern "C" fn srv_send_title(_ctx: *mut c_void, player: YogStr, title: YogStr, sub: YogStr, fi: i32, stay: i32, fo: i32) -> bool {
362 let Some(mut env) = get_env() else { return false };
363 let (Some(jp), Some(jt), Some(js)) = (ys_to_java(&mut env, player), ys_to_java(&mut env, title), ys_to_java(&mut env, sub)) else { return false };
364 env.call_static_method("dev/yog/NativeBridge", "sendTitle",
365 "(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;III)Z",
366 &[JValue::Object(&jp), JValue::Object(&jt), JValue::Object(&js), JValue::Int(fi), JValue::Int(stay), JValue::Int(fo)])
367 .and_then(|v| v.z()).unwrap_or(false)
368}
369
370unsafe extern "C" fn srv_send_actionbar(_ctx: *mut c_void, player: YogStr, msg: YogStr) -> bool {
371 let Some(mut env) = get_env() else { return false };
372 let (Some(jp), Some(jm)) = (ys_to_java(&mut env, player), ys_to_java(&mut env, msg)) else { return false };
373 env.call_static_method("dev/yog/NativeBridge", "sendActionbar",
374 "(Ljava/lang/String;Ljava/lang/String;)Z", &[JValue::Object(&jp), JValue::Object(&jm)])
375 .and_then(|v| v.z()).unwrap_or(false)
376}
377
378unsafe extern "C" fn srv_play_sound(_ctx: *mut c_void, dim: YogStr, pos: YogVec3, sound: YogStr, vol: f32, pitch: f32) -> bool {
379 let Some(mut env) = get_env() else { return false };
380 let (Some(jd), Some(js)) = (ys_to_java(&mut env, dim), ys_to_java(&mut env, sound)) else { return false };
381 env.call_static_method("dev/yog/NativeBridge", "playSound",
382 "(Ljava/lang/String;DDDLjava/lang/String;FF)Z",
383 &[JValue::Object(&jd), JValue::Double(pos.x), JValue::Double(pos.y), JValue::Double(pos.z), JValue::Object(&js), JValue::Float(vol), JValue::Float(pitch)])
384 .and_then(|v| v.z()).unwrap_or(false)
385}
386
387unsafe extern "C" fn srv_play_sound_player(_ctx: *mut c_void, player: YogStr, sound: YogStr, vol: f32, pitch: f32) -> bool {
388 let Some(mut env) = get_env() else { return false };
389 let (Some(jp), Some(js)) = (ys_to_java(&mut env, player), ys_to_java(&mut env, sound)) else { return false };
390 env.call_static_method("dev/yog/NativeBridge", "playSoundToPlayer",
391 "(Ljava/lang/String;Ljava/lang/String;FF)Z",
392 &[JValue::Object(&jp), JValue::Object(&js), JValue::Float(vol), JValue::Float(pitch)])
393 .and_then(|v| v.z()).unwrap_or(false)
394}
395
396unsafe extern "C" fn srv_entity_teleport(_ctx: *mut c_void, uuid: YogStr, pos: YogVec3) -> bool {
397 let Some(mut env) = get_env() else { return false };
398 let Some(ju) = ys_to_java(&mut env, uuid) else { return false };
399 env.call_static_method("dev/yog/NativeBridge", "entityTeleport",
400 "(Ljava/lang/String;DDD)Z",
401 &[JValue::Object(&ju), JValue::Double(pos.x), JValue::Double(pos.y), JValue::Double(pos.z)])
402 .and_then(|v| v.z()).unwrap_or(false)
403}
404
405unsafe extern "C" fn srv_entity_position(_ctx: *mut c_void, uuid: YogStr, out: *mut YogVec3) -> bool {
406 let Some(mut env) = get_env() else { return false };
407 let Some(ju) = ys_to_java(&mut env, uuid) else { return false };
408 let ret = env.call_static_method("dev/yog/NativeBridge", "entityPosition",
409 "(Ljava/lang/String;)Ljava/lang/String;", &[JValue::Object(&ju)]);
410 let obj = match ret.and_then(|v| v.l()) { Ok(o) => o, Err(_) => return false };
411 if obj.as_raw().is_null() { return false; }
412 let s: String = match env.get_string(&JString::from(obj)) { Ok(s) => String::from(s), Err(_) => return false };
413 let mut it = s.split('\t');
414 let (x, y, z) = (it.next(), it.next(), it.next());
415 if let (Some(x), Some(y), Some(z)) = (x.and_then(|v| v.parse().ok()), y.and_then(|v| v.parse().ok()), z.and_then(|v| v.parse().ok())) {
416 *out = YogVec3 { x, y, z }; true
417 } else { false }
418}
419
420unsafe extern "C" fn srv_entity_health(_ctx: *mut c_void, uuid: YogStr, out: *mut f32) -> bool {
421 let Some(mut env) = get_env() else { return false };
422 let Some(ju) = ys_to_java(&mut env, uuid) else { return false };
423 match env.call_static_method("dev/yog/NativeBridge", "entityHealth",
424 "(Ljava/lang/String;)D", &[JValue::Object(&ju)]).and_then(|v| v.d()) {
425 Ok(v) if !v.is_nan() => { *out = v as f32; true }
426 _ => false,
427 }
428}
429
430unsafe extern "C" fn srv_entity_set_health(_ctx: *mut c_void, uuid: YogStr, hp: f32) -> bool {
431 let Some(mut env) = get_env() else { return false };
432 let Some(ju) = ys_to_java(&mut env, uuid) else { return false };
433 env.call_static_method("dev/yog/NativeBridge", "entitySetHealth",
434 "(Ljava/lang/String;D)Z", &[JValue::Object(&ju), JValue::Double(hp as f64)])
435 .and_then(|v| v.z()).unwrap_or(false)
436}
437
438unsafe extern "C" fn srv_entity_kill(_ctx: *mut c_void, uuid: YogStr) -> bool {
439 let Some(mut env) = get_env() else { return false };
440 let Some(ju) = ys_to_java(&mut env, uuid) else { return false };
441 env.call_static_method("dev/yog/NativeBridge", "entityKill",
442 "(Ljava/lang/String;)Z", &[JValue::Object(&ju)])
443 .and_then(|v| v.z()).unwrap_or(false)
444}
445
446unsafe extern "C" fn srv_spawn_entity(_ctx: *mut c_void, type_id: YogStr, dim: YogStr, pos: YogVec3) -> YogOwnedStr {
447 let Some(mut env) = get_env() else { return YogOwnedStr::NONE };
448 let (Some(jt), Some(jd)) = (ys_to_java(&mut env, type_id), ys_to_java(&mut env, dim)) else { return YogOwnedStr::NONE };
449 let ret = env.call_static_method("dev/yog/NativeBridge", "spawnEntity",
450 "(Ljava/lang/String;Ljava/lang/String;DDD)Ljava/lang/String;",
451 &[JValue::Object(&jt), JValue::Object(&jd), JValue::Double(pos.x), JValue::Double(pos.y), JValue::Double(pos.z)]);
452 match ret.and_then(|v| v.l()) {
453 Ok(obj) => jstring_to_owned(&mut env, obj),
454 _ => YogOwnedStr::NONE,
455 }
456}
457
458unsafe extern "C" fn srv_entity_add_effect(_ctx: *mut c_void, uuid: YogStr, fx: YogStr, dur: i32, amp: u8, particles: bool) -> bool {
459 let Some(mut env) = get_env() else { return false };
460 let (Some(ju), Some(je)) = (ys_to_java(&mut env, uuid), ys_to_java(&mut env, fx)) else { return false };
461 env.call_static_method("dev/yog/NativeBridge", "entityAddEffect",
462 "(Ljava/lang/String;Ljava/lang/String;IIZ)Z",
463 &[JValue::Object(&ju), JValue::Object(&je), JValue::Int(dur), JValue::Int(amp as i32), JValue::Bool(particles as u8)])
464 .and_then(|v| v.z()).unwrap_or(false)
465}
466
467unsafe extern "C" fn srv_entity_remove_effect(_ctx: *mut c_void, uuid: YogStr, fx: YogStr) -> bool {
468 let Some(mut env) = get_env() else { return false };
469 let (Some(ju), Some(je)) = (ys_to_java(&mut env, uuid), ys_to_java(&mut env, fx)) else { return false };
470 env.call_static_method("dev/yog/NativeBridge", "entityRemoveEffect",
471 "(Ljava/lang/String;Ljava/lang/String;)Z", &[JValue::Object(&ju), JValue::Object(&je)])
472 .and_then(|v| v.z()).unwrap_or(false)
473}
474
475unsafe extern "C" fn srv_entity_clear_effects(_ctx: *mut c_void, uuid: YogStr) -> bool {
476 let Some(mut env) = get_env() else { return false };
477 let Some(ju) = ys_to_java(&mut env, uuid) else { return false };
478 env.call_static_method("dev/yog/NativeBridge", "entityClearEffects",
479 "(Ljava/lang/String;)Z", &[JValue::Object(&ju)])
480 .and_then(|v| v.z()).unwrap_or(false)
481}
482
483unsafe extern "C" fn srv_entity_velocity(_ctx: *mut c_void, uuid: YogStr, out: *mut YogVec3) -> bool {
484 let Some(mut env) = get_env() else { return false };
485 let Some(ju) = ys_to_java(&mut env, uuid) else { return false };
486 let ret = env.call_static_method("dev/yog/NativeBridge", "entityVelocity",
487 "(Ljava/lang/String;)Ljava/lang/String;", &[JValue::Object(&ju)]);
488 let obj = match ret.and_then(|v| v.l()) { Ok(o) => o, Err(_) => return false };
489 if obj.as_raw().is_null() { return false; }
490 let s: String = match env.get_string(&JString::from(obj)) { Ok(s) => String::from(s), Err(_) => return false };
491 let mut it = s.split('\t');
492 let (x, y, z) = (it.next(), it.next(), it.next());
493 if let (Some(x), Some(y), Some(z)) = (x.and_then(|v| v.parse().ok()), y.and_then(|v| v.parse().ok()), z.and_then(|v| v.parse().ok())) {
494 *out = YogVec3 { x, y, z }; true
495 } else { false }
496}
497
498unsafe extern "C" fn srv_entity_set_velocity(_ctx: *mut c_void, uuid: YogStr, vel: YogVec3) -> bool {
499 let Some(mut env) = get_env() else { return false };
500 let Some(ju) = ys_to_java(&mut env, uuid) else { return false };
501 env.call_static_method("dev/yog/NativeBridge", "entitySetVelocity",
502 "(Ljava/lang/String;DDD)Z",
503 &[JValue::Object(&ju), JValue::Double(vel.x), JValue::Double(vel.y), JValue::Double(vel.z)])
504 .and_then(|v| v.z()).unwrap_or(false)
505}
506
507unsafe extern "C" fn srv_entity_add_velocity(_ctx: *mut c_void, uuid: YogStr, vel: YogVec3) -> bool {
508 let Some(mut env) = get_env() else { return false };
509 let Some(ju) = ys_to_java(&mut env, uuid) else { return false };
510 env.call_static_method("dev/yog/NativeBridge", "entityAddVelocity",
511 "(Ljava/lang/String;DDD)Z",
512 &[JValue::Object(&ju), JValue::Double(vel.x), JValue::Double(vel.y), JValue::Double(vel.z)])
513 .and_then(|v| v.z()).unwrap_or(false)
514}
515
516unsafe extern "C" fn srv_has_item_tag(_ctx: *mut c_void, item: YogStr, tag: YogStr) -> bool {
517 let Some(mut env) = get_env() else { return false };
518 let (Some(ji), Some(jt)) = (ys_to_java(&mut env, item), ys_to_java(&mut env, tag)) else { return false };
519 env.call_static_method("dev/yog/NativeBridge", "hasItemTag",
520 "(Ljava/lang/String;Ljava/lang/String;)Z", &[JValue::Object(&ji), JValue::Object(&jt)])
521 .and_then(|v| v.z()).unwrap_or(false)
522}
523
524unsafe extern "C" fn srv_has_block_tag(_ctx: *mut c_void, block: YogStr, tag: YogStr) -> bool {
525 let Some(mut env) = get_env() else { return false };
526 let (Some(jb), Some(jt)) = (ys_to_java(&mut env, block), ys_to_java(&mut env, tag)) else { return false };
527 env.call_static_method("dev/yog/NativeBridge", "hasBlockTag",
528 "(Ljava/lang/String;Ljava/lang/String;)Z", &[JValue::Object(&jb), JValue::Object(&jt)])
529 .and_then(|v| v.z()).unwrap_or(false)
530}
531
532unsafe extern "C" fn srv_drop_loot(_ctx: *mut c_void, table: YogStr, dim: YogStr, pos: YogVec3) -> bool {
533 let Some(mut env) = get_env() else { return false };
534 let (Some(jt), Some(jd)) = (ys_to_java(&mut env, table), ys_to_java(&mut env, dim)) else { return false };
535 env.call_static_method("dev/yog/NativeBridge", "dropLoot",
536 "(Ljava/lang/String;Ljava/lang/String;DDD)Z",
537 &[JValue::Object(&jt), JValue::Object(&jd), JValue::Double(pos.x), JValue::Double(pos.y), JValue::Double(pos.z)])
538 .and_then(|v| v.z()).unwrap_or(false)
539}
540
541unsafe extern "C" fn srv_scoreboard_get(_ctx: *mut c_void, obj: YogStr, player: YogStr, out: *mut i32) -> bool {
542 let Some(mut env) = get_env() else { return false };
543 let (Some(jo), Some(jp)) = (ys_to_java(&mut env, obj), ys_to_java(&mut env, player)) else { return false };
544 match env.call_static_method("dev/yog/NativeBridge", "scoreboardGet",
545 "(Ljava/lang/String;Ljava/lang/String;)I", &[JValue::Object(&jo), JValue::Object(&jp)]).and_then(|v| v.i()) {
546 Ok(v) if v != i32::MIN => { *out = v; true }
547 _ => false,
548 }
549}
550
551unsafe extern "C" fn srv_scoreboard_set(_ctx: *mut c_void, obj: YogStr, player: YogStr, score: i32) -> bool {
552 let Some(mut env) = get_env() else { return false };
553 let (Some(jo), Some(jp)) = (ys_to_java(&mut env, obj), ys_to_java(&mut env, player)) else { return false };
554 env.call_static_method("dev/yog/NativeBridge", "scoreboardSet",
555 "(Ljava/lang/String;Ljava/lang/String;I)Z",
556 &[JValue::Object(&jo), JValue::Object(&jp), JValue::Int(score)])
557 .and_then(|v| v.z()).unwrap_or(false)
558}
559
560unsafe extern "C" fn srv_scoreboard_add(_ctx: *mut c_void, obj: YogStr, player: YogStr, delta: i32, out: *mut i32) -> bool {
561 let Some(mut env) = get_env() else { return false };
562 let (Some(jo), Some(jp)) = (ys_to_java(&mut env, obj), ys_to_java(&mut env, player)) else { return false };
563 match env.call_static_method("dev/yog/NativeBridge", "scoreboardAdd",
564 "(Ljava/lang/String;Ljava/lang/String;I)I",
565 &[JValue::Object(&jo), JValue::Object(&jp), JValue::Int(delta)]).and_then(|v| v.i()) {
566 Ok(v) if v != i32::MIN => { *out = v; true }
567 _ => false,
568 }
569}
570
571unsafe extern "C" fn srv_bossbar_create(_ctx: *mut c_void, id: YogStr, title: YogStr, color: YogStr, style: YogStr) -> bool {
572 let Some(mut env) = get_env() else { return false };
573 let (Some(ji), Some(jt), Some(jc), Some(js)) = (ys_to_java(&mut env, id), ys_to_java(&mut env, title), ys_to_java(&mut env, color), ys_to_java(&mut env, style)) else { return false };
574 env.call_static_method("dev/yog/NativeBridge", "bossbarCreate",
575 "(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Z",
576 &[JValue::Object(&ji), JValue::Object(&jt), JValue::Object(&jc), JValue::Object(&js)])
577 .and_then(|v| v.z()).unwrap_or(false)
578}
579
580unsafe extern "C" fn srv_bossbar_remove(_ctx: *mut c_void, id: YogStr) -> bool {
581 let Some(mut env) = get_env() else { return false };
582 let Some(ji) = ys_to_java(&mut env, id) else { return false };
583 env.call_static_method("dev/yog/NativeBridge", "bossbarRemove",
584 "(Ljava/lang/String;)Z", &[JValue::Object(&ji)])
585 .and_then(|v| v.z()).unwrap_or(false)
586}
587
588unsafe extern "C" fn srv_bossbar_set_title(_ctx: *mut c_void, id: YogStr, title: YogStr) -> bool {
589 let Some(mut env) = get_env() else { return false };
590 let (Some(ji), Some(jt)) = (ys_to_java(&mut env, id), ys_to_java(&mut env, title)) else { return false };
591 env.call_static_method("dev/yog/NativeBridge", "bossbarSetTitle",
592 "(Ljava/lang/String;Ljava/lang/String;)Z", &[JValue::Object(&ji), JValue::Object(&jt)])
593 .and_then(|v| v.z()).unwrap_or(false)
594}
595
596unsafe extern "C" fn srv_bossbar_set_progress(_ctx: *mut c_void, id: YogStr, progress: f32) -> bool {
597 let Some(mut env) = get_env() else { return false };
598 let Some(ji) = ys_to_java(&mut env, id) else { return false };
599 env.call_static_method("dev/yog/NativeBridge", "bossbarSetProgress",
600 "(Ljava/lang/String;F)Z", &[JValue::Object(&ji), JValue::Float(progress)])
601 .and_then(|v| v.z()).unwrap_or(false)
602}
603
604unsafe extern "C" fn srv_bossbar_set_color(_ctx: *mut c_void, id: YogStr, color: YogStr) -> bool {
605 let Some(mut env) = get_env() else { return false };
606 let (Some(ji), Some(jc)) = (ys_to_java(&mut env, id), ys_to_java(&mut env, color)) else { return false };
607 env.call_static_method("dev/yog/NativeBridge", "bossbarSetColor",
608 "(Ljava/lang/String;Ljava/lang/String;)Z", &[JValue::Object(&ji), JValue::Object(&jc)])
609 .and_then(|v| v.z()).unwrap_or(false)
610}
611
612unsafe extern "C" fn srv_bossbar_add_player(_ctx: *mut c_void, id: YogStr, player: YogStr) -> bool {
613 let Some(mut env) = get_env() else { return false };
614 let (Some(ji), Some(jp)) = (ys_to_java(&mut env, id), ys_to_java(&mut env, player)) else { return false };
615 env.call_static_method("dev/yog/NativeBridge", "bossbarAddPlayer",
616 "(Ljava/lang/String;Ljava/lang/String;)Z", &[JValue::Object(&ji), JValue::Object(&jp)])
617 .and_then(|v| v.z()).unwrap_or(false)
618}
619
620unsafe extern "C" fn srv_bossbar_remove_player(_ctx: *mut c_void, id: YogStr, player: YogStr) -> bool {
621 let Some(mut env) = get_env() else { return false };
622 let (Some(ji), Some(jp)) = (ys_to_java(&mut env, id), ys_to_java(&mut env, player)) else { return false };
623 env.call_static_method("dev/yog/NativeBridge", "bossbarRemovePlayer",
624 "(Ljava/lang/String;Ljava/lang/String;)Z", &[JValue::Object(&ji), JValue::Object(&jp)])
625 .and_then(|v| v.z()).unwrap_or(false)
626}
627
628unsafe extern "C" fn srv_bossbar_set_visible(_ctx: *mut c_void, id: YogStr, visible: bool) -> bool {
629 let Some(mut env) = get_env() else { return false };
630 let Some(ji) = ys_to_java(&mut env, id) else { return false };
631 env.call_static_method("dev/yog/NativeBridge", "bossbarSetVisible",
632 "(Ljava/lang/String;Z)Z", &[JValue::Object(&ji), JValue::Bool(visible as u8)])
633 .and_then(|v| v.z()).unwrap_or(false)
634}
635
636unsafe extern "C" fn srv_get_block_nbt(_ctx: *mut c_void, dim: YogStr, pos: YogBlockPos) -> YogOwnedStr {
637 let Some(mut env) = get_env() else { return YogOwnedStr::NONE };
638 let Some(jd) = ys_to_java(&mut env, dim) else { return YogOwnedStr::NONE };
639 let ret = env.call_static_method("dev/yog/NativeBridge", "getBlockNbt",
640 "(Ljava/lang/String;III)Ljava/lang/String;",
641 &[JValue::Object(&jd), JValue::Int(pos.x), JValue::Int(pos.y), JValue::Int(pos.z)]);
642 match ret.and_then(|v| v.l()) {
643 Ok(obj) => jstring_to_owned(&mut env, obj),
644 _ => YogOwnedStr::NONE,
645 }
646}
647
648unsafe extern "C" fn srv_set_block_nbt(_ctx: *mut c_void, dim: YogStr, pos: YogBlockPos, snbt: YogStr) -> bool {
649 let Some(mut env) = get_env() else { return false };
650 let (Some(jd), Some(js)) = (ys_to_java(&mut env, dim), ys_to_java(&mut env, snbt)) else { return false };
651 env.call_static_method("dev/yog/NativeBridge", "setBlockNbt",
652 "(Ljava/lang/String;IIILjava/lang/String;)Z",
653 &[JValue::Object(&jd), JValue::Int(pos.x), JValue::Int(pos.y), JValue::Int(pos.z), JValue::Object(&js)])
654 .and_then(|v| v.z()).unwrap_or(false)
655}
656
657unsafe extern "C" fn srv_player_inventory(_ctx: *mut c_void, player: YogStr) -> YogOwnedStr {
658 let Some(mut env) = get_env() else { return YogOwnedStr::NONE };
659 let Some(jp) = ys_to_java(&mut env, player) else { return YogOwnedStr::NONE };
660 let ret = env.call_static_method("dev/yog/NativeBridge", "playerInventory",
661 "(Ljava/lang/String;)Ljava/lang/String;", &[JValue::Object(&jp)]);
662 match ret.and_then(|v| v.l()) {
663 Ok(obj) => jstring_to_owned(&mut env, obj),
664 _ => YogOwnedStr::NONE,
665 }
666}
667
668unsafe extern "C" fn srv_player_set_slot(_ctx: *mut c_void, player: YogStr, slot: u32, item_id: YogStr, count: u32) -> bool {
669 let Some(mut env) = get_env() else { return false };
670 let (Some(jp), Some(ji)) = (ys_to_java(&mut env, player), ys_to_java(&mut env, item_id)) else { return false };
671 env.call_static_method("dev/yog/NativeBridge", "playerSetSlot",
672 "(Ljava/lang/String;ILjava/lang/String;I)Z",
673 &[JValue::Object(&jp), JValue::Int(slot as i32), JValue::Object(&ji), JValue::Int(count as i32)])
674 .and_then(|v| v.z()).unwrap_or(false)
675}
676
677unsafe extern "C" fn srv_player_teleport_dim(_ctx: *mut c_void, player: YogStr, dim: YogStr, pos: YogVec3) -> bool {
678 let Some(mut env) = get_env() else { return false };
679 let (Some(jp), Some(jd)) = (ys_to_java(&mut env, player), ys_to_java(&mut env, dim)) else { return false };
680 env.call_static_method("dev/yog/NativeBridge", "teleportToDim",
681 "(Ljava/lang/String;Ljava/lang/String;DDD)Z",
682 &[JValue::Object(&jp), JValue::Object(&jd), JValue::Double(pos.x), JValue::Double(pos.y), JValue::Double(pos.z)])
683 .and_then(|v| v.z()).unwrap_or(false)
684}
685
686unsafe extern "C" fn srv_entity_teleport_dim(_ctx: *mut c_void, uuid: YogStr, dim: YogStr, pos: YogVec3) -> bool {
687 let Some(mut env) = get_env() else { return false };
688 let (Some(ju), Some(jd)) = (ys_to_java(&mut env, uuid), ys_to_java(&mut env, dim)) else { return false };
689 env.call_static_method("dev/yog/NativeBridge", "entityTeleportToDim",
690 "(Ljava/lang/String;Ljava/lang/String;DDD)Z",
691 &[JValue::Object(&ju), JValue::Object(&jd), JValue::Double(pos.x), JValue::Double(pos.y), JValue::Double(pos.z)])
692 .and_then(|v| v.z()).unwrap_or(false)
693}
694
695unsafe extern "C" fn srv_online_players(_ctx: *mut c_void) -> YogOwnedStr {
696 let Some(mut env) = get_env() else { return YogOwnedStr::NONE };
697 let ret = env.call_static_method("dev/yog/NativeBridge", "onlinePlayers",
698 "()Ljava/lang/String;", &[]);
699 match ret.and_then(|v| v.l()) {
700 Ok(obj) => jstring_to_owned(&mut env, obj),
701 _ => YogOwnedStr::NONE,
702 }
703}
704
705unsafe extern "C" fn srv_world_entity_count(_ctx: *mut c_void, dim: YogStr, entity_type: YogStr) -> i32 {
706 let Some(mut env) = get_env() else { return -1 };
707 let d = dim.as_str();
708 let et = entity_type.as_str();
709 let jd = match env.new_string(d) { Ok(s) => s, Err(_) => return -1 };
710 let jet = match env.new_string(et) { Ok(s) => s, Err(_) => return -1 };
711 let ret = env.call_static_method("dev/yog/NativeBridge", "worldEntityCount",
712 "(Ljava/lang/String;Ljava/lang/String;)I",
713 &[JValue::Object(&jd), JValue::Object(&jet)]);
714 match ret.and_then(|v| v.i()) {
715 Ok(n) => n,
716 _ => -1,
717 }
718}
719
720unsafe extern "C" fn srv_game_dir(_ctx: *mut c_void) -> YogOwnedStr {
721 let Some(mut env) = get_env() else { return YogOwnedStr::NONE };
722 let ret = env.call_static_method("dev/yog/NativeBridge", "gameDir",
723 "()Ljava/lang/String;", &[]);
724 match ret.and_then(|v| v.l()) {
725 Ok(obj) => jstring_to_owned(&mut env, obj),
726 _ => YogOwnedStr::NONE,
727 }
728}
729
730unsafe extern "C" fn srv_entity_get_nbt(_ctx: *mut c_void, uuid: YogStr) -> YogOwnedStr {
731 let Some(mut env) = get_env() else { return YogOwnedStr::NONE };
732 let Some(ju) = ys_to_java(&mut env, uuid) else { return YogOwnedStr::NONE };
733 let ret = env.call_static_method("dev/yog/NativeBridge", "entityGetNbt",
734 "(Ljava/lang/String;)Ljava/lang/String;", &[JValue::Object(&ju)]);
735 match ret.and_then(|v| v.l()) {
736 Ok(obj) => jstring_to_owned(&mut env, obj),
737 _ => YogOwnedStr::NONE,
738 }
739}
740
741unsafe extern "C" fn srv_entity_set_nbt(_ctx: *mut c_void, uuid: YogStr, snbt: YogStr) -> bool {
742 let Some(mut env) = get_env() else { return false };
743 let (Some(ju), Some(js)) = (ys_to_java(&mut env, uuid), ys_to_java(&mut env, snbt)) else { return false };
744 env.call_static_method("dev/yog/NativeBridge", "entitySetNbt",
745 "(Ljava/lang/String;Ljava/lang/String;)Z", &[JValue::Object(&ju), JValue::Object(&js)])
746 .and_then(|v| v.z()).unwrap_or(false)
747}
748
749unsafe extern "C" fn srv_spawn_particles(
750 _ctx: *mut c_void, dim: YogStr, pos: YogVec3, particle_type: YogStr,
751 count: i32, dx: f64, dy: f64, dz: f64, speed: f64,
752) -> bool {
753 let Some(mut env) = get_env() else { return false };
754 let (Some(jd), Some(jp)) = (ys_to_java(&mut env, dim), ys_to_java(&mut env, particle_type)) else { return false };
755 env.call_static_method("dev/yog/NativeBridge", "spawnParticles",
756 "(Ljava/lang/String;DDDLjava/lang/String;IDDDD)Z",
757 &[JValue::Object(&jd), JValue::Double(pos.x), JValue::Double(pos.y), JValue::Double(pos.z),
758 JValue::Object(&jp), JValue::Int(count),
759 JValue::Double(dx), JValue::Double(dy), JValue::Double(dz), JValue::Double(speed)])
760 .and_then(|v| v.z()).unwrap_or(false)
761}
762
763unsafe extern "C" fn srv_entity_attribute_get(_ctx: *mut c_void, uuid: YogStr, attr: YogStr) -> f64 {
764 let Some(mut env) = get_env() else { return f64::NAN };
765 let (Some(ju), Some(ja)) = (ys_to_java(&mut env, uuid), ys_to_java(&mut env, attr)) else { return f64::NAN };
766 env.call_static_method("dev/yog/NativeBridge", "entityAttributeGet",
767 "(Ljava/lang/String;Ljava/lang/String;)D", &[JValue::Object(&ju), JValue::Object(&ja)])
768 .and_then(|v| v.d()).unwrap_or(f64::NAN)
769}
770
771unsafe extern "C" fn srv_entity_attribute_set(_ctx: *mut c_void, uuid: YogStr, attr: YogStr, value: f64) -> bool {
772 let Some(mut env) = get_env() else { return false };
773 let (Some(ju), Some(ja)) = (ys_to_java(&mut env, uuid), ys_to_java(&mut env, attr)) else { return false };
774 env.call_static_method("dev/yog/NativeBridge", "entityAttributeSet",
775 "(Ljava/lang/String;Ljava/lang/String;D)Z",
776 &[JValue::Object(&ju), JValue::Object(&ja), JValue::Double(value)])
777 .and_then(|v| v.z()).unwrap_or(false)
778}
779
780unsafe extern "C" fn srv_get_held_item_nbt(_ctx: *mut c_void, player: YogStr) -> YogOwnedStr {
781 let Some(mut env) = get_env() else { return YogOwnedStr::NONE };
782 let Some(jp) = ys_to_java(&mut env, player) else { return YogOwnedStr::NONE };
783 let ret = env.call_static_method("dev/yog/NativeBridge", "getHeldItemNbt",
784 "(Ljava/lang/String;)Ljava/lang/String;", &[JValue::Object(&jp)]);
785 match ret.and_then(|v| v.l()) {
786 Ok(obj) => jstring_to_owned(&mut env, obj),
787 _ => YogOwnedStr::NONE,
788 }
789}
790
791unsafe extern "C" fn srv_set_held_item_nbt(_ctx: *mut c_void, player: YogStr, snbt: YogStr) -> bool {
792 let Some(mut env) = get_env() else { return false };
793 let (Some(jp), Some(js)) = (ys_to_java(&mut env, player), ys_to_java(&mut env, snbt)) else { return false };
794 env.call_static_method("dev/yog/NativeBridge", "setHeldItemNbt",
795 "(Ljava/lang/String;Ljava/lang/String;)Z", &[JValue::Object(&jp), JValue::Object(&js)])
796 .and_then(|v| v.z()).unwrap_or(false)
797}
798
799unsafe extern "C" fn srv_get_offhand_item_nbt(_ctx: *mut c_void, player: YogStr) -> YogOwnedStr {
800 let Some(mut env) = get_env() else { return YogOwnedStr::NONE };
801 let Some(jp) = ys_to_java(&mut env, player) else { return YogOwnedStr::NONE };
802 let ret = env.call_static_method("dev/yog/NativeBridge", "getOffhandItemNbt",
803 "(Ljava/lang/String;)Ljava/lang/String;", &[JValue::Object(&jp)]);
804 match ret.and_then(|v| v.l()) {
805 Ok(obj) => jstring_to_owned(&mut env, obj),
806 _ => YogOwnedStr::NONE,
807 }
808}
809
810unsafe extern "C" fn srv_set_offhand_item_nbt(_ctx: *mut c_void, player: YogStr, snbt: YogStr) -> bool {
811 let Some(mut env) = get_env() else { return false };
812 let (Some(jp), Some(js)) = (ys_to_java(&mut env, player), ys_to_java(&mut env, snbt)) else { return false };
813 env.call_static_method("dev/yog/NativeBridge", "setOffhandItemNbt",
814 "(Ljava/lang/String;Ljava/lang/String;)Z", &[JValue::Object(&jp), JValue::Object(&js)])
815 .and_then(|v| v.z()).unwrap_or(false)
816}
817
818unsafe extern "C" fn srv_get_slot_item(_ctx: *mut c_void, player: YogStr, slot: u32) -> YogOwnedStr {
819 let Some(mut env) = get_env() else { return YogOwnedStr::NONE };
820 let Some(jp) = ys_to_java(&mut env, player) else { return YogOwnedStr::NONE };
821 let ret = env.call_static_method("dev/yog/NativeBridge", "getSlotItem",
822 "(Ljava/lang/String;I)Ljava/lang/String;",
823 &[JValue::Object(&jp), JValue::Int(slot as i32)]);
824 match ret.and_then(|v| v.l()) {
825 Ok(obj) => jstring_to_owned(&mut env, obj),
826 _ => YogOwnedStr::NONE,
827 }
828}
829
830unsafe extern "C" fn srv_set_slot_item(
831 _ctx: *mut c_void, player: YogStr, slot: u32,
832 item_id: YogStr, count: u32, snbt: YogStr,
833) -> bool {
834 let Some(mut env) = get_env() else { return false };
835 let (Some(jp), Some(ji), Some(js)) = (
836 ys_to_java(&mut env, player), ys_to_java(&mut env, item_id), ys_to_java(&mut env, snbt)
837 ) else { return false };
838 env.call_static_method("dev/yog/NativeBridge", "setSlotItem",
839 "(Ljava/lang/String;ILjava/lang/String;ILjava/lang/String;)Z",
840 &[JValue::Object(&jp), JValue::Int(slot as i32), JValue::Object(&ji), JValue::Int(count as i32), JValue::Object(&js)])
841 .and_then(|v| v.z()).unwrap_or(false)
842}
843
844fn gl_draw_mode(mode: u8) -> u32 {
853 match mode {
854 1 => glow::LINES,
855 2 => glow::LINE_STRIP,
856 3 => glow::TRIANGLE_STRIP,
857 4 => glow::TRIANGLE_FAN,
858 _ => glow::TRIANGLES,
859 }
860}
861
862fn gl_attr_type(dtype: u8) -> u32 {
863 match dtype {
864 1 => glow::UNSIGNED_BYTE,
865 2 => glow::INT,
866 3 => glow::UNSIGNED_INT,
867 _ => glow::FLOAT,
868 }
869}
870
871unsafe fn compile_shader(gl: &glow::Context, stage: u32, src: &str) -> Option<glow::NativeShader> {
872 let sh = gl.create_shader(stage).ok()?;
873 gl.shader_source(sh, src);
874 gl.compile_shader(sh);
875 if !gl.get_shader_compile_status(sh) {
876 yog_logging::error!("yog-gfx shader compile: {}", gl.get_shader_info_log(sh));
877 gl.delete_shader(sh);
878 return None;
879 }
880 Some(sh)
881}
882
883unsafe extern "C" fn gfx_buf_create() -> u32 {
886 let Some(g) = GL.get() else { return 0 };
887 g.0.create_buffer().map(|b| b.0.get()).unwrap_or(0)
888}
889
890unsafe extern "C" fn gfx_buf_delete(handle: u32) {
891 let Some(g) = GL.get() else { return };
892 let Some(n) = NonZeroU32::new(handle) else { return };
893 g.0.delete_buffer(glow::NativeBuffer(n));
894}
895
896unsafe extern "C" fn gfx_buf_data(handle: u32, bytes: *const u8, len: u32, dynamic: bool) {
897 let Some(g) = GL.get() else { return };
898 let Some(n) = NonZeroU32::new(handle) else { return };
899 let gl = &g.0;
900 let data = std::slice::from_raw_parts(bytes, len as usize);
901 let usage = if dynamic { glow::DYNAMIC_DRAW } else { glow::STATIC_DRAW };
902 gl.bind_buffer(glow::ARRAY_BUFFER, Some(glow::NativeBuffer(n)));
903 gl.buffer_data_u8_slice(glow::ARRAY_BUFFER, data, usage);
904 gl.bind_buffer(glow::ARRAY_BUFFER, None);
905}
906
907unsafe extern "C" fn gfx_buf_subdata(handle: u32, offset: u32, bytes: *const u8, len: u32) {
908 let Some(g) = GL.get() else { return };
909 let Some(n) = NonZeroU32::new(handle) else { return };
910 let gl = &g.0;
911 let data = std::slice::from_raw_parts(bytes, len as usize);
912 gl.bind_buffer(glow::ARRAY_BUFFER, Some(glow::NativeBuffer(n)));
913 gl.buffer_sub_data_u8_slice(glow::ARRAY_BUFFER, offset as i32, data);
914 gl.bind_buffer(glow::ARRAY_BUFFER, None);
915}
916
917unsafe extern "C" fn gfx_vao_create() -> u32 {
920 let Some(g) = GL.get() else { return 0 };
921 g.0.create_vertex_array().map(|v| v.0.get()).unwrap_or(0)
922}
923
924unsafe extern "C" fn gfx_vao_delete(handle: u32) {
925 let Some(g) = GL.get() else { return };
926 let Some(n) = NonZeroU32::new(handle) else { return };
927 g.0.delete_vertex_array(glow::NativeVertexArray(n));
928}
929
930unsafe extern "C" fn gfx_vao_attrib(
931 vao: u32, vbo: u32, index: u32, components: u8,
932 dtype: u8, normalized: bool, stride: u32, offset: u32,
933) {
934 let Some(g) = GL.get() else { return };
935 let (Some(vn), Some(bn)) = (NonZeroU32::new(vao), NonZeroU32::new(vbo)) else { return };
936 let gl = &g.0;
937 gl.bind_vertex_array(Some(glow::NativeVertexArray(vn)));
938 gl.bind_buffer(glow::ARRAY_BUFFER, Some(glow::NativeBuffer(bn)));
939 let gl_type = gl_attr_type(dtype);
940 if dtype == 2 || dtype == 3 {
941 gl.vertex_attrib_pointer_i32(index, components as i32, gl_type, stride as i32, offset as i32);
942 } else {
943 gl.vertex_attrib_pointer_f32(index, components as i32, gl_type, normalized, stride as i32, offset as i32);
944 }
945 gl.enable_vertex_attrib_array(index);
946 gl.bind_vertex_array(None);
947}
948
949unsafe extern "C" fn gfx_vao_set_ebo(vao: u32, ebo: u32) {
950 let Some(g) = GL.get() else { return };
951 let (Some(vn), Some(en)) = (NonZeroU32::new(vao), NonZeroU32::new(ebo)) else { return };
952 let gl = &g.0;
953 gl.bind_vertex_array(Some(glow::NativeVertexArray(vn)));
954 gl.bind_buffer(glow::ELEMENT_ARRAY_BUFFER, Some(glow::NativeBuffer(en)));
955 gl.bind_vertex_array(None);
956}
957
958fn shader_cache_path(vert: &str, frag: &str) -> Option<PathBuf> {
963 use std::hash::{Hash, Hasher};
964 let mut h = std::collections::hash_map::DefaultHasher::new();
965 vert.hash(&mut h);
966 frag.hash(&mut h);
967 let hash = h.finish();
968 let dir = std::env::var("HOME")
969 .map(|home| PathBuf::from(home).join(".cache").join("yog").join("shaders"))
970 .ok()?;
971 std::fs::create_dir_all(&dir).ok()?;
972 Some(dir.join(format!("{hash:016x}.ysc")))
973}
974
975unsafe fn load_shader_binary(gl: &glow::Context, data: &[u8]) -> Option<glow::NativeProgram> {
981 if data.len() < 4 { return None; }
982 type ProgramBinaryFn = unsafe extern "system" fn(u32, u32, *const c_void, i32);
983 let fn_ptr = (*GL_PROGRAM_BINARY.get()?)?;
984 let program_binary: ProgramBinaryFn = std::mem::transmute(fn_ptr);
985
986 let fmt = u32::from_le_bytes([data[0], data[1], data[2], data[3]]);
987 let prog = gl.create_program().ok()?;
988 program_binary(prog.0.get(), fmt, data[4..].as_ptr() as *const c_void, (data.len() - 4) as i32);
989 if gl.get_program_link_status(prog) { Some(prog) } else { gl.delete_program(prog); None }
990}
991
992unsafe fn get_shader_binary(prog: glow::NativeProgram) -> (Vec<u8>, u32) {
994 type GetProgramivFn = unsafe extern "system" fn(u32, u32, *mut i32);
995 type GetProgramBinaryFn = unsafe extern "system" fn(u32, i32, *mut i32, *mut u32, *mut c_void);
996
997 let Some(get_iv_raw) = GL_GET_PROGRAM_IV.get().and_then(|v| *v) else { return (vec![], 0) };
998 let Some(get_bin_raw) = GL_GET_PROGRAM_BINARY.get().and_then(|v| *v) else { return (vec![], 0) };
999 let get_program_iv: GetProgramivFn = std::mem::transmute(get_iv_raw);
1000 let get_program_binary: GetProgramBinaryFn = std::mem::transmute(get_bin_raw);
1001
1002 const PROGRAM_BINARY_LENGTH: u32 = 0x8741;
1004 let mut size: i32 = 0;
1005 get_program_iv(prog.0.get(), PROGRAM_BINARY_LENGTH, &mut size);
1006 if size <= 0 { return (vec![], 0); }
1007
1008 let mut buf = vec![0u8; size as usize];
1009 let mut actual_len: i32 = 0;
1010 let mut fmt: u32 = 0;
1011 get_program_binary(prog.0.get(), size, &mut actual_len, &mut fmt, buf.as_mut_ptr() as *mut c_void);
1012 buf.truncate(actual_len.max(0) as usize);
1013 (buf, fmt)
1014}
1015
1016unsafe extern "C" fn gfx_prog_create(vert: YogStr, frag: YogStr, out: *mut u32) -> bool {
1017 let Some(g) = GL.get() else { return false };
1018 let gl = &g.0;
1019 let vert_s = vert.as_str();
1020 let frag_s = frag.as_str();
1021
1022 let cache_path = shader_cache_path(vert_s, frag_s);
1024 if let Some(ref path) = cache_path {
1025 if let Ok(data) = std::fs::read(path) {
1026 if let Some(prog) = load_shader_binary(gl, &data) {
1027 *out = prog.0.get();
1028 return true;
1029 }
1030 let _ = std::fs::remove_file(path);
1032 }
1033 }
1034
1035 let vs = match compile_shader(gl, glow::VERTEX_SHADER, vert_s) {
1037 Some(s) => s,
1038 None => return false,
1039 };
1040 let fs = match compile_shader(gl, glow::FRAGMENT_SHADER, frag_s) {
1041 Some(s) => s,
1042 None => { gl.delete_shader(vs); return false; }
1043 };
1044 let prog = match gl.create_program() {
1045 Ok(p) => p,
1046 Err(e) => {
1047 yog_logging::error!("yog-gfx: create_program: {}", e);
1048 gl.delete_shader(vs); gl.delete_shader(fs);
1049 return false;
1050 }
1051 };
1052 gl.attach_shader(prog, vs);
1053 gl.attach_shader(prog, fs);
1054 gl.link_program(prog);
1055 gl.detach_shader(prog, vs);
1056 gl.detach_shader(prog, fs);
1057 gl.delete_shader(vs);
1058 gl.delete_shader(fs);
1059 if !gl.get_program_link_status(prog) {
1060 yog_logging::error!("yog-gfx: shader link: {}", gl.get_program_info_log(prog));
1061 gl.delete_program(prog);
1062 return false;
1063 }
1064
1065 if let Some(ref path) = cache_path {
1067 let (binary, fmt) = get_shader_binary(prog);
1068 if !binary.is_empty() {
1069 let mut blob = fmt.to_le_bytes().to_vec();
1070 blob.extend_from_slice(&binary);
1071 let _ = std::fs::write(path, &blob);
1072 }
1073 }
1074
1075 *out = prog.0.get();
1076 true
1077}
1078
1079unsafe extern "C" fn gfx_prog_delete(handle: u32) {
1080 let Some(g) = GL.get() else { return };
1081 let Some(n) = NonZeroU32::new(handle) else { return };
1082 g.0.delete_program(glow::NativeProgram(n));
1083}
1084
1085macro_rules! with_prog {
1086 ($handle:expr, |$gl:ident, $prog:ident, $loc:ident ($name:expr)| $body:expr) => {{
1087 let Some(g) = GL.get() else { return };
1088 let Some(n) = NonZeroU32::new($handle) else { return };
1089 let $gl = &g.0;
1090 let $prog = glow::NativeProgram(n);
1091 $gl.use_program(Some($prog));
1092 let $loc = $gl.get_uniform_location($prog, $name.as_str());
1093 $body
1094 }};
1095}
1096
1097unsafe extern "C" fn gfx_prog_uniform_1i(prog: u32, name: YogStr, v: i32) {
1098 with_prog!(prog, |gl, _p, loc(name)| gl.uniform_1_i32(loc.as_ref(), v));
1099}
1100unsafe extern "C" fn gfx_prog_uniform_1f(prog: u32, name: YogStr, v: f32) {
1101 with_prog!(prog, |gl, _p, loc(name)| gl.uniform_1_f32(loc.as_ref(), v));
1102}
1103unsafe extern "C" fn gfx_prog_uniform_2f(prog: u32, name: YogStr, x: f32, y: f32) {
1104 with_prog!(prog, |gl, _p, loc(name)| gl.uniform_2_f32(loc.as_ref(), x, y));
1105}
1106unsafe extern "C" fn gfx_prog_uniform_3f(prog: u32, name: YogStr, x: f32, y: f32, z: f32) {
1107 with_prog!(prog, |gl, _p, loc(name)| gl.uniform_3_f32(loc.as_ref(), x, y, z));
1108}
1109unsafe extern "C" fn gfx_prog_uniform_4f(prog: u32, name: YogStr, x: f32, y: f32, z: f32, w: f32) {
1110 with_prog!(prog, |gl, _p, loc(name)| gl.uniform_4_f32(loc.as_ref(), x, y, z, w));
1111}
1112unsafe extern "C" fn gfx_prog_uniform_mat4(prog: u32, name: YogStr, col_major: *const f32) {
1113 with_prog!(prog, |gl, _p, loc(name)| {
1114 let data = std::slice::from_raw_parts(col_major, 16);
1115 gl.uniform_matrix_4_f32_slice(loc.as_ref(), false, data);
1116 });
1117}
1118
1119unsafe extern "C" fn gfx_tex_create(w: u32, h: u32, rgba: *const u8, linear: bool) -> u32 {
1122 let Some(g) = GL.get() else { return 0 };
1123 let gl = &g.0;
1124 let tex = match gl.create_texture() { Ok(t) => t, Err(_) => return 0 };
1125 gl.bind_texture(glow::TEXTURE_2D, Some(tex));
1126 let filter = if linear { glow::LINEAR } else { glow::NEAREST };
1127 gl.tex_parameter_i32(glow::TEXTURE_2D, glow::TEXTURE_MIN_FILTER, filter as i32);
1128 gl.tex_parameter_i32(glow::TEXTURE_2D, glow::TEXTURE_MAG_FILTER, filter as i32);
1129 gl.tex_parameter_i32(glow::TEXTURE_2D, glow::TEXTURE_WRAP_S, glow::CLAMP_TO_EDGE as i32);
1130 gl.tex_parameter_i32(glow::TEXTURE_2D, glow::TEXTURE_WRAP_T, glow::CLAMP_TO_EDGE as i32);
1131 let pixels = std::slice::from_raw_parts(rgba, (w * h * 4) as usize);
1132 gl.tex_image_2d(
1133 glow::TEXTURE_2D, 0, glow::RGBA8 as i32,
1134 w as i32, h as i32, 0,
1135 glow::RGBA, glow::UNSIGNED_BYTE,
1136 Some(pixels),
1137 );
1138 gl.bind_texture(glow::TEXTURE_2D, None);
1139 tex.0.get()
1140}
1141
1142unsafe extern "C" fn gfx_tex_delete(handle: u32) {
1143 let Some(g) = GL.get() else { return };
1144 let Some(n) = NonZeroU32::new(handle) else { return };
1145 g.0.delete_texture(glow::NativeTexture(n));
1146}
1147
1148unsafe extern "C" fn gfx_tex_bind(unit: u32, handle: u32) {
1149 let Some(g) = GL.get() else { return };
1150 let gl = &g.0;
1151 gl.active_texture(glow::TEXTURE0 + unit);
1152 match NonZeroU32::new(handle) {
1153 Some(n) => gl.bind_texture(glow::TEXTURE_2D, Some(glow::NativeTexture(n))),
1154 None => gl.bind_texture(glow::TEXTURE_2D, None),
1155 }
1156}
1157
1158unsafe extern "C" fn gfx_tex_from_mc(id: YogStr) -> u32 {
1159 let Some(mut env) = get_env() else { return 0 };
1160 let Some(ji) = ys_to_java(&mut env, id) else { return 0 };
1161 env.call_static_method("dev/yog/NativeDraw", "getMcTextureId",
1162 "(Ljava/lang/String;)I", &[JValue::Object(&ji)])
1163 .and_then(|v| v.i())
1164 .map(|id| id as u32)
1165 .unwrap_or(0)
1166}
1167
1168unsafe extern "C" fn gfx_draw_arrays(vao: u32, prog: u32, mode: u8, first: u32, count: u32) {
1171 let Some(g) = GL.get() else { return };
1172 let (Some(vn), Some(pn)) = (NonZeroU32::new(vao), NonZeroU32::new(prog)) else { return };
1173 let gl = &g.0;
1174 gl.use_program(Some(glow::NativeProgram(pn)));
1175 gl.bind_vertex_array(Some(glow::NativeVertexArray(vn)));
1176 gl.draw_arrays(gl_draw_mode(mode), first as i32, count as i32);
1177 gl.bind_vertex_array(None);
1178}
1179
1180unsafe extern "C" fn gfx_draw_elements(vao: u32, ebo: u32, prog: u32, mode: u8, count: u32, u32_idx: bool) {
1181 let Some(g) = GL.get() else { return };
1182 let (Some(vn), Some(pn)) = (NonZeroU32::new(vao), NonZeroU32::new(prog)) else { return };
1183 let gl = &g.0;
1184 gl.use_program(Some(glow::NativeProgram(pn)));
1185 gl.bind_vertex_array(Some(glow::NativeVertexArray(vn)));
1186 let _ = ebo;
1188 let idx_type = if u32_idx { glow::UNSIGNED_INT } else { glow::UNSIGNED_SHORT };
1189 gl.draw_elements(gl_draw_mode(mode), count as i32, idx_type, 0);
1190 gl.bind_vertex_array(None);
1191}
1192
1193unsafe extern "C" fn gfx_set_blend(enabled: bool, src: u32, dst: u32) {
1196 let Some(g) = GL.get() else { return };
1197 let gl = &g.0;
1198 if enabled {
1199 gl.enable(glow::BLEND);
1200 gl.blend_func(src, dst);
1201 } else {
1202 gl.disable(glow::BLEND);
1203 }
1204}
1205
1206unsafe extern "C" fn gfx_set_depth(test: bool, write: bool) {
1207 let Some(g) = GL.get() else { return };
1208 let gl = &g.0;
1209 if test { gl.enable(glow::DEPTH_TEST); } else { gl.disable(glow::DEPTH_TEST); }
1210 gl.depth_mask(write);
1211 if !test { gl.disable(glow::CULL_FACE); }
1213}
1214
1215unsafe extern "C" fn gfx_set_scissor(x: i32, y: i32, w: i32, h: i32) {
1216 let Some(g) = GL.get() else { return };
1217 let gl = &g.0;
1218 gl.enable(glow::SCISSOR_TEST);
1219 gl.scissor(x, y, w, h);
1220}
1221
1222unsafe extern "C" fn gfx_clear_scissor() {
1223 let Some(g) = GL.get() else { return };
1224 g.0.disable(glow::SCISSOR_TEST);
1225}
1226
1227unsafe extern "C" fn gfx_set_viewport(x: i32, y: i32, w: i32, h: i32) {
1228 let Some(g) = GL.get() else { return };
1229 g.0.viewport(x, y, w, h);
1230}
1231
1232unsafe extern "C" fn gfx_draw2d_rect(x1: f32, y1: f32, x2: f32, y2: f32, color: u32) {
1235 let Some(mut env) = get_env() else { return };
1236 let _ = env.call_static_method("dev/yog/NativeDraw", "drawRect",
1237 "(FFFFI)V",
1238 &[JValue::Float(x1), JValue::Float(y1), JValue::Float(x2), JValue::Float(y2),
1239 JValue::Int(color as i32)]);
1240}
1241
1242unsafe extern "C" fn gfx_draw2d_gradient(x1: f32, y1: f32, x2: f32, y2: f32, top: u32, bottom: u32) {
1243 let Some(mut env) = get_env() else { return };
1244 let _ = env.call_static_method("dev/yog/NativeDraw", "drawGradientRect",
1245 "(FFFFII)V",
1246 &[JValue::Float(x1), JValue::Float(y1), JValue::Float(x2), JValue::Float(y2),
1247 JValue::Int(top as i32), JValue::Int(bottom as i32)]);
1248}
1249
1250unsafe extern "C" fn gfx_draw2d_text(text: YogStr, x: f32, y: f32, color: u32, shadow: bool) {
1251 let Some(mut env) = get_env() else { return };
1252 if let Some(jt) = ys_to_java(&mut env, text) {
1253 let _ = env.call_static_method("dev/yog/NativeDraw", "drawText",
1254 "(Ljava/lang/String;FFIZ)V",
1255 &[JValue::Object(&jt), JValue::Float(x), JValue::Float(y),
1256 JValue::Int(color as i32), JValue::Bool(shadow as u8)]);
1257 }
1258}
1259
1260unsafe extern "C" fn gfx_draw2d_mc_tex(
1261 id: YogStr, x: f32, y: f32, u0: f32, v0: f32, w: f32, h: f32, tw: f32, th: f32,
1262) {
1263 let Some(mut env) = get_env() else { return };
1264 if let Some(ji) = ys_to_java(&mut env, id) {
1265 let _ = env.call_static_method("dev/yog/NativeDraw", "drawTexture",
1266 "(Ljava/lang/String;FFFFFFFFF)V",
1267 &[JValue::Object(&ji),
1268 JValue::Float(x), JValue::Float(y), JValue::Float(u0), JValue::Float(v0),
1269 JValue::Float(w), JValue::Float(h), JValue::Float(tw), JValue::Float(th)]);
1270 }
1271}
1272
1273unsafe extern "C" fn gfx_draw2d_item(id: YogStr, x: f32, y: f32, size: f32) {
1274 let Some(mut env) = get_env() else { return };
1275 if let Some(ji) = ys_to_java(&mut env, id) {
1276 let _ = env.call_static_method("dev/yog/NativeDraw", "drawItem",
1277 "(Ljava/lang/String;FFF)V",
1278 &[JValue::Object(&ji), JValue::Float(x), JValue::Float(y), JValue::Float(size)]);
1279 }
1280}
1281
1282static GFX_FN_TABLE: YogGfxApi = YogGfxApi {
1285 screen_w: 0, screen_h: 0, delta_tick: 0.0, scale_factor: 1.0,
1287 view_proj: [0.0; 16], camera_pos: [0.0; 3], player_pos: [0.0; 3], _pad1: 0.0,
1288 buf_create: gfx_buf_create,
1289 buf_delete: gfx_buf_delete,
1290 buf_data: gfx_buf_data,
1291 buf_subdata: gfx_buf_subdata,
1292 vao_create: gfx_vao_create,
1293 vao_delete: gfx_vao_delete,
1294 vao_attrib: gfx_vao_attrib,
1295 vao_set_ebo: gfx_vao_set_ebo,
1296 prog_create: gfx_prog_create,
1297 prog_delete: gfx_prog_delete,
1298 prog_uniform_1i: gfx_prog_uniform_1i,
1299 prog_uniform_1f: gfx_prog_uniform_1f,
1300 prog_uniform_2f: gfx_prog_uniform_2f,
1301 prog_uniform_3f: gfx_prog_uniform_3f,
1302 prog_uniform_4f: gfx_prog_uniform_4f,
1303 prog_uniform_mat4: gfx_prog_uniform_mat4,
1304 tex_create: gfx_tex_create,
1305 tex_delete: gfx_tex_delete,
1306 tex_bind: gfx_tex_bind,
1307 tex_from_mc: gfx_tex_from_mc,
1308 draw_arrays: gfx_draw_arrays,
1309 draw_elements: gfx_draw_elements,
1310 set_blend: gfx_set_blend,
1311 set_depth: gfx_set_depth,
1312 set_scissor: gfx_set_scissor,
1313 clear_scissor: gfx_clear_scissor,
1314 set_viewport: gfx_set_viewport,
1315 draw2d_rect: gfx_draw2d_rect,
1316 draw2d_gradient: gfx_draw2d_gradient,
1317 draw2d_text: gfx_draw2d_text,
1318 draw2d_mc_tex: gfx_draw2d_mc_tex,
1319 draw2d_item: gfx_draw2d_item,
1320};
1321
1322macro_rules! api_event {
1327 ($name:ident, $field:ident, $fn_ty:ty) => {
1328 unsafe extern "C" fn $name(ctx: *mut c_void, ud: *mut c_void, h: $fn_ty) {
1329 let handlers = &mut *(ctx as *mut RuntimeHandlers);
1330 handlers.$field.push((ud, h));
1331 }
1332 };
1333}
1334
1335api_event!(api_on_block_break, block_break, YogBlockBreakFn);
1336api_event!(api_on_chat, chat, YogChatFn);
1337api_event!(api_on_player_join, player_join, YogPlayerFn);
1338api_event!(api_on_player_leave, player_leave, YogPlayerFn);
1339api_event!(api_on_use_item, use_item, YogUseItemFn);
1340api_event!(api_on_use_block, use_block, YogUseBlockFn);
1341api_event!(api_on_attack_entity, attack_entity, YogAttackEntityFn);
1342api_event!(api_on_entity_damage, entity_damage, YogEntityDamageFn);
1343api_event!(api_on_entity_death, entity_death, YogEntityDeathFn);
1344api_event!(api_on_entity_spawn, entity_spawn, YogEntitySpawnFn);
1345api_event!(api_on_player_place_block, player_place_block, YogPlaceBlockFn);
1346api_event!(api_on_player_death, player_death, YogPlayerDeathFn);
1347api_event!(api_on_player_respawn, player_respawn, YogPlayerRespawnFn);
1348api_event!(api_on_advancement, advancement, YogAdvancementFn);
1349api_event!(api_on_entity_interact, entity_interact, YogEntityInteractFn);
1350api_event!(api_on_item_craft, item_craft, YogCraftFn);
1351api_event!(api_on_explosion, explosion, YogExplosionFn);
1352api_event!(api_on_item_pickup, item_pickup, YogItemPickupFn);
1353api_event!(api_on_player_move, player_move, YogPlayerMoveFn);
1354api_event!(api_on_container_open, container_open, YogContainerOpenFn);
1355api_event!(api_on_container_close, container_close, YogContainerCloseFn);
1356api_event!(api_on_projectile_hit, projectile_hit, YogProjectileHitFn);
1357api_event!(api_on_client_tick, client_tick, YogClientFn);
1358api_event!(api_on_hud_render, hud_render, YogHudRenderFn);
1359api_event!(api_on_world_render, world_render, YogWorldRenderFn);
1360api_event!(api_on_key_press, key_press, YogKeyPressFn);
1361api_event!(api_on_screen_open, screen_open, YogScreenFn);
1362api_event!(api_on_screen_close, screen_close, YogScreenFn);
1363api_event!(api_on_server_tick, server_tick, YogServerFn);
1364api_event!(api_on_server_started, server_started, YogServerFn);
1365api_event!(api_on_server_stopping, server_stopping, YogServerFn);
1366
1367unsafe extern "C" fn api_on_packet(ctx: *mut c_void, channel: YogStr, ud: *mut c_void, h: YogPacketFn) {
1368 let handlers = &mut *(ctx as *mut RuntimeHandlers);
1369 handlers.packets.insert(channel.as_str().to_owned(), (ud, h));
1370}
1371
1372unsafe extern "C" fn api_on_client_packet(ctx: *mut c_void, channel: YogStr, ud: *mut c_void, h: YogPacketFn) {
1373 let handlers = &mut *(ctx as *mut RuntimeHandlers);
1374 handlers.client_packets.insert(channel.as_str().to_owned(), (ud, h));
1375}
1376
1377unsafe extern "C" fn api_register_command(ctx: *mut c_void, name: YogStr, ud: *mut c_void, h: YogCommandFn) {
1378 let handlers = &mut *(ctx as *mut RuntimeHandlers);
1379 handlers.commands.insert(name.as_str().to_owned(), (ud, h));
1380}
1381
1382unsafe extern "C" fn api_register_typed_command(ctx: *mut c_void, name: YogStr, schema: YogStr, ud: *mut c_void, h: YogCommandFn) {
1383 let handlers = &mut *(ctx as *mut RuntimeHandlers);
1384 let n = name.as_str().to_owned();
1385 handlers.typed_schemas.insert(n.clone(), schema.as_str().to_owned());
1386 handlers.commands.insert(n, (ud, h));
1387}
1388
1389
1390unsafe extern "C" fn api_register_recipe_json(ctx: *mut c_void, namespace: YogStr, name: YogStr, json: YogStr) {
1391 let handlers = &mut *(ctx as *mut RuntimeHandlers);
1392 let ns = namespace.as_str().to_owned();
1393 let n = name.as_str().to_owned();
1394 let j = json.as_str().to_owned();
1395 let full_id = format!("{}:{}", ns, n);
1397 for r in handlers.book_renderers.lock().unwrap().values_mut() {
1398 r.add_recipe(full_id.clone(), &j);
1399 }
1400 handlers.recipes.push((ns, n, j));
1401}
1402
1403unsafe extern "C" fn api_register_item(ctx: *mut c_void, def: *const YogItemDef) {
1404 let handlers = &mut *(ctx as *mut RuntimeHandlers);
1405 let d = &*def;
1406 let food = if d.food_nutrition > 0 {
1407 Some(FoodDef { nutrition: d.food_nutrition, saturation: d.food_saturation, can_always_eat: d.food_always_eat })
1408 } else { None };
1409 handlers.items.push(ItemDef {
1410 id: d.id.as_str().to_owned(),
1411 max_stack: d.max_stack as u8,
1412 name: if d.name.is_empty() { None } else { Some(d.name.as_str().to_owned()) },
1413 tooltip: if d.tooltip.is_empty() { None } else { Some(d.tooltip.as_str().to_owned()) },
1414 max_damage: d.max_damage,
1415 fire_resistant: d.fire_resistant,
1416 fuel_ticks: d.fuel_ticks,
1417 food,
1418 });
1419}
1420
1421unsafe extern "C" fn api_register_block(ctx: *mut c_void, def: *const YogBlockDef) {
1422 let handlers = &mut *(ctx as *mut RuntimeHandlers);
1423 let d = &*def;
1424 handlers.blocks.push(BlockDef {
1425 id: d.id.as_str().to_owned(),
1426 hardness: d.hardness,
1427 resistance: d.resistance,
1428 name: if d.name.is_empty() { None } else { Some(d.name.as_str().to_owned()) },
1429 light_level: d.light_level,
1430 sound: if d.sound.is_empty() { None } else { Some(d.sound.as_str().to_owned()) },
1431 requires_tool: d.requires_tool,
1432 no_collision: d.no_collision,
1433 slipperiness: d.slipperiness,
1434 shape: if d.shape == [0.0f32; 6] { None } else { Some(d.shape) },
1435 });
1436}
1437
1438unsafe extern "C" fn api_schedule_once(ctx: *mut c_void, delay_ticks: u64, ud: *mut c_void, h: YogScheduledFn) {
1439 let handlers = &mut *(ctx as *mut RuntimeHandlers);
1440 handlers.scheduler.lock().expect("scheduler poisoned").once_tasks.push(OnceTask { delay_remaining: delay_ticks, ud, f: h });
1441}
1442
1443unsafe extern "C" fn api_schedule_repeating(ctx: *mut c_void, period_ticks: u64, ud: *mut c_void, h: YogScheduledFn) {
1444 let handlers = &mut *(ctx as *mut RuntimeHandlers);
1445 handlers.scheduler.lock().expect("scheduler poisoned").repeating_tasks.push(RepeatingTask { period: period_ticks, ticks_left: period_ticks, ud, f: h });
1446}
1447
1448unsafe extern "C" fn api_register_startup_grant(ctx: *mut c_void, grant: *const YogStartupGrantDef) {
1449 let handlers = &mut *(ctx as *mut RuntimeHandlers);
1450 let g = &*grant;
1451 let items: Vec<String> = if g.items.is_empty() {
1452 Vec::new()
1453 } else {
1454 unsafe { g.items.as_str().split('|').map(|s: &str| s.to_owned()).collect() }
1455 };
1456 let book = if g.book.is_empty() { None } else { Some(unsafe { g.book.as_str().to_owned() }) };
1457 let command = if g.command.is_empty() { None } else { Some(unsafe { g.command.as_str().to_owned() }) };
1458 handlers.startup_grants.push(yog_registry::StartupGrant {
1459 id: unsafe { g.id.as_str().to_owned() },
1460 items,
1461 book,
1462 command,
1463 });
1464}
1465
1466unsafe extern "C" fn api_register_book(ctx: *mut c_void, book_id: YogStr, book_json: YogStr) {
1467 let handlers = &mut *(ctx as *mut RuntimeHandlers);
1468 let id = unsafe { book_id.as_str().to_owned() };
1469 let json = unsafe { book_json.as_str().to_owned() };
1470 handlers.books.insert(id.clone(), json.clone());
1471 match serde_json::from_str::<yog_book::Book>(&json) {
1473 Ok(book) => {
1474 let mut renderer = yog_book::BookRenderer::new(book);
1475 for (ns, name, j) in &handlers.recipes {
1477 renderer.add_recipe(format!("{}:{}", ns, name), j);
1478 }
1479 handlers.book_renderers.lock().unwrap().insert(id, renderer);
1480 }
1481 Err(e) => {
1482 yog_logging::warn!("book '{}': failed to parse JSON for Rust renderer: {}", id, e);
1483 }
1484 }
1485}
1486
1487unsafe extern "C" fn api_register_ui(ctx: *mut c_void, ui_id: YogStr, _layout_json: YogStr,
1488 ud: *mut c_void, h: yog_abi::YogUIEventFn) {
1489 let handlers = &mut *(ctx as *mut RuntimeHandlers);
1490 let id = unsafe { ui_id.as_str().to_owned() };
1491 handlers.ui_handlers.insert(id.clone(), (ud, h));
1492 yog_logging::info!("registered UI handler: {}", id);
1493}
1494
1495unsafe extern "C" fn api_on_ui_render(ctx: *mut c_void, ui_id: YogStr,
1496 ud: *mut c_void, h: YogHudRenderFn) {
1497 let handlers = &mut *(ctx as *mut RuntimeHandlers);
1498 let id = unsafe { ui_id.as_str().to_owned() };
1499 handlers.ui_render_handlers.entry(id).or_default().push((ud, h));
1500}
1501
1502fn tsv_clean(v: &str) -> String {
1504 v.replace(['\t', '\n', '\r'], " ")
1505}
1506
1507unsafe extern "C" fn api_mods_list(_ctx: *mut c_void) -> YogOwnedStr {
1508 let mut lines: Vec<String> = Vec::new();
1509 for m in MOD_INFOS.lock().expect("mod infos lock poisoned").iter() {
1510 lines.push(format!("yog\t{}\t{}\t{}\t{}\t{}", m[0], m[1], m[2], m[3], m[4]));
1511 }
1512 if let Some(mut env) = get_env() {
1514 if let Ok(val) = env.call_static_method(
1515 "dev/yog/NativeBridge", "listPlatformMods", "()Ljava/lang/String;", &[],
1516 ) {
1517 if let Ok(obj) = val.l() {
1518 if !obj.as_raw().is_null() {
1519 if let Ok(js) = env.get_string(&obj.into()) {
1520 for line in String::from(js).lines() {
1521 if !line.trim().is_empty() {
1522 lines.push(format!("platform\t{line}"));
1523 }
1524 }
1525 }
1526 }
1527 }
1528 } else {
1529 env.exception_clear().ok();
1530 }
1531 }
1532 YogOwnedStr::from_string(lines.join("\n"))
1533}
1534
1535unsafe extern "C" fn api_register_menu_entry(ctx: *mut c_void, label: YogStr, ui_id: YogStr) {
1536 let handlers = &mut *(ctx as *mut RuntimeHandlers);
1537 let l = unsafe { label.as_str().to_owned() };
1538 let u = unsafe { ui_id.as_str().to_owned() };
1539 handlers.menu_entries.push((l, u));
1540}
1541
1542
1543#[no_mangle]
1544pub extern "system" fn Java_dev_yog_NativeBridge_nativeBookJson<'l>(
1545 mut env: JNIEnv<'l>, _class: JClass<'l>, book_id: JString<'l>,
1546) -> jstring {
1547 let id = match env.get_string(&book_id) {
1548 Ok(s) => String::from(s),
1549 Err(_) => return std::ptr::null_mut(),
1550 };
1551 let json = handlers().books.get(&id).cloned().unwrap_or_else(|| "null".to_string());
1552 env.new_string(json).map(|s| s.into_raw()).unwrap_or(std::ptr::null_mut())
1553}
1554
1555fn build_server_table() -> YogServer {
1558 YogServer {
1559 ctx: std::ptr::null_mut(),
1560 abi_version: ABI_VERSION,
1561 size: std::mem::size_of::<YogServer>() as u32,
1562 free_str: yog_free_str,
1563 broadcast: srv_broadcast,
1564 get_block: srv_get_block,
1565 set_block: srv_set_block,
1566 world_time: srv_world_time,
1567 set_time: srv_set_time,
1568 is_raining: srv_is_raining,
1569 set_weather: srv_set_weather,
1570 give_item: srv_give_item,
1571 player_teleport: srv_player_teleport,
1572 send_to_player: srv_send_to_player,
1573 send_to_server: srv_send_to_server,
1574 kick_player: srv_kick_player,
1575 set_gamemode: srv_set_gamemode,
1576 send_title: srv_send_title,
1577 send_actionbar: srv_send_actionbar,
1578 play_sound: srv_play_sound,
1579 play_sound_player: srv_play_sound_player,
1580 entity_teleport: srv_entity_teleport,
1581 entity_position: srv_entity_position,
1582 entity_health: srv_entity_health,
1583 entity_set_health: srv_entity_set_health,
1584 entity_kill: srv_entity_kill,
1585 spawn_entity: srv_spawn_entity,
1586 entity_add_effect: srv_entity_add_effect,
1587 entity_remove_effect: srv_entity_remove_effect,
1588 entity_clear_effects: srv_entity_clear_effects,
1589 entity_velocity: srv_entity_velocity,
1590 entity_set_velocity: srv_entity_set_velocity,
1591 entity_add_velocity: srv_entity_add_velocity,
1592 has_item_tag: srv_has_item_tag,
1593 has_block_tag: srv_has_block_tag,
1594 drop_loot: srv_drop_loot,
1595 scoreboard_get: srv_scoreboard_get,
1596 scoreboard_set: srv_scoreboard_set,
1597 scoreboard_add: srv_scoreboard_add,
1598 bossbar_create: srv_bossbar_create,
1599 bossbar_remove: srv_bossbar_remove,
1600 bossbar_set_title: srv_bossbar_set_title,
1601 bossbar_set_progress: srv_bossbar_set_progress,
1602 bossbar_set_color: srv_bossbar_set_color,
1603 bossbar_add_player: srv_bossbar_add_player,
1604 bossbar_remove_player: srv_bossbar_remove_player,
1605 bossbar_set_visible: srv_bossbar_set_visible,
1606 game_dir: srv_game_dir,
1607 get_block_nbt: srv_get_block_nbt,
1608 set_block_nbt: srv_set_block_nbt,
1609 player_inventory: srv_player_inventory,
1610 player_set_slot: srv_player_set_slot,
1611 player_teleport_dim: srv_player_teleport_dim,
1612 entity_teleport_dim: srv_entity_teleport_dim,
1613 online_players: srv_online_players,
1614 world_entity_count: srv_world_entity_count,
1615 entity_get_nbt: srv_entity_get_nbt,
1616 entity_set_nbt: srv_entity_set_nbt,
1617 spawn_particles: srv_spawn_particles,
1618 entity_attribute_get: srv_entity_attribute_get,
1619 entity_attribute_set: srv_entity_attribute_set,
1620 get_held_item_nbt: srv_get_held_item_nbt,
1621 set_held_item_nbt: srv_set_held_item_nbt,
1622 get_offhand_item_nbt: srv_get_offhand_item_nbt,
1623 set_offhand_item_nbt: srv_set_offhand_item_nbt,
1624 get_slot_item: srv_get_slot_item,
1625 set_slot_item: srv_set_slot_item,
1626 }
1627}
1628
1629fn build_api_table(ctx: *mut RuntimeHandlers, server: *const YogServer) -> YogApi {
1630 YogApi {
1631 abi_version: ABI_VERSION,
1632 size: std::mem::size_of::<YogApi>() as u32,
1633 ctx: ctx as *mut c_void,
1634 server,
1635 on_block_break: api_on_block_break,
1636 on_chat: api_on_chat,
1637 on_player_join: api_on_player_join,
1638 on_player_leave: api_on_player_leave,
1639 on_use_item: api_on_use_item,
1640 on_use_block: api_on_use_block,
1641 on_attack_entity: api_on_attack_entity,
1642 on_entity_damage: api_on_entity_damage,
1643 on_entity_death: api_on_entity_death,
1644 on_entity_spawn: api_on_entity_spawn,
1645 on_player_place_block: api_on_player_place_block,
1646 on_player_death: api_on_player_death,
1647 on_player_respawn: api_on_player_respawn,
1648 on_advancement: api_on_advancement,
1649 on_entity_interact: api_on_entity_interact,
1650 on_item_craft: api_on_item_craft,
1651 on_explosion: api_on_explosion,
1652 on_item_pickup: api_on_item_pickup,
1653 on_player_move: api_on_player_move,
1654 on_container_open: api_on_container_open,
1655 on_container_close: api_on_container_close,
1656 on_projectile_hit: api_on_projectile_hit,
1657 on_server_tick: api_on_server_tick,
1658 on_server_started: api_on_server_started,
1659 on_server_stopping: api_on_server_stopping,
1660 on_packet: api_on_packet,
1661 on_client_packet: api_on_client_packet,
1662 register_command: api_register_command,
1663 register_typed_command: api_register_typed_command,
1664 register_recipe_json: api_register_recipe_json,
1665 register_item: api_register_item,
1666 register_block: api_register_block,
1667 schedule_once: api_schedule_once,
1668 schedule_repeating: api_schedule_repeating,
1669 on_client_tick: api_on_client_tick,
1670 on_hud_render: api_on_hud_render,
1671 on_key_press: api_on_key_press,
1672 on_screen_open: api_on_screen_open,
1673 on_screen_close: api_on_screen_close,
1674 on_world_render: api_on_world_render,
1675 register_startup_grant: api_register_startup_grant,
1676 register_book: api_register_book,
1677 register_ui: api_register_ui,
1678 on_ui_render: api_on_ui_render,
1679 register_menu_entry: api_register_menu_entry,
1680 mods_list: api_mods_list,
1681 free_str: yog_free_str,
1682 }
1683}
1684
1685fn platform_tag() -> String {
1688 format!("{}-{}", std::env::consts::OS, std::env::consts::ARCH)
1689}
1690
1691type AbiVersionFn = unsafe extern "C" fn() -> u32;
1692type RegisterFn = unsafe extern "C" fn(*const YogApi, *mut c_void);
1693
1694fn load_mods(dir: &Path, api: &YogApi) {
1695 let entries = match std::fs::read_dir(dir) {
1696 Ok(e) => e,
1697 Err(_) => {
1698 yog_logging::info!("no mods directory at {} — none loaded", dir.display());
1699 return;
1700 }
1701 };
1702 let mut count = 0u32;
1703 for entry in entries.flatten() {
1704 let path = entry.path();
1705 let lib_path = match path.extension().and_then(|e| e.to_str()) {
1706 Some("yog") => match extract_yog(&path) {
1707 Some(p) => p,
1708 None => {
1709 yog_logging::error!("no native for {} in {}", platform_tag(), path.display());
1710 continue;
1711 }
1712 },
1713 Some("so") | Some("dll") | Some("dylib") => path.clone(),
1714 _ => continue,
1715 };
1716 if load_mod_lib(&lib_path, api) {
1717 count += 1;
1718 MOD_INFOS.lock().expect("mod infos lock poisoned").push(read_mod_info(&path));
1719 }
1720 }
1721 yog_logging::info!("loaded {} mod(s) from {}", count, dir.display());
1722}
1723
1724fn load_mod_lib(path: &Path, api: &YogApi) -> bool {
1725 unsafe {
1726 let lib = match Library::new(path) {
1727 Ok(l) => l,
1728 Err(e) => { yog_logging::error!("failed to load {}: {}", path.display(), e); return false; }
1729 };
1730 let abi: Symbol<AbiVersionFn> = match lib.get(b"yog_abi_version") {
1731 Ok(s) => s,
1732 Err(_) => { yog_logging::error!("{} is not a Yog mod (no yog_abi_version)", path.display()); return false; }
1733 };
1734 let mod_abi = abi();
1735 if mod_abi != ABI_VERSION {
1736 yog_logging::error!("{}: ABI {} incompatible with runtime ABI {}", path.display(), mod_abi, ABI_VERSION);
1737 return false;
1738 }
1739 let register: Symbol<RegisterFn> = match lib.get(b"yog_mod_register") {
1740 Ok(s) => s,
1741 Err(_) => { yog_logging::error!("{} missing yog_mod_register", path.display()); return false; }
1742 };
1743 register(api as *const YogApi, std::ptr::null_mut());
1744 drop(register);
1745 drop(abi);
1746 LOADED_MODS.lock().expect("mods lock poisoned").push(lib);
1747 }
1748 true
1749}
1750
1751fn read_mod_info(path: &Path) -> [String; 5] {
1755 let stem = path.file_stem().map(|s| s.to_string_lossy().into_owned()).unwrap_or_default();
1756 let mut info = [stem.clone(), stem, String::new(), String::new(), String::new()];
1757 if path.extension().and_then(|e| e.to_str()) != Some("yog") {
1758 return info;
1759 }
1760 let Some(text) = (|| {
1761 let file = std::fs::File::open(path).ok()?;
1762 let mut archive = zip::ZipArchive::new(file).ok()?;
1763 let mut entry = archive.by_name("yog.toml").ok()?;
1764 let mut text = String::new();
1765 std::io::Read::read_to_string(&mut entry, &mut text).ok()?;
1766 Some(text)
1767 })() else { return info };
1768 let mut in_mod = false;
1771 for line in text.lines() {
1772 let line = line.trim();
1773 if line.starts_with('[') {
1774 in_mod = line == "[mod]";
1775 continue;
1776 }
1777 if !in_mod { continue; }
1778 let Some((key, value)) = line.split_once('=') else { continue };
1779 let key = key.trim();
1780 let value = value.trim();
1781 let unquote = |v: &str| v.trim().trim_matches('"').to_string();
1782 match key {
1783 "id" => info[0] = tsv_clean(&unquote(value)),
1784 "name" => info[1] = tsv_clean(&unquote(value)),
1785 "version" => info[2] = tsv_clean(&unquote(value)),
1786 "description" => info[4] = tsv_clean(&unquote(value)),
1787 "authors" => {
1788 let list = value.trim_start_matches('[').trim_end_matches(']');
1789 let authors: Vec<String> = list.split(',')
1790 .map(|a| unquote(a))
1791 .filter(|a| !a.is_empty())
1792 .collect();
1793 info[3] = tsv_clean(&authors.join(", "));
1794 }
1795 _ => {}
1796 }
1797 }
1798 info
1799}
1800
1801fn extract_yog(path: &Path) -> Option<PathBuf> {
1802 let file = std::fs::File::open(path).ok()?;
1803 let mut archive = zip::ZipArchive::new(file).ok()?;
1804 let prefix = format!("natives/{}/", platform_tag());
1805 let mut entry_name = None;
1806 for i in 0..archive.len() {
1807 let f = archive.by_index(i).ok()?;
1808 if f.name().starts_with(&prefix) && !f.name().ends_with('/') {
1809 entry_name = Some(f.name().to_string());
1810 break;
1811 }
1812 }
1813 let entry_name = entry_name?;
1814 let ext = Path::new(&entry_name).extension().and_then(|e| e.to_str()).unwrap_or("bin");
1815 let stem = path.file_stem()?.to_string_lossy().into_owned();
1816 let out = std::env::temp_dir().join(format!("yog-{}-{}.{}", stem, std::process::id(), ext));
1817 let mut entry = archive.by_name(&entry_name).ok()?;
1818 let mut out_file = std::fs::File::create(&out).ok()?;
1819 std::io::copy(&mut entry, &mut out_file).ok()?;
1820 Some(out)
1821}
1822
1823fn srv_ptr() -> *const YogServer {
1826 SERVER.get().expect("yog: SERVER not initialised") as *const YogServer
1827}
1828
1829#[no_mangle]
1832pub extern "system" fn Java_dev_yog_NativeBridge_nativeInit<'l>(
1833 mut env: JNIEnv<'l>,
1834 _class: JClass<'l>,
1835 mods_dir: JString<'l>,
1836) {
1837 if let Ok(vm) = env.get_java_vm() { let _ = JAVA_VM.set(vm); }
1838
1839 let dir = env.get_string(&mods_dir).map(String::from).unwrap_or_default();
1840
1841 let _ = SERVER.set(build_server_table());
1843 let server_ptr = SERVER.get().unwrap() as *const YogServer;
1844
1845 let mut handlers = Box::new(RuntimeHandlers::new());
1848 let handlers_ptr = &mut *handlers as *mut RuntimeHandlers;
1849
1850 let api = build_api_table(handlers_ptr, server_ptr);
1851
1852 guard("mod loading", || {
1853 load_mods(Path::new(&dir), &api);
1854 });
1855
1856 let _ = HANDLERS.set(*handlers);
1858
1859 yog_logging::info!("runtime initialised — the gate is open.");
1860}
1861
1862#[no_mangle]
1863pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnBlockBreak<'l>(
1864 mut env: JNIEnv<'l>, _class: JClass<'l>,
1865 player: JString<'l>, block: JString<'l>, x: jint, y: jint, z: jint,
1866) {
1867 let (p, b) = (jstr!(env, player), jstr!(env, block));
1868 let ev = yog_abi::YogBlockBreakEvent {
1869 player: YogStr::from_str(&p), block: YogStr::from_str(&b),
1870 pos: YogBlockPos { x, y, z },
1871 };
1872 let srv = srv_ptr();
1873 guard("on_block_break", || {
1874 for (ud, f) in &handlers().block_break {
1875 unsafe { f(*ud, srv, &ev, 1) };
1876 }
1877 });
1878}
1879
1880#[no_mangle]
1881pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnChat<'l>(
1882 mut env: JNIEnv<'l>, _class: JClass<'l>,
1883 player: JString<'l>, message: JString<'l>,
1884) {
1885 let (p, m) = (jstr!(env, player), jstr!(env, message));
1886 let ev = yog_abi::YogChatEvent { player: YogStr::from_str(&p), message: YogStr::from_str(&m) };
1887 let srv = srv_ptr();
1888 guard("on_chat", || {
1889 for (ud, f) in &handlers().chat {
1890 unsafe { f(*ud, srv, &ev, 1) };
1891 }
1892 });
1893}
1894
1895#[no_mangle]
1896pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnPlayerJoin<'l>(
1897 mut env: JNIEnv<'l>, _class: JClass<'l>,
1898 player: JString<'l>, uuid: JString<'l>,
1899) {
1900 let (p, u) = (jstr!(env, player), jstr!(env, uuid));
1901 let ev = yog_abi::YogPlayerEvent { player: YogStr::from_str(&p), uuid: YogStr::from_str(&u) };
1902 let srv = srv_ptr();
1903 guard("on_player_join", || {
1904 for (ud, f) in &handlers().player_join {
1905 unsafe { f(*ud, srv, &ev, 1) };
1906 }
1907 });
1908 let h = handlers();
1912 if !h.startup_grants.is_empty() {
1913 h.pending_grants.lock().expect("pending_grants poisoned")
1914 .push((p, u, 0));
1915 }
1916}
1917
1918fn process_pending_grants() {
1921 let h = handlers();
1922 let mut pending = match h.pending_grants.try_lock() { Ok(g) => g, Err(_) => return };
1923 if pending.is_empty() { return; }
1924 const FIRST_TRY_TICK: u32 = 2;
1926 const MAX_TICKS: u32 = 600;
1928
1929 let mut granted = h.startup_granted.lock().expect("startup_granted poisoned");
1930 let mut still_pending = Vec::new();
1931 let mut any_new = false;
1932
1933 for (p, u, ticks) in pending.drain(..) {
1934 if ticks < FIRST_TRY_TICK {
1935 still_pending.push((p, u, ticks + 1));
1936 continue;
1937 }
1938 let mut all_ok = true;
1939 for sg in &h.startup_grants {
1940 let key = format!("{}::{}", u, sg.id);
1941 if granted.contains_key(&key) { continue; }
1942 let mut ok = true;
1943 for item_id in &sg.items {
1944 ok &= unsafe { srv_give_item(std::ptr::null_mut(),
1945 YogStr::from_str(&p), YogStr::from_str(item_id), 1) };
1946 }
1947 if let Some(_book) = &sg.book {
1948 ok &= unsafe { srv_give_item(std::ptr::null_mut(),
1949 YogStr::from_str(&p), YogStr::from_str("minecraft:written_book"), 1) };
1950 }
1951 if ok {
1952 yog_logging::info!("startup grant {} given to {}", sg.id, p);
1953 granted.insert(key, true);
1954 any_new = true;
1955 } else {
1956 all_ok = false;
1957 }
1958 }
1959 if !all_ok && ticks < MAX_TICKS {
1960 still_pending.push((p, u, ticks + 1));
1961 }
1962 }
1963 *pending = still_pending;
1964 if any_new {
1965 save_startup_granted(&granted);
1966 }
1967}
1968
1969#[no_mangle]
1970pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnPlayerLeave<'l>(
1971 mut env: JNIEnv<'l>, _class: JClass<'l>,
1972 player: JString<'l>, uuid: JString<'l>,
1973) {
1974 let (p, u) = (jstr!(env, player), jstr!(env, uuid));
1975 let ev = yog_abi::YogPlayerEvent { player: YogStr::from_str(&p), uuid: YogStr::from_str(&u) };
1976 let srv = srv_ptr();
1977 guard("on_player_leave", || {
1978 for (ud, f) in &handlers().player_leave {
1979 unsafe { f(*ud, srv, &ev, 1) };
1980 }
1981 });
1982}
1983
1984#[no_mangle]
1985pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnUseItem<'l>(
1986 mut env: JNIEnv<'l>, _class: JClass<'l>,
1987 player: JString<'l>, item: JString<'l>,
1988) {
1989 let (p, i) = (jstr!(env, player), jstr!(env, item));
1990 let ev = yog_abi::YogUseItemEvent { player: YogStr::from_str(&p), item: YogStr::from_str(&i) };
1991 let srv = srv_ptr();
1992 guard("on_use_item", || {
1993 for (ud, f) in &handlers().use_item {
1994 unsafe { f(*ud, srv, &ev, 1) };
1995 }
1996 });
1997}
1998
1999#[no_mangle]
2000pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnUseBlock<'l>(
2001 mut env: JNIEnv<'l>, _class: JClass<'l>,
2002 player: JString<'l>, block: JString<'l>, x: jint, y: jint, z: jint,
2003) {
2004 let (p, b) = (jstr!(env, player), jstr!(env, block));
2005 let ev = yog_abi::YogUseBlockEvent {
2006 player: YogStr::from_str(&p), block: YogStr::from_str(&b),
2007 pos: YogBlockPos { x, y, z },
2008 };
2009 let srv = srv_ptr();
2010 guard("on_use_block", || {
2011 for (ud, f) in &handlers().use_block {
2012 unsafe { f(*ud, srv, &ev, 1) };
2013 }
2014 });
2015}
2016
2017#[no_mangle]
2018pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnAttackEntity<'l>(
2019 mut env: JNIEnv<'l>, _class: JClass<'l>,
2020 player: JString<'l>, target_type: JString<'l>, target_uuid: JString<'l>,
2021) {
2022 let (p, tt, tu) = (jstr!(env, player), jstr!(env, target_type), jstr!(env, target_uuid));
2023 let ev = yog_abi::YogAttackEntityEvent {
2024 player: YogStr::from_str(&p), target_type: YogStr::from_str(&tt), target_uuid: YogStr::from_str(&tu),
2025 };
2026 let srv = srv_ptr();
2027 guard("on_attack_entity", || {
2028 for (ud, f) in &handlers().attack_entity {
2029 unsafe { f(*ud, srv, &ev, 1) };
2030 }
2031 });
2032}
2033
2034#[no_mangle]
2035pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnEntityDamage<'l>(
2036 mut env: JNIEnv<'l>, _class: JClass<'l>,
2037 entity_type: JString<'l>, uuid: JString<'l>, amount: jfloat, source: JString<'l>,
2038) {
2039 let (et, u, s) = (jstr!(env, entity_type), jstr!(env, uuid), jstr!(env, source));
2040 let ev = yog_abi::YogEntityDamageEvent {
2041 entity_type: YogStr::from_str(&et), uuid: YogStr::from_str(&u),
2042 amount, source: YogStr::from_str(&s),
2043 };
2044 let srv = srv_ptr();
2045 guard("on_entity_damage", || {
2046 for (ud, f) in &handlers().entity_damage {
2047 unsafe { f(*ud, srv, &ev, 1) };
2048 }
2049 });
2050}
2051
2052#[no_mangle]
2053pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnEntityDeath<'l>(
2054 mut env: JNIEnv<'l>, _class: JClass<'l>,
2055 entity_type: JString<'l>, uuid: JString<'l>, source: JString<'l>,
2056) {
2057 let (et, u, s) = (jstr!(env, entity_type), jstr!(env, uuid), jstr!(env, source));
2058 let ev = yog_abi::YogEntityDeathEvent {
2059 entity_type: YogStr::from_str(&et), uuid: YogStr::from_str(&u), source: YogStr::from_str(&s),
2060 };
2061 let srv = srv_ptr();
2062 guard("on_entity_death", || {
2063 for (ud, f) in &handlers().entity_death {
2064 unsafe { f(*ud, srv, &ev, 1) };
2065 }
2066 });
2067}
2068
2069#[no_mangle]
2070pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnTick<'l>(
2071 _env: JNIEnv<'l>, _class: JClass<'l>,
2072) {
2073 let h = handlers();
2074 let srv = srv_ptr();
2075 guard("on_tick", || {
2076 for (ud, f) in &h.server_tick {
2077 unsafe { f(*ud, srv) };
2078 }
2079 });
2080
2081 guard("startup_grants", process_pending_grants);
2082
2083 {
2085 let mut sched = h.scheduler.lock().expect("scheduler poisoned");
2086 let mut to_fire: Vec<(*mut c_void, YogScheduledFn)> = Vec::new();
2087 let mut remaining = Vec::new();
2088 for task in sched.once_tasks.drain(..) {
2089 if task.delay_remaining == 0 {
2090 to_fire.push((task.ud, task.f));
2091 } else {
2092 remaining.push(OnceTask { delay_remaining: task.delay_remaining - 1, ..task });
2093 }
2094 }
2095 sched.once_tasks = remaining;
2096 drop(sched);
2097 for (ud, f) in to_fire {
2098 guard("schedule_once", || unsafe { f(ud, srv) });
2099 }
2100 }
2101
2102 {
2104 let mut sched = h.scheduler.lock().expect("scheduler poisoned");
2105 let mut to_fire: Vec<(*mut c_void, YogScheduledFn)> = Vec::new();
2106 for task in &mut sched.repeating_tasks {
2107 if task.ticks_left == 0 {
2108 to_fire.push((task.ud, task.f));
2109 task.ticks_left = task.period;
2110 } else {
2111 task.ticks_left -= 1;
2112 }
2113 }
2114 drop(sched);
2115 for (ud, f) in to_fire {
2116 guard("schedule_repeating", || unsafe { f(ud, srv) });
2117 }
2118 }
2119}
2120
2121static WORLD_DIR: Mutex<Option<std::path::PathBuf>> = Mutex::new(None);
2123
2124fn startup_grants_path() -> std::path::PathBuf {
2127 let base = WORLD_DIR.lock().ok()
2128 .and_then(|d| d.clone())
2129 .unwrap_or_else(|| std::path::PathBuf::from("."));
2130 base.join("yog-data").join("startup_grants.json")
2131}
2132
2133fn load_startup_granted() {
2134 let h = handlers();
2135 let mut granted = h.startup_granted.lock().expect("startup_granted poisoned");
2136 granted.clear();
2139 h.pending_grants.lock().expect("pending_grants poisoned").clear();
2140 let path = startup_grants_path();
2141 let Ok(data) = std::fs::read_to_string(&path) else { return };
2142 let Ok(keys) = serde_json::from_str::<Vec<String>>(&data) else {
2143 yog_logging::warn!("startup_grants.json: invalid JSON, ignoring");
2144 return;
2145 };
2146 for k in keys {
2147 granted.insert(k, true);
2148 }
2149 yog_logging::info!("loaded {} startup grants from disk", granted.len());
2150}
2151
2152fn save_startup_granted(granted: &HashMap<String, bool>) {
2153 let path = startup_grants_path();
2154 if let Some(parent) = path.parent() {
2155 let _ = std::fs::create_dir_all(parent);
2156 }
2157 let keys: Vec<&String> = granted.keys().collect();
2158 match serde_json::to_string(&keys) {
2159 Ok(json) => { let _ = std::fs::write(&path, json); }
2160 Err(e) => yog_logging::error!("failed to save startup_grants.json: {}", e),
2161 }
2162}
2163
2164#[no_mangle]
2165pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnServerStarted<'l>(
2166 mut env: JNIEnv<'l>, _class: JClass<'l>,
2167 world_dir: JString<'l>,
2168) {
2169 let dir = jstr!(env, world_dir);
2170 *WORLD_DIR.lock().expect("WORLD_DIR poisoned") =
2171 if dir.is_empty() { None } else { Some(std::path::PathBuf::from(dir)) };
2172 load_startup_granted();
2173 let srv = srv_ptr();
2174 guard("on_server_started", || {
2175 for (ud, f) in &handlers().server_started {
2176 unsafe { f(*ud, srv) };
2177 }
2178 });
2179}
2180
2181#[no_mangle]
2182pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnServerStopping<'l>(
2183 _env: JNIEnv<'l>, _class: JClass<'l>,
2184) {
2185 let srv = srv_ptr();
2186 guard("on_server_stopping", || {
2187 for (ud, f) in &handlers().server_stopping {
2188 unsafe { f(*ud, srv) };
2189 }
2190 });
2191}
2192
2193#[no_mangle]
2194pub extern "system" fn Java_dev_yog_NativeBridge_nativeCommandNames<'l>(
2195 env: JNIEnv<'l>, _class: JClass<'l>,
2196) -> jstring {
2197 let names = handlers().commands.keys().cloned().collect::<Vec<_>>().join("\n");
2198 env.new_string(names).map(|s| s.into_raw()).unwrap_or(std::ptr::null_mut())
2199}
2200
2201#[no_mangle]
2202pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnBlockBreakPre<'l>(
2203 mut env: JNIEnv<'l>, _class: JClass<'l>,
2204 player: JString<'l>, block: JString<'l>, x: jint, y: jint, z: jint,
2205) -> jni::sys::jboolean {
2206 let h = handlers();
2207 if h.block_break.is_empty() { return 1; }
2208 let p = match env.get_string(&player) { Ok(s) => String::from(s), Err(_) => return 1 };
2209 let b = match env.get_string(&block) { Ok(s) => String::from(s), Err(_) => return 1 };
2210 let ev = yog_abi::YogBlockBreakEvent {
2211 player: YogStr::from_str(&p), block: YogStr::from_str(&b),
2212 pos: YogBlockPos { x, y, z },
2213 };
2214 let srv = srv_ptr();
2215 let mut allow = true;
2216 std::panic::catch_unwind(std::panic::AssertUnwindSafe(|| {
2217 for (ud, f) in &h.block_break {
2218 if !unsafe { f(*ud, srv, &ev, 0) } { allow = false; break; }
2219 }
2220 })).ok();
2221 allow as jni::sys::jboolean
2222}
2223
2224#[no_mangle]
2225pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnChatPre<'l>(
2226 mut env: JNIEnv<'l>, _class: JClass<'l>,
2227 player: JString<'l>, message: JString<'l>,
2228) -> jni::sys::jboolean {
2229 let h = handlers();
2230 if h.chat.is_empty() { return 1; }
2231 let p = match env.get_string(&player) { Ok(s) => String::from(s), Err(_) => return 1 };
2232 let m = match env.get_string(&message) { Ok(s) => String::from(s), Err(_) => return 1 };
2233 let ev = yog_abi::YogChatEvent { player: YogStr::from_str(&p), message: YogStr::from_str(&m) };
2234 let srv = srv_ptr();
2235 let mut allow = true;
2236 std::panic::catch_unwind(std::panic::AssertUnwindSafe(|| {
2237 for (ud, f) in &h.chat {
2238 if !unsafe { f(*ud, srv, &ev, 0) } { allow = false; break; }
2239 }
2240 })).ok();
2241 allow as jni::sys::jboolean
2242}
2243
2244#[no_mangle]
2245pub extern "system" fn Java_dev_yog_NativeBridge_nativeRecipeJsons<'l>(
2246 env: JNIEnv<'l>, _class: JClass<'l>,
2247) -> jstring {
2248 let s = handlers().recipes.iter()
2249 .map(|(ns, name, json)| format!("{}\t{}\t{}", ns, name, json))
2250 .collect::<Vec<_>>().join("\n");
2251 env.new_string(s).map(|s| s.into_raw()).unwrap_or(std::ptr::null_mut())
2252}
2253
2254#[no_mangle]
2255pub extern "system" fn Java_dev_yog_NativeBridge_nativeTypedCommandSchemas<'l>(
2256 env: JNIEnv<'l>, _class: JClass<'l>,
2257) -> jstring {
2258 let s = handlers().typed_schemas.iter()
2259 .map(|(name, schema)| format!("{}\t{}", name, schema))
2260 .collect::<Vec<_>>().join("\n");
2261 env.new_string(s).map(|s| s.into_raw()).unwrap_or(std::ptr::null_mut())
2262}
2263
2264#[no_mangle]
2265pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnCommand<'l>(
2266 mut env: JNIEnv<'l>, _class: JClass<'l>,
2267 name: JString<'l>, args: JString<'l>, source: JString<'l>, uuid: JString<'l>,
2268) -> jstring {
2269 let (n, a, s, u) = (
2270 env.get_string(&name).map(String::from).unwrap_or_default(),
2271 env.get_string(&args).map(String::from).unwrap_or_default(),
2272 env.get_string(&source).map(String::from).unwrap_or_default(),
2273 env.get_string(&uuid).map(String::from).unwrap_or_default(),
2274 );
2275 let ev = yog_abi::YogCommandEvent {
2276 name: YogStr::from_str(&n), args: YogStr::from_str(&a),
2277 source: YogStr::from_str(&s), uuid: YogStr::from_str(&u),
2278 };
2279 let h = handlers();
2280 let srv = srv_ptr();
2281 let reply = std::panic::catch_unwind(std::panic::AssertUnwindSafe(|| {
2282 if let Some((ud, f)) = h.commands.get(&n) {
2283 let mut buf = [0u8; 4096];
2284 let mut reply_len: u32 = 0;
2285 unsafe { f(*ud, srv, &ev, buf.as_mut_ptr(), buf.len() as u32, &mut reply_len) };
2286 String::from_utf8_lossy(&buf[..reply_len as usize]).into_owned()
2287 } else {
2288 String::new()
2289 }
2290 }))
2291 .unwrap_or_else(|_| { yog_logging::error!("a mod panicked handling command `{}`", n); String::new() });
2292
2293 env.new_string(reply).map(|s| s.into_raw()).unwrap_or(std::ptr::null_mut())
2294}
2295
2296#[no_mangle]
2297pub extern "system" fn Java_dev_yog_NativeBridge_nativeItemDefs<'l>(
2298 env: JNIEnv<'l>, _class: JClass<'l>,
2299) -> jstring {
2300 let s = handlers().items.iter().map(|d| {
2301 let mut parts = vec![d.id.clone()];
2302 parts.push(format!("max_stack={}", d.max_stack));
2303 if let Some(n) = &d.name { parts.push(format!("name={n}")); }
2304 if let Some(t) = &d.tooltip { parts.push(format!("tooltip={t}")); }
2305 if d.max_damage > 0 { parts.push(format!("max_damage={}", d.max_damage)); }
2306 if d.fire_resistant { parts.push("fire_resistant=1".into()); }
2307 if d.fuel_ticks > 0 { parts.push(format!("fuel_ticks={}", d.fuel_ticks)); }
2308 if let Some(f) = &d.food {
2309 parts.push(format!("food={}:{}:{}", f.nutrition, f.saturation, if f.can_always_eat { 1 } else { 0 }));
2310 }
2311 parts.join("\t")
2312 }).collect::<Vec<_>>().join("\n");
2313 env.new_string(s).map(|s| s.into_raw()).unwrap_or(std::ptr::null_mut())
2314}
2315
2316#[no_mangle]
2317pub extern "system" fn Java_dev_yog_NativeBridge_nativeBlockDefs<'l>(
2318 env: JNIEnv<'l>, _class: JClass<'l>,
2319) -> jstring {
2320 let s = handlers().blocks.iter().map(|d| {
2321 let mut parts = vec![d.id.clone()];
2322 parts.push(format!("hardness={}", d.hardness));
2323 parts.push(format!("resistance={}", d.resistance));
2324 if let Some(n) = &d.name { parts.push(format!("name={n}")); }
2325 if let Some(sh) = d.shape {
2326 parts.push(format!("shape={}:{}:{}:{}:{}:{}", sh[0], sh[1], sh[2], sh[3], sh[4], sh[5]));
2327 }
2328 if d.light_level > 0 { parts.push(format!("light={}", d.light_level)); }
2329 if let Some(snd) = &d.sound { parts.push(format!("sound={snd}")); }
2330 if d.requires_tool { parts.push("requires_tool=1".into()); }
2331 if d.no_collision { parts.push("no_collision=1".into()); }
2332 if d.slipperiness > 0.0 { parts.push(format!("slipperiness={}", d.slipperiness)); }
2333 parts.join("\t")
2334 }).collect::<Vec<_>>().join("\n");
2335 env.new_string(s).map(|s| s.into_raw()).unwrap_or(std::ptr::null_mut())
2336}
2337
2338#[no_mangle]
2339pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnPacket<'l>(
2340 mut env: JNIEnv<'l>, _class: JClass<'l>,
2341 channel: JString<'l>, player: JString<'l>, payload: JByteArray<'l>,
2342) {
2343 let ch = env.get_string(&channel).map(String::from).unwrap_or_default();
2344 let pl = env.get_string(&player).map(String::from).unwrap_or_default();
2345 let data = env.convert_byte_array(&payload).unwrap_or_default();
2346 let ev = yog_abi::YogPacketEvent {
2347 channel: YogStr::from_str(&ch), player: YogStr::from_str(&pl),
2348 payload: data.as_ptr(), payload_len: data.len() as u32,
2349 };
2350 let h = handlers();
2351 let srv = srv_ptr();
2352 guard("on_packet", || {
2353 if let Some((ud, f)) = h.packets.get(&ch) {
2354 unsafe { f(*ud, srv, &ev) };
2355 }
2356 });
2357}
2358
2359#[no_mangle]
2360pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnClientPacket<'l>(
2361 mut env: JNIEnv<'l>, _class: JClass<'l>,
2362 channel: JString<'l>, payload: JByteArray<'l>,
2363) {
2364 let ch = env.get_string(&channel).map(String::from).unwrap_or_default();
2365 let data = env.convert_byte_array(&payload).unwrap_or_default();
2366 let ev = yog_abi::YogPacketEvent {
2367 channel: YogStr::from_str(&ch), player: YogStr::EMPTY,
2368 payload: data.as_ptr(), payload_len: data.len() as u32,
2369 };
2370 let h = handlers();
2371 let srv = srv_ptr();
2372 guard("on_client_packet", || {
2373 if let Some((ud, f)) = h.client_packets.get(&ch) {
2374 unsafe { f(*ud, srv, &ev) };
2375 }
2376 });
2377}
2378
2379#[no_mangle]
2380pub extern "system" fn Java_dev_yog_NativeBridge_nativePacketChannels<'l>(
2381 env: JNIEnv<'l>, _class: JClass<'l>,
2382) -> jstring {
2383 let s = handlers().packets.keys().cloned().collect::<Vec<_>>().join("\n");
2384 env.new_string(s).map(|s| s.into_raw()).unwrap_or(std::ptr::null_mut())
2385}
2386
2387#[no_mangle]
2388pub extern "system" fn Java_dev_yog_NativeBridge_nativeClientPacketChannels<'l>(
2389 env: JNIEnv<'l>, _class: JClass<'l>,
2390) -> jstring {
2391 let s = handlers().client_packets.keys().cloned().collect::<Vec<_>>().join("\n");
2392 env.new_string(s).map(|s| s.into_raw()).unwrap_or(std::ptr::null_mut())
2393}
2394
2395#[no_mangle]
2396pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnEntitySpawn<'l>(
2397 mut env: JNIEnv<'l>, _class: JClass<'l>,
2398 entity_type: JString<'l>, uuid: JString<'l>, dimension: JString<'l>,
2399) {
2400 let h = handlers();
2401 if h.entity_spawn.is_empty() { return; }
2402 let (et, u, d) = (jstr!(env, entity_type), jstr!(env, uuid), jstr!(env, dimension));
2403 let ev = yog_abi::YogEntitySpawnEvent {
2404 entity_type: YogStr::from_str(&et), uuid: YogStr::from_str(&u),
2405 dimension: YogStr::from_str(&d),
2406 };
2407 let srv = srv_ptr();
2408 guard("on_entity_spawn", || {
2409 for (ud, f) in &h.entity_spawn {
2410 unsafe { f(*ud, srv, &ev, 1) };
2411 }
2412 });
2413}
2414
2415#[no_mangle]
2416pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnEntitySpawnPre<'l>(
2417 mut env: JNIEnv<'l>, _class: JClass<'l>,
2418 entity_type: JString<'l>, uuid: JString<'l>, dimension: JString<'l>,
2419) -> jni::sys::jboolean {
2420 let h = handlers();
2421 if h.entity_spawn.is_empty() { return 1; }
2422 let et = match env.get_string(&entity_type) { Ok(s) => String::from(s), Err(_) => return 1 };
2423 let u = match env.get_string(&uuid) { Ok(s) => String::from(s), Err(_) => return 1 };
2424 let d = match env.get_string(&dimension) { Ok(s) => String::from(s), Err(_) => return 1 };
2425 let ev = yog_abi::YogEntitySpawnEvent {
2426 entity_type: YogStr::from_str(&et), uuid: YogStr::from_str(&u),
2427 dimension: YogStr::from_str(&d),
2428 };
2429 let srv = srv_ptr();
2430 let mut allow = true;
2431 std::panic::catch_unwind(std::panic::AssertUnwindSafe(|| {
2432 for (ud, f) in &h.entity_spawn {
2433 if !unsafe { f(*ud, srv, &ev, 0) } { allow = false; break; }
2434 }
2435 })).ok();
2436 allow as jni::sys::jboolean
2437}
2438
2439#[no_mangle]
2440pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnEntityDamagePre<'l>(
2441 mut env: JNIEnv<'l>, _class: JClass<'l>,
2442 entity_type: JString<'l>, uuid: JString<'l>, amount: jfloat, source: JString<'l>,
2443) -> jni::sys::jboolean {
2444 let h = handlers();
2445 if h.entity_damage.is_empty() { return 1; }
2446 let et = match env.get_string(&entity_type) { Ok(s) => String::from(s), Err(_) => return 1 };
2447 let u = match env.get_string(&uuid) { Ok(s) => String::from(s), Err(_) => return 1 };
2448 let s = match env.get_string(&source) { Ok(s) => String::from(s), Err(_) => return 1 };
2449 let ev = yog_abi::YogEntityDamageEvent {
2450 entity_type: YogStr::from_str(&et), uuid: YogStr::from_str(&u),
2451 amount, source: YogStr::from_str(&s),
2452 };
2453 let srv = srv_ptr();
2454 let mut allow = true;
2455 std::panic::catch_unwind(std::panic::AssertUnwindSafe(|| {
2456 for (ud, f) in &h.entity_damage {
2457 if !unsafe { f(*ud, srv, &ev, 0) } { allow = false; break; }
2458 }
2459 })).ok();
2460 allow as jni::sys::jboolean
2461}
2462
2463#[no_mangle]
2464pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnPlaceBlockPre<'l>(
2465 mut env: JNIEnv<'l>, _class: JClass<'l>,
2466 player: JString<'l>, block: JString<'l>, x: jint, y: jint, z: jint,
2467) -> jni::sys::jboolean {
2468 let h = handlers();
2469 if h.player_place_block.is_empty() { return 1; }
2470 let p = match env.get_string(&player) { Ok(s) => String::from(s), Err(_) => return 1 };
2471 let b = match env.get_string(&block) { Ok(s) => String::from(s), Err(_) => return 1 };
2472 let ev = YogPlaceBlockEvent {
2473 player: YogStr::from_str(&p), block: YogStr::from_str(&b),
2474 pos: YogBlockPos { x, y, z },
2475 };
2476 let srv = srv_ptr();
2477 let mut allow = true;
2478 std::panic::catch_unwind(std::panic::AssertUnwindSafe(|| {
2479 for (ud, f) in &h.player_place_block {
2480 if !unsafe { f(*ud, srv, &ev, 0) } { allow = false; break; }
2481 }
2482 })).ok();
2483 allow as jni::sys::jboolean
2484}
2485
2486#[no_mangle]
2487pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnPlaceBlock<'l>(
2488 mut env: JNIEnv<'l>, _class: JClass<'l>,
2489 player: JString<'l>, block: JString<'l>, x: jint, y: jint, z: jint,
2490) {
2491 let h = handlers();
2492 if h.player_place_block.is_empty() { return; }
2493 let (p, b) = (jstr!(env, player), jstr!(env, block));
2494 let ev = YogPlaceBlockEvent {
2495 player: YogStr::from_str(&p), block: YogStr::from_str(&b),
2496 pos: YogBlockPos { x, y, z },
2497 };
2498 let srv = srv_ptr();
2499 guard("on_player_place_block", || {
2500 for (ud, f) in &h.player_place_block {
2501 unsafe { f(*ud, srv, &ev, 1) };
2502 }
2503 });
2504}
2505
2506#[no_mangle]
2507pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnPlayerDeathPre<'l>(
2508 mut env: JNIEnv<'l>, _class: JClass<'l>,
2509 player: JString<'l>, uuid: JString<'l>, source: JString<'l>,
2510) -> jni::sys::jboolean {
2511 let h = handlers();
2512 if h.player_death.is_empty() { return 1; }
2513 let p = match env.get_string(&player) { Ok(s) => String::from(s), Err(_) => return 1 };
2514 let u = match env.get_string(&uuid) { Ok(s) => String::from(s), Err(_) => return 1 };
2515 let s = match env.get_string(&source) { Ok(s) => String::from(s), Err(_) => return 1 };
2516 let ev = YogPlayerDeathEvent {
2517 player: YogStr::from_str(&p), uuid: YogStr::from_str(&u), source: YogStr::from_str(&s),
2518 };
2519 let srv = srv_ptr();
2520 let mut allow = true;
2521 std::panic::catch_unwind(std::panic::AssertUnwindSafe(|| {
2522 for (ud, f) in &h.player_death {
2523 if !unsafe { f(*ud, srv, &ev, 0) } { allow = false; break; }
2524 }
2525 })).ok();
2526 allow as jni::sys::jboolean
2527}
2528
2529#[no_mangle]
2530pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnPlayerDeath<'l>(
2531 mut env: JNIEnv<'l>, _class: JClass<'l>,
2532 player: JString<'l>, uuid: JString<'l>, source: JString<'l>,
2533) {
2534 let h = handlers();
2535 if h.player_death.is_empty() { return; }
2536 let (p, u, s) = (jstr!(env, player), jstr!(env, uuid), jstr!(env, source));
2537 let ev = YogPlayerDeathEvent {
2538 player: YogStr::from_str(&p), uuid: YogStr::from_str(&u), source: YogStr::from_str(&s),
2539 };
2540 let srv = srv_ptr();
2541 guard("on_player_death", || {
2542 for (ud, f) in &h.player_death {
2543 unsafe { f(*ud, srv, &ev, 1) };
2544 }
2545 });
2546}
2547
2548#[no_mangle]
2549pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnPlayerRespawn<'l>(
2550 mut env: JNIEnv<'l>, _class: JClass<'l>,
2551 player: JString<'l>, uuid: JString<'l>, at_anchor: jni::sys::jboolean,
2552) {
2553 let h = handlers();
2554 if h.player_respawn.is_empty() { return; }
2555 let (p, u) = (jstr!(env, player), jstr!(env, uuid));
2556 let ev = YogPlayerRespawnEvent {
2557 player: YogStr::from_str(&p), uuid: YogStr::from_str(&u), at_anchor: at_anchor != 0,
2558 };
2559 let srv = srv_ptr();
2560 guard("on_player_respawn", || {
2561 for (ud, f) in &h.player_respawn {
2562 unsafe { f(*ud, srv, &ev, 1) };
2563 }
2564 });
2565}
2566
2567#[no_mangle]
2568pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnAdvancement<'l>(
2569 mut env: JNIEnv<'l>, _class: JClass<'l>,
2570 player: JString<'l>, uuid: JString<'l>, advancement: JString<'l>,
2571) {
2572 let h = handlers();
2573 if h.advancement.is_empty() { return; }
2574 let (p, u, a) = (jstr!(env, player), jstr!(env, uuid), jstr!(env, advancement));
2575 let ev = YogAdvancementEvent {
2576 player: YogStr::from_str(&p), uuid: YogStr::from_str(&u), advancement: YogStr::from_str(&a),
2577 };
2578 let srv = srv_ptr();
2579 guard("on_advancement", || {
2580 for (ud, f) in &h.advancement {
2581 unsafe { f(*ud, srv, &ev, 1) };
2582 }
2583 });
2584}
2585
2586#[no_mangle]
2587pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnEntityInteractPre<'l>(
2588 mut env: JNIEnv<'l>, _class: JClass<'l>,
2589 player: JString<'l>, player_uuid: JString<'l>,
2590 entity_type: JString<'l>, entity_uuid: JString<'l>, hand: JString<'l>,
2591) -> jni::sys::jboolean {
2592 let h = handlers();
2593 if h.entity_interact.is_empty() { return 1; }
2594 let p = match env.get_string(&player) { Ok(s) => String::from(s), Err(_) => return 1 };
2595 let pu = match env.get_string(&player_uuid) { Ok(s) => String::from(s), Err(_) => return 1 };
2596 let et = match env.get_string(&entity_type) { Ok(s) => String::from(s), Err(_) => return 1 };
2597 let eu = match env.get_string(&entity_uuid) { Ok(s) => String::from(s), Err(_) => return 1 };
2598 let ha = match env.get_string(&hand) { Ok(s) => String::from(s), Err(_) => return 1 };
2599 let ev = YogEntityInteractEvent {
2600 player: YogStr::from_str(&p), player_uuid: YogStr::from_str(&pu),
2601 entity_type: YogStr::from_str(&et), entity_uuid: YogStr::from_str(&eu),
2602 hand: YogStr::from_str(&ha),
2603 };
2604 let srv = srv_ptr();
2605 let mut allow = true;
2606 std::panic::catch_unwind(std::panic::AssertUnwindSafe(|| {
2607 for (ud, f) in &h.entity_interact {
2608 if !unsafe { f(*ud, srv, &ev, 0) } { allow = false; break; }
2609 }
2610 })).ok();
2611 allow as jni::sys::jboolean
2612}
2613
2614#[no_mangle]
2615pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnEntityInteract<'l>(
2616 mut env: JNIEnv<'l>, _class: JClass<'l>,
2617 player: JString<'l>, player_uuid: JString<'l>,
2618 entity_type: JString<'l>, entity_uuid: JString<'l>, hand: JString<'l>,
2619) {
2620 let h = handlers();
2621 if h.entity_interact.is_empty() { return; }
2622 let (p, pu) = (jstr!(env, player), jstr!(env, player_uuid));
2623 let (et, eu, ha) = (jstr!(env, entity_type), jstr!(env, entity_uuid), jstr!(env, hand));
2624 let ev = YogEntityInteractEvent {
2625 player: YogStr::from_str(&p), player_uuid: YogStr::from_str(&pu),
2626 entity_type: YogStr::from_str(&et), entity_uuid: YogStr::from_str(&eu),
2627 hand: YogStr::from_str(&ha),
2628 };
2629 let srv = srv_ptr();
2630 guard("on_entity_interact", || {
2631 for (ud, f) in &h.entity_interact {
2632 unsafe { f(*ud, srv, &ev, 1) };
2633 }
2634 });
2635}
2636
2637#[no_mangle]
2638pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnItemCraft<'l>(
2639 mut env: JNIEnv<'l>, _class: JClass<'l>,
2640 player: JString<'l>, player_uuid: JString<'l>,
2641 result_item: JString<'l>, result_count: jint,
2642) {
2643 let h = handlers();
2644 if h.item_craft.is_empty() { return; }
2645 let (p, pu, ri) = (jstr!(env, player), jstr!(env, player_uuid), jstr!(env, result_item));
2646 let ev = YogCraftEvent {
2647 player: YogStr::from_str(&p), player_uuid: YogStr::from_str(&pu),
2648 result_item: YogStr::from_str(&ri), result_count: result_count as u32,
2649 };
2650 let srv = srv_ptr();
2651 guard("on_item_craft", || {
2652 for (ud, f) in &h.item_craft {
2653 unsafe { f(*ud, srv, &ev, 1) };
2654 }
2655 });
2656}
2657
2658#[no_mangle]
2659pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnExplosionPre<'l>(
2660 mut env: JNIEnv<'l>, _class: JClass<'l>,
2661 dimension: JString<'l>, x: jdouble, y: jdouble, z: jdouble,
2662 power: jfloat, cause_uuid: JString<'l>,
2663) -> jni::sys::jboolean {
2664 let h = handlers();
2665 if h.explosion.is_empty() { return 1; }
2666 let d = match env.get_string(&dimension) { Ok(s) => String::from(s), Err(_) => return 1 };
2667 let cu = match env.get_string(&cause_uuid) { Ok(s) => String::from(s), Err(_) => return 1 };
2668 let ev = YogExplosionEvent {
2669 dimension: YogStr::from_str(&d), x, y, z, power, cause_uuid: YogStr::from_str(&cu),
2670 };
2671 let srv = srv_ptr();
2672 let mut allow = true;
2673 std::panic::catch_unwind(std::panic::AssertUnwindSafe(|| {
2674 for (ud, f) in &h.explosion {
2675 if !unsafe { f(*ud, srv, &ev, 0) } { allow = false; break; }
2676 }
2677 })).ok();
2678 allow as jni::sys::jboolean
2679}
2680
2681#[no_mangle]
2682pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnExplosion<'l>(
2683 mut env: JNIEnv<'l>, _class: JClass<'l>,
2684 dimension: JString<'l>, x: jdouble, y: jdouble, z: jdouble,
2685 power: jfloat, cause_uuid: JString<'l>,
2686) {
2687 let h = handlers();
2688 if h.explosion.is_empty() { return; }
2689 let (d, cu) = (jstr!(env, dimension), jstr!(env, cause_uuid));
2690 let ev = YogExplosionEvent {
2691 dimension: YogStr::from_str(&d), x, y, z, power, cause_uuid: YogStr::from_str(&cu),
2692 };
2693 let srv = srv_ptr();
2694 guard("on_explosion", || {
2695 for (ud, f) in &h.explosion {
2696 unsafe { f(*ud, srv, &ev, 1) };
2697 }
2698 });
2699}
2700
2701#[no_mangle]
2704pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnItemPickupPre<'l>(
2705 mut env: JNIEnv<'l>, _class: JClass<'l>,
2706 player: JString<'l>, player_uuid: JString<'l>,
2707 item_id: JString<'l>, item_count: jint, entity_uuid: JString<'l>,
2708) -> jni::sys::jboolean {
2709 let h = handlers();
2710 if h.item_pickup.is_empty() { return 1; }
2711 let p = match env.get_string(&player) { Ok(s) => String::from(s), Err(_) => return 1 };
2712 let pu = match env.get_string(&player_uuid) { Ok(s) => String::from(s), Err(_) => return 1 };
2713 let ii = match env.get_string(&item_id) { Ok(s) => String::from(s), Err(_) => return 1 };
2714 let eu = match env.get_string(&entity_uuid) { Ok(s) => String::from(s), Err(_) => return 1 };
2715 let ev = YogItemPickupEvent {
2716 player: YogStr::from_str(&p), player_uuid: YogStr::from_str(&pu),
2717 item_id: YogStr::from_str(&ii), item_count: item_count as u32,
2718 entity_uuid: YogStr::from_str(&eu),
2719 };
2720 let srv = srv_ptr();
2721 let mut allow = true;
2722 std::panic::catch_unwind(std::panic::AssertUnwindSafe(|| {
2723 for (ud, f) in &h.item_pickup {
2724 if !unsafe { f(*ud, srv, &ev, 0) } { allow = false; break; }
2725 }
2726 })).ok();
2727 allow as jni::sys::jboolean
2728}
2729
2730#[no_mangle]
2731pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnItemPickup<'l>(
2732 mut env: JNIEnv<'l>, _class: JClass<'l>,
2733 player: JString<'l>, player_uuid: JString<'l>,
2734 item_id: JString<'l>, item_count: jint, entity_uuid: JString<'l>,
2735) {
2736 let h = handlers();
2737 if h.item_pickup.is_empty() { return; }
2738 let (p, pu) = (jstr!(env, player), jstr!(env, player_uuid));
2739 let (ii, eu) = (jstr!(env, item_id), jstr!(env, entity_uuid));
2740 let ev = YogItemPickupEvent {
2741 player: YogStr::from_str(&p), player_uuid: YogStr::from_str(&pu),
2742 item_id: YogStr::from_str(&ii), item_count: item_count as u32,
2743 entity_uuid: YogStr::from_str(&eu),
2744 };
2745 let srv = srv_ptr();
2746 guard("on_item_pickup", || {
2747 for (ud, f) in &h.item_pickup {
2748 unsafe { f(*ud, srv, &ev, 1) };
2749 }
2750 });
2751}
2752
2753#[no_mangle]
2754pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnPlayerMove<'l>(
2755 mut env: JNIEnv<'l>, _class: JClass<'l>,
2756 player: JString<'l>, player_uuid: JString<'l>,
2757 x: jdouble, y: jdouble, z: jdouble, yaw: jfloat, pitch: jfloat,
2758) {
2759 let h = handlers();
2760 if h.player_move.is_empty() { return; }
2761 let (p, pu) = (jstr!(env, player), jstr!(env, player_uuid));
2762 let ev = YogPlayerMoveEvent {
2763 player: YogStr::from_str(&p), player_uuid: YogStr::from_str(&pu),
2764 x, y, z, yaw, pitch,
2765 };
2766 let srv = srv_ptr();
2767 guard("on_player_move", || {
2768 for (ud, f) in &h.player_move {
2769 unsafe { f(*ud, srv, &ev, 1) };
2770 }
2771 });
2772}
2773
2774#[no_mangle]
2775pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnContainerOpenPre<'l>(
2776 mut env: JNIEnv<'l>, _class: JClass<'l>,
2777 player: JString<'l>, player_uuid: JString<'l>,
2778) -> jni::sys::jboolean {
2779 let h = handlers();
2780 if h.container_open.is_empty() { return 1; }
2781 let p = match env.get_string(&player) { Ok(s) => String::from(s), Err(_) => return 1 };
2782 let pu = match env.get_string(&player_uuid) { Ok(s) => String::from(s), Err(_) => return 1 };
2783 let ev = YogContainerOpenEvent {
2784 player: YogStr::from_str(&p), player_uuid: YogStr::from_str(&pu),
2785 container_type: YogStr::EMPTY,
2786 };
2787 let srv = srv_ptr();
2788 let mut allow = true;
2789 std::panic::catch_unwind(std::panic::AssertUnwindSafe(|| {
2790 for (ud, f) in &h.container_open {
2791 if !unsafe { f(*ud, srv, &ev, 0) } { allow = false; break; }
2792 }
2793 })).ok();
2794 allow as jni::sys::jboolean
2795}
2796
2797#[no_mangle]
2798pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnContainerOpen<'l>(
2799 mut env: JNIEnv<'l>, _class: JClass<'l>,
2800 player: JString<'l>, player_uuid: JString<'l>, container_type: JString<'l>,
2801) {
2802 let h = handlers();
2803 if h.container_open.is_empty() { return; }
2804 let (p, pu, ct) = (jstr!(env, player), jstr!(env, player_uuid), jstr!(env, container_type));
2805 let ev = YogContainerOpenEvent {
2806 player: YogStr::from_str(&p), player_uuid: YogStr::from_str(&pu),
2807 container_type: YogStr::from_str(&ct),
2808 };
2809 let srv = srv_ptr();
2810 guard("on_container_open", || {
2811 for (ud, f) in &h.container_open {
2812 unsafe { f(*ud, srv, &ev, 1) };
2813 }
2814 });
2815}
2816
2817#[no_mangle]
2818pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnContainerClose<'l>(
2819 mut env: JNIEnv<'l>, _class: JClass<'l>,
2820 player: JString<'l>, player_uuid: JString<'l>,
2821) {
2822 let h = handlers();
2823 if h.container_close.is_empty() { return; }
2824 let (p, pu) = (jstr!(env, player), jstr!(env, player_uuid));
2825 let ev = YogContainerCloseEvent {
2826 player: YogStr::from_str(&p), player_uuid: YogStr::from_str(&pu),
2827 };
2828 let srv = srv_ptr();
2829 guard("on_container_close", || {
2830 for (ud, f) in &h.container_close {
2831 unsafe { f(*ud, srv, &ev, 1) };
2832 }
2833 });
2834}
2835
2836#[no_mangle]
2837pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnProjectileHitPre<'l>(
2838 mut env: JNIEnv<'l>, _class: JClass<'l>,
2839 projectile_type: JString<'l>, projectile_uuid: JString<'l>, shooter_uuid: JString<'l>,
2840 hit_type: JString<'l>, hit_entity_uuid: JString<'l>,
2841 x: jdouble, y: jdouble, z: jdouble, dimension: JString<'l>,
2842) -> jni::sys::jboolean {
2843 let h = handlers();
2844 if h.projectile_hit.is_empty() { return 1; }
2845 let pt = match env.get_string(&projectile_type) { Ok(s) => String::from(s), Err(_) => return 1 };
2846 let pu = match env.get_string(&projectile_uuid) { Ok(s) => String::from(s), Err(_) => return 1 };
2847 let su = match env.get_string(&shooter_uuid) { Ok(s) => String::from(s), Err(_) => return 1 };
2848 let ht = match env.get_string(&hit_type) { Ok(s) => String::from(s), Err(_) => return 1 };
2849 let heu = match env.get_string(&hit_entity_uuid) { Ok(s) => String::from(s), Err(_) => return 1 };
2850 let dim = match env.get_string(&dimension) { Ok(s) => String::from(s), Err(_) => return 1 };
2851 let ev = YogProjectileHitEvent {
2852 projectile_type: YogStr::from_str(&pt), projectile_uuid: YogStr::from_str(&pu),
2853 shooter_uuid: YogStr::from_str(&su), hit_type: YogStr::from_str(&ht),
2854 hit_entity_uuid: YogStr::from_str(&heu), x, y, z, dimension: YogStr::from_str(&dim),
2855 };
2856 let srv = srv_ptr();
2857 let mut allow = true;
2858 std::panic::catch_unwind(std::panic::AssertUnwindSafe(|| {
2859 for (ud, f) in &h.projectile_hit {
2860 if !unsafe { f(*ud, srv, &ev, 0) } { allow = false; break; }
2861 }
2862 })).ok();
2863 allow as jni::sys::jboolean
2864}
2865
2866#[no_mangle]
2867pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnProjectileHit<'l>(
2868 mut env: JNIEnv<'l>, _class: JClass<'l>,
2869 projectile_type: JString<'l>, projectile_uuid: JString<'l>, shooter_uuid: JString<'l>,
2870 hit_type: JString<'l>, hit_entity_uuid: JString<'l>,
2871 x: jdouble, y: jdouble, z: jdouble, dimension: JString<'l>,
2872) {
2873 let h = handlers();
2874 if h.projectile_hit.is_empty() { return; }
2875 let (pt, pu) = (jstr!(env, projectile_type), jstr!(env, projectile_uuid));
2876 let (su, ht) = (jstr!(env, shooter_uuid), jstr!(env, hit_type));
2877 let (heu, dim) = (jstr!(env, hit_entity_uuid), jstr!(env, dimension));
2878 let ev = YogProjectileHitEvent {
2879 projectile_type: YogStr::from_str(&pt), projectile_uuid: YogStr::from_str(&pu),
2880 shooter_uuid: YogStr::from_str(&su), hit_type: YogStr::from_str(&ht),
2881 hit_entity_uuid: YogStr::from_str(&heu), x, y, z, dimension: YogStr::from_str(&dim),
2882 };
2883 let srv = srv_ptr();
2884 guard("on_projectile_hit", || {
2885 for (ud, f) in &h.projectile_hit {
2886 unsafe { f(*ud, srv, &ev, 1) };
2887 }
2888 });
2889}
2890
2891#[no_mangle]
2894pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnClientTick<'l>(
2895 _env: JNIEnv<'l>, _class: JClass<'l>,
2896) {
2897 let h = handlers();
2898 if h.client_tick.is_empty() { return; }
2899 guard("on_client_tick", || {
2900 for (ud, f) in &h.client_tick {
2901 unsafe { f(*ud) };
2902 }
2903 });
2904}
2905
2906#[no_mangle]
2907pub extern "system" fn Java_dev_yog_NativeBridge_nativeGlInit<'l>(
2908 _env: JNIEnv<'l>, _class: JClass<'l>,
2909) {
2910 if GL.get().is_some() { return; }
2911 let mut raw_get_binary: usize = 0;
2912 let mut raw_prog_binary: usize = 0;
2913 let gl = unsafe {
2914 glow::Context::from_loader_function(|sym| {
2915 let Some(mut env) = get_env() else { return std::ptr::null() };
2916 let jsym = match env.new_string(sym) {
2917 Ok(s) => s,
2918 Err(_) => return std::ptr::null(),
2919 };
2920 let jsym_obj: JObject = jsym.into();
2921 let val = env.call_static_method(
2922 "dev/yog/NativeBridge",
2923 "glProcAddress",
2924 "(Ljava/lang/String;)J",
2925 &[JValue::Object(&jsym_obj)],
2926 );
2927 let ptr = match val.and_then(|v| v.j()) {
2928 Ok(p) if p != 0 => p as usize as *const _,
2929 _ => std::ptr::null(),
2930 };
2931 match sym {
2933 "glGetProgramBinary" => raw_get_binary = ptr as usize,
2934 "glProgramBinary" => raw_prog_binary = ptr as usize,
2935 _ => {}
2936 }
2937 ptr
2938 })
2939 };
2940 let _ = GL.set(GlCtx(gl));
2941 let _ = GL_GET_PROGRAM_BINARY.set(if raw_get_binary != 0 { Some(raw_get_binary) } else { None });
2942 let _ = GL_PROGRAM_BINARY.set(if raw_prog_binary != 0 { Some(raw_prog_binary) } else { None });
2943 if let Some(mut env) = get_env() {
2946 if let Ok(jsym) = env.new_string("glGetProgramiv") {
2947 let jsym_obj: JObject = jsym.into();
2948 if let Ok(jv) = env.call_static_method(
2949 "dev/yog/NativeBridge", "glProcAddress", "(Ljava/lang/String;)J",
2950 &[JValue::Object(&jsym_obj)],
2951 ) {
2952 if let Ok(ptr) = jv.j() {
2953 let _ = GL_GET_PROGRAM_IV.set(if ptr != 0 { Some(ptr as usize) } else { None });
2954 }
2955 }
2956 }
2957 }
2958}
2959
2960#[no_mangle]
2961pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnHudRender<'l>(
2962 _env: JNIEnv<'l>, _class: JClass<'l>,
2963 delta_tick: jfloat,
2964 screen_w: jint,
2965 screen_h: jint,
2966 scale_factor: jfloat,
2967 player_x: jfloat, player_y: jfloat, player_z: jfloat,
2968) {
2969 let h = handlers();
2970 let mut gfx = GFX_FN_TABLE;
2971 gfx.screen_w = screen_w;
2972 gfx.screen_h = screen_h;
2973 gfx.delta_tick = delta_tick;
2974 gfx.scale_factor = scale_factor;
2975 gfx.player_pos = [player_x, player_y, player_z];
2976
2977 if !h.hud_render.is_empty() {
2979 guard("on_hud_render", || {
2980 for (ud, f) in &h.hud_render {
2981 unsafe { f(*ud, &gfx) };
2982 }
2983 });
2984 }
2985
2986 let active_layers: Vec<UiLayer> = h.active_uis.lock().unwrap().clone();
2988 let sw = screen_w as f32;
2989 let sh = screen_h as f32;
2990 let ctx = unsafe { yog_gfx::GfxContext::from_raw(&gfx as *const _) };
2991 let mut renderers = h.book_renderers.lock().unwrap();
2992 for layer in &active_layers {
2993 if !layer.visible { continue; }
2994 if let Some(renderer) = renderers.get_mut(&layer.id) {
2995 renderer.render(&ctx, sw, sh);
2996 }
2997 }
2998}
2999
3000#[no_mangle]
3001pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnWorldRender<'l>(
3002 env: JNIEnv<'l>, _class: JClass<'l>,
3003 delta_tick: jfloat,
3004 screen_w: jint,
3005 screen_h: jint,
3006 scale_factor: jfloat,
3007 view_proj_arr: JFloatArray<'l>,
3008 cam_x: jfloat, cam_y: jfloat, cam_z: jfloat,
3009 player_x: jfloat, player_y: jfloat, player_z: jfloat,
3010) {
3011 let h = handlers();
3012 if h.world_render.is_empty() { return; }
3013 let mut view_proj = [0f32; 16];
3014 if env.get_float_array_region(&view_proj_arr, 0, &mut view_proj).is_err() { return; }
3015 let mut gfx = GFX_FN_TABLE;
3016 gfx.screen_w = screen_w;
3017 gfx.screen_h = screen_h;
3018 gfx.delta_tick = delta_tick;
3019 gfx.scale_factor = scale_factor;
3020 gfx.view_proj = view_proj;
3021 gfx.camera_pos = [cam_x, cam_y, cam_z];
3022 gfx.player_pos = [player_x, player_y, player_z];
3023 guard("on_world_render", || {
3024 for (ud, f) in &h.world_render {
3025 unsafe { f(*ud, &gfx) };
3026 }
3027 });
3028}
3029
3030#[no_mangle]
3031pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnKeyPress<'l>(
3032 _env: JNIEnv<'l>, _class: JClass<'l>,
3033 key_code: jint, scan_code: jint, action: jint, modifiers: jint,
3034) -> jni::sys::jboolean {
3035 let h = handlers();
3036 if h.key_press.is_empty() { return 1; }
3037 let ev = YogKeyPressEvent { key_code, scan_code, action, modifiers };
3038 let mut allow = true;
3039 std::panic::catch_unwind(std::panic::AssertUnwindSafe(|| {
3040 for (ud, f) in &h.key_press {
3041 if !unsafe { f(*ud, &ev) } { allow = false; break; }
3042 }
3043 })).ok();
3044 allow as jni::sys::jboolean
3045}
3046
3047#[no_mangle]
3048pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnScreenOpen<'l>(
3049 mut env: JNIEnv<'l>, _class: JClass<'l>,
3050 screen_class: JString<'l>,
3051) {
3052 let h = handlers();
3053 if h.screen_open.is_empty() { return; }
3054 let sc = match env.get_string(&screen_class) { Ok(s) => String::from(s), Err(_) => return };
3055 guard("on_screen_open", || {
3056 for (ud, f) in &h.screen_open {
3057 unsafe { f(*ud, YogStr::from_str(&sc)) };
3058 }
3059 });
3060}
3061
3062#[no_mangle]
3063pub extern "system" fn Java_dev_yog_NativeBridge_nativeOnScreenClose<'l>(
3064 mut env: JNIEnv<'l>, _class: JClass<'l>,
3065 screen_class: JString<'l>,
3066) {
3067 let h = handlers();
3068 if h.screen_close.is_empty() { return; }
3069 let sc = match env.get_string(&screen_class) { Ok(s) => String::from(s), Err(_) => return };
3070 guard("on_screen_close", || {
3071 for (ud, f) in &h.screen_close {
3072 unsafe { f(*ud, YogStr::from_str(&sc)) };
3073 }
3074 });
3075}
3076
3077
3078mod ui_jni;