Updated db/event.go source file format to LF from CRLF to fix Travis-CI failure (#229)

Author: johndelavega

db/event.go

@@ -1,91 +1,91 @@
-// Copyright 2019 Google Inc. All Rights Reserved.
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-//      http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-
-package db
-
-import (
-	"encoding/json"
-	"errors"
-	"net/http"
-)
-
-// SSE = Sever-Sent Events = ssevent
-
-// EventType ...
-type EventType uint
-
-// EventType ...
-const (
-	ChildChanged EventType = iota
-	ChildAdded             // to be implemented
-	ChildRemoved           // to be implemented
-	ValueChanged           // to be implemented
-)
-
-// Event Sever-Sent Event object
-type Event struct {
-	EventType EventType // ChildChanged, ValueChanged, ChildAdded, ChildRemoved
-
-	Data string // JSON-encoded snapshot
-	Path string // snapshot path
-}
-
-// SnapshotIterator iterator for continuous event
-type SnapshotIterator struct {
-	Snapshot    string         // initial snapshot, JSON-encoded, returned from http Respoonse, server sent event, data part
-	SSEDataChan <-chan string  // continuous event snapshot, channel receive only, directional channel
-	resp        *http.Response // http connection keep alive
-	active      bool           // false when resp is closed, used to prevent channel block, defaults to false
-}
-
-// Snapshot ssevent data, data part
-func (e *Event) Snapshot() string {
-	return e.Data // ssevent data (snapshot), snapshot only, data part of ssevent data
-}
-
-// Unmarshal current snapshot Event.Data
-func (e *Event) Unmarshal(v interface{}) error {
-
-	return json.Unmarshal([]byte(e.Data), v)
-}
-
-// Next ...
-func (i *SnapshotIterator) Next() (*Event, error) {
-
-	// prevent channel block
-	if i.active == false {
-		return nil, errors.New("SnapshotIterator is not active")
-	}
-
-	sseDataString := <-i.SSEDataChan
-
-	// todo: determine EventType
-
-	path, ss, err := splitSSEData(sseDataString)
-
-	return &Event{
-		EventType: ChildChanged,
-		Data:      ss, // snapshot
-		Path:      path,
-	}, err
-
-} // Next()
-
-// Stop ...
-func (i *SnapshotIterator) Stop() {
-	i.active = false
-	if i.resp != nil {
-		i.resp.Body.Close()
-	}
-}
+// Copyright 2019 Google Inc. All Rights Reserved.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//      http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package db
+
+import (
+	"encoding/json"
+	"errors"
+	"net/http"
+)
+
+// SSE = Sever-Sent Events = ssevent
+
+// EventType ...
+type EventType uint
+
+// EventType ...
+const (
+	ChildChanged EventType = iota
+	ChildAdded             // to be implemented
+	ChildRemoved           // to be implemented
+	ValueChanged           // to be implemented
+)
+
+// Event Sever-Sent Event object
+type Event struct {
+	EventType EventType // ChildChanged, ValueChanged, ChildAdded, ChildRemoved
+
+	Data string // JSON-encoded snapshot
+	Path string // snapshot path
+}
+
+// SnapshotIterator iterator for continuous event
+type SnapshotIterator struct {
+	Snapshot    string         // initial snapshot, JSON-encoded, returned from http Respoonse, server sent event, data part
+	SSEDataChan <-chan string  // continuous event snapshot, channel receive only, directional channel
+	resp        *http.Response // http connection keep alive
+	active      bool           // false when resp is closed, used to prevent channel block, defaults to false
+}
+
+// Snapshot ssevent data, data part
+func (e *Event) Snapshot() string {
+	return e.Data // ssevent data (snapshot), snapshot only, data part of ssevent data
+}
+
+// Unmarshal current snapshot Event.Data
+func (e *Event) Unmarshal(v interface{}) error {
+
+	return json.Unmarshal([]byte(e.Data), v)
+}
+
+// Next ...
+func (i *SnapshotIterator) Next() (*Event, error) {
+
+	// prevent channel block
+	if i.active == false {
+		return nil, errors.New("SnapshotIterator is not active")
+	}
+
+	sseDataString := <-i.SSEDataChan
+
+	// todo: determine EventType
+
+	path, ss, err := splitSSEData(sseDataString)
+
+	return &Event{
+		EventType: ChildChanged,
+		Data:      ss, // snapshot
+		Path:      path,
+	}, err
+
+} // Next()
+
+// Stop ...
+func (i *SnapshotIterator) Stop() {
+	i.active = false
+	if i.resp != nil {
+		i.resp.Body.Close()
+	}
+}