removed print statements

Author: naman47vyas

pkg/discovery/process.go

@@ -11,7 +11,6 @@ import (
 	"sync"
 	"time"
 
-	"github.com/k0kubun/pp"
 	"github.com/shirou/gopsutil/v4/process"
 )
 
@@ -128,7 +127,6 @@ func (d *discoverer) filterNodeProcesses(processes []*process.Process) []*proces
 	for _, proc := range processes {
 		if d.isNodeProcess(proc) {
 			nodeProcesses = append(nodeProcesses, proc)
-			// pp.Println("FOUND YA LITTLE NODE: ", nodeProcesses)
 		}
 	}
 
@@ -552,7 +550,6 @@ func (d *discoverer) extractPackageInfo(nodeProc *NodeProcess, workingDir string
 	if _, err := os.Stat(packageJsonPath); err == nil {
 		// TODO: Parse package.json and extract name, version, dependencies
 		// This would require json.Unmarshal(data, &PackageInfo{})
-		pp.Println("Does not exist, package")
 		nodeProc.PackageName = "unknown"    // Placeholder
 		nodeProc.PackageVersion = "unknown" // Placeholder
 	}
@@ -925,7 +922,6 @@ func (d *discoverer) processOne(ctx context.Context, proc *DiscoveryCandidate, o
 		} else {
 			javaProc.ContainerInfo = containerInfo
 
-			pp.Println("Found container info", javaProc.ContainerInfo)
 			// If we're excluding containers and this is in a container, return nil
 			if opts.ExcludeContainers && containerInfo.IsContainer {
 				return nil, fmt.Errorf("process %d is running in container, skipping", javaProc.ProcessPID)

pkg/discovery/report.go

@@ -72,7 +72,7 @@ func GetAgentReportValue() (AgentReportValue, error) {
 		// Decide if this should be a fatal error or just logged (assuming logged for now)
 	}
 
-	// nodeProcs, err := FindAllNodeProcesses(ctx)
+	nodeProcs, err := FindAllNodeProcesses(ctx)
 
 	// b) Docker Containers (java/Node)
 	// dockerDiscoverer := NewDockerDiscoverer(ctx)
@@ -108,10 +108,10 @@ func GetAgentReportValue() (AgentReportValue, error) {
 	// 	settings[setting.Key] = setting
 	// }
 
-	// for _, proc := range nodeProcs {
-	// 	setting := convertNodeProcessToServiceSetting(proc)
-	// 	settings[setting.Key] = setting
-	// }
+	for _, proc := range nodeProcs {
+		setting := convertNodeProcessToServiceSetting(proc)
+		settings[setting.Key] = setting
+	}
 
 	reportValue := AgentReportValue{
 		osKey: OSConfig{

pkg/docker/operations.go

@@ -168,7 +168,6 @@ type ContainerState struct {
 // InstrumentContainer instruments a specific Docker container
 func (do *DockerOperations) InstrumentContainer(containerName string, cfg *config.ProcessConfiguration) error {
 	// Discover the container
-	pp.Println("Container name: ", containerName)
 	container, err := do.discoverer.GetContainerByName(containerName)
 	if err != nil {
 		return fmt.Errorf("container not found: %w", err)
@@ -181,7 +180,6 @@ func (do *DockerOperations) InstrumentContainer(containerName string, cfg *confi
 
 	// Determine instrumentation strategy
 	if container.IsCompose {
-		pp.Println("Compose container")
 		if container.IsJava {
 			return do.instrumentComposeContainer(container, cfg)
 		} else if container.IsNodeJS {
@@ -442,7 +440,6 @@ func (do *DockerOperations) instrumentComposeNodeContainer(
 	if container.ComposeFile == "" {
 		return fmt.Errorf("compose file not found for container %s", container.ContainerName)
 	}
-	pp.Println("Compose File for node: ", container.ComposeFile)
 	modifier := NewComposeModifier(container.ComposeFile)
 
 	// Step 1: Validate compose file
@@ -883,7 +880,6 @@ func (do *DockerOperations) buildDockerRunCommand(config map[string]interface{},
 
 // runContainer runs a docker run command
 func (do *DockerOperations) runContainer(command string) error {
-	pp.Println("Running the docker command: ", command)
 	cmd := exec.CommandContext(do.ctx, "sh", "-c", command)
 	return cmd.Run()
 }
@@ -918,7 +914,6 @@ func (do *DockerOperations) modifyComposeFile(container *discovery.DockerContain
 
 	// Add instrumentation to service
 	if container.IsNodeJS {
-		pp.Println("Service: ", service)
 		if err := modifier.addNodeInstrumentation(&service, cfg, do.hostAgentPath); err != nil {
 			return fmt.Errorf("failed to add instrumentation: %w", err)
 		}
@@ -928,7 +923,6 @@ func (do *DockerOperations) modifyComposeFile(container *discovery.DockerContain
 
 	// Update the service in the compose data
 	composeData.Services[container.ComposeService] = service
-	pp.Println("compose Data, ", composeData)
 
 	// Write the modified compose file
 	if err := modifier.Write(composeData); err != nil {
@@ -967,10 +961,6 @@ func (cm *ComposeModifier) Write(composeFile *ComposeFile) error {
 		return fmt.Errorf("failed to marshal YAML: %w", err)
 	}
 
-	pp.Println("=== MODIFIED COMPOSE FILE CONTENT ===")
-	pp.Println(string(data))
-	pp.Println("=== END MODIFIED CONTENT ===")
-
 	// Write to file
 	if err := os.WriteFile(cm.filePath, data, 0o644); err != nil {
 		return fmt.Errorf("failed to write file: %w", err)
@@ -1089,8 +1079,6 @@ func (cm *ComposeModifier) addNodeInstrumentation(
 	hostAgentPath string,
 ) error {
 	cfg.MWServiceName = ""
-	pp.Println("----------------------------------------------------------")
-	pp.Println("cfg: OTEL SERVICE NAME: ", cfg.OtelServiceName)
 	mwEnv := cfg.ToEnvironmentVariables()
 	nodeOptions := fmt.Sprintf("NODE_OPTIONS=--import ${PWD}/autoinstrumentation/mw-register.js")