-
Notifications
You must be signed in to change notification settings - Fork 0
/
helpers.go
107 lines (88 loc) · 2.45 KB
/
helpers.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
package main
import (
"github.com/anaskhan96/soup"
"github.com/jinzhu/gorm"
"github.com/racerxdl/anatel/eventmanager"
"github.com/racerxdl/anatel/models"
)
func IndexOfString(item string, arr []string) int {
for idx, n := range arr {
if n == item {
return idx
}
}
return -1
}
func GetStringNested(n *soup.Root) string {
str := n.Text()
c := n.Children()
for i := 0; i < len(c); i++ {
v := c[i]
if v.Error == nil {
nst := GetStringNested(&v)
if len(nst) != 0 {
if len(str) != 0 {
str += " "
}
str += nst
}
}
}
return str
}
func triggerStationCallSignsNotifications(newCallsigns, newStations []int, callsigns []models.CallSign, stations []models.StationData, db *gorm.DB) {
callSignsToReport := make([]string, 0)
for i := 0; i < len(newCallsigns); i++ {
clsId := newCallsigns[i]
cls := callsigns[clsId]
callSignsToReport = append(callSignsToReport, cls.Callsign)
}
// Report new callsigns with all stations
for i := 0; i < len(callSignsToReport); i++ {
var cls models.CallSign
cstr := callSignsToReport[i]
stations := make([]models.StationData, 0)
db.Model(&models.CallSign{}).Where("callsign = ?", cstr).First(&cls)
db.Model(&models.StationData{}).Where("callsign = ?", cstr).Find(&stations)
name := "Desconhecido"
if len(stations) > 0 {
name = stations[0].Owner
}
eventManager.Emit(eventmanager.EvOnNewCallsign, eventmanager.NewCallsignEventData{
CallSign: cls,
Stations: stations,
Owner: name,
})
}
// Report new stations for existing callsigns
for i := 0; i < len(newStations); i++ {
ssid := newStations[i]
s := stations[ssid]
if IndexOfString(s.Callsign, callSignsToReport) == -1 {
// Not reported in new callsign
eventManager.Emit(eventmanager.EvOnNewStation, eventmanager.NewStationEventData{
StationData: s,
})
}
}
}
func triggerStationNotifications(newStations []int, stations []models.StationData, db *gorm.DB) {
// Report new stations for existing callsigns
for i := 0; i < len(newStations); i++ {
ssid := newStations[i]
s := stations[ssid]
// Not reported in new callsign
eventManager.Emit(eventmanager.EvOnNewStation, eventmanager.NewStationEventData{
StationData: s,
})
}
}
func triggerTestsNotifications(newTests []int, tests []models.TestData) {
for i := 0; i < len(newTests); i++ {
tdid := newTests[i]
td := tests[tdid]
eventManager.Emit(eventmanager.EvOnNewTestDate, eventmanager.NewTestDateEventData{
TestData: td,
})
}
}