HEX

File: //usr/lib/python3/dist-packages/boto/sdb/db/__pycache__/sequence.cpython-310.pyc
o

ckF[ �@sbddlmZddlmZGdd�de�Zddd�Zddd	�Zddd�Zed
�Z	Gdd�de�Z
dS)�)�SDBResponseError)�sixc@s0eZdZdZdZd
dd�Zddd�Zdd	�ZdS)�SequenceGeneratora�Generic Sequence Generator object, this takes a single
    string as the "sequence" and uses that to figure out
    what the next value in a string is. For example
    if you give "ABC" and pass in "A" it will give you "B",
    and if you give it "C" it will give you "AA".

    If you set "rollover" to True in the above example, passing
    in "C" would give you "A" again.

    The Sequence string can be a string or any iterable
    that has the "index" function and is indexable.
    FcCs:||_t|d�|_||_|d|_d|jj|f|_dS)a�Create a new SequenceGenerator using the sequence_string
        as how to generate the next item.

        :param sequence_string: The string or list that explains
        how to generate the next item in the sequence
        :type sequence_string: str,iterable

        :param rollover: Rollover instead of incrementing when
        we hit the end of the sequence
        :type rollover: bool
        r���z%s('%s')N)�sequence_string�len�sequence_length�rollover�	last_item�	__class__�__name__)�selfrr	�r�6/usr/lib/python3/dist-packages/boto/sdb/db/sequence.py�__init__(s

zSequenceGenerator.__init__NcCs�|dust|�|jkr|jdS||jd�}|js3||jkr3d||d|j��|�|�f}|Sd|d|j�|�|�f}|S)z"Get the next value in the sequenceNrz%s%s)rrrr	r
�_inc)r
�val�last�
last_valuerrr�__call__:s
"�zSequenceGenerator.__call__cCs2t|�|jks	J�|j|j�|�dt|j�S)zIncrement a single value�)rrr�index�r
rrrrrHs zSequenceGenerator._inc)F�N)r�
__module__�__qualname__�__doc__rrrrrrrrs

rNcCs|durdS|dS)Nrrr��cv�lvrrr�increment_by_oneQ�r cCs|durdS|dS)Nr�rrrrr�doubleVr!r#rcCs |durd}|durd}||S)z@The fibonacci sequence, this incrementer uses the
    last valueNrrrrrrr�fib[s
r$�ABCDEFGHIJKLMNOPQRSTUVWXYZc@sdeZdZdZddedfdd�Zdd�Zdd�Zeee�Z	d	d
�Z
dd�Zee�Zd
d�Z
dd�ZdS)�Sequencez�A simple Sequence using the new SDB "Consistent" features
    Based largly off of the "Counter" example from mitch garnaat:
    http://bitbucket.org/mitch/stupidbototricks/src/tip/counter.pyNcCs�d|_d|_d|_||_||_|dur||�}|jdur'ddl}t|���|_t|d��|_	d|_
t|tj
�rAddlm}||�}||_|jsL||_dSdS)anCreate a new Sequence, using an optional function to
        increment to the next number, by default we just increment by one.
        Every parameter here is optional, if you don't specify any options
        then you'll get a new SequenceGenerator with a random ID stored in the
        default domain that increments by one and uses the default botoweb
        environment

        :param id: Optional ID (name) for this counter
        :type id: str

        :param domain_name: Optional domain name to use, by default we get this out of the
            environment configuration
        :type domain_name:str

        :param fnc: Optional function to use for the incrementation, by default we just increment by one
            There are several functions defined in this module.
            Your function must accept "None" to get the initial value
        :type fnc: function, str

        :param init_val: Initial value, by default this is the first element in your sequence,
            but you can pass in any value, even a string if you pass in a function that uses
            strings instead of ints to increment
        Nr)�
find_class)�_db�_valuer�domain_name�id�uuid�str�uuid4�type�	item_type�	timestamp�
isinstancer�string_types�
boto.utilsr'�fncr)r
r+r*r5�init_valr,r'rrrrls&

�zSequence.__init__c
Cs�ddl}|��}g}i}||d<|jdur!|j|d<dt|j�g}||d<z|jj|j||d�|d|_WdStyM}z
|jdkrHt	d���d}~ww)	z
Set the valuerNr1r�
current_value)�expected_valuei�zSequence out of sync)
�timer)r-�db�put_attributesr+r1r�status�
ValueError)r
rr9�nowr8�new_val�errr�set�s$


��zSequence.setcCsj|jj|jdd�}|r2d|vr|d|_d|vr |�|d�|_d|vr2|ddur2|�|d�|_|jS)z
Get the valueT)�consistent_readr1r7rN)r:�get_attributesr+r1r0r)rrrrr�get�s
zSequence.getcCs&d|jj|j|j|jj|jj|jfS)Nz%s('%s', '%s', '%s.%s', '%s'))rrr+r*r5rr�r
rrr�__repr__�s�zSequence.__repr__c
Cs�|jsKddl}|��}|js|j�dd|j�ddd��|_z|�|j�|_W|jStyJ}z|jdkr=|�	|j�|_n�WYd}~|jSd}~ww|jS)zConnect to our domainrN�DB�sequence_db�db_name�defaulti�)
r(�boto�connect_sdbr*�configrD�
get_domainrr<�
create_domain)r
rK�sdbr@rrr�_connect�s"�

���zSequence._connectcCs|�|j|j�|_|jSr)r5rrrErrr�next�sz
Sequence.nextcCs|j�|j�dS)zRemove this sequenceN)r:�delete_attributesr+rErrr�delete�szSequence.delete)rrrrr rrArD�propertyrrFrQr:rRrTrrrrr&gs0
	r&)NN)rr)�boto.exceptionr�boto.compatr�objectrr r#r$�increment_stringr&rrrr�<module>s
8