Add first basic working scripts feature in server

Author: CodeDoctorDE

api/lib/src/models/kick.dart

@@ -2,6 +2,7 @@ import 'package:dart_mappable/dart_mappable.dart';
 
 part 'kick.mapper.dart';
 
+@MappableEnum()
 enum KickReason {
   kick,
   ban,

api/lib/src/models/kick.mapper.dart

@@ -36,6 +36,11 @@ class _WorldServerInterfaceImpl implements ServerInterface {
     bloc._processEvent(NetworkerPacket(event, target));
   }
 
+  @override
+  void print(String message, [String? plugin]) {
+    // TODO: implement better logging
+  }
+
   @override
   WorldState get state => bloc.state.world;
 

api/lib/src/models/table.mapper.dart

@@ -1,4 +1,6 @@
+import 'dart:async';
 import 'dart:io';
+import 'dart:typed_data';
 
 import 'package:dart_mappable/dart_mappable.dart';
 import 'package:networker/networker.dart';
@@ -93,7 +95,45 @@ final class UserLeaveCallback {
   UserLeaveCallback({required this.channel, required this.info});
 }
 
-@MappableClass()
+class _ConvertedConnectionInfo extends ConnectionInfo {
+  final Uri address;
+
+  _ConvertedConnectionInfo(this.address);
+
+  @override
+  FutureOr<void> close() {}
+
+  @override
+  bool get isClosed => true;
+
+  @override
+  FutureOr<void> sendMessage(Uint8List data) {}
+}
+
+class ConnectionInfoMapper extends SimpleMapper<ConnectionInfo> {
+  const ConnectionInfoMapper();
+
+  @override
+  ConnectionInfo decode(Object value) {
+    if (value is Map<String, Object?>) {
+      return _ConvertedConnectionInfo(
+        Uri.parse(value['address'] as String? ?? 'http://localhost'),
+      );
+    }
+    return _ConvertedConnectionInfo(Uri.parse('http://localhost'));
+  }
+
+  @override
+  Object? encode(ConnectionInfo self) {
+    return {
+      'address': self is _ConvertedConnectionInfo
+          ? self.address.toString()
+          : '',
+    };
+  }
+}
+
+@MappableClass(includeCustomMappers: [ConnectionInfoMapper()])
 final class UserJoined extends LocalWorldEvent with UserJoinedMappable {
   final Channel channel;
   final ConnectionInfo info;

app/lib/bloc/world/bloc.dart

@@ -22,6 +22,8 @@ mixin ServerInterface {
     required String plugin,
   });
 
+  void print(String message, [String? plugin]);
+
   WorldState get state;
   List<int> get players;
 }
@@ -32,16 +34,16 @@ final class PluginSystem {
 
   PluginSystem({required this.server});
 
-  SetonixPlugin registerPlugin(
+  Future<SetonixPlugin> registerPlugin(
     String name,
-    SetonixPlugin Function(PluginServerInterface) pluginBuilder,
-  ) {
+    FutureOr<SetonixPlugin> Function(PluginServerInterface) pluginBuilder,
+  ) async {
     final pluginServer = _PluginServerInterfaceImpl(server, name);
-    final plugin = pluginBuilder(pluginServer);
+    final plugin = await pluginBuilder(pluginServer);
     return _plugins[name] = plugin;
   }
 
-  SetonixPlugin registerLuauPlugin(
+  Future<SetonixPlugin> registerLuauPlugin(
     String name,
     String code, {
     void Function(String)? onPrint,
@@ -52,6 +54,7 @@ final class PluginSystem {
       (pluginServer) => RustSetonixPlugin.build(
         (c) => LuauPlugin(code: code, callback: c),
         pluginServer,
+        onPrint: (e) => server.print(e, name),
       ),
     );
   }
@@ -83,7 +86,7 @@ final class PluginSystem {
         .getPack(location.namespace)
         ?.getScript(location.id);
     if (data == null) return;
-    registerLuauPlugin(name, data);
+    registerLuauPlugin(name, data, onPrint: (e) => server.print(e, name));
   }
 
   bool get _nativeEnabled => RustLib.instance.initialized;
@@ -167,14 +170,12 @@ final class RustSetonixPlugin extends SetonixPlugin {
 
   RustSetonixPlugin._(super.server, this.plugin);
 
-  factory RustSetonixPlugin.build(
+  static Future<RustSetonixPlugin> build(
     RustPlugin Function(PluginCallback) builder,
     PluginServerInterface server, {
     void Function(String)? onPrint,
-  }) {
+  }) async {
     final callback = PluginCallback.default_();
-    final plugin = builder(callback);
-    final instance = RustSetonixPlugin._(server, plugin);
     if (onPrint != null) {
       callback.changeOnPrint(onPrint: onPrint);
     }
@@ -195,13 +196,17 @@ final class RustSetonixPlugin extends SetonixPlugin {
         final state = server.state;
         return switch (field) {
           StateFieldAccess.info => state.info.toJson(),
-          StateFieldAccess.table => state.table.toJson(),
+          StateFieldAccess.tables => jsonEncode(
+            state.data.getTables().toList(),
+          ),
           StateFieldAccess.tableName => jsonEncode(state.tableName),
           StateFieldAccess.players => jsonEncode(server.players),
           StateFieldAccess.teamMembers => jsonEncode(state.teamMembers),
         };
       },
     );
+    final plugin = builder(callback);
+    final instance = RustSetonixPlugin._(server, plugin);
     instance.eventSystem.on<WorldEvent>((e) {
       instance.plugin.runEvent(
         eventType: e.clientEvent.runtimeType.toString(),
@@ -211,6 +216,7 @@ final class RustSetonixPlugin extends SetonixPlugin {
         source: e.source,
       );
     });
+    await instance.plugin.run();
     return instance;
   }
 

plugin/lib/src/events/model.dart

@@ -27,6 +27,10 @@ abstract class PluginCallback implements RustOpaqueInterface {
     required FutureOr<String> Function(StateFieldAccess) stateFieldAccess,
   });
 
+  void changeTableAccess({
+    required FutureOr<String> Function(String?) tableAccess,
+  });
+
   static PluginCallback default_() =>
       RustLib.instance.api.crateApiPluginPluginCallbackDefault();
 }
@@ -64,4 +68,4 @@ class EventResult {
           needsUpdate == other.needsUpdate;
 }
 
-enum StateFieldAccess { table, tableName, info, players, teamMembers }
+enum StateFieldAccess { tableName, tables, info, players, teamMembers }