Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
550ce91a7f | ||
|
|
9d8f561b54 | ||
|
|
e12299ac20 |
@@ -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(),
|
||||||
|
|||||||
@@ -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)
|
||||||
|
|||||||
@@ -1,4 +1,5 @@
|
|||||||
{
|
{
|
||||||
|
"Name": "pa",
|
||||||
"Interval": {
|
"Interval": {
|
||||||
"OK": "6h0m0s",
|
"OK": "6h0m0s",
|
||||||
"Error": "6h",
|
"Error": "6h",
|
||||||
|
|||||||
@@ -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
|
||||||
|
|||||||
2
main.go
2
main.go
@@ -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
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -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
|
||||||
|
|||||||
Reference in New Issue
Block a user