ADTS转RTMP协议方式传输音频包

增加目录候选功能
增强对实例的控制
2025-10-03 20:26:23 +08:00 · 2020-02-18 15:19:21 +08:00 · 2020-02-17 11:48:58 +08:00 · 2020-02-15 21:07:47 +08:00 · 2020-02-14 09:54:53 +08:00 · 2020-02-13 17:41:39 +08:00
33 changed files with 789 additions and 350 deletions
--- a/dashboard/dist/index.html
+++ b/dashboard/dist/index.html
@@ -1 +1 @@
-<!DOCTYPE html><html lang=en><head><meta charset=utf-8><meta http-equiv=X-UA-Compatible content="IE=edge"><meta name=viewport content="width=device-width,initial-scale=1"><link rel=icon href=/favicon.ico><title>Monibuca</title><script src=jessibuca/ajax.js></script><script src=jessibuca/renderer.js></script><link href=/css/app.ce470878.css rel=preload as=style><link href=/css/chunk-vendors.22ebf426.css rel=preload as=style><link href=/js/app.017fb959.js rel=preload as=script><link href=/js/chunk-vendors.ebc28a73.js rel=preload as=script><link href=/css/chunk-vendors.22ebf426.css rel=stylesheet><link href=/css/app.ce470878.css rel=stylesheet></head><body><noscript><strong>We're sorry but dashboard doesn't work properly without JavaScript enabled. Please enable it to continue.</strong></noscript><div id=app></div><script src=/js/chunk-vendors.ebc28a73.js></script><script src=/js/app.017fb959.js></script></body></html>
+<!DOCTYPE html><html lang=en><head><meta charset=utf-8><meta http-equiv=X-UA-Compatible content="IE=edge"><meta name=viewport content="width=device-width,initial-scale=1"><link rel=icon href=/favicon.ico><title>Monibuca</title><script src=jessibuca/ajax.js></script><script src=jessibuca/renderer.js></script><link href=/css/app.ce470878.css rel=preload as=style><link href=/css/chunk-vendors.22ebf426.css rel=preload as=style><link href=/js/app.16c0d7c9.js rel=preload as=script><link href=/js/chunk-vendors.ebc28a73.js rel=preload as=script><link href=/css/chunk-vendors.22ebf426.css rel=stylesheet><link href=/css/app.ce470878.css rel=stylesheet></head><body><noscript><strong>We're sorry but dashboard doesn't work properly without JavaScript enabled. Please enable it to continue.</strong></noscript><div id=app></div><script src=/js/chunk-vendors.ebc28a73.js></script><script src=/js/app.16c0d7c9.js></script></body></html>
--- a/dashboard/dist/jessibuca/renderer.js
+++ b/dashboard/dist/jessibuca/renderer.js
@@ -1,4 +1,6 @@
 window.AudioContext = window.AudioContext || window.webkitAudioContext;
 function Jessibuca(opt) {
    this.audioContext  = new window.AudioContext()
    this.canvasElement = opt.canvas;
    this.contextOptions = opt.contextOptions;
    this.videoBuffer = opt.videoBuffer || 1
@@ -65,9 +67,7 @@ function Jessibuca(opt) {
        }
    }
 };
-window.AudioContext = window.AudioContext || window.webkitAudioContext;
+function _unlock(context) {
 function _unlock() {
    var context = Jessibuca.prototype.audioContext = Jessibuca.prototype.audioContext || new window.AudioContext();
    context.resume();
    var source = context.createBufferSource();
    source.buffer = context.createBuffer(1, 1, 22050);
@@ -81,7 +81,7 @@ function _unlock() {
 // document.addEventListener("touchend", _unlock, true);
 Jessibuca.prototype.audioEnabled = function (flag) {
    if (flag) {
-        _unlock()
+        _unlock(this.audioContext)
        this.audioEnabled = function (flag) {
            if (flag) {
                this.audioContext.resume();
@@ -452,6 +452,7 @@ Jessibuca.prototype.close = function () {
    if (this.audioInterval) {
        clearInterval(this.audioInterval)
    }
    delete this.playAudio
    this.decoderWorker.postMessage({ cmd: "close" })
    this.contextGL.clear(this.contextGL.COLOR_BUFFER_BIT);
 }
--- a/dashboard/dist/js/app.017fb959.js
+++ b/dashboard/dist/js/app.017fb959.js
--- a/dashboard/dist/js/app.017fb959.js.map
+++ b/dashboard/dist/js/app.017fb959.js.map
--- a/dashboard/dist/js/app.16c0d7c9.js
+++ b/dashboard/dist/js/app.16c0d7c9.js
--- a/dashboard/dist/js/app.16c0d7c9.js.map
+++ b/dashboard/dist/js/app.16c0d7c9.js.map
--- a/dashboard/public/jessibuca/renderer.js
+++ b/dashboard/public/jessibuca/renderer.js
@@ -1,4 +1,6 @@
 window.AudioContext = window.AudioContext || window.webkitAudioContext;
 function Jessibuca(opt) {
    this.audioContext  = new window.AudioContext()
    this.canvasElement = opt.canvas;
    this.contextOptions = opt.contextOptions;
    this.videoBuffer = opt.videoBuffer || 1
@@ -65,9 +67,7 @@ function Jessibuca(opt) {
        }
    }
 };
-window.AudioContext = window.AudioContext || window.webkitAudioContext;
+function _unlock(context) {
 function _unlock() {
    var context = Jessibuca.prototype.audioContext = Jessibuca.prototype.audioContext || new window.AudioContext();
    context.resume();
    var source = context.createBufferSource();
    source.buffer = context.createBuffer(1, 1, 22050);
@@ -81,7 +81,7 @@ function _unlock() {
 // document.addEventListener("touchend", _unlock, true);
 Jessibuca.prototype.audioEnabled = function (flag) {
    if (flag) {
-        _unlock()
+        _unlock(this.audioContext)
        this.audioEnabled = function (flag) {
            if (flag) {
                this.audioContext.resume();
@@ -452,6 +452,7 @@ Jessibuca.prototype.close = function () {
    if (this.audioInterval) {
        clearInterval(this.audioInterval)
    }
    delete this.playAudio
    this.decoderWorker.postMessage({ cmd: "close" })
    this.contextGL.clear(this.contextGL.COLOR_BUFFER_BIT);
 }
--- a/dashboard/src/components/Jessibuca.vue
+++ b/dashboard/src/components/Jessibuca.vue
@@ -9,8 +9,8 @@
  >
    <canvas id="canvas" width="488" height="275" style="background: black" />
    <div slot="footer">
-      音频缓冲：
+<!--      音频缓冲：-->
-      <InputNumber v-model="audioBuffer" size="small"></InputNumber>
+<!--      <InputNumber v-model="audioBuffer" size="small"></InputNumber>-->
      <Button v-if="audioEnabled" @click="turnOff" icon="md-volume-off" />
      <Button v-else @click="turnOn" icon="md-volume-up"></Button>
    </div>
@@ -24,7 +24,7 @@ export default {
  data() {
    return {
      audioEnabled: false,
-      audioBuffer: 12,
+      // audioBuffer: 12,
      url: ""
    };
  },
@@ -32,9 +32,9 @@ export default {
    audioEnabled(value) {
      h5lc.audioEnabled(value);
    },
-    audioBuffer(v) {
+    // audioBuffer(v) {
-      h5lc.audioBuffer = v;
+    //   h5lc.audioBuffer = v;
-    }
+    // }
  },
  mounted() {
    h5lc = new window.Jessibuca({
--- a/main.go
+++ b/main.go
@@ -6,6 +6,7 @@ import (
 	"errors"
 	"flag"
 	"fmt"
 	"io"
 	"io/ioutil"
 	"log"
 	"mime"
@@ -14,6 +15,8 @@ import (
 	"os/exec"
 	"os/user"
 	"path"
 	"path/filepath"
 	"regexp"
 	"runtime"
 	"strings"
@@ -29,7 +32,7 @@ type InstanceDesc struct {
 	Config  string
 }
-var instances map[string]*InstanceDesc
+var instances = make(map[string]*InstanceDesc)
 var instancesDir string
 func main() {
@@ -44,10 +47,13 @@ func main() {
 	}
 	addr := flag.String("port", "8000", "http server port")
 	flag.Parse()
-	http.HandleFunc("/list", listInstance)
+	http.HandleFunc("/instance/listDir", listDir)
-	http.HandleFunc("/create", initInstance)
+	http.HandleFunc("/instance/import", importInstance)
-	http.HandleFunc("/upgrade/engine", upgradeEngine)
+	http.HandleFunc("/instance/updateConfig", updateConfig)
-	http.HandleFunc("/restart/instance", restartInstance)
+	http.HandleFunc("/instance/list", listInstance)
 	http.HandleFunc("/instance/create", initInstance)
 	http.HandleFunc("/instance/restart", restartInstance)
 	http.HandleFunc("/instance/shutdown", shutdownInstance)
 	http.HandleFunc("/", website)
 	fmt.Printf("start listen at %s", *addr)
 	if err := http.ListenAndServe(":"+*addr, nil); err != nil {
@@ -55,6 +61,98 @@ func main() {
 	}
 }
 func listDir(w http.ResponseWriter, r *http.Request) {
 	if input := r.URL.Query().Get("input"); input != "" {
 		if dir, err := os.Open(filepath.Dir(input)); err == nil {
 			var dirs []string
 			if infos, err := dir.Readdir(0); err == nil {
 				for _, info := range infos {
 					if info.IsDir() {
 						dirs = append(dirs, info.Name())
 					}
 				}
 				if bytes, err := json.Marshal(dirs); err == nil {
 					w.Write(bytes)
 				}
 			}
 		}
 	}
 }
 func importInstance(w http.ResponseWriter, r *http.Request) {
 	var e error
 	defer func() {
 		result := "success"
 		if e != nil {
 			result = e.Error()
 		}
 		w.Write([]byte(result))
 	}()
 	name := r.URL.Query().Get("name")
 	if importPath := r.URL.Query().Get("path"); importPath != "" {
 		if strings.HasSuffix(importPath, "/") {
 			importPath = importPath[:len(importPath)-1]
 		}
 		f, err := os.Open(importPath)
 		if e = err; err != nil {
 			return
 		}
 		children, err := f.Readdir(0)
 		if e = err; err == nil {
 			var hasMain, hasConfig, hasMod, hasRestart bool
 			for _, child := range children {
 				switch child.Name() {
 				case "main.go":
 					hasMain = true
 				case "config.toml":
 					hasConfig = true
 				case "go.mod":
 					hasMod = true
 				case "restart.sh":
 					hasRestart = true
 				}
 			}
 			if hasMain && hasConfig && hasMod && hasRestart {
 				if name == "" {
 					_, name = path.Split(importPath)
 				}
 				config, err := ioutil.ReadFile(path.Join(importPath, "config.toml"))
 				if e = err; err != nil {
 					return
 				}
 				mainGo, err := ioutil.ReadFile(path.Join(importPath, "main.go"))
 				if e = err; err != nil {
 					return
 				}
 				reg, err := regexp.Compile("_ \"(.+)\"")
 				if e = err; err != nil {
 					return
 				}
 				instances[name] = &InstanceDesc{
 					Name:    name,
 					Path:    importPath,
 					Plugins: nil,
 					Config:  string(config),
 				}
 				for _, m := range reg.FindAllStringSubmatch(string(mainGo), -1) {
 					instances[name].Plugins = append(instances[name].Plugins, m[1])
 				}
 				var file *os.File
 				file, e = os.OpenFile(path.Join(instancesDir, name+".toml"), os.O_CREATE|os.O_TRUNC|os.O_WRONLY, 0666)
 				if err != nil {
 					return
 				}
 				tomlEncoder := toml.NewEncoder(file)
 				e = tomlEncoder.Encode(instances[name])
 			} else {
 				e = errors.New("路径中缺少文件")
 			}
 		}
 	} else {
 		w.Write([]byte("参数错误"))
 	}
 }
 func readInstances() error {
 	if homeDir, err := Home(); err == nil {
 		instancesDir = path.Join(homeDir, ".monibuca")
@@ -140,31 +238,50 @@ func initInstance(w http.ResponseWriter, r *http.Request) {
 	}
 	instances[instanceDesc.Name] = instanceDesc
 }
-func upgradeEngine(w http.ResponseWriter, r *http.Request) {
+func shutdownInstance(w http.ResponseWriter, r *http.Request) {
 	sse := util.NewSSE(w, r.Context())
 	cmd := exec.Command("go", "get", "-u", "github.com/langhuihui/monibuca/monica")
 	instanceName := r.URL.Query().Get("instance")
-	cmd.Dir = instances[instanceName].Path
+	if instance, ok := instances[instanceName]; ok {
-	err := sse.WriteExec(cmd)
+		if err := instance.command("kill", "-9", "`cat pid`").Run(); err == nil {
-	if err != nil {
+			w.Write([]byte("success"))
-		sse.Write([]byte(err.Error()))
+		} else {
 			w.Write([]byte(err.Error()))
 		}
 	} else {
 		w.Write([]byte("no such instance"))
 	}
 }
 func restartInstance(w http.ResponseWriter, r *http.Request) {
 	sse := util.NewSSE(w, r.Context())
 	instanceName := r.URL.Query().Get("instance")
-	cmd := exec.Command("sh", "restart.sh")
+	needUpdate := r.URL.Query().Get("update") != ""
-	cmd.Dir = path.Join(instancesDir, instanceName)
+	needBuild := r.URL.Query().Get("build") != ""
-	cmd.Stderr = sse
+	if instance, ok := instances[instanceName]; ok {
-	cmd.Stdout = sse
+		if needUpdate {
-	err := cmd.Start()
+			if err := sse.WriteExec(instance.command("go", "get", "-u")); err != nil {
-	if err != nil {
+				sse.WriteEvent("failed", []byte(err.Error()))
-		sse.Write([]byte(err.Error()))
+				return
 			}
 		}
 		if needBuild {
 			if err := sse.WriteExec(instance.command("go", "build")); err != nil {
 				sse.WriteEvent("failed", []byte(err.Error()))
 				return
 			}
 		}
 		if err := sse.WriteExec(instance.command("sh", "restart.sh")); err != nil {
 			sse.WriteEvent("failed", []byte(err.Error()))
 			return
 		}
 		sse.Write([]byte("success"))
 	} else {
 		sse.WriteEvent("failed", []byte("no such instance"))
 	}
 }
-func (p *InstanceDesc) writeExecSSE(sse *util.SSE, cmd *exec.Cmd) error {
+
 func (p *InstanceDesc) command(name string, args ...string) (cmd *exec.Cmd) {
 	cmd = exec.Command(name, args...)
 	cmd.Dir = p.Path
-	return sse.WriteExec(cmd)
+	return
 }
 func (p *InstanceDesc) createDir(sse *util.SSE, clearDir bool) (err error) {
 	if clearDir {
@@ -200,32 +317,45 @@ func main(){
 		return
 	}
 	sse.WriteEvent("step", []byte("3:文件创建成功！"))
-	err = p.writeExecSSE(sse, exec.Command("go", "mod", "init", p.Name))
+	err = sse.WriteExec(p.command("go", "mod", "init", p.Name))
 	if err != nil {
 		return
 	}
 	sse.WriteEvent("step", []byte("4:go mod 初始化完成！"))
-	err = p.writeExecSSE(sse, exec.Command("go", "build"))
+	err = sse.WriteExec(p.command("go", "build"))
 	if err != nil {
 		return
 	}
 	sse.WriteEvent("step", []byte("5:go build 成功！"))
 	build.Reset()
-	build.WriteString("kill -9 `cat pid`\nnohup ./")
+	build.WriteString("kill -9 `cat pid`\n ./")
 	binFile := strings.TrimSuffix(p.Path, "/")
 	_, binFile = path.Split(binFile)
 	build.WriteString(binFile)
-	build.WriteString(" > log.txt & echo $! > pid\n")
+	build.WriteString(" & echo $! > pid\n")
 	err = ioutil.WriteFile(path.Join(p.Path, "restart.sh"), build.Bytes(), 0777)
 	if err != nil {
 		return
 	}
-	cmd := exec.Command("sh", "restart.sh")
+	return sse.WriteExec(p.command("sh", "restart.sh"))
-	cmd.Dir = p.Path
+}
-	cmd.Stderr = sse
+func updateConfig(w http.ResponseWriter, r *http.Request) {
-	cmd.Stdout = sse
+	instanceName := r.URL.Query().Get("instance")
-	err = cmd.Start()
+	if instance, ok := instances[instanceName]; ok {
-	return
+		f, err := os.OpenFile(path.Join(instance.Path, "config.toml"), os.O_WRONLY|os.O_TRUNC, 0666)
 		if err != nil {
 			w.Write([]byte(err.Error()))
 			return
 		}
 		_, err = io.Copy(f, r.Body)
 		if err != nil {
 			w.Write([]byte(err.Error()))
 			return
 		}
 		w.Write([]byte("success"))
 	} else {
 		w.Write([]byte("no such instance"))
 	}
 }
 func Home() (string, error) {
 	user, err := user.Current()
--- a/monica/avformat/avpacket.go
+++ b/monica/avformat/avpacket.go
@@ -38,7 +38,7 @@ func (av *AVPacket) ADTS2ASC() (tagPacket *AVPacket) {
 	tagPacket = NewAVPacket(FLV_TAG_TYPE_AUDIO)
 	tagPacket.Payload = ADTSToAudioSpecificConfig(av.Payload)
 	tagPacket.IsAACSequence = true
-	ADTSLength := 7 + (int(av.Payload[1]&1) << 1)
+	ADTSLength := 7 + ((1 - int(av.Payload[1]&1)) << 1)
 	if len(av.Payload) > ADTSLength {
 		av.Payload[0] = 0xAF
 		av.Payload[1] = 0x01 //raw AAC
--- a/monica/index.go
+++ b/monica/index.go
@@ -4,12 +4,17 @@ import (
 	"encoding/json"
 	"io/ioutil"
 	"log"
 	"time"
 	"github.com/BurntSushi/toml"
 )
 var ConfigRaw []byte
-var Version = "0.2.1"
+var Version = "0.2.8"
 var EngineInfo = &struct {
 	Version   string
 	StartTime time.Time
 }{Version, time.Now()}
 func Run(configFile string) (err error) {
 	log.Printf("start monibuca version:%s", Version)
--- a/plugins/QoS/index.go
+++ b/plugins/QoS/index.go
@@ -1,28 +1,27 @@
 package QoS
 import (
 	"strings"
 	. "github.com/langhuihui/monibuca/monica"
 )
-var (
+// var (
-	selectMap = map[string][]string{
+// 	selectMap = map[string][]string{
-		"low":    {"low", "medium", "high"},
+// 		"low":    {"low", "medium", "high"},
-		"medium": {"medium", "low", "high"},
+// 		"medium": {"medium", "low", "high"},
-		"high":   {"high", "medium", "low"},
+// 		"high":   {"high", "medium", "low"},
-	}
+// 	}
-)
+// )
-func getQualityName(name string, qualityLevel string) string {
+// func getQualityName(name string, qualityLevel string) string {
-	if qualityLevel == "" {
+// 	for _, l := range selectMap[qualityLevel] {
-		return name
+// 		if _, ok := AllRoom.Load(name + "/" + l); ok {
-	}
+// 			return name + "/" + l
-	for _, l := range selectMap[qualityLevel] {
+// 		}
-		if _, ok := AllRoom.Load(name + "/" + l); ok {
+// 	}
-			return name + "/" + l
+// 	return name + "/" + qualityLevel
-		}
+// }
 	}
 	return name + "/" + qualityLevel
 }
 var config = struct {
 	Suffix []string
@@ -39,8 +38,23 @@ func init() {
 func run() {
 	OnDropHooks.AddHook(func(s *OutputStream) {
 		if s.TotalDrop > s.TotalPacket>>2 {
-			//TODO
+			var newStreamPath = ""
-			//s.Control<-&ChangeRoomCmd{s,AllRoom.Get()}
+			for i, suf := range config.Suffix {
 				if strings.HasSuffix(s.StreamPath, suf) {
 					if i < len(config.Suffix)-1 {
 						newStreamPath = s.StreamPath + "/" + config.Suffix[i+1]
 						break
 					}
 				} else {
 					newStreamPath = s.StreamPath + "/" + suf
 					break
 				}
 			}
 			if newStreamPath != "" {
 				if _, ok := AllRoom.Load(newStreamPath); ok {
 					s.Control <- &ChangeRoomCmd{s, AllRoom.Get(newStreamPath)}
 				}
 			}
 		}
 	})
 }
--- a/plugins/gateway/index.go
+++ b/plugins/gateway/index.go
@@ -15,8 +15,8 @@ import (
 )
 var (
-	config = new(ListenerConfig)
+	config        = new(ListenerConfig)
-
+	startTime     = time.Now()
 	dashboardPath string
 )
@@ -99,7 +99,8 @@ func summary(w http.ResponseWriter, r *http.Request) {
 	}
 }
 func sysInfo(w http.ResponseWriter, r *http.Request) {
-	bytes, err := json.Marshal(&struct{ Version string }{Version: Version})
+	w.Header().Set("Access-Control-Allow-Origin", "*")
 	bytes, err := json.Marshal(EngineInfo)
 	if err == nil {
 		_, err = w.Write(bytes)
 	}
--- a/plugins/logrotate/index.go
+++ b/plugins/logrotate/index.go
@@ -0,0 +1,78 @@
 package logrotate
 import (
 	"fmt"
 	. "github.com/langhuihui/monibuca/monica"
 	"log"
 	"os"
 	"path"
 	"time"
 )
 var config = new(LogRotate)
 type LogRotate struct {
 	Path        string
 	Size        int64
 	Days        int
 	file        *os.File
 	currentSize int64
 	createTime  time.Time
 	hours       float64
 	splitFunc   func() bool
 }
 func init() {
 	InstallPlugin(&PluginConfig{
 		Name:   "LogRotate",
 		Type:   PLUGIN_HOOK,
 		Config: config,
 		Run:    run,
 	})
 }
 func run() {
 	if config.Size > 0 {
 		config.splitFunc = config.splitBySize
 	} else {
 		if config.Days == 0 {
 			config.Days = 1
 		}
 		config.hours = float64(config.Days) * 24
 		config.splitFunc = config.splitByTime
 	}
 	config.createTime = time.Now()
 	err := os.MkdirAll(config.Path, 0666)
 	config.file, err = os.OpenFile(path.Join(config.Path, fmt.Sprintf("%s.log", config.createTime.Format("2006-01-02T15:04:05"))), os.O_TRUNC|os.O_WRONLY|os.O_CREATE, 0666)
 	if err == nil {
 		stat, _ := config.file.Stat()
 		config.currentSize = stat.Size()
 		AddWriter(config)
 	} else {
 		log.Println(err)
 	}
 }
 func (l *LogRotate) splitBySize() bool {
 	return l.currentSize >= l.Size
 }
 func (l *LogRotate) splitByTime() bool {
 	return time.Since(l.createTime).Hours() > l.hours
 }
 func (l *LogRotate) Write(data []byte) (n int, err error) {
 	n, err = l.file.Write(data)
 	l.currentSize += int64(n)
 	if err == nil {
 		if l.splitFunc() {
 			l.createTime = time.Now()
 			if file, err := os.OpenFile(path.Join(l.Path, fmt.Sprintf("%s.log", l.createTime.Format("2006-01-02T15:04:05"))), os.O_TRUNC|os.O_WRONLY|os.O_CREATE, 0666); err == nil {
 				l.file = file
 				l.currentSize = 0
 			}
 		}
 	}
 	return
 }
 //func (l *LogRotate) FindLog(grep string) string{
 //	cmd:=exec.Command("grep",fmt.Sprintf("\"%s\"",grep),l.Path)
 //	err:=cmd.Run()
 //}
--- a/pm/dist/index.html
+++ b/pm/dist/index.html
@@ -1 +1 @@
-<!DOCTYPE html><html lang=en><head><meta charset=utf-8><meta http-equiv=X-UA-Compatible content="IE=edge"><meta name=viewport content="width=device-width,initial-scale=1"><link rel=icon href=/favicon.ico><title>Monibuca Instance Manager</title><script src=ajax.js></script><link href=/css/app.200d2f8f.css rel=preload as=style><link href=/css/chunk-vendors.22ebf426.css rel=preload as=style><link href=/js/app.fd72a180.js rel=preload as=script><link href=/js/chunk-vendors.6b87e1b5.js rel=preload as=script><link href=/css/chunk-vendors.22ebf426.css rel=stylesheet><link href=/css/app.200d2f8f.css rel=stylesheet></head><body><noscript><strong>We're sorry but pm doesn't work properly without JavaScript enabled. Please enable it to continue.</strong></noscript><div id=app></div><script src=/js/chunk-vendors.6b87e1b5.js></script><script src=/js/app.fd72a180.js></script></body></html>
+<!DOCTYPE html><html lang=en><head><meta charset=utf-8><meta http-equiv=X-UA-Compatible content="IE=edge"><meta name=viewport content="width=device-width,initial-scale=1"><link rel=icon href=/favicon.ico><title>Monibuca Instance Manager</title><script src=ajax.js></script><link href=/css/app.200d2f8f.css rel=preload as=style><link href=/css/chunk-vendors.22ebf426.css rel=preload as=style><link href=/js/app.13e2de5f.js rel=preload as=script><link href=/js/chunk-vendors.2e3b192a.js rel=preload as=script><link href=/css/chunk-vendors.22ebf426.css rel=stylesheet><link href=/css/app.200d2f8f.css rel=stylesheet></head><body><noscript><strong>We're sorry but pm doesn't work properly without JavaScript enabled. Please enable it to continue.</strong></noscript><div id=app></div><script src=/js/chunk-vendors.2e3b192a.js></script><script src=/js/app.13e2de5f.js></script></body></html>
--- a/pm/dist/js/app.13e2de5f.js
+++ b/pm/dist/js/app.13e2de5f.js
--- a/pm/dist/js/app.13e2de5f.js.map
+++ b/pm/dist/js/app.13e2de5f.js.map
--- a/pm/dist/js/app.fd72a180.js
+++ b/pm/dist/js/app.fd72a180.js
--- a/pm/dist/js/app.fd72a180.js.map
+++ b/pm/dist/js/app.fd72a180.js.map
--- a/pm/dist/js/chunk-vendors.2e3b192a.js
+++ b/pm/dist/js/chunk-vendors.2e3b192a.js
--- a/pm/dist/js/chunk-vendors.2e3b192a.js.map
+++ b/pm/dist/js/chunk-vendors.2e3b192a.js.map
--- a/pm/dist/js/chunk-vendors.6b87e1b5.js.map
+++ b/pm/dist/js/chunk-vendors.6b87e1b5.js.map
--- a/pm/package-lock.json
+++ b/pm/package-lock.json
@@ -979,6 +979,11 @@
        "@hapi/hoek": "8.5.0"
      }
    },
    "@iarna/toml": {
      "version": "2.2.3",
      "resolved": "https://registry.npm.taobao.org/@iarna/toml/download/@iarna/toml-2.2.3.tgz",
      "integrity": "sha1-8GC/bqr65NVqfaxhiYCDiwaW4qs="
    },
    "@intervolga/optimize-cssnano-plugin": {
      "version": "1.0.6",
      "resolved": "https://registry.npm.taobao.org/@intervolga/optimize-cssnano-plugin/download/@intervolga/optimize-cssnano-plugin-1.0.6.tgz",
--- a/pm/package.json
+++ b/pm/package.json
@@ -8,6 +8,7 @@
    "lint": "vue-cli-service lint"
  },
  "dependencies": {
    "@iarna/toml": "^2.2.3",
    "core-js": "^3.4.4",
    "view-design": "^4.0.0",
    "vue": "^2.6.10",
@@ -37,7 +38,7 @@
      "plugin:vue/essential",
      "eslint:recommended"
    ],
-    "rules": {},
+    "rules": {"no-console": "off"},
    "parserOptions": {
      "parser": "babel-eslint"
    }
--- a/pm/src/components/CreateInstance.vue
+++ b/pm/src/components/CreateInstance.vue
@@ -1,5 +1,5 @@
 <template>
-    <Modal v-bind="$attrs" v-on="$listeners" :title="info.Path">
+    <Modal v-bind="$attrs" v-on="$listeners" :title="info && info.Path">
        <Steps :current="currentStep" size="small" :status="status">
            <Step title="解析请求"></Step>
            <Step title="创建目录"></Step>
@@ -14,8 +14,7 @@
        </div>
        <div slot="footer">
            <Checkbox v-model="clearDir">安装前清空目录</Checkbox>
-            <Button type="primary" @click="start">开始</Button>
+            <Button type="primary" @click="start" :loading="status=='process'">开始</Button>
            <Button type="success" @click="close" v-if="status=='finish'">完成</Button>
        </div>
    </Modal>
 </template>
@@ -27,36 +26,37 @@ export default {
    props: {
        info: Object
    },
-    methods:{
+    methods: {
-        start(){
+        start() {
-             eventSource = new EventSource(
+            this.status = "process";
-                    "/create?info=" + JSON.stringify(this.info)+(this.clearDir?"&clear=true":"")
+            eventSource = new EventSource(
-                );
+                "/instance/create?info=" +
-                eventSource.onopen = () => (this.log = "");
+                    JSON.stringify(this.info) +
-                eventSource.onmessage = evt => {
+                    (this.clearDir ? "&clear=true" : "")
-                    this.log += evt.data + "\n";
+            );
-                    if (evt.data == "success") {
+            eventSource.onopen = () => (this.log = "");
-                        this.status = "finish";
+            eventSource.onmessage = evt => {
-                        eventSource.close();
+                this.log += evt.data + "\n";
-                    }
+                if (evt.data == "success") {
-                };
+                    this.status = "finish";
                eventSource.addEventListener("exception", evt => {
                    this.log += evt.data + "\n";
                    this.status = "error";
                    eventSource.close();
-                });
+                }
-                eventSource.addEventListener("step", evt => {
+            };
-                    let [step, msg] = evt.data.split(":");
+            eventSource.addEventListener("exception", evt => {
-                    this.currentStep = step | 0;
+                this.log += evt.data + "\n";
-                    this.log += msg + "\n";
+                this.status = "error";
-                });
+                eventSource.close();
-        },close(){
+            });
-            this.$Modal.remove()
+            eventSource.addEventListener("step", evt => {
-        }
+                let [step, msg] = evt.data.split(":");
                this.currentStep = step | 0;
                this.log += msg + "\n";
            });
        },
    },
-    
+
    data() {
-        return { clearDir: true, currentStep: 0, log: "", status: "process" };
+        return { clearDir: true, currentStep: 0, log: "", status: "wait" };
    }
 };
 </script>
--- a/pm/src/components/HelloWorld.vue
+++ b/pm/src/components/HelloWorld.vue
@@ -1,60 +0,0 @@
 <template>
  <div class="hello">
    <h1>{{ msg }}</h1>
    <p>
      For a guide and recipes on how to configure / customize this project,<br>
      check out the
      <a href="https://cli.vuejs.org" target="_blank" rel="noopener">vue-cli documentation</a>.
    </p>
    <h3>Installed CLI Plugins</h3>
    <ul>
      <li><a href="https://github.com/vuejs/vue-cli/tree/dev/packages/%40vue/cli-plugin-babel" target="_blank" rel="noopener">babel</a></li>
      <li><a href="https://github.com/vuejs/vue-cli/tree/dev/packages/%40vue/cli-plugin-router" target="_blank" rel="noopener">router</a></li>
      <li><a href="https://github.com/vuejs/vue-cli/tree/dev/packages/%40vue/cli-plugin-vuex" target="_blank" rel="noopener">vuex</a></li>
      <li><a href="https://github.com/vuejs/vue-cli/tree/dev/packages/%40vue/cli-plugin-eslint" target="_blank" rel="noopener">eslint</a></li>
    </ul>
    <h3>Essential Links</h3>
    <ul>
      <li><a href="https://vuejs.org" target="_blank" rel="noopener">Core Docs</a></li>
      <li><a href="https://forum.vuejs.org" target="_blank" rel="noopener">Forum</a></li>
      <li><a href="https://chat.vuejs.org" target="_blank" rel="noopener">Community Chat</a></li>
      <li><a href="https://twitter.com/vuejs" target="_blank" rel="noopener">Twitter</a></li>
      <li><a href="https://news.vuejs.org" target="_blank" rel="noopener">News</a></li>
    </ul>
    <h3>Ecosystem</h3>
    <ul>
      <li><a href="https://router.vuejs.org" target="_blank" rel="noopener">vue-router</a></li>
      <li><a href="https://vuex.vuejs.org" target="_blank" rel="noopener">vuex</a></li>
      <li><a href="https://github.com/vuejs/vue-devtools#vue-devtools" target="_blank" rel="noopener">vue-devtools</a></li>
      <li><a href="https://vue-loader.vuejs.org" target="_blank" rel="noopener">vue-loader</a></li>
      <li><a href="https://github.com/vuejs/awesome-vue" target="_blank" rel="noopener">awesome-vue</a></li>
    </ul>
  </div>
 </template>
 <script>
 export default {
  name: 'HelloWorld',
  props: {
    msg: String
  }
 }
 </script>
 <!-- Add "scoped" attribute to limit CSS to this component only -->
 <style scoped lang="less">
 h3 {
  margin: 40px 0 0;
 }
 ul {
  list-style-type: none;
  padding: 0;
 }
 li {
  display: inline-block;
  margin: 0 10px;
 }
 a {
  color: #42b983;
 }
 </style>
--- a/pm/src/components/ImportInstance.vue
+++ b/pm/src/components/ImportInstance.vue
@@ -0,0 +1,47 @@
 <template>
    <div>
        <PathSelector v-model="instancePath" placeholder="输入实例所在的路径"></PathSelector>
        <i-input style="width: 300px;margin:40px auto" v-model="instanceName" :placeholder="defaultInstanceName" search enter-button="Import" @on-search="doImport">
            <span slot="prepend">实例名称</span>
        </i-input>
    </div>
 </template>
 <script>
    import PathSelector from "./PathSelector"
    export default {
        name: "ImportInstance",
        components:{
            PathSelector
        },
        data(){
            return {
                instancePath:"",
                instanceName:""
            }
        },
        computed:{
            defaultInstanceName(){
                let path = this.instancePath.replace(/\\/g,"/")
                let s = path.split("/")
                if(path.endsWith("/")) s.pop()
                return s.pop()
            }
        },
        methods:{
            doImport(){
                window.ajax.get("/instance/import?path="+this.instancePath+"&name="+this.instanceName).then(x=>{
                    if(x=="success"){
                        this.$Message.success("导入成功！")
                    }else{
                        this.$Message.error(x)
                    }
                })
            }
        }
    }
 </script>
 <style scoped>
 </style>
--- a/pm/src/components/InstanceList.vue
+++ b/pm/src/components/InstanceList.vue
@@ -0,0 +1,156 @@
 <template>
    <div>
        <List border>
            <ListItem v-for="item in instances" :key="item.Name">
                <ListItemMeta :title="item.Name" :description="item.Path"></ListItemMeta>
                <template v-if="item.Info.StartTime">
                    引擎版本：{{item.Info.Version}} <br>启动时间：
                    <StartTime :value="item.Info.StartTime"></StartTime>
                </template>
                <template v-else>{{item.Info}}</template>
                <template slot="action">
                    <li @click="changeConfig(item)">
                        <Icon type="ios-settings"/>
                        修改配置
                    </li>
                    <li v-if="hasGateway(item)" @click="openGateway(item)">
                        <Icon type="md-browsers"/>
                        管理界面
                    </li>
                    <li @click="currentItem=item,showRestart=true">
                        <Icon type="ios-refresh"/>
                        重启
                    </li>
                    <li @click="shutdown(item)">
                        <Icon type="ios-power"/>
                        关闭
                    </li>
                </template>
            </ListItem>
        </List>
        <Modal v-model="showRestart" title="重启选项" @on-ok="restart">
            <Checkbox v-model="update">go get -u</Checkbox>
            <Checkbox v-model="build">go build</Checkbox>
        </Modal>
        <Modal v-model="showConfig" title="修改实例配置" @on-ok="submitConfigChange">
            <i-input type="textarea" v-model="currentConfig" :rows="20"></i-input>
        </Modal>
    </div>
 </template>
 <script>
    import toml from "@iarna/toml"
    import StartTime from "./StartTime"
    export default {
        name: "InstanceList",
        components: {StartTime},
        data() {
            return {
                instances: [],
                showRestart: false,
                update: false,
                build: false,
                showConfig: false,
                currentItem: null,
                currentConfig: ""
            }
        },
        mounted() {
            window.ajax.getJSON("/instance/list").then(x => {
                for (let name in x) {
                    let instance = x[name]
                    instance.Config = toml.parse(instance.Config)
                    if (this.hasGateway(instance)) {
                        window.ajax.getJSON(this.gateWayHref(instance) + "/api/sysInfo").then(x => {
                            instance.Info = x
                        }).catch(() => {
                            instance.Info = "无法访问实例"
                        })
                    } else {
                        instance.Info = "实例未配置网关插件"
                    }
                    this.instances.push(instance)
                }
                // this.instances = x;
            });
        },
        methods: {
            changeConfig(item) {
                this.showConfig = true
                this.currentItem = item
                this.currentConfig = toml.stringify(item.Config)
            },
            submitConfigChange() {
                try {
                    this.currentItem.Config = toml.parse(this.currentConfig)
                    window.ajax.post("/instance/updateConfig?instance=" + this.currentItem.Name, this.currentConfig).then(x => {
                        if (x == "success") {
                            this.$Message.success("更新成功！")
                        } else {
                            this.$Message.error(x)
                        }
                    }).catch(e => {
                        this.$Message.error(e)
                    })
                } catch (e) {
                    this.$Message.error(e)
                }
            },
            openGateway(item) {
                window.open(this.gateWayHref(item), '_blank')
            },
            hasGateway(item) {
                return item.Config.Plugins.hasOwnProperty("GateWay")
            },
            gateWayHref(item) {
                return "http://" + location.hostname + ":" + item.Config.Plugins.GateWay.ListenAddr.split(":").pop()
            },
            restart() {
                let item = this.currentItem
                const msg = this.$Message.loading({
                    content: 'restart ' + item.Name + '...',
                    duration: 0
                });
                let arg = item.Name
                if (this.update) {
                    arg += "&update=true"
                }
                if (this.build) {
                    arg += "&build=true"
                }
                const es = new EventSource("/instance/restart?instance=" + arg)
                es.onmessage = evt => {
                    if (evt.data == "success") {
                        this.$Message.success("重启成功！")
                        msg()
                    } else {
                        this.$Message.info(evt.data)
                    }
                }
                es.addEventListener("failed", evt => {
                    this.$Message.error(evt.data)
                    msg()
                })
                es.onerror = e => {
                    if (e && e.toString()) this.$Message.error(e);
                    msg()
                    es.close()
                }
            },
            shutdown(item) {
                window.ajax.get("/instance/shutdown?instance=" + item.Name).then(x => {
                    if (x == "success") {
                        this.$Message.success("已关闭实例")
                    } else {
                        this.$Message.error(x)
                    }
                })
            },
        }
    }
 </script>
 <style scoped>
 </style>
--- a/pm/src/components/PathSelector.vue
+++ b/pm/src/components/PathSelector.vue
@@ -0,0 +1,66 @@
 <template>
    <div>
        <i-input ref="input" v-bind="$attrs" v-on="$listeners" clearable @on-change="onInput">
            <Button slot="prepend" icon="md-arrow-round-up" @click="goUp"></Button>
        </i-input>
        <CellGroup @on-click="onSelectCand">
            <Cell v-for="item in candidate" :key="item" :title="item" :name="item"></Cell>
        </CellGroup>
    </div>
 </template>
 <script>
    export default {
        name: "PathSelector",
        data() {
            return {
                candidate: [],
                lastInput: "",
                searching: false,
            }
        },
        methods: {
            dir(){
                let paths = this.$refs.input.value.split("/");
                paths.pop();
                return paths.join("/");
            },
            goUp() {
                this.lastInput = this.$attrs.value = this.dir()
                this.$refs.input.$emit('input', this.$attrs.value)
                this.search(this.lastInput)
            },
            onSelectCand(name) {
                this.lastInput = this.$attrs.value = this.dir()+"/"+name+"/"
                this.$refs.input.$emit('input', this.$attrs.value)
                this.search(this.lastInput)
            },
            onInput(evt) {
                this.lastInput = evt.target.value
                this.search(this.lastInput)
            },
            search(v) {
                if(this.searching)return
                window.ajax.getJSON("/instance/listDir?input=" + v).then(x => {
                    this.candidate = x
                    if (this.lastInput != v) {
                        this.search(this.lastInput)
                    }else{
                        this.searching = false
                    }
                }).catch(e => {
                    this.$Message.error(e)
                    if (this.lastInput != v) {
                        this.search(this.lastInput)
                    }else{
                        this.searching = false
                    }
                })
            }
        }
    }
 </script>
 <style scoped>
 </style>
--- a/pm/src/components/StartTime.vue
+++ b/pm/src/components/StartTime.vue
@@ -0,0 +1,18 @@
 <template>
    <Poptip trigger="hover" :content="'⌚️'+ new Date(value).toLocaleString()">
        <Time :time="new Date(value)"></Time>
    </Poptip>
 </template>
 <script>
    export default {
        name: "StartTime",
        props:{
            value:String
        }
    }
 </script>
 <style scoped>
 </style>
--- a/pm/src/store/index.js
+++ b/pm/src/store/index.js
@@ -1,10 +1,40 @@
 import Vue from 'vue'
 import Vuex from 'vuex'
 Vue.use(Vuex)
 export default new Vuex.Store({
  state: {
    defaultPlugins:{
      GateWay:[
          "gateway",'ListenAddr = ":8081"',"网关插件，提供各种API服务，包括信息采集和控制等，控制台页面展示（静态资源服务器）"
      ],
      LogRotate:[
          "logrotate",`Path = "log"
 Size = 0
 Days = 1`,"日志分割插件，Size 代表按照字节数分割，0代表采用时间分割"
      ],
      Jessica:[
          "jessica",'ListenAddr = ":8080"',"WebSocket协议订阅，采用私有协议，搭配Jessibuca播放器实现低延时播放"
      ],
      Cluster:[
          "cluster",'Master = "localhost:2019"\nListenAddr = ":2019"',"集群插件，可以实现级联转发功能，Master代表上游服务器，ListenAdder代表源服务器监听端口，可只配置一项"
      ],
      RTMP:[
          "rtmp",'ListenAddr = ":1935"',"rtmp协议实现，基本发布和订阅功能"
      ],
      RecordFlv:[
          "record",'Path="./resource"',"录制视频流到flv文件"
      ],
      HDL:[
          "HDL",'ListenAddr = ":2020"',"Http-flv格式实现，可以对接CDN厂商进行回源拉流"
      ],
      Auth:[
          "auth",'Key = "www.monibuca.com"',"一个鉴权验证模块"
      ],
      Qos:[
          "QoS",'Suffix = ["high","medium","low"]',"质量控制插件，可以动态改变订阅的不同的质量的流"
      ]
    }
  },
  mutations: {
  },
--- a/pm/src/views/Home.vue
+++ b/pm/src/views/Home.vue
@@ -1,18 +0,0 @@
 <template>
  <div class="home">
    <img alt="Vue logo" src="../assets/logo.png">
    <HelloWorld msg="Welcome to Your Vue.js App"/>
  </div>
 </template>
 <script>
 // @ is an alias to /src
 import HelloWorld from '@/components/HelloWorld.vue'
 export default {
  name: 'home',
  components: {
    HelloWorld
  }
 }
 </script>
--- a/pm/src/views/Instances.vue
+++ b/pm/src/views/Instances.vue
@@ -4,11 +4,7 @@
        <Content class="content">
            <Tabs value="name1">
                <TabPane label="实例" name="name1">
-                    <List border>
+                    <InstanceList></InstanceList>
                        <ListItem v-for="item in instances" :key="item.Name">
                            <ListItemMeta :title="item.Name" :description="item.Path"></ListItemMeta>
                        </ListItem>
                    </List>
                </TabPane>
                <TabPane label="创建" name="name2">
                    <Steps :current="createStep">
@@ -17,25 +13,23 @@
                        <Step title="完成" content="完成实例创建"></Step>
                    </Steps>
                    <div style="margin:50px;width:auto">
-                        <i-input v-model="createPath" v-if="createStep==0">
+                        <PathSelector v-model="createPath" v-if="createStep==0"></PathSelector>
-                            <Button slot="prepend" icon="md-arrow-round-up" @click="goUp"></Button>
+                        <div style="display: flex;flex-wrap: wrap" v-else-if="createStep==1">
-                        </i-input>
+                            <Card v-for="(item,name) in plugins" :key="name" style="width:200px;margin:5px">
-                        <List v-else-if="createStep==1" border>
+                                <Poptip :content="item.Description" slot="extra" width="200" word-wrap>
-                            <ListItem v-for="(item,name) in plugins" :key="name">
+                                    <Icon size="18" type="ios-help-circle-outline" style="cursor:pointer"/>
-                                <ListItemMeta :title="name" :description="item.Path"></ListItemMeta>
+                                </Poptip>
-                                {{item.Config}}
+                                <Poptip :content="item.Path" trigger="hover" word-wrap slot="title">
-                                <template slot="action">
+                                    <Checkbox v-model="item.enabled" style="color: #eb5e46">{{name}}</Checkbox>
-                                    <li @click="removePlugin(name)">
+                                </Poptip>
-                                        <Icon type="ios-trash" />移除
+                                <i-input type="textarea" v-model="item.Config" placeholder="请输入toml格式"></i-input>
-                                    </li>
+                            </Card>
-                                </template>
+                        </div>
                            </ListItem>
                        </List>
                        <div v-else>
                            <h3>实例名称：</h3>
                            <i-input
-                                v-model="instanceName"
+                                    v-model="instanceName"
-                                :placeholder="createPath.split('/').pop()"
+                                    :placeholder="createPath.split('/').pop()"
                            ></i-input>
                            <h4>安装路径：</h4>
                            <div>
@@ -52,27 +46,28 @@
                        </div>
                        <ButtonGroup style="display:table;margin:50px auto;">
                            <Button
-                                size="large"
+                                    size="large"
-                                type="primary"
+                                    type="primary"
-                                @click="createStep--"
+                                    @click="createStep--"
-                                v-if="createStep!=0"
+                                    v-if="createStep!=0"
                            >
-                                <Icon type="ios-arrow-back"></Icon>上一步
+                                <Icon type="ios-arrow-back"></Icon>
                                上一步
                            </Button>
                            <Button
-                                size="large"
+                                    size="large"
-                                type="success"
+                                    type="success"
-                                @click="showAddPlugin=true"
+                                    @click="showAddPlugin=true"
-                                v-if="createStep==1"
+                                    v-if="createStep==1"
                            >
                                +
                                添加插件
                            </Button>
                            <Button
-                                size="large"
+                                    size="large"
-                                type="primary"
+                                    type="primary"
-                                @click="createStep++"
+                                    @click="createStep++"
-                                v-if="createStep!=2"
+                                    v-if="createStep!=2"
                            >
                                下一步
                                <Icon type="ios-arrow-forward"></Icon>
@@ -81,7 +76,9 @@
                        </ButtonGroup>
                    </div>
                </TabPane>
-                <TabPane label="导入" name="name3"></TabPane>
+                <TabPane label="导入" name="name3">
                    <ImportInstance></ImportInstance>
                </TabPane>
            </Tabs>
        </Content>
        <Modal v-model="showAddPlugin" title="添加Plugin" @on-ok="addPlugin">
@@ -90,14 +87,9 @@
                    <i-input v-model="formPlugin.Name" placeholder="插件名称必须和插件注册时的名称一致"></i-input>
                </FormItem>
                <FormItem label="插件包地址">
-                    <i-input v-model="formPlugin.Path">
+                    <i-input v-model="formPlugin.Path"></i-input>
                        <Button slot="append" @click="showBuiltinPlugin=true">内置插件</Button>
                    </i-input>
                </FormItem>
-                <Alert
+                <Alert show-icon type="warning">
                    type="show-icon"
                    v-if="!Object.values(builtinPlugins).includes(formPlugin.Path)"
                >
                    如果该插件是私有仓库，请到服务器上输入：echo "machine {{privateHost}} login 用户名 password 密码" >> ~/.netrc
                    并且添加环境变量GOPRIVATE={{privateHost}}
                </Alert>
@@ -106,133 +98,98 @@
                </FormItem>
            </Form>
        </Modal>
        <Modal v-model="showBuiltinPlugin">
            <List>
                <ListItem v-for="(item,name) in builtinPlugins" :key="name">
                    <ListItemMeta :title="name" :description="item"></ListItemMeta>
                    <template slot="action">
                        <li @click="addBuiltin(name,item)">
                            <Icon type="ios-add" />添加
                        </li>
                    </template>
                </ListItem>
            </List>
        </Modal>
        <CreateInstance v-model="showCreate" :info="createInfo"></CreateInstance>
    </Layout>
 </template>
 <script>
-import CreateInstance from "../components/CreateInstance";
+    import CreateInstance from "../components/CreateInstance";
    import InstanceList from "../components/InstanceList";
    import ImportInstance from "../components/ImportInstance";
    import PathSelector from "../components/PathSelector"
-export default {
+    export default {
-    components: {
+        components: {
-        CreateInstance
+            CreateInstance, InstanceList, ImportInstance, PathSelector
-    },
+        },
-    data() {
+        data() {
-        return {
+            let plugins = {}
-            instanceName: "",
+            for (let name in this.$store.state.defaultPlugins) {
-            createStep: 0,
+                plugins[name] = {
-            showCreate: false,
+                    Name: name,
-            createInfo: null,
+                    enabled: ["GateWay", "LogRotate", "Jessica"].includes(name),
-            createPath: "/opt/monibuca",
+                    Path: "github.com/langhuihui/monibuca/plugins/" + this.$store.state.defaultPlugins[name][0],
-            instances: {},
+                    Config: this.$store.state.defaultPlugins[name][1],
-            plugins: {},
+                    Description: this.$store.state.defaultPlugins[name][2],
-            showAddPlugin: false,
+                }
            formPlugin: {},
            showBuiltinPlugin: false,
            builtinPlugins: {
                Auth: "github.com/langhuihui/monibuca/plugins/auth",
                Cluster: "github.com/langhuihui/monibuca/plugins/cluster",
                GateWay: "github.com/langhuihui/monibuca/plugins/gateway",
                HDL: "github.com/langhuihui/monibuca/plugins/HDL",
                Jessica: "github.com/langhuihui/monibuca/plugins/jessica",
                QoS: "github.com/langhuihui/monibuca/plugins/QoS",
                RecordFlv: "github.com/langhuihui/monibuca/plugins/record",
                RTMP: "github.com/langhuihui/monibuca/plugins/rtmp"
            },
            defaultConfig: {
                Auth: 'Key = "www.monibuca.com"',
                RecordFlv: 'Path="./resource"',
                QoS: 'Suffix = ["high","medium","low"]',
                Cluster: 'Master = "localhost:2019"\nListenAddr = ":2019"',
                GateWay: 'ListenAddr = ":8081"',
                RTMP: 'ListenAddr = ":1935"',
                Jessica: 'ListenAddr = ":8080"',
                HDL: 'ListenAddr = ":2020"'
            }
-        };
+            return {
-    },
+                instanceName: "",
-    computed: {
+                createStep: 0,
-        pluginStr() {
+                showCreate: false,
-            return Object.values(this.plugins)
+                createInfo: null,
-                .map(x => x.Path)
+                createPath: "/opt/monibuca",
-                .join("\n");
+                plugins,
-        },
+                showAddPlugin: false,
-        configStr() {
+                formPlugin: {},
            return Object.values(this.plugins)
                .map(
                    x => `[Plugins.${x.Name}]
 ${x.Config || ""}`
                )
                .join("\n");
        },
        privateHost() {
            return (
                (this.formPlugin.Path && this.formPlugin.Path.split("/")[0]) ||
                "仓库域名"
            );
        }
    },
    mounted() {
        window.ajax.getJSON("/list").then(x => {
            this.instances = x;
        });
    },
    methods: {
        goUp() {
            let paths = this.createPath.split("/");
            paths.pop();
            this.createPath = paths.join("/");
        },
        createInstance() {
            this.showCreate = true;
            this.createInfo = {
                Name: this.instanceName || this.createPath.split("/").pop(),
                Path: this.createPath,
                Plugins: Object.values(this.plugins).map(x => x.Path),
                Config: this.configStr
            };
        },
-        addPlugin() {
+        computed: {
-            this.plugins[this.formPlugin.Name] = this.formPlugin;
+            pluginStr() {
-            this.formPlugin = {};
+                return Object.values(this.plugins).filter(x => x.enabled)
                    .map(x => x.Path)
                    .join("\n");
            },
            configStr() {
                return Object.values(this.plugins).filter(x => x.enabled)
                    .map(
                        x => `[Plugins.${x.Name}]
 ${x.Config || ""}`
                    )
                    .join("\n");
            },
            privateHost() {
                return (
                    (this.formPlugin.Path && this.formPlugin.Path.split("/")[0]) ||
                    "仓库域名"
                );
            }
        },
-        removePlugin(name) {
+
-            delete this.plugins[name];
+        methods: {
-            this.$forceUpdate();
+            goUp() {
-        },
+                let paths = this.createPath.split("/");
-        addBuiltin(name, item) {
+                paths.pop();
-            this.formPlugin.Name = name;
+                this.createPath = paths.join("/");
-            this.formPlugin.Path = item;
+            },
-            this.formPlugin.Config = this.defaultConfig[name];
+            createInstance() {
-            this.showBuiltinPlugin = false;
+                this.showCreate = true;
                this.createInfo = {
                    Name: this.instanceName || this.createPath.split("/").pop(),
                    Path: this.createPath,
                    Plugins: Object.values(this.plugins).filter(x => x.enabled).map(x => x.Path),
                    Config: this.configStr
                };
            },
            addPlugin() {
                this.plugins[this.formPlugin.Name] = this.formPlugin;
                this.formPlugin = {};
            },
        }
-    }
+    };
 };
 </script>
 <style>
-.content {
+    .content {
-    background: white;
+        background: white;
-}
+    }
-pre {
+    pre {
-    white-space: pre-wrap;
+        white-space: pre-wrap;
-    word-wrap: break-word;
+        word-wrap: break-word;
-}
+    }
-.ivu-tabs .ivu-tabs-tabpane {
+    .ivu-tabs .ivu-tabs-tabpane {
-    padding: 20px;
+        padding: 20px;
-}
+    }
 </style>
Author	SHA1	Message	Date
langhuihui	73941d1e0b	ADTS转RTMP协议方式传输音频包	2020-02-18 15:19:21 +08:00
langhuihui	709c2c6ac7	增加目录候选功能	2020-02-17 11:48:58 +08:00
langhuihui	f96bc11ddb	增强对实例的控制	2020-02-15 21:07:47 +08:00
langhuihui	5563ddc0d2	增强对实例的控制	2020-02-14 09:54:53 +08:00
langhuihui	95657bd6df	增强对实例的控制	2020-02-13 17:41:39 +08:00
langhuihui	b9e19e75c8	增强对实例的控制	2020-02-13 10:43:32 +08:00
langhuihui	eac623639d	界面增加重启和升级	2020-02-11 21:59:31 +08:00
		`@@ -1 +1 @@`
			<!DOCTYPE html><html lang=en><head><meta charset=utf-8><meta http-equiv=X-UA-Compatible content="IE=edge"><meta name=viewport content="width=device-width,initial-scale=1"><link rel=icon href=/favicon.ico><title>Monibuca</title><script src=jessibuca/ajax.js></script><script src=jessibuca/renderer.js></script><link href=/css/app.ce470878.css rel=preload as=style><link href=/css/chunk-vendors.22ebf426.css rel=preload as=style><link href=/js/app.017fb959.js rel=preload as=script><link href=/js/chunk-vendors.ebc28a73.js rel=preload as=script><link href=/css/chunk-vendors.22ebf426.css rel=stylesheet><link href=/css/app.ce470878.css rel=stylesheet></head><body><noscript><strong>We're sorry but dashboard doesn't work properly without JavaScript enabled. Please enable it to continue.</strong></noscript><div id=app></div><script src=/js/chunk-vendors.ebc28a73.js></script><script src=/js/app.017fb959.js></script></body></html>				<!DOCTYPE html><html lang=en><head><meta charset=utf-8><meta http-equiv=X-UA-Compatible content="IE=edge"><meta name=viewport content="width=device-width,initial-scale=1"><link rel=icon href=/favicon.ico><title>Monibuca</title><script src=jessibuca/ajax.js></script><script src=jessibuca/renderer.js></script><link href=/css/app.ce470878.css rel=preload as=style><link href=/css/chunk-vendors.22ebf426.css rel=preload as=style><link href=/js/app.16c0d7c9.js rel=preload as=script><link href=/js/chunk-vendors.ebc28a73.js rel=preload as=script><link href=/css/chunk-vendors.22ebf426.css rel=stylesheet><link href=/css/app.ce470878.css rel=stylesheet></head><body><noscript><strong>We're sorry but dashboard doesn't work properly without JavaScript enabled. Please enable it to continue.</strong></noscript><div id=app></div><script src=/js/chunk-vendors.ebc28a73.js></script><script src=/js/app.16c0d7c9.js></script></body></html>