Compare commits

..

3 Commits

Author SHA1 Message Date
Bel LaPointe
550ce91a7f accept more noauth codes from ntg 2022-01-11 08:35:07 -05:00
Bel LaPointe
9d8f561b54 logs 2022-01-11 08:24:46 -05:00
Bel LaPointe
e12299ac20 add config name for identifying who wants what 2022-01-11 08:16:02 -05:00
6 changed files with 11 additions and 3 deletions

View File

@@ -2,6 +2,7 @@ package broker
import ( import (
"fmt" "fmt"
"local/truckstop/config"
"time" "time"
) )
@@ -37,7 +38,8 @@ func (j JobLocation) String() string {
func (j Job) FormatMultilineText() string { func (j Job) FormatMultilineText() string {
return fmt.Sprintf( return fmt.Sprintf(
"--- %s => %s ---\nPickup: %s\nDropoff: %s\nNotes: %d lbs, %d miles, %s", "--- %s: %s => %s ---\nPickup: %s\nDropoff: %s\nNotes: %d lbs, %d miles, %s",
config.Get().Name,
j.Pickup.State, j.Pickup.State,
j.Dropoff.State, j.Dropoff.State,
j.Pickup.String(), j.Pickup.String(),

View File

@@ -146,7 +146,7 @@ func (ntg NTGVision) _search(states []config.State) (io.ReadCloser, error) {
if resp.StatusCode != http.StatusOK { if resp.StatusCode != http.StatusOK {
b, _ := ioutil.ReadAll(resp.Body) b, _ := ioutil.ReadAll(resp.Body)
resp.Body.Close() resp.Body.Close()
if resp.StatusCode > 400 && resp.StatusCode < 404 { if resp.StatusCode > 400 && resp.StatusCode < 500 && resp.StatusCode != 404 && resp.StatusCode != 410 {
return nil, ErrNoAuth return nil, ErrNoAuth
} }
return nil, fmt.Errorf("bad status searching ntg: %d: %s", resp.StatusCode, b) return nil, fmt.Errorf("bad status searching ntg: %d: %s", resp.StatusCode, b)

View File

@@ -1,4 +1,5 @@
{ {
"Name": "pa",
"Interval": { "Interval": {
"OK": "6h0m0s", "OK": "6h0m0s",
"Error": "6h", "Error": "6h",

View File

@@ -10,6 +10,7 @@ import (
) )
type Config struct { type Config struct {
Name string
Interval struct { Interval struct {
Email Duration Email Duration
OK Duration OK Duration

View File

@@ -118,6 +118,7 @@ func _mainOne() error {
if err := once(); err != nil { if err := once(); err != nil {
return err return err
} }
log.Println("/_mainOne")
return nil return nil
} }
@@ -138,6 +139,7 @@ func once() error {
if err := sendJob(jobs[i]); err != nil { if err := sendJob(jobs[i]); err != nil {
return err return err
} }
log.Println("sent job", jobs[i])
if err := config.Get().DB().Set(jobs[i].ID, []byte(`sent`)); err != nil { if err := config.Get().DB().Set(jobs[i].ID, []byte(`sent`)); err != nil {
return err return err
} }

View File

@@ -3,9 +3,11 @@ todo:
subtasks: subtasks:
- banlist criteria like vendors, brokers, metadata - banlist criteria like vendors, brokers, metadata
- quiet hours - quiet hours
- setup pa on element - setup ma on element
- accept states via element for one system - accept states via element for one system
- set up copy for caleb, broc
done: done:
- setup pa on element
- configurable email interval - configurable email interval
- jitter on intervals, including dedicated err span - jitter on intervals, including dedicated err span
- email doesnt get all matches - email doesnt get all matches