[feat] 重新梳理依赖

mqtt.go

@@ -1,6 +1,7 @@
 package contracts
 
 import (
+	"git.fsdpf.net/go/req"
 	"github.com/samber/do"
 )
 
@@ -36,15 +37,15 @@ type Mqtt interface {
 	// 断开链接
 	// OnDisconnect(g GlobalParams, topic string) error
 	// 订阅事件
-	OnSubscribed(g GlobalParams, topic string) error
+	OnSubscribed(g req.GlobalParams, topic string) error
 	// 取消订阅事件
-	OnUnsubscribed(g GlobalParams, topic string) error
+	OnUnsubscribed(g req.GlobalParams, topic string) error
 	// 消息发布事件
-	OnMessage(g GlobalParams, topic string, retain bool, qos byte) error
+	OnMessage(g req.GlobalParams, topic string, retain bool, qos byte) error
 	// 消息被丢弃
-	OnMessageDropped(g GlobalParams, topic string, retain bool, qos byte) error
+	OnMessageDropped(g req.GlobalParams, topic string, retain bool, qos byte) error
 	// 原生消息修改
-	OnPublish(g GlobalParams, topic string, retain bool, qos byte, raw []byte) ([]byte, error)
+	OnPublish(g req.GlobalParams, topic string, retain bool, qos byte, raw []byte) ([]byte, error)
 	// 保留类型消息事件
 	// OnRetainMessage(g GlobalParams, topic string) error
 	// Qos消息完成事件
@@ -59,23 +60,23 @@ type MqttHandle struct {
 	Controller
 }
 
-func (this *MqttHandle) OnSubscribed(g GlobalParams, topic string) error {
+func (this *MqttHandle) OnSubscribed(g req.GlobalParams, topic string) error {
 	return ErrFuncNotImplemented
 }
 
-func (this MqttHandle) OnUnsubscribed(g GlobalParams, topic string) error {
+func (this MqttHandle) OnUnsubscribed(g req.GlobalParams, topic string) error {
 	return ErrFuncNotImplemented
 }
 
-func (this MqttHandle) OnMessage(g GlobalParams, topic string, retain bool, qos byte) error {
+func (this MqttHandle) OnMessage(g req.GlobalParams, topic string, retain bool, qos byte) error {
 	return ErrFuncNotImplemented
 }
 
-func (this MqttHandle) OnMessageDropped(g GlobalParams, topic string, retain bool, qos byte) error {
+func (this MqttHandle) OnMessageDropped(g req.GlobalParams, topic string, retain bool, qos byte) error {
 	return ErrFuncNotImplemented
 }
 
-func (this MqttHandle) OnPublish(g GlobalParams, topic string, retain bool, qos byte, raw []byte) ([]byte, error) {
+func (this MqttHandle) OnPublish(g req.GlobalParams, topic string, retain bool, qos byte, raw []byte) ([]byte, error) {
 	return nil, ErrFuncNotImplemented
 }