syslog hardcoding removed

Author: PrashantRaj18198

pkg/telemetry/manager.go

@@ -64,7 +64,7 @@ func (tm *TelemetryManager) Start() error {
 	log.Logger().Debugf("Started S3 Uploader")
 
 	// Create telemetry service with required parameters
-	service := uploader.NewTelemetryService(tm.warpbuildAPI, tm.runnerID, tm.pollingSecret, tm.hostURL)
+	service := uploader.NewTelemetryService(tm.warpbuildAPI, tm.runnerID, tm.pollingSecret, tm.hostURL, tm.maxBufferSize)
 
 	// Create receiver
 	tm.receiver = uploader.NewReceiver(tm.port, service)

pkg/telemetry/uploader/service.go

@@ -21,16 +21,18 @@ type TelemetryService struct {
 	buffer map[string]*Buffer
 	mu     sync.RWMutex
 	// Store API client and other required fields for creating buffers
+	maxLines      int
 	warpbuildAPI  *warpbuild.APIClient
 	runnerID      string
 	pollingSecret string
 	hostURL       string
 }
 
 // NewTelemetryService creates a new telemetry service
-func NewTelemetryService(warpbuildAPI *warpbuild.APIClient, runnerID, pollingSecret, hostURL string) *TelemetryService {
+func NewTelemetryService(warpbuildAPI *warpbuild.APIClient, runnerID, pollingSecret, hostURL string, maxLines int) *TelemetryService {
 	return &TelemetryService{
 		buffer:        map[string]*Buffer{},
+		maxLines:      maxLines,
 		warpbuildAPI:  warpbuildAPI,
 		runnerID:      runnerID,
 		pollingSecret: pollingSecret,
@@ -49,7 +51,7 @@ func (s *TelemetryService) createBufferIfNil(eventType string) error {
 			RunnerID:      s.runnerID,
 			PollingSecret: s.pollingSecret,
 			HostURL:       s.hostURL,
-			MaxLines:      100, // Default max lines
+			MaxLines:      s.maxLines, // Default max lines
 		})
 		if err != nil {
 			log.Logger().Errorf("Failed to create buffer for %s: %v", eventType, err)