o z!h@sddlZddlZddlmZgZedZdZdZdZ ddd Z d d Z d d Z ddZ ddZddZedddddZdddZdS)N)profilez \W|^(?=\d)))/z per )%percent)*z times )riiiii<i(iiilixiiPiiiDFcCs.|rtD] \}}||t|}qtd|S)z/Create a valid Python name out of *method_name*_)UNIT_NAME_TO_FUNC_REPLACEMENTSreplacestrMETHOD_NAME_SCRUBBERsub) method_name convert_units replace_from replace_torE/var/www/html/gps/gps/lib/python3.10/site-packages/fitdecode/utils.pyscrub_method_names  rcCsRztj|WStyYnwtjD] }||jkr |Sqtd|d)z Get a :class:`fitdecode.MessageType` from ``profile``, by its name (`str`) or its global number (`int`). Raise `ValueError` if type was not found. message type " " not found)r MESSAGE_TYPESKeyErrorvaluesname ValueError)mesg_name_or_num mesg_typerrr get_mesg_type!s   rcCs4tjD] }||jkr|jSqtd|d)z Get the global number of a message as defined in ``profile``, by its name Raise `ValueError` if type was not found. rr)rrrrmesg_numr) mesg_namerrrr get_mesg_num5s   r!cCsBt|}|jD]}||j|jfvr|Sqtd|d|d)z Get the :class:`fitdecode.types.Field` object of a particular field from a particular message. Raise `ValueError` if message or field was not found. field "" not found in message "")rfieldsdef_numrr)rfield_name_or_numrfieldrrrget_mesg_fieldBs r)cCs>t|}|jD] }|j|kr|jSqtd|d|d)z Get the definition number of a particular field from a particular message. Raise `ValueError` if message or field was not found. r"r#r$)rr%rr&r)r field_namerr(rrrget_mesg_field_numSs   r+cCs,ztj|WStytd|dw)zs Get :class:`fitdecode.FieldType` by name from ``profile``. Raise `ValueError` if type was not found. z field type "r)r FIELD_TYPErr)r*rrrget_field_typebs   r-)crcstartendcCs|st|}||kr Jt|||D]0}t|d@}|d?d@}||At|d@A}t|d@}|d?d@}||At|d?d@A}q|S)z~ Compute the CRC as per FIT definition, of *byteslike* object, from offset *start* (included) to *end* (excluded) ri)len memoryview CRC_TABLE) bytesliker.r/r0bytetmprrr compute_crcns    r9Q?cs|dust|trt|trJ|sdSgd}fdd} z:||dkr(dn||}|dkr4|WS|s?s;|WS|WS|dksEJ||t|7}||krX|WSWntygt|Ynwq)a Read from *istream* and do not return until *size* `bytes` have been read unless EOF has been reached. Return all the data read so far. The length of the returned data may still be less than *size* in case EOF has been reached. *nonblocking_reads_delay* specifies the number of seconds (float) to wait before trying to read from *istream* again in case `BlockingIOError` has been raised during previous call. Nrcs tdtr dnd}|S)Nr) isinstancer join)glueoutputrr_joins zblocking_read.._joinTr:) r>intboolreadappendr3BlockingIOErrortimesleep)istreamsizenonblocking_reads_delaylen_readrCchunkrrAr blocking_reads2      rP)F)r:r;)rerIr<r__all__compiler r CRC_STARTr5rrr!r)r+r-r9rPrrrrs       #