diff options
author | Lunny Xiao <xiaolunwen@gmail.com> | 2021-07-25 00:03:58 +0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-07-24 18:03:58 +0200 |
commit | 9f31f3aa8ac4f6bfc8390c9ae63b2a387b414c88 (patch) | |
tree | 6f27dc68a35d1f9d806c632e36f0edc8543184ea /modules/queue | |
parent | e0f9635c0691cb67f0fcbb758cabba801d9fc51b (diff) | |
download | gitea-9f31f3aa8ac4f6bfc8390c9ae63b2a387b414c88.tar.gz gitea-9f31f3aa8ac4f6bfc8390c9ae63b2a387b414c88.zip |
Add an abstract json layout to make it's easier to change json library (#16528)
* Add an abstract json layout to make it's easier to change json library
* Fix import
* Fix import sequence
* Fix blank lines
* Fix blank lines
Diffstat (limited to 'modules/queue')
-rw-r--r-- | modules/queue/helper.go | 7 | ||||
-rw-r--r-- | modules/queue/manager.go | 3 | ||||
-rw-r--r-- | modules/queue/queue_bytefifo.go | 4 | ||||
-rw-r--r-- | modules/queue/queue_test.go | 5 | ||||
-rw-r--r-- | modules/queue/setting.go | 4 |
5 files changed, 6 insertions, 17 deletions
diff --git a/modules/queue/helper.go b/modules/queue/helper.go index e0368bce3a..f1aba411a8 100644 --- a/modules/queue/helper.go +++ b/modules/queue/helper.go @@ -7,7 +7,7 @@ package queue import ( "reflect" - jsoniter "github.com/json-iterator/go" + "code.gitea.io/gitea/modules/json" ) // Mappable represents an interface that can MapTo another interface @@ -20,8 +20,6 @@ type Mappable interface { // It will tolerate the cfg being passed as a []byte or string of a json representation of the // exemplar or the correct type of the exemplar itself func toConfig(exemplar, cfg interface{}) (interface{}, error) { - json := jsoniter.ConfigCompatibleWithStandardLibrary - // First of all check if we've got the same type as the exemplar - if so it's all fine. if reflect.TypeOf(cfg).AssignableTo(reflect.TypeOf(exemplar)) { return cfg, nil @@ -48,7 +46,6 @@ func toConfig(exemplar, cfg interface{}) (interface{}, error) { if !ok { // hmm ... can we marshal it to json? var err error - configBytes, err = json.Marshal(cfg) ok = err == nil } @@ -68,7 +65,6 @@ func toConfig(exemplar, cfg interface{}) (interface{}, error) { // unmarshalAs will attempt to unmarshal provided bytes as the provided exemplar func unmarshalAs(bs []byte, exemplar interface{}) (data Data, err error) { - json := jsoniter.ConfigCompatibleWithStandardLibrary if exemplar != nil { t := reflect.TypeOf(exemplar) n := reflect.New(t) @@ -78,7 +74,6 @@ func unmarshalAs(bs []byte, exemplar interface{}) (data Data, err error) { } else { err = json.Unmarshal(bs, &data) } - return } diff --git a/modules/queue/manager.go b/modules/queue/manager.go index a6d48575ab..a88933191a 100644 --- a/modules/queue/manager.go +++ b/modules/queue/manager.go @@ -12,8 +12,8 @@ import ( "sync" "time" + "code.gitea.io/gitea/modules/json" "code.gitea.io/gitea/modules/log" - jsoniter "github.com/json-iterator/go" ) var manager *Manager @@ -110,7 +110,6 @@ func (m *Manager) Add(managed interface{}, configuration, exemplar interface{}) int64 { - json := jsoniter.ConfigCompatibleWithStandardLibrary cfg, _ := json.Marshal(configuration) mq := &ManagedQueue{ Type: t, diff --git a/modules/queue/queue_bytefifo.go b/modules/queue/queue_bytefifo.go index 3ea61aad0e..edde47a62d 100644 --- a/modules/queue/queue_bytefifo.go +++ b/modules/queue/queue_bytefifo.go @@ -10,8 +10,8 @@ import ( "sync" "time" + "code.gitea.io/gitea/modules/json" "code.gitea.io/gitea/modules/log" - jsoniter "github.com/json-iterator/go" ) // ByteFIFOQueueConfiguration is the configuration for a ByteFIFOQueue @@ -83,7 +83,6 @@ func (q *ByteFIFOQueue) PushFunc(data Data, fn func() error) error { if !assignableTo(data, q.exemplar) { return fmt.Errorf("Unable to assign data: %v to same type as exemplar: %v in %s", data, q.exemplar, q.name) } - json := jsoniter.ConfigCompatibleWithStandardLibrary bs, err := json.Marshal(data) if err != nil { return err @@ -309,7 +308,6 @@ func (q *ByteFIFOUniqueQueue) Has(data Data) (bool, error) { if !assignableTo(data, q.exemplar) { return false, fmt.Errorf("Unable to assign data: %v to same type as exemplar: %v in %s", data, q.exemplar, q.name) } - json := jsoniter.ConfigCompatibleWithStandardLibrary bs, err := json.Marshal(data) if err != nil { return false, err diff --git a/modules/queue/queue_test.go b/modules/queue/queue_test.go index 89ce23ac4c..65fb816537 100644 --- a/modules/queue/queue_test.go +++ b/modules/queue/queue_test.go @@ -7,7 +7,8 @@ package queue import ( "testing" - jsoniter "github.com/json-iterator/go" + "code.gitea.io/gitea/modules/json" + "github.com/stretchr/testify/assert" ) @@ -29,8 +30,6 @@ func TestToConfig(t *testing.T) { assert.True(t, ok) assert.NotEqual(t, cfg2, exemplar) assert.Equal(t, &cfg, &cfg2) - - json := jsoniter.ConfigCompatibleWithStandardLibrary cfgString, err := json.Marshal(cfg) assert.NoError(t, err) diff --git a/modules/queue/setting.go b/modules/queue/setting.go index 9b2c31b783..0e6ff3a0a8 100644 --- a/modules/queue/setting.go +++ b/modules/queue/setting.go @@ -8,9 +8,9 @@ import ( "fmt" "strings" + "code.gitea.io/gitea/modules/json" "code.gitea.io/gitea/modules/log" "code.gitea.io/gitea/modules/setting" - jsoniter "github.com/json-iterator/go" ) func validType(t string) (Type, error) { @@ -27,8 +27,6 @@ func validType(t string) (Type, error) { func getQueueSettings(name string) (setting.QueueSettings, []byte) { q := setting.GetQueueSettings(name) - - json := jsoniter.ConfigCompatibleWithStandardLibrary cfg, err := json.Marshal(q) if err != nil { log.Error("Unable to marshall generic options: %v Error: %v", q, err) |