From 495dd8bdf9f12286a5ce07783e78bdf107186949 Mon Sep 17 00:00:00 2001 From: Jesse Peterson Date: Sun, 28 May 2017 10:17:16 -0700 Subject: [PATCH] Issue DEP Sync Event on receiving devices from the DEP sync API (#177) --- depsync/depsync.go | 16 +++++++++++++--- 1 file changed, 13 insertions(+), 3 deletions(-) diff --git a/depsync/depsync.go b/depsync/depsync.go index 586ce69e..75912ee2 100644 --- a/depsync/depsync.go +++ b/depsync/depsync.go @@ -132,8 +132,18 @@ SYNC: if err := w.conf.Save(); err != nil { return errors.Wrap(err, "saving cursor from sync") } - - // TODO handle sync response here. - <-ticker + if len(resp.Devices) > 0 { + e := NewEvent(resp.Devices) + data, err := MarshalEvent(e) + if err != nil { + return err + } + if err := w.publisher.Publish(SyncTopic, data); err != nil { + return err + } + } + if !resp.MoreToFollow { + <-ticker + } } }