gui.go

@@ -38,8 +38,9 @@ func debugTab(title string) {
 		debugger.DebugWindow(me.myGui)
 	})
 
-	g2.NewButton("dig A & AAAA DNS records (updateDNS())", func () {
+	g2.NewButton("dig A & AAAA DNS records", func () {
-		log.Log(CHANGE, "updateDNS() going to run:")
+		log.Println("updateDNS()")
+		updateDNS()
 	})
 
 	g2 = me.debug.Box().NewGroup("debugging options")
@@ -177,18 +178,42 @@ func statusGrid(n *gui.Node) {
 
 	gridP.NewLabel("DNS API")
 	me.DnsAPIstatus = gridP.NewLabel("unknown")
-	me.apiButton = gridP.NewButton("unknown wit.com", func () {
+	var apiButton *gui.Node
+	apiButton = gridP.NewButton("unknown wit.com", func () {
 		log.Log(CHANGE, "WHAT API ARE YOU USING?")
 		provider := me.statusDNS.GetDNSapi()
+		apiButton.SetText(provider + " wit.com")
 		if provider == "cloudflare" {
+			me.DnsAPIstatus.Set("WORKING")
+			return
+
 			if me.witcom != nil {
 				me.witcom.Toggle()
-			} else {
-				me.witcom = cloudflare.CreateRR(me.myGui, "wit.com", "3777302ac4a78cd7fa4f6d3f72086d06")
 			}
+			me.witcom = cloudflare.CreateRR(me.myGui, "wit.com", "3777302ac4a78cd7fa4f6d3f72086d06")
 		}
 	})
 
 	n.NewGroup("NOTES")
 
 }
+
+// run everything because something has changed
+func updateDNS() {
+	me.digStatus.Update()
+	me.statusDNS.Update()
+
+	if me.digStatus.Ready() {
+		if me.digStatus.IPv6() {
+			me.statusIPv6.Set("WORKING")
+		} else {
+			me.statusIPv6.Set("Need VPN")
+		}
+	}
+
+	// lookup the NS records for your domain
+	// if your host is test.wit.com, find the NS resource records for wit.com
+	lookupNS(me.statusOS.GetDomainName())
+
+	log.Println("updateDNS() END")
+}

main.go

@@ -6,7 +6,7 @@ package main
 
 import 	(
 	"fmt"
-	// "runtime"
+	"runtime"
 	"time"
 	"embed"
 
@@ -54,57 +54,111 @@ func main() {
 	me.statusOS.Draw2()
 
 	if debugger.ArgDebug() {
-		go func() {
 		log.Sleep(2)
 		debugger.DebugWindow(me.myGui)
-		}()
 	}
 
+	// forever monitor for network and dns changes
 	log.Sleep(me.artificialSleep)
+	checkNetworkChanges()
+}
 
-	// TCP & UDP port 53 lookups + DNS over HTTP lookups + os.Exec(dig)
+/*
-	go myTicker(60 * time.Second, "DNSloop", func() {
+	Poll for changes to the networking settings
-		me.digStatus.Update()
+*/
 
-		if me.digStatus.Ready() {
+/* https://github.com/robfig/cron/blob/master/cron.go
-			current := me.statusIPv6.Get()
+
-			if me.digStatus.IPv6() {
+// Run the cron scheduler, or no-op if already running.
-				if current != "WORKING" {
+func (c *Cron) Run() {
-					log.Log(CHANGE, "IPv6 resolution is WORKING")
+	c.runningMu.Lock()
-					me.statusIPv6.Set("WORKING")
+	if c.running {
+		c.runningMu.Unlock()
+		return
 	}
+	c.running = true
+	c.runningMu.Unlock()
+	c.run()
+}
+
+// run the scheduler.. this is private just due to the need to synchronize
+// access to the 'running' state variable.
+func (c *Cron) run() {
+	c.logger.Info("start")
+*/
+
+func checkNetworkChanges() {
+	var lastLocal time.Time = time.Now()
+	var lastDNS time.Time = time.Now()
+
+	timer2 := time.NewTimer(time.Second)
+	go func() {
+		<-timer2.C
+		fmt.Println("Timer 2 fired")
+	}()
+
+	for {
+		time.Sleep(me.ttl.Duration)
+		if (time.Since(lastLocal) > me.localSleep) {
+			if (runtime.GOOS == "linux") {
+				duration := timeFunction(linuxLoop)
+				s := fmt.Sprint(duration)
+				me.statusOS.SetSpeedActual(s)
 			} else {
-				if current != "Need VPN" {
+				// TODO: make windows and macos diagnostics
-					log.Log(CHANGE, "IPv6 resolution seems to have broken")
+				log.Warn("Windows and MacOS don't work yet")
-					me.statusIPv6.Set("Need VPN")
 			}
+			lastLocal = time.Now()
 		}
+		if (time.Since(lastDNS) > me.dnsTtl.Duration) {
+			DNSloop()
+			lastDNS = time.Now()
 		}
-	})
 
-	// checks if your DNS records are still broken
+		/*
-	// if everything is working, then it just ignores
+		stop2 := timer2.Stop()
-	// things until the timeout happens
+		if stop2 {
-
+			fmt.Println("Timer 2 stopped")
-	lastProvider := "unknown"
-	go myTicker(10 * time.Second, "DNSloop", func() {
-		log.Log(CHANGE, "me.statusDNS.Update() START")
-		me.statusDNS.Update()
-
-		provider := me.statusDNS.GetDNSapi()
-		if provider != lastProvider {
-			log.Log(CHANGE, "Your DNS API provider appears to have changed to", provider)
-			lastProvider = provider
-			me.apiButton.SetText(provider + " wit.com")
 		}
-		if provider == "cloudflare" {
+		*/
-			me.DnsAPIstatus.Set("WORKING")
 	}
-	})
+}
 
-	// probes the OS network settings
+// run this on each timeout
-	go myTicker(500 * time.Millisecond, "me.statusOS,Update()", func() {
+func DNSloop() {
-		duration := timeFunction( func() {
+	duration := timeFunction(dnsTTL)
+	log.Info("dnsTTL() execution Time: ", duration)
+	var s, newSpeed string
+	if (duration > 5000 * time.Millisecond ) {
+		newSpeed = "VERY SLOW"
+	} else if (duration > 2000 * time.Millisecond ) {
+		newSpeed = "SLOWER"
+	} else if (duration > 500 * time.Millisecond ) {
+		newSpeed = "SLOW"
+	} else if (duration > 100 * time.Millisecond ) {
+		newSpeed = "OK"
+	} else {
+		newSpeed = "FAST"
+	}
+	if (newSpeed != me.DnsSpeedLast) {
+		log.Log(CHANGE, "dns lookup speed changed =", newSpeed)
+		log.Log(CHANGE, "dnsTTL() execution Time: ", duration)
+		me.DnsSpeed.SetText(newSpeed)
+		me.DnsSpeedLast = newSpeed
+	}
+	s = fmt.Sprint(duration)
+	me.DnsSpeedActual.SetText(s)
+}
+
+// This checks for changes to the network settings
+// and verifies that DNS is working or not working
+func dnsTTL() {
+	updateDNS()
+}
+
+// run update on the LinuxStatus() window
+// also update a few things on the main window
+func linuxLoop() {
 	me.statusOS.Update()
 
 	if me.statusOS.ValidHostname() {
@@ -114,38 +168,12 @@ func main() {
 		}
 	}
 
-			// re-check DNS API provider
 	if (me.statusOS.Changed()) {
-				// lookup the NS records for your domain
+		stamp := time.Now().Format("2006/01/02 15:04:05")
-				// if your host is test.wit.com, find the NS resource records for wit.com
+		log.Log(CHANGE, "Network things changed on", stamp)
-				lookupNS(me.statusOS.GetDomainName())
+		duration := timeFunction(updateDNS)
-				log.Log(CHANGE, "updateDNS() END")
+		log.Log(CHANGE, "updateDNS() execution Time: ", duration)
 	}
-		})
-		s := fmt.Sprint(duration)
-		me.statusOS.SetSpeedActual(s)
-	})
-
-	// check the four known things to see if they are all WORKING
-	myTicker(3 * time.Second, "MAIN LOOP", func() {
-		if me.hostnameStatus.GetText() != "WORKING" {
-			log.Log(CHANGE, "The hostname is not WORKING yet", me.hostnameStatus.GetText())
-			return
-		}
-		if me.statusIPv6.Get() != "WORKING" {
-			log.Log(CHANGE, "IPv6 DNS lookup has not been confirmed yet", me.statusIPv6.Get())
-			return
-		}
-		if me.DnsStatus.GetText() != "WORKING" {
-			log.Log(CHANGE, "Your IPv6 DNS settings have not been confirmed yet", me.DnsStatus.GetText()) 
-			return
-		}
-		if me.DnsAPIstatus.GetText() != "WORKING" {
-			log.Log(CHANGE, "The DNS API provider is not yet working", me.DnsAPIstatus.GetText())
-			return
-		}
-		log.Log(CHANGE, "EVERYTHING IS WORKING. YOU HAVE IPv6 BLISS")
-	})
 }
 
 /*
@@ -160,32 +188,3 @@ func timeFunction(f func()) time.Duration {
 	f()                     // Execute the function
 	return time.Since(startTime) // Calculate the elapsed time
 }
-
-func timeStamp() string {
-	stamp := time.Now().Format("2006/01/02 15:04:05")
-	log.Log(CHANGE, "Network things changed on", stamp)
-	return stamp
-}
-
-
-func myTicker(t time.Duration, name string, f func()) {
-	ticker := time.NewTicker(t)
-	defer ticker.Stop()
-	done := make(chan bool)
-	/*
-	go func() {
-		time.Sleep(10 * time.Second)
-		done <- true
-	}()
-	*/
-	for {
-		select {
-		case <-done:
-			fmt.Println("Done!")
-			return
-		case t := <-ticker.C:
-			log.Log(INFO, name, "Current time: ", t)
-			f()
-		}
-	}
-}

structs.go

@@ -30,7 +30,6 @@ type Host struct {
 	hostnameStatus	*gui.Node		// a summary for the user of where things are
 	DnsAPIstatus	*gui.Node		// does your DNS API work?
 	APIprovider	string
-	apiButton	*gui.Node		// the button you click for the API config page
 
 	artificialSleep float64	`default:"0.7"`	// artificial sleep on startup
 	artificialS     string 	`default:"abc"`	// artificial sleep on startup