redefiniendo el builder

packs2
DEV 3 years ago
parent d0529f9c2a
commit f07a23f57f

@ -34,10 +34,10 @@ func main() {
pk := pjson.NewPacker()
pk.PackList(func(p packs.ListPacker, flags packs.Flags){
pk.PackList(func(p packs.BuilderList, flags packs.Flags){
p.ItemUInt64(0,flags)
p.ItemFloat64(7.8,flags)
p.ItemList(func (p1 packs.ListPacker, f packs.Flags){
p.ItemList(func (p1 packs.BuilderList, f packs.Flags){
p1.ItemString("MICasa",flags)
p1.ItemString("Coche",flags)
},flags)

@ -27,7 +27,7 @@ import "time"
type (
ListPacker interface {
BuilderList interface {
ItemAny (value any, flags Flags)
@ -53,9 +53,9 @@ type (
ItemDate (value time.Time, flags Flags)
ItemList (builder func(packer ListPacker, flags Flags), flags Flags)
ItemMap (builder func(packer MapPacker , flags Flags), flags Flags)
ItemObject(builder func(packer ObjectPacker, flags Flags), flags Flags)
ItemList (builder func(packer BuilderList, flags Flags), flags Flags)
ItemMap (builder func(packer BuilderMap, flags Flags), flags Flags)
ItemObject(builder func(packer BuilderObject, flags Flags), flags Flags)
}
)

@ -0,0 +1,65 @@
// ------------------------------------------------------------------------
// Project atila
// Active Thing (activething.com, flags Flags) git.activething.com/go
//
// File name map_packer.go
// Created by DEV
// Modified 23/01/2024
//
// Copyright 2024 activething.com
// ------------------------------------------------------------------------
// Licensed under the Apache License, Version 2.0 (the "License", flags Flags);
// 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 packs
import "time"
type (
BuilderMap interface {
KeyValueAny (key any, value any, flags Flags)
KeyValueRaw (key any,value []byte, flags Flags)
KeyValueBinary(key any, value []byte, flags Flags)
KeyValueString(key any, value string, flags Flags)
KeyValueBool (key any, value bool, flags Flags)
KeyValueInt8 (key any, value int8 , flags Flags)
KeyValueInt16 (key any, value int16, flags Flags)
KeyValueInt32 (key any, value int32, flags Flags)
KeyValueInt64 (key any, value int64, flags Flags)
KeyValueUInt8 (key any, value uint8 , flags Flags)
KeyValueUInt16 (key any, value uint16, flags Flags)
KeyValueUInt32 (key any, value uint32, flags Flags)
KeyValueUInt64 (key any, value uint64, flags Flags)
KeyValueFloat32(key any, value float32, flags Flags)
KeyValueFloat64(key any, value float64, flags Flags)
KeyValueDate (key any, value time.Time, flags Flags)
KeyValueList (key any, builder func(packer BuilderList, flags Flags), flags Flags)
KeyValueMap (key any, builder func(packer BuilderMap, flags Flags), flags Flags)
KeyValueObject(key any, builder func(packer BuilderObject, flags Flags), flags Flags)
}
)

@ -0,0 +1,65 @@
// ------------------------------------------------------------------------
// Project atila
// Active Thing (activething.com) git.activething.com/go
//
// File name object_packer.go
// Created by DEV
// Modified 23/01/2024
//
// Copyright 2024 activething.com
// ------------------------------------------------------------------------
// 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 packs
import "time"
type (
BuilderObject interface {
FieldAny (name string, value any, flags Flags)
FieldRaw (name string, value []byte, flags Flags)
FieldBinary (name string, value []byte, flags Flags)
FieldString (name string, value string, flags Flags)
FieldBool (name string, value bool, flags Flags)
FieldInt8 (name string, value int8 , flags Flags)
FieldInt16 (name string, value int16, flags Flags)
FieldInt32 (name string, value int32, flags Flags)
FieldInt64 (name string, value int64, flags Flags)
FieldUInt8 (name string, value uint8, flags Flags)
FieldUInt16 (name string, value uint16, flags Flags)
FieldUInt32 (name string, value uint32, flags Flags)
FieldUInt64 (name string, value uint64, flags Flags)
FieldFloat32 (name string, value float32, flags Flags)
FieldFloat64 (name string, value float64, flags Flags)
FieldDate (name string, value time.Time, flags Flags)
FieldList (name string, builder func(packer BuilderList, flags Flags), flags Flags)
FieldMap (name string, builder func(packer BuilderMap, flags Flags), flags Flags)
FieldObject(name string, builder func(packer BuilderObject, flags Flags), flags Flags)
}
)

@ -1,66 +0,0 @@
// ------------------------------------------------------------------------
// Project atila
// Active Thing (activething.com) git.activething.com/go
//
// File name object_packer.go
// Created by DEV
// Modified 23/01/2024
//
// Copyright 2024 activething.com
// ------------------------------------------------------------------------
// 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 packs
import "time"
type (
ObjectPacker interface {
Field (name string, value any)
FieldRaw (name string, value []byte)
FieldBinary (name string, value []byte)
FieldString (name string, value string)
FieldBool (name string, value bool)
FieldInt8 (name string, value int8)
FieldInt16 (name string, value int16)
FieldInt32 (name string, value int32)
FieldInt64 (name string, value int64)
FieldUInt8 (name string, value uint8)
FieldUInt16 (name string, value uint16)
FieldUInt32 (name string, value uint32)
FieldUInt64 (name string, value uint64)
FieldFloat32 (name string, value float32)
FieldFloat64 (name string, value float64)
FieldDate (name string, value time.Time)
FieldList (name string, builder func(packer ListPacker))
FieldMap (name string, builder func(packer MapPacker ))
FieldObject(name string, builder func(packer ObjectPacker))
}
)

@ -1,65 +0,0 @@
// ------------------------------------------------------------------------
// Project atila
// Active Thing (activething.com) git.activething.com/go
//
// File name map_packer.go
// Created by DEV
// Modified 23/01/2024
//
// Copyright 2024 activething.com
// ------------------------------------------------------------------------
// 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 packs
import "time"
type (
MapPacker interface {
KeyValueAny (key any, value any)
KeyValueRaw (key any,value []byte)
KeyValueBinary(key any, value []byte)
KeyValueString(key any, value string)
KeyValueBool (key any, value bool)
KeyValueInt8 (key any, value int8)
KeyValueInt16 (key any, value int16)
KeyValueInt32 (key any, value int32)
KeyValueInt64 (key any, value int64)
KeyValueUInt8 (key any, value uint8)
KeyValueUInt16 (key any, value uint16)
KeyValueUInt32 (key any, value uint32)
KeyValueUInt64 (key any, value uint64)
KeyValueFloat32(key any, value float32)
KeyValueFloat64(key any, value float64)
KeyValueDate (key any, value time.Time)
KeyValueList (key any, builder func(packer ListPacker))
KeyValueMap (key any, builder func(packer MapPacker ))
KeyValueObject(key any, builder func(packer ObjectPacker))
}
)

@ -52,9 +52,9 @@ type (
PackDate (value time.Time, flags Flags)
PackList (builder func(packer ListPacker , flags Flags), flags Flags)
PackMap (builder func(packer MapPacker , flags Flags), flags Flags)
PackObject(builder func(packer ObjectPacker, flags Flags), flags Flags)
PackList (builder func(packer BuilderList, flags Flags), flags Flags)
PackMap (builder func(packer BuilderMap, flags Flags), flags Flags)
PackObject(builder func(packer BuilderObject, flags Flags), flags Flags)
}
)

@ -2,9 +2,9 @@
// Project atila
// Active Thing (activething.com) git.activething.com/go
//
// File name packer_list.go
// File name builder_list.go
// Created by DEV
// Modified 05/02/2024
// Modified 06/02/2024
//
// Copyright 2024 activething.com
// ------------------------------------------------------------------------
@ -28,7 +28,6 @@ import (
"time"
)
func (p *Packer) ItemAny (value any, flags packs.Flags) { p.addSep(); p.PackAny(value,flags) }
func (p *Packer) ItemRaw (value []byte, flags packs.Flags) { p.addSep(); packRaw(p.state,value,flags); p.state.Inc() }
@ -53,15 +52,15 @@ func (p *Packer) ItemFloat64 (value float64, flags packs.Flags) { p.addSep(); pa
func (p *Packer) ItemDate (value time.Time, flags packs.Flags) { p.addSep(); packDate(p.state,value,flags); p.state.Inc() }
func (p *Packer) ItemList (builder func(packer packs.ListPacker, flags packs.Flags), flags packs.Flags) {
func (p *Packer) ItemList (builder func(packs.BuilderList, packs.Flags), flags packs.Flags) {
p.addSep()
p.PackList(builder,flags)
p.state.Inc()
}
func (p *Packer) ItemMap (builder func(packer packs.MapPacker , flags packs.Flags), flags packs.Flags) {}
func (p *Packer) ItemMap (builder func(packs.BuilderMap, packs.Flags), flags packs.Flags) {}
func (p *Packer) ItemObject(builder func(packer packs.ObjectPacker, flags packs.Flags), flags packs.Flags) {}
func (p *Packer) ItemObject(builder func(packs.BuilderObject, packs.Flags), flags packs.Flags) {}
func (p *Packer) addSep () {
@ -71,117 +70,4 @@ func (p *Packer) addSep () {
}
func packListString (state *packs.State, list []string, flags packs.Flags) {
if !checkList(state,list == nil, len(list) ==0) {
return
}
state.WriteByte('[')
for i,v := range list {
if i > 0 {
state.WriteByte(',')
}
packString(state,v,flags)
if state.Error != nil {
return
}
}
state.WriteByte(']')
}
func packListBool (state *packs.State, list []bool, flags packs.Flags) {
if !checkList(state,list == nil, len(list) ==0) {
return
}
state.WriteByte('[')
for i,v := range list {
if i > 0 {
state.WriteByte(',')
}
packBool(state,v,flags)
if state.Error != nil {
return
}
}
state.WriteByte(']')
}
func packListInt [T int | int8 | int16 | int32 | int64](state *packs.State, list []T, flags packs.Flags) {
if !checkList(state,list == nil, len(list) ==0) {
return
}
state.WriteByte('[')
for i,v := range list {
if i > 0 {
state.WriteByte(',')
}
packInt(state,int64(v),flags)
if state.Error != nil {
return
}
}
state.WriteByte(']')
}
func packListUInt [T uint | uint8 | uint16 | uint32 | uint64](state *packs.State, list []T, flags packs.Flags) {
if !checkList(state,list == nil, len(list) ==0) {
return
}
state.WriteByte('[')
for i,v := range list {
if i > 0 {
state.WriteByte(',')
}
packUInt(state,uint64(v),flags)
if state.Error != nil {
return
}
}
state.WriteByte(']')
}
func packListFloat[T float32 | float64](state *packs.State, list []T, flags packs.Flags, bits int) {
if !checkList(state,list == nil, len(list) ==0) {
return
}
state.WriteByte('[')
for i,v := range list {
if i > 0 {
state.WriteByte(',')
}
packFloatString(state,float64(v),flags,bits)
if state.Error != nil {
return
}
}
state.WriteByte(']')
}
func packListDate (state *packs.State, list []time.Time, flags packs.Flags) {
if !checkList(state,list == nil, len(list) ==0) {
return
}
state.WriteByte('[')
for i,v := range list {
if i > 0 {
state.WriteByte(',')
}
packDate(state,v,flags)
if state.Error != nil {
return
}
}
state.WriteByte(']')
}
func checkList (state *packs.State, isNull, isEmpty bool) bool {
if isNull {
state.Write2Byte('"','"')
return false
}
if isEmpty {
state.Write2Byte('[',']')
return false
}
return true
}

@ -0,0 +1,60 @@
// ------------------------------------------------------------------------
// Project atila
// Active Thing (activething.com) git.activething.com/go
//
// File name builderMap.go
// Created by DEV
// Modified 06/02/2024
//
// Copyright 2024 activething.com
// ------------------------------------------------------------------------
// 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 pjson
import (
"activething.com/go/gogo/packs"
"time"
)
func (p *Packer) KeyValueAny (key any, value any, flags packs.Flags) {}
func (p *Packer) KeyValueRaw (key any,value []byte, flags packs.Flags) {}
func (p *Packer) KeyValueBinary (key any, value []byte, flags packs.Flags) {}
func (p *Packer) KeyValueString (key any, value string, flags packs.Flags) {}
func (p *Packer) KeyValueBool (key any, value bool, flags packs.Flags) {}
func (p *Packer) KeyValueInt8 (key any, value int8 , flags packs.Flags) {}
func (p *Packer) KeyValueInt16 (key any, value int16, flags packs.Flags) {}
func (p *Packer) KeyValueInt32 (key any, value int32, flags packs.Flags) {}
func (p *Packer) KeyValueInt64 (key any, value int64, flags packs.Flags) {}
func (p *Packer) KeyValueUInt8 (key any, value uint8 , flags packs.Flags) {}
func (p *Packer) KeyValueUInt16 (key any, value uint16, flags packs.Flags) {}
func (p *Packer) KeyValueUInt32 (key any, value uint32, flags packs.Flags) {}
func (p *Packer) KeyValueUInt64 (key any, value uint64, flags packs.Flags) {}
func (p *Packer) KeyValueFloat32(key any, value float32, flags packs.Flags) {}
func (p *Packer) KeyValueFloat64(key any, value float64, flags packs.Flags) {}
func (p *Packer) KeyValueDate (key any, value time.Time, flags packs.Flags) {}
func (p *Packer) KeyValueList (key any, builder func(packs.BuilderList, packs.Flags), flags packs.Flags) {}
func (p *Packer) KeyValueMap (key any, builder func(packs.BuilderMap , packs.Flags), flags packs.Flags) {}
func (p *Packer) KeyValueObject (key any, builder func(packs.BuilderObject,packs.Flags), flags packs.Flags) {}

@ -0,0 +1,58 @@
// ------------------------------------------------------------------------
// Project atila
// Active Thing (activething.com) git.activething.com/go
//
// File name builder_object.go
// Created by DEV
// Modified 06/02/2024
//
// Copyright 2024 activething.com
// ------------------------------------------------------------------------
// 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 pjson
import (
"activething.com/go/gogo/packs"
"time"
)
func (p *Packer) FieldAny (name string, value any, flags packs.Flags) {}
func (p *Packer) FieldRaw (name string, value []byte, flags packs.Flags) {}
func (p *Packer) FieldBinary (name string, value []byte, flags packs.Flags) {}
func (p *Packer) FieldString (name string, value string, flags packs.Flags) {}
func (p *Packer) FieldBool (name string, value bool, flags packs.Flags) {}
func (p *Packer) FieldInt8 (name string, value int8 , flags packs.Flags) {}
func (p *Packer) FieldInt16 (name string, value int16, flags packs.Flags) {}
func (p *Packer) FieldInt32 (name string, value int32, flags packs.Flags) {}
func (p *Packer) FieldInt64 (name string, value int64, flags packs.Flags) {}
func (p *Packer) FieldUInt8 (name string, value uint8, flags packs.Flags) {}
func (p *Packer) FieldUInt16 (name string, value uint16, flags packs.Flags) {}
func (p *Packer) FieldUInt32 (name string, value uint32, flags packs.Flags) {}
func (p *Packer) FieldUInt64 (name string, value uint64, flags packs.Flags) {}
func (p *Packer) FieldFloat32(name string, value float32,flags packs.Flags) {}
func (p *Packer) FieldFloat64(name string, value float64,flags packs.Flags) {}
func (p *Packer) FieldDate (name string, value time.Time,flags packs.Flags) {}
func (p *Packer) FieldList (name string, builder func(packs.BuilderList,packs.Flags), flags packs.Flags) {}
func (p *Packer) FieldMap (name string, builder func(packs.BuilderMap, packs.Flags), flags packs.Flags) {}
func (p *Packer) FieldObject (name string, builder func(packs.BuilderObject,packs.Flags), flags packs.Flags) {}
func (p *Packer) addField(name string) bool {}

@ -2,9 +2,9 @@
// Project atila
// Active Thing (activething.com) git.activething.com/go
//
// File name packer.go
// File name value_packer.go
// Created by DEV
// Modified 05/02/2024
// Modified 06/02/2024
//
// Copyright 2024 activething.com
// ------------------------------------------------------------------------
@ -24,10 +24,20 @@
package pjson
import (
"activething.com/go/gogo/core/errs"
"activething.com/go/gogo/core/opts"
"activething.com/go/gogo/packs"
"encoding/base32"
"encoding/base64"
"encoding/json"
"math"
"reflect"
"strconv"
"time"
"unicode/utf8"
)
type (
@ -37,8 +47,6 @@ type (
Options
}
)
@ -73,8 +81,516 @@ func (p *Packer) Error () error {
func (p *Packer) Reset () {
p.state.Reset()
p.Options.reset()
p.dirty = false
}
func (p *Packer) PackAny (value any, flags packs.Flags) {
if p.state.Error != nil {
panic(packs.G.ErrInvalidState.WithCause(p.state.Error))
}
if value == nil {
p.state.W(G.nullValue)
return
}
switch v := value.(type) {
case packs.Builder:
p.state.SetError(v.Build(p))
case json.Marshaler:
d,e := v.MarshalJSON()
if e != nil {
p.state.SetError(e)
} else {
p.state.W(d)
}
case bool : packBool (p.state,v,flags )
case string : packString(p.state,v,flags )
case int : packInt(p.state,int64(v),flags)
case int8 : packInt(p.state,int64(v),flags)
case int16 : packInt(p.state,int64(v),flags)
case int32 : packInt(p.state,int64(v),flags)
case int64 : packInt(p.state,v,flags )
case uint : packUInt(p.state,uint64(v),flags)
case uint8 : packUInt(p.state,uint64(v),flags)
case uint16 : packUInt(p.state,uint64(v),flags)
case uint32 : packUInt(p.state,uint64(v),flags)
case uint64 : packUInt(p.state,v,flags )
case float32: packFloatString(p.state,float64(v),flags,32)
case float64: packFloatString(p.state,v,flags,64)
case time.Time: packDate (p.state,v,flags)
case reflect.Value: rTypePacker(v.Type())(p.state,v,flags)
case []uint8 :
if flags.Binary() {
packBinary(p.state,v,flags)
return
}
packListUInt[uint8 ](p.state,v,flags)
case []uint : packListUInt [uint ] (p.state,v,flags)
case []uint16 : packListUInt [uint16] (p.state,v,flags)
case []uint32 : packListUInt [uint32] (p.state,v,flags)
case []uint64 : packListUInt [uint64] (p.state,v,flags)
case []int : packListInt [int ] (p.state,v,flags)
case []int8 : packListInt [int8 ] (p.state,v,flags)
case []int16 : packListInt [int16] (p.state,v,flags)
case []int32 : packListInt [int32] (p.state,v,flags)
case []int64 : packListInt [int64] (p.state,v,flags)
case []float32: packListFloat[float32](p.state,v,flags,32)
case []float64: packListFloat[float64](p.state,v,flags,64)
case []bool : packListBool (p.state,v,flags)
case []string : packListString(p.state,v,flags)
case []time.Time: packListDate(p.state,v,flags)
default:
rv := reflect.ValueOf(value)
rTypePacker(rv.Type())(p.state,rv,flags)
}
}
func (p *Packer) PackRaw (value []byte, flags packs.Flags) { packRaw(p.state,value,flags) }
func (p *Packer) PackBinary (value []byte, flags packs.Flags) { packBinary(p.state,value,flags) }
func (p *Packer) PackString (value string, flags packs.Flags) { packString (p.state,value,flags) }
func (p *Packer) PackBool (value bool, flags packs.Flags) { packBool(p.state,value,flags) }
func (p *Packer) PackInt8 (value int8 , flags packs.Flags) { packInt(p.state,int64(value),flags) }
func (p *Packer) PackInt16 (value int16, flags packs.Flags) { packInt(p.state,int64(value),flags) }
func (p *Packer) PackInt32 (value int32, flags packs.Flags) { packInt(p.state,int64(value),flags) }
func (p *Packer) PackInt64 (value int64, flags packs.Flags) { packInt(p.state,value,flags)}
func (p *Packer) PackUInt8 (value uint8 , flags packs.Flags) { packUInt(p.state,uint64(value),flags) }
func (p *Packer) PackUInt16 (value uint16, flags packs.Flags) { packUInt(p.state,uint64(value),flags) }
func (p *Packer) PackUInt32 (value uint32, flags packs.Flags) { packUInt(p.state,uint64(value),flags) }
func (p *Packer) PackUInt64 (value uint64, flags packs.Flags) { packUInt(p.state, value,flags) }
func (p *Packer) PackFloat32 (value float32, flags packs.Flags) { packFloatString(p.state, float64(value), flags, 32) }
func (p *Packer) PackFloat64 (value float64, flags packs.Flags) { packFloatString(p.state, value, flags, 64) }
func (p *Packer) PackDate (value time.Time, flags packs.Flags) { packDate(p.state,value,flags) }
func (p *Packer) PackList (builder func(packs.BuilderList, packs.Flags), flags packs.Flags) {
p.packCompound('[',']',builder==nil,func(pk *Packer, fl packs.Flags){ builder(pk,fl) },flags)
}
func (p *Packer) PackMap (builder func(packs.BuilderMap, packs.Flags), flags packs.Flags) {
//p.packCompound('{','}',builder==nil,func(pk *Packer, fl packs.Flags){ builder(pk,fl) },flags)
}
func (p *Packer) PackObject(builder func(packs.BuilderObject, packs.Flags), flags packs.Flags) {
//p.packCompound('{','}',builder==nil,func(pk *Packer, fl packs.Flags){ builder(pk,fl) },flags)
}
func (p *Packer) packCompound (opener, closer byte, isnil bool, buildFn func(*Packer,packs.Flags), flags packs.Flags) {
if p.state.Error != nil {
panic(packs.G.ErrInvalidState.WithCause(p.state.Error))
}
if isnil {
p.state.W(G.nullValue)
return
}
dn := false
defer func(d *bool) {
if !(*d) {
p.state.SetError(errs.ToError(recover()))
}
}(&dn)
p.state.Open(opener)
buildFn(p,flags)
if p.state.Error != nil {
return
}
p.state.Close(closer)
dn = true
}
func packRaw (state *packs.State, value []byte, flags packs.Flags) {
if state.Error != nil {
panic(packs.G.ErrInvalidState.WithCause(state.Error))
}
if value == nil {
state.W(G.nullValue)
return
}
if len(value) == 0 {
state.Write2Byte('"','"')
return
}
state.WOQ(flags.Quote(),'"',value)
}
func packString (state *packs.State, value string , flags packs.Flags) {
if state.Error != nil {
panic(packs.G.ErrInvalidState.WithCause(state.Error))
}
if len(value) == 0 {
state.Write2Byte('"','"')
return
}
state.WriteByte('"')
start := 0
for i := 0; i < len(value); {
if b := value[i]; b < utf8.RuneSelf {
if !G.jsonChars[b].isHtmlUnsafe() || (!flags.EscapeHTML() && !G.jsonChars[b].isUnsafe()) {
i++
continue
}
if start < i {
state.WriteString(value[start:i])
}
state.WriteByte('\\')
switch b {
case '\\', '"': state.WriteByte(b)
case '\n': state.WriteByte('n')
case '\r': state.WriteByte('r')
case '\t': state.WriteByte('t')
default:
state.WriteString(`u00`)
state.Write2Byte(G.hex[b>>4], G.hex[b&0xF])
}
i++
start = i
continue
}
c, size := utf8.DecodeRuneInString(value[i:])
if c == utf8.RuneError && size == 1 {
if start < i {
state.WriteString(value[start:i])
}
state.WriteString(`\ufffd`)
i += size
start = i
continue
}
if c == '\u2028' || c == '\u2029' {
if start < i {
state.WriteString(value[start:i])
}
state.WriteString(`\u202`)
state.WriteByte(G.hex[c&0xF])
i += size
start = i
continue
}
i += size
}
if start < len(value) {
state.WriteString(value[start:])
}
state.WriteByte('"')
}
func packBinary (state *packs.State, value []byte , flags packs.Flags) {
if state.Error != nil {
panic(packs.G.ErrInvalidState.WithCause(state.Error))
}
if value == nil {
_,_ = state.Write(G.nullValue)
return
}
if len(value) == 0 {
state.Write2Byte('"','"')
return
}
state.WriteByte('"')
if flags.Bin64() {
packBinary64(state, value, 0)
} else if flags.Bin32() {
packBinary32(state, value, 0)
} else {
state.SetError(packs.G.ErrUnsupportedType)
return
}
if state.Error == nil {
state.WriteByte('"')
}
}
func packBinary64 (state *packs.State, value []byte , _ packs.Flags) {
ln := base64.StdEncoding.EncodedLen(len(value))
if ln <= len(state.Temp) {
dst := state.Temp[:ln]
base64.StdEncoding.Encode(dst, value)
_,_= state.Write(dst)
} else if ln <= 1024 {
dst := make([]byte, ln)
base64.StdEncoding.Encode(dst, value)
_,_ = state.Write(dst)
} else {
ec := base64.NewEncoder(base64.StdEncoding, state)
_,_ = ec.Write(value)
state.SetError(ec.Close())
}
}
func packBinary32 (state *packs.State, value []byte , _ packs.Flags) {
ln := base32.StdEncoding.EncodedLen(len(value))
if ln <= len(state.Temp) {
dst := state.Temp[:ln]
base32.StdEncoding.Encode(dst, value)
_,_= state.Write(dst)
} else if ln <= 1024 {
dst := make([]byte, ln)
base32.StdEncoding.Encode(dst, value)
_,_ = state.Write(dst)
} else {
ec := base32.NewEncoder(base32.StdEncoding, state)
_,_ = ec.Write(value)
state.SetError(ec.Close())
}
}
func packBool (state *packs.State, value bool , flags packs.Flags) {
if state.Error != nil {
panic(packs.G.ErrInvalidState.WithCause(state.Error))
}
if value {
state.WOQ(flags.Quote(),'"',G.trueValue)
} else {
state.WOQ(flags.Quote(),'"',G.falseValue)
}
}
func packInt (state *packs.State, value int64 , flags packs.Flags) {
if state.Error != nil {
panic(packs.G.ErrInvalidState.WithCause(state.Error))
}
q :=flags.Quote()
if q {
state.WriteByte('"')
}
if value == 0 {
state.WriteByte('0')
} else {
state.WriteIntStr(value, 10)
}
if q {
state.WriteByte('"')
}
}
func packUInt (state *packs.State, value uint64 , flags packs.Flags) {
if state.Error != nil {
panic(packs.G.ErrInvalidState.WithCause(state.Error))
}
q :=flags.Quote()
if q {
state.WriteByte('"')
}
if value == 0 {
state.WriteByte('0')
} else {
state.WriteUIntStr(value, 10)
}
if q {
state.WriteByte('"')
}
}
func packFloat (state *packs.State, value float64, flags packs.Flags) {
packFloatString(state, value, flags, 64)
}
func packFloatString (state *packs.State, f float64, flags packs.Flags, bits int) {
if state.Error != nil {
panic(packs.G.ErrInvalidState.WithCause(state.Error))
}
if math.IsInf(f, 0) || math.IsNaN(f) {
state.SetError(packs.G.ErrInvalidValue)
return
}
abs := math.Abs(f)
fmt := byte('f')
if abs != 0 {
if bits == 64 && (abs < 1e-6 || abs >= 1e21) || bits == 32 && (float32(abs) < 1e-6 || float32(abs) >= 1e21) {
fmt = 'e'
}
}
bf := state.Temp[:0]
bf = strconv.AppendFloat(bf, f, fmt, -1, int(bits))
if fmt == 'e' {
// clean up e-09 to e-9
n := len(bf)
if n >= 4 && bf[n-4] == 'e' && bf[n-3] == '-' && bf[n-2] == '0' {
bf[n-2] = bf[n-1]
bf = bf[:n-1]
}
}
state.WOQ(flags.Quote(),'"',bf)
}
func packDate(state *packs.State, value time.Time, flags packs.Flags) {
if state.Error != nil {
panic(packs.G.ErrInvalidState.WithCause(state.Error))
}
bf := state.Temp[:0]
state.WOQ(true,'"',bf)
}
func packListString (state *packs.State, list []string, flags packs.Flags) {
if !checkList(state,list == nil, len(list) ==0) {
return
}
state.WriteByte('[')
for i,v := range list {
if i > 0 {
state.WriteByte(',')
}
packString(state,v,flags)
if state.Error != nil {
return
}
}
state.WriteByte(']')
}
func packListBool (state *packs.State, list []bool, flags packs.Flags) {
if !checkList(state,list == nil, len(list) ==0) {
return
}
state.WriteByte('[')
for i,v := range list {
if i > 0 {
state.WriteByte(',')
}
packBool(state,v,flags)
if state.Error != nil {
return
}
}
state.WriteByte(']')
}
func packListInt [T int | int8 | int16 | int32 | int64](state *packs.State, list []T, flags packs.Flags) {
if !checkList(state,list == nil, len(list) ==0) {
return
}
state.WriteByte('[')
for i,v := range list {
if i > 0 {
state.WriteByte(',')
}
packInt(state,int64(v),flags)
if state.Error != nil {
return
}
}
state.WriteByte(']')
}
func packListUInt [T uint | uint8 | uint16 | uint32 | uint64](state *packs.State, list []T, flags packs.Flags) {
if !checkList(state,list == nil, len(list) ==0) {
return
}
state.WriteByte('[')
for i,v := range list {
if i > 0 {
state.WriteByte(',')
}
packUInt(state,uint64(v),flags)
if state.Error != nil {
return
}
}
state.WriteByte(']')
}
func packListFloat[T float32 | float64](state *packs.State, list []T, flags packs.Flags, bits int) {
if !checkList(state,list == nil, len(list) ==0) {
return
}
state.WriteByte('[')
for i,v := range list {
if i > 0 {
state.WriteByte(',')
}
packFloatString(state,float64(v),flags,bits)
if state.Error != nil {
return
}
}
state.WriteByte(']')
}
func packListDate (state *packs.State, list []time.Time, flags packs.Flags) {
if !checkList(state,list == nil, len(list) ==0) {
return
}
state.WriteByte('[')
for i,v := range list {
if i > 0 {
state.WriteByte(',')
}
packDate(state,v,flags)
if state.Error != nil {
return
}
}
state.WriteByte(']')
}
func checkList (state *packs.State, isNull, isEmpty bool) bool {
if isNull {
state.Write2Byte('"','"')
return false
}
if isEmpty {
state.Write2Byte('[',']')
return false
}
return true
}

@ -1,425 +0,0 @@
// ------------------------------------------------------------------------
// Project atila
// Active Thing (activething.com) git.activething.com/go
//
// File name value_packer.go
// Created by DEV
// Modified 06/02/2024
//
// Copyright 2024 activething.com
// ------------------------------------------------------------------------
// 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 pjson
import (
"activething.com/go/gogo/core/errs"
"activething.com/go/gogo/packs"
"encoding/base32"
"encoding/base64"
"encoding/json"
"math"
"reflect"
"strconv"
"time"
"unicode/utf8"
)
func (p *Packer) PackAny (value any, flags packs.Flags) {
if p.state.Error != nil {
panic(packs.G.ErrInvalidState.WithCause(p.state.Error))
}
if value == nil {
p.state.W(G.nullValue)
return
}
switch v := value.(type) {
case packs.Builder:
p.state.SetError(v.Build(p))
case json.Marshaler:
d,e := v.MarshalJSON()
if e != nil {
p.state.SetError(e)
} else {
p.state.W(d)
}
case bool : packBool (p.state,v,flags )
case string : packString(p.state,v,flags )
case int : packInt(p.state,int64(v),flags)
case int8 : packInt(p.state,int64(v),flags)
case int16 : packInt(p.state,int64(v),flags)
case int32 : packInt(p.state,int64(v),flags)
case int64 : packInt(p.state,v,flags )
case uint : packUInt(p.state,uint64(v),flags)
case uint8 : packUInt(p.state,uint64(v),flags)
case uint16 : packUInt(p.state,uint64(v),flags)
case uint32 : packUInt(p.state,uint64(v),flags)
case uint64 : packUInt(p.state,v,flags )
case float32: packFloatString(p.state,float64(v),flags,32)
case float64: packFloatString(p.state,v,flags,64)
case time.Time: packDate (p.state,v,flags)
case reflect.Value: rTypePacker(v.Type())(p.state,v,flags)
case []uint8 :
if flags.Binary() {
packBinary(p.state,v,flags)
return
}
packListUInt[uint8 ](p.state,v,flags)
case []uint : packListUInt [uint ] (p.state,v,flags)
case []uint16 : packListUInt [uint16] (p.state,v,flags)
case []uint32 : packListUInt [uint32] (p.state,v,flags)
case []uint64 : packListUInt [uint64] (p.state,v,flags)
case []int : packListInt [int ] (p.state,v,flags)
case []int8 : packListInt [int8 ] (p.state,v,flags)
case []int16 : packListInt [int16] (p.state,v,flags)
case []int32 : packListInt [int32] (p.state,v,flags)
case []int64 : packListInt [int64] (p.state,v,flags)
case []float32: packListFloat[float32](p.state,v,flags,32)
case []float64: packListFloat[float64](p.state,v,flags,64)
case []bool : packListBool (p.state,v,flags)
case []string : packListString(p.state,v,flags)
case []time.Time: packListDate(p.state,v,flags)
default:
rv := reflect.ValueOf(value)
rTypePacker(rv.Type())(p.state,rv,flags)
}
}
func (p *Packer) PackRaw (value []byte, flags packs.Flags) { packRaw(p.state,value,flags) }
func (p *Packer) PackBinary (value []byte, flags packs.Flags) { packBinary(p.state,value,flags) }
func (p *Packer) PackString (value string, flags packs.Flags) { packString (p.state,value,flags) }
func (p *Packer) PackBool (value bool, flags packs.Flags) { packBool(p.state,value,flags) }
func (p *Packer) PackInt8 (value int8 , flags packs.Flags) { packInt(p.state,int64(value),flags) }
func (p *Packer) PackInt16 (value int16, flags packs.Flags) { packInt(p.state,int64(value),flags) }
func (p *Packer) PackInt32 (value int32, flags packs.Flags) { packInt(p.state,int64(value),flags) }
func (p *Packer) PackInt64 (value int64, flags packs.Flags) { packInt(p.state,value,flags)}
func (p *Packer) PackUInt8 (value uint8 , flags packs.Flags) { packUInt(p.state,uint64(value),flags) }
func (p *Packer) PackUInt16 (value uint16, flags packs.Flags) { packUInt(p.state,uint64(value),flags) }
func (p *Packer) PackUInt32 (value uint32, flags packs.Flags) { packUInt(p.state,uint64(value),flags) }
func (p *Packer) PackUInt64 (value uint64, flags packs.Flags) { packUInt(p.state, value,flags) }
func (p *Packer) PackFloat32 (value float32, flags packs.Flags) { packFloatString(p.state, float64(value), flags, 32) }
func (p *Packer) PackFloat64 (value float64, flags packs.Flags) { packFloatString(p.state, value, flags, 64) }
func (p *Packer) PackDate (value time.Time, flags packs.Flags) { packDate(p.state,value,flags) }
func (p *Packer) PackList (builder func(packs.ListPacker, packs.Flags), flags packs.Flags) {
p.packCompound('[',']',builder==nil,func(pk *Packer, fl packs.Flags){ builder(pk,fl) },flags)
}
func (p *Packer) PackMap (builder func(packs.MapPacker, packs.Flags), flags packs.Flags) {
//p.packCompound('{','}',builder==nil,func(pk *Packer, fl packs.Flags){ builder(pk,fl) },flags)
}
func (p *Packer) PackObject(builder func(packs.ObjectPacker, packs.Flags), flags packs.Flags) {
//p.packCompound('{','}',builder==nil,func(pk *Packer, fl packs.Flags){ builder(pk,fl) },flags)
}
func (p *Packer) packCompound (opener, closer byte, isnil bool, buildFn func(*Packer,packs.Flags), flags packs.Flags) {
if p.state.Error != nil {
panic(packs.G.ErrInvalidState.WithCause(p.state.Error))
}
if isnil {
p.state.W(G.nullValue)
return
}
dn := false
defer func(d *bool) {
if !(*d) {
p.state.SetError(errs.ToError(recover()))
}
}(&dn)
p.state.Open(opener)
buildFn(p,flags)
if p.state.Error != nil {
return
}
p.state.Close(closer)
dn = true
}
func packRaw (state *packs.State, value []byte, flags packs.Flags) {
if state.Error != nil {
panic(packs.G.ErrInvalidState.WithCause(state.Error))
}
if value == nil {
state.W(G.nullValue)
return
}
if len(value) == 0 {
state.Write2Byte('"','"')
return
}
state.WOQ(flags.Quote(),'"',value)
}
func packString (state *packs.State, value string , flags packs.Flags) {
if state.Error != nil {
panic(packs.G.ErrInvalidState.WithCause(state.Error))
}
if len(value) == 0 {
state.Write2Byte('"','"')
return
}
state.WriteByte('"')
start := 0
for i := 0; i < len(value); {
if b := value[i]; b < utf8.RuneSelf {
if !G.jsonChars[b].isHtmlUnsafe() || (!flags.EscapeHTML() && !G.jsonChars[b].isUnsafe()) {
i++
continue
}
if start < i {
state.WriteString(value[start:i])
}
state.WriteByte('\\')
switch b {
case '\\', '"': state.WriteByte(b)
case '\n': state.WriteByte('n')
case '\r': state.WriteByte('r')
case '\t': state.WriteByte('t')
default:
state.WriteString(`u00`)
state.Write2Byte(G.hex[b>>4], G.hex[b&0xF])
}
i++
start = i
continue
}
c, size := utf8.DecodeRuneInString(value[i:])
if c == utf8.RuneError && size == 1 {
if start < i {
state.WriteString(value[start:i])
}
state.WriteString(`\ufffd`)
i += size
start = i
continue
}
if c == '\u2028' || c == '\u2029' {
if start < i {
state.WriteString(value[start:i])
}
state.WriteString(`\u202`)
state.WriteByte(G.hex[c&0xF])
i += size
start = i
continue
}
i += size
}
if start < len(value) {
state.WriteString(value[start:])
}
state.WriteByte('"')
}
func packBinary (state *packs.State, value []byte , flags packs.Flags) {
if state.Error != nil {
panic(packs.G.ErrInvalidState.WithCause(state.Error))
}
if value == nil {
_,_ = state.Write(G.nullValue)
return
}
if len(value) == 0 {
state.Write2Byte('"','"')
return
}
state.WriteByte('"')
if flags.Bin64() {
packBinary64(state, value, 0)
} else if flags.Bin32() {
packBinary32(state, value, 0)
} else {
state.SetError(packs.G.ErrUnsupportedType)
return
}
if state.Error == nil {
state.WriteByte('"')
}
}
func packBinary64 (state *packs.State, value []byte , _ packs.Flags) {
ln := base64.StdEncoding.EncodedLen(len(value))
if ln <= len(state.Temp) {
dst := state.Temp[:ln]
base64.StdEncoding.Encode(dst, value)
_,_= state.Write(dst)
} else if ln <= 1024 {
dst := make([]byte, ln)
base64.StdEncoding.Encode(dst, value)
_,_ = state.Write(dst)
} else {
ec := base64.NewEncoder(base64.StdEncoding, state)
_,_ = ec.Write(value)
state.SetError(ec.Close())
}
}
func packBinary32 (state *packs.State, value []byte , _ packs.Flags) {
ln := base32.StdEncoding.EncodedLen(len(value))
if ln <= len(state.Temp) {
dst := state.Temp[:ln]
base32.StdEncoding.Encode(dst, value)
_,_= state.Write(dst)
} else if ln <= 1024 {
dst := make([]byte, ln)
base32.StdEncoding.Encode(dst, value)
_,_ = state.Write(dst)
} else {
ec := base32.NewEncoder(base32.StdEncoding, state)
_,_ = ec.Write(value)
state.SetError(ec.Close())
}
}
func packBool (state *packs.State, value bool , flags packs.Flags) {
if state.Error != nil {
panic(packs.G.ErrInvalidState.WithCause(state.Error))
}
if value {
state.WOQ(flags.Quote(),'"',G.trueValue)
} else {
state.WOQ(flags.Quote(),'"',G.falseValue)
}
}
func packInt (state *packs.State, value int64 , flags packs.Flags) {
if state.Error != nil {
panic(packs.G.ErrInvalidState.WithCause(state.Error))
}
q :=flags.Quote()
if q {
state.WriteByte('"')
}
if value == 0 {
state.WriteByte('0')
} else {
state.WriteIntStr(value, 10)
}
if q {
state.WriteByte('"')
}
}
func packUInt (state *packs.State, value uint64 , flags packs.Flags) {
if state.Error != nil {
panic(packs.G.ErrInvalidState.WithCause(state.Error))
}
q :=flags.Quote()
if q {
state.WriteByte('"')
}
if value == 0 {
state.WriteByte('0')
} else {
state.WriteUIntStr(value, 10)
}
if q {
state.WriteByte('"')
}
}
func packFloat (state *packs.State, value float64, flags packs.Flags) {
packFloatString(state, value, flags, 64)
}
func packFloatString (state *packs.State, f float64, flags packs.Flags, bits int) {
if state.Error != nil {
panic(packs.G.ErrInvalidState.WithCause(state.Error))
}
if math.IsInf(f, 0) || math.IsNaN(f) {
state.SetError(packs.G.ErrInvalidValue)
return
}
abs := math.Abs(f)
fmt := byte('f')
if abs != 0 {
if bits == 64 && (abs < 1e-6 || abs >= 1e21) || bits == 32 && (float32(abs) < 1e-6 || float32(abs) >= 1e21) {
fmt = 'e'
}
}
bf := state.Temp[:0]
bf = strconv.AppendFloat(bf, f, fmt, -1, int(bits))
if fmt == 'e' {
// clean up e-09 to e-9
n := len(bf)
if n >= 4 && bf[n-4] == 'e' && bf[n-3] == '-' && bf[n-2] == '0' {
bf[n-2] = bf[n-1]
bf = bf[:n-1]
}
}
state.WOQ(flags.Quote(),'"',bf)
}
func packDate(state *packs.State, value time.Time, flags packs.Flags) {
if state.Error != nil {
panic(packs.G.ErrInvalidState.WithCause(state.Error))
}
bf := state.Temp[:0]
state.WOQ(true,'"',bf)
}
Loading…
Cancel
Save

Powered by TurnKey Linux.