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