feature/SCFF-24 removed files related to syslog

Author: nmillalaf

caching/caching_boltdb.go

@@ -2,13 +2,16 @@ package caching
 
 import (
 	"fmt"
+
 	"github.com/boltdb/bolt"
-	"bitbucket.org/mcplusa-ondemand/firehouse-to-sumologic/logging"
-	cfClient "github.com/cloudfoundry-community/go-cfclient"
-	json "github.com/mailru/easyjson"
+	//"bitbucket.org/mcplusa-ondemand/firehouse-to-sumologic/logging"
 	"log"
 	"os"
 	"time"
+
+	"github.com/cloudfoundry-community/firehose-to-syslog1/logging"
+	cfClient "github.com/cloudfoundry-community/go-cfclient"
+	json "github.com/mailru/easyjson"
 )
 
 type CachingBolt struct {

eventRouting/eventRouting_test.go

@@ -3,7 +3,6 @@ package eventRouting_test
 import (
 	. "bitbucket.org/mcplusa-ondemand/firehouse-to-sumologic/caching/cachingfakes"
 	. "bitbucket.org/mcplusa-ondemand/firehouse-to-sumologic/eventRouting"
-	. "bitbucket.org/mcplusa-ondemand/firehouse-to-sumologic/logging/loggingfakes"
 	. "bitbucket.org/mcplusa-ondemand/firehouse-to-sumologic/sumoCFFirehose/sumoLog4gofakes" //**
 	. "github.com/cloudfoundry/sonde-go/events"
 	. "github.com/onsi/ginkgo"
@@ -15,10 +14,10 @@ var _ = Describe("Events", func() {
 	var eventRouting *EventRouting
 
 	BeforeEach(func() {
-		logging := new(FakeLogging)
+		//*logging := new(FakeLogging)
 		caching := new(FakeCaching)
 		sLAppender := new(FakeSumoLog4go)
-		eventRouting = NewEventRouting(caching, logging, sLAppender)
+		eventRouting = NewEventRouting(caching, sLAppender)
 		eventRouting.SetupEventRouting("")
 
 	})

eventRouting/eventrouting.go

@@ -10,10 +10,10 @@ import (
 
 	"bitbucket.org/mcplusa-ondemand/firehouse-to-sumologic/caching"
 	fevents "bitbucket.org/mcplusa-ondemand/firehouse-to-sumologic/events"
-	"bitbucket.org/mcplusa-ondemand/firehouse-to-sumologic/extrafields"
-	"bitbucket.org/mcplusa-ondemand/firehouse-to-sumologic/logging"
-	"bitbucket.org/mcplusa-ondemand/firehouse-to-sumologic/sumoCFFirehose" //**
+	"bitbucket.org/mcplusa-ondemand/firehouse-to-sumologic/sumoCFFirehose"
 	"github.com/Sirupsen/logrus"
+	"github.com/cloudfoundry-community/firehose-to-syslog1/extrafields"
+	"github.com/cloudfoundry-community/firehose-to-syslog1/logging"
 	"github.com/cloudfoundry/sonde-go/events"
 )
 
@@ -23,19 +23,19 @@ type EventRouting struct {
 	selectedEventsCount map[string]uint64
 	mutex               *sync.Mutex
 	sLAppender          sumoCFFirehose.SumoCFFirehose //**
-	log                 logging.Logging
-	ExtraFields         map[string]string
+	//*log                 logging.Logging
+	ExtraFields map[string]string
 }
 
-func NewEventRouting(caching caching.Caching, logging logging.Logging, sLAppender sumoCFFirehose.SumoCFFirehose) *EventRouting {
+func NewEventRouting(caching caching.Caching, sLAppender sumoCFFirehose.SumoCFFirehose) *EventRouting {
 	return &EventRouting{
 		CachingClient:       caching,
 		selectedEvents:      make(map[string]bool),
 		selectedEventsCount: make(map[string]uint64),
 		sLAppender:          sLAppender, //**
-		log:                 logging,
-		mutex:               &sync.Mutex{},
-		ExtraFields:         make(map[string]string),
+		//*		log:                 logging,
+		mutex:       &sync.Mutex{},
+		ExtraFields: make(map[string]string),
 	}
 }
 
@@ -80,8 +80,10 @@ func (e *EventRouting) RouteEvent(msg *events.Envelope) {
 		if ignored, hasIgnoredField := event.Fields["cf_ignored_app"]; ignored == true && hasIgnoredField {
 			e.selectedEventsCount["ignored_app_message"]++
 		} else {
-			e.sLAppender.AppendLogs(event.Fields)     //**
-			e.log.ShipEvents(event.Fields, event.Msg) // here we have to change the method for the one on sumoLogicAppender
+			/*fmt.Printf("I'm in eventRpouting method .. -------")
+			fmt.Println(event.Fields)
+			fmt.Println(event.Msg)*/
+			e.sLAppender.AppendLogs(event.Fields) //**/here we have to change the method for the one on sumoLogicAppender
 			e.selectedEventsCount[eventType.String()]++
 
 		}
@@ -97,7 +99,7 @@ func (e *EventRouting) SetupEventRouting(wantedEvents string) error {
 		for _, event := range strings.Split(wantedEvents, ",") {
 			if e.isAuthorizedEvent(strings.TrimSpace(event)) {
 				e.selectedEvents[strings.TrimSpace(event)] = true
-				logging.LogStd(fmt.Sprintf("Event Type [%s] is included in the fireshose!", event), false)
+				//logging.LogStd(fmt.Sprintf("Event Type [%s] is included in the fireshose!", event), false)
 			} else {
 				return fmt.Errorf("Rejected Event Name [%s] - Valid events: %s", event, GetListAuthorizedEventEvents())
 			}
@@ -159,7 +161,8 @@ func (e *EventRouting) LogEventTotals(logTotalsTime time.Duration) {
 			startTime = time.Now()
 			event, lastCount := e.getEventTotals(totalElapsedTime, elapsedTime, count)
 			count = lastCount
-			e.log.ShipEvents(event.Fields, event.Msg)
+			//*e.log.ShipEvents(event.Fields, event.Msg)
+			e.sLAppender.AppendLogs(event.Fields)
 		}
 	}()
 }

extrafields/extrafields.go

@@ -5,7 +5,8 @@ import (
 	"time"
 
 	"bitbucket.org/mcplusa-ondemand/firehouse-to-sumologic/eventRouting"
-	"bitbucket.org/mcplusa-ondemand/firehouse-to-sumologic/logging"
+	//*"bitbucket.org/mcplusa-ondemand/firehouse-to-sumologic/logging"
+
 	"github.com/cloudfoundry-community/go-cfclient"
 	"github.com/cloudfoundry/noaa/consumer"
 	"github.com/cloudfoundry/sonde-go/events"
@@ -75,22 +76,22 @@ func (f *FirehoseNozzle) handleError(err error) {
 
 	switch {
 	case websocket.IsCloseError(err, websocket.CloseNormalClosure):
-		logging.LogError("Normal Websocket Closure", err)
+		//logging.LogError("Normal Websocket Closure", err)
 	case websocket.IsCloseError(err, websocket.ClosePolicyViolation):
-		logging.LogError("Error while reading from the firehose", err)
-		logging.LogError("Disconnected because nozzle couldn't keep up. Please try scaling up the nozzle.", nil)
+		//logging.LogError("Error while reading from the firehose", err)
+		//logging.LogError("Disconnected because nozzle couldn't keep up. Please try scaling up the nozzle.", nil)
 
 	default:
-		logging.LogError("Error while reading from the firehose", err)
+		//logging.LogError("Error while reading from the firehose", err)
 	}
 
-	logging.LogError("Closing connection with traffic controller due to error", err)
+	//logging.LogError("Closing connection with traffic controller due to error", err)
 	f.consumer.Close()
 }
 
 func (f *FirehoseNozzle) handleMessage(envelope *events.Envelope) {
 	if envelope.GetEventType() == events.Envelope_CounterEvent && envelope.CounterEvent.GetName() == "TruncatingBuffer.DroppedMessages" && envelope.GetOrigin() == "doppler" {
-		logging.LogStd("We've intercepted an upstream message which indicates that the nozzle or the TrafficController is not keeping up. Please try scaling up the nozzle.", true)
+		//logging.LogStd("We've intercepted an upstream message which indicates that the nozzle or the TrafficController is not keeping up. Please try scaling up the nozzle.", true)
 	}
 }