"github.com/matrix-org/dendrite/clientapi/auth/authtypes"

"github.com/matrix-org/dendrite/federationapi"

"github.com/matrix-org/dendrite/roomserver"

"github.com/matrix-org/dendrite/roomserver/api"

"github.com/matrix-org/dendrite/setup/config"

rsAPI := roomserver.NewInternalAPI(base)

// Needed for changing the password/login

// We mostly need the userAPI for this test, so nil for other APIs/caches etc.

// Create the users in the userapi and login

accessTokens := map[*test.User]string{

fedClient := base.CreateFederationClient()

rsAPI := roomserver.NewInternalAPI(base)

// this starts the JetStream consumers

federationapi.NewInternalAPI(base, fedClient, rsAPI, base.Caches, nil, true)

rsAPI.SetFederationAPI(nil, nil)

// Create the room

if err := api.SendEvents(ctx, rsAPI, api.KindNew, room.Events(), "test", "test", "test", nil, false); err != nil {

}

// We mostly need the rsAPI for this test, so nil for other APIs/caches etc.

// Create the users in the userapi and login

accessTokens := map[*test.User]string{

package clientapi

import (

"github.com/matrix-org/gomatrixserverlib"

appserviceAPI "github.com/matrix-org/dendrite/appservice/api"

"github.com/matrix-org/dendrite/clientapi/routing"

federationAPI "github.com/matrix-org/dendrite/federationapi/api"

"github.com/matrix-org/dendrite/internal/transactions"

roomserverAPI "github.com/matrix-org/dendrite/roomserver/api"

"github.com/matrix-org/dendrite/setup/base"

"github.com/matrix-org/dendrite/setup/jetstream"

)

// AddPublicRoutes sets up and registers HTTP handlers for the ClientAPI component.

fsAPI federationAPI.ClientFederationAPI,

userAPI userapi.ClientUserAPI,

userDirectoryProvider userapi.QuerySearchProfilesAPI,

extRoomsProvider api.ExtraPublicRoomsProvider,

) {

cfg := &base.Cfg.ClientAPI

base,

cfg, rsAPI, asAPI,

userAPI, userDirectoryProvider, federation,

extRoomsProvider, mscCfg, natsClient,

)

}

"github.com/matrix-org/dendrite/clientapi/jsonerror"

"github.com/matrix-org/dendrite/internal/httputil"

roomserverAPI "github.com/matrix-org/dendrite/roomserver/api"

"github.com/matrix-org/dendrite/setup/config"

"github.com/matrix-org/dendrite/setup/jetstream"

)

vars, err := httputil.URLDecodeMapValues(mux.Vars(req))

if err != nil {

return util.ErrorResponse(err)

}

}

vars, err := httputil.URLDecodeMapValues(mux.Vars(req))

if err != nil {

return util.ErrorResponse(err)

}

}

vars, err := httputil.URLDecodeMapValues(mux.Vars(req))

if err != nil {

return util.ErrorResponse(err)

}

}

if req.Body == nil {

return util.JSONResponse{

Code: http.StatusBadRequest,

JSON: jsonerror.InvalidArgumentValue(err.Error()),

}

}

Localpart: localpart,

ServerName: serverName,

}, accAvailableResp); err != nil {

return *internal.PasswordResponse(err)

}

Localpart: localpart,

ServerName: serverName,

Password: request.Password,

LogoutDevices: true,

}

if err := userAPI.PerformPasswordUpdate(req.Context(), updateReq, updateRes); err != nil {

return util.JSONResponse{

Code: http.StatusBadRequest,

}

}

_, err := natsClient.RequestMsg(nats.NewMsg(cfg.Matrix.JetStream.Prefixed(jetstream.InputFulltextReindex)), time.Second*10)

if err != nil {

logrus.WithError(err).Error("failed to publish nats message")

}

}

vars, err := httputil.URLDecodeMapValues(mux.Vars(req))

if err != nil {

return util.ErrorResponse(err)

"github.com/matrix-org/gomatrixserverlib"

"github.com/matrix-org/dendrite/appservice"

"github.com/matrix-org/dendrite/roomserver"

"github.com/matrix-org/dendrite/test"

"github.com/matrix-org/dendrite/test/testrig"

defer baseClose()

rsAPI := roomserver.NewInternalAPI(base)

asAPI := appservice.NewInternalAPI(base, userAPI, rsAPI)

rsAPI.SetFederationAPI(nil, nil) // creates the rs.Inputer etc

"github.com/matrix-org/dendrite/clientapi/auth/authtypes"

"github.com/matrix-org/dendrite/clientapi/httputil"

"github.com/matrix-org/dendrite/clientapi/jsonerror"

"github.com/matrix-org/dendrite/setup/config"

"github.com/matrix-org/util"

)

func UploadCrossSigningDeviceKeys(

req *http.Request, userInteractiveAuth *auth.UserInteractive,

) util.JSONResponse {

uploadReq := &crossSigningRequest{}

uploadRes := &api.PerformUploadDeviceKeysResponse{}

}

}

uploadReq := &api.PerformUploadDeviceSignaturesRequest{}

uploadRes := &api.PerformUploadDeviceSignaturesResponse{}

"github.com/matrix-org/dendrite/clientapi/httputil"

"github.com/matrix-org/dendrite/clientapi/jsonerror"

)

type uploadKeysRequest struct {

OneTimeKeys map[string]json.RawMessage `json:"one_time_keys"`

}

var r uploadKeysRequest

resErr := httputil.UnmarshalJSONRequest(req, &r)

if resErr != nil {

return timeout

}

var r queryKeysRequest

resErr := httputil.UnmarshalJSONRequest(req, &r)

if resErr != nil {

"testing"

"github.com/matrix-org/dendrite/clientapi/auth/authtypes"

"github.com/matrix-org/dendrite/roomserver"

"github.com/matrix-org/dendrite/setup/config"

"github.com/matrix-org/gomatrixserverlib"

rsAPI := roomserver.NewInternalAPI(base)

// Needed for /login

// We mostly need the userAPI for this test, so nil for other APIs/caches etc.

// Create password

password := util.RandomString(8)

"github.com/matrix-org/dendrite/clientapi/auth/authtypes"

"github.com/matrix-org/dendrite/clientapi/jsonerror"

"github.com/matrix-org/dendrite/internal"

"github.com/matrix-org/dendrite/roomserver"

"github.com/matrix-org/dendrite/setup/config"

"github.com/matrix-org/dendrite/test"

defer baseClose()

rsAPI := roomserver.NewInternalAPI(base)

for _, tc := range testCases {

t.Run(tc.name, func(t *testing.T) {

base.Cfg.Global.ServerName = "server"

rsAPI := roomserver.NewInternalAPI(base)

deviceName, deviceID := "deviceName", "deviceID"

expectedDisplayName := "DisplayName"

response := completeRegistration(

base.Cfg.ClientAPI.RegistrationSharedSecret = sharedSecret

rsAPI := roomserver.NewInternalAPI(base)

expectedDisplayName := "rabbit"

jsonStr := []byte(`{"admin":true,"mac":"24dca3bba410e43fe64b9b5c28306693bf3baa9f","nonce":"759f047f312b99ff428b21d581256f8592b8976e58bc1b543972dc6147e529a79657605b52d7becd160ff5137f3de11975684319187e06901955f79e5a6c5a79","password":"wonderland","username":"alice","displayname":"rabbit"}`)

"github.com/gorilla/mux"

"github.com/matrix-org/dendrite/setup/base"

"github.com/matrix-org/gomatrixserverlib"

"github.com/matrix-org/util"

"github.com/nats-io/nats.go"

federationAPI "github.com/matrix-org/dendrite/federationapi/api"

"github.com/matrix-org/dendrite/internal/httputil"

"github.com/matrix-org/dendrite/internal/transactions"

roomserverAPI "github.com/matrix-org/dendrite/roomserver/api"

"github.com/matrix-org/dendrite/setup/config"

"github.com/matrix-org/dendrite/setup/jetstream"

)

// Setup registers HTTP handlers with the given ServeMux. It also supplies the given http.Client

syncProducer *producers.SyncAPIProducer,

transactionsCache *transactions.Cache,

federationSender federationAPI.ClientFederationAPI,

extRoomsProvider api.ExtraPublicRoomsProvider,

mscCfg *config.MSCs, natsClient *nats.Conn,

) {

dendriteAdminRouter.Handle("/admin/refreshDevices/{userID}",

httputil.MakeAdminAPI("admin_refresh_devices", userAPI, func(req *http.Request, device *userapi.Device) util.JSONResponse {

}),

).Methods(http.MethodPost, http.MethodOptions)

// Cross-signing device keys

postDeviceSigningKeys := httputil.MakeAuthAPI("post_device_signing_keys", userAPI, func(req *http.Request, device *userapi.Device) util.JSONResponse {

})

postDeviceSigningSignatures := httputil.MakeAuthAPI("post_device_signing_signatures", userAPI, func(req *http.Request, device *userapi.Device) util.JSONResponse {

}, httputil.WithAllowGuests())

v3mux.Handle("/keys/device_signing/upload", postDeviceSigningKeys).Methods(http.MethodPost, http.MethodOptions)

// Supplying a device ID is deprecated.

v3mux.Handle("/keys/upload/{deviceID}",

httputil.MakeAuthAPI("keys_upload", userAPI, func(req *http.Request, device *userapi.Device) util.JSONResponse {

}, httputil.WithAllowGuests()),

).Methods(http.MethodPost, http.MethodOptions)

v3mux.Handle("/keys/upload",

httputil.MakeAuthAPI("keys_upload", userAPI, func(req *http.Request, device *userapi.Device) util.JSONResponse {

}, httputil.WithAllowGuests()),

).Methods(http.MethodPost, http.MethodOptions)

v3mux.Handle("/keys/query",

httputil.MakeAuthAPI("keys_query", userAPI, func(req *http.Request, device *userapi.Device) util.JSONResponse {

}, httputil.WithAllowGuests()),

).Methods(http.MethodPost, http.MethodOptions)

v3mux.Handle("/keys/claim",

httputil.MakeAuthAPI("keys_claim", userAPI, func(req *http.Request, device *userapi.Device) util.JSONResponse {

}, httputil.WithAllowGuests()),

).Methods(http.MethodPost, http.MethodOptions)

v3mux.Handle("/rooms/{roomId}/receipt/{receiptType}/{eventId}",