Fixed bugs & enhancement

Author: vim89

flowforge.g8/src/main/g8/README.md

@@ -9,7 +9,7 @@ Generated from flowforge template with **F-polymorphic effects** and **compile-t
 sbt compile
 
 # 2. Run the complete pipeline
-sbt "runMain $organization$;format="word"$.UsersPipelineApp"
+sbt "runMain $organization$;format=\"word\".UsersPipelineApp"
 ```
 
 **Expected Output:**
@@ -225,7 +225,7 @@ val s3Sink = TypedSink[EnrichedUser](
 // Add domain-specific quality checks
 .addTransform[CleanedUser] { user =>
   if (isValidBusinessUser(user)) F.pure(user)
-  else F.raiseError(new ValidationException(s"Business rule violation: \$user"))
+  else F.raiseError(new ValidationException(s"Business rule violation:" + user))
 }
 ```
 

flowforge.g8/src/main/g8/src/main/scala/$organization$/Pipeline.scala

@@ -104,7 +104,7 @@ class FlowForgePipeline[F[_]: EffectSystem] {
     val lineageEmitter = $if(include_lineage.truthy)$OpenLineageEmitter.noop[F]$else$OpenLineageEmitter.noop[F]$endif$
 
     F.delay {
-      PipelineBuilder[F]("$name;format="kebab"$-comprehensive-pipeline")
+      PipelineBuilder[F]("$name$")
         .withDescription("Complete CSV→Parquet→Delta pipeline with contracts & quality")
         .withLineageEmitter(lineageEmitter)
         .addTypedSource[RawUser, RawUser, SchemaPolicy.Exact](
@@ -201,7 +201,7 @@ class FlowForgePipeline[F[_]: EffectSystem] {
   def runPipeline(): F[Unit] = {
     val sparkConfig = Map(
       "spark.master" -> "local[*]",
-      "spark.app.name" -> "FlowForge-$name;format="Camel"$",
+      "spark.app.name" -> "FlowForge-$name$",
       "spark.sql.extensions" -> "io.delta.sql.DeltaSparkSessionExtension",
       "spark.sql.catalog.spark_catalog" -> "org.apache.spark.sql.delta.catalog.DeltaCatalog",
       "spark.serializer" -> "org.apache.spark.serializer.KryoSerializer"
@@ -263,7 +263,7 @@ object PipelineApp extends cats.effect.IOApp.Simple {
     val rawUser = SimpleRawUser(1L, "Alice Johnson", "alice@example.com", Some(28), "USA", true)
 
     val pipeline = FlowForgePipeline[IO, SimpleRawUser, SimpleCleanedUser](
-      name = "$name;format=\"kebab\"$-direct-pipeline",
+      name = "$name$",
       source = DataSource.local("input.csv", DataFormat.CSV),
       sink = DataSink.local("output.parquet", DataFormat.Parquet),
       transformation = Kleisli[IO, SimpleRawUser, SimpleCleanedUser](raw => IO.pure(sampleTransformation(raw))),

modules/contracts/src/main/scala/com/flowforge/contracts/syntax/ContractDSL.scala

@@ -57,7 +57,7 @@ case class ContractBuilder(name: String) {
 
   def build: ContractSchema = {
     versionOpt.getOrElse(ContractVersion(1, 0, 0))
-    val finalMetadata = metadata ++ 
+    val finalMetadata = metadata ++
       slaOpt.map("sla" -> _) ++
       ownerOpt.map("owner" -> _)
 
@@ -75,7 +75,8 @@ case class ContractBuilder(name: String) {
  */
 case class FieldBuilder(name: String, parent: ContractBuilder) {
   private var fieldType: Option[FieldType] = None
-  
+
+  private var isRequired: Boolean = false
   private var isOptional: Boolean = false
   private var constraints: List[FieldConstraint] = List.empty
   private var descriptionOpt: Option[String] = None
@@ -123,7 +124,7 @@ case class FieldBuilder(name: String, parent: ContractBuilder) {
  * Typed Field Builder that provides type-specific methods
  */
 case class TypedFieldBuilder(fieldBuilder: FieldBuilder) {
-  
+
   // Basic types
   def string: StringFieldBuilder = {
     fieldBuilder.setFieldType(FieldType.StringType)
@@ -170,7 +171,7 @@ case class TypedFieldBuilder(fieldBuilder: FieldBuilder) {
  * String-specific field builder with string constraints
  */
 class StringFieldBuilder(fieldBuilder: FieldBuilder) extends FieldTerminator(fieldBuilder) {
-  
+
   def minLength(length: Int): StringFieldBuilder = {
     fieldBuilder.addConstraint(FieldConstraint.MinLength(length))
     this
@@ -219,7 +220,7 @@ class StringFieldBuilder(fieldBuilder: FieldBuilder) extends FieldTerminator(fie
  * Numeric field builder with numeric constraints
  */
 class NumericFieldBuilder[T](fieldBuilder: FieldBuilder) extends FieldTerminator(fieldBuilder) {
-  
+
   def min(minValue: Double): NumericFieldBuilder[T] = {
     fieldBuilder.addConstraint(FieldConstraint.Range(minValue, Double.MaxValue))
     this
@@ -250,7 +251,7 @@ class NumericFieldBuilder[T](fieldBuilder: FieldBuilder) extends FieldTerminator
  * Field terminator that allows returning to contract building
  */
 case class FieldTerminator(fieldBuilder: FieldBuilder) {
-  
+
   def field(name: String): FieldBuilder = {
     fieldBuilder.parent.field(name)
   }
@@ -281,7 +282,7 @@ case class FieldTerminator(fieldBuilder: FieldBuilder) {
  * DSL entry points and syntax extensions
  */
 object ContractDSL {
-  
+
   /**
    * Create a new contract with the given name
    */
@@ -304,11 +305,11 @@ object ContractDSL {
    * Example usage demonstrations
    */
   object Examples {
-    
+
     /**
      * User contract with comprehensive field definitions
      */
-    def userContract: ContractSchema = 
+    def userContract: ContractSchema =
       Contract("user")
         .field("id").required.long.positive
         .field("email").required.string.email.maxLength(255)
@@ -360,32 +361,32 @@ object ContractDSL {
  * Implicit conversions for seamless integration
  */
 object ContractSyntax {
-  
+
   implicit class ContractOps(contract: ContractSchema) {
     def toDataContract[A]: DataContract[A] = {
       new DataContract[A] {
         def validate(data: A): cats.data.ValidatedNel[ContractViolation, A] = {
           // Basic validation - in practice this would introspect the data structure
           data.validNel
         }
-        
+
         def schema: ContractSchema = contract
         def version: ContractVersion = ContractVersion(1, 0, 0)
-        def rules: NonEmptyList[ValidationRule[A]] = 
+        def rules: NonEmptyList[ValidationRule[A]] =
           NonEmptyList.one(ValidationRules.custom[A]("schema_valid")(_ => ().validNel))
       }
     }
   }
-  
+
   implicit class StringFieldOps(name: String) {
     def requiredString: StringFieldBuilder = {
       val builder = ContractBuilder(name).field(name)
       builder.required.string
     }
-    
+
     def optionalString: StringFieldBuilder = {
-      val builder = ContractBuilder(name).field(name) 
+      val builder = ContractBuilder(name).field(name)
       builder.optional.string
     }
   }
-}
+}