Method getBlock

sqlchain/observer/service.go:641–660

(dbID proto.DatabaseID, h *hash.Hash)

}

func (s *Service) getBlock(dbID proto.DatabaseID, h *hash.Hash) (count int32, height int32, b *types.Block, err error) {
	var blockData []byte
	err = s.db.Writer().QueryRow(getBlockByHashSQL, string(dbID), h.String()).Scan(&height, &count, &blockData)
	if err != nil {
		if errors.Cause(err) == sql.ErrNoRows {
			err = ErrNotFound
			return
		}

		err = errors.Wrapf(err, "query block by hash failed: %s, %s", dbID, h.String())
		return
	}

	err = utils.DecodeMsgPack(blockData, &b)
	if err != nil {
		err = errors.Wrapf(err, "decode block failed: %s", dbID)
	}

	return
}

func (s *Service) getAllSubscriptions() (subscriptions map[proto.DatabaseID]int32, err error) {
	subscriptions = map[proto.DatabaseID]int32{}