Method addQueryTracker

sqlchain/observer/service.go:265–293

(dbID proto.DatabaseID, height int32, offset int32, qt *types.QueryAsTx)

}

func (s *Service) addQueryTracker(dbID proto.DatabaseID, height int32, offset int32, qt *types.QueryAsTx) (err error) {
	log.WithFields(log.Fields{
		"req":  qt.Request.Header.Hash(),
		"resp": qt.Response.Hash(),
	}).Debug("add query tracker")

	if atomic.LoadInt32(&s.stopped) == 1 {
		// stopped
		return ErrStopped
	}

	if err = qt.Request.Verify(); err != nil {
		return
	}
	if err = qt.Response.VerifyHash(); err != nil {
		return
	}

	_, err = s.db.Writer().Exec(saveRequestSQL, string(dbID), qt.Request.Header.Hash().String(), height, offset)
	if err != nil {
		err = errors.Wrapf(err, "save request failed: %s, %s, %d", dbID, qt.Request.Header.Hash().String(), height)
		return
	}
	_, err = s.db.Writer().Exec(saveResponseSQL, string(dbID), qt.Response.Hash().String(), height, offset)
	if err != nil {
		err = errors.Wrapf(err, "save response failed: %s, %s, %d", dbID, qt.Response.Hash().String(), height)
	}
	return
}

func (s *Service) addBlock(dbID proto.DatabaseID, count int32, b *types.Block) (err error) {
	instance, err := s.getUpstream(dbID)