waku-org/go-waku

package pb

import "errors"

// This special value for requestId indicates that the message was rate limited
// and we did not retreive the requestId to avoid a potential attack vector.
const REQUESTID_RATE_LIMITED = "N/A"

var (
    errMissingRequestID   = errors.New("missing RequestId field")
    errMissingQuery       = errors.New("missing Query field")
    errMissingMessage     = errors.New("missing Message field")
    errMissingPubsubTopic = errors.New("missing PubsubTopic field")
    errRequestIDMismatch  = errors.New("requestID in response does not match request")
    errMissingResponse    = errors.New("missing Response field")
)

func (x *PushRpc) ValidateRequest() error {
    if x.RequestId == "" {
        return errMissingRequestID
    }

    if x.Request == nil {
        return errMissingQuery
    }

    if x.Request.PubsubTopic == "" {
        return errMissingPubsubTopic
    }

    if x.Request.Message == nil {
        return errMissingMessage
    }

    return x.Request.Message.Validate()
}

func (x *PushRpc) ValidateResponse(requestID string) error {
    if x.RequestId == REQUESTID_RATE_LIMITED {
        return nil
    }
    if x.RequestId == "" {
        return errMissingRequestID
    }

    if x.RequestId != requestID {
        return errRequestIDMismatch
    }

    if x.Response == nil {
        return errMissingResponse
    }

    return nil
}