first commit

2021-05-26 23:42:34 +01:00
commit 386a8f518a
89 changed files with 3630 additions and 0 deletions
--- a/lib/src/services/local_server.dart
+++ b/lib/src/services/local_server.dart
@@ -0,0 +1,124 @@
+import 'dart:async';
+import 'dart:io';
+
+import 'package:flutter/services.dart';
+import 'package:mime/mime.dart';
+
+/*
+ * credit thanks to https://github.com/shah-xad/flutter_tex/blob/master/lib/src/utils/tex_view_server.dart
+ */
+
+class LocalServer {
+  HttpServer? server;
+  final int port;
+
+  LocalServer(this.port);
+
+  ///Closes the server.
+  Future<void> close() async {
+    if (this.server != null) {
+      await this.server?.close(force: true);
+      this.server = null;
+    }
+  }
+
+  ///Starts the server
+  Future<void> start(Function(HttpRequest request) request) async {
+    if (this.server != null) {
+      throw Exception('Server already started on http://localhost:$port');
+    }
+
+    var completer = new Completer();
+    runZoned(() {
+      HttpServer.bind('localhost', port, shared: true).then((server) {
+        this.server = server;
+
+        server.listen((HttpRequest httpRequest) async {
+          request(httpRequest);
+          var body = <int>[];
+          var path = httpRequest.requestedUri.path;
+          path = (path.startsWith('/')) ? path.substring(1) : path;
+          path += (path.endsWith('/')) ? 'index.html' : '';
+
+          try {
+            body = (await rootBundle.load(path)).buffer.asUint8List();
+          } catch (e) {
+            print(e.toString());
+            httpRequest.response.close();
+            return;
+          }
+
+          var contentType = ['text', 'html'];
+          if (!httpRequest.requestedUri.path.endsWith('/') &&
+              httpRequest.requestedUri.pathSegments.isNotEmpty) {
+            var mimeType = lookupMimeType(httpRequest.requestedUri.path,
+                headerBytes: body);
+            if (mimeType != null) {
+              contentType = mimeType.split('/');
+            }
+          }
+
+          httpRequest.response.headers.contentType =
+              new ContentType(contentType[0], contentType[1], charset: 'utf-8');
+          httpRequest.response.add(body);
+          httpRequest.response.close();
+        });
+        completer.complete();
+      });
+    }, onError: (e, stackTrace) => print('Error: $e $stackTrace'));
+    return completer.future;
+  }
+}
+
+class WebSocketServer {
+  HttpServer? server;
+
+  final int port;
+
+  WebSocketServer(this.port);
+
+  ///Closes the server.
+  Future<void> close() async {
+    if (this.server != null) {
+      await this.server?.close(force: true);
+      this.server = null;
+    }
+  }
+
+  ///Starts the server
+  Future<void> start() async {
+    if (this.server != null) {
+      throw Exception('Server already started on http://localhost:$port');
+    }
+    var completer = new Completer();
+    runZoned(() {
+      HttpServer.bind('localhost', port, shared: true).then(
+          (HttpServer server) {
+        print('[+]WebSocket listening at -- ws://localhost:$port/');
+        this.server = server;
+        server.listen((HttpRequest request) {
+          WebSocketTransformer.upgrade(request).then((WebSocket ws) {
+            ws.listen(
+              (data) {
+                print(
+                    '\t\t${request.connectionInfo?.remoteAddress} -- ${data.toString()}');
+                Timer(Duration(seconds: 1), () {
+                  if (ws.readyState == WebSocket.open)
+                    // checking connection state helps to avoid unprecedented errors
+                    ws.add("dfdfdfdfdfd");
+                });
+              },
+              onDone: () => print('[+]Done :)'),
+              onError: (err) => print('[!]Error -- ${err.toString()}'),
+              cancelOnError: true,
+            );
+            // request.response.close();
+          }, onError: (err) => print('[!]Error -- ${err.toString()}'));
+        }, onError: (err) => print('[!]Error -- ${err.toString()}'));
+        completer.complete();
+      }, onError: (err) => print('[!]Error -- ${err.toString()}'));
+    }, onError: (err) => print('[!]Error -- ${err.toString()}'));
+
+    return completer.future;
+  }
+}