@@ -8,11 +8,12 @@ import (
88 "os"
99 "runtime"
1010 "strings"
11+ "time"
1112)
1213
1314var ENDPOINT string
1415var HOSTNAME string
15- var PORT int
16+ var INTERVAL int
1617
1718// Flow:
1819/*
@@ -25,26 +26,35 @@ var PORT int
2526
2627func main () {
2728 fmt .Println ("Tally Beacon Service Starting..." )
28- tasks , err := getTasks ()
29- if err != nil {
30- fmt .Println ("Error getting tasks:" , err )
31- return
32- }
29+ for {
30+ tasks , err := getTasks ()
31+ if err != nil {
32+ fmt .Println ("Error getting tasks:" , err )
33+ continue
34+ }
3335
34- topTask , err := getTopTask (tasks )
35- if err != nil {
36- fmt .Println ("Error getting top task :" , err )
37- return
38- }
36+ topTask , err := getTopTask (tasks )
37+ if err != nil {
38+ fmt .Println ("No tasks to execute :" , err )
39+ continue
40+ }
3941
40- controlResp , keyRotResp , err := executeTask (topTask )
41- if err != nil {
42- fmt .Println ("Error executing task:" , err )
43- return
44- }
42+ controlResp , keyRotResp , err := executeTask (topTask )
43+ if err != nil {
44+ fmt .Println ("Error executing task:" , err )
45+ continue
46+ }
4547
46- fmt .Println ("Control Check Response:" , controlResp )
47- fmt .Println ("Key Rotation Response:" , keyRotResp )
48+ if topTask .TaskType == "check_control" {
49+ fmt .Printf ("Control Check Response: %+v\n " , controlResp )
50+ } else if topTask .TaskType == "rotate_key" {
51+ fmt .Printf ("Key Rotation Response: %+v\n " , keyRotResp )
52+ }
53+
54+ // Sleep for a while before checking for new tasks
55+ // time.Sleep(time.Duration(INTERVAL) * time.Second)
56+ time .Sleep (time .Duration (10 ) * time .Second )
57+ }
4858}
4959
5060type Tasks struct {
0 commit comments