node.go 52 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843
  1. /*
  2. * Copyright 2021 ByteDance Inc.
  3. *
  4. * Licensed under the Apache License, Version 2.0 (the "License");
  5. * you may not use this file except in compliance with the License.
  6. * You may obtain a copy of the License at
  7. *
  8. * http://www.apache.org/licenses/LICENSE-2.0
  9. *
  10. * Unless required by applicable law or agreed to in writing, software
  11. * distributed under the License is distributed on an "AS IS" BASIS,
  12. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13. * See the License for the specific language governing permissions and
  14. * limitations under the License.
  15. */
  16. package ast
  17. import (
  18. "encoding/json"
  19. "fmt"
  20. "strconv"
  21. "sync"
  22. "sync/atomic"
  23. "unsafe"
  24. "github.com/bytedance/sonic/internal/native/types"
  25. "github.com/bytedance/sonic/internal/rt"
  26. )
  27. const (
  28. _V_NONE types.ValueType = 0
  29. _V_NODE_BASE types.ValueType = 1 << 5
  30. _V_LAZY types.ValueType = 1 << 7
  31. _V_RAW types.ValueType = 1 << 8
  32. _V_NUMBER = _V_NODE_BASE + 1
  33. _V_ANY = _V_NODE_BASE + 2
  34. _V_ARRAY_LAZY = _V_LAZY | types.V_ARRAY
  35. _V_OBJECT_LAZY = _V_LAZY | types.V_OBJECT
  36. _MASK_LAZY = _V_LAZY - 1
  37. _MASK_RAW = _V_RAW - 1
  38. )
  39. const (
  40. V_NONE = 0
  41. V_ERROR = 1
  42. V_NULL = int(types.V_NULL)
  43. V_TRUE = int(types.V_TRUE)
  44. V_FALSE = int(types.V_FALSE)
  45. V_ARRAY = int(types.V_ARRAY)
  46. V_OBJECT = int(types.V_OBJECT)
  47. V_STRING = int(types.V_STRING)
  48. V_NUMBER = int(_V_NUMBER)
  49. V_ANY = int(_V_ANY)
  50. )
  51. type Node struct {
  52. t types.ValueType
  53. l uint
  54. p unsafe.Pointer
  55. m *sync.RWMutex
  56. }
  57. // UnmarshalJSON is just an adapter to json.Unmarshaler.
  58. // If you want better performance, use Searcher.GetByPath() directly
  59. func (self *Node) UnmarshalJSON(data []byte) (err error) {
  60. *self = NewRaw(string(data))
  61. return self.Check()
  62. }
  63. /** Node Type Accessor **/
  64. // Type returns json type represented by the node
  65. // It will be one of bellows:
  66. // V_NONE = 0 (empty node, key not exists)
  67. // V_ERROR = 1 (error node)
  68. // V_NULL = 2 (json value `null`, key exists)
  69. // V_TRUE = 3 (json value `true`)
  70. // V_FALSE = 4 (json value `false`)
  71. // V_ARRAY = 5 (json value array)
  72. // V_OBJECT = 6 (json value object)
  73. // V_STRING = 7 (json value string)
  74. // V_NUMBER = 33 (json value number )
  75. // V_ANY = 34 (golang interface{})
  76. //
  77. // Deprecated: not concurrent safe. Use TypeSafe instead
  78. func (self Node) Type() int {
  79. return int(self.t & _MASK_LAZY & _MASK_RAW)
  80. }
  81. // Type concurrently-safe returns json type represented by the node
  82. // It will be one of bellows:
  83. // V_NONE = 0 (empty node, key not exists)
  84. // V_ERROR = 1 (error node)
  85. // V_NULL = 2 (json value `null`, key exists)
  86. // V_TRUE = 3 (json value `true`)
  87. // V_FALSE = 4 (json value `false`)
  88. // V_ARRAY = 5 (json value array)
  89. // V_OBJECT = 6 (json value object)
  90. // V_STRING = 7 (json value string)
  91. // V_NUMBER = 33 (json value number )
  92. // V_ANY = 34 (golang interface{})
  93. func (self *Node) TypeSafe() int {
  94. return int(self.loadt() & _MASK_LAZY & _MASK_RAW)
  95. }
  96. func (self *Node) itype() types.ValueType {
  97. return self.t & _MASK_LAZY & _MASK_RAW
  98. }
  99. // Exists returns false only if the self is nil or empty node V_NONE
  100. func (self *Node) Exists() bool {
  101. if self == nil {
  102. return false
  103. }
  104. t := self.loadt()
  105. return t != V_ERROR && t != _V_NONE
  106. }
  107. // Valid reports if self is NOT V_ERROR or nil
  108. func (self *Node) Valid() bool {
  109. if self == nil {
  110. return false
  111. }
  112. return self.loadt() != V_ERROR
  113. }
  114. // Check checks if the node itself is valid, and return:
  115. // - ErrNotExist If the node is nil
  116. // - Its underlying error If the node is V_ERROR
  117. func (self *Node) Check() error {
  118. if self == nil {
  119. return ErrNotExist
  120. } else if self.loadt() != V_ERROR {
  121. return nil
  122. } else {
  123. return self
  124. }
  125. }
  126. // isRaw returns true if node's underlying value is raw json
  127. //
  128. // Deprecated: not concurrent safe
  129. func (self Node) IsRaw() bool {
  130. return self.t & _V_RAW != 0
  131. }
  132. // IsRaw returns true if node's underlying value is raw json
  133. func (self *Node) isRaw() bool {
  134. return self.loadt() & _V_RAW != 0
  135. }
  136. func (self *Node) isLazy() bool {
  137. return self != nil && self.t & _V_LAZY != 0
  138. }
  139. func (self *Node) isAny() bool {
  140. return self != nil && self.loadt() == _V_ANY
  141. }
  142. /** Simple Value Methods **/
  143. // Raw returns json representation of the node,
  144. func (self *Node) Raw() (string, error) {
  145. if self == nil {
  146. return "", ErrNotExist
  147. }
  148. lock := self.rlock()
  149. if !self.isRaw() {
  150. if lock {
  151. self.runlock()
  152. }
  153. buf, err := self.MarshalJSON()
  154. return rt.Mem2Str(buf), err
  155. }
  156. ret := self.toString()
  157. if lock {
  158. self.runlock()
  159. }
  160. return ret, nil
  161. }
  162. func (self *Node) checkRaw() error {
  163. if err := self.Check(); err != nil {
  164. return err
  165. }
  166. if self.isRaw() {
  167. self.parseRaw(false)
  168. }
  169. return self.Check()
  170. }
  171. // Bool returns bool value represented by this node,
  172. // including types.V_TRUE|V_FALSE|V_NUMBER|V_STRING|V_ANY|V_NULL,
  173. // V_NONE will return error
  174. func (self *Node) Bool() (bool, error) {
  175. if err := self.checkRaw(); err != nil {
  176. return false, err
  177. }
  178. switch self.t {
  179. case types.V_TRUE : return true , nil
  180. case types.V_FALSE : return false, nil
  181. case types.V_NULL : return false, nil
  182. case _V_NUMBER :
  183. if i, err := self.toInt64(); err == nil {
  184. return i != 0, nil
  185. } else if f, err := self.toFloat64(); err == nil {
  186. return f != 0, nil
  187. } else {
  188. return false, err
  189. }
  190. case types.V_STRING: return strconv.ParseBool(self.toString())
  191. case _V_ANY :
  192. any := self.packAny()
  193. switch v := any.(type) {
  194. case bool : return v, nil
  195. case int : return v != 0, nil
  196. case int8 : return v != 0, nil
  197. case int16 : return v != 0, nil
  198. case int32 : return v != 0, nil
  199. case int64 : return v != 0, nil
  200. case uint : return v != 0, nil
  201. case uint8 : return v != 0, nil
  202. case uint16 : return v != 0, nil
  203. case uint32 : return v != 0, nil
  204. case uint64 : return v != 0, nil
  205. case float32: return v != 0, nil
  206. case float64: return v != 0, nil
  207. case string : return strconv.ParseBool(v)
  208. case json.Number:
  209. if i, err := v.Int64(); err == nil {
  210. return i != 0, nil
  211. } else if f, err := v.Float64(); err == nil {
  212. return f != 0, nil
  213. } else {
  214. return false, err
  215. }
  216. default: return false, ErrUnsupportType
  217. }
  218. default : return false, ErrUnsupportType
  219. }
  220. }
  221. // Int64 casts the node to int64 value,
  222. // including V_NUMBER|V_TRUE|V_FALSE|V_ANY|V_STRING
  223. // V_NONE it will return error
  224. func (self *Node) Int64() (int64, error) {
  225. if err := self.checkRaw(); err != nil {
  226. return 0, err
  227. }
  228. switch self.t {
  229. case _V_NUMBER, types.V_STRING :
  230. if i, err := self.toInt64(); err == nil {
  231. return i, nil
  232. } else if f, err := self.toFloat64(); err == nil {
  233. return int64(f), nil
  234. } else {
  235. return 0, err
  236. }
  237. case types.V_TRUE : return 1, nil
  238. case types.V_FALSE : return 0, nil
  239. case types.V_NULL : return 0, nil
  240. case _V_ANY :
  241. any := self.packAny()
  242. switch v := any.(type) {
  243. case bool : if v { return 1, nil } else { return 0, nil }
  244. case int : return int64(v), nil
  245. case int8 : return int64(v), nil
  246. case int16 : return int64(v), nil
  247. case int32 : return int64(v), nil
  248. case int64 : return int64(v), nil
  249. case uint : return int64(v), nil
  250. case uint8 : return int64(v), nil
  251. case uint16 : return int64(v), nil
  252. case uint32 : return int64(v), nil
  253. case uint64 : return int64(v), nil
  254. case float32: return int64(v), nil
  255. case float64: return int64(v), nil
  256. case string :
  257. if i, err := strconv.ParseInt(v, 10, 64); err == nil {
  258. return i, nil
  259. } else if f, err := strconv.ParseFloat(v, 64); err == nil {
  260. return int64(f), nil
  261. } else {
  262. return 0, err
  263. }
  264. case json.Number:
  265. if i, err := v.Int64(); err == nil {
  266. return i, nil
  267. } else if f, err := v.Float64(); err == nil {
  268. return int64(f), nil
  269. } else {
  270. return 0, err
  271. }
  272. default: return 0, ErrUnsupportType
  273. }
  274. default : return 0, ErrUnsupportType
  275. }
  276. }
  277. // StrictInt64 exports underlying int64 value, including V_NUMBER, V_ANY
  278. func (self *Node) StrictInt64() (int64, error) {
  279. if err := self.checkRaw(); err != nil {
  280. return 0, err
  281. }
  282. switch self.t {
  283. case _V_NUMBER : return self.toInt64()
  284. case _V_ANY :
  285. any := self.packAny()
  286. switch v := any.(type) {
  287. case int : return int64(v), nil
  288. case int8 : return int64(v), nil
  289. case int16 : return int64(v), nil
  290. case int32 : return int64(v), nil
  291. case int64 : return int64(v), nil
  292. case uint : return int64(v), nil
  293. case uint8 : return int64(v), nil
  294. case uint16: return int64(v), nil
  295. case uint32: return int64(v), nil
  296. case uint64: return int64(v), nil
  297. case json.Number:
  298. if i, err := v.Int64(); err == nil {
  299. return i, nil
  300. } else {
  301. return 0, err
  302. }
  303. default: return 0, ErrUnsupportType
  304. }
  305. default : return 0, ErrUnsupportType
  306. }
  307. }
  308. func castNumber(v bool) json.Number {
  309. if v {
  310. return json.Number("1")
  311. } else {
  312. return json.Number("0")
  313. }
  314. }
  315. // Number casts node to float64,
  316. // including V_NUMBER|V_TRUE|V_FALSE|V_ANY|V_STRING|V_NULL,
  317. // V_NONE it will return error
  318. func (self *Node) Number() (json.Number, error) {
  319. if err := self.checkRaw(); err != nil {
  320. return json.Number(""), err
  321. }
  322. switch self.t {
  323. case _V_NUMBER : return self.toNumber(), nil
  324. case types.V_STRING :
  325. if _, err := self.toInt64(); err == nil {
  326. return self.toNumber(), nil
  327. } else if _, err := self.toFloat64(); err == nil {
  328. return self.toNumber(), nil
  329. } else {
  330. return json.Number(""), err
  331. }
  332. case types.V_TRUE : return json.Number("1"), nil
  333. case types.V_FALSE : return json.Number("0"), nil
  334. case types.V_NULL : return json.Number("0"), nil
  335. case _V_ANY :
  336. any := self.packAny()
  337. switch v := any.(type) {
  338. case bool : return castNumber(v), nil
  339. case int : return castNumber(v != 0), nil
  340. case int8 : return castNumber(v != 0), nil
  341. case int16 : return castNumber(v != 0), nil
  342. case int32 : return castNumber(v != 0), nil
  343. case int64 : return castNumber(v != 0), nil
  344. case uint : return castNumber(v != 0), nil
  345. case uint8 : return castNumber(v != 0), nil
  346. case uint16 : return castNumber(v != 0), nil
  347. case uint32 : return castNumber(v != 0), nil
  348. case uint64 : return castNumber(v != 0), nil
  349. case float32: return castNumber(v != 0), nil
  350. case float64: return castNumber(v != 0), nil
  351. case string :
  352. if _, err := strconv.ParseFloat(v, 64); err == nil {
  353. return json.Number(v), nil
  354. } else {
  355. return json.Number(""), err
  356. }
  357. case json.Number: return v, nil
  358. default: return json.Number(""), ErrUnsupportType
  359. }
  360. default : return json.Number(""), ErrUnsupportType
  361. }
  362. }
  363. // Number exports underlying float64 value, including V_NUMBER, V_ANY of json.Number
  364. func (self *Node) StrictNumber() (json.Number, error) {
  365. if err := self.checkRaw(); err != nil {
  366. return json.Number(""), err
  367. }
  368. switch self.t {
  369. case _V_NUMBER : return self.toNumber() , nil
  370. case _V_ANY :
  371. if v, ok := self.packAny().(json.Number); ok {
  372. return v, nil
  373. } else {
  374. return json.Number(""), ErrUnsupportType
  375. }
  376. default : return json.Number(""), ErrUnsupportType
  377. }
  378. }
  379. // String cast node to string,
  380. // including V_NUMBER|V_TRUE|V_FALSE|V_ANY|V_STRING|V_NULL,
  381. // V_NONE it will return error
  382. func (self *Node) String() (string, error) {
  383. if err := self.checkRaw(); err != nil {
  384. return "", err
  385. }
  386. switch self.t {
  387. case types.V_NULL : return "" , nil
  388. case types.V_TRUE : return "true" , nil
  389. case types.V_FALSE : return "false", nil
  390. case types.V_STRING, _V_NUMBER : return self.toString(), nil
  391. case _V_ANY :
  392. any := self.packAny()
  393. switch v := any.(type) {
  394. case bool : return strconv.FormatBool(v), nil
  395. case int : return strconv.Itoa(v), nil
  396. case int8 : return strconv.Itoa(int(v)), nil
  397. case int16 : return strconv.Itoa(int(v)), nil
  398. case int32 : return strconv.Itoa(int(v)), nil
  399. case int64 : return strconv.Itoa(int(v)), nil
  400. case uint : return strconv.Itoa(int(v)), nil
  401. case uint8 : return strconv.Itoa(int(v)), nil
  402. case uint16 : return strconv.Itoa(int(v)), nil
  403. case uint32 : return strconv.Itoa(int(v)), nil
  404. case uint64 : return strconv.Itoa(int(v)), nil
  405. case float32: return strconv.FormatFloat(float64(v), 'g', -1, 64), nil
  406. case float64: return strconv.FormatFloat(float64(v), 'g', -1, 64), nil
  407. case string : return v, nil
  408. case json.Number: return v.String(), nil
  409. default: return "", ErrUnsupportType
  410. }
  411. default : return "" , ErrUnsupportType
  412. }
  413. }
  414. // StrictString returns string value (unescaped), including V_STRING, V_ANY of string.
  415. // In other cases, it will return empty string.
  416. func (self *Node) StrictString() (string, error) {
  417. if err := self.checkRaw(); err != nil {
  418. return "", err
  419. }
  420. switch self.t {
  421. case types.V_STRING : return self.toString(), nil
  422. case _V_ANY :
  423. if v, ok := self.packAny().(string); ok {
  424. return v, nil
  425. } else {
  426. return "", ErrUnsupportType
  427. }
  428. default : return "", ErrUnsupportType
  429. }
  430. }
  431. // Float64 cast node to float64,
  432. // including V_NUMBER|V_TRUE|V_FALSE|V_ANY|V_STRING|V_NULL,
  433. // V_NONE it will return error
  434. func (self *Node) Float64() (float64, error) {
  435. if err := self.checkRaw(); err != nil {
  436. return 0.0, err
  437. }
  438. switch self.t {
  439. case _V_NUMBER, types.V_STRING : return self.toFloat64()
  440. case types.V_TRUE : return 1.0, nil
  441. case types.V_FALSE : return 0.0, nil
  442. case types.V_NULL : return 0.0, nil
  443. case _V_ANY :
  444. any := self.packAny()
  445. switch v := any.(type) {
  446. case bool :
  447. if v {
  448. return 1.0, nil
  449. } else {
  450. return 0.0, nil
  451. }
  452. case int : return float64(v), nil
  453. case int8 : return float64(v), nil
  454. case int16 : return float64(v), nil
  455. case int32 : return float64(v), nil
  456. case int64 : return float64(v), nil
  457. case uint : return float64(v), nil
  458. case uint8 : return float64(v), nil
  459. case uint16 : return float64(v), nil
  460. case uint32 : return float64(v), nil
  461. case uint64 : return float64(v), nil
  462. case float32: return float64(v), nil
  463. case float64: return float64(v), nil
  464. case string :
  465. if f, err := strconv.ParseFloat(v, 64); err == nil {
  466. return float64(f), nil
  467. } else {
  468. return 0, err
  469. }
  470. case json.Number:
  471. if f, err := v.Float64(); err == nil {
  472. return float64(f), nil
  473. } else {
  474. return 0, err
  475. }
  476. default : return 0, ErrUnsupportType
  477. }
  478. default : return 0.0, ErrUnsupportType
  479. }
  480. }
  481. // Float64 exports underlying float64 value, including V_NUMBER, V_ANY
  482. func (self *Node) StrictFloat64() (float64, error) {
  483. if err := self.checkRaw(); err != nil {
  484. return 0.0, err
  485. }
  486. switch self.t {
  487. case _V_NUMBER : return self.toFloat64()
  488. case _V_ANY :
  489. any := self.packAny()
  490. switch v := any.(type) {
  491. case float32 : return float64(v), nil
  492. case float64 : return float64(v), nil
  493. default : return 0, ErrUnsupportType
  494. }
  495. default : return 0.0, ErrUnsupportType
  496. }
  497. }
  498. /** Sequential Value Methods **/
  499. // Len returns children count of a array|object|string node
  500. // WARN: For partially loaded node, it also works but only counts the parsed children
  501. func (self *Node) Len() (int, error) {
  502. if err := self.checkRaw(); err != nil {
  503. return 0, err
  504. }
  505. if self.t == types.V_ARRAY || self.t == types.V_OBJECT || self.t == _V_ARRAY_LAZY || self.t == _V_OBJECT_LAZY || self.t == types.V_STRING {
  506. return int(self.l), nil
  507. } else if self.t == _V_NONE || self.t == types.V_NULL {
  508. return 0, nil
  509. } else {
  510. return 0, ErrUnsupportType
  511. }
  512. }
  513. func (self *Node) len() int {
  514. return int(self.l)
  515. }
  516. // Cap returns malloc capacity of a array|object node for children
  517. func (self *Node) Cap() (int, error) {
  518. if err := self.checkRaw(); err != nil {
  519. return 0, err
  520. }
  521. switch self.t {
  522. case types.V_ARRAY: return (*linkedNodes)(self.p).Cap(), nil
  523. case types.V_OBJECT: return (*linkedPairs)(self.p).Cap(), nil
  524. case _V_ARRAY_LAZY: return (*parseArrayStack)(self.p).v.Cap(), nil
  525. case _V_OBJECT_LAZY: return (*parseObjectStack)(self.p).v.Cap(), nil
  526. case _V_NONE, types.V_NULL: return 0, nil
  527. default: return 0, ErrUnsupportType
  528. }
  529. }
  530. // Set sets the node of given key under self, and reports if the key has existed.
  531. //
  532. // If self is V_NONE or V_NULL, it becomes V_OBJECT and sets the node at the key.
  533. func (self *Node) Set(key string, node Node) (bool, error) {
  534. if err := self.checkRaw(); err != nil {
  535. return false, err
  536. }
  537. if err := node.Check(); err != nil {
  538. return false, err
  539. }
  540. if self.t == _V_NONE || self.t == types.V_NULL {
  541. *self = NewObject([]Pair{NewPair(key, node)})
  542. return false, nil
  543. } else if self.itype() != types.V_OBJECT {
  544. return false, ErrUnsupportType
  545. }
  546. p := self.Get(key)
  547. if !p.Exists() {
  548. // self must be fully-loaded here
  549. if self.len() == 0 {
  550. *self = newObject(new(linkedPairs))
  551. }
  552. s := (*linkedPairs)(self.p)
  553. s.Push(NewPair(key, node))
  554. self.l++
  555. return false, nil
  556. } else if err := p.Check(); err != nil {
  557. return false, err
  558. }
  559. *p = node
  560. return true, nil
  561. }
  562. // SetAny wraps val with V_ANY node, and Set() the node.
  563. func (self *Node) SetAny(key string, val interface{}) (bool, error) {
  564. return self.Set(key, NewAny(val))
  565. }
  566. // Unset REMOVE (soft) the node of given key under object parent, and reports if the key has existed.
  567. func (self *Node) Unset(key string) (bool, error) {
  568. if err := self.should(types.V_OBJECT); err != nil {
  569. return false, err
  570. }
  571. // NOTICE: must get accurate length before deduct
  572. if err := self.skipAllKey(); err != nil {
  573. return false, err
  574. }
  575. p, i := self.skipKey(key)
  576. if !p.Exists() {
  577. return false, nil
  578. } else if err := p.Check(); err != nil {
  579. return false, err
  580. }
  581. self.removePairAt(i)
  582. return true, nil
  583. }
  584. // SetByIndex sets the node of given index, and reports if the key has existed.
  585. //
  586. // The index must be within self's children.
  587. func (self *Node) SetByIndex(index int, node Node) (bool, error) {
  588. if err := self.checkRaw(); err != nil {
  589. return false, err
  590. }
  591. if err := node.Check(); err != nil {
  592. return false, err
  593. }
  594. if index == 0 && (self.t == _V_NONE || self.t == types.V_NULL) {
  595. *self = NewArray([]Node{node})
  596. return false, nil
  597. }
  598. p := self.Index(index)
  599. if !p.Exists() {
  600. return false, ErrNotExist
  601. } else if err := p.Check(); err != nil {
  602. return false, err
  603. }
  604. *p = node
  605. return true, nil
  606. }
  607. // SetAny wraps val with V_ANY node, and SetByIndex() the node.
  608. func (self *Node) SetAnyByIndex(index int, val interface{}) (bool, error) {
  609. return self.SetByIndex(index, NewAny(val))
  610. }
  611. // UnsetByIndex REMOVE (softly) the node of given index.
  612. //
  613. // WARN: this will change address of elements, which is a dangerous action.
  614. // Use Unset() for object or Pop() for array instead.
  615. func (self *Node) UnsetByIndex(index int) (bool, error) {
  616. if err := self.checkRaw(); err != nil {
  617. return false, err
  618. }
  619. var p *Node
  620. it := self.itype()
  621. if it == types.V_ARRAY {
  622. if err := self.skipAllIndex(); err != nil {
  623. return false, err
  624. }
  625. p = self.nodeAt(index)
  626. } else if it == types.V_OBJECT {
  627. if err := self.skipAllKey(); err != nil {
  628. return false, err
  629. }
  630. pr := self.pairAt(index)
  631. if pr == nil {
  632. return false, ErrNotExist
  633. }
  634. p = &pr.Value
  635. } else {
  636. return false, ErrUnsupportType
  637. }
  638. if !p.Exists() {
  639. return false, ErrNotExist
  640. }
  641. // last elem
  642. if index == self.len() - 1 {
  643. return true, self.Pop()
  644. }
  645. // not last elem, self.len() change but linked-chunk not change
  646. if it == types.V_ARRAY {
  647. self.removeNode(index)
  648. }else if it == types.V_OBJECT {
  649. self.removePair(index)
  650. }
  651. return true, nil
  652. }
  653. // Add appends the given node under self.
  654. //
  655. // If self is V_NONE or V_NULL, it becomes V_ARRAY and sets the node at index 0.
  656. func (self *Node) Add(node Node) error {
  657. if err := self.checkRaw(); err != nil {
  658. return err
  659. }
  660. if self != nil && (self.t == _V_NONE || self.t == types.V_NULL) {
  661. *self = NewArray([]Node{node})
  662. return nil
  663. }
  664. if err := self.should(types.V_ARRAY); err != nil {
  665. return err
  666. }
  667. s, err := self.unsafeArray()
  668. if err != nil {
  669. return err
  670. }
  671. // Notice: array won't have unset node in tail
  672. s.Push(node)
  673. self.l++
  674. return nil
  675. }
  676. // Pop remove the last child of the V_Array or V_Object node.
  677. func (self *Node) Pop() error {
  678. if err := self.checkRaw(); err != nil {
  679. return err
  680. }
  681. if it := self.itype(); it == types.V_ARRAY {
  682. s, err := self.unsafeArray()
  683. if err != nil {
  684. return err
  685. }
  686. // remove tail unset nodes
  687. for i := s.Len()-1; i >= 0; i-- {
  688. if s.At(i).Exists() {
  689. s.Pop()
  690. self.l--
  691. break
  692. }
  693. s.Pop()
  694. }
  695. } else if it == types.V_OBJECT {
  696. s, err := self.unsafeMap()
  697. if err != nil {
  698. return err
  699. }
  700. // remove tail unset nodes
  701. for i := s.Len()-1; i >= 0; i-- {
  702. if p := s.At(i); p != nil && p.Value.Exists() {
  703. s.Pop()
  704. self.l--
  705. break
  706. }
  707. s.Pop()
  708. }
  709. } else {
  710. return ErrUnsupportType
  711. }
  712. return nil
  713. }
  714. // Move moves the child at src index to dst index,
  715. // meanwhile slides sliblings from src+1 to dst.
  716. //
  717. // WARN: this will change address of elements, which is a dangerous action.
  718. func (self *Node) Move(dst, src int) error {
  719. if err := self.should(types.V_ARRAY); err != nil {
  720. return err
  721. }
  722. s, err := self.unsafeArray()
  723. if err != nil {
  724. return err
  725. }
  726. // check if any unset node exists
  727. if l := s.Len(); self.len() != l {
  728. di, si := dst, src
  729. // find real pos of src and dst
  730. for i := 0; i < l; i++ {
  731. if s.At(i).Exists() {
  732. di--
  733. si--
  734. }
  735. if di == -1 {
  736. dst = i
  737. di--
  738. }
  739. if si == -1 {
  740. src = i
  741. si--
  742. }
  743. if di == -2 && si == -2 {
  744. break
  745. }
  746. }
  747. }
  748. s.MoveOne(src, dst)
  749. return nil
  750. }
  751. // SetAny wraps val with V_ANY node, and Add() the node.
  752. func (self *Node) AddAny(val interface{}) error {
  753. return self.Add(NewAny(val))
  754. }
  755. // GetByPath load given path on demands,
  756. // which only ensure nodes before this path got parsed.
  757. //
  758. // Note, the api expects the json is well-formed at least,
  759. // otherwise it may return unexpected result.
  760. func (self *Node) GetByPath(path ...interface{}) *Node {
  761. if !self.Valid() {
  762. return self
  763. }
  764. var s = self
  765. for _, p := range path {
  766. switch p := p.(type) {
  767. case int:
  768. s = s.Index(p)
  769. if !s.Valid() {
  770. return s
  771. }
  772. case string:
  773. s = s.Get(p)
  774. if !s.Valid() {
  775. return s
  776. }
  777. default:
  778. panic("path must be either int or string")
  779. }
  780. }
  781. return s
  782. }
  783. // Get loads given key of an object node on demands
  784. func (self *Node) Get(key string) *Node {
  785. if err := self.should(types.V_OBJECT); err != nil {
  786. return unwrapError(err)
  787. }
  788. n, _ := self.skipKey(key)
  789. return n
  790. }
  791. // Index indexies node at given idx,
  792. // node type CAN be either V_OBJECT or V_ARRAY
  793. func (self *Node) Index(idx int) *Node {
  794. if err := self.checkRaw(); err != nil {
  795. return unwrapError(err)
  796. }
  797. it := self.itype()
  798. if it == types.V_ARRAY {
  799. return self.skipIndex(idx)
  800. }else if it == types.V_OBJECT {
  801. pr := self.skipIndexPair(idx)
  802. if pr == nil {
  803. return newError(_ERR_NOT_FOUND, "value not exists")
  804. }
  805. return &pr.Value
  806. } else {
  807. return newError(_ERR_UNSUPPORT_TYPE, fmt.Sprintf("unsupported type: %v", self.itype()))
  808. }
  809. }
  810. // IndexPair indexies pair at given idx,
  811. // node type MUST be either V_OBJECT
  812. func (self *Node) IndexPair(idx int) *Pair {
  813. if err := self.should(types.V_OBJECT); err != nil {
  814. return nil
  815. }
  816. return self.skipIndexPair(idx)
  817. }
  818. func (self *Node) indexOrGet(idx int, key string) (*Node, int) {
  819. if err := self.should(types.V_OBJECT); err != nil {
  820. return unwrapError(err), idx
  821. }
  822. pr := self.skipIndexPair(idx)
  823. if pr != nil && pr.Key == key {
  824. return &pr.Value, idx
  825. }
  826. return self.skipKey(key)
  827. }
  828. // IndexOrGet firstly use idx to index a value and check if its key matches
  829. // If not, then use the key to search value
  830. func (self *Node) IndexOrGet(idx int, key string) *Node {
  831. node, _ := self.indexOrGet(idx, key)
  832. return node
  833. }
  834. // IndexOrGetWithIdx attempts to retrieve a node by index and key, returning the node and its correct index.
  835. // If the key does not match at the given index, it searches by key and returns the node with its updated index.
  836. func (self *Node) IndexOrGetWithIdx(idx int, key string) (*Node, int) {
  837. return self.indexOrGet(idx, key)
  838. }
  839. /** Generic Value Converters **/
  840. // Map loads all keys of an object node
  841. func (self *Node) Map() (map[string]interface{}, error) {
  842. if self.isAny() {
  843. any := self.packAny()
  844. if v, ok := any.(map[string]interface{}); ok {
  845. return v, nil
  846. } else {
  847. return nil, ErrUnsupportType
  848. }
  849. }
  850. if err := self.should(types.V_OBJECT); err != nil {
  851. return nil, err
  852. }
  853. if err := self.loadAllKey(false); err != nil {
  854. return nil, err
  855. }
  856. return self.toGenericObject()
  857. }
  858. // MapUseNumber loads all keys of an object node, with numeric nodes casted to json.Number
  859. func (self *Node) MapUseNumber() (map[string]interface{}, error) {
  860. if self.isAny() {
  861. any := self.packAny()
  862. if v, ok := any.(map[string]interface{}); ok {
  863. return v, nil
  864. } else {
  865. return nil, ErrUnsupportType
  866. }
  867. }
  868. if err := self.should(types.V_OBJECT); err != nil {
  869. return nil, err
  870. }
  871. if err := self.loadAllKey(false); err != nil {
  872. return nil, err
  873. }
  874. return self.toGenericObjectUseNumber()
  875. }
  876. // MapUseNode scans both parsed and non-parsed children nodes,
  877. // and map them by their keys
  878. func (self *Node) MapUseNode() (map[string]Node, error) {
  879. if self.isAny() {
  880. any := self.packAny()
  881. if v, ok := any.(map[string]Node); ok {
  882. return v, nil
  883. } else {
  884. return nil, ErrUnsupportType
  885. }
  886. }
  887. if err := self.should(types.V_OBJECT); err != nil {
  888. return nil, err
  889. }
  890. if err := self.skipAllKey(); err != nil {
  891. return nil, err
  892. }
  893. return self.toGenericObjectUseNode()
  894. }
  895. // MapUnsafe exports the underlying pointer to its children map
  896. // WARN: don't use it unless you know what you are doing
  897. //
  898. // Deprecated: this API now returns copied nodes instead of directly reference,
  899. // func (self *Node) UnsafeMap() ([]Pair, error) {
  900. // if err := self.should(types.V_OBJECT, "an object"); err != nil {
  901. // return nil, err
  902. // }
  903. // if err := self.skipAllKey(); err != nil {
  904. // return nil, err
  905. // }
  906. // return self.toGenericObjectUsePair()
  907. // }
  908. //go:nocheckptr
  909. func (self *Node) unsafeMap() (*linkedPairs, error) {
  910. if err := self.skipAllKey(); err != nil {
  911. return nil, err
  912. }
  913. if self.p == nil {
  914. *self = newObject(new(linkedPairs))
  915. }
  916. return (*linkedPairs)(self.p), nil
  917. }
  918. // SortKeys sorts children of a V_OBJECT node in ascending key-order.
  919. // If recurse is true, it recursively sorts children's children as long as a V_OBJECT node is found.
  920. func (self *Node) SortKeys(recurse bool) error {
  921. // check raw node first
  922. if err := self.checkRaw(); err != nil {
  923. return err
  924. }
  925. if self.itype() == types.V_OBJECT {
  926. return self.sortKeys(recurse)
  927. } else if self.itype() == types.V_ARRAY {
  928. var err error
  929. err2 := self.ForEach(func(path Sequence, node *Node) bool {
  930. it := node.itype()
  931. if it == types.V_ARRAY || it == types.V_OBJECT {
  932. err = node.SortKeys(recurse)
  933. if err != nil {
  934. return false
  935. }
  936. }
  937. return true
  938. })
  939. if err != nil {
  940. return err
  941. }
  942. return err2
  943. } else {
  944. return nil
  945. }
  946. }
  947. func (self *Node) sortKeys(recurse bool) (err error) {
  948. // check raw node first
  949. if err := self.checkRaw(); err != nil {
  950. return err
  951. }
  952. ps, err := self.unsafeMap()
  953. if err != nil {
  954. return err
  955. }
  956. ps.Sort()
  957. if recurse {
  958. var sc Scanner
  959. sc = func(path Sequence, node *Node) bool {
  960. if node.itype() == types.V_OBJECT {
  961. if err := node.sortKeys(recurse); err != nil {
  962. return false
  963. }
  964. }
  965. if node.itype() == types.V_ARRAY {
  966. if err := node.ForEach(sc); err != nil {
  967. return false
  968. }
  969. }
  970. return true
  971. }
  972. if err := self.ForEach(sc); err != nil {
  973. return err
  974. }
  975. }
  976. return nil
  977. }
  978. // Array loads all indexes of an array node
  979. func (self *Node) Array() ([]interface{}, error) {
  980. if self.isAny() {
  981. any := self.packAny()
  982. if v, ok := any.([]interface{}); ok {
  983. return v, nil
  984. } else {
  985. return nil, ErrUnsupportType
  986. }
  987. }
  988. if err := self.should(types.V_ARRAY); err != nil {
  989. return nil, err
  990. }
  991. if err := self.loadAllIndex(false); err != nil {
  992. return nil, err
  993. }
  994. return self.toGenericArray()
  995. }
  996. // ArrayUseNumber loads all indexes of an array node, with numeric nodes casted to json.Number
  997. func (self *Node) ArrayUseNumber() ([]interface{}, error) {
  998. if self.isAny() {
  999. any := self.packAny()
  1000. if v, ok := any.([]interface{}); ok {
  1001. return v, nil
  1002. } else {
  1003. return nil, ErrUnsupportType
  1004. }
  1005. }
  1006. if err := self.should(types.V_ARRAY); err != nil {
  1007. return nil, err
  1008. }
  1009. if err := self.loadAllIndex(false); err != nil {
  1010. return nil, err
  1011. }
  1012. return self.toGenericArrayUseNumber()
  1013. }
  1014. // ArrayUseNode copies both parsed and non-parsed children nodes,
  1015. // and indexes them by original order
  1016. func (self *Node) ArrayUseNode() ([]Node, error) {
  1017. if self.isAny() {
  1018. any := self.packAny()
  1019. if v, ok := any.([]Node); ok {
  1020. return v, nil
  1021. } else {
  1022. return nil, ErrUnsupportType
  1023. }
  1024. }
  1025. if err := self.should(types.V_ARRAY); err != nil {
  1026. return nil, err
  1027. }
  1028. if err := self.skipAllIndex(); err != nil {
  1029. return nil, err
  1030. }
  1031. return self.toGenericArrayUseNode()
  1032. }
  1033. // ArrayUnsafe exports the underlying pointer to its children array
  1034. // WARN: don't use it unless you know what you are doing
  1035. //
  1036. // Deprecated: this API now returns copied nodes instead of directly reference,
  1037. // which has no difference with ArrayUseNode
  1038. // func (self *Node) UnsafeArray() ([]Node, error) {
  1039. // if err := self.should(types.V_ARRAY, "an array"); err != nil {
  1040. // return nil, err
  1041. // }
  1042. // if err := self.skipAllIndex(); err != nil {
  1043. // return nil, err
  1044. // }
  1045. // return self.toGenericArrayUseNode()
  1046. // }
  1047. func (self *Node) unsafeArray() (*linkedNodes, error) {
  1048. if err := self.skipAllIndex(); err != nil {
  1049. return nil, err
  1050. }
  1051. if self.p == nil {
  1052. *self = newArray(new(linkedNodes))
  1053. }
  1054. return (*linkedNodes)(self.p), nil
  1055. }
  1056. // Interface loads all children under all paths from this node,
  1057. // and converts itself as generic type.
  1058. // WARN: all numeric nodes are casted to float64
  1059. func (self *Node) Interface() (interface{}, error) {
  1060. if err := self.checkRaw(); err != nil {
  1061. return nil, err
  1062. }
  1063. switch self.t {
  1064. case V_ERROR : return nil, self.Check()
  1065. case types.V_NULL : return nil, nil
  1066. case types.V_TRUE : return true, nil
  1067. case types.V_FALSE : return false, nil
  1068. case types.V_ARRAY : return self.toGenericArray()
  1069. case types.V_OBJECT : return self.toGenericObject()
  1070. case types.V_STRING : return self.toString(), nil
  1071. case _V_NUMBER :
  1072. v, err := self.toFloat64()
  1073. if err != nil {
  1074. return nil, err
  1075. }
  1076. return v, nil
  1077. case _V_ARRAY_LAZY :
  1078. if err := self.loadAllIndex(false); err != nil {
  1079. return nil, err
  1080. }
  1081. return self.toGenericArray()
  1082. case _V_OBJECT_LAZY :
  1083. if err := self.loadAllKey(false); err != nil {
  1084. return nil, err
  1085. }
  1086. return self.toGenericObject()
  1087. case _V_ANY:
  1088. switch v := self.packAny().(type) {
  1089. case Node : return v.Interface()
  1090. case *Node: return v.Interface()
  1091. default : return v, nil
  1092. }
  1093. default : return nil, ErrUnsupportType
  1094. }
  1095. }
  1096. func (self *Node) packAny() interface{} {
  1097. return *(*interface{})(self.p)
  1098. }
  1099. // InterfaceUseNumber works same with Interface()
  1100. // except numeric nodes are casted to json.Number
  1101. func (self *Node) InterfaceUseNumber() (interface{}, error) {
  1102. if err := self.checkRaw(); err != nil {
  1103. return nil, err
  1104. }
  1105. switch self.t {
  1106. case V_ERROR : return nil, self.Check()
  1107. case types.V_NULL : return nil, nil
  1108. case types.V_TRUE : return true, nil
  1109. case types.V_FALSE : return false, nil
  1110. case types.V_ARRAY : return self.toGenericArrayUseNumber()
  1111. case types.V_OBJECT : return self.toGenericObjectUseNumber()
  1112. case types.V_STRING : return self.toString(), nil
  1113. case _V_NUMBER : return self.toNumber(), nil
  1114. case _V_ARRAY_LAZY :
  1115. if err := self.loadAllIndex(false); err != nil {
  1116. return nil, err
  1117. }
  1118. return self.toGenericArrayUseNumber()
  1119. case _V_OBJECT_LAZY :
  1120. if err := self.loadAllKey(false); err != nil {
  1121. return nil, err
  1122. }
  1123. return self.toGenericObjectUseNumber()
  1124. case _V_ANY : return self.packAny(), nil
  1125. default : return nil, ErrUnsupportType
  1126. }
  1127. }
  1128. // InterfaceUseNode clone itself as a new node,
  1129. // or its children as map[string]Node (or []Node)
  1130. func (self *Node) InterfaceUseNode() (interface{}, error) {
  1131. if err := self.checkRaw(); err != nil {
  1132. return nil, err
  1133. }
  1134. switch self.t {
  1135. case types.V_ARRAY : return self.toGenericArrayUseNode()
  1136. case types.V_OBJECT : return self.toGenericObjectUseNode()
  1137. case _V_ARRAY_LAZY :
  1138. if err := self.skipAllIndex(); err != nil {
  1139. return nil, err
  1140. }
  1141. return self.toGenericArrayUseNode()
  1142. case _V_OBJECT_LAZY :
  1143. if err := self.skipAllKey(); err != nil {
  1144. return nil, err
  1145. }
  1146. return self.toGenericObjectUseNode()
  1147. default : return *self, self.Check()
  1148. }
  1149. }
  1150. // LoadAll loads the node's children
  1151. // and ensure all its children can be READ concurrently (include its children's children)
  1152. func (self *Node) LoadAll() error {
  1153. return self.Load()
  1154. }
  1155. // Load loads the node's children as parsed.
  1156. // and ensure all its children can be READ concurrently (include its children's children)
  1157. func (self *Node) Load() error {
  1158. switch self.t {
  1159. case _V_ARRAY_LAZY: self.loadAllIndex(true)
  1160. case _V_OBJECT_LAZY: self.loadAllKey(true)
  1161. case V_ERROR: return self
  1162. case V_NONE: return nil
  1163. }
  1164. if self.m == nil {
  1165. self.m = new(sync.RWMutex)
  1166. }
  1167. return self.checkRaw()
  1168. }
  1169. /**---------------------------------- Internal Helper Methods ----------------------------------**/
  1170. func (self *Node) should(t types.ValueType) error {
  1171. if err := self.checkRaw(); err != nil {
  1172. return err
  1173. }
  1174. if self.itype() != t {
  1175. return ErrUnsupportType
  1176. }
  1177. return nil
  1178. }
  1179. func (self *Node) nodeAt(i int) *Node {
  1180. var p *linkedNodes
  1181. if self.isLazy() {
  1182. _, stack := self.getParserAndArrayStack()
  1183. p = &stack.v
  1184. } else {
  1185. p = (*linkedNodes)(self.p)
  1186. if l := p.Len(); l != self.len() {
  1187. // some nodes got unset, iterate to skip them
  1188. for j:=0; j<l; j++ {
  1189. v := p.At(j)
  1190. if v.Exists() {
  1191. i--
  1192. }
  1193. if i < 0 {
  1194. return v
  1195. }
  1196. }
  1197. return nil
  1198. }
  1199. }
  1200. return p.At(i)
  1201. }
  1202. func (self *Node) pairAt(i int) *Pair {
  1203. var p *linkedPairs
  1204. if self.isLazy() {
  1205. _, stack := self.getParserAndObjectStack()
  1206. p = &stack.v
  1207. } else {
  1208. p = (*linkedPairs)(self.p)
  1209. if l := p.Len(); l != self.len() {
  1210. // some nodes got unset, iterate to skip them
  1211. for j:=0; j<l; j++ {
  1212. v := p.At(j)
  1213. if v != nil && v.Value.Exists() {
  1214. i--
  1215. }
  1216. if i < 0 {
  1217. return v
  1218. }
  1219. }
  1220. return nil
  1221. }
  1222. }
  1223. return p.At(i)
  1224. }
  1225. func (self *Node) skipAllIndex() error {
  1226. if !self.isLazy() {
  1227. return nil
  1228. }
  1229. var err types.ParsingError
  1230. parser, stack := self.getParserAndArrayStack()
  1231. parser.skipValue = true
  1232. parser.noLazy = true
  1233. *self, err = parser.decodeArray(&stack.v)
  1234. if err != 0 {
  1235. return parser.ExportError(err)
  1236. }
  1237. return nil
  1238. }
  1239. func (self *Node) skipAllKey() error {
  1240. if !self.isLazy() {
  1241. return nil
  1242. }
  1243. var err types.ParsingError
  1244. parser, stack := self.getParserAndObjectStack()
  1245. parser.skipValue = true
  1246. parser.noLazy = true
  1247. *self, err = parser.decodeObject(&stack.v)
  1248. if err != 0 {
  1249. return parser.ExportError(err)
  1250. }
  1251. return nil
  1252. }
  1253. func (self *Node) skipKey(key string) (*Node, int) {
  1254. nb := self.len()
  1255. lazy := self.isLazy()
  1256. if nb > 0 {
  1257. /* linear search */
  1258. var p *Pair
  1259. var i int
  1260. if lazy {
  1261. s := (*parseObjectStack)(self.p)
  1262. p, i = s.v.Get(key)
  1263. } else {
  1264. p, i = (*linkedPairs)(self.p).Get(key)
  1265. }
  1266. if p != nil {
  1267. return &p.Value, i
  1268. }
  1269. }
  1270. /* not found */
  1271. if !lazy {
  1272. return nil, -1
  1273. }
  1274. // lazy load
  1275. for last, i := self.skipNextPair(), nb; last != nil; last, i = self.skipNextPair(), i+1 {
  1276. if last.Value.Check() != nil {
  1277. return &last.Value, -1
  1278. }
  1279. if last.Key == key {
  1280. return &last.Value, i
  1281. }
  1282. }
  1283. return nil, -1
  1284. }
  1285. func (self *Node) skipIndex(index int) *Node {
  1286. nb := self.len()
  1287. if nb > index {
  1288. v := self.nodeAt(index)
  1289. return v
  1290. }
  1291. if !self.isLazy() {
  1292. return nil
  1293. }
  1294. // lazy load
  1295. for last := self.skipNextNode(); last != nil; last = self.skipNextNode(){
  1296. if last.Check() != nil {
  1297. return last
  1298. }
  1299. if self.len() > index {
  1300. return last
  1301. }
  1302. }
  1303. return nil
  1304. }
  1305. func (self *Node) skipIndexPair(index int) *Pair {
  1306. nb := self.len()
  1307. if nb > index {
  1308. return self.pairAt(index)
  1309. }
  1310. if !self.isLazy() {
  1311. return nil
  1312. }
  1313. // lazy load
  1314. for last := self.skipNextPair(); last != nil; last = self.skipNextPair(){
  1315. if last.Value.Check() != nil {
  1316. return last
  1317. }
  1318. if self.len() > index {
  1319. return last
  1320. }
  1321. }
  1322. return nil
  1323. }
  1324. func (self *Node) loadAllIndex(loadOnce bool) error {
  1325. if !self.isLazy() {
  1326. return nil
  1327. }
  1328. var err types.ParsingError
  1329. parser, stack := self.getParserAndArrayStack()
  1330. if !loadOnce {
  1331. parser.noLazy = true
  1332. } else {
  1333. parser.loadOnce = true
  1334. }
  1335. *self, err = parser.decodeArray(&stack.v)
  1336. if err != 0 {
  1337. return parser.ExportError(err)
  1338. }
  1339. return nil
  1340. }
  1341. func (self *Node) loadAllKey(loadOnce bool) error {
  1342. if !self.isLazy() {
  1343. return nil
  1344. }
  1345. var err types.ParsingError
  1346. parser, stack := self.getParserAndObjectStack()
  1347. if !loadOnce {
  1348. parser.noLazy = true
  1349. *self, err = parser.decodeObject(&stack.v)
  1350. } else {
  1351. parser.loadOnce = true
  1352. *self, err = parser.decodeObject(&stack.v)
  1353. }
  1354. if err != 0 {
  1355. return parser.ExportError(err)
  1356. }
  1357. return nil
  1358. }
  1359. func (self *Node) removeNode(i int) {
  1360. node := self.nodeAt(i)
  1361. if node == nil {
  1362. return
  1363. }
  1364. *node = Node{}
  1365. // NOTICE: not be consistent with linkedNode.Len()
  1366. self.l--
  1367. }
  1368. func (self *Node) removePair(i int) {
  1369. last := self.pairAt(i)
  1370. if last == nil {
  1371. return
  1372. }
  1373. *last = Pair{}
  1374. // NOTICE: should be consistent with linkedPair.Len()
  1375. self.l--
  1376. }
  1377. func (self *Node) removePairAt(i int) {
  1378. p := (*linkedPairs)(self.p).At(i)
  1379. if p == nil {
  1380. return
  1381. }
  1382. *p = Pair{}
  1383. // NOTICE: should be consistent with linkedPair.Len()
  1384. self.l--
  1385. }
  1386. func (self *Node) toGenericArray() ([]interface{}, error) {
  1387. nb := self.len()
  1388. if nb == 0 {
  1389. return []interface{}{}, nil
  1390. }
  1391. ret := make([]interface{}, 0, nb)
  1392. /* convert each item */
  1393. it := self.values()
  1394. for v := it.next(); v != nil; v = it.next() {
  1395. vv, err := v.Interface()
  1396. if err != nil {
  1397. return nil, err
  1398. }
  1399. ret = append(ret, vv)
  1400. }
  1401. /* all done */
  1402. return ret, nil
  1403. }
  1404. func (self *Node) toGenericArrayUseNumber() ([]interface{}, error) {
  1405. nb := self.len()
  1406. if nb == 0 {
  1407. return []interface{}{}, nil
  1408. }
  1409. ret := make([]interface{}, 0, nb)
  1410. /* convert each item */
  1411. it := self.values()
  1412. for v := it.next(); v != nil; v = it.next() {
  1413. vv, err := v.InterfaceUseNumber()
  1414. if err != nil {
  1415. return nil, err
  1416. }
  1417. ret = append(ret, vv)
  1418. }
  1419. /* all done */
  1420. return ret, nil
  1421. }
  1422. func (self *Node) toGenericArrayUseNode() ([]Node, error) {
  1423. var nb = self.len()
  1424. if nb == 0 {
  1425. return []Node{}, nil
  1426. }
  1427. var s = (*linkedNodes)(self.p)
  1428. var out = make([]Node, nb)
  1429. s.ToSlice(out)
  1430. return out, nil
  1431. }
  1432. func (self *Node) toGenericObject() (map[string]interface{}, error) {
  1433. nb := self.len()
  1434. if nb == 0 {
  1435. return map[string]interface{}{}, nil
  1436. }
  1437. ret := make(map[string]interface{}, nb)
  1438. /* convert each item */
  1439. it := self.properties()
  1440. for v := it.next(); v != nil; v = it.next() {
  1441. vv, err := v.Value.Interface()
  1442. if err != nil {
  1443. return nil, err
  1444. }
  1445. ret[v.Key] = vv
  1446. }
  1447. /* all done */
  1448. return ret, nil
  1449. }
  1450. func (self *Node) toGenericObjectUseNumber() (map[string]interface{}, error) {
  1451. nb := self.len()
  1452. if nb == 0 {
  1453. return map[string]interface{}{}, nil
  1454. }
  1455. ret := make(map[string]interface{}, nb)
  1456. /* convert each item */
  1457. it := self.properties()
  1458. for v := it.next(); v != nil; v = it.next() {
  1459. vv, err := v.Value.InterfaceUseNumber()
  1460. if err != nil {
  1461. return nil, err
  1462. }
  1463. ret[v.Key] = vv
  1464. }
  1465. /* all done */
  1466. return ret, nil
  1467. }
  1468. func (self *Node) toGenericObjectUseNode() (map[string]Node, error) {
  1469. var nb = self.len()
  1470. if nb == 0 {
  1471. return map[string]Node{}, nil
  1472. }
  1473. var s = (*linkedPairs)(self.p)
  1474. var out = make(map[string]Node, nb)
  1475. s.ToMap(out)
  1476. /* all done */
  1477. return out, nil
  1478. }
  1479. /**------------------------------------ Factory Methods ------------------------------------**/
  1480. var (
  1481. nullNode = Node{t: types.V_NULL}
  1482. trueNode = Node{t: types.V_TRUE}
  1483. falseNode = Node{t: types.V_FALSE}
  1484. )
  1485. // NewRaw creates a node of raw json.
  1486. // If the input json is invalid, NewRaw returns a error Node.
  1487. func NewRaw(json string) Node {
  1488. parser := NewParserObj(json)
  1489. start, err := parser.skip()
  1490. if err != 0 {
  1491. return *newError(err, err.Message())
  1492. }
  1493. it := switchRawType(parser.s[start])
  1494. if it == _V_NONE {
  1495. return Node{}
  1496. }
  1497. return newRawNode(parser.s[start:parser.p], it, false)
  1498. }
  1499. // NewRawConcurrentRead creates a node of raw json, which can be READ
  1500. // (GetByPath/Get/Index/GetOrIndex/Int64/Bool/Float64/String/Number/Interface/Array/Map/Raw/MarshalJSON) concurrently.
  1501. // If the input json is invalid, NewRaw returns a error Node.
  1502. func NewRawConcurrentRead(json string) Node {
  1503. parser := NewParserObj(json)
  1504. start, err := parser.skip()
  1505. if err != 0 {
  1506. return *newError(err, err.Message())
  1507. }
  1508. it := switchRawType(parser.s[start])
  1509. if it == _V_NONE {
  1510. return Node{}
  1511. }
  1512. return newRawNode(parser.s[start:parser.p], it, true)
  1513. }
  1514. // NewAny creates a node of type V_ANY if any's type isn't Node or *Node,
  1515. // which stores interface{} and can be only used for `.Interface()`\`.MarshalJSON()`.
  1516. func NewAny(any interface{}) Node {
  1517. switch n := any.(type) {
  1518. case Node:
  1519. return n
  1520. case *Node:
  1521. return *n
  1522. default:
  1523. return Node{
  1524. t: _V_ANY,
  1525. p: unsafe.Pointer(&any),
  1526. }
  1527. }
  1528. }
  1529. // NewBytes encodes given src with Base64 (RFC 4648), and creates a node of type V_STRING.
  1530. func NewBytes(src []byte) Node {
  1531. if len(src) == 0 {
  1532. panic("empty src bytes")
  1533. }
  1534. out := rt.EncodeBase64ToString(src)
  1535. return NewString(out)
  1536. }
  1537. // NewNull creates a node of type V_NULL
  1538. func NewNull() Node {
  1539. return Node{
  1540. p: nil,
  1541. t: types.V_NULL,
  1542. }
  1543. }
  1544. // NewBool creates a node of type bool:
  1545. // If v is true, returns V_TRUE node
  1546. // If v is false, returns V_FALSE node
  1547. func NewBool(v bool) Node {
  1548. var t = types.V_FALSE
  1549. if v {
  1550. t = types.V_TRUE
  1551. }
  1552. return Node{
  1553. p: nil,
  1554. t: t,
  1555. }
  1556. }
  1557. // NewNumber creates a json.Number node
  1558. // v must be a decimal string complying with RFC8259
  1559. func NewNumber(v string) Node {
  1560. return Node{
  1561. l: uint(len(v)),
  1562. p: rt.StrPtr(v),
  1563. t: _V_NUMBER,
  1564. }
  1565. }
  1566. func (node *Node) toNumber() json.Number {
  1567. return json.Number(rt.StrFrom(node.p, int64(node.l)))
  1568. }
  1569. func (self *Node) toString() string {
  1570. return rt.StrFrom(self.p, int64(self.l))
  1571. }
  1572. func (node *Node) toFloat64() (float64, error) {
  1573. ret, err := node.toNumber().Float64()
  1574. if err != nil {
  1575. return 0, err
  1576. }
  1577. return ret, nil
  1578. }
  1579. func (node *Node) toInt64() (int64, error) {
  1580. ret,err := node.toNumber().Int64()
  1581. if err != nil {
  1582. return 0, err
  1583. }
  1584. return ret, nil
  1585. }
  1586. func newBytes(v []byte) Node {
  1587. return Node{
  1588. t: types.V_STRING,
  1589. p: mem2ptr(v),
  1590. l: uint(len(v)),
  1591. }
  1592. }
  1593. // NewString creates a node of type V_STRING.
  1594. // v is considered to be a valid UTF-8 string,
  1595. // which means it won't be validated and unescaped.
  1596. // when the node is encoded to json, v will be escaped.
  1597. func NewString(v string) Node {
  1598. return Node{
  1599. t: types.V_STRING,
  1600. p: rt.StrPtr(v),
  1601. l: uint(len(v)),
  1602. }
  1603. }
  1604. // NewArray creates a node of type V_ARRAY,
  1605. // using v as its underlying children
  1606. func NewArray(v []Node) Node {
  1607. s := new(linkedNodes)
  1608. s.FromSlice(v)
  1609. return newArray(s)
  1610. }
  1611. const _Threshold_Index = 16
  1612. func newArray(v *linkedNodes) Node {
  1613. return Node{
  1614. t: types.V_ARRAY,
  1615. l: uint(v.Len()),
  1616. p: unsafe.Pointer(v),
  1617. }
  1618. }
  1619. func (self *Node) setArray(v *linkedNodes) {
  1620. self.t = types.V_ARRAY
  1621. self.l = uint(v.Len())
  1622. self.p = unsafe.Pointer(v)
  1623. }
  1624. // NewObject creates a node of type V_OBJECT,
  1625. // using v as its underlying children
  1626. func NewObject(v []Pair) Node {
  1627. s := new(linkedPairs)
  1628. s.FromSlice(v)
  1629. return newObject(s)
  1630. }
  1631. func newObject(v *linkedPairs) Node {
  1632. if v.size > _Threshold_Index {
  1633. v.BuildIndex()
  1634. }
  1635. return Node{
  1636. t: types.V_OBJECT,
  1637. l: uint(v.Len()),
  1638. p: unsafe.Pointer(v),
  1639. }
  1640. }
  1641. func (self *Node) setObject(v *linkedPairs) {
  1642. if v.size > _Threshold_Index {
  1643. v.BuildIndex()
  1644. }
  1645. self.t = types.V_OBJECT
  1646. self.l = uint(v.Len())
  1647. self.p = unsafe.Pointer(v)
  1648. }
  1649. func (self *Node) parseRaw(full bool) {
  1650. lock := self.lock()
  1651. defer self.unlock()
  1652. if !self.isRaw() {
  1653. return
  1654. }
  1655. raw := self.toString()
  1656. parser := NewParserObj(raw)
  1657. var e types.ParsingError
  1658. if full {
  1659. parser.noLazy = true
  1660. *self, e = parser.Parse()
  1661. } else if lock {
  1662. var n Node
  1663. parser.noLazy = true
  1664. parser.loadOnce = true
  1665. n, e = parser.Parse()
  1666. self.assign(n)
  1667. } else {
  1668. *self, e = parser.Parse()
  1669. }
  1670. if e != 0 {
  1671. *self = *newSyntaxError(parser.syntaxError(e))
  1672. }
  1673. }
  1674. func (self *Node) assign(n Node) {
  1675. self.l = n.l
  1676. self.p = n.p
  1677. atomic.StoreInt64(&self.t, n.t)
  1678. }