Pi1B , d Z ddlmZ ddlmZ ddlmZmZmZm Z m
Z
m Z m Z m
Z
mZmZmZmZ ddlmZ ddlmZ ddlmZmZ ddlmZ dd lm Z m Z m Z m Z ed
e Z!er
dd lm"Z"m#Z#m$Z$ d
dgZ% G d d
e Z&dZ'dZ(dZ)dZ*dZ+ G d de& Z,dS )zr
Turtle RDF graph serializer for RDFLib.
See for syntax specification.
) annotations) defaultdict) IO
TYPE_CHECKINGAny DefaultDictDictListMappingOptionalSequenceTupleTypeVarUnion)Error)Graph)RDFRDFS)
Serializer)BNodeLiteralNodeURIRef_StrT)bound)_PredicateType _SubjectType _TripleTypeRecursiveSerializerTurtleSerializerc e Zd ZU dZej gZej ej gZ
dZ dZ dZ
ded< d, fd Zd-dZd.dZd.dZd/dZd0dZd1dZd0d Zd2d Zd3d!Zd4d"Zd5d6d&Zd7d(Zd8d+Z xZ S )9r z%Base class for recursive serializers.
z zTuple[Any, ...]roundtrip_prefixesstorer c t t | | d | _ | d S N)superr __init__streamresetselfr% __class__s u/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/rdflib/plugins/serializers/turtle.pyr) z RecursiveSerializer.__init__/ s:
!4((11%888+/
prefixstrurir returnNonec || j v r4| j | |k r#t d|d|d| j | || j |< d S )Nz$Trying to override namespace prefix z => z , but it's already bound to )
namespaces Exception)r- r1 r3 s r/ addNamespacez RecursiveSerializer.addNamespace4 sf T_ $ $ )@C)G)G)66333 7 79
#& r0 subjectr boolc | | sB|| j vs9|| j v r | j dk s%t |t
r| j | j k rdS dS )z4Check to see if the subject should be serialized yet FT)isDone _subjects
_topLevelsdepth
isinstancer maxDepthr- r: s r/ checkSubjectz RecursiveSerializer.checkSubject< sh [[
!
! t~--DO++$*q..7F++ 3A15t}1L1L5tr0 c || j v S )z$Return true if subject is serialized _serializedrD s r/ r> zRecursiveSerializer.isDoneG s $***r0 List[_SubjectType]c i g } j D ]q}t j t j | }| | | |D ]}d j |< d|< r fd j D }| | d |D |S )NTc ^ g | ])}|vt |t j | |f*S r# )rB r _references).0r: seenr- s r/
z5RecursiveSerializer.orderSubjects..Y sG
d""
'
')9')BG L"""r0 c g | ]\ }}}| S r# r# )rM isbnoderefsr: s r/ rO z5RecursiveSerializer.orderSubjects..` s LLL%=gtWLLLr0 )
topClasseslistr% subjectsr typesortextendr@ r? )r- rU classURImembersmember
recursablerN s ` @r/
orderSubjectsz!RecursiveSerializer.orderSubjectsK s )+') $ $H4:..sxBBCCG LLNNN OOG $ $ $!
$
$*.' #V
$
>
LLLLLMMMr0 c j | j d D ]}| | d S )NNNN)r% triplespreprocessTriple)r- triples r/
preprocessz RecursiveSerializer.preprocessd sC j(();<< * *F ! !& ) ) ) ) * *r0 spor c P |\ }}}| j |xx dz
cc< d| j |< d S )Nr= T)rL r? )r- rd spos r/ ra z$RecursiveSerializer.preprocessTripleh s> 1a q qr0 c d| _ i | _ i | _ t t | _ i | _ i | _ i | _ | j rt | j d r@| j D ]$\ }}|| j v r| || %d S | j D ] \ }}| || d S d S )Nr __iter__)
rA listsr7 r intrL rH r? r@ r$ hasattrr% r9 )r- r1 nss r/ r+ zRecursiveSerializer.resetm s
')
-/3>s3C3C573546 " 2t.
;;
2"&*"7"7"9"9 6 6JFB !888 ))&"5556 6 #'*"7"7"9"9 2 2JFB%%fb1111 2 2 2 2r0 #Mapping[_PredicateType, List[Node]]c i }| j |ddf D ]6\ }}}| |g }| | |||< 7|S )zb
Build a hash key by predicate to a list of objects for the given
subject
N)r% r` getappend)r- r:
propertiesrf rg rh oLists r/ buildPredicateHashz&RecursiveSerializer.buildPredicateHash sh 8:
z))7D$*?@@ " "GAq! NN1b))E LLOOO !JqMMr0 rs List[_PredicateType]c r | D ]\ }}| g }i }| j D ]$}||v r ||vr| | d||< %t | }| |D ] }||vr| | d||< !|S )zzTake a hash from predicate uris to lists of values.
Sort the lists of values. Return a sorted list of properties.T)itemsrW predicateOrderrr rT keys)r- rs propobjectspropListrN propss r/ sortPropertiesz"RecursiveSerializer.sortProperties s ( - - / / MD' LLNNNN *,+-' " "D
""T)9)9%%% !T
Z__&&''
" "D4 %%% !T
r0 c d| j |< dS )zMark a subject as done.TNrG rD s r/ subjectDonez RecursiveSerializer.subjectDone s $(!!!r0 r modifierrl c & | j |z | j z S )z-Returns indent string multiplied by the depth)rA indentString)r- r s r/ indentzRecursiveSerializer.indent s
X%):::r0 textc l | j | | j d dS )z Write text in given encoding.replaceN)r* writeencodeencoding)r- r s r/ r zRecursiveSerializer.write s0
$++dmY??@@@@@r0 r Union[_StrT, URIRef]c | j }|i| | rTd| |d vr r] rc ra r+ ru r r r r r
__classcell__r. s @r/ r r & s //* Jh
+NHL*,,,,,
& & & & + + + + 2* * * *! ! ! !
2 2 2 2& 4) ) ) ); ; ; ; ;A A A A
r0 r= Fc e Zd ZdZdZdZd; fd Zd< fd Zd= fd Z d>d?dZ d@ fd Z
dAdBd"Z d=d#Z d=d$Z
dCd'ZdCd(ZdCd)ZdDdEd/ZdDdFd0ZdGd1ZdDdFd2ZdHd4ZdId5ZdDdJd6ZdDdKd7ZdLd:Z xZS )Mr z Turtle RDF graph serializer.turtlez r% r c i | _ t t | | t j di| _ | d | _ t | _
d S )Na) _ns_rewriter( r r) r rV keywordsr+ r* _SPACIOUS_OUTPUT _spaciousr, s r/ r) zTurtleSerializer.__init__ sV +-
%%..u555*-(C
)r0 r1 r2 namespacer r4 c P |dk r |d dk s | j || |k rJ|| j vr&d|z }|| j v rd|z }|| j v || j |< | j || }t t | || |S )Nr r _rg )r7 rq r r( r r9 )r- r1 r rg r. s r/ r9 z TurtleSerializer.addNamespace s
RKKF1I , , 1D1D I2
2
2 2 T ---&L4?**aA 4?**+, (%))&&99F
%%2269EEE
r0 r5 c t t | i | _ d| _ i | _ d S )NF)r( r r+ _shortNames_startedr )r- r. s r/ r+ zTurtleSerializer.reset s=
%%++----/
r0 Nr* IO[bytes]r
Optional[str]r spaciousOptional[bool]kwargsr c 4 | || _ ||| _ n | j j | j j | _ ||| _ | | }| d}|D ]H}| | r|rd}| | r|s|
d I| |
d d d | _ d S )NTF
zlatin-1)
r+ r* r r% r rc r]
startDocumentr> statementr endDocumentr ) r- r* r r r r
subjects_list firstTimer: s r/ serializezTurtleSerializer.serialize s
DII
Z_
(
DI %DN **,,
$ ! !G{{7##
" ! ~~g&&
!y
!
4 T[[++,,, r0 rb r c t t | | t | D ]\ }}|t k r{|| j v r| j jt |t rU| | j r;d|
| j d vr d|
| j d vr| ||t k t |t r(|j
r!| |j
t |d }t |t r| j |xx dz
cc< d S d S )Nr r r )
gen_prefixr= )r( r ra enumerateVERBr r rB r r r getQNamer datatype_GEN_QNAME_FOR_DTr rL )r- rb inoderg r. s r/ ra z!TurtleSerializer.preprocessTriple s`
%%66v>>> (( K KGAtDyy4=(( I)"400 * 22 * 4<< 2#>#>>>4<< 2#>#>>> MM$AIM 7 7 7$((
KT]
K
dm8I
JJJ 1I a % Q 1 $ % %r0 Tr3 r r r; c t |t sd S d } | j || }n:# t $ r- | j j | }|||df}nY d S Y nw xY w|\ }}}| dd dd }| d rd S | || }|d|S ) N)generater (z\()z\).:) rB r r%
compute_qnamer8 r1 r endswithr9 )r- r3 r partspfxr1 r locals r/ r zTurtleSerializer.getQName7 s #v&& 4
J,,S:,FFEE *"))#..C c2 tt $) 5
dE**224?? >># 4""6955 &&%%((s 8 1A/.A/c d| _ t | j }| j r2| | d| j z z |D ]6\ }}| | d|d|dz 7|r | j r| d d S d S d S )NTz
@base <%s> .
z@prefix z: .
r )r sortedr7 rx r r r r )r- ns_listr1 r3 s r/ r z TurtleSerializer.startDocumentU s
..0011 9 E JJt{{}}'7$)'CC D D D" O OKFC JJt{{}}}'MM N N N N t~ JJt r0 c B | j r| d d S d S )Nr )r r )r- s r/ r z TurtleSerializer.endDocument` s. > JJt r0 r: r c | | | | p| | S r' )r s_squared s_defaultrD s r/ r zTurtleSerializer.statementd s9 !!!~~g&&A$..*A*AAr0 c | d| z | |t | | | d dS )Nr .T)r r pathSUBJECT
predicateListrD s r/ r zTurtleSerializer.s_defaulth s`
4$++--'((( '7### 7###
4tr0 c | j | dk st |t sdS | d| z dz | | | d dS )Nr Fr z[]r T)rL rB r r r r rD s r/ r zTurtleSerializer.s_squaredo sx W % ) )*We2L2L )5
4$++--'$./// 7###
4tr0 Fr positionrl newlinec | ||| s*| ||| st d|d d S d S )NzCannot serialize node '') p_squared p_defaultr r- r r r s r/ r zTurtleSerializer.pathw se NN47 3 3 @~~dHg66 @ %>?? ? @ @ @ @r0 c |t k r|s| d | | || dS )N T)r r r r s r/ r zTurtleSerializer.p_default~ sF w w JJsOOO
4::dH--...tr0 c T |t j k rdS |t u r| j v r
j | S t |t
r| d fd S | } ||t k p| S )Nz()Tc : | t S r' )r r )dtr- s r/ z(TurtleSerializer.label.. s $-- | |t | d S r' )r r )r- r r s r/ r zTurtleSerializer.verb s $g&&&&&r0 r| Sequence[Node]c t t | }|dk rd S |dk rdpd}| xj |z
c_ | |d t |dd D ]J}| d| d z | |t d K| xj |z c_ d S )Nr r= z,
Tr )r rA r r r r )r- r| countdepthmodobjs r/ r zTurtleSerializer.objectList s G A:: FQJ%A*
h
'!*f%%%122; 1 1C JJut{{1~~- . . . IIc64I 0 0 0 0
h
r0 r )r1 r2 r r r4 r2 r r_ ) r* r r r r r r r r r r4 r5 )rb r r4 r5 )T)r3 r r r; r4 r r )F)r r r rl r r; r4 r5 )r r r rl r r; r4 r; )r r r rl r4 r2 )r r r4 r; )r r r4 r5 )r: r r r; r4 r5 )r r r r; r4 r5 )r| r r4 r5 )r r r r
short_namer r) r9 r+ r ra r r r r r r r r r r r r r r r r r s @r/ r r s$ &&JL* * * * * * 0 #"&#' $ $ $ $ $L% % % % % %2 ) ) ) ) )< B B B B @ @ @ @ @
F
F
F
F B 0 0 0 0
3
3
3
3
3' ' ' ' '
r0 N)-r
__future__r collectionsr typingr r r r r r
r r r
r r r rdflib.exceptionsr rdflib.graphr rdflib.namespacer r rdflib.serializerr rdflib.termr r r r r2 r r r r __all__r r r r r r r r# r0 r/ r s
# " " " " " # # # # # #
$ # # # # # & & & & & & & & ( ( ( ( ( ( 4 4 4 4 4 4 4 4 4 4 4 4s### GFFFFFFFFFF "4
5Y Y Y Y Y* Y Y Yx
\ \ \ \ \ * \ \ \ \ \ r0