louis/oktopus
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

reaftor: mtp interface + mqtt disconnection log

Browse Source
This commit is contained in:
leandrofars 2024-02-05 23:29:45 -03:00
parent ef34e499de
commit d9560ec167
2 changed files with 5 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
backend/services/controller/internal/mqtt/mqtt.go
View File

@ -86,6 +86,7 @@ func (m *Mqtt) Connect() {
} }
func (m *Mqtt) Disconnect() { func (m *Mqtt) Disconnect() {
log.Println("Disconnecting from MQTT broker...")
err := c.Disconnect(m.Ctx) err := c.Disconnect(m.Ctx)
if err != nil { if err != nil {
log.Fatalf("failed to send Disconnect: %s", err) log.Fatalf("failed to send Disconnect: %s", err)

15
backend/services/controller/internal/mtp/mtp.go
View File

@ -23,7 +23,7 @@ type Broker interface {
//Request(msg []byte, msgType usp_msg.Header_MsgType, pubTopic string, subTopic string) //Request(msg []byte, msgType usp_msg.Header_MsgType, pubTopic string, subTopic string)
} }
// Not used, since we are using a broker solution. // Not used, since we are using a broker approach.
type P2P interface { type P2P interface {
} }
@ -31,14 +31,7 @@ type P2P interface {
func MtpService(b Broker, done chan os.Signal, wg *sync.WaitGroup) { func MtpService(b Broker, done chan os.Signal, wg *sync.WaitGroup) {
b.Connect() b.Connect()
wg.Done() wg.Done()
go func() { <-done
for range done { log.Println("Disconnect of MTP!")
b.Disconnect() b.Disconnect()
log.Println("Successfully disconnected to MTPs!")
// Receives signal and then replicates it to the rest of the app.
done <- os.Interrupt
}
}()
//b.Subscribe()
} }