mirror of
https://github.com/matrix-org/dendrite.git
synced 2025-03-23 01:54:28 -05:00
'verify' the access token
This commit is contained in:
parent
3cd0a94963
commit
17cc782aff
|
@ -3,13 +3,22 @@ package readers
|
||||||
import (
|
import (
|
||||||
"net/http"
|
"net/http"
|
||||||
|
|
||||||
|
"github.com/matrix-org/dendrite/clientapi/auth"
|
||||||
"github.com/matrix-org/util"
|
"github.com/matrix-org/util"
|
||||||
)
|
)
|
||||||
|
|
||||||
// Sync implements /sync
|
// Sync implements /sync
|
||||||
func Sync(req *http.Request) (interface{}, *util.HTTPError) {
|
func Sync(req *http.Request) (interface{}, *util.HTTPError) {
|
||||||
logger := util.GetLogger(req.Context())
|
logger := util.GetLogger(req.Context())
|
||||||
logger.Info("Doing stuff...")
|
userID, err := auth.VerifyAccessToken(req)
|
||||||
|
if err != nil {
|
||||||
|
return nil, &util.HTTPError{
|
||||||
|
Code: 403,
|
||||||
|
JSON: err,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
logger.WithField("userID", userID).Info("Doing stuff...")
|
||||||
return nil, &util.HTTPError{
|
return nil, &util.HTTPError{
|
||||||
Code: 404,
|
Code: 404,
|
||||||
Message: "Not implemented yet",
|
Message: "Not implemented yet",
|
||||||
|
|
|
@ -3,13 +3,26 @@ package writers
|
||||||
import (
|
import (
|
||||||
"net/http"
|
"net/http"
|
||||||
|
|
||||||
|
log "github.com/Sirupsen/logrus"
|
||||||
|
"github.com/matrix-org/dendrite/clientapi/auth"
|
||||||
"github.com/matrix-org/util"
|
"github.com/matrix-org/util"
|
||||||
)
|
)
|
||||||
|
|
||||||
// SendMessage implements /rooms/{roomID}/send/{eventType}
|
// SendMessage implements /rooms/{roomID}/send/{eventType}
|
||||||
func SendMessage(req *http.Request, roomID, eventType string) (interface{}, *util.HTTPError) {
|
func SendMessage(req *http.Request, roomID, eventType string) (interface{}, *util.HTTPError) {
|
||||||
logger := util.GetLogger(req.Context())
|
logger := util.GetLogger(req.Context())
|
||||||
logger.WithField("roomID", roomID).WithField("eventType", eventType).Info("Doing stuff...")
|
userID, err := auth.VerifyAccessToken(req)
|
||||||
|
if err != nil {
|
||||||
|
return nil, &util.HTTPError{
|
||||||
|
Code: 403,
|
||||||
|
JSON: err,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
logger.WithFields(log.Fields{
|
||||||
|
"roomID": roomID,
|
||||||
|
"eventType": eventType,
|
||||||
|
"userID": userID,
|
||||||
|
}).Info("Doing stuff...")
|
||||||
return nil, &util.HTTPError{
|
return nil, &util.HTTPError{
|
||||||
Code: 404,
|
Code: 404,
|
||||||
Message: "Not implemented yet",
|
Message: "Not implemented yet",
|
||||||
|
|
Loading…
Reference in a new issue