mirror of
https://github.com/matrix-org/dendrite.git
synced 2025-12-10 08:23:11 -06:00
c44e48f540
Previously, all database stuff was under the helpfully named
package 'storage'. However, this convention is used throughout all
of dendrite, which will clash the moment we want to add auth to all
the CS API endpoints. To prevent the package name clash, add
sub-directories which represent what is being stored so the final
usage ends up being:
```
func doThing(db *storage.SyncServerDatabase, authDB *accounts.Database)
{
// ...
}
```
92 lines
2.9 KiB
Go
92 lines
2.9 KiB
Go
// 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 (
|
|
"net/http"
|
|
"os"
|
|
"strings"
|
|
|
|
"github.com/matrix-org/dendrite/clientapi/auth/storage/accounts"
|
|
"github.com/matrix-org/dendrite/clientapi/config"
|
|
"github.com/matrix-org/dendrite/clientapi/producers"
|
|
"github.com/matrix-org/dendrite/clientapi/routing"
|
|
"github.com/matrix-org/dendrite/common"
|
|
"github.com/matrix-org/dendrite/roomserver/api"
|
|
"github.com/matrix-org/gomatrixserverlib"
|
|
|
|
log "github.com/Sirupsen/logrus"
|
|
)
|
|
|
|
var (
|
|
kafkaURIs = strings.Split(os.Getenv("KAFKA_URIS"), ",")
|
|
bindAddr = os.Getenv("BIND_ADDRESS")
|
|
logDir = os.Getenv("LOG_DIR")
|
|
roomserverURL = os.Getenv("ROOMSERVER_URL")
|
|
clientAPIOutputTopic = os.Getenv("CLIENTAPI_OUTPUT_TOPIC")
|
|
serverName = gomatrixserverlib.ServerName(os.Getenv("SERVER_NAME"))
|
|
serverKey = os.Getenv("SERVER_KEY")
|
|
accountDataSource = os.Getenv("ACCOUNT_DATABASE")
|
|
)
|
|
|
|
func main() {
|
|
common.SetupLogging(logDir)
|
|
if bindAddr == "" {
|
|
log.Panic("No BIND_ADDRESS environment variable found.")
|
|
}
|
|
if len(kafkaURIs) == 0 {
|
|
// the kafka default is :9092
|
|
kafkaURIs = []string{"localhost:9092"}
|
|
}
|
|
if roomserverURL == "" {
|
|
log.Panic("No ROOMSERVER_URL environment variable found.")
|
|
}
|
|
if clientAPIOutputTopic == "" {
|
|
log.Panic("No CLIENTAPI_OUTPUT_TOPIC environment variable found. This should match the roomserver input topic.")
|
|
}
|
|
if serverName == "" {
|
|
serverName = "localhost"
|
|
}
|
|
|
|
cfg := config.ClientAPI{
|
|
ServerName: serverName,
|
|
KafkaProducerURIs: kafkaURIs,
|
|
ClientAPIOutputTopic: clientAPIOutputTopic,
|
|
RoomserverURL: roomserverURL,
|
|
}
|
|
|
|
var err error
|
|
cfg.KeyID, cfg.PrivateKey, err = common.ReadKey(serverKey)
|
|
if err != nil {
|
|
log.Panicf("Failed to load private key: %s", err)
|
|
}
|
|
|
|
log.Info("Starting clientapi")
|
|
|
|
roomserverProducer, err := producers.NewRoomserverProducer(cfg.KafkaProducerURIs, cfg.ClientAPIOutputTopic)
|
|
if err != nil {
|
|
log.Panicf("Failed to setup kafka producers(%s): %s", cfg.KafkaProducerURIs, err)
|
|
}
|
|
|
|
queryAPI := api.NewRoomserverQueryAPIHTTP(cfg.RoomserverURL, nil)
|
|
accountDB, err := accounts.NewDatabase(accountDataSource, serverName)
|
|
if err != nil {
|
|
log.Panicf("Failed to setup account database(%s): %s", accountDataSource, err.Error())
|
|
}
|
|
|
|
routing.Setup(http.DefaultServeMux, http.DefaultClient, cfg, roomserverProducer, queryAPI, accountDB)
|
|
log.Fatal(http.ListenAndServe(bindAddr, nil))
|
|
}
|