Method Check

worker/db_storage.go:69–101

Check implements kayak.types.Handler.Check.

(rawReq interface{})

// Check implements kayak.types.Handler.Check.
func (db *Database) Check(rawReq interface{}) (err error) {
	var req *types.Request
	var ok bool
	if req, ok = rawReq.(*types.Request); !ok || req == nil {
		err = errors.Wrap(ErrInvalidRequest, "invalid request payload")
		return
	}

	// verify signature, check time/sequence only
	if err = req.Verify(); err != nil {
		return
	}

	// verify timestamp
	nowTime := getLocalTime()
	minTime := nowTime.Add(-db.cfg.MaxWriteTimeGap)
	maxTime := nowTime.Add(db.cfg.MaxWriteTimeGap)

	if req.Header.Timestamp.Before(minTime) || req.Header.Timestamp.After(maxTime) {
		err = errors.Wrap(ErrInvalidRequest, "invalid request time")
		return
	}

	// verify sequence
	if err = db.verifySequence(req.Header.ConnectionID, req.Header.SeqNo); err != nil {
		return
	}

	// record sequence
	db.recordSequence(req.Header.ConnectionID, req.Header.SeqNo)

	return
}

// TrackerAndResponse defines a query tracker used by xenomint and an unsigned response.
type TrackerAndResponse struct {