(ctx context.Context, principal *models.Principal, repl *additional.ReplicationProperties, incoming *models.Object, existing *models.Object, fetchedClasses map[string]versioned.Class, )
| 186 | } |
| 187 | |
| 188 | func (m *Manager) validateObjectAndNormalizeNames(ctx context.Context, |
| 189 | principal *models.Principal, |
| 190 | repl *additional.ReplicationProperties, |
| 191 | incoming *models.Object, existing *models.Object, fetchedClasses map[string]versioned.Class, |
| 192 | ) error { |
| 193 | err := m.validateUUID(incoming) |
| 194 | if err != nil { |
| 195 | return err |
| 196 | } |
| 197 | |
| 198 | if _, ok := fetchedClasses[incoming.Class]; !ok || fetchedClasses[incoming.Class].Class == nil { |
| 199 | return fmt.Errorf("class %q not found in schema", incoming.Class) |
| 200 | } |
| 201 | class := fetchedClasses[incoming.Class].Class |
| 202 | |
| 203 | return validation.New(m.vectorRepo.Exists, m.config, repl, |
| 204 | principal, m.config.Config.Namespaces.Enabled). |
| 205 | Object(ctx, class, incoming, existing) |
| 206 | } |
| 207 | |
| 208 | func (m *Manager) validateUUID(obj *models.Object) error { |
| 209 | // Validate schema given in body with the weaviate schema |
no test coverage detected