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

processing transmissions

main
nilo 2025-03-23 22:28:27 -03:00
parent d919cd65e7
commit f4647668c0
2 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
main.go
View File

@ -4,6 +4,7 @@ import (
"api/config" "api/config"
"api/database" "api/database"
"api/globals" "api/globals"
"api/models"
"api/routes" "api/routes"
"api/services" "api/services"
"io" "io"
@ -88,6 +89,9 @@ func main() {
routes.Setup(app) routes.Setup(app)
// Starts transmissions processing // Starts transmissions processing
globals.Transmissions = make(map[string]models.CurrentTransmission, 100)
log.Println("Starting transmissions limits verification process")
ticker := time.NewTicker(1 * time.Minute) ticker := time.NewTicker(1 * time.Minute)
go func() { go func() {
for range ticker.C { for range ticker.C {

4
services/channelservices.go
View File

@ -4,10 +4,12 @@ import (
"api/globals" "api/globals"
"api/models" "api/models"
"api/utils" "api/utils"
"log"
"time" "time"
) )
func VerifyTransmissionsLimits() { func VerifyTransmissionsLimits() {
log.Println("Verificando")
for channelname, currentTransmission := range globals.Transmissions { for channelname, currentTransmission := range globals.Transmissions {
// If the channel has no daily transmission limit, skip the verification (Channels with 24 hours daily limit) // If the channel has no daily transmission limit, skip the verification (Channels with 24 hours daily limit)
if time.Duration(currentTransmission.PlanDailyLimit) == 1440 { if time.Duration(currentTransmission.PlanDailyLimit) == 1440 {
@ -72,5 +74,7 @@ func VerifyTransmissionAuthorization(channelname, sessionid, transmissionkey str
// TODO: Save the transmission on database for future calculation of remaining daily time // TODO: Save the transmission on database for future calculation of remaining daily time
globals.Transmissions[channelname] = currentTransmission
return true, currentTransmission return true, currentTransmission
} }