aboutsummaryrefslogtreecommitdiff
path: root/userapi
diff options
context:
space:
mode:
authorTill <2353100+S7evinK@users.noreply.github.com>2023-02-14 12:47:47 +0100
committerGitHub <noreply@github.com>2023-02-14 12:47:47 +0100
commit11d9b9db0e96c51c1430d451d23cf5ae9f36e4ee (patch)
treea0837bfa69051295b76140e3940a45fc61854cab /userapi
parentcc59879faa57cac043cf5f1585773b301994bebf (diff)
Remove polylith/API mode (#2967)
This removes most of the code used for polylith/API mode. This removes the `/api` internal endpoints entirely. Binary size change roughly 5%: ``` 51437560 Feb 13 10:15 dendrite-monolith-server # old 48759008 Feb 13 10:15 dendrite-monolith-server # new ```
Diffstat (limited to 'userapi')
-rw-r--r--userapi/api/api_trace.go219
-rw-r--r--userapi/api/api_trace_logintoken.go39
-rw-r--r--userapi/inthttp/client.go454
-rw-r--r--userapi/inthttp/client_logintoken.go61
-rw-r--r--userapi/inthttp/server.go197
-rw-r--r--userapi/inthttp/server_logintoken.go40
-rw-r--r--userapi/userapi.go8
-rw-r--r--userapi/userapi_test.go40
-rw-r--r--userapi/util/phonehomestats.go2
9 files changed, 3 insertions, 1057 deletions
diff --git a/userapi/api/api_trace.go b/userapi/api/api_trace.go
deleted file mode 100644
index d10b5767..00000000
--- a/userapi/api/api_trace.go
+++ /dev/null
@@ -1,219 +0,0 @@
-// Copyright 2021 The Matrix.org Foundation C.I.C.
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-
-package api
-
-import (
- "context"
- "encoding/json"
- "fmt"
-
- "github.com/matrix-org/util"
-)
-
-// UserInternalAPITrace wraps a RoomserverInternalAPI and logs the
-// complete request/response/error
-type UserInternalAPITrace struct {
- Impl UserInternalAPI
-}
-
-func (t *UserInternalAPITrace) InputAccountData(ctx context.Context, req *InputAccountDataRequest, res *InputAccountDataResponse) error {
- err := t.Impl.InputAccountData(ctx, req, res)
- util.GetLogger(ctx).Infof("InputAccountData req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) PerformAccountCreation(ctx context.Context, req *PerformAccountCreationRequest, res *PerformAccountCreationResponse) error {
- err := t.Impl.PerformAccountCreation(ctx, req, res)
- util.GetLogger(ctx).Infof("PerformAccountCreation req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) PerformPasswordUpdate(ctx context.Context, req *PerformPasswordUpdateRequest, res *PerformPasswordUpdateResponse) error {
- err := t.Impl.PerformPasswordUpdate(ctx, req, res)
- util.GetLogger(ctx).Infof("PerformPasswordUpdate req=%+v res=%+v", js(req), js(res))
- return err
-}
-
-func (t *UserInternalAPITrace) PerformDeviceCreation(ctx context.Context, req *PerformDeviceCreationRequest, res *PerformDeviceCreationResponse) error {
- err := t.Impl.PerformDeviceCreation(ctx, req, res)
- util.GetLogger(ctx).Infof("PerformDeviceCreation req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) PerformDeviceDeletion(ctx context.Context, req *PerformDeviceDeletionRequest, res *PerformDeviceDeletionResponse) error {
- err := t.Impl.PerformDeviceDeletion(ctx, req, res)
- util.GetLogger(ctx).Infof("PerformDeviceDeletion req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) PerformLastSeenUpdate(ctx context.Context, req *PerformLastSeenUpdateRequest, res *PerformLastSeenUpdateResponse) error {
- err := t.Impl.PerformLastSeenUpdate(ctx, req, res)
- util.GetLogger(ctx).Infof("PerformLastSeenUpdate req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) PerformDeviceUpdate(ctx context.Context, req *PerformDeviceUpdateRequest, res *PerformDeviceUpdateResponse) error {
- err := t.Impl.PerformDeviceUpdate(ctx, req, res)
- util.GetLogger(ctx).Infof("PerformDeviceUpdate req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) PerformAccountDeactivation(ctx context.Context, req *PerformAccountDeactivationRequest, res *PerformAccountDeactivationResponse) error {
- err := t.Impl.PerformAccountDeactivation(ctx, req, res)
- util.GetLogger(ctx).Infof("PerformAccountDeactivation req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) PerformOpenIDTokenCreation(ctx context.Context, req *PerformOpenIDTokenCreationRequest, res *PerformOpenIDTokenCreationResponse) error {
- err := t.Impl.PerformOpenIDTokenCreation(ctx, req, res)
- util.GetLogger(ctx).Infof("PerformOpenIDTokenCreation req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) PerformKeyBackup(ctx context.Context, req *PerformKeyBackupRequest, res *PerformKeyBackupResponse) error {
- err := t.Impl.PerformKeyBackup(ctx, req, res)
- util.GetLogger(ctx).Infof("PerformKeyBackup req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) PerformPusherSet(ctx context.Context, req *PerformPusherSetRequest, res *struct{}) error {
- err := t.Impl.PerformPusherSet(ctx, req, res)
- util.GetLogger(ctx).Infof("PerformPusherSet req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) PerformPusherDeletion(ctx context.Context, req *PerformPusherDeletionRequest, res *struct{}) error {
- err := t.Impl.PerformPusherDeletion(ctx, req, res)
- util.GetLogger(ctx).Infof("PerformPusherDeletion req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) PerformPushRulesPut(ctx context.Context, req *PerformPushRulesPutRequest, res *struct{}) error {
- err := t.Impl.PerformPushRulesPut(ctx, req, res)
- util.GetLogger(ctx).Infof("PerformPushRulesPut req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) QueryKeyBackup(ctx context.Context, req *QueryKeyBackupRequest, res *QueryKeyBackupResponse) error {
- err := t.Impl.QueryKeyBackup(ctx, req, res)
- util.GetLogger(ctx).Infof("QueryKeyBackup req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) QueryProfile(ctx context.Context, req *QueryProfileRequest, res *QueryProfileResponse) error {
- err := t.Impl.QueryProfile(ctx, req, res)
- util.GetLogger(ctx).Infof("QueryProfile req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) QueryAccessToken(ctx context.Context, req *QueryAccessTokenRequest, res *QueryAccessTokenResponse) error {
- err := t.Impl.QueryAccessToken(ctx, req, res)
- util.GetLogger(ctx).Infof("QueryAccessToken req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) QueryDevices(ctx context.Context, req *QueryDevicesRequest, res *QueryDevicesResponse) error {
- err := t.Impl.QueryDevices(ctx, req, res)
- util.GetLogger(ctx).Infof("QueryDevices req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) QueryAccountData(ctx context.Context, req *QueryAccountDataRequest, res *QueryAccountDataResponse) error {
- err := t.Impl.QueryAccountData(ctx, req, res)
- util.GetLogger(ctx).Infof("QueryAccountData req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) QueryDeviceInfos(ctx context.Context, req *QueryDeviceInfosRequest, res *QueryDeviceInfosResponse) error {
- err := t.Impl.QueryDeviceInfos(ctx, req, res)
- util.GetLogger(ctx).Infof("QueryDeviceInfos req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) QuerySearchProfiles(ctx context.Context, req *QuerySearchProfilesRequest, res *QuerySearchProfilesResponse) error {
- err := t.Impl.QuerySearchProfiles(ctx, req, res)
- util.GetLogger(ctx).Infof("QuerySearchProfiles req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) QueryOpenIDToken(ctx context.Context, req *QueryOpenIDTokenRequest, res *QueryOpenIDTokenResponse) error {
- err := t.Impl.QueryOpenIDToken(ctx, req, res)
- util.GetLogger(ctx).Infof("QueryOpenIDToken req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) QueryPushers(ctx context.Context, req *QueryPushersRequest, res *QueryPushersResponse) error {
- err := t.Impl.QueryPushers(ctx, req, res)
- util.GetLogger(ctx).Infof("QueryPushers req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) QueryPushRules(ctx context.Context, req *QueryPushRulesRequest, res *QueryPushRulesResponse) error {
- err := t.Impl.QueryPushRules(ctx, req, res)
- util.GetLogger(ctx).Infof("QueryPushRules req=%+v res=%+v", js(req), js(res))
- return err
-}
-func (t *UserInternalAPITrace) QueryNotifications(ctx context.Context, req *QueryNotificationsRequest, res *QueryNotificationsResponse) error {
- err := t.Impl.QueryNotifications(ctx, req, res)
- util.GetLogger(ctx).Infof("QueryNotifications req=%+v res=%+v", js(req), js(res))
- return err
-}
-
-func (t *UserInternalAPITrace) SetAvatarURL(ctx context.Context, req *PerformSetAvatarURLRequest, res *PerformSetAvatarURLResponse) error {
- err := t.Impl.SetAvatarURL(ctx, req, res)
- util.GetLogger(ctx).Infof("SetAvatarURL req=%+v res=%+v", js(req), js(res))
- return err
-}
-
-func (t *UserInternalAPITrace) QueryNumericLocalpart(ctx context.Context, req *QueryNumericLocalpartRequest, res *QueryNumericLocalpartResponse) error {
- err := t.Impl.QueryNumericLocalpart(ctx, req, res)
- util.GetLogger(ctx).Infof("QueryNumericLocalpart req= res=%+v", js(res))
- return err
-}
-
-func (t *UserInternalAPITrace) QueryAccountAvailability(ctx context.Context, req *QueryAccountAvailabilityRequest, res *QueryAccountAvailabilityResponse) error {
- err := t.Impl.QueryAccountAvailability(ctx, req, res)
- util.GetLogger(ctx).Infof("QueryAccountAvailability req=%+v res=%+v", js(req), js(res))
- return err
-}
-
-func (t *UserInternalAPITrace) SetDisplayName(ctx context.Context, req *PerformUpdateDisplayNameRequest, res *PerformUpdateDisplayNameResponse) error {
- err := t.Impl.SetDisplayName(ctx, req, res)
- util.GetLogger(ctx).Infof("SetDisplayName req=%+v res=%+v", js(req), js(res))
- return err
-}
-
-func (t *UserInternalAPITrace) QueryAccountByPassword(ctx context.Context, req *QueryAccountByPasswordRequest, res *QueryAccountByPasswordResponse) error {
- err := t.Impl.QueryAccountByPassword(ctx, req, res)
- util.GetLogger(ctx).Infof("QueryAccountByPassword req=%+v res=%+v", js(req), js(res))
- return err
-}
-
-func (t *UserInternalAPITrace) QueryLocalpartForThreePID(ctx context.Context, req *QueryLocalpartForThreePIDRequest, res *QueryLocalpartForThreePIDResponse) error {
- err := t.Impl.QueryLocalpartForThreePID(ctx, req, res)
- util.GetLogger(ctx).Infof("QueryLocalpartForThreePID req=%+v res=%+v", js(req), js(res))
- return err
-}
-
-func (t *UserInternalAPITrace) QueryThreePIDsForLocalpart(ctx context.Context, req *QueryThreePIDsForLocalpartRequest, res *QueryThreePIDsForLocalpartResponse) error {
- err := t.Impl.QueryThreePIDsForLocalpart(ctx, req, res)
- util.GetLogger(ctx).Infof("QueryThreePIDsForLocalpart req=%+v res=%+v", js(req), js(res))
- return err
-}
-
-func (t *UserInternalAPITrace) PerformForgetThreePID(ctx context.Context, req *PerformForgetThreePIDRequest, res *struct{}) error {
- err := t.Impl.PerformForgetThreePID(ctx, req, res)
- util.GetLogger(ctx).Infof("PerformForgetThreePID req=%+v res=%+v", js(req), js(res))
- return err
-}
-
-func (t *UserInternalAPITrace) PerformSaveThreePIDAssociation(ctx context.Context, req *PerformSaveThreePIDAssociationRequest, res *struct{}) error {
- err := t.Impl.PerformSaveThreePIDAssociation(ctx, req, res)
- util.GetLogger(ctx).Infof("PerformSaveThreePIDAssociation req=%+v res=%+v", js(req), js(res))
- return err
-}
-
-func (t *UserInternalAPITrace) QueryAccountByLocalpart(ctx context.Context, req *QueryAccountByLocalpartRequest, res *QueryAccountByLocalpartResponse) error {
- err := t.Impl.QueryAccountByLocalpart(ctx, req, res)
- util.GetLogger(ctx).Infof("QueryAccountByLocalpart req=%+v res=%+v", js(req), js(res))
- return err
-}
-
-func js(thing interface{}) string {
- b, err := json.Marshal(thing)
- if err != nil {
- return fmt.Sprintf("Marshal error:%s", err)
- }
- return string(b)
-}
diff --git a/userapi/api/api_trace_logintoken.go b/userapi/api/api_trace_logintoken.go
deleted file mode 100644
index e60dae59..00000000
--- a/userapi/api/api_trace_logintoken.go
+++ /dev/null
@@ -1,39 +0,0 @@
-// Copyright 2021 The Matrix.org Foundation C.I.C.
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-
-package api
-
-import (
- "context"
-
- "github.com/matrix-org/util"
-)
-
-func (t *UserInternalAPITrace) PerformLoginTokenCreation(ctx context.Context, req *PerformLoginTokenCreationRequest, res *PerformLoginTokenCreationResponse) error {
- err := t.Impl.PerformLoginTokenCreation(ctx, req, res)
- util.GetLogger(ctx).Infof("PerformLoginTokenCreation req=%+v res=%+v", js(req), js(res))
- return err
-}
-
-func (t *UserInternalAPITrace) PerformLoginTokenDeletion(ctx context.Context, req *PerformLoginTokenDeletionRequest, res *PerformLoginTokenDeletionResponse) error {
- err := t.Impl.PerformLoginTokenDeletion(ctx, req, res)
- util.GetLogger(ctx).Infof("PerformLoginTokenDeletion req=%+v res=%+v", js(req), js(res))
- return err
-}
-
-func (t *UserInternalAPITrace) QueryLoginToken(ctx context.Context, req *QueryLoginTokenRequest, res *QueryLoginTokenResponse) error {
- err := t.Impl.QueryLoginToken(ctx, req, res)
- util.GetLogger(ctx).Infof("QueryLoginToken req=%+v res=%+v", js(req), js(res))
- return err
-}
diff --git a/userapi/inthttp/client.go b/userapi/inthttp/client.go
deleted file mode 100644
index 51b0fe3e..00000000
--- a/userapi/inthttp/client.go
+++ /dev/null
@@ -1,454 +0,0 @@
-// Copyright 2020 The Matrix.org Foundation C.I.C.
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-
-package inthttp
-
-import (
- "context"
- "errors"
- "net/http"
-
- "github.com/matrix-org/dendrite/internal/httputil"
- "github.com/matrix-org/dendrite/userapi/api"
-)
-
-// HTTP paths for the internal HTTP APIs
-const (
- InputAccountDataPath = "/userapi/inputAccountData"
-
- PerformDeviceCreationPath = "/userapi/performDeviceCreation"
- PerformAccountCreationPath = "/userapi/performAccountCreation"
- PerformPasswordUpdatePath = "/userapi/performPasswordUpdate"
- PerformDeviceDeletionPath = "/userapi/performDeviceDeletion"
- PerformLastSeenUpdatePath = "/userapi/performLastSeenUpdate"
- PerformDeviceUpdatePath = "/userapi/performDeviceUpdate"
- PerformAccountDeactivationPath = "/userapi/performAccountDeactivation"
- PerformOpenIDTokenCreationPath = "/userapi/performOpenIDTokenCreation"
- PerformKeyBackupPath = "/userapi/performKeyBackup"
- PerformPusherSetPath = "/pushserver/performPusherSet"
- PerformPusherDeletionPath = "/pushserver/performPusherDeletion"
- PerformPushRulesPutPath = "/pushserver/performPushRulesPut"
- PerformSetAvatarURLPath = "/userapi/performSetAvatarURL"
- PerformSetDisplayNamePath = "/userapi/performSetDisplayName"
- PerformForgetThreePIDPath = "/userapi/performForgetThreePID"
- PerformSaveThreePIDAssociationPath = "/userapi/performSaveThreePIDAssociation"
-
- QueryKeyBackupPath = "/userapi/queryKeyBackup"
- QueryProfilePath = "/userapi/queryProfile"
- QueryAccessTokenPath = "/userapi/queryAccessToken"
- QueryDevicesPath = "/userapi/queryDevices"
- QueryAccountDataPath = "/userapi/queryAccountData"
- QueryDeviceInfosPath = "/userapi/queryDeviceInfos"
- QuerySearchProfilesPath = "/userapi/querySearchProfiles"
- QueryOpenIDTokenPath = "/userapi/queryOpenIDToken"
- QueryPushersPath = "/pushserver/queryPushers"
- QueryPushRulesPath = "/pushserver/queryPushRules"
- QueryNotificationsPath = "/pushserver/queryNotifications"
- QueryNumericLocalpartPath = "/userapi/queryNumericLocalpart"
- QueryAccountAvailabilityPath = "/userapi/queryAccountAvailability"
- QueryAccountByPasswordPath = "/userapi/queryAccountByPassword"
- QueryLocalpartForThreePIDPath = "/userapi/queryLocalpartForThreePID"
- QueryThreePIDsForLocalpartPath = "/userapi/queryThreePIDsForLocalpart"
- QueryAccountByLocalpartPath = "/userapi/queryAccountType"
-)
-
-// NewUserAPIClient creates a UserInternalAPI implemented by talking to a HTTP POST API.
-// If httpClient is nil an error is returned
-func NewUserAPIClient(
- apiURL string,
- httpClient *http.Client,
-) (api.UserInternalAPI, error) {
- if httpClient == nil {
- return nil, errors.New("NewUserAPIClient: httpClient is <nil>")
- }
- return &httpUserInternalAPI{
- apiURL: apiURL,
- httpClient: httpClient,
- }, nil
-}
-
-type httpUserInternalAPI struct {
- apiURL string
- httpClient *http.Client
-}
-
-func (h *httpUserInternalAPI) InputAccountData(ctx context.Context, req *api.InputAccountDataRequest, res *api.InputAccountDataResponse) error {
- return httputil.CallInternalRPCAPI(
- "InputAccountData", h.apiURL+InputAccountDataPath,
- h.httpClient, ctx, req, res,
- )
-}
-
-func (h *httpUserInternalAPI) PerformAccountCreation(
- ctx context.Context,
- request *api.PerformAccountCreationRequest,
- response *api.PerformAccountCreationResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "PerformAccountCreation", h.apiURL+PerformAccountCreationPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) PerformPasswordUpdate(
- ctx context.Context,
- request *api.PerformPasswordUpdateRequest,
- response *api.PerformPasswordUpdateResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "PerformPasswordUpdate", h.apiURL+PerformPasswordUpdatePath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) PerformDeviceCreation(
- ctx context.Context,
- request *api.PerformDeviceCreationRequest,
- response *api.PerformDeviceCreationResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "PerformDeviceCreation", h.apiURL+PerformDeviceCreationPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) PerformDeviceDeletion(
- ctx context.Context,
- request *api.PerformDeviceDeletionRequest,
- response *api.PerformDeviceDeletionResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "PerformDeviceDeletion", h.apiURL+PerformDeviceDeletionPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) PerformLastSeenUpdate(
- ctx context.Context,
- request *api.PerformLastSeenUpdateRequest,
- response *api.PerformLastSeenUpdateResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "PerformLastSeen", h.apiURL+PerformLastSeenUpdatePath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) PerformDeviceUpdate(
- ctx context.Context,
- request *api.PerformDeviceUpdateRequest,
- response *api.PerformDeviceUpdateResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "PerformDeviceUpdate", h.apiURL+PerformDeviceUpdatePath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) PerformAccountDeactivation(
- ctx context.Context,
- request *api.PerformAccountDeactivationRequest,
- response *api.PerformAccountDeactivationResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "PerformAccountDeactivation", h.apiURL+PerformAccountDeactivationPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) PerformOpenIDTokenCreation(
- ctx context.Context,
- request *api.PerformOpenIDTokenCreationRequest,
- response *api.PerformOpenIDTokenCreationResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "PerformOpenIDTokenCreation", h.apiURL+PerformOpenIDTokenCreationPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) QueryProfile(
- ctx context.Context,
- request *api.QueryProfileRequest,
- response *api.QueryProfileResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "QueryProfile", h.apiURL+QueryProfilePath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) QueryDeviceInfos(
- ctx context.Context,
- request *api.QueryDeviceInfosRequest,
- response *api.QueryDeviceInfosResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "QueryDeviceInfos", h.apiURL+QueryDeviceInfosPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) QueryAccessToken(
- ctx context.Context,
- request *api.QueryAccessTokenRequest,
- response *api.QueryAccessTokenResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "QueryAccessToken", h.apiURL+QueryAccessTokenPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) QueryDevices(
- ctx context.Context,
- request *api.QueryDevicesRequest,
- response *api.QueryDevicesResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "QueryDevices", h.apiURL+QueryDevicesPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) QueryAccountData(
- ctx context.Context,
- request *api.QueryAccountDataRequest,
- response *api.QueryAccountDataResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "QueryAccountData", h.apiURL+QueryAccountDataPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) QuerySearchProfiles(
- ctx context.Context,
- request *api.QuerySearchProfilesRequest,
- response *api.QuerySearchProfilesResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "QuerySearchProfiles", h.apiURL+QuerySearchProfilesPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) QueryOpenIDToken(
- ctx context.Context,
- request *api.QueryOpenIDTokenRequest,
- response *api.QueryOpenIDTokenResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "QueryOpenIDToken", h.apiURL+QueryOpenIDTokenPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) PerformKeyBackup(
- ctx context.Context,
- request *api.PerformKeyBackupRequest,
- response *api.PerformKeyBackupResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "PerformKeyBackup", h.apiURL+PerformKeyBackupPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) QueryKeyBackup(
- ctx context.Context,
- request *api.QueryKeyBackupRequest,
- response *api.QueryKeyBackupResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "QueryKeyBackup", h.apiURL+QueryKeyBackupPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) QueryNotifications(
- ctx context.Context,
- request *api.QueryNotificationsRequest,
- response *api.QueryNotificationsResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "QueryNotifications", h.apiURL+QueryNotificationsPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) PerformPusherSet(
- ctx context.Context,
- request *api.PerformPusherSetRequest,
- response *struct{},
-) error {
- return httputil.CallInternalRPCAPI(
- "PerformPusherSet", h.apiURL+PerformPusherSetPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) PerformPusherDeletion(
- ctx context.Context,
- request *api.PerformPusherDeletionRequest,
- response *struct{},
-) error {
- return httputil.CallInternalRPCAPI(
- "PerformPusherDeletion", h.apiURL+PerformPusherDeletionPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) QueryPushers(
- ctx context.Context,
- request *api.QueryPushersRequest,
- response *api.QueryPushersResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "QueryPushers", h.apiURL+QueryPushersPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) PerformPushRulesPut(
- ctx context.Context,
- request *api.PerformPushRulesPutRequest,
- response *struct{},
-) error {
- return httputil.CallInternalRPCAPI(
- "PerformPushRulesPut", h.apiURL+PerformPushRulesPutPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) QueryPushRules(
- ctx context.Context,
- request *api.QueryPushRulesRequest,
- response *api.QueryPushRulesResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "QueryPushRules", h.apiURL+QueryPushRulesPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) SetAvatarURL(
- ctx context.Context,
- request *api.PerformSetAvatarURLRequest,
- response *api.PerformSetAvatarURLResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "SetAvatarURL", h.apiURL+PerformSetAvatarURLPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) QueryNumericLocalpart(
- ctx context.Context,
- request *api.QueryNumericLocalpartRequest,
- response *api.QueryNumericLocalpartResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "QueryNumericLocalpart", h.apiURL+QueryNumericLocalpartPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) QueryAccountAvailability(
- ctx context.Context,
- request *api.QueryAccountAvailabilityRequest,
- response *api.QueryAccountAvailabilityResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "QueryAccountAvailability", h.apiURL+QueryAccountAvailabilityPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) QueryAccountByPassword(
- ctx context.Context,
- request *api.QueryAccountByPasswordRequest,
- response *api.QueryAccountByPasswordResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "QueryAccountByPassword", h.apiURL+QueryAccountByPasswordPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) SetDisplayName(
- ctx context.Context,
- request *api.PerformUpdateDisplayNameRequest,
- response *api.PerformUpdateDisplayNameResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "SetDisplayName", h.apiURL+PerformSetDisplayNamePath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) QueryLocalpartForThreePID(
- ctx context.Context,
- request *api.QueryLocalpartForThreePIDRequest,
- response *api.QueryLocalpartForThreePIDResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "QueryLocalpartForThreePID", h.apiURL+QueryLocalpartForThreePIDPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) QueryThreePIDsForLocalpart(
- ctx context.Context,
- request *api.QueryThreePIDsForLocalpartRequest,
- response *api.QueryThreePIDsForLocalpartResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "QueryThreePIDsForLocalpart", h.apiURL+QueryThreePIDsForLocalpartPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) PerformForgetThreePID(
- ctx context.Context,
- request *api.PerformForgetThreePIDRequest,
- response *struct{},
-) error {
- return httputil.CallInternalRPCAPI(
- "PerformForgetThreePID", h.apiURL+PerformForgetThreePIDPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) PerformSaveThreePIDAssociation(
- ctx context.Context,
- request *api.PerformSaveThreePIDAssociationRequest,
- response *struct{},
-) error {
- return httputil.CallInternalRPCAPI(
- "PerformSaveThreePIDAssociation", h.apiURL+PerformSaveThreePIDAssociationPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) QueryAccountByLocalpart(
- ctx context.Context,
- req *api.QueryAccountByLocalpartRequest,
- res *api.QueryAccountByLocalpartResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "QueryAccountByLocalpart", h.apiURL+QueryAccountByLocalpartPath,
- h.httpClient, ctx, req, res,
- )
-}
diff --git a/userapi/inthttp/client_logintoken.go b/userapi/inthttp/client_logintoken.go
deleted file mode 100644
index 211b1b7a..00000000
--- a/userapi/inthttp/client_logintoken.go
+++ /dev/null
@@ -1,61 +0,0 @@
-// Copyright 2021 The Matrix.org Foundation C.I.C.
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-
-package inthttp
-
-import (
- "context"
-
- "github.com/matrix-org/dendrite/internal/httputil"
- "github.com/matrix-org/dendrite/userapi/api"
-)
-
-const (
- PerformLoginTokenCreationPath = "/userapi/performLoginTokenCreation"
- PerformLoginTokenDeletionPath = "/userapi/performLoginTokenDeletion"
- QueryLoginTokenPath = "/userapi/queryLoginToken"
-)
-
-func (h *httpUserInternalAPI) PerformLoginTokenCreation(
- ctx context.Context,
- request *api.PerformLoginTokenCreationRequest,
- response *api.PerformLoginTokenCreationResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "PerformLoginTokenCreation", h.apiURL+PerformLoginTokenCreationPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) PerformLoginTokenDeletion(
- ctx context.Context,
- request *api.PerformLoginTokenDeletionRequest,
- response *api.PerformLoginTokenDeletionResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "PerformLoginTokenDeletion", h.apiURL+PerformLoginTokenDeletionPath,
- h.httpClient, ctx, request, response,
- )
-}
-
-func (h *httpUserInternalAPI) QueryLoginToken(
- ctx context.Context,
- request *api.QueryLoginTokenRequest,
- response *api.QueryLoginTokenResponse,
-) error {
- return httputil.CallInternalRPCAPI(
- "QueryLoginToken", h.apiURL+QueryLoginTokenPath,
- h.httpClient, ctx, request, response,
- )
-}
diff --git a/userapi/inthttp/server.go b/userapi/inthttp/server.go
deleted file mode 100644
index b40b507c..00000000
--- a/userapi/inthttp/server.go
+++ /dev/null
@@ -1,197 +0,0 @@
-// Copyright 2020 The Matrix.org Foundation C.I.C.
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-
-package inthttp
-
-import (
- "github.com/gorilla/mux"
-
- "github.com/matrix-org/dendrite/internal/httputil"
- "github.com/matrix-org/dendrite/userapi/api"
-)
-
-// nolint: gocyclo
-func AddRoutes(internalAPIMux *mux.Router, s api.UserInternalAPI, enableMetrics bool) {
- addRoutesLoginToken(internalAPIMux, s, enableMetrics)
-
- internalAPIMux.Handle(
- PerformAccountCreationPath,
- httputil.MakeInternalRPCAPI("UserAPIPerformAccountCreation", enableMetrics, s.PerformAccountCreation),
- )
-
- internalAPIMux.Handle(
- PerformPasswordUpdatePath,
- httputil.MakeInternalRPCAPI("UserAPIPerformPasswordUpdate", enableMetrics, s.PerformPasswordUpdate),
- )
-
- internalAPIMux.Handle(
- PerformDeviceCreationPath,
- httputil.MakeInternalRPCAPI("UserAPIPerformDeviceCreation", enableMetrics, s.PerformDeviceCreation),
- )
-
- internalAPIMux.Handle(
- PerformLastSeenUpdatePath,
- httputil.MakeInternalRPCAPI("UserAPIPerformLastSeenUpdate", enableMetrics, s.PerformLastSeenUpdate),
- )
-
- internalAPIMux.Handle(
- PerformDeviceUpdatePath,
- httputil.MakeInternalRPCAPI("UserAPIPerformDeviceUpdate", enableMetrics, s.PerformDeviceUpdate),
- )
-
- internalAPIMux.Handle(
- PerformDeviceDeletionPath,
- httputil.MakeInternalRPCAPI("UserAPIPerformDeviceDeletion", enableMetrics, s.PerformDeviceDeletion),
- )
-
- internalAPIMux.Handle(
- PerformAccountDeactivationPath,
- httputil.MakeInternalRPCAPI("UserAPIPerformAccountDeactivation", enableMetrics, s.PerformAccountDeactivation),
- )
-
- internalAPIMux.Handle(
- PerformOpenIDTokenCreationPath,
- httputil.MakeInternalRPCAPI("UserAPIPerformOpenIDTokenCreation", enableMetrics, s.PerformOpenIDTokenCreation),
- )
-
- internalAPIMux.Handle(
- QueryProfilePath,
- httputil.MakeInternalRPCAPI("UserAPIQueryProfile", enableMetrics, s.QueryProfile),
- )
-
- internalAPIMux.Handle(
- QueryAccessTokenPath,
- httputil.MakeInternalRPCAPI("UserAPIQueryAccessToken", enableMetrics, s.QueryAccessToken),
- )
-
- internalAPIMux.Handle(
- QueryDevicesPath,
- httputil.MakeInternalRPCAPI("UserAPIQueryDevices", enableMetrics, s.QueryDevices),
- )
-
- internalAPIMux.Handle(
- QueryAccountDataPath,
- httputil.MakeInternalRPCAPI("UserAPIQueryAccountData", enableMetrics, s.QueryAccountData),
- )
-
- internalAPIMux.Handle(
- QueryDeviceInfosPath,
- httputil.MakeInternalRPCAPI("UserAPIQueryDeviceInfos", enableMetrics, s.QueryDeviceInfos),
- )
-
- internalAPIMux.Handle(
- QuerySearchProfilesPath,
- httputil.MakeInternalRPCAPI("UserAPIQuerySearchProfiles", enableMetrics, s.QuerySearchProfiles),
- )
-
- internalAPIMux.Handle(
- QueryOpenIDTokenPath,
- httputil.MakeInternalRPCAPI("UserAPIQueryOpenIDToken", enableMetrics, s.QueryOpenIDToken),
- )
-
- internalAPIMux.Handle(
- InputAccountDataPath,
- httputil.MakeInternalRPCAPI("UserAPIInputAccountData", enableMetrics, s.InputAccountData),
- )
-
- internalAPIMux.Handle(
- QueryKeyBackupPath,
- httputil.MakeInternalRPCAPI("UserAPIQueryKeyBackup", enableMetrics, s.QueryKeyBackup),
- )
-
- internalAPIMux.Handle(
- PerformKeyBackupPath,
- httputil.MakeInternalRPCAPI("UserAPIPerformKeyBackup", enableMetrics, s.PerformKeyBackup),
- )
-
- internalAPIMux.Handle(
- QueryNotificationsPath,
- httputil.MakeInternalRPCAPI("UserAPIQueryNotifications", enableMetrics, s.QueryNotifications),
- )
-
- internalAPIMux.Handle(
- PerformPusherSetPath,
- httputil.MakeInternalRPCAPI("UserAPIPerformPusherSet", enableMetrics, s.PerformPusherSet),
- )
-
- internalAPIMux.Handle(
- PerformPusherDeletionPath,
- httputil.MakeInternalRPCAPI("UserAPIPerformPusherDeletion", enableMetrics, s.PerformPusherDeletion),
- )
-
- internalAPIMux.Handle(
- QueryPushersPath,
- httputil.MakeInternalRPCAPI("UserAPIQueryPushers", enableMetrics, s.QueryPushers),
- )
-
- internalAPIMux.Handle(
- PerformPushRulesPutPath,
- httputil.MakeInternalRPCAPI("UserAPIPerformPushRulesPut", enableMetrics, s.PerformPushRulesPut),
- )
-
- internalAPIMux.Handle(
- QueryPushRulesPath,
- httputil.MakeInternalRPCAPI("UserAPIQueryPushRules", enableMetrics, s.QueryPushRules),
- )
-
- internalAPIMux.Handle(
- PerformSetAvatarURLPath,
- httputil.MakeInternalRPCAPI("UserAPIPerformSetAvatarURL", enableMetrics, s.SetAvatarURL),
- )
-
- internalAPIMux.Handle(
- QueryNumericLocalpartPath,
- httputil.MakeInternalRPCAPI("UserAPIQueryNumericLocalpart", enableMetrics, s.QueryNumericLocalpart),
- )
-
- internalAPIMux.Handle(
- QueryAccountAvailabilityPath,
- httputil.MakeInternalRPCAPI("UserAPIQueryAccountAvailability", enableMetrics, s.QueryAccountAvailability),
- )
-
- internalAPIMux.Handle(
- QueryAccountByPasswordPath,
- httputil.MakeInternalRPCAPI("UserAPIQueryAccountByPassword", enableMetrics, s.QueryAccountByPassword),
- )
-
- internalAPIMux.Handle(
- PerformSetDisplayNamePath,
- httputil.MakeInternalRPCAPI("UserAPISetDisplayName", enableMetrics, s.SetDisplayName),
- )
-
- internalAPIMux.Handle(
- QueryLocalpartForThreePIDPath,
- httputil.MakeInternalRPCAPI("UserAPIQueryLocalpartForThreePID", enableMetrics, s.QueryLocalpartForThreePID),
- )
-
- internalAPIMux.Handle(
- QueryThreePIDsForLocalpartPath,
- httputil.MakeInternalRPCAPI("UserAPIQueryThreePIDsForLocalpart", enableMetrics, s.QueryThreePIDsForLocalpart),
- )
-
- internalAPIMux.Handle(
- PerformForgetThreePIDPath,
- httputil.MakeInternalRPCAPI("UserAPIPerformForgetThreePID", enableMetrics, s.PerformForgetThreePID),
- )
-
- internalAPIMux.Handle(
- PerformSaveThreePIDAssociationPath,
- httputil.MakeInternalRPCAPI("UserAPIPerformSaveThreePIDAssociation", enableMetrics, s.PerformSaveThreePIDAssociation),
- )
-
- internalAPIMux.Handle(
- QueryAccountByLocalpartPath,
- httputil.MakeInternalRPCAPI("AccountByLocalpart", enableMetrics, s.QueryAccountByLocalpart),
- )
-}
diff --git a/userapi/inthttp/server_logintoken.go b/userapi/inthttp/server_logintoken.go
deleted file mode 100644
index dc116428..00000000
--- a/userapi/inthttp/server_logintoken.go
+++ /dev/null
@@ -1,40 +0,0 @@
-// Copyright 2021 The Matrix.org Foundation C.I.C.
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-
-package inthttp
-
-import (
- "github.com/gorilla/mux"
-
- "github.com/matrix-org/dendrite/internal/httputil"
- "github.com/matrix-org/dendrite/userapi/api"
-)
-
-// addRoutesLoginToken adds routes for all login token API calls.
-func addRoutesLoginToken(internalAPIMux *mux.Router, s api.UserInternalAPI, enableMetrics bool) {
- internalAPIMux.Handle(
- PerformLoginTokenCreationPath,
- httputil.MakeInternalRPCAPI("UserAPIPerformLoginTokenCreation", enableMetrics, s.PerformLoginTokenCreation),
- )
-
- internalAPIMux.Handle(
- PerformLoginTokenDeletionPath,
- httputil.MakeInternalRPCAPI("UserAPIPerformLoginTokenDeletion", enableMetrics, s.PerformLoginTokenDeletion),
- )
-
- internalAPIMux.Handle(
- QueryLoginTokenPath,
- httputil.MakeInternalRPCAPI("UserAPIQueryLoginToken", enableMetrics, s.QueryLoginToken),
- )
-}
diff --git a/userapi/userapi.go b/userapi/userapi.go
index 183ca312..2dd81d75 100644
--- a/userapi/userapi.go
+++ b/userapi/userapi.go
@@ -17,7 +17,6 @@ package userapi
import (
"time"
- "github.com/gorilla/mux"
"github.com/sirupsen/logrus"
"github.com/matrix-org/dendrite/internal/pushgateway"
@@ -29,18 +28,11 @@ import (
"github.com/matrix-org/dendrite/userapi/api"
"github.com/matrix-org/dendrite/userapi/consumers"
"github.com/matrix-org/dendrite/userapi/internal"
- "github.com/matrix-org/dendrite/userapi/inthttp"
"github.com/matrix-org/dendrite/userapi/producers"
"github.com/matrix-org/dendrite/userapi/storage"
"github.com/matrix-org/dendrite/userapi/util"
)
-// AddInternalRoutes registers HTTP handlers for the internal API. Invokes functions
-// on the given input API.
-func AddInternalRoutes(router *mux.Router, intAPI api.UserInternalAPI, enableMetrics bool) {
- inthttp.AddRoutes(router, intAPI, enableMetrics)
-}
-
// NewInternalAPI returns a concerete implementation of the internal API. Callers
// can call functions directly on the returned API or via an HTTP interface using AddInternalRoutes.
func NewInternalAPI(
diff --git a/userapi/userapi_test.go b/userapi/userapi_test.go
index dada56de..68d08c2f 100644
--- a/userapi/userapi_test.go
+++ b/userapi/userapi_test.go
@@ -17,23 +17,18 @@ package userapi_test
import (
"context"
"fmt"
- "net/http"
"reflect"
"testing"
"time"
- "github.com/gorilla/mux"
"github.com/matrix-org/gomatrixserverlib"
"golang.org/x/crypto/bcrypt"
- "github.com/matrix-org/dendrite/internal/httputil"
"github.com/matrix-org/dendrite/setup/config"
"github.com/matrix-org/dendrite/test"
"github.com/matrix-org/dendrite/test/testrig"
- "github.com/matrix-org/dendrite/userapi"
"github.com/matrix-org/dendrite/userapi/api"
"github.com/matrix-org/dendrite/userapi/internal"
- "github.com/matrix-org/dendrite/userapi/inthttp"
"github.com/matrix-org/dendrite/userapi/storage"
)
@@ -142,20 +137,7 @@ func TestQueryProfile(t *testing.T) {
t.Fatalf("failed to set display name: %s", err)
}
- t.Run("HTTP API", func(t *testing.T) {
- router := mux.NewRouter().PathPrefix(httputil.InternalPathPrefix).Subrouter()
- userapi.AddInternalRoutes(router, userAPI, false)
- apiURL, cancel := test.ListenAndServe(t, router, false)
- defer cancel()
- httpAPI, err := inthttp.NewUserAPIClient(apiURL, &http.Client{})
- if err != nil {
- t.Fatalf("failed to create HTTP client")
- }
- runCases(httpAPI, true)
- })
- t.Run("Monolith", func(t *testing.T) {
- runCases(userAPI, false)
- })
+ runCases(userAPI, false)
})
}
@@ -347,24 +329,6 @@ func TestQueryAccountByLocalpart(t *testing.T) {
}
}
- t.Run("Monolith", func(t *testing.T) {
- testCases(t, intAPI)
- // also test tracing
- testCases(t, &api.UserInternalAPITrace{Impl: intAPI})
- })
-
- t.Run("HTTP API", func(t *testing.T) {
- router := mux.NewRouter().PathPrefix(httputil.InternalPathPrefix).Subrouter()
- userapi.AddInternalRoutes(router, intAPI, false)
- apiURL, cancel := test.ListenAndServe(t, router, false)
- defer cancel()
-
- userHTTPApi, err := inthttp.NewUserAPIClient(apiURL, &http.Client{Timeout: time.Second * 5})
- if err != nil {
- t.Fatalf("failed to create HTTP client: %s", err)
- }
- testCases(t, userHTTPApi)
-
- })
+ testCases(t, intAPI)
})
}
diff --git a/userapi/util/phonehomestats.go b/userapi/util/phonehomestats.go
index 42c8f5d7..21035e04 100644
--- a/userapi/util/phonehomestats.go
+++ b/userapi/util/phonehomestats.go
@@ -55,7 +55,7 @@ func StartPhoneHomeCollector(startTime time.Time, cfg *config.Dendrite, statsDB
serverName: cfg.Global.ServerName,
cfg: cfg,
db: statsDB,
- isMonolith: cfg.IsMonolith,
+ isMonolith: true,
client: &http.Client{
Timeout: time.Second * 30,
Transport: http.DefaultTransport,