nilopaim
/
apifiber
1
0
Fork 0
Code Issues Pull Requests Packages Projects 1 Releases Wiki Activity

bugfix on saving transmission

main
Nilo Roberto C Paim 2025-08-13 11:19:29 -03:00
parent e7b34caeb4
commit 7d590e8e0b
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
controllers/webhookController.go
View File

@ -109,8 +109,6 @@ func OnPubStop(c *fiber.Ctx) error {
transm := globals.Transmissions[p.StreamName] transm := globals.Transmissions[p.StreamName]
// TODO: Check if the transmission does not have errors and log only if true (and only once)
now := time.Now() now := time.Now()
duration := now.Sub(transm.StartTime) duration := now.Sub(transm.StartTime)
@ -121,21 +119,21 @@ func OnPubStop(c *fiber.Ctx) error {
return c.SendString("On_Pub_Stop: " + string(c.Body())) return c.SendString("On_Pub_Stop: " + string(c.Body()))
} }
log.Printf("======================== Transmissão encerrada do canal %s - Duration %d\n", p.StreamName, duration)
// TODO: Updates the transmission on database for future calculation of remaining daily time // TODO: Updates the transmission on database for future calculation of remaining daily time
if int(minutes) == 0 { if int(minutes) == 0 {
minutes = 1 minutes = 1
} }
log.Printf("======================== Transmissão encerrada do canal %s - Duração %d\n", p.StreamName, minutes)
// msg := fmt.Sprintf("Transmissão encerrada. Duração %d minutos.\n", int(minutes)) // msg := fmt.Sprintf("Transmissão encerrada. Duração %d minutos.\n", int(minutes))
// services.AddTransmissionlog(p.StreamName, msg) // services.AddTransmissionlog(p.StreamName, msg)
// Saves the transmission on the database // Saves the transmission on the database
transm.Duration = minutes transm.Duration = minutes
globals.DB.Save(&transm) globals.DB.Create(&transm)
delete(globals.Transmissions, p.StreamName) delete(globals.Transmissions, p.StreamName)
return c.SendString("On_Pub_Stop: " + string(c.Body())) return c.SendString("On_Pub_Stop: " + string(c.Body()))