(id proto.DatabaseID)
| 360 | } |
| 361 | |
| 362 | func deleteShardChain(id proto.DatabaseID) storageProcedure { |
| 363 | return func(tx *sql.Tx) (err error) { |
| 364 | log.WithFields(log.Fields{ |
| 365 | "profile_database_id": id, |
| 366 | }).Debug("deleting profile") |
| 367 | _, err = tx.Exec(`DELETE FROM "shardChain" WHERE "id"=?`, id) |
| 368 | if err != nil { |
| 369 | return |
| 370 | } |
| 371 | _, err = tx.Exec(`DELETE FROM "indexed_shardChains" WHERE "id" = ?`, id) |
| 372 | return |
| 373 | } |
| 374 | } |
| 375 | |
| 376 | func updateProvider(profile *types.ProviderProfile) storageProcedure { |
| 377 | var ( |
no test coverage detected