split pieces into modules

1 files changed, 46 insertions, 0 deletions

diff --git a/lib/Ultramarine/Server.pm b/lib/Ultramarine/Server.pm
new file mode 100644
index 0000000..ec7220c
--- /dev/null
+++ b/lib/Ultramarine/Server.pm
@@ -0,0 +1,46 @@
+use v6.d.PREVIEW;
+use Cro::HTTP::Server;
+use Cro::HTTP::Request;
+use Cro::HTTP::Response;
+
+class Ultramarine::Server {
+    has $.authentication is required;
+    has @.serialisers is required;
+    has $.set-content-type is required;
+    has $.controller is required;
+    has $.host = 'localhost';
+    has $.port = 8080;
+    has $.do-trace = False;
+    
+    my class Trace does Cro::Transform {
+        has $.type is required;
+
+        method consumes() { $!type }
+        method produces() { $!type }
+        
+        method transformer(Supply $input --> Supply) {
+            supply whenever $input -> $thing {
+                say $thing.trace-output,"\n";
+                say (await $thing.body-text).indent(2);
+                emit $thing;
+            }
+        }
+    }
+
+    method server() {
+        return Cro::HTTP::Server.new(
+            :$!host,
+            :$!port,
+            application => $!controller,
+            before => [
+                       $.do-trace ?? Trace.new(type=>Cro::HTTP::Request) !! (),
+                       $.authentication,
+                   ],
+            add-body-serializers => @.serialisers,
+            after => [
+                      $.set-content-type,
+                      $.do-trace ?? Trace.new(type=>Cro::HTTP::Response) !! (),
+                  ],
+        );
+    }
+}