Merge pull request #287 from pankona/sync-periodically

sync periodically

cmd/hashira-cui/main.go

@@ -10,6 +10,7 @@ import (
 	"os"
 	"os/user"
 	"path/filepath"
+	"time"
 
 	"github.com/pankona/gocui"
 	hashirac "github.com/pankona/hashira/client"
@@ -88,17 +89,26 @@ func main() {
 				log.Printf("HASHIRA_ACCESSTOKEN is invalid. Synchronization is not started: %v", err)
 			}
 			m.SetAccessToken(accesstoken)
+
 			if err := m.SyncOnNotify(context.Background()); err != nil {
 				log.Printf("sync on notify finished: %v", err)
 			}
 
-			// sync on launch
-			m.NotifySync()
+		}()
+
+		go func() {
+			// start polling
+			for {
+				m.NotifySync()
+				<-time.After(2 * time.Minute)
+			}
 		}()
 	}
 
 	// prepare controller
 	ps := &PubSub{}
+	m.SetPublisher(ps)
+
 	c := &Ctrl{
 		m:   m,
 		pub: ps,

cmd/hashira-cui/model.go

@@ -20,6 +20,8 @@ type Model struct {
 	// TODO: remove if accesstoken is held by syncclient
 	accesstoken string
 	syncChan    chan struct{}
+
+	pub Publisher
 }
 
 func NewModel(hc *hashirac.Client, sc *syncutil.Client) *Model {
@@ -82,6 +84,10 @@ func (m *Model) SetAccessToken(accesstoken string) {
 	m.accesstoken = accesstoken
 }
 
+func (m *Model) SetPublisher(p Publisher) {
+	m.pub = p
+}
+
 func (m *Model) NotifySync() {
 	select {
 	case m.syncChan <- struct{}{}:
@@ -122,6 +128,23 @@ func (m *Model) SyncOnNotify(ctx context.Context) error {
 						log.Printf("failed to download tasks: %v", err)
 					}
 
+					// publish to notify update of tasks and priorities
+					tasks, err := m.List(ctx)
+					if err != nil {
+						log.Printf("failed to retrieve tasks: %v", err)
+					}
+
+					priorities, err := m.RetrievePriority(ctx)
+					if err != nil {
+						log.Printf("failed to retrieve priorities: %v", err)
+					}
+
+					ktasks := make(map[string]*KeyedTask)
+					for k, v := range tasks {
+						ktasks[k] = (*KeyedTask)(v)
+					}
+
+					m.pub.Publish("update", ktasks, priorities)
 				}
 			}(ctx)
 		}

sync/syncutil/upload.go

@@ -58,7 +58,7 @@ func (c *Client) Upload(accesstoken string, uploadTarget UploadTarget) error {
 
 	if len(ur.Tasks) == 0 && !isPriorityDirty(allPriorities) {
 		// there's no task to upload
-		return fmt.Errorf("there's no dirty task. no task to upload")
+		return nil
 	}
 
 	sc := sync.NewClient()