1 files changed, 20 insertions, 0 deletions
diff --git a/model/pipeline/impl.ts b/model/pipeline/impl.ts
new file mode 100644
index 0000000..2e08d6e
--- /dev/null
+++ b/model/pipeline/impl.ts
@@ -0,0 +1,20 @@
+import { Either, IEither } from '@emprespresso/pengueno';
+import { isPipeline, Pipeline, PipelineStage } from '.';
+
+export class PipelineImpl implements Pipeline {
+    constructor(public readonly serialJobs: Array<PipelineStage>) {}
+
+    public serialize() {
+        return JSON.stringify(this.serialJobs);
+    }
+
+    public static from(s: string): IEither<Error, Pipeline> {
+        return Either.fromFailable<Error, unknown>(() => JSON.parse(s))
+            .flatMap<Pipeline>((eitherPipelineJson) =>
+                isPipeline(eitherPipelineJson)
+                    ? Either.right(eitherPipelineJson)
+                    : Either.left(new Error('oh noes D: its a bad pipewine :((')),
+            )
+            .mapRight((pipeline) => new PipelineImpl(pipeline.serialJobs));
+    }
+}