DEV
3 years ago
parent
9c824de31a
commit
63f83a353b
@ -1,49 +0,0 @@
|
||||
// ------------------------------------------------------------------------
|
||||
// Project atila
|
||||
// Active Thing (activething.com) git.activething.com/go
|
||||
//
|
||||
// File name cache.go
|
||||
// Created by DEV
|
||||
// Modified 30/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 js
|
||||
|
||||
import (
|
||||
"reflect"
|
||||
"sync"
|
||||
)
|
||||
|
||||
type (
|
||||
|
||||
cachePackers struct {
|
||||
sync.RWMutex
|
||||
packers map[reflect.Type]packerFn
|
||||
|
||||
keyers map[reflect.Type]StringerFn
|
||||
|
||||
}
|
||||
)
|
||||
|
||||
func NewCachePackers () *cachePackers {
|
||||
return &cachePackers{
|
||||
keyers : make(map[reflect.Type]StringerFn),
|
||||
packers: make(map[reflect.Type]packerFn),
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@ -0,0 +1,110 @@
|
||||
// ------------------------------------------------------------------------
|
||||
// Project atila
|
||||
// Active Thing (activething.com) git.activething.com/go
|
||||
//
|
||||
// File name key_val_packer.go
|
||||
// Created by DEV
|
||||
// Modified 03/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 js
|
||||
|
||||
import (
|
||||
"activething.com/go/gogo/packs"
|
||||
"reflect"
|
||||
"sort"
|
||||
)
|
||||
|
||||
type (
|
||||
|
||||
rMap struct {
|
||||
keyFn rMapEntryFnc
|
||||
valFn packerFn
|
||||
}
|
||||
|
||||
|
||||
)
|
||||
|
||||
|
||||
|
||||
func newRMap (rtype reflect.Type) *rMap {
|
||||
return &rMap{
|
||||
valFn : typePacker(rtype.Elem()),
|
||||
keyFn : stringifyRKey(rtype.Key()),
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
func (p *rMap) pack (s *packs.State, v reflect.Value, f Flags) {
|
||||
if p.keyFn == nil {
|
||||
s.SetError(packs.G.ErrInvalidKey)
|
||||
return
|
||||
}
|
||||
|
||||
if v.IsNil() {
|
||||
s.W(G.nullValue)
|
||||
return
|
||||
}
|
||||
if v.Len() == 0{
|
||||
s.Write2Byte('{','}')
|
||||
return
|
||||
}
|
||||
|
||||
if s.Level > startDetectingCyclesAfter {
|
||||
if fn,ok := s.CheckCycle(v.UnsafePointer()); ok {
|
||||
defer fn()
|
||||
} else {
|
||||
s.SetError(packs.G.ErrRedundantPack)
|
||||
return
|
||||
}
|
||||
}
|
||||
|
||||
mi := v.MapRange()
|
||||
ls := make(rMapEntryList,v.Len())
|
||||
|
||||
for i:=0; mi.Next(); i++ {
|
||||
ls[i] = rMapEntry{
|
||||
v: mi.Value(),
|
||||
}
|
||||
if er := p.keyFn(&ls[i], mi.Key()); er != nil {
|
||||
s.SetError(er)
|
||||
return
|
||||
}
|
||||
}
|
||||
|
||||
sort.Sort(ls)
|
||||
|
||||
s.Open ('{')
|
||||
for i:=0; i<len(ls); i++ {
|
||||
if i>0 {
|
||||
s.WriteByte(',')
|
||||
}
|
||||
packString(s,ls[i].k,ls[i].f)
|
||||
if s.Error != nil {
|
||||
return
|
||||
}
|
||||
s.WriteByte(':')
|
||||
p.valFn(s,ls[i].v,0)
|
||||
if s.Error != nil {
|
||||
return
|
||||
}
|
||||
}
|
||||
s.Close('}')
|
||||
}
|
||||
|
||||
|
||||
@ -1,289 +0,0 @@
|
||||
// ------------------------------------------------------------------------
|
||||
// Project atila
|
||||
// Active Thing (activething.com) git.activething.com/go
|
||||
//
|
||||
// File name type_map_packer.go
|
||||
// Created by DEV
|
||||
// Modified 30/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 js
|
||||
|
||||
import (
|
||||
"activething.com/go/gogo/packs"
|
||||
"encoding"
|
||||
"reflect"
|
||||
"sort"
|
||||
"strconv"
|
||||
)
|
||||
|
||||
type (
|
||||
|
||||
typeMapPacker struct {
|
||||
keyStringer StringerFn
|
||||
valPacker packerFn
|
||||
}
|
||||
|
||||
|
||||
StringerFn func(me *TypeMapEntry, key reflect.Value) error
|
||||
|
||||
|
||||
|
||||
TypeMapEntry struct {
|
||||
Val reflect.Value
|
||||
Key string
|
||||
flags Flags
|
||||
}
|
||||
|
||||
Entries []TypeMapEntry
|
||||
)
|
||||
|
||||
func (e Entries) Len() int {
|
||||
return len(e)
|
||||
}
|
||||
|
||||
// Less compares two entries based on their keys
|
||||
func (e Entries) Less(i, j int) bool {
|
||||
return e[i].Key < e[j].Key
|
||||
}
|
||||
|
||||
// Swap swaps two entries in the slice
|
||||
func (e Entries) Swap(i, j int) {
|
||||
e[i], e[j] = e[j], e[i]
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
func newTypeMapPacker (rtype reflect.Type) *typeMapPacker {
|
||||
return &typeMapPacker{
|
||||
valPacker : typePacker (rtype.Elem()),
|
||||
keyStringer: keyStringer(rtype.Key ()),
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
func (m typeMapPacker) pack (s *packs.State, v reflect.Value, _ Flags) {
|
||||
if v.IsNil() {
|
||||
_,_ = s.Write(G.nullValue)
|
||||
return
|
||||
}
|
||||
|
||||
mi := v.MapRange()
|
||||
ls := make(Entries,v.Len())
|
||||
|
||||
if s.Level > startDetectingCyclesAfter {
|
||||
if fn,ok := s.CheckCycle(v.UnsafePointer()); ok {
|
||||
defer fn()
|
||||
} else {
|
||||
s.SetError(packs.G.ErrRedundantPack)
|
||||
return
|
||||
}
|
||||
}
|
||||
|
||||
for i:=0; mi.Next(); i++ {
|
||||
ls[i] = TypeMapEntry{
|
||||
Val: mi.Value(),
|
||||
}
|
||||
if er := m.keyStringer(&ls[i], mi.Key()); er != nil {
|
||||
s.SetError(er)
|
||||
return
|
||||
}
|
||||
}
|
||||
|
||||
sort.Sort(ls)
|
||||
//sort.Slice(ls, func(i, j int) bool { return ls[i].Key < ls[j].Key })
|
||||
|
||||
s.Open ('{')
|
||||
for i:=0; i<len(ls); i++ {
|
||||
if i>0 {
|
||||
s.WriteByte(',')
|
||||
}
|
||||
packString(s,ls[i].Key,ls[i].flags)
|
||||
if s.Error != nil {
|
||||
return
|
||||
}
|
||||
s.WriteByte(':')
|
||||
m.valPacker(s,ls[i].Val,0)
|
||||
if s.Error != nil {
|
||||
return
|
||||
}
|
||||
}
|
||||
s.Close('}')
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
/*
|
||||
func (m typeMapPacker) pack (s *packs.State, v reflect.Value, _ Flags) {
|
||||
if v.IsNil() {
|
||||
_,_ = s.Write(G.nullValue)
|
||||
return
|
||||
}
|
||||
|
||||
|
||||
|
||||
mi := v.MapRange()
|
||||
ls := make(Entries,v.Len())
|
||||
|
||||
if s.Level > startDetectingCyclesAfter {
|
||||
if fn,ok := s.CheckCycle(v.UnsafePointer()); ok {
|
||||
defer fn()
|
||||
} else {
|
||||
s.SetError(packs.G.ErrRedundantPack)
|
||||
return
|
||||
}
|
||||
}
|
||||
|
||||
for i:=0; mi.Next(); i++ {
|
||||
ls[i] = TypeMapEntry{
|
||||
Val: mi.Value(),
|
||||
}
|
||||
if er := m.keyStringer(&ls[i], mi.Key()); er != nil {
|
||||
s.SetError(er)
|
||||
return
|
||||
}
|
||||
}
|
||||
|
||||
sort.Sort(ls)
|
||||
//sort.Slice(ls, func(i, j int) bool { return ls[i].Key < ls[j].Key })
|
||||
|
||||
s.Open ('{')
|
||||
for i:=0; i<len(ls); i++ {
|
||||
if i>0 {
|
||||
s.WriteByte(',')
|
||||
}
|
||||
packString(s,ls[i].Key,ls[i].flags)
|
||||
if s.Error != nil {
|
||||
return
|
||||
}
|
||||
s.WriteByte(':')
|
||||
m.valPacker(s,ls[i].Val,0)
|
||||
if s.Error != nil {
|
||||
return
|
||||
}
|
||||
}
|
||||
s.Close('}')
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
*/
|
||||
|
||||
func keyStringer(rt reflect.Type) func(me *TypeMapEntry, key reflect.Value) error {
|
||||
if rt.Kind() == reflect.String {
|
||||
return func(e *TypeMapEntry, k reflect.Value) error {
|
||||
e.Key = k.String()
|
||||
e.flags = FlagScapeHTML
|
||||
return nil
|
||||
}
|
||||
}
|
||||
|
||||
if rt.Implements(reflect.TypeOf((*encoding.TextMarshaler)(nil)).Elem()) {
|
||||
return func(e *TypeMapEntry, k reflect.Value) error {
|
||||
if k.Kind() == reflect.Pointer && k.IsNil() {
|
||||
return nil
|
||||
}
|
||||
bf, er := (k.Interface().(encoding.TextMarshaler)).MarshalText()
|
||||
if er == nil {
|
||||
e.Key = string(bf)
|
||||
e.flags = FlagScapeHTML
|
||||
}
|
||||
return er
|
||||
}
|
||||
}
|
||||
|
||||
switch rt.Kind() {
|
||||
|
||||
case reflect.Int,
|
||||
reflect.Int8,
|
||||
reflect.Int16,
|
||||
reflect.Int32,
|
||||
reflect.Int64:
|
||||
return func(e *TypeMapEntry, k reflect.Value) error {
|
||||
e.Key = strconv.FormatInt(k.Int(), 10)
|
||||
return nil
|
||||
}
|
||||
case reflect.Uint,
|
||||
reflect.Uint8,
|
||||
reflect.Uint16,
|
||||
reflect.Uint32,
|
||||
reflect.Uint64,
|
||||
reflect.Uintptr:
|
||||
return func(e *TypeMapEntry, k reflect.Value) error {
|
||||
e.Key = strconv.FormatUint(k.Uint(), 10)
|
||||
return nil
|
||||
}
|
||||
|
||||
case reflect.Interface:
|
||||
return func(e *TypeMapEntry, k reflect.Value) error {
|
||||
k = k.Elem()
|
||||
|
||||
if k.Type().Kind() == reflect.String {
|
||||
e.Key = k.String()
|
||||
e.flags = FlagScapeHTML
|
||||
return nil
|
||||
}
|
||||
|
||||
if t,h := k.Interface().(encoding.TextMarshaler); h {
|
||||
if k.Type().Kind() == reflect.Pointer && k.IsNil() {
|
||||
return nil
|
||||
}
|
||||
bf, er := t.MarshalText()
|
||||
if er == nil {
|
||||
e.Key = string(bf)
|
||||
e.flags = FlagScapeHTML
|
||||
}
|
||||
return er
|
||||
}
|
||||
|
||||
switch rt.Kind() {
|
||||
|
||||
case reflect.Int,
|
||||
reflect.Int8,
|
||||
reflect.Int16,
|
||||
reflect.Int32,
|
||||
reflect.Int64:
|
||||
e.Key = strconv.FormatInt(k.Int(), 10)
|
||||
return nil
|
||||
|
||||
case reflect.Uint,
|
||||
reflect.Uint8,
|
||||
reflect.Uint16,
|
||||
reflect.Uint32,
|
||||
reflect.Uint64,
|
||||
reflect.Uintptr:
|
||||
e.Key = strconv.FormatUint(k.Uint(), 10)
|
||||
return nil
|
||||
|
||||
default:
|
||||
return packs.G.ErrInvalidKey
|
||||
}
|
||||
}
|
||||
|
||||
default:
|
||||
return func(e *TypeMapEntry, k reflect.Value) error {
|
||||
return packs.G.ErrInvalidKey
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
Loading…
Reference in new issue