26936915281

Committed 04 Jun 2026 07:15AM UTC coverage: 91.739% (+0.2%) from 91.501%

Build # 26936915281

Build Type

Pull #620

github

Committed by

liran-funaro

Commit Message

[notify] Introduce StreamAllTransactions stream

Signed-off-by: Liran Funaro <liran.funaro@gmail.com>

Pull Request Pull Request #620: [notify] Introduce StreamAllTransactions stream

Coverage Stats

47 of 204 new or added lines in 6 files covered. (23.04%)

837 existing lines in 48 files now uncovered.

10406 of 11343 relevant lines covered (91.74%)

82884.38 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

89.74

/utils/encoding.go

/*
Copyright IBM Corp. All Rights Reserved.

SPDX-License-Identifier: Apache-2.0
*/

package utils

import (
        "encoding/binary"
        "fmt"

        "github.com/cockroachdb/errors"
        "github.com/golang/protobuf/proto" //nolint:staticcheck // proto.EncodeVarint does not exist in the new version
)

// EncodeOrderPreservingVarUint64 returns a byte-representation for a uint64 number such that
// all zero-bits starting bytes are trimmed in order to reduce the length of the array
// For preserving the order in a default bytes-comparison, first byte contains the number of remaining bytes.
// The presence of first byte also allows to use the returned bytes as part of other larger byte array such as a
// composite-key representation in db.
func EncodeOrderPreservingVarUint64(number uint64) []byte {
        bytes := make([]byte, 8)
        binary.BigEndian.PutUint64(bytes, number)
        startingIndex := 0
        size := 0
        for i, b := range bytes {
                if b != 0x00 {
                        startingIndex = i
                        size = 8 - i
                        break
                }
        }

        sizeBytes := proto.EncodeVarint(uint64(size)) //nolint:gosec // integer overflow conversion int -> uint64.
        if len(sizeBytes) > 1 {
                panic(fmt.Errorf(
                        "[]sizeBytes should not be more than one byte because the max number it needs to hold is 8. size=%d",
                        size,
                ))
        }
        encodedBytes := make([]byte, size+1)
        encodedBytes[0] = sizeBytes[0]
        copy(encodedBytes[1:], bytes[startingIndex:])
        return encodedBytes
}

// DecodeOrderPreservingVarUint64 decodes the number from the bytes obtained from method
// 'EncodeOrderPreservingVarUint64'.
// It returns the decoded number, the number of bytes that are consumed in the process,
// and an error if the input bytes are invalid.
func DecodeOrderPreservingVarUint64(bytes []byte) (uint64, int, error) {
        s, numBytes := proto.DecodeVarint(bytes)

        switch {
        case numBytes != 1:
                return 0, 0, errors.Newf("number of consumed bytes from DecodeVarint is invalid, expected 1, but got %d",
                        numBytes)
        case s > 8:
                return 0, 0, errors.Newf("decoded size from DecodeVarint is invalid, expected <=8, but got %d", s)
        case int(s) > len(bytes)-1:
                return 0, 0, errors.Newf("decoded size (%d) from DecodeVarint is more than available bytes (%d)",
                        s, len(bytes)-1)
        default:
                // no error
                size := int(s)
                decodedBytes := make([]byte, 8)
                copy(decodedBytes[8-size:], bytes[1:size+1])
                numBytesConsumed := size + 1
                return binary.BigEndian.Uint64(decodedBytes), numBytesConsumed, nil
        }
}

1	/*
2	Copyright IBM Corp. All Rights Reserved.
3
4	SPDX-License-Identifier: Apache-2.0
5	*/
6
7	package utils
8
9	import (
10	"encoding/binary"
11	"fmt"
12
13	"github.com/cockroachdb/errors"
14	"github.com/golang/protobuf/proto" //nolint:staticcheck // proto.EncodeVarint does not exist in the new version
15	)
16
17	// EncodeOrderPreservingVarUint64 returns a byte-representation for a uint64 number such that
18	// all zero-bits starting bytes are trimmed in order to reduce the length of the array
19	// For preserving the order in a default bytes-comparison, first byte contains the number of remaining bytes.
20	// The presence of first byte also allows to use the returned bytes as part of other larger byte array such as a
21	// composite-key representation in db.
22	func EncodeOrderPreservingVarUint64(number uint64) []byte {	87,924✔
23	bytes := make([]byte, 8)	87,924✔
24	binary.BigEndian.PutUint64(bytes, number)	87,924✔
25	startingIndex := 0	87,924✔
26	size := 0	87,924✔
27	for i, b := range bytes {	754,947✔
28	if b != 0x00 {	754,635✔
29	startingIndex = i	87,612✔
30	size = 8 - i	87,612✔
31	break	87,612✔
32	}
33	}
34
35	sizeBytes := proto.EncodeVarint(uint64(size)) //nolint:gosec // integer overflow conversion int -> uint64.	87,924✔
36	if len(sizeBytes) > 1 {	87,924✔
37	panic(fmt.Errorf(	×
38	"[]sizeBytes should not be more than one byte because the max number it needs to hold is 8. size=%d",	×
39	size,	×
40	))	×
41	}
42	encodedBytes := make([]byte, size+1)	87,924✔
43	encodedBytes[0] = sizeBytes[0]	87,924✔
44	copy(encodedBytes[1:], bytes[startingIndex:])	87,924✔
45	return encodedBytes	87,924✔
46	}
47
48	// DecodeOrderPreservingVarUint64 decodes the number from the bytes obtained from method
49	// 'EncodeOrderPreservingVarUint64'.
50	// It returns the decoded number, the number of bytes that are consumed in the process,
51	// and an error if the input bytes are invalid.
52	func DecodeOrderPreservingVarUint64(bytes []byte) (uint64, int, error) {	11,676✔
53	s, numBytes := proto.DecodeVarint(bytes)	11,676✔
54		11,676✔
55	switch {	11,676✔
UNCOV 56	case numBytes != 1:	6✔
UNCOV 57	return 0, 0, errors.Newf("number of consumed bytes from DecodeVarint is invalid, expected 1, but got %d",	6✔
UNCOV 58	numBytes)	6✔
UNCOV 59	case s > 8:	1✔
UNCOV 60	return 0, 0, errors.Newf("decoded size from DecodeVarint is invalid, expected <=8, but got %d", s)	1✔
UNCOV 61	case int(s) > len(bytes)-1:	1✔
UNCOV 62	return 0, 0, errors.Newf("decoded size (%d) from DecodeVarint is more than available bytes (%d)",	1✔
UNCOV 63	s, len(bytes)-1)	1✔
64	default:	11,668✔
65	// no error	11,668✔
66	size := int(s)	11,668✔
67	decodedBytes := make([]byte, 8)	11,668✔
68	copy(decodedBytes[8-size:], bytes[1:size+1])	11,668✔
69	numBytesConsumed := size + 1	11,668✔
70	return binary.BigEndian.Uint64(decodedBytes), numBytesConsumed, nil	11,668✔
71	}
72	}

hyperledger / fabric-x-committer / 26936915281

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous