Fix errors with new record_unknown_job_error endpoint

internal/model/update.go

@@ -60,6 +60,11 @@ type RecordUpdateJobError struct {
 	ErrorDetails map[string]any `json:"error-details" yaml:"error-details"`
 }
 
+type RecordUpdateJobUnknownError struct {
+	ErrorType    string         `json:"error-type" yaml:"error-type"`
+	ErrorDetails map[string]any `json:"error-details" yaml:"error-details"`
+}
+
 type IncrementMetric struct {
 	Metric string         `json:"metric" yaml:"metric"`
 	Tags   map[string]any `json:"tags" yaml:"tags"`

internal/server/api.go

@@ -233,6 +233,8 @@ func decodeWrapper(kind string, data []byte) (actual *model.UpdateWrapper, err e
 		actual.Data, err = decode[model.RecordEcosystemVersions](data)
 	case "record_update_job_error":
 		actual.Data, err = decode[model.RecordUpdateJobError](data)
+	case "record_update_job_unknown_error":
+		actual.Data, err = decode[model.RecordUpdateJobUnknownError](data)
 	case "increment_metric":
 		actual.Data, err = decode[model.IncrementMetric](data)
 	default:
@@ -285,6 +287,8 @@ func compare(expect, actual *model.UpdateWrapper) error {
 		return compareMarkAsProcessed(v, actual.Data.(model.MarkAsProcessed))
 	case model.RecordUpdateJobError:
 		return compareRecordUpdateJobError(v, actual.Data.(model.RecordUpdateJobError))
+	case model.RecordUpdateJobUnknownError:
+		return compareRecordUpdateJobUnknownError(v, actual.Data.(model.RecordUpdateJobUnknownError))
 	default:
 		return fmt.Errorf("unexpected type: %s", reflect.TypeOf(v))
 	}
@@ -342,3 +346,10 @@ func compareRecordUpdateJobError(expect, actual model.RecordUpdateJobError) erro
 	}
 	return unexpectedBody("record_update_job_error")
 }
+
+func compareRecordUpdateJobUnknownError(expect, actual model.RecordUpdateJobUnknownError) error {
+	if reflect.DeepEqual(expect, actual) {
+		return nil
+	}
+	return unexpectedBody("record_update_job_unknown_error")
+}