Merge pull request #1 from v8platform/develop

v0.2.0

Author: khorevaa

bracket.go

@@ -20,22 +20,44 @@ import (
 type Node interface {
 
 	// GetNode получение вложенных нов по их адресу в массиве норд
-	GetNode(address ...int) (Node, error)
+	GetNode(address ...int) Node
+	GetNodeE(address ...int) (Node, error)
+
+	// Get получение значение ноды по адресу
+	Get(address ...int) string
 
 	// String получение строкового значение ноды
 	//	Для нод без вложенных нод выводиться их значение
 	//	Для всех остальных выводиться строковое представление ноды
 	String() string
 
-	// Int получение числового значение ноды
-	Int() int
+	// Int64 получение числового значение ноды
+	Int64(address ...int) int64
 	// Bool получение булевного значение ноды
-	Bool() bool
+	Bool(address ...int) bool
 	// Int получение числового с запятой значение ноды
-	Float64() float64
+	Float64(address ...int) float64
+
+	value() bool
 }
 
 var ErrNodeAddress = errors.New("address node is broken")
+var emptyNode = bracketsNode{}
+
+func EmptyNode(n Node) bool {
+
+	bNode, ok := n.(bracketsNode)
+
+	if !ok {
+		return false
+	}
+
+	if len(bNode.Text) > 0 || len(bNode.Nodes) > 0 {
+		return true
+	}
+
+	return false
+}
 
 // Nodes Массив Node с функцией String()
 type Nodes []Node
@@ -54,28 +76,57 @@ func (b Nodes) String() string {
 }
 
 type bracketsNode struct {
-	Text string
-
+	Text  string
 	Nodes Nodes
-	//Count int
 
 	valueNode bool
 }
 
-func (b bracketsNode) GetNode(address ...int) (Node, error) {
+func (b bracketsNode) value() bool {
+	return b.valueNode
+}
+
+func (b bracketsNode) Get(address ...int) string {
+
+	if len(address) == 0 && b.value() {
+		return b.Text
+	}
+
+	node, _ := b.getNode(address)
+	if node.value() {
+		return node.Text
+	}
+
+	return ""
+
+}
+
+func (b bracketsNode) getNode(address []int) (bracketsNode, error) {
 
 	currentNode := b
 
 	for i, _ := range address {
 
 		if len(currentNode.Nodes) <= address[i] {
-			return nil, ErrNodeAddress
+			return emptyNode, ErrNodeAddress
 		}
 
 		currentNode = currentNode.Nodes[address[i]].(bracketsNode)
 	}
 
 	return currentNode, nil
+
+}
+
+func (b bracketsNode) GetNode(address ...int) Node {
+
+	node, _ := b.getNode(address)
+	return node
+}
+
+func (b bracketsNode) GetNodeE(address ...int) (Node, error) {
+
+	return b.getNode(address)
 }
 
 func (b bracketsNode) String() string {
@@ -95,27 +146,55 @@ func (b bracketsNode) String() string {
 	return fmt.Sprintf("{%s}", val)
 }
 
-func (b bracketsNode) Int() int {
-	i, _ := strconv.ParseInt(b.Text, 10, 64)
-	return int(i)
+func (b bracketsNode) Int64(address ...int) int64 {
+
+	n, err := b.getNode(address)
+	if err != nil ||
+		!b.value() ||
+		len(b.Text) == 0 {
+		return 0
+	}
+
+	i, _ := strconv.ParseInt(n.Text, 10, 64)
+	return i
 }
 
-func (b bracketsNode) Bool() bool {
+func (b bracketsNode) Bool(address ...int) bool {
 
-	val, _ := strconv.ParseBool(b.Text)
+	n, err := b.getNode(address)
+	if err != nil ||
+		!b.value() ||
+		len(b.Text) == 0 {
+		return false
+	}
+	val, _ := strconv.ParseBool(n.Text)
 	return val
 }
 
-func (b bracketsNode) Float64() float64 {
+func (b bracketsNode) Float64(address ...int) float64 {
+
+	n, err := b.getNode(address)
+	if err != nil ||
+		!b.value() ||
+		len(b.Text) == 0 {
+		return 0
+	}
 
-	f, _ := strconv.ParseFloat(b.Text, 64)
+	f, _ := strconv.ParseFloat(n.Text, 64)
 	return f
 }
 
 func newValueNode(value string) bracketsNode {
-
+	addQuotesIfNeed(&value)
 	return bracketsNode{
 		Text:      value,
 		valueNode: true,
 	}
 }
+
+func addQuotesIfNeed(value *string) {
+
+	if strings.ContainsAny(*value, `'"`) {
+		*value = `"` + *value + `"`
+	}
+}

bracket_test.go

@@ -65,7 +65,7 @@ func Test_bucketsNode_GetNode(t *testing.T) {
 				Nodes:     tt.fields.Nodes,
 				valueNode: tt.fields.valueNode,
 			}
-			got, err := b.GetNode(tt.args.address...)
+			got, err := b.GetNodeE(tt.args.address...)
 			if (err != nil) != tt.wantErr {
 				t.Errorf("GetNode() error = %v, wantErr %v", err, tt.wantErr)
 				return

example_test.go

@@ -82,19 +82,19 @@ func ExampleBracketsNode_GetNode() {
 
 	node := parser.NextNode()
 
-	node0, _ := node.GetNode(0)
+	node0, _ := node.GetNodeE(0)
 	fmt.Printf("node <%s>\n", node0.String()) // 20200412134348
 
-	node1, _ := node.GetNode(1)
-	fmt.Printf("node <%s>\n", node1.String()) // N
+	node1 := node.Get(1)
+	fmt.Printf("node <%s>\n", node1) // N
 
-	node21, _ := node.GetNode(2, 1)
-	fmt.Printf("node <%d>\n", node21.Int()) // {0,13} -> 13
+	node21 := node.Int64(2, 1)
+	fmt.Printf("node <%d>\n", node21) // {0,13} -> 13
 
-	node11, _ := node.GetNode(11)
+	node11 := node.GetNode(11)
 	fmt.Printf("node <%s>\n", node11) // {"U"}
 
-	_, err := node.GetNode(1, 2)  // Отсутствующий адрес ноды
+	_, err := node.GetNodeE(1, 2) // Отсутствующий адрес ноды
 	fmt.Printf("err <%s>\n", err) // {0,13} -> 13
 
 	// Output:

parser_test.go

@@ -136,6 +136,11 @@ func TestBucketsParser_ReadAllNodes_file(t *testing.T) {
 			"./20200412130000.lgp",
 			5,
 		},
+		{
+			"multiline log",
+			"./tests/multiline.lgp",
+			5,
+		},
 	}
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {

tests/multiline.lgp

@@ -0,0 +1,38 @@
+{20200930215529,N,
+{0,0},4,1,2,2,12,I,"Идентификатор шага: Новости. Все обновления новостей. Проверка версии платформы
+Проверка изменения версии платформы
+Строка подключения: File=""/Users/khorevaa/Documents/InfoBase2"";
+ТекущийРежимЗапуска: Управляемое приложение
+Это разделенная конфигурация: Да
+Разделение включено: Нет
+Доступно использование разделенных данных: Да
+Сеанс запущен без разделителей: Да
+Конфигурация (метаданные): УправлениеНебольшойФирмой, 1.6.21.124
+Конфигурация (переопределение): SmallBusiness, 01.06.021.0124
+Платформа: 08.03.015.1830
+Функциональная опция Разрешена работа с новостями: Да
+Функциональная опция Разрешена работа с новостями через интернет: Да
+Текущий пользователь ИБ:
+	Имя: Администратор
+	УИН: 1366c862-f385-11ea-3284-005056ae0f31
+	Разделение данных:
+
+Время начала (мс): 63 737 088 929 329
+Время окончания (мс): 63 737 088 929 361
+Длительность (мс): 32
+Результат по шагам:
+Шаг: Проверка изменения версии платформы
+Длительность (мс): 32
+Результат выполнения: (0), Сохраненная версия платформы: 8.3.15.1830
+Текущая версия платформы: 8.3.15.1830
+Редко меняющиеся отборы останутся как есть
+
+Версия конфигурации в этой обработке не проверяется, а пересчитывается принудительно в модуле обновления конфигурации, а также после каждого получения новостей.
+Попытка зафиксировать транзакцию.
+ТекущаяДатаДляРегистров: 30.09.2020 18:55:29
+ДатаСледующегоОбновления: 01.10.2020 0:55:29
+
+",0,
+{"N",32},"",0,0,0,4,0,
+{2,1,1,2,1}
+}