Main Poll() loop
This commit is contained in:
@@ -2,10 +2,15 @@ package main
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
"fmt"
|
||||||
|
"log"
|
||||||
|
"math/rand"
|
||||||
"os"
|
"os"
|
||||||
|
"time"
|
||||||
)
|
)
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
|
rand.Seed(time.Now().UnixNano())
|
||||||
|
|
||||||
ic, err := NewImapClient(
|
ic, err := NewImapClient(
|
||||||
os.Getenv("IMAP_HOST"),
|
os.Getenv("IMAP_HOST"),
|
||||||
os.Getenv("IMAP_USERNAME"),
|
os.Getenv("IMAP_USERNAME"),
|
||||||
@@ -19,13 +24,18 @@ func main() {
|
|||||||
|
|
||||||
defer ic.Close()
|
defer ic.Close()
|
||||||
|
|
||||||
tasks, err := ic.Poll()
|
err = Poll(ic)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic(err)
|
log.Printf("%s", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
for _, task := range tasks {
|
for {
|
||||||
fmt.Printf("%#v\n", task)
|
time.Sleep(time.Duration(rand.Intn(60)) * time.Second)
|
||||||
|
|
||||||
|
err := Poll(ic)
|
||||||
|
if err != nil {
|
||||||
|
log.Printf("%s", err)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -33,3 +43,16 @@ type Task struct {
|
|||||||
Name string
|
Name string
|
||||||
HtmlNotes string
|
HtmlNotes string
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func Poll(ic *ImapClient) error {
|
||||||
|
tasks, err := ic.Poll()
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, task := range tasks {
|
||||||
|
fmt.Printf("%#v\n", task)
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user