code: func pubsubPushHandler(c *router.Context) {
  	rc := requestContext(*c)
  	body, err := ioutil.ReadAll(rc.Request.Body)
  	if err != nil {
  		rc.fail(500, "Failed to read the request: %s", err)
  		return
  	}
  	if err = globalEngine.ProcessPubSubPush(rc.Context, body); err != nil {
  		rc.err(err, "Failed to process incoming PubSub push")
  		return
  	}
  	rc.ok()
  }
docs: // pubsubPushHandler handles incoming PubSub messages.