apps/monibuca
1
0
Fork 0
mirror of https://github.com/langhuihui/monibuca.git synced 2025-12-24 13:48:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: add stop publish api

Browse Source
This commit is contained in:
langhuihui
2024-10-30 15:25:14 +08:00
parent 691f52ef4a
commit 5bd650bd53
11 changed files with 258 additions and 49 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
recoder.go
View File

@@ -1,11 +1,10 @@
package m7s
import (
"m7s.live/pro/pkg/config"
"os"
"path/filepath"
"time"
"m7s.live/pro/pkg/config"
"m7s.live/pro/pkg/task"
"m7s.live/pro/pkg"
@@ -80,14 +79,14 @@ func (p *RecordJob) Start() (err error) {
if _, ok := s.Records.Get(p.GetKey()); ok {
return pkg.ErrRecordSamePath
}
dir := p.FilePath
if p.Fragment == 0 || p.Append {
dir = filepath.Dir(p.FilePath)
}
p.SetDescription("filePath", p.FilePath)
if err = os.MkdirAll(dir, 0755); err != nil {
return
}
// dir := p.FilePath
// if p.Fragment == 0 || p.Append {
// dir = filepath.Dir(p.FilePath)
// }
// p.SetDescription("filePath", p.FilePath)
// if err = os.MkdirAll(dir, 0755); err != nil {
// return
// }
p.AddTask(p.recorder, p.Logger)
return
}