Merge pull request #89 from intergral/frame_data

fix(frame): fix missing data in frame storage/response

CHANGELOG.md

@@ -1,7 +1,12 @@
 <!-- main START -->
 # main (unreleased)
+- **[BUGFIX]**: fix missing data in frame response [#89](https://github.com/intergral/deep/pull/89) [@Umaaz](https://github.com/Umaaz)
+<!-- main START -->
+
+<!-- main START -->
+# 1.0.5 (08/02/2024)
 - **[ENHANCEMENT]**: Update deep proto version to support new properties on tracepoints [#78](https://github.com/intergral/deep/pull/78) [@Umaaz](https://github.com/Umaaz) 
-- **[ENHANCEMENT]**: change(builds): change builds to use goreleaser [#79](https://github.com/intergral/deep/pull/79) [@Umaaz](https://github.com/Umaaz)
+- **[ENHANCEMENT]**: change builds to use goreleaser [#79](https://github.com/intergral/deep/pull/79) [@Umaaz](https://github.com/Umaaz)
 <!-- main START -->
 
 <!-- 1.0.4 START -->

modules/distributor/forwarder/otlpgrpc/forwarder_test.go

@@ -19,6 +19,7 @@ package otlpgrpc
 
 import (
 	"context"
+	"errors"
 	"net"
 	"testing"
 
@@ -80,7 +81,9 @@ func newListener(t *testing.T, srv ptraceotlp.Server) *bufconn.Listener {
 	ptraceotlp.RegisterServer(s, srv)
 	go func() {
 		err := s.Serve(l)
-		require.NoError(t, err)
+		if !errors.Is(err, grpc.ErrServerStopped) {
+			require.NoError(t, err)
+		}
 	}()
 
 	return l

pkg/deepdb/encoding/vparquet/schema.go

@@ -162,6 +162,7 @@ type StackFrame struct {
 	TranspiledColumnNumber *uint32      `parquet:",snappy,optional"`
 	Variables              []VariableID `parquet:""`
 	AppFrame               bool         `parquet:""`
+	NativeFrame            bool         `parquet:""`
 	ShortPath              *string      `parquet:",snappy,dict,optional"`
 }
 
@@ -341,6 +342,10 @@ func convertFrame(frame *deepTP.StackFrame) StackFrame {
 	if frame.AppFrame != nil {
 		appFrame = *frame.AppFrame
 	}
+	nativeFrame := false
+	if frame.NativeFrame != nil {
+		nativeFrame = *frame.NativeFrame
+	}
 	return StackFrame{
 		FileName:               frame.FileName,
 		MethodName:             frame.MethodName,
@@ -353,6 +358,7 @@ func convertFrame(frame *deepTP.StackFrame) StackFrame {
 		TranspiledColumnNumber: frame.TranspiledColumnNumber,
 		Variables:              convertChildren(frame.Variables),
 		AppFrame:               appFrame,
+		NativeFrame:            nativeFrame,
 		ShortPath:              frame.ShortPath,
 	}
 }
@@ -688,6 +694,10 @@ func parquetConvertFrame(frame StackFrame) *deepTP.StackFrame {
 	if frame.AppFrame {
 		appFrame = &trueBool
 	}
+	var nativeframe *bool = nil
+	if frame.NativeFrame {
+		nativeframe = &trueBool
+	}
 	return &deepTP.StackFrame{
 		FileName:               frame.FileName,
 		MethodName:             frame.MethodName,
@@ -700,6 +710,8 @@ func parquetConvertFrame(frame StackFrame) *deepTP.StackFrame {
 		TranspiledColumnNumber: frame.TranspiledColumnNumber,
 		Variables:              parquetConvertChildren(frame.Variables),
 		AppFrame:               appFrame,
+		NativeFrame:            nativeframe,
+		ShortPath:              frame.ShortPath,
 	}
 }