�
J�g� � �4 � d dl mZ d dlmZ d dlmZ d dlZd dlZd dlZd dl m
Z
d dl m Z d dl m Z d dl m
Z
d dlZd d lmZ d
d lmZ ej e� � Z ej d � � � ej � � � � d dlZd dlZd dlZ ej d ej ej d
d d d d � � � � Z ej d
e� � \ Z Z Z!Z"e d k rdZ n# e#e$f$ r dZ Y nw xY wdd�d-d�Z%e d.d/d �� � Z&d0d1d �Z'd2d!�Z(d3d4d&�Z) d5d6d)�Z*d7d,�Z+dS )8� )� annotations)�Iterable)�contextmanagerN)�Iterator)�Optional)�TextIO)�Union)�url� )� sqla_compat�alembic�HHHHF��quiet�streamr �text�Union[str, bytes]r �bool�return�Nonec � � |rd S t | dd� � pd}|D ]j}t |t � � s|� |d� � }|� |� � } | � |� � �Y# t $ r Y d S w xY wd S )N�encoding�ascii�replace)�getattr�
isinstance�bytes�encode�decode�write�OSError)r r r r �ts �f/home/asafur/pinokio/api/open-webui.git/app/env/lib/python3.11/site-packages/alembic/util/messaging.py�write_outstreamr$ % s� � �
� ����v�z�7�3�3�>�w�H�
�
�
���!�U�#�#� .�����9�-�-�A�
�H�H�X� � �� � �L�L��O�O�O�O��� � � �
�E�E�E� ����
�
s � A3�3
B�B�
status_msg�str�newline�Iterator[None]c # �� K � t | dz |d|�� � d V � |s t t j d� � d S d S # |st t j d� � � xY w)Nz ...T)�flushr z done
z FAILED
)�msgr$ �sys�stdout)r% r' r s r# �statusr. 8 s� � � � � �
�V��W�D��>�>�>�>�4�
���� � 4� �C�J�
� 3� 3� 3� 3� 3� 4� 4�� �� 6� �C�J� � 5� 5� 5�
���s �> � A �messagec � � t � | � � t d| � �|�� � t j d� � d S )NzFAILED: r �����)�log�errorr+ r, �exit)r/ r s r# �errr5 H sA � ��I�I�g����� �7� � �E�*�*�*�*��H�R�L�L�L�L�L� � input_urlc �V � t j | � � }t j |d�� � S )NT)�
hide_password)r
�make_urlr �url_render_as_string)r7 �us r# �obfuscate_url_pwr= N s' � � � �Y� � �A� � +�A�T� B� B� B�Br6 � r+ �
stacklevel�intc �> � t j | t |�� � d S )N)r? )�warnings�warn� UserWarning)r+ r? s r# rC rC S s � � �M�#�{�z�:�:�:�:�:�:r6 Tr* c �� � |rd S t �7t t j | � � |rt t j d� � nd}t j | t ||�� � }t
|� � dk r(|dd� D ] }t t j |d� � � t t j |d |rdnd� � |r t j � � � d S d S )N�
z )�initial_indent�subsequent_indentr r r1 � )� TERMWIDTHr$ r, r- �textwrap�wrap�lenr* )r+ r' r* r �indent�lines�lines r# r+ r+ W s� � �
� �������
�C�(�(�(� � .� �C�J�� -� -� -�� ���
� � �!� $�
�
�
�� �u�:�:��>�>� �a��d� �
8�
8�� ��
�D�$�7�7�7�7���
�E�"�I��0G���R�I�I�I� � � �
��������� r6 �value�#Optional[Union[str, Iterable[str]]]c � � | �dS t | t � � r| S t | t � � rd� | � � S t d| z � � �)NrI z, z!Don't know how to comma-format %r)r r& r �join�
ValueError)rQ s r# �format_as_commarV q s] � � �}��r� �E�3� � � F�� � �E�8� $� $� F��y�y�� � � ��<�u�D�E�E�Er6 )r r r r r r r r )FF)r% r& r' r r r r r( )F)r/ r& r r r r )r7 r& r r& )r> )r+ r& r? r@ r r )TFF)
r+ r& r' r r* r r r r r )rQ rR r r& ),�
__future__r �collections.abcr �
contextlibr �loggingr, rK �typingr r r r rB �sqlalchemy.enginer
rI r � getLogger�__name__r2 �
addHandler� NullHandler�fcntl�termios�struct�ioctl�
TIOCGWINSZ�pack�unpack�_hrJ �_hp�_wp� ImportErrorr! r$ r. r5 r= rC r+ rV � r6 r# �<module>rm s� �� "� "� "� "� "� "� $� $� $� $� $� $� %� %� %� %� %� %� ����
�
�
�
� ���� � � � � � � � � � � � � � � � � � � � � � � � � ���� !� !� !� !� !� !� � � � � � ��g���!�!�� �� �)� � � '� '�(;��(;�(=�(=� >� >� >�
��L�L�L��N�N�N��M�M�M� �E�K��7�-�{�v�{�6�1�a��A�/N�/N� O� O�E� +�f�m�F�E� :� :��B� �3���A�~�~�� ����W� � � � ��I�I�I�����
=B�� � � � � �& �:?� 4� 4� 4� 4� � � 4� � � � � � C� C� C� C�
;� ;� ;� ;� ;�
HM�� � � � �4F� F� F� F� F� Fs �AC � C(�'C(