Merge branch 'main' into feat/busybox-download-from-release

Author: tomassrnka

packages/api/internal/handlers/sandbox.go

@@ -110,6 +110,19 @@ func (a *APIStore) startSandboxInternal(
 		props = props.Set("mcp_servers", slices.Collect(maps.Keys(mcp)))
 	}
 
+	if len(sbx.VolumeMounts) > 0 {
+		volumeNames := make([]string, 0, len(sbx.VolumeMounts))
+		volumeIDs := make([]string, 0, len(sbx.VolumeMounts))
+		for _, vol := range sbx.VolumeMounts {
+			volumeNames = append(volumeNames, vol.Name)
+			volumeIDs = append(volumeIDs, vol.ID)
+		}
+		props = props.
+			Set("volume_names", volumeNames).
+			Set("volume_ids", volumeIDs).
+			Set("volume_count", len(sbx.VolumeMounts))
+	}
+
 	a.posthog.CreateAnalyticsTeamEvent(ctx, team.ID.String(), "created_instance", props)
 	analyticsSpan.End()
 

packages/api/internal/handlers/volume_create.go

@@ -9,6 +9,7 @@ import (
 
 	"github.com/gin-gonic/gin"
 	"github.com/google/uuid"
+	"github.com/posthog/posthog-go"
 
 	"github.com/e2b-dev/infra/packages/api/internal/api"
 	"github.com/e2b-dev/infra/packages/api/internal/clusters"
@@ -148,6 +149,12 @@ func (a *APIStore) PostVolumes(c *gin.Context) {
 		return
 	}
 
+	a.posthog.CreateAnalyticsTeamEvent(ctx, team.ID.String(), "created_volume", posthog.NewProperties().
+		Set("volume_id", volume.ID.String()).
+		Set("volume_name", volume.Name).
+		Set("volume_type", volumeType),
+	)
+
 	result := api.VolumeAndToken{
 		VolumeID: volume.ID.String(),
 		Name:     volume.Name,

packages/api/internal/handlers/volume_delete.go

@@ -7,6 +7,7 @@ import (
 
 	"github.com/gin-gonic/gin"
 	"github.com/google/uuid"
+	"github.com/posthog/posthog-go"
 
 	"github.com/e2b-dev/infra/packages/api/internal/api"
 	"github.com/e2b-dev/infra/packages/api/internal/clusters"
@@ -36,6 +37,11 @@ func (a *APIStore) DeleteVolumesVolumeID(c *gin.Context, volumeID api.VolumeID)
 		return
 	}
 
+	a.posthog.CreateAnalyticsTeamEvent(ctx, team.ID.String(), "deleted_volume", posthog.NewProperties().
+		Set("volume_id", volume.ID.String()).
+		Set("volume_name", volume.Name),
+	)
+
 	go func(ctx context.Context) {
 		// if this fails, we can clean it up later
 		if err := a.deleteVolume(ctx, clusterID, volume); err != nil {