mirror of
https://github.com/matrix-org/dendrite.git
synced 2026-01-20 04:23:09 -06:00
Rename binary, move /metrics back to the normal router
This commit is contained in:
parent
503f34422f
commit
1df9c478d5
|
|
@ -3,7 +3,7 @@
|
||||||
#
|
#
|
||||||
# base installs required dependencies and runs go mod download to cache dependencies
|
# base installs required dependencies and runs go mod download to cache dependencies
|
||||||
#
|
#
|
||||||
FROM --platform=${BUILDPLATFORM} docker.io/golang:1.19-alpine AS base
|
FROM --platform=${BUILDPLATFORM} docker.io/golang:1.20-alpine AS base
|
||||||
RUN apk --update --no-cache add bash build-base curl
|
RUN apk --update --no-cache add bash build-base curl
|
||||||
|
|
||||||
#
|
#
|
||||||
|
|
@ -28,6 +28,7 @@ RUN --mount=target=. \
|
||||||
# Builds the Dendrite image containing all required binaries
|
# Builds the Dendrite image containing all required binaries
|
||||||
#
|
#
|
||||||
FROM alpine:latest
|
FROM alpine:latest
|
||||||
|
RUN apk --update --no-cache add curl
|
||||||
LABEL org.opencontainers.image.title="Dendrite"
|
LABEL org.opencontainers.image.title="Dendrite"
|
||||||
LABEL org.opencontainers.image.description="Next-generation Matrix homeserver written in Go"
|
LABEL org.opencontainers.image.description="Next-generation Matrix homeserver written in Go"
|
||||||
LABEL org.opencontainers.image.source="https://github.com/matrix-org/dendrite"
|
LABEL org.opencontainers.image.source="https://github.com/matrix-org/dendrite"
|
||||||
|
|
@ -38,11 +39,11 @@ LABEL org.opencontainers.image.vendor="The Matrix.org Foundation C.I.C."
|
||||||
COPY --from=build /out/create-account /usr/bin/create-account
|
COPY --from=build /out/create-account /usr/bin/create-account
|
||||||
COPY --from=build /out/generate-config /usr/bin/generate-config
|
COPY --from=build /out/generate-config /usr/bin/generate-config
|
||||||
COPY --from=build /out/generate-keys /usr/bin/generate-keys
|
COPY --from=build /out/generate-keys /usr/bin/generate-keys
|
||||||
COPY --from=build /out/dendrite-monolith-server /usr/bin/dendrite-monolith-server
|
COPY --from=build /out/dendrite /usr/bin/dendrite
|
||||||
|
|
||||||
VOLUME /etc/dendrite
|
VOLUME /etc/dendrite
|
||||||
WORKDIR /etc/dendrite
|
WORKDIR /etc/dendrite
|
||||||
|
|
||||||
ENTRYPOINT ["/usr/bin/dendrite-monolith-server"]
|
ENTRYPOINT ["/usr/bin/dendrite"]
|
||||||
EXPOSE 8008 8448
|
EXPOSE 8008 8448
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -1,109 +0,0 @@
|
||||||
// Copyright 2017 Vector Creations Ltd
|
|
||||||
//
|
|
||||||
// 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 main
|
|
||||||
|
|
||||||
import (
|
|
||||||
"flag"
|
|
||||||
|
|
||||||
"github.com/sirupsen/logrus"
|
|
||||||
|
|
||||||
"github.com/matrix-org/dendrite/appservice"
|
|
||||||
"github.com/matrix-org/dendrite/federationapi"
|
|
||||||
"github.com/matrix-org/dendrite/keyserver"
|
|
||||||
"github.com/matrix-org/dendrite/roomserver"
|
|
||||||
"github.com/matrix-org/dendrite/setup"
|
|
||||||
basepkg "github.com/matrix-org/dendrite/setup/base"
|
|
||||||
"github.com/matrix-org/dendrite/setup/config"
|
|
||||||
"github.com/matrix-org/dendrite/setup/mscs"
|
|
||||||
"github.com/matrix-org/dendrite/userapi"
|
|
||||||
)
|
|
||||||
|
|
||||||
var (
|
|
||||||
httpBindAddr = flag.String("http-bind-address", ":8008", "The HTTP listening port for the server")
|
|
||||||
httpsBindAddr = flag.String("https-bind-address", ":8448", "The HTTPS listening port for the server")
|
|
||||||
certFile = flag.String("tls-cert", "", "The PEM formatted X509 certificate to use for TLS")
|
|
||||||
keyFile = flag.String("tls-key", "", "The PEM private key to use for TLS")
|
|
||||||
)
|
|
||||||
|
|
||||||
func main() {
|
|
||||||
cfg := setup.ParseFlags(true)
|
|
||||||
httpAddr := config.HTTPAddress("http://" + *httpBindAddr)
|
|
||||||
httpsAddr := config.HTTPAddress("https://" + *httpsBindAddr)
|
|
||||||
options := []basepkg.BaseDendriteOptions{}
|
|
||||||
|
|
||||||
base := basepkg.NewBaseDendrite(cfg, options...)
|
|
||||||
defer base.Close() // nolint: errcheck
|
|
||||||
|
|
||||||
federation := base.CreateFederationClient()
|
|
||||||
|
|
||||||
rsAPI := roomserver.NewInternalAPI(base)
|
|
||||||
|
|
||||||
fsAPI := federationapi.NewInternalAPI(
|
|
||||||
base, federation, rsAPI, base.Caches, nil, false,
|
|
||||||
)
|
|
||||||
|
|
||||||
keyRing := fsAPI.KeyRing()
|
|
||||||
|
|
||||||
keyAPI := keyserver.NewInternalAPI(base, &base.Cfg.KeyServer, fsAPI, rsAPI)
|
|
||||||
|
|
||||||
pgClient := base.PushGatewayHTTPClient()
|
|
||||||
userAPI := userapi.NewInternalAPI(base, &cfg.UserAPI, cfg.Derived.ApplicationServices, keyAPI, rsAPI, pgClient)
|
|
||||||
|
|
||||||
asAPI := appservice.NewInternalAPI(base, userAPI, rsAPI)
|
|
||||||
|
|
||||||
// The underlying roomserver implementation needs to be able to call the fedsender.
|
|
||||||
// This is different to rsAPI which can be the http client which doesn't need this
|
|
||||||
// dependency. Other components also need updating after their dependencies are up.
|
|
||||||
rsAPI.SetFederationAPI(fsAPI, keyRing)
|
|
||||||
rsAPI.SetAppserviceAPI(asAPI)
|
|
||||||
rsAPI.SetUserAPI(userAPI)
|
|
||||||
keyAPI.SetUserAPI(userAPI)
|
|
||||||
|
|
||||||
monolith := setup.Monolith{
|
|
||||||
Config: base.Cfg,
|
|
||||||
Client: base.CreateClient(),
|
|
||||||
FedClient: federation,
|
|
||||||
KeyRing: keyRing,
|
|
||||||
|
|
||||||
AppserviceAPI: asAPI,
|
|
||||||
// always use the concrete impl here even in -http mode because adding public routes
|
|
||||||
// must be done on the concrete impl not an HTTP client else fedapi will call itself
|
|
||||||
FederationAPI: fsAPI,
|
|
||||||
RoomserverAPI: rsAPI,
|
|
||||||
UserAPI: userAPI,
|
|
||||||
KeyAPI: keyAPI,
|
|
||||||
}
|
|
||||||
monolith.AddAllPublicRoutes(base)
|
|
||||||
|
|
||||||
if len(base.Cfg.MSCs.MSCs) > 0 {
|
|
||||||
if err := mscs.Enable(base, &monolith); err != nil {
|
|
||||||
logrus.WithError(err).Fatalf("Failed to enable MSCs")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Expose the matrix APIs directly rather than putting them under a /api path.
|
|
||||||
go func() {
|
|
||||||
base.SetupAndServeHTTP(httpAddr, nil, nil)
|
|
||||||
}()
|
|
||||||
// Handle HTTPS if certificate and key are provided
|
|
||||||
if *certFile != "" && *keyFile != "" {
|
|
||||||
go func() {
|
|
||||||
base.SetupAndServeHTTP(httpsAddr, certFile, keyFile)
|
|
||||||
}()
|
|
||||||
}
|
|
||||||
|
|
||||||
// We want to block forever to let the HTTP and HTTPS handler serve the APIs
|
|
||||||
base.WaitForShutdown()
|
|
||||||
}
|
|
||||||
|
|
@ -1,50 +0,0 @@
|
||||||
package main
|
|
||||||
|
|
||||||
import (
|
|
||||||
"os"
|
|
||||||
"os/signal"
|
|
||||||
"strings"
|
|
||||||
"syscall"
|
|
||||||
"testing"
|
|
||||||
)
|
|
||||||
|
|
||||||
// This is an instrumented main, used when running integration tests (sytest) with code coverage.
|
|
||||||
// Compile: go test -c -race -cover -covermode=atomic -o monolith.debug -coverpkg "github.com/matrix-org/..." ./cmd/dendrite-monolith-server
|
|
||||||
// Run the monolith: ./monolith.debug -test.coverprofile=/somewhere/to/dump/integrationcover.out DEVEL --config dendrite.yaml
|
|
||||||
// Generate HTML with coverage: go tool cover -html=/somewhere/where/there/is/integrationcover.out -o cover.html
|
|
||||||
// Source: https://dzone.com/articles/measuring-integration-test-coverage-rate-in-pouchc
|
|
||||||
func TestMain(_ *testing.T) {
|
|
||||||
var (
|
|
||||||
args []string
|
|
||||||
)
|
|
||||||
|
|
||||||
for _, arg := range os.Args {
|
|
||||||
switch {
|
|
||||||
case strings.HasPrefix(arg, "DEVEL"):
|
|
||||||
case strings.HasPrefix(arg, "-test"):
|
|
||||||
default:
|
|
||||||
args = append(args, arg)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
// only run the tests if there are args to be passed
|
|
||||||
if len(args) <= 1 {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
waitCh := make(chan int, 1)
|
|
||||||
os.Args = args
|
|
||||||
go func() {
|
|
||||||
main()
|
|
||||||
close(waitCh)
|
|
||||||
}()
|
|
||||||
|
|
||||||
signalCh := make(chan os.Signal, 1)
|
|
||||||
signal.Notify(signalCh, syscall.SIGINT, syscall.SIGQUIT, syscall.SIGTERM, syscall.SIGHUP)
|
|
||||||
|
|
||||||
select {
|
|
||||||
case <-signalCh:
|
|
||||||
return
|
|
||||||
case <-waitCh:
|
|
||||||
return
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -371,8 +371,8 @@ func (b *BaseDendrite) SetupAndServeHTTP(
|
||||||
http.Redirect(w, r, httputil.PublicStaticPath, http.StatusFound)
|
http.Redirect(w, r, httputil.PublicStaticPath, http.StatusFound)
|
||||||
})
|
})
|
||||||
|
|
||||||
if b.Cfg.Global.Metrics.Enabled && b.DendriteAdminMux != nil {
|
if b.Cfg.Global.Metrics.Enabled {
|
||||||
b.DendriteAdminMux.Handle("/metrics", httputil.WrapHandlerInBasicAuth(promhttp.Handler(), b.Cfg.Global.Metrics.BasicAuth))
|
externalRouter.Handle("/metrics", httputil.WrapHandlerInBasicAuth(promhttp.Handler(), b.Cfg.Global.Metrics.BasicAuth))
|
||||||
}
|
}
|
||||||
|
|
||||||
b.ConfigureAdminEndpoints()
|
b.ConfigureAdminEndpoints()
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue