From d452b8854fcacf252a362e3f7a09595e1ae233c5 Mon Sep 17 00:00:00 2001
From: langhuihui <178529795@qq.com>
Date: Mon, 14 Aug 2023 10:08:22 +0800
Subject: [PATCH] fit engine update

---
 main.go | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/main.go b/main.go
index afc7b4b..4ef9870 100644
--- a/main.go
+++ b/main.go
@@ -10,18 +10,18 @@ import (
 )
 
 type EdgeConfig struct {
-	Origin string //源服务器地址
 	config.Pull
+	Origin string //源服务器地址
 }
 
 func (p *EdgeConfig) OnEvent(event any) {
 	switch v := event.(type) {
 	case FirstConfig:
 		if len(p.Origin) < 4 {
-			plugin.Warn("origin config error plugin disabled")
-			plugin.Disabled = true
+			EdgePlugin.Warn("origin config error plugin disabled")
+			EdgePlugin.Disabled = true
 		}
-	case *Stream:
+	case InvitePublish:
 		var puller IPuller
 		switch p.Origin[:4] {
 		case "http":
@@ -31,13 +31,13 @@ func (p *EdgeConfig) OnEvent(event any) {
 		case "rtsp":
 			puller = new(rtsp.RTSPPuller)
 		default:
-			plugin.Panic("origin config not support")
+			EdgePlugin.Panic("origin config not support")
 		}
-		err := plugin.Pull(v.Path, p.Origin+v.Path, puller, 0)
+		err := EdgePlugin.Pull(v.Target, p.Origin+v.Target, puller, 0)
 		if err != nil {
-			plugin.Error("pull", zap.Error(err))
+			EdgePlugin.Error("pull", zap.Error(err))
 		}
 	}
 }
 
-var plugin = InstallPlugin(new(EdgeConfig))
+var EdgePlugin = InstallPlugin(new(EdgeConfig))