Freifunk-Troisdorf/ubnt-freifunk-map-api
5
0
Fork 0
Code Issues 1 Pull Requests Packages Releases 23 Wiki Activity

added webserver to serve json file. also running indefinitely now

Browse Source
This commit is contained in:
Nils Stinnesbeck 2021-01-02 22:16:07 +01:00
parent 94222942e6
commit 78b274c160
1 changed files with 118 additions and 108 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

226
main.go
View File

@ -23,118 +23,131 @@ const (
// flags // flags
var token = flag.String("token", "", "Defines the x-auth-token") var token = flag.String("token", "", "Defines the x-auth-token")
var version = "development" var version = "development"
var delay time.Duration = 60 * time.Second
func main() { func main() {
log.Printf("starting version %s...\n", version)
log.Println("starting version", version, "...")
// parse all flags // parse all flags
flag.Parse() flag.Parse()
// check if token is set // check if token is set
if *token == "" { if *token == "" {
log.Fatalln("Please specify an API token via the flag '-token'") log.Fatalln("Please specify an API token via the flag '-token'")
} }
// Variables for runtime // start API processing (runs in a loop)
var links []link go processAPIs()
var nodes []node
d, err := getDevices() // start webserver
if err != nil { serveJSON()
log.Fatalln(err) }
}
// API CALL 1 func processAPIs() {
log.Println("calling API 1") tick := time.Tick(delay)
var u []unifiAPIResponse for range tick {
err = callUnifiAPI("/devices", &u) // Variables for runtime
if err != nil { var links []link
log.Fatalln(err) var nodes []node
}
for i := range d.Devices { d, err := getDevices()
var dev unifiAPIResponse if err != nil {
var currentDevice device log.Fatalln(err)
for j := range u { }
if strings.ToUpper(u[j].Identification.MAC) == strings.ToUpper(d.Devices[i].MAC) {
dev = u[j] // API CALL 1
currentDevice = d.Devices[i] log.Println("calling API 1")
var u []unifiAPIResponse
err = callUnifiAPI("/devices", &u)
if err != nil {
log.Fatalln(err)
}
for i := range d.Devices {
var dev unifiAPIResponse
var currentDevice device
for j := range u {
if strings.ToUpper(u[j].Identification.MAC) == strings.ToUpper(d.Devices[i].MAC) {
dev = u[j]
currentDevice = d.Devices[i]
}
} }
}
var isOnline bool = false var isOnline bool = false
if dev.Overview.Status == "active" { if dev.Overview.Status == "active" {
isOnline = true isOnline = true
}
// END OF API CALL 1
// API CALL 2
log.Println("calling API 2 for device", d.Devices[i].Name)
var details unifiAPIDetails
callUnifiAPI("/devices/erouters/"+dev.Identification.ID, &details)
// END OF API CALL 2
// API CALL 3
log.Println("calling API 3 for device", d.Devices[i].Name)
var airmaxes []unifiAPIAirmax
callUnifiAPI("/devices/airmaxes/"+dev.Identification.ID+"/stations", &airmaxes)
// check if remote mac address is part of our published network
for i := range airmaxes {
if isRemoteMACpublished(airmaxes[i].DeviceIdentification.MAC, d.Devices) == true {
links = addLink(dev, airmaxes[i], links)
} }
// END OF API CALL 1
// API CALL 2
log.Println("calling API 2 for device", d.Devices[i].Name)
var details unifiAPIDetails
callUnifiAPI("/devices/erouters/"+dev.Identification.ID, &details)
// END OF API CALL 2
// API CALL 3
log.Println("calling API 3 for device", d.Devices[i].Name)
var airmaxes []unifiAPIAirmax
callUnifiAPI("/devices/airmaxes/"+dev.Identification.ID+"/stations", &airmaxes)
// check if remote mac address is part of our published network
for i := range airmaxes {
if isRemoteMACpublished(airmaxes[i].DeviceIdentification.MAC, d.Devices) == true {
links = addLink(dev, airmaxes[i], links)
}
}
// END OF API CALL 3
// Get info from json file (static)
nodes = append(nodes, node{
Firstseen: dev.Overview.CreatedAt.Format(iso8601),
Lastseen: dev.Overview.LastSeen.Format(iso8601),
IsOnline: isOnline,
IsGateway: false,
Clients: 0,
ClientsWifi24: 0,
ClientsWifi5: 0,
ClientsOther: 0,
RootFSUsage: 0,
LoadAVG: details.Overview.CPU / 100,
MemoryUsage: details.Overview.RAM / 100,
Uptime: dev.Identification.Started.Format(iso8601),
GatewayNexthop: currentDevice.GatewayNexthop,
Gateway: currentDevice.Gateway,
Location: currentDevice.Location,
NodeID: strings.ReplaceAll(dev.Identification.MAC, ":", ""),
MAC: dev.Identification.MAC,
Adresses: getAddresses(details.IPAddress),
Domain: currentDevice.Domain,
Hostname: "[RiFu] " + details.Identification.Name,
Owner: "Freifunk Rhein-Sieg",
Firmware: firmware{
Base: "Ubiquiti - Stock",
Release: details.Firmware.Current,
},
Autoupdater: autoupdater{
Enabled: false,
Branch: "stable",
},
NProc: 1,
Model: details.Identification.Model,
})
} }
// END OF API CALL 3
// Get info from json file (static) // assemble final struct
nodes = append(nodes, node{ o := output{
Firstseen: dev.Overview.CreatedAt.Format(iso8601), Timestamp: time.Now().Format(iso8601),
Lastseen: dev.Overview.LastSeen.Format(iso8601), Nodes: nodes,
IsOnline: isOnline, Links: links,
IsGateway: false, }
Clients: 0,
ClientsWifi24: 0, // create file output
ClientsWifi5: 0, log.Println("writing json file")
ClientsOther: 0,
RootFSUsage: 0, if err := o.writeToFile(); err != nil {
LoadAVG: details.Overview.CPU / 100, log.Fatalln(err)
MemoryUsage: details.Overview.RAM / 100, }
Uptime: dev.Identification.Started.Format(iso8601),
GatewayNexthop: currentDevice.GatewayNexthop, // we're done here
Gateway: currentDevice.Gateway, log.Println("...done")
Location: currentDevice.Location,
NodeID: strings.ReplaceAll(dev.Identification.MAC, ":", ""),
MAC: dev.Identification.MAC,
Adresses: getAddresses(details.IPAddress),
Domain: currentDevice.Domain,
Hostname: "[RiFu] " + details.Identification.Name,
Owner: "Freifunk Rhein-Sieg",
Firmware: firmware{
Base: "Ubiquiti - Stock",
Release: details.Firmware.Current,
},
Autoupdater: autoupdater{
Enabled: false,
Branch: "stable",
},
NProc: 1,
Model: details.Identification.Model,
})
} }
// assemble final struct
o := output{
Timestamp: time.Now().Format(iso8601),
Nodes: nodes,
Links: links,
}
// create file output
log.Println("writing json file")
writeJSONtoFile(o)
// we're done here
log.Println("...done")
} }
func getDevices() (devices, error) { func getDevices() (devices, error) {
@ -213,22 +226,19 @@ func addLink(dev unifiAPIResponse, airmaxes unifiAPIAirmax, links []link) []link
return links return links
} }
func writeJSONtoFile(o output) error {
file, err := json.MarshalIndent(o, "", " ")
if err != nil {
return fmt.Errorf("can't marshal to json: %+v", o)
}
// write to file
err = ioutil.WriteFile("example.json", file, 0644)
if err != nil {
return fmt.Errorf("can't write to json file example.json")
}
return nil
}
func getAddresses(ip string) []string { func getAddresses(ip string) []string {
var adresses []string var adresses []string
adresses = append(adresses, strings.Split(ip, "/")[0]) adresses = append(adresses, strings.Split(ip, "/")[0])
return adresses return adresses
} }
func serveJSON() {
fs := http.FileServer(http.Dir("./output"))
http.Handle("/", fs)
log.Println("Listening on :3000...")
err := http.ListenAndServe(":3000", nil)
if err != nil {
log.Fatalln(err)
}
}