fix(orchestrator): CollectionResult returns error on bad rawJSON

examples/sdk/orchestrator/features/basic.go

@@ -98,7 +98,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 	hostname.DependsOn(health)

examples/sdk/orchestrator/features/broadcast.go

@@ -88,7 +88,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/features/container-targeting.go

@@ -129,7 +129,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 	pull.DependsOn(preCleanup)
@@ -160,7 +160,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 	create.DependsOn(pull)
@@ -187,7 +187,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 	execHostname.DependsOn(create)
@@ -212,7 +212,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 	execUname.DependsOn(create)
@@ -239,7 +239,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 	execOS.DependsOn(create)
@@ -264,7 +264,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 	inspect.DependsOn(create)
@@ -304,7 +304,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	).DependsOn(execHostname, execUname, execOS, inspect)
 

examples/sdk/orchestrator/features/error-strategy.go

@@ -100,7 +100,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/features/guards.go

@@ -99,7 +99,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 	getHostname.DependsOn(health)

examples/sdk/orchestrator/features/hooks.go

@@ -141,7 +141,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 	hostname.DependsOn(health)
@@ -165,7 +165,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 	disk.DependsOn(health)

examples/sdk/orchestrator/features/only-if-changed.go

@@ -83,7 +83,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/features/parallel.go

@@ -113,7 +113,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 	hostnameTask.DependsOn(health)
@@ -137,7 +137,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 	diskTask.DependsOn(health)
@@ -161,7 +161,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 	memoryTask.DependsOn(health)

examples/sdk/orchestrator/features/result-decode.go

@@ -73,7 +73,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/features/task-func-results.go

@@ -96,7 +96,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 	getHostname.DependsOn(health)

examples/sdk/orchestrator/features/task-func.go

@@ -96,7 +96,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 	hostname.DependsOn(health)

examples/sdk/orchestrator/operations/command-exec.go

@@ -79,7 +79,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/operations/command-shell.go

@@ -79,7 +79,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/operations/docker-create.go

@@ -78,7 +78,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/operations/docker-exec.go

@@ -78,7 +78,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/operations/docker-inspect.go

@@ -76,7 +76,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/operations/docker-list.go

@@ -76,7 +76,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/operations/docker-pull.go

@@ -78,7 +78,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/operations/docker-remove.go

@@ -76,7 +76,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/operations/docker-start.go

@@ -76,7 +76,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/operations/docker-stop.go

@@ -78,7 +78,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/operations/network-dns-get.go

@@ -76,7 +76,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/operations/network-dns-update.go

@@ -79,7 +79,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/operations/network-ping.go

@@ -76,7 +76,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/operations/node-disk.go

@@ -76,7 +76,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/operations/node-hostname.go

@@ -76,7 +76,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/operations/node-load.go

@@ -76,7 +76,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/operations/node-memory.go

@@ -76,7 +76,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/operations/node-status.go

@@ -76,7 +76,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

examples/sdk/orchestrator/operations/node-uptime.go

@@ -76,7 +76,7 @@ func main() {
 						Error:    r.Error,
 					}
 				},
-			), nil
+			)
 		},
 	)
 

pkg/sdk/orchestrator/bridge.go

@@ -2,6 +2,7 @@ package orchestrator
 
 import (
 	"encoding/json"
+	"fmt"
 
 	client "github.com/retr0h/osapi/pkg/sdk/client"
 )
@@ -44,7 +45,7 @@ func CollectionResult[T any](
 	col client.Collection[T],
 	rawJSON []byte,
 	toHostResult func(T) HostResult,
-) *Result {
+) (*Result, error) {
 	hostResults := make([]HostResult, 0, len(col.Results))
 	changed := false
 
@@ -64,13 +65,15 @@ func CollectionResult[T any](
 
 	var data map[string]any
 	if len(rawJSON) > 0 {
-		_ = jsonUnmarshalFn(rawJSON, &data)
+		if err := jsonUnmarshalFn(rawJSON, &data); err != nil {
+			return nil, fmt.Errorf("unmarshal response data: %w", err)
+		}
 	}
 
 	return &Result{
 		JobID:       col.JobID,
 		Changed:     changed,
 		Data:        data,
 		HostResults: hostResults,
-	}
+	}, nil
 }