10814152930

Committed 11 Sep 2024 02:44PM UTC coverage: 75.27%. Remained the same

Build # 10814152930

Build Type

push

github

Committed by

web-flow

Commit Message

Update deps (#305)

* Update k6 to v0.53.0
* Update Go to v1.23.1
* Update deps
* Update Go version in actions
* Pin package to avoid conflicts

Run Details

1534 of 2038 relevant lines covered (75.27%)

13.66 hits per line

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

76.47

/utils.go

package kafka

import (
        "encoding/base64"
        "encoding/json"

        "github.com/grafana/sobek"
)

// freeze disallows resetting or changing the properties of the object.
func freeze(o *sobek.Object) {
        for _, key := range o.Keys() {
                if err := o.DefineDataProperty(
                        key, o.Get(key), sobek.FLAG_FALSE, sobek.FLAG_FALSE, sobek.FLAG_TRUE); err != nil {
                        panic(err)
                }
        }
}

// base64ToBytes converts the base64 encoded data to bytes.
func base64ToBytes(data string) ([]byte, *Xk6KafkaError) {
        result, err := base64.StdEncoding.DecodeString(data)
        if err != nil {
                return nil, NewXk6KafkaError(failedDecodeBase64, "Failed to decode base64 string", err)
        }
        return result, nil
}

// isBase64Encoded checks whether the data is base64 encoded.
func isBase64Encoded(data string) bool {
        _, err := base64ToBytes(data)
        return err == nil
}

// toJSONBytes encodes a map into JSON bytes
func toJSONBytes(data interface{}) ([]byte, *Xk6KafkaError) {
        if data, ok := data.(map[string]interface{}); ok {
                if jsonData, err := json.Marshal(data); err == nil {
                        return jsonData, nil
                }
        }

        return nil, ErrInvalidDataType
}

func toMap(data []byte) (map[string]interface{}, *Xk6KafkaError) {
        var js map[string]interface{}
        if err := json.Unmarshal(data, &js); err != nil {
                return nil, NewXk6KafkaError(failedUnmarshalJSON, "Failed to decode data", err)
        }
        return js, nil
}

func isJSON(data []byte) bool {
        if json.Valid(data) {
                if _, err := toMap(data); err != nil {
                        return false
                }
                return true
        }
        return false
}

1	package kafka
2
3	import (
4	"encoding/base64"
5	"encoding/json"
6
7	"github.com/grafana/sobek"
8	)
9
10	// freeze disallows resetting or changing the properties of the object.
11	func freeze(o *sobek.Object) {	2✔
12	for _, key := range o.Keys() {	8✔
13	if err := o.DefineDataProperty(	6✔
14	key, o.Get(key), sobek.FLAG_FALSE, sobek.FLAG_FALSE, sobek.FLAG_TRUE); err != nil {	6✔
15	panic(err)	×
16	}
17	}
18	}
19
20	// base64ToBytes converts the base64 encoded data to bytes.
21	func base64ToBytes(data string) ([]byte, *Xk6KafkaError) {	2✔
22	result, err := base64.StdEncoding.DecodeString(data)	2✔
23	if err != nil {	2✔
24	return nil, NewXk6KafkaError(failedDecodeBase64, "Failed to decode base64 string", err)	×
25	}	×
26	return result, nil	2✔
27	}
28
29	// isBase64Encoded checks whether the data is base64 encoded.
30	func isBase64Encoded(data string) bool {	1✔
31	_, err := base64ToBytes(data)	1✔
32	return err == nil	1✔
33	}	1✔
34
35	// toJSONBytes encodes a map into JSON bytes
36	func toJSONBytes(data interface{}) ([]byte, *Xk6KafkaError) {	8✔
37	if data, ok := data.(map[string]interface{}); ok {	14✔
38	if jsonData, err := json.Marshal(data); err == nil {	11✔
39	return jsonData, nil	5✔
40	}	5✔
41	}
42
43	return nil, ErrInvalidDataType	3✔
44	}
45
46	func toMap(data []byte) (map[string]interface{}, *Xk6KafkaError) {	2✔
47	var js map[string]interface{}	2✔
48	if err := json.Unmarshal(data, &js); err != nil {	2✔
49	return nil, NewXk6KafkaError(failedUnmarshalJSON, "Failed to decode data", err)	×
50	}	×
51	return js, nil	2✔
52	}
53
54	func isJSON(data []byte) bool {	1✔
55	if json.Valid(data) {	2✔
56	if _, err := toMap(data); err != nil {	1✔
57	return false	×
58	}	×
59	return true	1✔
60	}
61	return false	×
62	}

mostafa / xk6-kafka / 10814152930

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