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