mirror of
https://github.com/matrix-org/dendrite
synced 2024-11-03 22:49:10 +01:00
714959126b
* Fall back to postgres when parsing the database connection string for a URI schema fails * Fix behaviour so that it really tries postgres when URL parsing fails and it complains about unknown schema if it succeeds
52 lines
1.9 KiB
Go
52 lines
1.9 KiB
Go
// 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 storage
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"net/url"
|
|
|
|
"github.com/matrix-org/dendrite/common"
|
|
"github.com/matrix-org/dendrite/publicroomsapi/storage/postgres"
|
|
"github.com/matrix-org/dendrite/publicroomsapi/types"
|
|
"github.com/matrix-org/gomatrixserverlib"
|
|
)
|
|
|
|
type Database interface {
|
|
common.PartitionStorer
|
|
GetRoomVisibility(ctx context.Context, roomID string) (bool, error)
|
|
SetRoomVisibility(ctx context.Context, visible bool, roomID string) error
|
|
CountPublicRooms(ctx context.Context) (int64, error)
|
|
GetPublicRooms(ctx context.Context, offset int64, limit int16, filter string) ([]types.PublicRoom, error)
|
|
UpdateRoomFromEvents(ctx context.Context, eventsToAdd []gomatrixserverlib.Event, eventsToRemove []gomatrixserverlib.Event) error
|
|
UpdateRoomFromEvent(ctx context.Context, event gomatrixserverlib.Event) error
|
|
}
|
|
|
|
// NewPublicRoomsServerDatabase opens a database connection.
|
|
func NewPublicRoomsServerDatabase(dataSourceName string) (Database, error) {
|
|
uri, err := url.Parse(dataSourceName)
|
|
if err != nil {
|
|
// if the scheme doesn't match, fall back to postgres in case the config has
|
|
// postgres key=value connection strings
|
|
return postgres.NewPublicRoomsServerDatabase(dataSourceName)
|
|
}
|
|
switch uri.Scheme {
|
|
case "postgres":
|
|
return postgres.NewPublicRoomsServerDatabase(dataSourceName)
|
|
default:
|
|
return nil, errors.New("unknown schema")
|
|
}
|
|
}
|