(ctx context.Context, id string, updateFn func(T) error)
| 329 | } |
| 330 | |
| 331 | func DBUpdateFnErr[T waveobj.WaveObj](ctx context.Context, id string, updateFn func(T) error) error { |
| 332 | return WithTx(ctx, func(tx *TxWrap) error { |
| 333 | val, err := DBMustGet[T](tx.Context(), id) |
| 334 | if err != nil { |
| 335 | return err |
| 336 | } |
| 337 | err = updateFn(val) |
| 338 | if err != nil { |
| 339 | return err |
| 340 | } |
| 341 | return DBUpdate(tx.Context(), val) |
| 342 | }) |
| 343 | } |
| 344 | |
| 345 | func DBInsert(ctx context.Context, val waveobj.WaveObj) error { |
| 346 | oid := waveobj.GetOID(val) |
no test coverage detected