Add calls to policy enforcer helpers

Signed-off-by: Kirtana Ashok <[email protected]>

cmd/gcs-sidecar/internal/bridge/bridge.go

@@ -184,6 +184,12 @@ func (b *Bridge) AssignHandlers() {
 	b.HandleFunc(rpcLifecycleNotification, b.lifecycleNotification) // TODO: Validate this request as well?
 }
 
+type messageHeader struct {
+	Type uint32
+	Size uint32
+	ID   int64
+}
+
 func readMessage(r io.Reader) (request, error) {
 	var h [hdrSize]byte
 	_, err := io.ReadFull(r, h[:])
@@ -245,7 +251,12 @@ func (b *Bridge) ListenAndServeShimRequests() error {
 				recverr = errors.Wrap(err, "bridge read from shim failed:")
 				break
 			}
-			log.Printf("bridge recv from shim: \n Header: %v \n msg: %v \n", "", string(req.message))
+			var header messageHeader
+			messageTyp := msgType(binary.LittleEndian.Uint32(req.header[hdrOffType:]))
+			header.Type = binary.LittleEndian.Uint32(req.header[hdrOffType:])
+			header.Size = binary.LittleEndian.Uint32(req.header[hdrOffSize:])
+			header.ID = int64(binary.LittleEndian.Uint64(req.header[hdrOffID:]))
+			log.Printf("bridge recv from shim: \n Header {Type: %v Size: %v ID: %v }\n msg: %v \n", messageTyp, header.Size, header.ID, string(req.message))
 			shimRequestChan <- req
 		}
 		shimRequestErrChan <- recverr
@@ -262,6 +273,7 @@ func (b *Bridge) ListenAndServeShimRequests() error {
 					// 2. Code cleanup on error
 					// ? b.close(err)
 					// b.quitCh <- true // give few seconds delay and close connections?
+					b.close(err)
 					return
 				}