fire and forget presence

Author: petethepossum

proxy.api/src/main/java/net/swofty/proxyapi/redis/ServerOutboundMessage.java

@@ -90,6 +90,42 @@ public static void sendMessageToService(ServiceType service,
                         specification.channel(), message).toJSON().toString());
     }
 
+    /**
+     * Fire-and-forget: send to a service and do not wait for or register a response.
+     */
+    public static void sendMessageToServiceFireAndForget(ServiceType service,
+                                                         ProtocolObject specification,
+                                                         Object rawMessage) {
+        UUID requestId = UUID.randomUUID();
+        String callback = null;
+        try {
+            callback = RedisAPI.getInstance().getFilterId();
+        } catch (Exception ignored) {
+        }
+
+        String message = specification.translateToString(rawMessage);
+        RedisAPI.getInstance().publishMessage(
+                service.name(),
+                ChannelRegistry.getFromName(specification.channel()),
+                new ServiceProxyRequest(
+                        requestId,
+                        callback != null ? callback : "proxy",
+                        specification.channel(),
+                        message
+                ).toJSON().toString()
+        );
+    }
+
+    /**
+     * Fire-and-forget broadcast to all service types.
+     */
+    public static void sendMessageToAllServicesFireAndForget(ProtocolObject specification,
+                                                             Object rawMessage) {
+        for (ServiceType serviceType : ServiceType.values()) {
+            sendMessageToServiceFireAndForget(serviceType, specification, rawMessage);
+        }
+    }
+
     private static String getRequestTypeName(ProtocolObject<?, ?> protocolObject) {
         Class<?> clazz = protocolObject.getClass();
         Type genericSuperclass = clazz.getGenericSuperclass();

velocity.extension/src/main/java/net/swofty/velocity/presence/PresencePublisher.java

@@ -22,11 +22,9 @@ public static void publish(Player player, boolean online, String serverType, UUI
                 System.currentTimeMillis()
         );
 
-        ServerOutboundMessage.sendMessageToService(
-                ServiceType.FRIEND,
+        ServerOutboundMessage.sendMessageToAllServicesFireAndForget(
                 new UpdatePresenceProtocolObject(),
-                new UpdatePresenceProtocolObject.UpdatePresenceMessage(info),
-                (ignored) -> {}
+                new UpdatePresenceProtocolObject.UpdatePresenceMessage(info)
         );
     }