1 | #!/usr/bin/env python2
|
2 | """
|
3 | func_misc.py
|
4 | """
|
5 | from __future__ import print_function
|
6 |
|
7 | from _devbuild.gen.value_asdl import (value, value_e, value_t, value_str, Obj)
|
8 |
|
9 | from core import error
|
10 | from core import num
|
11 | from display import pp_value
|
12 | from display import ui
|
13 | from core import vm
|
14 | from data_lang import j8
|
15 | from frontend import match
|
16 | from frontend import typed_args
|
17 | from mycpp import mops
|
18 | from mycpp import mylib
|
19 | from mycpp.mylib import NewDict, iteritems, log, tagswitch
|
20 | from ysh import val_ops
|
21 |
|
22 | from typing import TYPE_CHECKING, Dict, List, Optional, cast
|
23 | if TYPE_CHECKING:
|
24 | from osh import glob_
|
25 | from osh import split
|
26 |
|
27 | _ = log
|
28 |
|
29 |
|
30 | class Object(vm._Callable):
|
31 | """OLD API to a value.Obj
|
32 |
|
33 | The order of params follows JavaScript's Object.create():
|
34 | var obj = Object(prototype, props)
|
35 | """
|
36 |
|
37 | def __init__(self):
|
38 | # type: () -> None
|
39 | pass
|
40 |
|
41 | def Call(self, rd):
|
42 | # type: (typed_args.Reader) -> value_t
|
43 |
|
44 | prototype = rd.PosValue()
|
45 | proto_loc = rd.BlamePos()
|
46 |
|
47 | props = rd.PosDict()
|
48 | rd.Done()
|
49 |
|
50 | chain = None # type: Optional[Obj]
|
51 | UP_prototype = prototype
|
52 | with tagswitch(prototype) as case:
|
53 | if case(value_e.Null):
|
54 | pass
|
55 | elif case(value_e.Obj):
|
56 | prototype = cast(Obj, UP_prototype)
|
57 | chain = prototype
|
58 | else:
|
59 | raise error.TypeErr(prototype, 'Object() expected Obj or Null',
|
60 | proto_loc)
|
61 |
|
62 | return Obj(chain, props)
|
63 |
|
64 |
|
65 | class Obj_call(vm._Callable):
|
66 | """New API to create a value.Obj
|
67 |
|
68 | It has a more natural order
|
69 | var obj = Obj(props, prototype)
|
70 |
|
71 | Until we have __call__, it's Obj:
|
72 | var obj = Obj.new(props, prototype)
|
73 | """
|
74 |
|
75 | def __init__(self):
|
76 | # type: () -> None
|
77 | pass
|
78 |
|
79 | def Call(self, rd):
|
80 | # type: (typed_args.Reader) -> value_t
|
81 |
|
82 | props = rd.PosDict()
|
83 |
|
84 | prototype = rd.OptionalValue()
|
85 | proto_loc = rd.BlamePos()
|
86 |
|
87 | rd.Done()
|
88 |
|
89 | chain = None # type: Optional[Obj]
|
90 |
|
91 | if prototype is not None:
|
92 | UP_prototype = prototype
|
93 | with tagswitch(prototype) as case:
|
94 | if case(value_e.Null): # Obj({}, null)
|
95 | pass
|
96 | elif case(value_e.Obj):
|
97 | prototype = cast(Obj, UP_prototype)
|
98 | chain = prototype
|
99 | else:
|
100 | raise error.TypeErr(prototype,
|
101 | 'Object() expected Obj or Null',
|
102 | proto_loc)
|
103 |
|
104 | return Obj(chain, props)
|
105 |
|
106 |
|
107 | class Prototype(vm._Callable):
|
108 | """Get an object's prototype."""
|
109 |
|
110 | def __init__(self):
|
111 | # type: () -> None
|
112 | pass
|
113 |
|
114 | def Call(self, rd):
|
115 | # type: (typed_args.Reader) -> value_t
|
116 | obj = rd.PosObj()
|
117 | rd.Done()
|
118 |
|
119 | if obj.prototype is None:
|
120 | return value.Null
|
121 |
|
122 | return obj.prototype
|
123 |
|
124 |
|
125 | class PropView(vm._Callable):
|
126 | """Get a Dict view of an object's properties."""
|
127 |
|
128 | def __init__(self):
|
129 | # type: () -> None
|
130 | pass
|
131 |
|
132 | def Call(self, rd):
|
133 | # type: (typed_args.Reader) -> value_t
|
134 | obj = rd.PosObj()
|
135 | rd.Done()
|
136 |
|
137 | return value.Dict(obj.d)
|
138 |
|
139 |
|
140 | class Len(vm._Callable):
|
141 |
|
142 | def __init__(self):
|
143 | # type: () -> None
|
144 | pass
|
145 |
|
146 | def Call(self, rd):
|
147 | # type: (typed_args.Reader) -> value_t
|
148 |
|
149 | x = rd.PosValue()
|
150 | rd.Done()
|
151 |
|
152 | UP_x = x
|
153 | with tagswitch(x) as case:
|
154 | if case(value_e.List):
|
155 | x = cast(value.List, UP_x)
|
156 | return num.ToBig(len(x.items))
|
157 |
|
158 | elif case(value_e.Dict):
|
159 | x = cast(value.Dict, UP_x)
|
160 | return num.ToBig(len(x.d))
|
161 |
|
162 | elif case(value_e.Str):
|
163 | x = cast(value.Str, UP_x)
|
164 | return num.ToBig(len(x.s))
|
165 |
|
166 | raise error.TypeErr(x, 'len() expected Str, List, or Dict',
|
167 | rd.BlamePos())
|
168 |
|
169 |
|
170 | class Type(vm._Callable):
|
171 |
|
172 | def __init__(self):
|
173 | # type: () -> None
|
174 | pass
|
175 |
|
176 | def Call(self, rd):
|
177 | # type: (typed_args.Reader) -> value_t
|
178 |
|
179 | val = rd.PosValue()
|
180 | rd.Done()
|
181 |
|
182 | # TODO: assert it's not Undef, Interrupted, Slice
|
183 | # Then return an Obj type
|
184 | #
|
185 | # It would be nice if they were immutable, if we didn't have to create
|
186 | # 23-24 dicts and 23-24 Obj on startup?
|
187 | return value.Str(ui.ValType(val))
|
188 |
|
189 |
|
190 | class Join(vm._Callable):
|
191 | """Both free function join() and List->join() method."""
|
192 |
|
193 | def __init__(self):
|
194 | # type: () -> None
|
195 | pass
|
196 |
|
197 | def Call(self, rd):
|
198 | # type: (typed_args.Reader) -> value_t
|
199 |
|
200 | li = rd.PosList()
|
201 | delim = rd.OptionalStr(default_='')
|
202 | rd.Done()
|
203 |
|
204 | strs = [] # type: List[str]
|
205 | for i, el in enumerate(li):
|
206 | strs.append(val_ops.Stringify(el, rd.LeftParenToken(), 'join() '))
|
207 |
|
208 | return value.Str(delim.join(strs))
|
209 |
|
210 |
|
211 | class Maybe(vm._Callable):
|
212 |
|
213 | def __init__(self):
|
214 | # type: () -> None
|
215 | pass
|
216 |
|
217 | def Call(self, rd):
|
218 | # type: (typed_args.Reader) -> value_t
|
219 |
|
220 | val = rd.PosValue()
|
221 | rd.Done()
|
222 |
|
223 | if val == value.Null:
|
224 | return value.List([])
|
225 |
|
226 | s = val_ops.ToStr(
|
227 | val, 'maybe() expected Str, but got %s' % value_str(val.tag()),
|
228 | rd.LeftParenToken())
|
229 | if len(s):
|
230 | return value.List([val]) # use val to avoid needlessly copy
|
231 |
|
232 | return value.List([])
|
233 |
|
234 |
|
235 | class Bool(vm._Callable):
|
236 |
|
237 | def __init__(self):
|
238 | # type: () -> None
|
239 | pass
|
240 |
|
241 | def Call(self, rd):
|
242 | # type: (typed_args.Reader) -> value_t
|
243 |
|
244 | val = rd.PosValue()
|
245 | rd.Done()
|
246 |
|
247 | return value.Bool(val_ops.ToBool(val))
|
248 |
|
249 |
|
250 | class Int(vm._Callable):
|
251 |
|
252 | def __init__(self):
|
253 | # type: () -> None
|
254 | pass
|
255 |
|
256 | def Call(self, rd):
|
257 | # type: (typed_args.Reader) -> value_t
|
258 |
|
259 | val = rd.PosValue()
|
260 | rd.Done()
|
261 |
|
262 | UP_val = val
|
263 | with tagswitch(val) as case:
|
264 | if case(value_e.Int):
|
265 | return val
|
266 |
|
267 | elif case(value_e.Bool):
|
268 | val = cast(value.Bool, UP_val)
|
269 | return value.Int(mops.FromBool(val.b))
|
270 |
|
271 | elif case(value_e.Float):
|
272 | val = cast(value.Float, UP_val)
|
273 | ok, big_int = mops.FromFloat(val.f)
|
274 | if ok:
|
275 | return value.Int(big_int)
|
276 | else:
|
277 | raise error.Expr(
|
278 | "Can't convert float %s to Int" %
|
279 | pp_value.FloatString(val.f), rd.BlamePos())
|
280 |
|
281 | elif case(value_e.Str):
|
282 | val = cast(value.Str, UP_val)
|
283 | if not match.LooksLikeYshInt(val.s):
|
284 | raise error.Expr("Can't convert %s to Int" % val.s,
|
285 | rd.BlamePos())
|
286 |
|
287 | s = val.s.replace('_', '')
|
288 | ok, big_int = mops.FromStr2(s)
|
289 | if not ok:
|
290 | raise error.Expr("Integer too big: %s" % val.s,
|
291 | rd.BlamePos())
|
292 |
|
293 | return value.Int(big_int)
|
294 |
|
295 | raise error.TypeErr(val, 'int() expected Bool, Int, Float, or Str',
|
296 | rd.BlamePos())
|
297 |
|
298 |
|
299 | class Float(vm._Callable):
|
300 |
|
301 | def __init__(self):
|
302 | # type: () -> None
|
303 | pass
|
304 |
|
305 | def Call(self, rd):
|
306 | # type: (typed_args.Reader) -> value_t
|
307 |
|
308 | val = rd.PosValue()
|
309 | rd.Done()
|
310 |
|
311 | UP_val = val
|
312 | with tagswitch(val) as case:
|
313 | if case(value_e.Int):
|
314 | val = cast(value.Int, UP_val)
|
315 | return value.Float(mops.ToFloat(val.i))
|
316 |
|
317 | elif case(value_e.Float):
|
318 | return val
|
319 |
|
320 | elif case(value_e.Str):
|
321 | val = cast(value.Str, UP_val)
|
322 | if not match.LooksLikeYshFloat(val.s):
|
323 | raise error.Expr('Cannot convert %s to Float' % val.s,
|
324 | rd.BlamePos())
|
325 |
|
326 | return value.Float(float(val.s))
|
327 |
|
328 | raise error.TypeErr(val, 'float() expected Int, Float, or Str',
|
329 | rd.BlamePos())
|
330 |
|
331 |
|
332 | class Str_(vm._Callable):
|
333 |
|
334 | def __init__(self):
|
335 | # type: () -> None
|
336 | pass
|
337 |
|
338 | def Call(self, rd):
|
339 | # type: (typed_args.Reader) -> value_t
|
340 |
|
341 | val = rd.PosValue()
|
342 | rd.Done()
|
343 |
|
344 | with tagswitch(val) as case:
|
345 | # Avoid extra allocation
|
346 | if case(value_e.Str):
|
347 | return val
|
348 | else:
|
349 | s = val_ops.Stringify(val, rd.LeftParenToken(), 'str() ')
|
350 | return value.Str(s)
|
351 |
|
352 |
|
353 | class List_(vm._Callable):
|
354 |
|
355 | def __init__(self):
|
356 | # type: () -> None
|
357 | pass
|
358 |
|
359 | def Call(self, rd):
|
360 | # type: (typed_args.Reader) -> value_t
|
361 |
|
362 | val = rd.PosValue()
|
363 | rd.Done()
|
364 |
|
365 | l = [] # type: List[value_t]
|
366 | it = None # type: val_ops.Iterator
|
367 | UP_val = val
|
368 | with tagswitch(val) as case:
|
369 | if case(value_e.List):
|
370 | val = cast(value.List, UP_val)
|
371 | it = val_ops.ListIterator(val)
|
372 |
|
373 | elif case(value_e.Dict):
|
374 | val = cast(value.Dict, UP_val)
|
375 | it = val_ops.DictIterator(val)
|
376 |
|
377 | elif case(value_e.Range):
|
378 | val = cast(value.Range, UP_val)
|
379 | it = val_ops.RangeIterator(val)
|
380 |
|
381 | else:
|
382 | raise error.TypeErr(val,
|
383 | 'list() expected Dict, List, or Range',
|
384 | rd.BlamePos())
|
385 |
|
386 | assert it is not None
|
387 | while True:
|
388 | first = it.FirstValue()
|
389 | if first is None:
|
390 | break
|
391 | l.append(first)
|
392 | it.Next()
|
393 |
|
394 | return value.List(l)
|
395 |
|
396 |
|
397 | class DictFunc(vm._Callable):
|
398 |
|
399 | def __init__(self):
|
400 | # type: () -> None
|
401 | pass
|
402 |
|
403 | def Call(self, rd):
|
404 | # type: (typed_args.Reader) -> value_t
|
405 |
|
406 | val = rd.PosValue()
|
407 | rd.Done()
|
408 |
|
409 | UP_val = val
|
410 | with tagswitch(val) as case:
|
411 | if case(value_e.Dict):
|
412 | val = cast(value.Dict, UP_val)
|
413 | d = NewDict() # type: Dict[str, value_t]
|
414 | for k, v in iteritems(val.d):
|
415 | d[k] = v
|
416 |
|
417 | return value.Dict(d)
|
418 |
|
419 | elif case(value_e.Obj):
|
420 | val = cast(Obj, UP_val)
|
421 | d = NewDict()
|
422 | for k, v in iteritems(val.d):
|
423 | d[k] = v
|
424 |
|
425 | return value.Dict(d)
|
426 |
|
427 | elif case(value_e.BashAssoc):
|
428 | val = cast(value.BashAssoc, UP_val)
|
429 | d = NewDict()
|
430 | for k, s in iteritems(val.d):
|
431 | d[k] = value.Str(s)
|
432 |
|
433 | return value.Dict(d)
|
434 |
|
435 | elif case(value_e.Frame):
|
436 | val = cast(value.Frame, UP_val)
|
437 | d = NewDict()
|
438 | for k, cell in iteritems(val.frame):
|
439 | d[k] = cell.val
|
440 |
|
441 | return value.Dict(d)
|
442 |
|
443 | raise error.TypeErr(val, 'dict() expected Dict, Obj, or BashAssoc',
|
444 | rd.BlamePos())
|
445 |
|
446 |
|
447 | class Runes(vm._Callable):
|
448 |
|
449 | def __init__(self):
|
450 | # type: () -> None
|
451 | pass
|
452 |
|
453 | def Call(self, rd):
|
454 | # type: (typed_args.Reader) -> value_t
|
455 | return value.Null
|
456 |
|
457 |
|
458 | class EncodeRunes(vm._Callable):
|
459 |
|
460 | def __init__(self):
|
461 | # type: () -> None
|
462 | pass
|
463 |
|
464 | def Call(self, rd):
|
465 | # type: (typed_args.Reader) -> value_t
|
466 | return value.Null
|
467 |
|
468 |
|
469 | class Bytes(vm._Callable):
|
470 |
|
471 | def __init__(self):
|
472 | # type: () -> None
|
473 | pass
|
474 |
|
475 | def Call(self, rd):
|
476 | # type: (typed_args.Reader) -> value_t
|
477 | return value.Null
|
478 |
|
479 |
|
480 | class EncodeBytes(vm._Callable):
|
481 |
|
482 | def __init__(self):
|
483 | # type: () -> None
|
484 | pass
|
485 |
|
486 | def Call(self, rd):
|
487 | # type: (typed_args.Reader) -> value_t
|
488 | return value.Null
|
489 |
|
490 |
|
491 | class Split(vm._Callable):
|
492 |
|
493 | def __init__(self, splitter):
|
494 | # type: (split.SplitContext) -> None
|
495 | vm._Callable.__init__(self)
|
496 | self.splitter = splitter
|
497 |
|
498 | def Call(self, rd):
|
499 | # type: (typed_args.Reader) -> value_t
|
500 | s = rd.PosStr()
|
501 |
|
502 | ifs = rd.OptionalStr()
|
503 |
|
504 | rd.Done()
|
505 |
|
506 | l = [
|
507 | value.Str(elem)
|
508 | for elem in self.splitter.SplitForWordEval(s, ifs=ifs)
|
509 | ] # type: List[value_t]
|
510 | return value.List(l)
|
511 |
|
512 |
|
513 | class FloatsEqual(vm._Callable):
|
514 |
|
515 | def __init__(self):
|
516 | # type: () -> None
|
517 | pass
|
518 |
|
519 | def Call(self, rd):
|
520 | # type: (typed_args.Reader) -> value_t
|
521 | left = rd.PosFloat()
|
522 | right = rd.PosFloat()
|
523 | rd.Done()
|
524 |
|
525 | return value.Bool(left == right)
|
526 |
|
527 |
|
528 | class Glob(vm._Callable):
|
529 |
|
530 | def __init__(self, globber):
|
531 | # type: (glob_.Globber) -> None
|
532 | vm._Callable.__init__(self)
|
533 | self.globber = globber
|
534 |
|
535 | def Call(self, rd):
|
536 | # type: (typed_args.Reader) -> value_t
|
537 | s = rd.PosStr()
|
538 | rd.Done()
|
539 |
|
540 | out = [] # type: List[str]
|
541 | self.globber._Glob(s, out)
|
542 |
|
543 | l = [value.Str(elem) for elem in out] # type: List[value_t]
|
544 | return value.List(l)
|
545 |
|
546 |
|
547 | # status code 4 is special, for encode/decode errors.
|
548 | _CODEC_STATUS = 4
|
549 |
|
550 |
|
551 | class ToJson8(vm._Callable):
|
552 |
|
553 | def __init__(self, is_j8):
|
554 | # type: (bool) -> None
|
555 | self.is_j8 = is_j8
|
556 |
|
557 | def Call(self, rd):
|
558 | # type: (typed_args.Reader) -> value_t
|
559 |
|
560 | val = rd.PosValue()
|
561 | space = mops.BigTruncate(rd.NamedInt('space', 0))
|
562 | type_errors = rd.NamedBool('type_errors', True)
|
563 | rd.Done()
|
564 |
|
565 | # Convert from external JS-like API to internal API.
|
566 | if space <= 0:
|
567 | indent = -1
|
568 | else:
|
569 | indent = space
|
570 |
|
571 | buf = mylib.BufWriter()
|
572 | try:
|
573 | if self.is_j8:
|
574 | j8.PrintMessage(val, buf, indent, type_errors)
|
575 | else:
|
576 | j8.PrintJsonMessage(val, buf, indent, type_errors)
|
577 | except error.Encode as e:
|
578 | raise error.Structured(_CODEC_STATUS, e.Message(),
|
579 | rd.LeftParenToken())
|
580 |
|
581 | return value.Str(buf.getvalue())
|
582 |
|
583 |
|
584 | class FromJson8(vm._Callable):
|
585 |
|
586 | def __init__(self, is_j8):
|
587 | # type: (bool) -> None
|
588 | self.is_j8 = is_j8
|
589 |
|
590 | def Call(self, rd):
|
591 | # type: (typed_args.Reader) -> value_t
|
592 |
|
593 | s = rd.PosStr()
|
594 | rd.Done()
|
595 |
|
596 | p = j8.Parser(s, self.is_j8)
|
597 | try:
|
598 | val = p.ParseValue()
|
599 | except error.Decode as e:
|
600 | # Right now I'm not exposing the original string, because that
|
601 | # could lead to a memory leak in the _error Dict.
|
602 | # The message quotes part of the string, and we could improve
|
603 | # that. We could have a substring with context.
|
604 | props = {
|
605 | 'start_pos': num.ToBig(e.start_pos),
|
606 | 'end_pos': num.ToBig(e.end_pos),
|
607 | } # type: Dict[str, value_t]
|
608 | raise error.Structured(_CODEC_STATUS, e.Message(),
|
609 | rd.LeftParenToken(), props)
|
610 |
|
611 | return val
|