improved sdnpublisher schema

internal/schema/marte.cue

@@ -65,8 +65,8 @@ package schema
 		...
 	}
 	FileDataSource: {
-		Filename:       string
+		Filename: string
-		Format?:        string
+		Format?:  string
 		#meta: multithreaded: bool | *false
 		#meta: direction:     "INOUT"
 		...
@@ -77,7 +77,7 @@ package schema
 		...
 	}
 	DANStream: {
-		Timeout?:       int
+		Timeout?: int
 		#meta: multithreaded: bool | *false
 		#meta: direction:     "OUT"
 		...
@@ -103,38 +103,43 @@ package schema
 		...
 	}
 	SDNSubscriber: {
-		Address:        string
+		ExecutionMode?:      *"IndependentThread" | "RealTimeThread"
-		Port:           int
+		Topic!:              string
-		Interface?:     string
+		Address?:            string
+		Interface!:          string
+		CPUs?:               uint32
+		InternalTimeout?:    uint32
+		Timeout?:            uint32
+		IgnoreTimeoutError?: 0 | 1
 		#meta: multithreaded: bool | *false
 		#meta: direction:     "IN"
 		...
 	}
 	SDNPublisher: {
-		Address:        string
+		Address:    string
-		Port:           int
+		Port:       int
-		Interface?:     string
+		Interface?: string
 		#meta: multithreaded: bool | *false
 		#meta: direction:     "OUT"
 		...
 	}
 	UDPReceiver: {
-		Port:           int
+		Port:     int
-		Address?:       string
+		Address?: string
 		#meta: multithreaded: bool | *false
 		#meta: direction:     "IN"
 		...
 	}
 	UDPSender: {
-		Destination:    string
+		Destination: string
 		#meta: multithreaded: bool | *false
 		#meta: direction:     "OUT"
 		...
 	}
 	FileReader: {
-		Filename:       string
+		Filename:     string
-		Format?:        string
+		Format?:      string
-		Interpolate?:   string
+		Interpolate?: string
 		#meta: multithreaded: bool | *false
 		#meta: direction:     "IN"
 		...
@@ -143,8 +148,8 @@ package schema
 		Filename:        string
 		Format?:         string
 		StoreOnTrigger?: int
-		#meta: multithreaded:  bool | *false
+		#meta: multithreaded: bool | *false
-		#meta: direction:      "OUT"
+		#meta: direction:     "OUT"
 		...
 	}
 	OrderedClass: {

test/validator_extra_test.go

@@ -15,7 +15,7 @@ func TestSDNSubscriberValidation(t *testing.T) {
 +MySDN = {
     Class = SDNSubscriber
     Address = "239.0.0.1"
-    // Missing Port
+    // Missing Interface
 }
 `
 	p := parser.NewParser(content)
@@ -32,7 +32,7 @@ func TestSDNSubscriberValidation(t *testing.T) {
 
 	found := false
 	for _, d := range v.Diagnostics {
-		if strings.Contains(d.Message, "Port: incomplete value") {
+		if strings.Contains(d.Message, "Interface: field is required but not present") {
 			found = true
 			break
 		}