updates to gosky

cmd/gosky/debug.go

···
 
 				return nil
 			},
+			RepoSync: func(evt *comatproto.SyncSubscribeRepos_Sync) error {
+				fmt.Printf("\rChecking seq: %d      ", evt.Seq)
+				if lastSeq > 0 && evt.Seq != lastSeq+1 {
+					fmt.Println("Gap in sequence numbers: ", lastSeq, evt.Seq)
+				}
+				lastSeq = evt.Seq
+				return nil
+			},
 			RepoInfo: func(evt *comatproto.SyncSubscribeRepos_Info) error {
 				return nil
 			},

cmd/gosky/main.go

···
 
 				return nil
 			},
+			RepoSync: func(sync *comatproto.SyncSubscribeRepos_Sync) error {
+				if jsonfmt {
+					b, err := json.Marshal(sync)
+					if err != nil {
+						return err
+					}
+					fmt.Println(string(b))
+				} else {
+					fmt.Printf("(%d) Sync: %s\n", sync.Seq, sync.Did)
+				}
+
+				return nil
+
+			},
 			RepoInfo: func(info *comatproto.SyncSubscribeRepos_Info) error {
 				if jsonfmt {
 					b, err := json.Marshal(info)

cmd/gosky/streamdiff.go

···
 		return "ERROR"
 	case evt.RepoCommit != nil:
 		return "#commit"
+	case evt.RepoSync != nil:
+		return "#sync"
 	case evt.RepoInfo != nil:
 		return "#info"
 	default: