2A - First non-beta release

read changelog.md for actual changes

Author: Omena0

changelog.md

@@ -11,21 +11,23 @@ Feature update
 
 - Optimized for single request latency
 - Use batching to speed up multiple requests
+- Now uses orjson for faster parsing
+- Automatic handle management
 
 #### New APIs
 
 - Tab list API on Player
-- Region utils on World
+- Region utils on World: .set_block, .fill, .replace, .fill_sphere, .fill_cylinder, .fill_line
 - Particle shapes on World
-- Entity spawn helpers on World
+- Entity spawn helpers on World: spawn_at_player, spawn_projectile, spawn_with_nbt.
 - Support for command execution on Server
 - world.entities property
 - RaycastResult.distance and .hit_face
 
 #### New helpers
 
 - Sidebar: Scoreboard helper
-- Config: YAML config helper
+- Config: TOML config helper
 - Cooldown: Automatically manage cooldowns
 - Hologram: Show floating text
 - Menu / MenuItem: Create easy chest GUIs
@@ -35,6 +37,7 @@ Feature update
 - ItemDisplay: Show floating items
 - ImageDisplay: Show images in the world
 - ItemBuilder: Easily create items
+- Shutdown event
 
 #### API improvements
 
@@ -45,11 +48,14 @@ Feature update
 - Added command description parameter
 - Location: .add, .clone, .distance, .distance_squared are now sync
 - Scoreboard, Team, Objective, and BossBar creation methods are now sync
+- Config: Added support for multiple formats, toml (default), json, and properties.
+- Commands can be now executes as console
 
 #### Cleanup
 
 - Entity class moved before Player
 - Moved most of the code from a single file to multiple
+- Improved typing across python bridge
 
 #### Misc
 

docs/site/exceptions.html

@@ -168,7 +168,7 @@ <h2 id="entitygoneexception">EntityGoneException</h2>
 
 <span class="dc">@event</span>
 <span class="kw">async</span> <span class="kw">def</span> entity_damage(e):
-    <span class="kw">await</span> server.wait(<span class="nb">20</span>)  <span class="cm"># Wait 1 second</span>
+    <span class="kw">await</span> server.after(<span class="nb">20</span>)  <span class="cm"># Wait 1 second</span>
     <span class="kw">try</span>:
         <span class="kw">await</span> e.entity.set_fire_ticks(<span class="nb">100</span>)
     <span class="kw">except</span> EntityGoneException:
@@ -179,7 +179,7 @@ <h3 id="when-to-expect-it">When to expect it</h3>
 <p>Any awaitable method on <code>Entity</code> or <code>Player</code> can raise <code>EntityGoneException</code> if the underlying Java entity has been garbage collected. This is especially common when:</p>
 <ul>
 <li>You store entity references across ticks</li>
-<li>You use <code>server.wait()</code> between getting a reference and using it</li>
+<li>You use <code>server.after()</code> between getting a reference and using it</li>
 <li>You handle events where the entity might die (e.g. <code>entity_damage</code>)</li>
 </ul>
 <h3 id="best-practice">Best practice</h3>

docs/site/server.html

@@ -65,7 +65,7 @@
     <li><a href="#world" style="padding-left:40px;font-size:.8rem">world</a></li>
     <li><a href="#create_boss_bar" style="padding-left:40px;font-size:.8rem">create_boss_bar</a></li>
     <li><a href="#get_advancement" style="padding-left:40px;font-size:.8rem">get_advancement</a></li>
-    <li><a href="#wait" style="padding-left:40px;font-size:.8rem">wait</a></li>
+    <li><a href="#after" style="padding-left:40px;font-size:.8rem">after</a></li>
     <li><a href="#frame" style="padding-left:40px;font-size:.8rem">frame</a></li>
     <li><a href="#atomic" style="padding-left:40px;font-size:.8rem">atomic</a></li>
     <li><a href="#flush" style="padding-left:40px;font-size:.8rem">flush</a></li>
@@ -238,7 +238,7 @@ <h3 id="scheduler">scheduler</h3>
 <ul>
 <li><strong>Type:</strong> <code>any</code></li>
 </ul>
-<p>The Bukkit scheduler. Rarely needed — use <code>server.wait()</code> and <code>@task</code> instead.</p>
+<p>The Bukkit scheduler. Rarely needed — use <code>server.after()</code> and <code>@task</code> instead.</p>
 <h3 id="scoreboard_manager">scoreboard_manager</h3>
 <ul>
 <li><strong>Type:</strong> <code>any</code></li>
@@ -302,8 +302,8 @@ <h3 id="get_advancement">get_advancement</h3>
 <li><code>key</code> (<code>str</code>) — The advancement key (e.g. <code>"minecraft:story/mine_diamond"</code>).</li>
 <li><strong>Returns:</strong> <code>Awaitable[</code><a href="advancement.html"><code>Advancement</code></a><code>]</code></li>
 </ul>
-<h3 id="wait">wait</h3>
-<pre><code class="language-python"><span class="kw">await</span> server.wait(ticks: int = <span class="nb">1</span>, after: callable | <span class="kw">None</span> = <span class="kw">None</span>)
+<h3 id="after">after</h3>
+<pre><code class="language-python"><span class="kw">await</span> server.after(ticks: int = <span class="nb">1</span>, after: callable | <span class="kw">None</span> = <span class="kw">None</span>)
 </code></pre>
 <p>Pause execution for a number of ticks. Optionally run a callback after the wait.</p>
 <ul>
@@ -312,11 +312,11 @@ <h3 id="wait">wait</h3>
 <li><code>after</code> (<code>callable | None</code>) — Optional callback to run after the wait completes.</li>
 <li><strong>Returns:</strong> <code>Awaitable[None]</code></li>
 </ul>
-<pre><code class="language-python"><span class="kw">await</span> server.wait(<span class="nb">20</span>)  <span class="cm"># Wait 1 second</span>
-<span class="kw">await</span> server.wait(<span class="nb">60</span>)  <span class="cm"># Wait 3 seconds</span>
+<pre><code class="language-python"><span class="kw">await</span> server.after(<span class="nb">20</span>)  <span class="cm"># Wait 1 second</span>
+<span class="kw">await</span> server.after(<span class="nb">60</span>)  <span class="cm"># Wait 3 seconds</span>
 
 <span class="cm"># With callback</span>
-<span class="kw">await</span> server.wait(<span class="nb">20</span>, after=<span class="kw">lambda</span>: print(<span class="st">&quot;Done waiting!&quot;</span>))
+<span class="kw">await</span> server.after(<span class="nb">20</span>, after=<span class="kw">lambda</span>: print(<span class="st">&quot;Done waiting!&quot;</span>))
 </code></pre>
 <h3 id="frame">frame</h3>
 <pre><code class="language-python"><span class="kw">async</span> <span class="kw">with</span> server.frame():

docs/src/exceptions.md

@@ -43,7 +43,7 @@ from bridge import *
 
 @event
 async def entity_damage(e):
-    await server.wait(20)  # Wait 1 second
+    await server.after(20)  # Wait 1 second
     try:
         await e.entity.set_fire_ticks(100)
     except EntityGoneException:
@@ -56,7 +56,7 @@ async def entity_damage(e):
 Any awaitable method on `Entity` or `Player` can raise `EntityGoneException` if the underlying Java entity has been garbage collected. This is especially common when:
 
 - You store entity references across ticks
-- You use `server.wait()` between getting a reference and using it
+- You use `server.after()` between getting a reference and using it
 - You handle events where the entity might die (e.g. `entity_damage`)
 
 ### Best practice

docs/src/server.md

@@ -98,7 +98,7 @@ The Bukkit plugin manager. Primarily useful for advanced reflection use cases.
 
 - **Type:** `any`
 
-The Bukkit scheduler. Rarely needed — use `server.wait()` and `@task` instead.
+The Bukkit scheduler. Rarely needed — use `server.after()` and `@task` instead.
 
 ### scoreboard_manager
 
@@ -189,10 +189,10 @@ Get an advancement by its namespaced key.
   - `key` (`str`) — The advancement key (e.g. `"minecraft:story/mine_diamond"`).
 - **Returns:** `Awaitable[`[`Advancement`](advancement.md)`]`
 
-### wait
+### after
 
 ```python
-await server.wait(ticks: int = 1, after: callable | None = None)
+await server.after(ticks: int = 1, after: callable | None = None)
 ```
 
 Pause execution for a number of ticks. Optionally run a callback after the wait.
@@ -203,11 +203,11 @@ Pause execution for a number of ticks. Optionally run a callback after the wait.
 - **Returns:** `Awaitable[None]`
 
 ```python
-await server.wait(20)  # Wait 1 second
-await server.wait(60)  # Wait 3 seconds
+await server.after(20)  # Wait 1 second
+await server.after(60)  # Wait 3 seconds
 
 # With callback
-await server.wait(20, after=lambda: print("Done waiting!"))
+await server.after(20, after=lambda: print("Done waiting!"))
 ```
 
 ### frame

releases/pyjavabridge-1C.jar

@@ -62,7 +62,9 @@
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicInteger;
+import org.bukkit.event.Listener;
+import org.bukkit.event.EventHandler;
+import org.bukkit.event.player.PlayerQuitEvent;
 
 public class BridgeInstance {
     private final PyJavaBridgePlugin plugin;
@@ -89,10 +91,10 @@ public class BridgeInstance {
     private final ReflectFacade reflectFacade = new ReflectFacade();
     private final RegionFacade regionFacade = new RegionFacade();
     private final ParticleFacade particleFacade = new ParticleFacade();
-    private PermissionsFacade permissionsFacade;
-    private MetricsFacade metricsFacade;
-    private RefFacade refFacade;
-    private CommandsFacade commandsFacade;
+    private final PermissionsFacade permissionsFacade;
+    private final MetricsFacade metricsFacade;
+    private final RefFacade refFacade;
+    private final CommandsFacade commandsFacade;
 
     private ServerSocket serverSocket;
     private Socket socket;
@@ -117,6 +119,19 @@ public class BridgeInstance {
         this.metricsFacade = new MetricsFacade(plugin);
         this.refFacade = new RefFacade(this);
         this.commandsFacade = new CommandsFacade(plugin, this);
+
+        Bukkit.getPluginManager().registerEvents(new Listener() {
+            @EventHandler
+            public void onPlayerQuit(PlayerQuitEvent event) {
+                PermissionAttachment attachment = permissionAttachments.remove(event.getPlayer().getUniqueId());
+                if (attachment != null) {
+                    try {
+                        event.getPlayer().removeAttachment(attachment);
+                    } catch (Exception ignored) {
+                    }
+                }
+            }
+        }, plugin);
     }
 
     public boolean isRunning() {
@@ -203,6 +218,8 @@ private void bridgeLoop() {
         try {
             serverSocket.setSoTimeout(30_000);
             socket = serverSocket.accept();
+            closeQuietly(serverSocket);
+            serverSocket = null;
             plugin.getLogger().info("[" + name + "] Python connected");
 
             reader = new DataInputStream(socket.getInputStream());
@@ -239,8 +256,14 @@ private void bridgeLoop() {
                 }
                 byte[] payload = new byte[length];
                 reader.readFully(payload);
-                JsonObject message = JsonParser.parseString(new String(payload, StandardCharsets.UTF_8))
-                        .getAsJsonObject();
+                JsonObject message;
+                try {
+                    message = JsonParser.parseString(new String(payload, StandardCharsets.UTF_8))
+                            .getAsJsonObject();
+                } catch (Exception e) {
+                    plugin.getLogger().severe("[" + name + "] Failed to parse message: " + e.getMessage());
+                    continue;
+                }
                 handleMessage(message);
             }
 

releases/pyjavabridge-dev.jar

@@ -122,32 +122,35 @@ private boolean dispatchCancellableEvent(Event event, String eventName, JsonObje
         }
         PendingEvent pending = pendingEvents.get(eventId);
         if (pending != null) {
-            long deadline = System.currentTimeMillis() + timeoutMs;
             try {
-                while (System.currentTimeMillis() < deadline && pending.latch.getCount() > 0) {
-                    plugin.drainMainThreadQueue();
-                    pending.latch.await(5, java.util.concurrent.TimeUnit.MILLISECONDS);
+                long deadline = System.currentTimeMillis() + timeoutMs;
+                try {
+                    while (System.currentTimeMillis() < deadline && pending.latch.getCount() > 0) {
+                        plugin.drainMainThreadQueue();
+                        pending.latch.await(5, java.util.concurrent.TimeUnit.MILLISECONDS);
+                    }
+                } catch (InterruptedException ignored) {
+                    Thread.currentThread().interrupt();
                 }
-            } catch (InterruptedException ignored) {
-                Thread.currentThread().interrupt();
-            }
-            boolean cancelRequested = pending.cancelRequested.get();
-            if (pending.chatOverride != null && isChatEvent(pending.event)) {
-                pending.cancellable.setCancelled(true);
-                String message = pending.chatOverride;
-                Bukkit.getScheduler().runTask(plugin,
-                        () -> Bukkit.getServer().broadcast(net.kyori.adventure.text.Component.text(message)));
-            }
-            if (pending.damageOverride != null && pending.event instanceof EntityDamageEvent damageEvent) {
-                damageEvent.setDamage(pending.damageOverride);
-            }
-            if (cancelRequested && cancelMode == CancelMode.EVENT) {
-                pending.cancellable.setCancelled(true);
-            }
-            if (pending.latch.getCount() > 0 && timeoutMs >= 100) {
-                plugin.getLogger().warning("[" + name + "] Event handler timed out for " + eventName);
+                boolean cancelRequested = pending.cancelRequested.get();
+                if (pending.chatOverride != null && isChatEvent(pending.event)) {
+                    pending.cancellable.setCancelled(true);
+                    String message = pending.chatOverride;
+                    Bukkit.getScheduler().runTask(plugin,
+                            () -> Bukkit.getServer().broadcast(net.kyori.adventure.text.Component.text(message)));
+                }
+                if (pending.damageOverride != null && pending.event instanceof EntityDamageEvent damageEvent) {
+                    damageEvent.setDamage(pending.damageOverride);
+                }
+                if (cancelRequested && cancelMode == CancelMode.EVENT) {
+                    pending.cancellable.setCancelled(true);
+                }
+                if (pending.latch.getCount() > 0 && timeoutMs >= 100) {
+                    plugin.getLogger().warning("[" + name + "] Event handler timed out for " + eventName);
+                }
+            } finally {
+                pendingEvents.remove(eventId);
             }
-            pendingEvents.remove(eventId);
         }
         return cancellable && ((org.bukkit.event.Cancellable) event).isCancelled();
     }

src/main/java/com/pyjavabridge/BridgeInstance.java

@@ -234,8 +234,9 @@ private void startFileWatcher(Path scriptsDir) {
         }
         watchEnabled = true;
         fileWatcherThread = new Thread(() -> {
+            java.nio.file.WatchService watcher = null;
             try {
-                java.nio.file.WatchService watcher = java.nio.file.FileSystems.getDefault().newWatchService();
+                watcher = java.nio.file.FileSystems.getDefault().newWatchService();
                 scriptsDir.register(watcher,
                         java.nio.file.StandardWatchEventKinds.ENTRY_MODIFY,
                         java.nio.file.StandardWatchEventKinds.ENTRY_CREATE);
@@ -265,11 +266,17 @@ private void startFileWatcher(Path scriptsDir) {
                         }
                     }
                 }
-                watcher.close();
             } catch (Exception e) {
                 if (watchEnabled) {
                     getLogger().warning("File watcher error: " + e.getMessage());
                 }
+            } finally {
+                if (watcher != null) {
+                    try {
+                        watcher.close();
+                    } catch (Exception ignored) {
+                    }
+                }
             }
         }, "PyJavaBridge-FileWatcher");
         fileWatcherThread.setDaemon(true);