From 08a69f5b1822520d9c165f76b644ff298d2c0f81 Mon Sep 17 00:00:00 2001
From: Keyvan Fatehi <keyvanfatehi@gmail.com>
Date: Sun, 19 Feb 2023 19:47:20 -0800
Subject: [PATCH] the sock is providing events

---
 main.go | 25 ++++++++++---------------
 1 file changed, 10 insertions(+), 15 deletions(-)

diff --git a/main.go b/main.go
index 303b3d8..a5aeff0 100644
--- a/main.go
+++ b/main.go
@@ -59,29 +59,24 @@ func main() {
 			if len(msgs) > 0 {
 				for _, msg := range msgs {
 
-					evt, err := cereal.ReadRootEncodeData(msg)
+					evt, err := cereal.ReadRootEvent(msg)
 					if err != nil {
 						panic(err)
 					}
 
-					ts := evt.UnixTimestampNanos()
-
-					idx, err := evt.Idx()
+					encodeData, err := evt.RoadEncodeData()
 					if err != nil {
 						panic(err)
 					}
-					encodeId := idx.EncodeId()
-					idxFlags := idx.Flags()
-					frameId := idx.FrameId()
-					idxType := idx.Type().String()
-					segmentNum := idx.SegmentNum()
-					segmentId := idx.SegmentId()
 
-					fmt.Printf("ts: %d,frameId: %d,type:%s,encodeId: %d,segmentNum: %d,segmentId: %d,idxFlags: %d\n",
-						ts, frameId, idxType, encodeId, segmentNum, segmentId, idxFlags,
-					)
+					encodeIndex, err := encodeData.Idx()
+					if err != nil {
+						panic(err)
+					}
+
+					encodeId := encodeIndex.EncodeId()
+					idxFlags := encodeIndex.Flags()
 
-					continue
 					if encodeId != 0 && encodeId != uint32(lastIdx+1) {
 						fmt.Println("DROP PACKET!")
 					}
@@ -101,7 +96,7 @@ func main() {
 						}
 
 						// AvPacketFromData
-						header, err := evt.Header()
+						header, err := encodeData.Header()
 						if err != nil {
 							panic(err)
 						}