(height uint32, b *types.BPBlock)
| 173 | } |
| 174 | |
| 175 | func addBlock(height uint32, b *types.BPBlock) storageProcedure { |
| 176 | var ( |
| 177 | enc *bytes.Buffer |
| 178 | err error |
| 179 | ) |
| 180 | if enc, err = utils.EncodeMsgPack(b); err != nil { |
| 181 | return errPass(err) |
| 182 | } |
| 183 | return func(tx *sql.Tx) (err error) { |
| 184 | _, err = tx.Exec(`INSERT OR REPLACE INTO "blocks" ("height", "hash", "parent", "encoded") |
| 185 | VALUES (?, ?, ?, ?)`, |
| 186 | height, |
| 187 | b.BlockHash().String(), |
| 188 | b.ParentHash().String(), |
| 189 | enc.Bytes()) |
| 190 | return |
| 191 | } |
| 192 | } |
| 193 | |
| 194 | func addTx(t pi.Transaction) storageProcedure { |
| 195 | var ( |
no test coverage detected