DEV
2 years ago
parent
c8c699b3b6
commit
5da4029132
@ -0,0 +1,163 @@
|
||||
// ------------------------------------------------------------------------
|
||||
// 🚀 Project active3
|
||||
// 🔗 Active Thing (activething.com) git.activething.com/go
|
||||
//
|
||||
// File name packer.go
|
||||
// ✍️ Created by DEV
|
||||
// 📅 Modified 30/05/2024
|
||||
//
|
||||
// 🔒 Copyright 2024 activething.com
|
||||
//
|
||||
// 📜 LICENSE --------------------------------------------------------------
|
||||
// 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 pkj
|
||||
|
||||
import (
|
||||
"blds"
|
||||
"cdcs/cjson"
|
||||
"encoding/json"
|
||||
"reflect"
|
||||
"sync"
|
||||
)
|
||||
|
||||
type (
|
||||
|
||||
rpackers struct {
|
||||
mux sync.RWMutex
|
||||
fncs map[reflect.Type]rPackFnc
|
||||
}
|
||||
|
||||
|
||||
rPackFnc func(b *Builder, v reflect.Value)
|
||||
)
|
||||
|
||||
|
||||
func newRPackers () *rpackers {
|
||||
return &rpackers{
|
||||
fncs : make(map[reflect.Type]rPackFnc),
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
func (p *rpackers) getRPacker (rtype reflect.Type) rPackFnc {
|
||||
p.mux.RLock()
|
||||
fn, hs := p.fncs[rtype]
|
||||
p.mux.RUnlock()
|
||||
if hs {
|
||||
return fn
|
||||
}
|
||||
|
||||
fn = p.buildRPacker(rtype)
|
||||
p.mux.Lock()
|
||||
p.fncs[rtype]=fn
|
||||
p.mux.Unlock()
|
||||
|
||||
return fn
|
||||
}
|
||||
|
||||
|
||||
func (p *rpackers) buildRPacker (rtype reflect.Type) rPackFnc {
|
||||
|
||||
if rtype.Implements(g.buildableType) {
|
||||
return func(b *Builder, v reflect.Value) {
|
||||
b.Buildable(v.Interface().(blds.Buildable))
|
||||
}
|
||||
}
|
||||
|
||||
if rtype.Implements(g.jsonMarshalerType) {
|
||||
return func(b *Builder, v reflect.Value) {
|
||||
b.Marshaller(v.Interface().(json.Marshaler))
|
||||
}
|
||||
}
|
||||
|
||||
if rtype.Implements(g.errorType) {
|
||||
return func(b *Builder, v reflect.Value) {
|
||||
b.Error(v.Interface().(error)) }
|
||||
}
|
||||
|
||||
|
||||
switch rtype.Kind() {
|
||||
|
||||
case reflect.Bool:
|
||||
return func(b *Builder, v reflect.Value) { b.Bool(v.Bool()) }
|
||||
|
||||
case reflect.String:
|
||||
return func(b *Builder, v reflect.Value) { b.String(v.String()) }
|
||||
|
||||
case reflect.Int,
|
||||
reflect.Int8,
|
||||
reflect.Int16,
|
||||
reflect.Int32,
|
||||
reflect.Int64:
|
||||
return func(b *Builder, v reflect.Value) { b.Int64(v.Int()) }
|
||||
|
||||
case reflect.Uint,
|
||||
reflect.Uint8,
|
||||
reflect.Uint16,
|
||||
reflect.Uint32,
|
||||
reflect.Uint64,
|
||||
reflect.Uintptr:
|
||||
return func(b *Builder, v reflect.Value) { b.Uint64(v.Uint()) }
|
||||
|
||||
case reflect.Float32:
|
||||
return func(b *Builder, v reflect.Value) { b.float(v.Float(), 32) }
|
||||
case reflect.Float64:
|
||||
return func(b *Builder, v reflect.Value) { b.float(v.Float(), 64) }
|
||||
|
||||
case reflect.Pointer:
|
||||
eleFn := p.getRPacker(rtype.Elem())
|
||||
return func(b *Builder, v reflect.Value) {
|
||||
if v.IsNil() {
|
||||
if !b.preValue() {
|
||||
return
|
||||
}
|
||||
b.B.W(cjson.G.NullValue)
|
||||
b.postValue()
|
||||
return
|
||||
}
|
||||
|
||||
b.Level++
|
||||
if b.Level > maxCyclesAfter {
|
||||
if fn,ok := b.CheckCycle(v.Interface()); ok {
|
||||
defer fn()
|
||||
} else {
|
||||
return
|
||||
}
|
||||
}
|
||||
eleFn(b,v.Elem())
|
||||
b.Level--
|
||||
}
|
||||
|
||||
case reflect.Interface:
|
||||
return func(b *Builder, v reflect.Value) {
|
||||
if v.IsNil() {
|
||||
if !b.preValue() {
|
||||
return
|
||||
}
|
||||
b.B.W(cjson.G.NullValue)
|
||||
return
|
||||
}
|
||||
packReflected(v.Elem().Type())(b,v.Elem())
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
Loading…
Reference in new issue