diff options
Diffstat (limited to 'internal')
| -rw-r--r-- | internal/basecomponent/base.go | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/internal/basecomponent/base.go b/internal/basecomponent/base.go index 3781cea4..e86d9102 100644 --- a/internal/basecomponent/base.go +++ b/internal/basecomponent/base.go @@ -265,7 +265,15 @@ func setupNaffka(cfg *config.Dendrite) (sarama.Consumer, sarama.SyncProducer) { uri, err := url.Parse(string(cfg.Database.Naffka)) if err != nil || uri.Scheme == "file" { - db, err = sqlutil.Open(internal.SQLiteDriverName(), string(uri.Path), nil) + var cs string + if uri.Opaque != "" { // file:filename.db + cs = uri.Opaque + } else if uri.Path != "" { // file:///path/to/filename.db + cs = uri.Path + } else { + logrus.Panic("file uri has no filename") + } + db, err = sqlutil.Open(internal.SQLiteDriverName(), cs, nil) if err != nil { logrus.WithError(err).Panic("Failed to open naffka database") } |