frontend: add Loop.HostSyncMsg()

diff --git a/cmd/safcm/sync_sync.go b/cmd/safcm/sync_sync.go
index bc11043299e77152483fac038fa59d3b829b301a..01e712c50f552d8296491c2a3ea515432ff46006 100644 (file)
--- a/cmd/safcm/sync_sync.go
+++ b/cmd/safcm/sync_sync.go
@@ -35,14 +35,10 @@ func (s *Sync) hostSync(conn *rpc.Conn, detectedGroups []string) error {
        if err != nil {
                return err
        }
-       x, err := s.loop.SendRecv(s, conn, req)
+       resp, err := s.loop.HostSyncMsg(s, conn, req)
        if err != nil {
                return err
        }
-       resp, ok := x.(safcm.MsgSyncResp)
-       if !ok {
-               return fmt.Errorf("unexpected response %v", x)
-       }
 
        // Display changes
        c := frontend.Changes{

diff --git a/frontend/conn.go b/frontend/conn.go
index 02dfe8bf904111b1edca797cc61270dab64b5bc6..01486ff00869e413d3e11174c298e17aa748f144 100644 (file)
--- a/frontend/conn.go
+++ b/frontend/conn.go
@@ -64,3 +64,20 @@ func (l *Loop) HostInfoMsg(host Host, conn *rpc.Conn, req safcm.MsgInfoReq) (
        }
        return resp, nil
 }
+
+// HostSyncMsg sends a MsgSyncReq for host via conn and returns the resulting
+// MsgSyncResp.
+func (l *Loop) HostSyncMsg(host Host, conn *rpc.Conn, req safcm.MsgSyncReq) (
+       safcm.MsgSyncResp, error) {
+
+       var empty safcm.MsgSyncResp
+       x, err := l.SendRecv(host, conn, req)
+       if err != nil {
+               return empty, err
+       }
+       resp, ok := x.(safcm.MsgSyncResp)
+       if !ok {
+               return empty, fmt.Errorf("unexpected response %v", x)
+       }
+       return resp, nil
+}