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