diff --git a/nx01-no2all-react-nostr/src/main/java/love/distributedrebirth/no2all/react/nostr/client/NoStrRtsClient.java b/nx01-no2all-react-nostr/src/main/java/love/distributedrebirth/no2all/react/nostr/client/NoStrRtsClient.java index 5c3354c..7d8ee1d 100644 --- a/nx01-no2all-react-nostr/src/main/java/love/distributedrebirth/no2all/react/nostr/client/NoStrRtsClient.java +++ b/nx01-no2all-react-nostr/src/main/java/love/distributedrebirth/no2all/react/nostr/client/NoStrRtsClient.java @@ -14,28 +14,28 @@ import love.distributedrebirth.no2all.nostr.model.message.NoStrMsgToRelayClose; import love.distributedrebirth.no2all.nostr.model.message.NoStrMsgToRelayCount; import love.distributedrebirth.no2all.nostr.model.message.NoStrMsgToRelayEvent; import love.distributedrebirth.no2all.nostr.model.message.NoStrMsgToRelayReq; -import love.distributedrebirth.no2all.react.No2AllReactSlotLoad; -import love.distributedrebirth.no2all.react.No2AllReact; -import love.distributedrebirth.no2all.react.No2AllReactListener; -import love.distributedrebirth.no2all.react.No2AllReactSlot; -import love.distributedrebirth.no2all.react.No2AllReactSlotSignal; -import love.distributedrebirth.no2all.react.No2AllReactTypeScript; import love.distributedrebirth.no2all.react.wire.client.No2AllActClientClose; import love.distributedrebirth.no2all.react.wire.client.No2AllActClientSendMessage; import love.distributedrebirth.no2all.react.wire.client.No2AllArtClient; import love.distributedrebirth.no2all.react.wire.client.No2AllArtClientOnMessage; import love.distributedrebirth.no2all.react.wire.client.No2AllRtsClient; +import love.distributedrebirth.nx01.warp.core.react.WarpReact; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasmaCoil; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasmaPulse; +import love.distributedrebirth.nx01.warp.core.react.WarpReactTypeScript; +import love.distributedrebirth.nx01.warp.core.space.WarpSpaceAntimatterInducer; -public class NoStrRtsClient implements No2AllReactTypeScript { +public class NoStrRtsClient implements WarpReactTypeScript { - public static final No2AllReactSlot API = No2AllReactSlot.ofClass(NoStrRtsClient.class); + public static final WarpReactPlasma API = WarpReactPlasma.ofClass(NoStrRtsClient.class); @Override - public void onEvent(No2AllReactSlotSignal signal) { - No2AllReact react = signal.getReact(); + public void onEvent(WarpReactPlasmaPulse signal) { + WarpReact react = signal.getReact(); react.claim(API); react.registrate(No2AllRtsClient.API, No2AllArtClient.class, artClient -> { - No2AllReactSlot clientSlot = artClient.getData().getSlot(); + WarpReactPlasma clientSlot = artClient.getData().getSlot(); react.claimIn(clientSlot, NoStrMsgToRelayAuth.class); react.claimIn(clientSlot, NoStrMsgToRelayClose.class); react.claimIn(clientSlot, NoStrMsgToRelayCount.class); @@ -63,7 +63,7 @@ public class NoStrRtsClient implements No2AllReactTypeScript { }); } - private No2AllReactListener pipeWriter(No2AllReact react, No2AllReactSlot clientSlot) { + private WarpReactPlasmaCoil pipeWriter(WarpReact react, WarpReactPlasma clientSlot) { return v -> { react.fire(clientSlot, new No2AllActClientSendMessage(v.getData().toBible().toString())); }; diff --git a/nx01-no2all-react-nostr/src/main/java/love/distributedrebirth/no2all/react/nostr/server/NoStrRtsServer.java b/nx01-no2all-react-nostr/src/main/java/love/distributedrebirth/no2all/react/nostr/server/NoStrRtsServer.java index 9a19f50..89d0ab8 100644 --- a/nx01-no2all-react-nostr/src/main/java/love/distributedrebirth/no2all/react/nostr/server/NoStrRtsServer.java +++ b/nx01-no2all-react-nostr/src/main/java/love/distributedrebirth/no2all/react/nostr/server/NoStrRtsServer.java @@ -14,12 +14,6 @@ import love.distributedrebirth.no2all.nostr.model.message.NoStrMsgToRelayClose; import love.distributedrebirth.no2all.nostr.model.message.NoStrMsgToRelayCount; import love.distributedrebirth.no2all.nostr.model.message.NoStrMsgToRelayEvent; import love.distributedrebirth.no2all.nostr.model.message.NoStrMsgToRelayReq; -import love.distributedrebirth.no2all.react.No2AllReactSlotLoad; -import love.distributedrebirth.no2all.react.No2AllReact; -import love.distributedrebirth.no2all.react.No2AllReactListener; -import love.distributedrebirth.no2all.react.No2AllReactSlot; -import love.distributedrebirth.no2all.react.No2AllReactSlotSignal; -import love.distributedrebirth.no2all.react.No2AllReactTypeScript; import love.distributedrebirth.no2all.react.wire.server.No2AllActServerBroadcastMessage; import love.distributedrebirth.no2all.react.wire.server.No2AllActServerSocketClose; import love.distributedrebirth.no2all.react.wire.server.No2AllActServerSocketSendMessage; @@ -27,14 +21,20 @@ import love.distributedrebirth.no2all.react.wire.server.No2AllArtServer; import love.distributedrebirth.no2all.react.wire.server.No2AllArtServerSocket; import love.distributedrebirth.no2all.react.wire.server.No2AllArtServerSocketOnMessage; import love.distributedrebirth.no2all.react.wire.server.No2AllRtsServer; +import love.distributedrebirth.nx01.warp.core.react.WarpReact; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasmaCoil; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasmaPulse; +import love.distributedrebirth.nx01.warp.core.react.WarpReactTypeScript; +import love.distributedrebirth.nx01.warp.core.space.WarpSpaceAntimatterInducer; -public class NoStrRtsServer implements No2AllReactTypeScript { +public class NoStrRtsServer implements WarpReactTypeScript { - public static final No2AllReactSlot API = No2AllReactSlot.ofClass(NoStrRtsServer.class); + public static final WarpReactPlasma API = WarpReactPlasma.ofClass(NoStrRtsServer.class); @Override - public void onEvent(No2AllReactSlotSignal signal) { - No2AllReact react = signal.getReact(); + public void onEvent(WarpReactPlasmaPulse signal) { + WarpReact react = signal.getReact(); react.claim(API); react.requireSlot(API, No2AllRtsServer.API); react.claimIn(API, NoStrMsgToClientNotice.class); @@ -42,10 +42,10 @@ public class NoStrRtsServer implements No2AllReactTypeScript { react.fireForEach(No2AllRtsServer.API, new No2AllActServerBroadcastMessage(v.getData().toBible().toString())); }); react.registrate(No2AllRtsServer.API, No2AllArtServer.class, artServer -> { - No2AllReactSlot serverSlot = artServer.getData().getSlot(); + WarpReactPlasma serverSlot = artServer.getData().getSlot(); react.claimIn(serverSlot, NoStrMsgToClientNotice.class); react.registrate(serverSlot, No2AllArtServerSocket.class, artSocket -> { - No2AllReactSlot socketSlot = artSocket.getData().getSlot(); + WarpReactPlasma socketSlot = artSocket.getData().getSlot(); react.claimIn(socketSlot, NoStrMsgToClientAuth.class); react.claimIn(socketSlot, NoStrMsgToClientCount.class); react.claimIn(socketSlot, NoStrMsgToClientEose.class); @@ -78,7 +78,7 @@ public class NoStrRtsServer implements No2AllReactTypeScript { }); } - private No2AllReactListener pipeWriter(No2AllReact react, No2AllReactSlot clientSlot) { + private WarpReactPlasmaCoil pipeWriter(WarpReact react, WarpReactPlasma clientSlot) { return v -> { react.fire(clientSlot, new No2AllActServerSocketSendMessage(v.getData().toBible().toString())); }; diff --git a/nx01-no2all-react-nostr/src/main/java/love/distributedrebirth/no2all/react/nostr/server/relay/NoStrRtsServerRelay.java b/nx01-no2all-react-nostr/src/main/java/love/distributedrebirth/no2all/react/nostr/server/relay/NoStrRtsServerRelay.java index 772c430..9de7d9f 100644 --- a/nx01-no2all-react-nostr/src/main/java/love/distributedrebirth/no2all/react/nostr/server/relay/NoStrRtsServerRelay.java +++ b/nx01-no2all-react-nostr/src/main/java/love/distributedrebirth/no2all/react/nostr/server/relay/NoStrRtsServerRelay.java @@ -7,31 +7,31 @@ import love.distributedrebirth.no2all.nostr.model.event.NoStrEventSignature; import love.distributedrebirth.no2all.nostr.model.message.NoStrMsgToClientOk; import love.distributedrebirth.no2all.nostr.model.message.NoStrMsgToRelayEvent; import love.distributedrebirth.no2all.nostr.nip.NoStrImplMessageOkReason; -import love.distributedrebirth.no2all.react.No2AllReact; -import love.distributedrebirth.no2all.react.No2AllReactSlot; -import love.distributedrebirth.no2all.react.No2AllReactSlotLoad; -import love.distributedrebirth.no2all.react.No2AllReactSlotSignal; -import love.distributedrebirth.no2all.react.No2AllReactTypeScript; import love.distributedrebirth.no2all.react.nostr.server.NoStrRtsServer; import love.distributedrebirth.no2all.react.wire.server.No2AllArtServer; import love.distributedrebirth.no2all.react.wire.server.No2AllArtServerSocket; import love.distributedrebirth.no2all.react.wire.server.No2AllRtsServer; +import love.distributedrebirth.nx01.warp.core.react.WarpReact; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasmaPulse; +import love.distributedrebirth.nx01.warp.core.react.WarpReactTypeScript; +import love.distributedrebirth.nx01.warp.core.space.WarpSpaceAntimatterInducer; -public class NoStrRtsServerRelay implements No2AllReactTypeScript { +public class NoStrRtsServerRelay implements WarpReactTypeScript { - public static final No2AllReactSlot API = No2AllReactSlot.ofClass(NoStrRtsServerRelay.class); + public static final WarpReactPlasma API = WarpReactPlasma.ofClass(NoStrRtsServerRelay.class); private static final Logger logger = Logger.getLogger(NoStrRtsServerRelay.class.getName()); @Override - public void onEvent(No2AllReactSlotSignal signal) { - No2AllReact react = signal.getReact(); + public void onEvent(WarpReactPlasmaPulse signal) { + WarpReact react = signal.getReact(); react.claim(API); react.claimOut(API, NoStrArtServerRelayStoreEvent.class); react.requireSlot(API, NoStrRtsServer.API); react.registrate(No2AllRtsServer.API, No2AllArtServer.class, artServer -> { - No2AllReactSlot serverSlot = artServer.getData().getSlot(); + WarpReactPlasma serverSlot = artServer.getData().getSlot(); react.registrate(serverSlot, No2AllArtServerSocket.class, artSocket -> { - No2AllReactSlot socketSlot = artSocket.getData().getSlot(); + WarpReactPlasma socketSlot = artSocket.getData().getSlot(); react.registrate(socketSlot, NoStrMsgToRelayEvent.class, v -> { handleRelayEvent(react, v.getData().getEvent(), artSocket.getData().getRemoteAddr(), socketSlot); }); @@ -39,7 +39,7 @@ public class NoStrRtsServerRelay implements No2AllReactTypeScript { }); } - private void handleRelayEvent(No2AllReact react, NoStrEvent event, String remoteAddr, No2AllReactSlot socketSlot) { + private void handleRelayEvent(WarpReact react, NoStrEvent event, String remoteAddr, WarpReactPlasma socketSlot) { boolean eventSaved = false; String eventResponse = ""; NoStrImplMessageOkReason eventReason = NoStrImplMessageOkReason.DEFAULT; diff --git a/nx01-no2all-react-nostr/src/main/java/love/distributedrebirth/no2all/react/nostr/server/relay/NoStrRtsServerRelaySubs.java b/nx01-no2all-react-nostr/src/main/java/love/distributedrebirth/no2all/react/nostr/server/relay/NoStrRtsServerRelaySubs.java index c22a6d8..8fa6ead 100644 --- a/nx01-no2all-react-nostr/src/main/java/love/distributedrebirth/no2all/react/nostr/server/relay/NoStrRtsServerRelaySubs.java +++ b/nx01-no2all-react-nostr/src/main/java/love/distributedrebirth/no2all/react/nostr/server/relay/NoStrRtsServerRelaySubs.java @@ -2,28 +2,28 @@ package love.distributedrebirth.no2all.react.nostr.server.relay; import love.distributedrebirth.no2all.nostr.model.message.NoStrMsgToRelayClose; import love.distributedrebirth.no2all.nostr.model.message.NoStrMsgToRelayReq; -import love.distributedrebirth.no2all.react.No2AllReactSlotLoad; -import love.distributedrebirth.no2all.react.No2AllReact; -import love.distributedrebirth.no2all.react.No2AllReactSlot; -import love.distributedrebirth.no2all.react.No2AllReactSlotSignal; -import love.distributedrebirth.no2all.react.No2AllReactTypeScript; import love.distributedrebirth.no2all.react.wire.server.No2AllArtServer; import love.distributedrebirth.no2all.react.wire.server.No2AllArtServerSocket; import love.distributedrebirth.no2all.react.wire.server.No2AllRtsServer; +import love.distributedrebirth.nx01.warp.core.react.WarpReact; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasmaPulse; +import love.distributedrebirth.nx01.warp.core.react.WarpReactTypeScript; +import love.distributedrebirth.nx01.warp.core.space.WarpSpaceAntimatterInducer; -public class NoStrRtsServerRelaySubs implements No2AllReactTypeScript { +public class NoStrRtsServerRelaySubs implements WarpReactTypeScript { - public static final No2AllReactSlot API = No2AllReactSlot.ofClass(NoStrRtsServerRelaySubs.class); + public static final WarpReactPlasma API = WarpReactPlasma.ofClass(NoStrRtsServerRelaySubs.class); @Override - public void onEvent(No2AllReactSlotSignal signal) { - No2AllReact react = signal.getReact(); + public void onEvent(WarpReactPlasmaPulse signal) { + WarpReact react = signal.getReact(); react.claim(API); react.requireSlot(API, NoStrRtsServerRelay.API); react.registrate(No2AllRtsServer.API, No2AllArtServer.class, v -> { - No2AllReactSlot serverSlot = v.getData().getSlot(); + WarpReactPlasma serverSlot = v.getData().getSlot(); react.registrate(serverSlot, No2AllArtServerSocket.class, x -> { - No2AllReactSlot socketSlot = x.getData().getSlot(); + WarpReactPlasma socketSlot = x.getData().getSlot(); react.registrate(socketSlot, NoStrMsgToRelayReq.class, y -> { String subId = y.getData().getSubscriptionId(); y.getData().getFilters(); diff --git a/nx01-no2all-react-nostr/src/test/java/love/distributedrebirth/no2all/react/nostr/client/NoStrClientTest.java b/nx01-no2all-react-nostr/src/test/java/love/distributedrebirth/no2all/react/nostr/client/NoStrClientTest.java index f200c05..c30fe64 100644 --- a/nx01-no2all-react-nostr/src/test/java/love/distributedrebirth/no2all/react/nostr/client/NoStrClientTest.java +++ b/nx01-no2all-react-nostr/src/test/java/love/distributedrebirth/no2all/react/nostr/client/NoStrClientTest.java @@ -12,9 +12,6 @@ import love.distributedrebirth.no2all.nostr.model.NoStrIdentityPrivateKey; import love.distributedrebirth.no2all.nostr.model.event.NoStrEvent; import love.distributedrebirth.no2all.nostr.model.message.NoStrMsgToRelayEvent; import love.distributedrebirth.no2all.nostr.nip.NoStrImplEventKind; -import love.distributedrebirth.no2all.react.No2AllReactSlot; -import love.distributedrebirth.no2all.react.warp.No2AllReactWarpCore; -import love.distributedrebirth.no2all.react.warp.No2AllRtsWarpSpeedMonitor; import love.distributedrebirth.no2all.react.wire.client.No2AllActClient; import love.distributedrebirth.no2all.react.wire.client.No2AllActClientClose; import love.distributedrebirth.no2all.react.wire.client.No2AllActClientConnect; @@ -26,19 +23,22 @@ import love.distributedrebirth.no2all.react.wire.client.No2AllArtClientOnOpen; import love.distributedrebirth.no2all.react.wire.client.No2AllArtClientOnStart; import love.distributedrebirth.no2all.react.wire.client.No2AllRtsClient; import love.distributedrebirth.no2all.wire.ojw.OjwWireClientEndpoint; +import love.distributedrebirth.nx01.warp.core.WarpCoreReactor; +import love.distributedrebirth.nx01.warp.core.WarpCoreSpeedMonitor; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; public class NoStrClientTest { public static void main(String[] args) throws Exception { ExecutorService executor = Executors.newFixedThreadPool(10); NoStrIdentity nid = new NoStrIdentity(NoStrIdentityPrivateKey.ofRandom()); - No2AllReactWarpCore react = new No2AllReactWarpCore(); - react.load(new No2AllRtsWarpSpeedMonitor()); + WarpCoreReactor react = new WarpCoreReactor(); + react.load(new WarpCoreSpeedMonitor()); react.load(new No2AllRtsClient()); react.load(new NoStrRtsClient()); react.registrate(No2AllRtsClient.API, No2AllArtClient.class, v -> { - No2AllReactSlot clientSlot = v.getData().getSlot(); + WarpReactPlasma clientSlot = v.getData().getSlot(); System.out.println("NoStrClient created: " + clientSlot.getSlotPath()); react.registrate(clientSlot, No2AllArtClientOnError.class, x -> { System.out.println("NoStrClient socket error: " + x.getData().getError().getMessage()); diff --git a/nx01-no2all-react-nostr/src/test/java/love/distributedrebirth/no2all/react/nostr/server/NoStrServerTest.java b/nx01-no2all-react-nostr/src/test/java/love/distributedrebirth/no2all/react/nostr/server/NoStrServerTest.java index 17ff855..328a573 100644 --- a/nx01-no2all-react-nostr/src/test/java/love/distributedrebirth/no2all/react/nostr/server/NoStrServerTest.java +++ b/nx01-no2all-react-nostr/src/test/java/love/distributedrebirth/no2all/react/nostr/server/NoStrServerTest.java @@ -2,11 +2,8 @@ package love.distributedrebirth.no2all.react.nostr.server; import java.net.InetSocketAddress; -import love.distributedrebirth.no2all.react.No2AllReactSlot; import love.distributedrebirth.no2all.react.nostr.server.relay.NoStrRtsServerRelay; import love.distributedrebirth.no2all.react.nostr.server.relay.NoStrRtsServerRelaySubs; -import love.distributedrebirth.no2all.react.warp.No2AllReactWarpCore; -import love.distributedrebirth.no2all.react.warp.No2AllRtsWarpSpeedMonitor; import love.distributedrebirth.no2all.react.wire.server.No2AllActServer; import love.distributedrebirth.no2all.react.wire.server.No2AllArtServer; import love.distributedrebirth.no2all.react.wire.server.No2AllArtServerOnStart; @@ -16,12 +13,15 @@ import love.distributedrebirth.no2all.react.wire.server.No2AllRtsServerLog; import love.distributedrebirth.no2all.react.wire.server.No2AllRtsServer; import love.distributedrebirth.no2all.wire.ojw.OjwWireServer; import love.distributedrebirth.no2all.wire.ojw.OjwWireServerEndpoint; +import love.distributedrebirth.nx01.warp.core.WarpCoreReactor; +import love.distributedrebirth.nx01.warp.core.WarpCoreSpeedMonitor; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; public class NoStrServerTest { static OjwWireServer server = null; public static void main(String[] args) throws Exception { - No2AllReactWarpCore react = new No2AllReactWarpCore(); - react.load(new No2AllRtsWarpSpeedMonitor()); + WarpCoreReactor react = new WarpCoreReactor(); + react.load(new WarpCoreSpeedMonitor()); react.load(new No2AllRtsServer()); react.load(new No2AllRtsServerLog()); react.load(new NoStrRtsServer()); @@ -29,7 +29,7 @@ public class NoStrServerTest { react.load(new NoStrRtsServerRelaySubs()); react.registrate(No2AllRtsServer.API, No2AllArtServer.class, artServer -> { - No2AllReactSlot serverSlot = artServer.getData().getSlot(); + WarpReactPlasma serverSlot = artServer.getData().getSlot(); react.registrate(serverSlot, No2AllArtServerOnStart.class, v -> { System.out.println("RelayServer started: " + v.getTarget().getSlotSlug()); }); diff --git a/nx01-no2all-react-wire/pom.xml b/nx01-no2all-react-wire/pom.xml index f2d121f..5df3ddb 100644 --- a/nx01-no2all-react-wire/pom.xml +++ b/nx01-no2all-react-wire/pom.xml @@ -15,7 +15,7 @@ ${project.groupId} - nx01-no2all-react + nx01-warp-core ${project.groupId} diff --git a/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/client/No2AllArtClient.java b/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/client/No2AllArtClient.java index 0cc5786..ca5f30a 100644 --- a/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/client/No2AllArtClient.java +++ b/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/client/No2AllArtClient.java @@ -1,11 +1,11 @@ package love.distributedrebirth.no2all.react.wire.client; -import love.distributedrebirth.no2all.react.No2AllReactSlot; -import love.distributedrebirth.no2all.react.warp.No2AllActAbstractSlot; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; +import love.distributedrebirth.nx01.warp.core.space.AbstractSpacePlasma; -public final class No2AllArtClient extends No2AllActAbstractSlot { +public final class No2AllArtClient extends AbstractSpacePlasma { - protected No2AllArtClient(No2AllReactSlot slot) { + protected No2AllArtClient(WarpReactPlasma slot) { super(slot); } } diff --git a/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/client/No2AllArtClientOnStart.java b/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/client/No2AllArtClientOnStart.java index f8010ac..04cbba3 100644 --- a/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/client/No2AllArtClientOnStart.java +++ b/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/client/No2AllArtClientOnStart.java @@ -1,11 +1,11 @@ package love.distributedrebirth.no2all.react.wire.client; -import love.distributedrebirth.no2all.react.No2AllReactSlot; -import love.distributedrebirth.no2all.react.warp.No2AllActAbstractSlot; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; +import love.distributedrebirth.nx01.warp.core.space.AbstractSpacePlasma; -public final class No2AllArtClientOnStart extends No2AllActAbstractSlot { +public final class No2AllArtClientOnStart extends AbstractSpacePlasma { - protected No2AllArtClientOnStart(No2AllReactSlot slot) { + protected No2AllArtClientOnStart(WarpReactPlasma slot) { super(slot); } } diff --git a/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/client/No2AllRtsClient.java b/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/client/No2AllRtsClient.java index bf48aae..02d6ba3 100644 --- a/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/client/No2AllRtsClient.java +++ b/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/client/No2AllRtsClient.java @@ -2,28 +2,28 @@ package love.distributedrebirth.no2all.react.wire.client; import java.nio.ByteBuffer; -import love.distributedrebirth.no2all.react.No2AllReact; -import love.distributedrebirth.no2all.react.No2AllReactSlot; -import love.distributedrebirth.no2all.react.No2AllReactSlotLoad; -import love.distributedrebirth.no2all.react.No2AllReactSlotSignal; -import love.distributedrebirth.no2all.react.No2AllReactTypeScript; import love.distributedrebirth.no2all.wire.WireClient; import love.distributedrebirth.no2all.wire.WireClientEndpoint; import love.distributedrebirth.no2all.wire.WireClientHandler; +import love.distributedrebirth.nx01.warp.core.react.WarpReact; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasmaPulse; +import love.distributedrebirth.nx01.warp.core.react.WarpReactTypeScript; +import love.distributedrebirth.nx01.warp.core.space.WarpSpaceAntimatterInducer; -public class No2AllRtsClient implements No2AllReactTypeScript { +public class No2AllRtsClient implements WarpReactTypeScript { - public static final No2AllReactSlot API = No2AllReactSlot.ofClass(No2AllRtsClient.class); + public static final WarpReactPlasma API = WarpReactPlasma.ofClass(No2AllRtsClient.class); @Override - public void onEvent(No2AllReactSlotSignal signal) { - No2AllReact react = signal.getReact(); + public void onEvent(WarpReactPlasmaPulse signal) { + WarpReact react = signal.getReact(); react.claim(API); react.claimIn(API, No2AllActClient.class); react.claimOut(API, No2AllArtClient.class); react.registrate(API, No2AllActClient.class, actClient -> { WireClientEndpoint clientEndpoint = actClient.getData().getEndpoint(); - No2AllReactSlot clientSlot = No2AllReactSlot.of(API, "wireId=" + clientEndpoint.wireId()); + WarpReactPlasma clientSlot = WarpReactPlasma.of(API, "wireId=" + clientEndpoint.wireId()); WireClient client = clientEndpoint.wireClient(wireHandler(react, clientSlot)); react.claim(clientSlot); react.claimIn(clientSlot, No2AllActClientConnect.class); @@ -54,7 +54,7 @@ public class No2AllRtsClient implements No2AllReactTypeScript { }); } - private WireClientHandler wireHandler(No2AllReact react, No2AllReactSlot clientSlot) { + private WireClientHandler wireHandler(WarpReact react, WarpReactPlasma clientSlot) { return new WireClientHandler() { @Override public void onStart() { diff --git a/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/server/No2AllArtServer.java b/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/server/No2AllArtServer.java index 0176e7f..6800335 100644 --- a/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/server/No2AllArtServer.java +++ b/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/server/No2AllArtServer.java @@ -1,11 +1,11 @@ package love.distributedrebirth.no2all.react.wire.server; -import love.distributedrebirth.no2all.react.No2AllReactSlot; -import love.distributedrebirth.no2all.react.warp.No2AllActAbstractSlot; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; +import love.distributedrebirth.nx01.warp.core.space.AbstractSpacePlasma; -public final class No2AllArtServer extends No2AllActAbstractSlot { +public final class No2AllArtServer extends AbstractSpacePlasma { - protected No2AllArtServer(No2AllReactSlot slot) { + protected No2AllArtServer(WarpReactPlasma slot) { super(slot); } } diff --git a/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/server/No2AllArtServerSocket.java b/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/server/No2AllArtServerSocket.java index 793f8a7..2a7a477 100644 --- a/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/server/No2AllArtServerSocket.java +++ b/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/server/No2AllArtServerSocket.java @@ -1,13 +1,13 @@ package love.distributedrebirth.no2all.react.wire.server; -import love.distributedrebirth.no2all.react.No2AllReactSlot; -import love.distributedrebirth.no2all.react.warp.No2AllActAbstractSlot; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; +import love.distributedrebirth.nx01.warp.core.space.AbstractSpacePlasma; -public final class No2AllArtServerSocket extends No2AllActAbstractSlot { +public final class No2AllArtServerSocket extends AbstractSpacePlasma { private final String remoteAddr; - protected No2AllArtServerSocket(No2AllReactSlot slot, String remoteAddr) { + protected No2AllArtServerSocket(WarpReactPlasma slot, String remoteAddr) { super(slot); this.remoteAddr = remoteAddr; } diff --git a/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/server/No2AllRtsServer.java b/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/server/No2AllRtsServer.java index 3c548f6..cc11059 100644 --- a/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/server/No2AllRtsServer.java +++ b/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/server/No2AllRtsServer.java @@ -2,29 +2,29 @@ package love.distributedrebirth.no2all.react.wire.server; import java.nio.ByteBuffer; -import love.distributedrebirth.no2all.react.No2AllReactSlotLoad; -import love.distributedrebirth.no2all.react.No2AllReact; -import love.distributedrebirth.no2all.react.No2AllReactSlot; -import love.distributedrebirth.no2all.react.No2AllReactSlotSignal; -import love.distributedrebirth.no2all.react.No2AllReactTypeScript; import love.distributedrebirth.no2all.wire.WireServer; import love.distributedrebirth.no2all.wire.WireServerEndpoint; import love.distributedrebirth.no2all.wire.WireServerHandler; import love.distributedrebirth.no2all.wire.WireServerSocket; +import love.distributedrebirth.nx01.warp.core.react.WarpReact; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasmaPulse; +import love.distributedrebirth.nx01.warp.core.react.WarpReactTypeScript; +import love.distributedrebirth.nx01.warp.core.space.WarpSpaceAntimatterInducer; -public class No2AllRtsServer implements No2AllReactTypeScript { +public class No2AllRtsServer implements WarpReactTypeScript { - public static final No2AllReactSlot API = No2AllReactSlot.ofClass(No2AllRtsServer.class); + public static final WarpReactPlasma API = WarpReactPlasma.ofClass(No2AllRtsServer.class); @Override - public void onEvent(No2AllReactSlotSignal signal) { - No2AllReact react = signal.getReact(); + public void onEvent(WarpReactPlasmaPulse signal) { + WarpReact react = signal.getReact(); react.claim(API); react.claimIn(API, No2AllActServer.class); react.claimOut(API, No2AllArtServer.class); react.registrate(API, No2AllActServer.class, actServer -> { WireServerEndpoint serverEndpoint = actServer.getData().getEndpoint(); - No2AllReactSlot serverSlot = No2AllReactSlot.of(API, "wireId=" + serverEndpoint.wireId()); + WarpReactPlasma serverSlot = WarpReactPlasma.of(API, "wireId=" + serverEndpoint.wireId()); WireServer server = serverEndpoint.wireServer(wireHandler(react, serverSlot)); react.claim(serverSlot); react.claimIn(serverSlot, No2AllActServerBroadcastMessage.class); @@ -44,10 +44,10 @@ public class No2AllRtsServer implements No2AllReactTypeScript { }); } - private WireServerHandler wireHandler(No2AllReact react, No2AllReactSlot serverSlot) { + private WireServerHandler wireHandler(WarpReact react, WarpReactPlasma serverSlot) { return new WireServerHandler() { - private No2AllReactSlot socketSlug(WireServerSocket conn) { - return No2AllReactSlot.of(serverSlot, "hashCode=" + conn.hashCode()); + private WarpReactPlasma socketSlug(WireServerSocket conn) { + return WarpReactPlasma.of(serverSlot, "hashCode=" + conn.hashCode()); } @Override @@ -57,7 +57,7 @@ public class No2AllRtsServer implements No2AllReactTypeScript { @Override public void onOpen(WireServerSocket conn) { - No2AllReactSlot socketSlot = socketSlug(conn); + WarpReactPlasma socketSlot = socketSlug(conn); react.claim(socketSlot); react.claimIn(socketSlot, No2AllActServerSocketSendMessage.class); react.claimIn(socketSlot, No2AllActServerSocketSendBinary.class); @@ -80,7 +80,7 @@ public class No2AllRtsServer implements No2AllReactTypeScript { @Override public void onClose(WireServerSocket conn, int code, String reason, boolean remote) { - No2AllReactSlot socketSlot = socketSlug(conn); + WarpReactPlasma socketSlot = socketSlug(conn); react.fire(socketSlot, new No2AllArtServerSocketOnClose(code, reason, remote)); react.release(socketSlot); } diff --git a/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/server/No2AllRtsServerLog.java b/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/server/No2AllRtsServerLog.java index 93990f0..ff90abc 100644 --- a/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/server/No2AllRtsServerLog.java +++ b/nx01-no2all-react-wire/src/main/java/love/distributedrebirth/no2all/react/wire/server/No2AllRtsServerLog.java @@ -1,30 +1,29 @@ package love.distributedrebirth.no2all.react.wire.server; -import love.distributedrebirth.no2all.react.No2AllReactSlotLoad; - import java.util.logging.Logger; -import love.distributedrebirth.no2all.react.No2AllReact; -import love.distributedrebirth.no2all.react.No2AllReactSlot; -import love.distributedrebirth.no2all.react.No2AllReactSlotSignal; -import love.distributedrebirth.no2all.react.No2AllReactTypeScript; +import love.distributedrebirth.nx01.warp.core.react.WarpReact; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasmaPulse; +import love.distributedrebirth.nx01.warp.core.react.WarpReactTypeScript; +import love.distributedrebirth.nx01.warp.core.space.WarpSpaceAntimatterInducer; -public class No2AllRtsServerLog implements No2AllReactTypeScript { +public class No2AllRtsServerLog implements WarpReactTypeScript { - public static final No2AllReactSlot API = No2AllReactSlot.ofClass(No2AllRtsServerLog.class); + public static final WarpReactPlasma API = WarpReactPlasma.ofClass(No2AllRtsServerLog.class); private static final Logger logger = Logger.getLogger(No2AllRtsServerLog.class.getName()); @Override - public void onEvent(No2AllReactSlotSignal signal) { - No2AllReact react = signal.getReact(); + public void onEvent(WarpReactPlasmaPulse signal) { + WarpReact react = signal.getReact(); react.claim(API); react.registrate(No2AllRtsServer.API, No2AllArtServer.class, artServer -> { - No2AllReactSlot serverSlot = artServer.getData().getSlot(); + WarpReactPlasma serverSlot = artServer.getData().getSlot(); react.registrate(serverSlot, No2AllActServerBroadcastMessage.class, v -> { logger.info("broadcastMessage: " + v.getData().getMessage()); }); react.registrate(serverSlot, No2AllArtServerSocket.class, v -> { - No2AllReactSlot socketSlot = v.getData().getSlot(); + WarpReactPlasma socketSlot = v.getData().getSlot(); String wireId = socketSlot.getSlotSlug(); react.registrate(socketSlot, No2AllArtServerSocketOnMessage.class, z -> { logger.info(wireId+".socketOnMessage: " + z.getData().getMessage()); diff --git a/nx01-no2all-wire-jetty/src/test/java/love/distributedrebirth/no2all/wire/jetty/EventServer.java b/nx01-no2all-wire-jetty/src/test/java/love/distributedrebirth/no2all/wire/jetty/EventServer.java index bd86dc9..622ec6d 100644 --- a/nx01-no2all-wire-jetty/src/test/java/love/distributedrebirth/no2all/wire/jetty/EventServer.java +++ b/nx01-no2all-wire-jetty/src/test/java/love/distributedrebirth/no2all/wire/jetty/EventServer.java @@ -11,15 +11,15 @@ import org.eclipse.jetty.websocket.server.config.JettyWebSocketServletContainerI import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import love.distributedrebirth.no2all.react.No2AllReactSlot; -import love.distributedrebirth.no2all.react.warp.No2AllReactWarpCore; -import love.distributedrebirth.no2all.react.warp.No2AllRtsWarpSpeedMonitor; import love.distributedrebirth.no2all.react.wire.server.No2AllActServer; import love.distributedrebirth.no2all.react.wire.server.No2AllActServerSocketSendMessage; import love.distributedrebirth.no2all.react.wire.server.No2AllArtServer; import love.distributedrebirth.no2all.react.wire.server.No2AllArtServerSocket; import love.distributedrebirth.no2all.react.wire.server.No2AllArtServerSocketOnMessage; import love.distributedrebirth.no2all.react.wire.server.No2AllRtsServerLog; +import love.distributedrebirth.nx01.warp.core.WarpCoreReactor; +import love.distributedrebirth.nx01.warp.core.WarpCoreSpeedMonitor; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; import love.distributedrebirth.no2all.react.wire.server.No2AllRtsServer; public class EventServer { @@ -55,16 +55,16 @@ public class EventServer { @Override public void lifeCycleStarted(LifeCycle event) { LOG.info("Startup No2AllReactWarpCore"); - No2AllReactWarpCore react = new No2AllReactWarpCore(); - react.load(new No2AllRtsWarpSpeedMonitor()); + WarpCoreReactor react = new WarpCoreReactor(); + react.load(new WarpCoreSpeedMonitor()); react.load(new No2AllRtsServer()); react.load(new No2AllRtsServerLog()); // auto reply react.registrate(No2AllRtsServer.API, No2AllArtServer.class, artServer -> { - No2AllReactSlot serverSlot = artServer.getData().getSlot(); + WarpReactPlasma serverSlot = artServer.getData().getSlot(); react.registrate(serverSlot, No2AllArtServerSocket.class, artSocket -> { - No2AllReactSlot socketSlot = artSocket.getData().getSlot(); + WarpReactPlasma socketSlot = artSocket.getData().getSlot(); react.registrate(socketSlot, No2AllArtServerSocketOnMessage.class, artMsg -> { react.fire(socketSlot, new No2AllActServerSocketSendMessage("RE: "+artMsg.getData().getMessage())); }); diff --git a/nx01-no2all-zerofungus/src/main/java/love/distributedrebirth/no2all/zerofungus/ZFunRtsServer.java b/nx01-no2all-zerofungus/src/main/java/love/distributedrebirth/no2all/zerofungus/ZFunRtsServer.java index 66f2b49..d6f0c45 100644 --- a/nx01-no2all-zerofungus/src/main/java/love/distributedrebirth/no2all/zerofungus/ZFunRtsServer.java +++ b/nx01-no2all-zerofungus/src/main/java/love/distributedrebirth/no2all/zerofungus/ZFunRtsServer.java @@ -11,22 +11,22 @@ import javax.sql.DataSource; import jakarta.json.Json; import jakarta.json.JsonWriter; import love.distributedrebirth.no2all.nostr.model.event.NoStrEvent; -import love.distributedrebirth.no2all.react.No2AllReact; -import love.distributedrebirth.no2all.react.No2AllReactSlot; -import love.distributedrebirth.no2all.react.No2AllReactSlotLoad; -import love.distributedrebirth.no2all.react.No2AllReactSlotSignal; -import love.distributedrebirth.no2all.react.No2AllReactTypeScript; import love.distributedrebirth.no2all.react.nostr.server.relay.NoStrArtServerRelayStoreEvent; import love.distributedrebirth.no2all.react.nostr.server.relay.NoStrRtsServerRelay; +import love.distributedrebirth.nx01.warp.core.react.WarpReact; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasmaPulse; +import love.distributedrebirth.nx01.warp.core.react.WarpReactTypeScript; +import love.distributedrebirth.nx01.warp.core.space.WarpSpaceAntimatterInducer; -public class ZFunRtsServer implements No2AllReactTypeScript { +public class ZFunRtsServer implements WarpReactTypeScript { - public static final No2AllReactSlot API = No2AllReactSlot.ofClass(ZFunRtsServer.class); + public static final WarpReactPlasma API = WarpReactPlasma.ofClass(ZFunRtsServer.class); private static final Logger logger = Logger.getLogger(ZFunRtsServer.class.getName()); @Override - public void onEvent(No2AllReactSlotSignal signal) { - No2AllReact react = signal.getReact(); + public void onEvent(WarpReactPlasmaPulse signal) { + WarpReact react = signal.getReact(); react.claim(API); DataSource ds = react.service(DataSource.class); diff --git a/nx01-no2all-zerofungus/src/main/java/love/distributedrebirth/no2all/zerofungus/ZFunRtsServerBooted.java b/nx01-no2all-zerofungus/src/main/java/love/distributedrebirth/no2all/zerofungus/ZFunRtsServerBooted.java index 564b8c0..290ace0 100644 --- a/nx01-no2all-zerofungus/src/main/java/love/distributedrebirth/no2all/zerofungus/ZFunRtsServerBooted.java +++ b/nx01-no2all-zerofungus/src/main/java/love/distributedrebirth/no2all/zerofungus/ZFunRtsServerBooted.java @@ -2,18 +2,18 @@ package love.distributedrebirth.no2all.zerofungus; import java.util.logging.Logger; -import love.distributedrebirth.no2all.react.No2AllReactSlot; -import love.distributedrebirth.no2all.react.No2AllReactSlotLoad; -import love.distributedrebirth.no2all.react.No2AllReactSlotSignal; -import love.distributedrebirth.no2all.react.No2AllReactTypeScript; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasmaPulse; +import love.distributedrebirth.nx01.warp.core.react.WarpReactTypeScript; +import love.distributedrebirth.nx01.warp.core.space.WarpSpaceAntimatterInducer; -public class ZFunRtsServerBooted implements No2AllReactTypeScript { +public class ZFunRtsServerBooted implements WarpReactTypeScript { - public static final No2AllReactSlot API = No2AllReactSlot.ofClass(ZFunRtsServerBooted.class); + public static final WarpReactPlasma API = WarpReactPlasma.ofClass(ZFunRtsServerBooted.class); private static final Logger logger = Logger.getLogger(ZFunRtsServerBooted.class.getName()); @Override - public void onEvent(No2AllReactSlotSignal signal) { + public void onEvent(WarpReactPlasmaPulse signal) { signal.getReact().claim(API); logger.info("╔═╗┌─┐┬─┐┌─┐ .╔═╗┬ ┬┌┐┌╔═╗┬ ┬┌─┐"); logger.info("╔═╝├┤ ├┬┘│ │ . ╠╣ │ ││││║ ╦│ │└─┐"); diff --git a/nx01-no2all-zerofungus/src/main/java/love/distributedrebirth/no2all/zerofungus/ZeroFungus.java b/nx01-no2all-zerofungus/src/main/java/love/distributedrebirth/no2all/zerofungus/ZeroFungus.java index 1a2edc6..0f31d64 100644 --- a/nx01-no2all-zerofungus/src/main/java/love/distributedrebirth/no2all/zerofungus/ZeroFungus.java +++ b/nx01-no2all-zerofungus/src/main/java/love/distributedrebirth/no2all/zerofungus/ZeroFungus.java @@ -10,8 +10,6 @@ import love.distributedrebirth.no2all.react.nostr.client.NoStrRtsClient; import love.distributedrebirth.no2all.react.nostr.server.NoStrRtsServer; import love.distributedrebirth.no2all.react.nostr.server.relay.NoStrRtsServerRelay; import love.distributedrebirth.no2all.react.nostr.server.relay.NoStrRtsServerRelaySubs; -import love.distributedrebirth.no2all.react.warp.No2AllReactWarpCore; -import love.distributedrebirth.no2all.react.warp.No2AllRtsWarpSpeedMonitor; import love.distributedrebirth.no2all.react.wire.client.No2AllRtsClient; import love.distributedrebirth.no2all.react.wire.server.No2AllRtsServer; import love.distributedrebirth.no2all.react.wire.server.No2AllRtsServerLog; @@ -19,11 +17,13 @@ import love.distributedrebirth.no2all.zerofungus.service.ZFunRtsConfigJetty; import love.distributedrebirth.no2all.zerofungus.service.ZFunRtsConfigLogger; //import ᒢᐩᐩ.ᔿᐤᒄʸ.ᣔᒃᣔᒼᓑᔆ.BãßBȍőnAbacusInstanceMBeanʸᴰ; import love.distributedrebirth.no2all.zerofungus.service.ZFunRtsInitJdbc; +import love.distributedrebirth.nx01.warp.core.WarpCoreReactor; +import love.distributedrebirth.nx01.warp.core.WarpCoreSpeedMonitor; public enum ZeroFungus /* implements BãßBȍőnAbacusInstanceMBeanʸᴰ */ { INSTANCE; - private No2AllReactWarpCore foei = new No2AllReactWarpCore(); + private WarpCoreReactor foei = new WarpCoreReactor(); private List jetties = new ArrayList<>(); public static void main(String[] args) { @@ -52,7 +52,7 @@ public enum ZeroFungus /* implements BãßBȍőnAbacusInstanceMBeanʸᴰ signal) { + public void onEvent(WarpReactPlasmaPulse signal) { logger.info(" ╦┌─┐╔╦╗╔╦╗┬ ┬ ╔═╗┌─┐╦ ╦╔═╗┬─┐┌┬┐"); logger.info(" ║├┤ ║ ║ └┬┘ ╠═╝│ │║║║║╣ ├┬┘ ││"); logger.info("╚╝└─┘ ╩ ╩ ┴ ╩ └─┘╚╩╝╚═╝┴└──┴┘"); @@ -84,7 +84,7 @@ public final class ZFunRtsConfigJetty implements No2AllReactTypeScript { CustomRequestLog log = new CustomRequestLog("logs/http.log", CustomRequestLog.EXTENDED_NCSA_FORMAT); server.setRequestLog(log); - No2AllReact react = signal.getReact(); + WarpReact react = signal.getReact(); server.addEventListener(new Listener() { @Override public void lifeCycleStarted(LifeCycle event) { diff --git a/nx01-no2all-zerofungus/src/main/java/love/distributedrebirth/no2all/zerofungus/service/ZFunRtsConfigLogger.java b/nx01-no2all-zerofungus/src/main/java/love/distributedrebirth/no2all/zerofungus/service/ZFunRtsConfigLogger.java index ebeaeab..f010d07 100644 --- a/nx01-no2all-zerofungus/src/main/java/love/distributedrebirth/no2all/zerofungus/service/ZFunRtsConfigLogger.java +++ b/nx01-no2all-zerofungus/src/main/java/love/distributedrebirth/no2all/zerofungus/service/ZFunRtsConfigLogger.java @@ -6,18 +6,18 @@ import org.slf4j.LoggerFactory; import org.slf4j.bridge.SLF4JBridgeHandler; import ch.qos.logback.core.status.NopStatusListener; -import love.distributedrebirth.no2all.react.No2AllReactSlot; -import love.distributedrebirth.no2all.react.No2AllReactSlotLoad; -import love.distributedrebirth.no2all.react.No2AllReactSlotSignal; -import love.distributedrebirth.no2all.react.No2AllReactTypeScript; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasmaPulse; +import love.distributedrebirth.nx01.warp.core.react.WarpReactTypeScript; +import love.distributedrebirth.nx01.warp.core.space.WarpSpaceAntimatterInducer; -public class ZFunRtsConfigLogger implements No2AllReactTypeScript { +public class ZFunRtsConfigLogger implements WarpReactTypeScript { - public static final No2AllReactSlot API = No2AllReactSlot.ofClass(ZFunRtsConfigLogger.class); + public static final WarpReactPlasma API = WarpReactPlasma.ofClass(ZFunRtsConfigLogger.class); private static final Logger logger = Logger.getLogger(ZFunRtsConfigLogger.class.getName()); @Override - public void onEvent(No2AllReactSlotSignal signal) { + public void onEvent(WarpReactPlasmaPulse signal) { if (System.getProperty("logback.configurationFile") == null) { String logConfig = null; if (System.getProperty("java.class.path").contains("classes")) { diff --git a/nx01-no2all-zerofungus/src/main/java/love/distributedrebirth/no2all/zerofungus/service/ZFunRtsInitJdbc.java b/nx01-no2all-zerofungus/src/main/java/love/distributedrebirth/no2all/zerofungus/service/ZFunRtsInitJdbc.java index 51b0845..a94c99f 100644 --- a/nx01-no2all-zerofungus/src/main/java/love/distributedrebirth/no2all/zerofungus/service/ZFunRtsInitJdbc.java +++ b/nx01-no2all-zerofungus/src/main/java/love/distributedrebirth/no2all/zerofungus/service/ZFunRtsInitJdbc.java @@ -11,24 +11,25 @@ import javax.sql.DataSource; import org.flywaydb.core.Flyway; import org.h2.jdbcx.JdbcConnectionPool; -import love.distributedrebirth.no2all.react.No2AllReactSlot; -import love.distributedrebirth.no2all.react.No2AllReactSlotLoad; -import love.distributedrebirth.no2all.react.No2AllReactSlotSignal; -import love.distributedrebirth.no2all.react.No2AllReactTypeScript; -import love.distributedrebirth.no2all.react.warp.No2AllReactWarpCore; +import love.distributedrebirth.nx01.warp.core.WarpCoreReactor; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasmaPulse; +import love.distributedrebirth.nx01.warp.core.react.WarpReactTypeScript; +import love.distributedrebirth.nx01.warp.core.space.WarpSpaceAntimatterInducer; -public class ZFunRtsInitJdbc implements No2AllReactTypeScript { - public static final No2AllReactSlot API = No2AllReactSlot.ofClass(ZFunRtsInitJdbc.class); +public class ZFunRtsInitJdbc implements WarpReactTypeScript { + + public static final WarpReactPlasma API = WarpReactPlasma.ofClass(ZFunRtsInitJdbc.class); private static final Logger logger = Logger.getLogger(ZFunRtsInitJdbc.class.getName()); - private final No2AllReactWarpCore foei; + private final WarpCoreReactor foei; - public ZFunRtsInitJdbc(No2AllReactWarpCore foei) { + public ZFunRtsInitJdbc(WarpCoreReactor foei) { this.foei = foei; } @Override - public void onEvent(No2AllReactSlotSignal signal) { + public void onEvent(WarpReactPlasmaPulse signal) { signal.getReact().claim(API); JdbcConnectionPool cp = JdbcConnectionPool.create("jdbc:h2:file:./target/h2db/zfun", "sa", "sa"); diff --git a/nx01-warp-core/pom.xml b/nx01-warp-core/pom.xml new file mode 100644 index 0000000..145b387 --- /dev/null +++ b/nx01-warp-core/pom.xml @@ -0,0 +1,21 @@ + + 4.0.0 + + love.distributedrebirth.nx01 + nx01 + 〇一。壬寅。一〄-SNAPSHOT + + nx01-warp-core + + + love.distributedrebirth.nx01 + nx01-warp-fault + + + org.junit.jupiter + junit-jupiter + test + + + \ No newline at end of file diff --git a/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/WarpCorePlasmaConduit.java b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/WarpCorePlasmaConduit.java new file mode 100644 index 0000000..8f354bc --- /dev/null +++ b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/WarpCorePlasmaConduit.java @@ -0,0 +1,120 @@ +package love.distributedrebirth.nx01.warp.core; + +import java.util.ArrayList; +import java.util.HashMap; +import java.util.HashSet; +import java.util.List; +import java.util.Map; +import java.util.Objects; +import java.util.Set; + +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasmaCoil; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasmaPulse; + +public class WarpCorePlasmaConduit { + + private final WarpCoreReactor no2AllReactWarpCore; + private final WarpReactPlasma containerSlot; + private final Map, List>> listeners = new HashMap<>(); + private final Set> claimTypesOut = new HashSet<>(); + private final Set> claimTypesIn = new HashSet<>(); + private final Set> requireServices = new HashSet<>(); + private final Set requireSlots = new HashSet<>(); + + protected WarpCorePlasmaConduit(WarpCoreReactor no2AllReactWarpCore, WarpReactPlasma containerSlot) { + this.no2AllReactWarpCore = Objects.requireNonNull(no2AllReactWarpCore); + this.containerSlot = Objects.requireNonNull(containerSlot); + } + + private List> toViewOfListeners(Class eventType) { + List> result = new ArrayList<>(); + synchronized (listeners) { + List> typeListeners = listeners.get(eventType); + if (typeListeners == null) { + return result; + } + result.addAll(typeListeners); + } + return result; + } + + public void fire(Object event, WarpReactPlasma slot) { + for (WarpReactPlasmaCoil listener : toViewOfListeners(event.getClass())) { + listener.onEvent(new WarpReactPlasmaPulse<>(slot, event, this.no2AllReactWarpCore)); + } + } + + public void registrateListener(Class eventType, WarpReactPlasmaCoil listener) { + Objects.requireNonNull(eventType); + Objects.requireNonNull(listener); + synchronized (listeners) { + List> typeListeners = listeners.get(eventType); + if (typeListeners == null) { + typeListeners = new ArrayList<>(); + listeners.put(eventType, typeListeners); + } + typeListeners.add(listener); + } + } + + public void registrateTypeOut(Class eventType) { + Objects.requireNonNull(eventType); + synchronized (claimTypesOut) { + claimTypesOut.add(eventType); + } + } + + public void registrateTypeIn(Class eventType) { + Objects.requireNonNull(eventType); + synchronized (claimTypesIn) { + claimTypesIn.add(eventType); + } + } + + public WarpCorePlasmaIntermixChamber readContract() { + WarpCorePlasmaIntermixChamber result = new WarpCorePlasmaIntermixChamber(containerSlot); + synchronized (claimTypesIn) { + result.slotTypesIn.addAll(claimTypesIn); + } + synchronized (claimTypesOut) { + result.slotTypesOut.addAll(claimTypesOut); + } + return result; + } + + public void addRequireService(Class serviceType) { + Objects.requireNonNull(serviceType); + synchronized (requireServices) { + requireServices.add(serviceType); + } + } + + public void addRequireSlot(WarpReactPlasma dep) { + Objects.requireNonNull(dep); + synchronized (requireSlots) { + requireSlots.add(dep); + } + } + + public void removeAll() { + synchronized (listeners) { + for (Class eventType : listeners.keySet()) { + List> typeListeners = listeners.get(eventType); + typeListeners.clear(); + } + } + synchronized (claimTypesOut) { + claimTypesOut.clear(); + } + synchronized (claimTypesIn) { + claimTypesIn.clear(); + } + synchronized (requireServices) { + requireServices.clear(); + } + synchronized (requireSlots) { + requireSlots.clear(); + } + } +} diff --git a/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/WarpCorePlasmaIntermixChamber.java b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/WarpCorePlasmaIntermixChamber.java new file mode 100644 index 0000000..5d8e363 --- /dev/null +++ b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/WarpCorePlasmaIntermixChamber.java @@ -0,0 +1,30 @@ +package love.distributedrebirth.nx01.warp.core; + +import java.util.ArrayList; +import java.util.List; + +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; + + +public class WarpCorePlasmaIntermixChamber { + + private final WarpReactPlasma slot; + final List> slotTypesIn = new ArrayList<>(); + final List> slotTypesOut = new ArrayList<>(); + + public WarpCorePlasmaIntermixChamber(WarpReactPlasma slot) { + this.slot = slot; + } + + public WarpReactPlasma getSlot() { + return slot; + } + + public List> getSlotTypesIn() { + return slotTypesIn; + } + + public List> getSlotTypesOut() { + return slotTypesOut; + } +} \ No newline at end of file diff --git a/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/WarpCoreReactor.java b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/WarpCoreReactor.java new file mode 100644 index 0000000..4f3da58 --- /dev/null +++ b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/WarpCoreReactor.java @@ -0,0 +1,188 @@ +package love.distributedrebirth.nx01.warp.core; + +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import java.util.Objects; + +import love.distributedrebirth.nx01.warp.core.react.WarpReact; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasmaCoil; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasmaPulse; +import love.distributedrebirth.nx01.warp.core.react.WarpReactTypeScript; +import love.distributedrebirth.nx01.warp.core.space.WarpSpaceAntimatterInducer; +import love.distributedrebirth.nx01.warp.core.space.WarpSpacePlasmaAdd; +import love.distributedrebirth.nx01.warp.core.space.WarpSpacePlasmaRemove; + +public class WarpCoreReactor implements WarpReact { + + public static final WarpReactPlasma DILITHIUM = WarpReactPlasma.ofClass(WarpCoreReactor.class); + private final Map slots = new HashMap<>(); + private final Map, Object> services = new HashMap<>(); + private final List backlog = new ArrayList<>(); + private Object currentEvent = null; + + public WarpCoreReactor() { + claim(DILITHIUM); + toWarpFuel(DILITHIUM).registrateTypeIn(WarpSpaceAntimatterInducer.class); + toWarpFuel(DILITHIUM).registrateTypeOut(WarpSpacePlasmaAdd.class); + toWarpFuel(DILITHIUM).registrateTypeOut(WarpSpacePlasmaRemove.class); + } + + public void load(WarpReactTypeScript script) { + Objects.requireNonNull(script).onEvent(new WarpReactPlasmaPulse<>(DILITHIUM, new WarpSpaceAntimatterInducer(), this)); + } + + public WarpCorePlasmaIntermixChamber getSlotContract(WarpReactPlasma slot) { + return toWarpFuel(slot).readContract(); + } + + public List listChilds(WarpReactPlasma slot) { + Objects.requireNonNull(slot); + List result = new ArrayList<>(); + synchronized (slots) { + for (WarpReactPlasma slug : slots.keySet()) { + if (slot == null) { + result.add(slug); + continue; + } + if (slug.getParent() == null) { + continue; + } + if (slug.getParent().getSlotPath().equals(slot.getSlotPath())) { + result.add(slug); + } + } + } + return result; + } + + @Override + public void fireForEach(WarpReactPlasma slot, Object event) { + for (WarpReactPlasma target : listChilds(slot)) { + fire(target, event); + } + } + + @Override + public void fire(WarpReactPlasma slot, Object event) { + Objects.requireNonNull(slot); + Objects.requireNonNull(event); + if (currentEvent != null) { + backlog.add(new BacklogEvent(slot, event)); + return; + } + currentEvent = event; + try { + toWarpFuel(slot).fire(event, slot); + + while (!backlog.isEmpty()) { + List backlog2 = new ArrayList<>(backlog); + backlog.clear(); + for (BacklogEvent next : backlog2) { + toWarpFuel(next.slot).fire(next.event, next.slot); + } + } + } finally { + currentEvent = null; + } + } + + static class BacklogEvent { + WarpReactPlasma slot; + Object event; + public BacklogEvent(WarpReactPlasma slot, Object event) { + this.slot = slot; + this.event = event; + } + } + + @SuppressWarnings("unchecked") + @Override + public void registrate(WarpReactPlasma slot, Class eventType, WarpReactPlasmaCoil listener) { + WarpReactPlasmaCoil listenerObj = (WarpReactPlasmaCoil) listener; + toWarpFuel(slot).registrateListener(eventType, listenerObj); + } + + @Override + public void release(WarpReactPlasma slot) { + toWarpFuel(slot).removeAll(); + synchronized (slots) { + slots.remove(slot); + } + fire(DILITHIUM, new WarpSpacePlasmaRemove(slot)); + } + + @Override + public void claim(WarpReactPlasma slot) { + Objects.requireNonNull(slot); + synchronized (slots) { + if (slots.keySet().contains(slot)) { + throw new IllegalStateException("Slug already claimed: " + slot.getSlotPath()); + } + slots.put(slot, new WarpCorePlasmaConduit(this, slot)); + } + fire(DILITHIUM, new WarpSpacePlasmaAdd(slot)); + } + + @Override + public void claimOut(WarpReactPlasma slot, Class eventType) { + toWarpFuel(slot).registrateTypeOut(eventType); + } + + + @Override + public void claimIn(WarpReactPlasma slot, Class eventType) { + toWarpFuel(slot).registrateTypeIn(eventType); + } + + @Override + public void requireSlot(WarpReactPlasma slot, WarpReactPlasma dep) { + if (!isClaimed(dep)) { + throw new IllegalStateException("Script dependency missing: " + dep); + } + toWarpFuel(slot).addRequireSlot(dep); + } + + @Override + public void requireService(WarpReactPlasma slot, Class serviceType) { + toWarpFuel(slot).addRequireService(serviceType); + } + + @SuppressWarnings("unchecked") + @Override + public T service(Class serviceType) { + Objects.requireNonNull(serviceType); + synchronized (services) { + return (T) services.get(serviceType); + } + } + + public void addService(Class serviceType, T service) { + Objects.requireNonNull(serviceType); + Objects.requireNonNull(service); + synchronized (services) { + services.put(serviceType, service); + } + } + + public boolean isClaimed(WarpReactPlasma slug) { + Objects.requireNonNull(slug); + synchronized (slots) { + return slots.keySet().contains(slug); + } + } + + protected WarpCorePlasmaConduit toWarpFuel(WarpReactPlasma slot) { + Objects.requireNonNull(slot); + WarpCorePlasmaConduit result; + synchronized (slots) { + result = slots.get(slot); + if (result == null) { + throw new IllegalStateException("Slot not claimed: " + slot.getSlotPath()); + } + } + return result; + } +} diff --git a/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/WarpCoreSpeedMonitor.java b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/WarpCoreSpeedMonitor.java new file mode 100644 index 0000000..9310b48 --- /dev/null +++ b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/WarpCoreSpeedMonitor.java @@ -0,0 +1,31 @@ +package love.distributedrebirth.nx01.warp.core; + +import java.util.logging.Logger; + +import love.distributedrebirth.nx01.warp.core.react.WarpReact; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasmaPulse; +import love.distributedrebirth.nx01.warp.core.react.WarpReactTypeScript; +import love.distributedrebirth.nx01.warp.core.space.WarpSpaceAntimatterInducer; +import love.distributedrebirth.nx01.warp.core.space.WarpSpacePlasmaAdd; +import love.distributedrebirth.nx01.warp.core.space.WarpSpacePlasmaRemove; + +public class WarpCoreSpeedMonitor implements WarpReactTypeScript { + + public static final WarpReactPlasma API = WarpReactPlasma.ofClass(WarpCoreSpeedMonitor.class); + private static final WarpReactPlasma API_DILITHIUM = WarpCoreReactor.DILITHIUM; + private static final Logger LOG = Logger.getLogger(WarpCoreSpeedMonitor.class.getName()); + + @Override + public void onEvent(WarpReactPlasmaPulse signal) { + WarpReact react = signal.getReact(); + react.claim(API); + react.requireSlot(API, API_DILITHIUM); + react.registrate(API_DILITHIUM, WarpSpacePlasmaAdd.class, v -> { + LOG.fine("slot-add: " + v.getData().getSlot().getSlotPath()); + }); + react.registrate(API_DILITHIUM, WarpSpacePlasmaRemove.class, v -> { + LOG.fine("slot-remove: " + v.getData().getSlot().getSlotPath()); + }); + } +} diff --git a/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/react/WarpReact.java b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/react/WarpReact.java new file mode 100644 index 0000000..d1e7877 --- /dev/null +++ b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/react/WarpReact.java @@ -0,0 +1,17 @@ +package love.distributedrebirth.nx01.warp.core.react; + +public interface WarpReact { + + void claim(WarpReactPlasma slot); + void claimIn(WarpReactPlasma slot, Class eventType); + void claimOut(WarpReactPlasma slot, Class eventType); + void requireSlot(WarpReactPlasma slot, WarpReactPlasma dep); + void requireService(WarpReactPlasma slot, Class serviceType); + + void fire(WarpReactPlasma slot, Object event); + void fireForEach(WarpReactPlasma slot, Object event); + void registrate(WarpReactPlasma slot, Class eventType, WarpReactPlasmaCoil listener); + + T service(Class serviceType); + void release(WarpReactPlasma slot); +} diff --git a/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/react/WarpReactPlasma.java b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/react/WarpReactPlasma.java new file mode 100644 index 0000000..8ed7dd8 --- /dev/null +++ b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/react/WarpReactPlasma.java @@ -0,0 +1,75 @@ +package love.distributedrebirth.nx01.warp.core.react; + +import java.util.ArrayList; +import java.util.List; +import java.util.Objects; + +public final class WarpReactPlasma { + + private final WarpReactPlasma parent; + private final String slotSlug; + private final String slotPath; + + private WarpReactPlasma(WarpReactPlasma parent, String slotSlug) { + this.parent = parent; + this.slotSlug = slotSlug; + this.slotPath = createSlotPath(); + } + + public WarpReactPlasma getParent() { + return parent; + } + + public String getSlotSlug() { + return slotSlug; + } + + public String getSlotPath() { + return slotPath; + } + + public String createSlotPath() { + List slugs = new ArrayList<>(); + WarpReactPlasma parentNode = this; + while (parentNode != null) { + slugs.add(parentNode.getSlotSlug()); + parentNode = parentNode.getParent(); + } + StringBuilder buf = new StringBuilder(); + for (int i = slugs.size() - 1; i >= 0; i--) { + buf.append(slugs.get(i)); + if (i > 0) { + buf.append(','); + } + } + return buf.toString(); + } + + @Override + public int hashCode() { + return Objects.hash(slotPath); + } + + @Override + public boolean equals(Object obj) { + if (this == obj) { + return true; + } + if (obj == null) { + return false; + } + if (getClass() != obj.getClass()) { + return false; + } + WarpReactPlasma other = (WarpReactPlasma) obj; + return Objects.equals(slotPath, other.slotPath); + } + + public static WarpReactPlasma ofClass(Class scriptClz) { + return new WarpReactPlasma(null, scriptClz.getPackageName() + ":type=" + scriptClz.getSimpleName()); + } + + public static WarpReactPlasma of(WarpReactPlasma parent, String kvPair) { + return new WarpReactPlasma(parent, kvPair); + } +} diff --git a/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/react/WarpReactPlasmaCoil.java b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/react/WarpReactPlasmaCoil.java new file mode 100644 index 0000000..42806a5 --- /dev/null +++ b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/react/WarpReactPlasmaCoil.java @@ -0,0 +1,7 @@ +package love.distributedrebirth.nx01.warp.core.react; + +@FunctionalInterface +public interface WarpReactPlasmaCoil { + + void onEvent(WarpReactPlasmaPulse signal); +} diff --git a/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/react/WarpReactPlasmaPulse.java b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/react/WarpReactPlasmaPulse.java new file mode 100644 index 0000000..cc4b027 --- /dev/null +++ b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/react/WarpReactPlasmaPulse.java @@ -0,0 +1,30 @@ +package love.distributedrebirth.nx01.warp.core.react; + +public final class WarpReactPlasmaPulse { + + private final WarpReactPlasma target; + private final T data; + private final WarpReact react; + + public WarpReactPlasmaPulse(WarpReactPlasma target, T data, WarpReact react) { + this.target = target; + this.data = data; + this.react = react; + } + + public WarpReactPlasma getTarget() { + return target; + } + + public T getData() { + return data; + } + + public WarpReact getReact() { + return react; + } + +// public T $() { +// return getData(); +// } +} diff --git a/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/react/WarpReactTypeScript.java b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/react/WarpReactTypeScript.java new file mode 100644 index 0000000..963b59c --- /dev/null +++ b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/react/WarpReactTypeScript.java @@ -0,0 +1,9 @@ +package love.distributedrebirth.nx01.warp.core.react; + +import love.distributedrebirth.nx01.warp.core.space.WarpSpaceAntimatterInducer; + +public interface WarpReactTypeScript extends WarpReactPlasmaCoil { + + default void onRelease(WarpReactPlasmaPulse signal) { + } +} diff --git a/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/space/AbstractSpacePlasma.java b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/space/AbstractSpacePlasma.java new file mode 100644 index 0000000..930bcf1 --- /dev/null +++ b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/space/AbstractSpacePlasma.java @@ -0,0 +1,16 @@ +package love.distributedrebirth.nx01.warp.core.space; + +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; + +public abstract class AbstractSpacePlasma { + + private final WarpReactPlasma slot; + + public AbstractSpacePlasma(WarpReactPlasma slot) { + this.slot = slot; + } + + public final WarpReactPlasma getSlot() { + return slot; + } +} diff --git a/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/space/WarpSpaceAntimatterInducer.java b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/space/WarpSpaceAntimatterInducer.java new file mode 100644 index 0000000..8d56959 --- /dev/null +++ b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/space/WarpSpaceAntimatterInducer.java @@ -0,0 +1,7 @@ +package love.distributedrebirth.nx01.warp.core.space; + +public final class WarpSpaceAntimatterInducer { + + public WarpSpaceAntimatterInducer() { + } +} diff --git a/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/space/WarpSpacePlasmaAdd.java b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/space/WarpSpacePlasmaAdd.java new file mode 100644 index 0000000..6200ffc --- /dev/null +++ b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/space/WarpSpacePlasmaAdd.java @@ -0,0 +1,10 @@ +package love.distributedrebirth.nx01.warp.core.space; + +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; + +public final class WarpSpacePlasmaAdd extends AbstractSpacePlasma { + + public WarpSpacePlasmaAdd(WarpReactPlasma slot) { + super(slot); + } +} diff --git a/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/space/WarpSpacePlasmaRemove.java b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/space/WarpSpacePlasmaRemove.java new file mode 100644 index 0000000..90a6c3d --- /dev/null +++ b/nx01-warp-core/src/main/java/love/distributedrebirth/nx01/warp/core/space/WarpSpacePlasmaRemove.java @@ -0,0 +1,10 @@ +package love.distributedrebirth.nx01.warp.core.space; + +import love.distributedrebirth.nx01.warp.core.react.WarpReactPlasma; + +public final class WarpSpacePlasmaRemove extends AbstractSpacePlasma { + + public WarpSpacePlasmaRemove(WarpReactPlasma slot) { + super(slot); + } +} diff --git a/pom.xml b/pom.xml index cdc1d21..79440a7 100644 --- a/pom.xml +++ b/pom.xml @@ -41,6 +41,12 @@ nx01-popcorn nx01-popcorn-duytsdoc nx01-popcorn-mm-jdbc + nx01-redsea + nx01-redsea-hyper-local + nx01-redsea-hyper + nx01-redsea-hyper-nostr + nx01-redsea-jdatstart + nx01-warp-core nx01-warp-fault nx01-warp-manifestor nx01-x4o-driver @@ -49,11 +55,6 @@ nx01-x4o-tool-ant-plugin nx01-x4o-tool-maven-plugin nx01-x4o-html - nx01-redsea - nx01-redsea-hyper-local - nx01-redsea-hyper - nx01-redsea-hyper-nostr - nx01-redsea-jdatstart @@ -288,11 +289,6 @@ nx01-no2all-nostr ${project.version} - - love.distributedrebirth.nx01 - nx01-no2all-react - ${project.version} - love.distributedrebirth.nx01 nx01-no2all-react-nostr @@ -368,6 +364,11 @@ nx01-redsea-hyper-nostr ${project.version} + + love.distributedrebirth.nx01 + nx01-warp-core + ${project.version} + love.distributedrebirth.nx01 nx01-warp-fault