From 85a7caffca8864359c4a179cf582c221f6ed5d00 Mon Sep 17 00:00:00 2001 From: Ingo Oppermann Date: Tue, 23 Aug 2022 09:37:18 +0300 Subject: [PATCH] Allow access to S3 filesystem via placeholder --- app/api/api.go | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/app/api/api.go b/app/api/api.go index 6e66f97a..876074da 100644 --- a/app/api/api.go +++ b/app/api/api.go @@ -423,8 +423,8 @@ func (a *api) start() error { baseS3FS.Host = cfg.Address } - if cfg.Storage.Memory.Auth.Enable { - baseS3FS.User = url.UserPassword(cfg.Storage.Memory.Auth.Username, cfg.Storage.Memory.Auth.Password) + if cfg.Storage.S3.Auth.Enable { + baseS3FS.User = url.UserPassword(cfg.Storage.S3.Auth.Username, cfg.Storage.S3.Auth.Password) } s3fs, err := fs.NewS3Filesystem(fs.S3Config{ @@ -485,6 +485,13 @@ func (a *api) start() error { a.replacer.RegisterTemplate("diskfs", a.diskfs.Base()) a.replacer.RegisterTemplate("memfs", a.memfs.Base()) + a.replacer.RegisterTemplate("fs:diskfs", a.diskfs.Base()) + a.replacer.RegisterTemplate("fs:memfs", a.memfs.Base()) + + if a.s3fs != nil { + a.replacer.RegisterTemplate("fs:s3fs", a.s3fs.Base()) + } + host, port, _ := gonet.SplitHostPort(cfg.RTMP.Address) if len(host) == 0 { host = "localhost"