(t pi.Transaction)
| 192 | } |
| 193 | |
| 194 | func addTx(t pi.Transaction) storageProcedure { |
| 195 | var ( |
| 196 | enc *bytes.Buffer |
| 197 | err error |
| 198 | ) |
| 199 | if enc, err = utils.EncodeMsgPack(t); err != nil { |
| 200 | return errPass(err) |
| 201 | } |
| 202 | return func(tx *sql.Tx) (err error) { |
| 203 | _, err = tx.Exec(`INSERT OR REPLACE INTO "txPool" ("type", "hash", "encoded") |
| 204 | VALUES (?, ?, ?)`, |
| 205 | uint32(t.GetTransactionType()), |
| 206 | t.Hash().String(), |
| 207 | enc.Bytes()) |
| 208 | return err |
| 209 | } |
| 210 | } |
| 211 | |
| 212 | func buildBlockIndex(height uint32, b *types.BPBlock) storageProcedure { |
| 213 | return func(tx *sql.Tx) (err error) { |
no test coverage detected