remove unwanted from help, only print !zip or !state as configured

broker/ntgvision.go

@@ -221,43 +221,7 @@ func (ntg NTGVision) SearchZips(zips []string) ([]Job, error) {
 	return jobs, nil
 }
 
-func (ntg NTGVision) workingHours(now time.Time) bool {
-	// TODO assert M-F 9-4 EST
-	now = now.In(time.FixedZone("EST", -5*60*60))
-	working := config.Get().Brokers.NTG.Working
-	logtr.Debugf("ntg.workingHours: now=%s, weekday=%v, hour=%v (ok=%+v)", now.String(), now.Weekday(), now.Hour(), working)
-	if ok := func() bool {
-		for _, hr := range working.Hours {
-			if now.Hour() == hr {
-				return true
-			}
-		}
-		return false
-	}(); !ok {
-		return false
-	}
-	if ok := func() bool {
-		for _, weekday := range working.Weekdays {
-			if now.Weekday() == time.Weekday(weekday) {
-				return true
-			}
-		}
-		return false
-	}(); !ok {
-		return false
-	}
-	return true
-}
-
 func (ntg NTGVision) SearchStates(states []config.State) ([]Job, error) {
-	if !ntg.workingHours(time.Now()) {
-		lastNtgB, _ := config.Get().DB().Get("ntg_last_search_states")
-		var jobs []Job
-		json.Unmarshal(lastNtgB, &jobs)
-		logtr.Verbosef("ntg.SearchStates: outside of working hours so returning ntg_last_search_states: %+v", jobs)
-		return jobs, nil
-	}
-
 	rc, err := ntg.searcher.searchStates(states)
 	if err != nil {
 		return nil, err
@@ -273,22 +237,12 @@ func (ntg NTGVision) SearchStates(states []config.State) ([]Job, error) {
 
 	var ntgjobs []ntgVisionJob
 	err = json.Unmarshal(b, &ntgjobs)
-	if err != nil {
-		return nil, err
-	}
 
 	jobs := make([]Job, len(ntgjobs))
 	for i := range jobs {
 		jobs[i] = ntgjobs[i].Job()
 	}
-
+	return jobs, err
-	jobsB, err := json.Marshal(jobs)
-	if err == nil {
-		config.Get().DB().Set("ntg_last_search_states", jobsB)
-		logtr.Verbosef("ntg.SearchStates: in working hours so setting ntg_last_search_states: %+v", jobs)
-	}
-
-	return jobs, nil
 }
 
 func getNTGTokenKey() string {
@@ -380,7 +334,7 @@ func (ntg NTGVision) _searchStates(states []config.State) (io.ReadCloser, error)
 		request2, _ := ntg.newRequest(states)
 		requestb, _ := ioutil.ReadAll(request2.Body)
 		logtr.Debugf("ntg auth bad status: url=%s, status=%v, body=%s, headers=%+v, request=%+v, requestb=%s", request.URL.String(), resp.StatusCode, b, resp.Header, request2, requestb)
-		if resp.StatusCode > 400 && resp.StatusCode < 404 || resp.StatusCode == 417 { // TODO wtf is 417 for
+		if resp.StatusCode > 400 && resp.StatusCode < 404 {
 			logtr.Debugf("ntg auth bad status: err no auth")
 			return nil, ErrNoAuth
 		}

broker/ntgvision_test.go

@@ -1,22 +0,0 @@
-package broker
-
-import (
-	"local/truckstop/config"
-	"os"
-	"testing"
-	"time"
-)
-
-func TestWorkingHoursNTG(t *testing.T) {
-	os.Setenv("CONFIG", "../config.json")
-	if err := config.Refresh(nil); err != nil {
-		t.Fatal(err)
-	}
-	ntg := NTGVision{}
-	if !ntg.workingHours(time.Date(2022, 1, 27, 12, 0, 0, 0, time.FixedZone("MST", -7*60*60))) {
-		t.Fatal("noon MST not ok")
-	}
-	if ntg.workingHours(time.Date(2022, 1, 27, 23, 0, 0, 0, time.FixedZone("MST", -7*60*60))) {
-		t.Fatal("midnight MST ok")
-	}
-}

config.json

@@ -77,15 +77,11 @@
    "Once": false,
    "Brokers": {
       "UseZips": true,
-      "RadiusMiles": 200,
+      "RadiusMiles": 300,
       "NTG": {
-         "Working": {
+         "Enabled": true,
-            "Hours": [6, 7, 8, 9, 10, 11, 12, 13, 14, 15],
-            "Weekdays": [1, 2, 3, 4, 5]
-         },
-         "Enabled": false,
          "JobInfo": true,
-         "Mock": true,
+         "Mock": false,
          "LoadPageURIFormat": "https://ntgvision.com/LoadDetails?loadId=%d",
          "LoadPageAPIURIFormat": "https://ntgvision.com/api/v1/load/LoadDetails?loadId=%d",
          "Username": "noeasyrunstrucking@gmail.com",
@@ -93,7 +89,7 @@
       },
       "FastExact": {
          "Enabled": true,
-         "Mock": true,
+         "Mock": false,
          "Username": "birdman",
          "Password": "166647"
       }

config.main_test.json

@@ -83,10 +83,6 @@
          "Password": "p"
       },
       "NTG": {
-         "Working": {
-            "Hours": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23],
-            "Weekdays": [0, 1, 2, 3, 4, 5, 6]
-         },
          "Enabled": true,
          "JobInfo": true,
          "Mock": true,

config/config.go

@@ -67,10 +67,6 @@ type Config struct {
 		UseZips     bool
 		RadiusMiles int
 		NTG         struct {
-			Working struct {
-				Hours    []int
-				Weekdays []int
-			}
 			Enabled              bool
 			JobInfo              bool
 			Mock                 bool

main.go

@@ -13,7 +13,6 @@ import (
 	"net/url"
 	"regexp"
 	"sort"
-	"strconv"
 	"strings"
 	"sync"
 	"time"
@@ -85,9 +84,9 @@ func matrixrecv() error {
 					logtr.Debugf("sending help")
 					locationHelp := "`!state nc NC nC Nc`   set states for self"
 					if config.Get().Brokers.UseZips {
-						locationHelp = "...`!zip 27006 84058` to set zip codes for self\n...`!radius 100` to set miles radius to 100, 200, or 300"
+						locationHelp = "`!zip 27006 84058` to set zip codes for self"
 					}
-					help := fmt.Sprintf("commands:\n...`!help`   print this help\n%s\n\nrun a command for someone else: `!zip 2022-12-31 @caleb`", locationHelp)
+					help := fmt.Sprintf("commands:\n...`!help`   print this help\n...%s\n\nrun a command for someone else: `!zip 2022-12-31 @caleb`", locationHelp)
 					if err := sender.Send(help); err != nil {
 						logtr.Errorf("failed to send help: %v", err)
 					} else {
@@ -152,31 +151,6 @@ func matrixrecv() error {
 		}
 		setNewStates(states)
 	}()
-	func() {
-		logtr.Verbosef("looking for radius")
-		db := config.Get().DB()
-		var radius *int
-		for _, msg := range messages {
-			key := fmt.Sprintf("radius_%d", msg.Timestamp.Unix())
-			if !strings.HasPrefix(msg.Content, "!radius ") {
-				continue
-			}
-			if _, err := db.Get(key); err == storage.ErrNotFound {
-				cmd := msg.Content
-				for strings.HasPrefix(cmd, "!radius ") {
-					cmd = strings.TrimPrefix(cmd, "!radius ")
-				}
-				n, err := strconv.Atoi(strings.TrimSpace(cmd))
-				if err == nil {
-					radius = &n
-				}
-			}
-			if err := db.Set(key, []byte{'k'}); err != nil {
-				logtr.Errorf("failed to mark radius gathered @%s: %v", key, err)
-			}
-		}
-		setNewRadius(radius)
-	}()
 	func() {
 		logtr.Verbosef("looking for pauses")
 		db := config.Get().DB()
@@ -209,33 +183,6 @@ func matrixrecv() error {
 	return nil
 }
 
-func setNewRadius(radius *int) {
-	if radius == nil {
-		return
-	}
-	sender := message.NewMatrix()
-	logtr.Debugf("set new radius: %d", *radius)
-	acceptable := map[int]struct{}{
-		100: struct{}{},
-		200: struct{}{},
-		300: struct{}{},
-	}
-	if _, ok := acceptable[*radius]; !ok {
-		sender.Send(fmt.Sprintf("radius of %v is not among acceptable %+v", *radius, acceptable))
-		logtr.Debugf("bad radius, not setting: %d", *radius)
-		return
-	}
-	conf := *config.Get()
-	if conf.Brokers.RadiusMiles == *radius {
-		logtr.Debugf("noop radius, not setting: %d", *radius)
-		return
-	}
-	conf.Brokers.RadiusMiles = *radius
-	logtr.Infof("updating config new pauses: %+v", conf)
-	config.Set(conf)
-	sender.Send(fmt.Sprintf("now using radius of %d mi for zip code search", *radius))
-}
-
 func setNewPauses(pauses map[string]time.Time) {
 	if len(pauses) == 0 {
 		return
@@ -371,7 +318,7 @@ func __main() error {
 			logtr.Errorf("failed _main: %v", err)
 		}
 		if config.Get().Once {
-			time.Sleep(10 * time.Second)
+			time.Sleep(3 * time.Second)
 			return err
 		}
 		if err != nil {

todo.yaml

@@ -1,4 +1,7 @@
 todo:
+- fast exact does not use ID in UID because they spammy
+- from states to zip codes w/ range
+- modify old items once no longer available; drop stale jobs good candidate but requires new matrix interaction
 - more than NTG; blue one
 - !states emits current state
 - test each !command callbacks to matrix
@@ -11,11 +14,7 @@ todo:
   subtasks:
   - banlist criteria like vendors, brokers, metadata
 - set up copy for caleb, broc
-- move from main() and make more functions
 done:
-- modify old items once no longer available; drop stale jobs good candidate but requires new matrix interaction
-- from states to zip codes w/ range
-- fast exact does not use ID in UID because they spammy
 - fast exact is dumb or...?
 - try search ntg by autoinc?
 - TEST. Just like, refactor and test to shit.

zip/zip.go

@@ -2,7 +2,6 @@ package zip
 
 import (
 	_ "embed"
-	"local/truckstop/logtr"
 	"math"
 	"strconv"
 	"strings"
@@ -45,7 +44,6 @@ func init() {
 			State: state,
 		}
 	}
-	logtr.Infof("loaded %d zip codes", len(zips))
 }
 
 func alphafy(s string) string {