opensocketexception.py 0000644 00000001535 15173153063 0011217 0 ustar 00 # Exposing rich exception information from callbacks example
import pycurl, random, socket
class ConnectionRejected(Exception):
pass
def opensocket(curl, purpose, curl_address):
if random.random() < 0.5:
curl.exception = ConnectionRejected('Rejecting connection attempt in opensocket callback')
return pycurl.SOCKET_BAD
family, socktype, protocol, address = curl_address
s = socket.socket(family, socktype, protocol)
s.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1)
return s
c = pycurl.Curl()
c.setopt(c.URL, 'http://pycurl.io')
c.exception = None
c.setopt(c.OPENSOCKETFUNCTION,
lambda purpose, address: opensocket(c, purpose, address))
try:
c.perform()
except pycurl.error as e:
if e.args[0] == pycurl.E_COULDNT_CONNECT and c.exception:
print(c.exception)
else:
print(e)
__pycache__/ssh_keyfunction.cpython-312.pyc 0000644 00000001644 15173153064 0014704 0 ustar 00 �
���g. � �8 � d dl Z dZ e j � Zej ej
e� ej ej d� d� Zej ej d� ej ej e� ej � y)� Nzsftp://web.sourceforge.netTc �" � t j S )N)�c� KHSTAT_FINE)� known_key� found_key�matchs �c/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/ssh_keyfunction.py� keyfunctionr
s � � �=�=�� z .known_hosts) �pycurl� sftp_server�Curlr �setopt�URL�VERBOSEr
�SSH_KNOWNHOSTS�SSH_KEYFUNCTION�perform� r r �<module>r sv ��
�*� ��F�K�K�M�� ������ � � ������D� �� ���� � �>� *� ���� � �K� (� � � � r __pycache__/multi-socket_action-select.cpython-312.pyc 0000644 00000011645 15173153064 0016725 0 ustar 00 �
���g? � � � d dl Z d dlZd dlZd dlmZ ee j � dkD re j d ZndZg g dddddd�Zd� Z d� Z
d� Z ej � Z
e
j ej e � e
j ej e � ej" � Zej ej& e� ej ej( d � ej ej* d � ej ej, d� e� Zej ej0 e� e
j3 e� e
j5 ej6 d � Z ed
d k( rned Z e � e d � � e
e � �!e
j? e� ejA � e
jA � ed
� e d� �ed
r e!d eejE � � z � y e!ded ed fz � y)� N)�BytesIO� zhttps://www.python.org)�rlist�wlist�running�timeout�result�code�msgc �� � | t j k( s| t j k( rt d j |� y | t j
k( s| t j k( rt d j |� y | t j k( rH|t d v rt d j |� |t d v rt d j |� y y t d| z � �)Nr r zUnknown value of what: %s) �pycurl�POLL_IN�
POLL_INOUT�state�append�POLL_OUT� POLL_REMOVE�remove� Exception)�what�sock_fd�multi�socketps �n/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/multi-socket_action-select.py� socket_fnr O s� � � �v�~�~� ���):�):�!:�
�g�� � �g�&�
�� � � �D�F�,=�,=�$=�
�g�� � �g�&�
��#�#� #� �e�G�n� $� �'�N� !� !�'� *� �e�G�n� $� �'�N� !� !�'� *� %� �3�d�:�;�;� c � � t j t d t d t t d � t t d � z | � \ }}}t |� dk( rDt |� dk( r6t |� dk( r(t j t j d� \ }}n�|D ]) }t j |t j � \ }}�+ |D ]) }t j |t j � \ }}�+ |D ]) }t j |t j � \ }}�+ t d ��t d k7 r�t j � \ }}} |dk( sJ �t |� dk( rt | � dk( s t |� dk( rt | � dk( sJ �|r dt d< | r dt d< | d \ }
t d < t d
< t d< y ) Nr r r r r Tr Fr
r ) �selectr �set�lenr �
socket_actionr
�SOCKET_TIMEOUT�
CSELECT_IN� CSELECT_OUT� CSELECT_ERR� info_read) r �rready�wready�xready�_r r �qmsg� successes�failures�_easys r �workr/ \ s� � � #�]�]�
�g���g���E�'�N�(;�c�%��.�>Q�(Q�SZ� \��F�F�F� �6�{�a��C��K�1� ,��V���1A�
�(�(��)>�)>��B�
��7� �G� �,�,�W�f�6G�6G�H�J�A�w� � �G� �,�,�W�f�6H�6H�I�J�A�w� � �G� �,�,�W�f�6H�6H�I�J�A�w� �
�Y��#��5��3C�(C� %*�O�O�$5�!��i�� �q�y��y� �9�~��"�s�8�}��'9� � �N�a� �C��M�Q�$6� 7� 7� � "�E�(�O� � #�E�(�O� 2:�!�� .�E�5��=�%��,� �E�)�r c �: � | dk r
d t d< y | dz t d< y )Nr r g @�@)r )�
timeout_mss r �timer_fnr2 � s$ � ��A�~� ��i��%��.��i�r � r r z0Need to poll for I/O but the timeout is not set!r z!Script finished without a result!z'Transfer successful, retrieved %d bytesz Transfer failed with code %d: %sr
r )#�sysr r
�ior r �argv�urlr r r/ r2 � CurlMultir �setopt�M_SOCKETFUNCTION�M_TIMERFUNCTION�Curl�easy�URL�CONNECTTIMEOUT�LOW_SPEED_TIME�LOW_SPEED_LIMIT�_io� WRITEDATA�
add_handler! r" �handlesr r �
remove_handle�close�print�getvalue� r r �<module>rK s� ��v �
� ��s�x�x�=�1��
�(�(�1�+�C�
"�C� �
���� � � �� <�4 �l/� ������ � � �V�
$�
$�i� 0� � � �V�
#�
#�X� .��v�{�{�}�� � � �F�J�J�� � � � �F� !� !�1� %� � � �F� !� !�1� %� � � �F� "� "�A� &�
�i�� � � �F� � �c� "� � � �� �
�
�
�f� 3� 3�Q�
7�� � �Y��1� �
� � �"�� �?�� N�O� O� �W�
� � � � �D� � �
�
� � � � �
�
��?��
�7�
8�8���?� �
3�c�#�,�,�.�6I�
I�J� �
,��f�
�u�U�|�/L�
L�Mr __pycache__/file_upload.cpython-312.pyc 0000644 00000003750 15173153065 0013755 0 ustar 00 �
���g� � �� � d dl Z d dlZd dlZ G d� d� Z eej
� dk r edej
d z � e�ej
d Zej
d Z e j j e � s
ede z � e� ej � Z
e
j ej e� e
j ej d� e
j ej" e ee d � � j& � e j j+ e � Ze
j ej. e� ed
e �d e��� e
j1 � e
j3 � y) � Nc � � e Zd Zd� Zd� Zy)�
FileReaderc � � || _ y �N)�fp)�selfr s �_/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/file_upload.py�__init__zFileReader.__init__
s � ���� c �8 � | j j |� S r )r �read)r �sizes r �
read_callbackzFileReader.read_callback s � ��w�w�|�|�D�!�!r N)�__name__�
__module__� __qualname__r
r � r r r r s � ��"r r � z Usage: %s <url> <file to upload>� � z#Error: the file '%s' does not exist�rbzUploading file z to url )�os�sys�pycurlr �len�argv�print�
SystemExit�url�filename�path�exists�Curl�c�setopt�URL�UPLOAD� READFUNCTION�openr r
�getsize�filesize�
INFILESIZE�perform�closer r r �<module>r/ s* ��
�
�"� "� �s�x�x�=�1�� �
,�s�x�x��{�
:�;�
�� �h�h�q�k�� �8�8�A�;�� �w�w�~�~�h� � �
/�(�
:�;�
�� �F�K�K�M�� ������S� � ���� � �� � ��H�H�V�
�
�*�T�(�D�-A�"B�"P�"P�Q�
�7�7�?�?�8� $�� ���� � �H� %� �x��5� 6� � � � � ��� r __pycache__/linksys.cpython-312.pyc 0000644 00000105676 15173153066 0013201 0 ustar 00 �
���g U � � � d dl Z d dlZd dlZd dlZd� Z G d� dej
� Z G d� d� Zedk( red dl Z d dl
Z
G d� d e
j � Z e � Z
e j d
d D ] Ze
j! e� � d Zes e
j% � d Zes�yyy# e$ r/ e j& � d
j( \ ZZ ed
ez � Y �9w xY w)� Nc � � t j j | � t j j d� y )N�
)�sys�stderr�write)�args �[/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/linksys.py� print_stderrr
% s& � ��J�J���S���J�J���T�� c � � e Zd Zd� Zy)� LinksysErrorc � � || _ y �N)�args)�selfr s r �__init__zLinksysError.__init__* s � ��� r N)�__name__�
__module__� __qualname__r � r r r
r
) s � �r r
c � � e Zd ZdZdZdZdZdZdZdZ dd d
d d d
�Z
d� Z d� Z d� Z
d� Zd� Zd� Zd� Zd� Zd� Zd� Zd� Zd� Zd� Zd� Zd � Zd � Zd � Zd � Z d � Z d!� Z d"� Z d#� Z d$� Z!d%� Z"d&� Z#d'� Z$d(� Z%d)� Z&d*� Z'd+� Z(d,� Z)d-� Z*d.� Z+d/� Z,d0� Z-d1� Z.d2� Z/y3)4�LinksysSessionz/Jan|Feb|Mar|Apr|May|Jun|Jul|Aug|Sep|Oct|Nov|Dec�1�2�3�4�5�6zbasic setup functionszFor security reasons,z-You can configure the router to act as a DHCPz3There are some log settings and lists in this page.z5Port forwarding can be used to set up public services)� �
Passwd.htmz DHCP.htmlzLog.htmlz Forward.htmc �< � g | _ d| _ d| _ i | _ y )Nzhttp://192.168.1.1F)�actions�host� verbosity� pagecache�r s r r zLinksysSession.__init__A s � ��� �(�� � �����r c � � || _ y r )r$ �r �flags r �
set_verbosityz LinksysSession.set_verbosityG s � � ��r c � � || j vr�t j | j � }|j | j
� |j
|� |j � | j |< |j d� r t dd� �|j t j | � sD| j |= t dt j j | j |� z d� �|j � y y )N�401zauthorization failure.Tz!check string for page %s missing!F)r% �curl�Curlr# r* r$ �get�body�answeredr
r �
check_strings�os�path�join�close)r �page�fetchs r �
cache_loadzLinksysSession.cache_loadL s� � � �t�~�~� %��I�I�d�i�i�(�E� � � ���� /� �I�I�d�O�#(�:�:�<�D�N�N�4� ��~�~�e�$�"�#;�T�B�B��^�^�N�$@�$@��$F�G��N�N�4�(�"�#F���� � �VZ�V_�V_�ae�If�#f�hm�n�n� �K�K�M� &r c � � i | _ y r )r% r& s r � cache_flushzLinksysSession.cache_flushX s � ���r c � � | j |� t j |� j | j | � }|r|j d� }|S d }|S �N� )r9 �re�compile�searchr% �group)r r7 �template�match�results r �
screen_scrapez LinksysSession.screen_scrape\ sS � � ���� ��
�
�8�$�+�+�D�N�N�4�,@�A�� ��[�[��^�F� �
� �F��
r c �, � | j d|dz � S )Nr z :[^M]*\(MAC Address: *([^)]*))rF )r r7 �prefixs r �get_MAC_addressz LinksysSession.get_MAC_addressd s � ��!�!�"�f�-M�&M�N�Nr c �~ � |r | j j ||d� y | j j ||d� y )Nr �0�r" �append)r r7 r) �values r �set_flagzLinksysSession.set_flagf s1 � � � �L�L� � ��d�C� 0� �L�L� � ��d�C� 0r c
� � d}|j d� D ]5 }| j j dd|t |dz � z |f� |dz
}�7 y )Nr �.r �F1r> )�splitr" rM �repr)r r7 �cgi�role�ip�ind�octets r �set_IP_addressz LinksysSession.set_IP_addressk sJ � ����X�X�c�]�E� �L�L� � ��T�4�$�s�1�u�+�+=�u� E� F� �1�H�C� #r c �N � | j ddt j z dz � S )Nr z
>([0-9.v]*, (z)[^<]*)<)rF r �monthsr& s r �get_firmware_versionz#LinksysSession.get_firmware_versionr s4 � � �!�!�"�o�"0�"7�"7�'8�:D�'E� H� Hr c �& � | j dd� S )Nr zLAN IP Address�rI r& s r � get_LAN_MACzLinksysSession.get_LAN_MACx s � ��#�#�B�(9�:�:r c �& � | j dd� S )Nr �Wirelessr_ r& s r �get_Wireless_MACz LinksysSession.get_Wireless_MACz s � ��#�#�B� �4�4r c �& � | j dd� S )Nr zWAN Connection Typer_ r& s r � get_WAN_MACzLinksysSession.get_WAN_MAC| s � ��#�#�B�(>�?�?r c �@ � | j j dd|f� y )Nr �hostNamerL �r �names r �
set_host_namez LinksysSession.set_host_name� s � � � � ���R��T� 2�3r c �@ � | j j dd|f� y )Nr �
DomainNamerL rh s r �set_domain_namez LinksysSession.set_domain_name� s � � � � ���R� �t� 4�5r c �* � | j dd|� y )Nr �ipAddr�rZ �r rW s r �
set_LAN_IPzLinksysSession.set_LAN_IP� s � � ���B��"�-r c � � |j d� st �|j d� d }|dvrt �| j j dd|� y )Nz 255.255.255.rQ ���)rK �128�192�240�252r �netMask)�
startswith�
ValueErrorrS r" rM )r rW �lastquads r �set_LAN_netmaskz LinksysSession.set_LAN_netmask� sK � ��}�}�^�,� � ��8�8�C�=��$�� �<� <� � � � � ���B� �8�4r c �( � | j dd� y )Nr �wirelessStatus�rO r( s r � set_wirelesszLinksysSession.set_wireless� s � � �
�
�b�*�+r c �@ � | j j dd|f� y )Nr �
wirelessESSIDrL )r �ssids r �set_SSIDzLinksysSession.set_SSID� s � � � � ���R� �$� 7�8r c �( � | j dd� y )Nr �
broadcastSSIDr� r( s r �set_SSID_broadcastz!LinksysSession.set_SSID_broadcast� s � � �
�
�b�/�*r c �@ � | j j dd|f� y )Nr �wirelessChannelrL )r �channels r � set_channelzLinksysSession.set_channel� s � � � � ���R�!2�G� <�=r c �( � | j dd� y )Nr �WepTyper� r( s r �set_WEPzLinksysSession.set_WEP� s � � �
�
�b�)�$r c �@ � | j j dd|f� y )Nr �WANConnectionTyperL )r �types r �set_connection_typez"LinksysSession.set_connection_type� s � � � � ���R�!4�d� ;�<r c �* � | j dd|� y )Nr �aliasIPrp rq s r �
set_WAN_IPzLinksysSession.set_WAN_IP� s � � ���B� �2�.r c �* � | j dd|� y )Nr � aliasMaskIPrp rq s r �set_WAN_netmaskz LinksysSession.set_WAN_netmask� s � � ���B�
�r�2r c �* � | j dd|� y )Nr �routerIPrp rq s r �set_WAN_gateway_addressz&LinksysSession.set_WAN_gateway_address� s � � ���B�
�B�/r c �6 � | j ddd| z |� y )Nr �dns�ABCrp �r �indexrW s r �set_DNS_serverz LinksysSession.set_DNS_server� s � � ���B���e� � 4�b�9r c �x � | j j dd|� | j j dd|� y )Nr � sysPasswd�sysPasswdConfirmrL )r �strs r � set_passwordzLinksysSession.set_password� s/ � � � � ���L��c�:� � � ���L�);�S�Ar c �( � | j dd� y )Nr � UPnP_Workr� r( s r �set_UPnPzLinksysSession.set_UPnP� s � � �
�
�l�K�0r c �< � | j j dd� y )Nr �FactoryDefaultsrL r& s r �resetzLinksysSession.reset� s � � � � ���L�*;�<r c �~ � |r | j j ddd� y | j j ddd� y )N�DHCP.htm�
dhcpStatus�Enable�DisablerL r( s r �set_DHCPzLinksysSession.set_DHCP� s1 � � � �L�L� � �
�<�� A� �L�L� � �
�<� � Br c �P � | j j ddt |� � y )Nr� �dhcpS4�r" rM r� �r �vals r �set_DHCP_starting_IPz#LinksysSession.set_DHCP_starting_IP� s � � � � ���J�x��S��:r c �P � | j j ddt |� � y )Nr� �dhcpLenr� r� s r �set_DHCP_usersz LinksysSession.set_DHCP_users� s � � � � ���J�y�#�c�(�;r c �P � | j j ddt |� � y )Nr� � leaseTimer� r� s r �set_DHCP_lease_timez"LinksysSession.set_DHCP_lease_time� � � � � � ���J�{�C��H�=r c �6 � | j ddd| z |� y )Nr� r� r� rp r� s r �set_DHCP_DNS_serverz"LinksysSession.set_DHCP_DNS_server� s � � ���J���e� �(<�b�Ar c �~ � |r | j j ddd� y | j j ddd� y )NzLog.htm�rLogr� r� rL r( s r � set_loggingzLinksysSession.set_logging� s1 � � � �L�L� � � �6�8� <� �L�L� � � �6�9� =r c �P � | j j ddt |� � y )Nr� � trapAddr3r� r� s r �set_log_addressz LinksysSession.set_log_address� r� r c
�F � | j �rg }| j � | j D ]� \ }}}| j |� | j | j |� dk( r;t d|�dt j j | j |� �d�� �t|j ||f� �� g | _ t j | j � }|j | j � |j dt! |� � |j# � yy)z+Write configuration changes to the Linksys.rt zlinksys: field z" not found where expected in page �!z
Gozila.cgiN)r" r; r9 r% �findr
r3 r4 r5 r# rM r- r. r* r$ r/ �tupler6 )r �fieldsr7 �fieldrN � transactions r � configurezLinksysSession.configure� s� � � �<�<��F� � � � �(,� � �$��u�e�����%��>�>�$�'�,�,�U�3�r�9� �]b�df�dk�dk�dp�dp�qu�qz�qz� }A� eB� "C� D� ��M�M�5�%�.�1�
)5� �D�L� �)�)�D�I�I�.�K� � %� %�d�n�n� 5� �O�O�L�%��-� 8� � � � �! r N)0r r r r\ �WAN_CONNECT_AUTO�WAN_CONNECT_STATIC�WAN_CONNECT_PPOE�WAN_CONNECT_RAS�WAN_CONNECT_PPTP�WAN_CONNECT_HEARTBEATr2 r r* r9 r; rF rI rO rZ r] r` rc re rj rm rr r} r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r - s � �
>�F��� �����O��� ��
.�-�E�K�M�
�M� � �
� ��O�1�
�H� ;�5�@�4�6�.�5�,�9�+�>�%�=�/�3�0�:�B�1�=�C�
;�<�>�B�
>�
>� r r �__main__c �� � e Zd ZdZd� Zd� Zd� Zd� Zd� Zd� Z d� Z
d � Z d
� Z d � Z
d � Zd
� Zd� Zd� Zd� Zd� Zd� Zd� Zd� Zd� Zd� Zd� Zd� Zd� Zd� Z d� Z d � Z d � Z d � Z d � Z!d � Z"d!� Z#d"� Z$d#� Z%d$� Z&d%� Z'd&� Z(d'� Z)d(� Z*d)� Z+d*� Z,d+� Z-d,� Z.d-� Z/d.� Z0d/� Z1d0� Z2d1� Z3d2� Z4d3� Z5d4� Z6d5� Z7d6� Z8d7� Z9d8� Z:d9� Z;d:� Z<d;� Z=d<� Z>d=� Z?d>� Z@d?� ZAd@� ZBdA� ZCdB� ZDdC� ZEdD� ZFdE� ZGdF� ZHdG� ZIdH� ZJdI� ZKdJ� ZLyK)L�LinksysInterpreterz:Interpret commands to perform LinkSys programming actions.c � � t j j | � t � | _ t j d� r*t d� | j j dz | _ y d| _ t d� y )Nr zType ? or `help' for help.�: r �Bar1)
�cmd�Cmdr r �sessionr3 �isatty�printr# �promptr& s r r zLinksysInterpreter.__init__� sV � � �G�G� � �T� "�)�+�D�L��y�y��|��2�3� "�l�l� /� /�$� 6�� � �� ��f�
r c � � |j � dv r |d� y|j � dv r |d� yt d� y)N)�on�enable�yesT)�off�disable�noFz linksys: unknown switch valuer )�stripr
)r �func�lines r � flag_commandz LinksysInterpreter.flag_command� sH � ��z�z�|� 6�6��T�
�
� ��� �!9�9��U� � � � <�=�r c � � |j � }|rJ|| j _ | j j � | j j dz | _ yt | j j � y)Nr� r )r� r� r# r; r� r� )r r� �newhosts r �
do_connectz LinksysInterpreter.do_connect� s^ � ��j�j�l�G��$+�� � �!�� � �(�(�*� "�l�l� /� /�$� 6�� � � �d�l�l�'�'�(�r c �F � t d� t d� t d� y )Nz!Usage: connect [<hostname-or-IP>]z+Connect to a Linksys by name or IP address.z0If no argument is given, print the current host.�r� r& s r � help_connectz LinksysInterpreter.help_connect� s � � �5� 6� �?� @� �D� Er c � � | j j d� d| j j v r�t d| j j � � t d| j j � � t d| j j
� � t d| j j � � t d� y)Nr z Firmware:zLAN MAC:z
Wireless MAC:zWAN MAC:rQ r )r� r9 r% r� r] r` rc re �r r� s r � do_statusz LinksysInterpreter.do_status s� � � �L�L� #� #�B� '��T�\�\�+�+�+��k�4�<�<�#D�#D�#F�G��j�$�,�,�":�":�"<�=��o�t�|�|�'D�'D�'F�G��j�$�,�,�":�":�"<�=��c�
�r c �\ � t d� t d� t d� t d� y )Nz
Usage: statusz3The status command shows the status of the Linksys.z2It is mainly useful as a sanity check to make surez the box is responding correctly.r� r& s r � help_statusz LinksysInterpreter.help_status s% � � �/� "� �G� H� �F� G� �4� 5r c �P � | j | j j |� y r )r� r� r* r� s r �
do_verbosez LinksysInterpreter.do_verbose s � � � � �d�l�l� 8� 8�$� ?r c �0 � t d� t d� y )Nz-Usage: verbose {on|off|enable|disable|yes|no}z!Enables display of HTTP requests.r� r& s r � help_verbosez LinksysInterpreter.help_verbose s � � �A� B� �5� 6r c �: � | j j |� y�Nr )r� rj r� s r �do_hostzLinksysInterpreter.do_host s � � �L�L� &� &�t� ,�r c �0 � t d� t d� y )NzUsage: host <hostname>z-Sets the Host field to be queried by the ISP.r� r& s r � help_hostz LinksysInterpreter.help_host s � � �*� +� �A� Br c �P � t d� | j j |� y)NzUsage: host <domainname>r )r� r� rm r� s r � do_domainz LinksysInterpreter.do_domain s � � �,� -� �L�L� (� (�� .�r c � � t d� y )Nz/Sets the Domain field to be queried by the ISP.r� r& s r � help_domainz LinksysInterpreter.help_domain# s � � �C� Dr c �: � | j j |� yr� )r� rr r� s r �do_lan_addressz!LinksysInterpreter.do_lan_address& � � � �L�L� #� #�D� )�r c �0 � t d� t d� y )Nz Usage: lan_address <ip-address>zSets the LAN IP address.r� r& s r �help_lan_addressz#LinksysInterpreter.help_lan_address) � � � �3� 4� �,� -r c �: � | j j |� yr� )r� r} r� s r �do_lan_netmaskz!LinksysInterpreter.do_lan_netmask- � � � �L�L� (� (�� .�r c �0 � t d� t d� y )Nz Usage: lan_netmask <ip-mask>� Sets the LAN subnetwork mask.r� r& s r �help_lan_netmaskz#LinksysInterpreter.help_lan_netmask0 � � � �0� 1� �1� 2r c �P � | j | j j |� yr� )r� r� r� r� s r � do_wirelessz LinksysInterpreter.do_wireless4 s � � � � �d�l�l� 7� 7�� >�r c �0 � t d� t d� y )Nz.Usage: wireless {on|off|enable|disable|yes|no}z.Switch to enable or disable wireless features.r� r& s r �
help_wirelessz LinksysInterpreter.help_wireless7 s � � �B� C� �B� Cr c �: � | j j |� yr� )r� r� r� s r �do_ssidzLinksysInterpreter.do_ssid; s � � �L�L� !� !�$� '�r c �0 � t d� t d� y )NzUsage: ssid <string>z.Sets the SSID used to control wireless access.r� r& s r � help_ssidz LinksysInterpreter.help_ssid> s � � �(� )� �B� Cr c �P � | j | j j |� yr� )r� r� r� r� s r �do_ssid_broadcastz$LinksysInterpreter.do_ssid_broadcastB s � � � � �d�l�l� =� =�t� D�r c �0 � t d� t d� y )Nz4Usage: ssid_broadcast {on|off|enable|disable|yes|no}z+Switch to enable or disable SSID broadcast.r� r& s r �help_ssid_broadcastz&LinksysInterpreter.help_ssid_broadcastE s � � �H� I� �?� @r c �: � | j j |� yr� )r� r� r� s r �
do_channelz LinksysInterpreter.do_channelI s � � �L�L� $� $�T� *�r c �0 � t d� t d� y )NzUsage: channel <number>zSets the wireless channel.r� r& s r � help_channelz LinksysInterpreter.help_channelL s � � �+� ,� �.� /r c �P � | j | j j |� yr� )r� r� r� r� s r �do_wepzLinksysInterpreter.do_wepP s � � � � �d�l�l� 2� 2�D� 9�r c �0 � t d� t d� y )Nz)Usage: wep {on|off|enable|disable|yes|no}z)Switch to enable or disable WEP security.r� r& s r �help_wepzLinksysInterpreter.help_wepS s � � �=� >� �=� >r c �� � t d|j � j � z � }| j j |� y# t
$ r t
d� Y yw xY w)NzLinksysSession.WAN_CONNECT_z!linksys: unknown connection type.r )�evalr� �upperr� r� r{ r
)r r� r� s r � do_wan_typez LinksysInterpreter.do_wan_typeW s] � �
B��7��
�
� �8J�8J�8L�L�M��� � �0�0��6� �� �
B� � @�A��
B�s �AA �A � A c �0 � t d� t d� y )Nz5Usage: wan_type {auto|static|ppoe|ras|pptp|heartbeat}z Set the WAN connection type.r� r& s r �
help_wan_typez LinksysInterpreter.help_wan_type^ s � � �I� J� �0� 1r c �: � | j j |� yr� )r� r� r� s r �do_wan_addressz!LinksysInterpreter.do_wan_addressb r r c �0 � t d� t d� y )Nz Usage: wan_address <ip-address>zSets the WAN IP address.r� r& s r �help_wan_addressz#LinksysInterpreter.help_wan_addresse r r c �: � | j j |� yr� )r� r� r� s r �do_wan_netmaskz!LinksysInterpreter.do_wan_netmaski r r c �0 � t d� t d� y )Nz Usage: wan_netmask <ip-mask>z Sets the WAN subnetwork mask.r� r& s r �help_wan_netmaskz#LinksysInterpreter.help_wan_netmaskl r r c �: � | j j |� yr� )r� �set_WAN_gatewayr� s r �do_wan_gatewayz!LinksysInterpreter.do_wan_gatewayp r r c �0 � t d� t d� y )Nz Usage: wan_gateway <ip-address>r r� r& s r �help_wan_gatewayz#LinksysInterpreter.help_wan_gateways s � � �3� 4� �1� 2r c � � |j � \ }}|dv r&| j j t |� |� yt d� y�N)r r r z$linksys: server index out of bounds.r )rS r� r� r( r
�r r� r� �addresss r �do_dnszLinksysInterpreter.do_dnsw sE � � #�z�z�|� �U�G���'�� � �+�+�D��K��A� � � C�D�r c �0 � t d� t d� y )Nz Usage: dns {1|2|3} <ip-mask>z:Sets a primary, secondary, or tertiary DNS server address.r� r& s r �help_dnszLinksysInterpreter.help_dns~ s � � �0� 1� �N� Or c �: � | j j |� yr� )r� r� r� s r � do_passwordz LinksysInterpreter.do_password� s � � �L�L� %� %�d� +�r c �0 � t d� t d� y )NzUsage: password <string>zSets the router password.r� r& s r �
help_passwordz LinksysInterpreter.help_password� s � � �,� -� �-� .r c �P � | j | j j |� yr� )r� r� r� r� s r �do_upnpzLinksysInterpreter.do_upnp� s � � � � �d�l�l� 3� 3�T� :�r c �0 � t d� t d� y )Nz*Usage: upnp {on|off|enable|disable|yes|no}z4Switch to enable or disable Universal Plug and Play.r� r& s r � help_upnpz LinksysInterpreter.help_upnp� s � � �>� ?� �H� Ir c �8 � | j j � y r )r� r� r� s r �do_resetzLinksysInterpreter.do_reset� s � � �L�L� � � r c �0 � t d� t d� y )Nz Usage: resetz+Reset Linksys settings to factory defaults.r� r& s r �
help_resetz LinksysInterpreter.help_reset� s � � �.� !� �?� @r c �P � | j | j j |� y r )r� r� r� r� s r �do_dhcpzLinksysInterpreter.do_dhcp� s � � � � �d�l�l� 3� 3�T� :r c �0 � t d� t d� y )Nz*Usage: dhcp {on|off|enable|disable|yes|no}z*Switch to enable or disable DHCP features.r� r& s r � help_dhcpz LinksysInterpreter.help_dhcp� s � � �>� ?� �>� ?r c �: � | j j |� y r )r� r� r� s r �
do_dhcp_startz LinksysInterpreter.do_dhcp_start� s � � �L�L� -� -�d� 3r c �0 � t d� t d� y )NzUsage: dhcp_start <number>z'Set the start address of the DHCP pool.r� r& s r �help_dhcp_startz"LinksysInterpreter.help_dhcp_start� s � � �.� /� �;� <r c �: � | j j |� y r )r� r� r� s r �
do_dhcp_usersz LinksysInterpreter.do_dhcp_users� � � � �L�L� '� '�� -r c �0 � t d� t d� y )NzUsage: dhcp_users <number>�9Set number of address slots to allocate in the DHCP pool.r� r& s r �help_dhcp_usersz"LinksysInterpreter.help_dhcp_users� � � � �.� /� �M� Nr c �: � | j j |� y r )r� �set_DHCP_leaser� s r �
do_dhcp_leasez LinksysInterpreter.do_dhcp_lease� rW r c �0 � t d� t d� y )NzUsage: dhcp_lease <number>rY r� r& s r �help_dhcp_leasez"LinksysInterpreter.help_dhcp_lease� r[ r c � � |j � \ }}|dv r&| j j t |� |� yt d� yr; )rS r� r� r( r
r< s r � do_dhcp_dnsz LinksysInterpreter.do_dhcp_dns� sE � � #�z�z�|� �U�G���'�� � �0�0��e��g�F� � � C�D�r c �0 � t d� t d� y )Nz!Usage: dhcp_dns {1|2|3} <ip-mask>z8Sets primary, secondary, or tertiary DNS server address.r� r& s r �
help_dhcp_dnsz LinksysInterpreter.help_dhcp_dns� s � � �5� 6� �L� Mr c �P � | j | j j |� y r )r� r� r� r� s r �
do_loggingz LinksysInterpreter.do_logging� s � � � � �d�l�l� 6� 6�� =r c �0 � t d� t d� y )Nz-Usage: logging {on|off|enable|disable|yes|no}z,Switch to enable or disable session logging.r� r& s r � help_loggingz LinksysInterpreter.help_logging� s � � �A� B� �@� Ar c �: � | j j |� y r )r� �set_Log_addressr� s r �do_log_addressz!LinksysInterpreter.do_log_address� s � � �L�L� (� (�� .r c �0 � t d� t d� y )NzUsage: log_address <number>z1Set the last quad of the address to which to log.r� r& s r �help_log_addressz#LinksysInterpreter.help_log_address� s � � �/� 0� �E� Fr c �8 � | j j � yr� )r� r� r� s r � do_configurez LinksysInterpreter.do_configure� s � � �L�L� "� "� $�r c �0 � t d� t d� y )NzUsage: configurez(Writes the configuration to the Linksys.r� r& s r �help_configurez!LinksysInterpreter.help_configure� s � � �$� %� �<� =r c �B � t | j j � y r )r� r� r% r� s r �do_cachezLinksysInterpreter.do_cache� s � � �$�,�,�(�(� )r c �0 � t d� t d� y )Nz Usage: cachezDisplay the page cache.r� r& s r �
help_cachez LinksysInterpreter.help_cache� s � � �.� !� �+� ,r c � � yr= r r� s r �do_quitzLinksysInterpreter.do_quit� s � �r c �0 � t d� t d� y )Nz2The quit command ends your linksys session withoutz-writing configuration changes to the Linksys.r� r� s r � help_quitz LinksysInterpreter.help_quit� s � � �F� G� �A� Br c �N � t d� | j j � y)Nr r> )r� r� r� r� s r �do_EOFzLinksysInterpreter.do_EOF� s � � �"�I� �L�L� "� "� $�r c �0 � t d� t d� y )Nz7The EOF command writes the configuration to the linksyszand ends your session.r� r& s r �help_EOFzLinksysInterpreter.help_EOF� s � � �K� L� �*� +r c �. � t j |� y)z5Pass the command through to be executed by the shell.r )r3 �systemr� s r �defaultzLinksysInterpreter.default� s � � �I�I�d�O�r c �0 � t d� t d� y )Nz/On-line help is available through this command.z"? is a convenience alias for help.r� r& s r � help_helpz LinksysInterpreter.help_help� s � � �C� D� �6� 7r c � � t d� y )Na�
This program supports changing the settings on Linksys blue-box routers. This
capability may come in handy when they freeze up and have to be reset. Though
it can be used interactively (and will command-prompt when standard input is a
terminal) it is really designed to be used in batch mode. Commands are taken
from the command line first, then standard input.
By default, it is assumed that the Linksys is at http://192.168.1.1, the
default LAN address. You can connect to a different address or IP with the
'connect' command. Note that your .netrc must contain correct user/password
credentials for the router. The entry corresponding to the defaults is:
machine 192.168.1.1
login ""
password admin
Most commands queue up changes but don't actually send them to the Linksys.
You can force pending changes to be written with 'configure'. Otherwise, they
will be shipped to the Linksys at the end of session (e.g. when the program
running in batch mode encounters end-of-file or you type a control-D). If you
end the session with `quit', pending changes will be discarded.
For more help, read the topics 'wan', 'lan', and 'wireless'.r� r& s r �help_introductionz$LinksysInterpreter.help_introduction� s � � � @�
Ar c � � t d� y )Nz�The `lan_address' and `lan_netmask' commands let you set the IP location of
the Linksys on your LAN, or inside. Normally you'll want to leave these
untouched.r� r& s r �help_lanzLinksysInterpreter.help_lan s � � � �
r c � � t d� y )Na{ The WAN commands become significant if you are using the BEFSR41 or any of
the other Linksys boxes designed as DSL or cable-modem gateways. You will
need to use `wan_type' to declare how you expect to get your address.
If your ISP has issued you a static address, you'll need to use the
`wan_address', `wan_netmask', and `wan_gateway' commands to set the address
of the router as seen from the WAN, the outside. In this case you will also
need to use the `dns' command to declare which remote servers your DNS
requests should be forwarded to.
Some ISPs may require you to set host and domain for use with dynamic-address
allocation.r� r& s r �help_wanzLinksysInterpreter.help_wan s � � � �
r c � � t d� y )NzWThe channel, ssid, ssid_broadcast, wep, and wireless commands control
wireless routing.r� r& s r �help_wireless_descz%LinksysInterpreter.help_wireless_desc s � � � �
r c �F � t d� t d� t d� y )Nz8Switches may be turned on with 'on', 'enable', or 'yes'.z:Switches may be turned off with 'off', 'disable', or 'no'.z2Switch commands include: wireless, ssid_broadcast.r� r& s r �
help_switchesz LinksysInterpreter.help_switches s � � �L� M� �N� O� �F� Gr c �F � t d� t d� t d� y )Nz/An address argument must be a valid IP address;z-four decimal numbers separated by dots, each zbetween 0 and 255.r� r& s r �help_addressesz!LinksysInterpreter.help_addresses! s � � �C� D� �A� B� �&� 'r c � � y r r r& s r � emptylinez LinksysInterpreter.emptyline& s � � r N)Mr r r �__doc__r r� r� r� r� r� r� r� r� r r r r r
r
r r r r r r r r r" r$ r& r* r, r. r0 r2 r4 r7 r9 r> r@ rB rD rF rH rJ rL rN rP rR rT rV rZ r^ r` rb rd rf rh rk rm ro rq rs ru rw ry r{ r} r� r� r� r� r� r� r� r� r� r r r r� r� � s� � �H� � � � F�
� 6� @� 7� � C� � E� � .� � 3� � D� � D� � A� � 0� � ?� � 2� � .� � 3� � 3� � P� � /� � J� !� A� ;� @� 4� =� .� O� .� O� � N� >� B� /� G� � >� *� -� � C� � ,� �
8� A�4 �
� �
H�
(�
r r� r> FTz linksys: )r r? r- �
exceptionsr
� Exceptionr
r r r3 r� r� r� � interpreter�argvr �onecmd�fatal�cmdloop�exc_infor �messager� r r r �<module>r� s� ��F !� ���:�'�'� �n � n �` �z���G�S�W�W� G�R
%�&�K��x�x���|�����3� � � �E�� )� � � � !��E� �a
��h
� )� )�S�\�\�^�A� .� 3� 3�N�G�U� �+��'� (� )�s �B � 1C�C __pycache__/xmlrpc_curl.cpython-312.pyc 0000644 00000007650 15173153067 0014031 0 ustar 00 �
���g� � �0 � d dl Z d dl mZmZ e j ee� d dlmZ d dlZd dl
Z
d dl Z e j d dkD Z
G d� dej � Zedk( rD ej" d e� � � Z ee� eej( j+ d
� � yy# e$ r Y ��w xY w# e$ r d dlmZ n# e$ r d dlmZ Y nw xY wY ��w xY w# e$ r d dlm Z Y ��w xY w# ej, $ r e j. � d Z ed e� Y yw xY w)
� N)�SIGPIPE�SIG_IGN)�StringIO� c �& � e Zd ZdZdgZdd�Zdd�Zy)�
CURLTransportz5Handles a cURL HTTP transaction to an XML-RPC server.zContent-Type: text/xmlNc � � t j � | _ | j j t j d� | j j t j
d� | j j t j d� | j j t j | j � |d k7 r4|d k7 r/| j j t j |�d|��� d| _
y )N� � �:F) �pycurl�Curl�c�setopt�POST�NOSIGNAL�CONNECTTIMEOUT�
HTTPHEADER�xmlrpc_h�USERPWD�
_use_datetime)�self�username�passwords �_/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/xmlrpc_curl.py�__init__zCURLTransport.__init__% s� � ���� ��� ���
�
�f�k�k�1�%� ���
�
�f�o�o�q�)� ���
�
�f�+�+�R�0� ���
�
�f�'�'�� � �7� �t� ��D� 0� �F�F�M�M�&�.�.�X�x�*H� I� "��� c �� � t � }| j j t j d|�|��� | j j t j
|� | j j t j |j � | j j t j |� || _ | j j � |j% d� | j' |� S # t j $ rK t j � d }t r |j }t! j" ||z |d |d d � �w xY w)Nzhttp://r
r )r r r r
�URL�
POSTFIELDS�
WRITEFUNCTION�write�VERBOSE�verbose�perform�error�sys�exc_info�PY3�args� xmlrpclib�
ProtocolError�seek�parse_response)r �host�handler� request_bodyr$ �b�vs r �requestzCURLTransport.request/ s � � �J�� ���
�
�f�j�j�4��"A�B� ���
�
�f�'�'� �6� ���
�
�f�*�*�A�G�G�4� ���
�
�f�n�n�g�.� �� � � �6�6�>�>� �
���q� ��"�"�1�%�%�� �|�|� �� � ��q�!�A���F�F���)�)��w���!��a��d�D��
� �s
�
D �A E$)NN)r )�__name__�
__module__� __qualname__�__doc__r r r4 � r r r r s � �?�)�+�H�#�&r r �__main__zhttp://betty.userland.com)� transport�) r
�ERROR)�signalr r � ImportError� cStringIOr �ior+ �
xmlrpc.client�clientr
r' � version_infor) � Transportr r5 � ServerProxy�server�print�examples� getStateName�Errorr( r3 r9 r r �<module>rL s1 ��$��'� �F�M�M�'�7�#� �"� &�� �
� ���q��A� ��!&�I�'�'� !&�H �z��
"�Y�
"�
"�#>�-:�_�>�F� �&�M��
�f�o�o�*�*�2�.�/�
��u � �� �� � � �%�� � � � �� �� � &�%�&��f �?�?� � �C�L�L�N�1� ��
�g�q���si � B& �B1 �C �!C& �&B.�-B.�1C�7B>�=C�> C � C� C � C�C� C#�"C#�&,D�D __pycache__/smtp.cpython-312.pyc 0000644 00000002657 15173153067 0012464 0 ustar 00 �
���gK � �d � d dl mZ ddlZ ddlmZ ddlZej d dkD Z dez Z
dZ d Z ej � Zej ej e
� ej ej" e � ej ej$ e g� d
e �d e �d �Ze rej) d
� Z ee� Zej ej* e� ej ej, d� ej ej. d� ej1 � y# e$ r
ddlmZ Y �� w xY w)� )� localhost� N)�BytesIO)�StringIO� z smtp://%szsender@example.orgzaddressee@example.netzFrom: z
To: z7
Subject: PycURL SMTP example
SMTP example via PycURL
�asciiT)� r �pycurl�ior � ImportErrorr �sys� version_info�PY3� mail_server� mail_from�mail_to�Curl�c�setopt�URL� MAIL_FROM� MAIL_RCPT�message�encode�READDATA�UPLOAD�VERBOSE�perform� � �X/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/smtp.py�<module>r" s ��
�
�-�� � ���q��A� ���I�%� � � �
!���F�K�K�M�� ������ � � ������i� � ������w�i� � �'�
�� ��n�n�W�%�G�
�W��� ������R� � ������4� � ������D� � � � � ��K � -�,�,�-�s �D � D/�.D/ __pycache__/retriever-multi.cpython-312.pyc 0000644 00000011031 15173153070 0014614 0 ustar 00 �
���g
� � � d dl Z d dlZ d dlZd dlmZmZ ej ee� dZ e j d dk( re j j � Z
n# e e j d � j � Z
e e j � dk\ r e
e j d � Zg Ze
D ]> Zej% � Zered d k( r� d
e e� dz z Zej) eef� �@ esJ d � � e e� Z eee� Zdecxk r d k sJ d
� � J d
� � edej. ej0 fz � ededed� ej2 � Zg e_ e e� D ]� Z ej< � Z de _ e jC ejD d� e jC ejF d� e jC ejH d� e jC ejJ d� e jC ejL d� ej6 j) e � �� ej6 dd Z'd Z(e(ek �r�er�e'r�ejS d � \ ZZe'jS � Z e ed� e _ e jC ejT e� e jC ejV e j@ � ejY e � ee _ ee _ ere'r�� ej[ � \ Z.Z/e.ej` k7 rn�$ ejc � \ Z2Z3Z4e3D ]} Z e j@ jk � de _ ejm e � ede j& e j" e jo ejp � � e'j) e � � e4D ]i \ Z Z9Z:e j@ jk � de _ ejm e � ede j& e j" e9e:� e'j) e � �k e( e e3� z e e4� z Z(e2d k( rn�� ejw d� e(ek r���ej6 D ]? Z e j@ �!e j@ jk � de _ e jk � �A ejk � y# e$ r Y ��w xY w# ede j d z � e�xY w)� N)�SIGPIPE�SIG_IGN�
� �-� � zCUsage: %s <file with URLs to fetch> [<# of concurrent connections>]�#z doc_%03d.datz
no URLs giveni' z(invalid number of concurrent connectionsz!PycURL %s (compiled against 0x%x)z
----- Gettingz
URLs usingzconnections -----� � i, �wbzSuccess:zFailed: g �?)<�sys�pycurl�signalr r � ImportError�num_conn�argv�stdin� readlines�urls�open�len�int�print�
SystemExit�queue�url�strip�filename�append�num_urls�min�version�COMPILE_LIBCURL_VERSION_NUM� CurlMulti�m�handles�range�i�Curl�c�fp�setopt�FOLLOWLOCATION� MAXREDIRS�CONNECTTIMEOUT�TIMEOUT�NOSIGNAL�freelist�
num_processed�pop�URL� WRITEDATA�
add_handle�perform�ret� num_handles�E_CALL_MULTI_PERFORM� info_read�num_q�ok_list�err_list�close�
remove_handle�getinfo�
EFFECTIVE_URL�errno�errmsg�select� � �c/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/retriever-multi.py�<module>rK sO �� �
�$��'� �F�M�M�'�7�#�
�� �
�x�x��{�c���y�y�"�"�$���C�H�H�Q�K� �*�*�,��
�3�8�8�}����s�x�x��{�#�� �� �C�
�)�)�+�C� �#�a�&�C�-�� ��U��a� �0�H� �L�L�#�x� �!� �
� �o� �u� �u�:�� �x�� "���H� �� � I� I� I� � I� I� I� � �)�V�^�^�V�=_�=_�,`�`� a� �o�x� �x�9L� M� �F����� �� � �x� �A��� � �
�A� �A�D��H�H�V�
"�
"�A�&��H�H�V�
�
�q�!��H�H�V�
"�
"�B�'��H�H�V�^�^�S�!��H�H�V�_�_�a� ��I�I���Q��
�
�9�9�Q�<���
��h� �
�H� � � �!� �
��X� �L�L�N���H�d�#��� ������S�!� ����!�!�1�4�4�(� � � �Q�� ��
���� �H� � �9�9�;���[� �&�-�-� -� � �
�#$�;�;�=� ��w���A�
�D�D�J�J�L��A�D�
�O�O�A� � �*�a�j�j�!�%�%����6�;O�;O�1P� Q� �O�O�A� � � !)� �A�u�f�
�D�D�J�J�L��A�D�
�O�O�A� � �*�a�j�j�!�%�%��� ?� �O�O�A� � !)� &��G� �4�s�8�}�D�
� �A�:� �! �( �H�H�S�M�M �h� �T
���A��t�t�� ���
�
� �����G�G�I�
�
��� ��Q � �� �� � �
O�RU�RZ�RZ�[\�R]�
]�^�
��s � R �A:R, � R)�(R)�, S __pycache__/basicfirst.cpython-312.pyc 0000644 00000003021 15173153070 0013606 0 ustar 00 �
���g! � � � d dl Z d dlZe j d dkD Z G d� d� Ze j
j
dej z � e� Z ej � Z
e
j e
j d� e
j e
j ej � e
j � e
j! � eej$ � y)� N� c � � e Zd Zd� Zd� Zy)�Testc �` � d| _ t r!| j j d� | _ y y )N� �ascii)�contents�PY3�encode)�selfs �^/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/basicfirst.py�__init__z
Test.__init__ s' � ���
� � �M�M� 0� 0�� 9�D�M� � c �, � | j |z | _ y )N)r )r �bufs r
�
body_callbackzTest.body_callback s � � �
�
��+��
r N)�__name__�
__module__� __qualname__r r � r r
r r
s � �:�
,r r z Testing %s
zhttps://curl.haxx.se/dev/)�sys�pycurl� version_infor
r �stderr�write�version�t�Curl�c�setopt�URL�
WRITEFUNCTIONr �perform�close�printr r r r
�<module>r& s� �� �
� ���q��A� ��,� ,� �
�
� � � �&�.�.�0� 1��F���F�K�K�M�� ������+� ,� ���� � �!�/�/� *� � � � � ��� � �a�j�j� r __pycache__/retriever.cpython-312.pyc 0000644 00000010730 15173153070 0013471 0 ustar 00 �
���gi
� �D � d dl Z d dlZ d dlZd dlZ d dlZd dlmZmZ ej ee� dZ e j d dk( re j j � Z
n# ee j d � j � Z
ee j � dk\ r ee j d � Z ej � Ze
D ]H Zej) � Zered d k( r� d
eej � dz z Zej- eef� �J ej sJ d � � eej � Z ee e� Z de cxk r d k sJ d
� � J d
� � edej2 ej4 fz � edede d� G d� dej6 � Z g Z e e � D ]+ Z e e� Z e jC � e jE e � �- e D ] Z#e#jI � � y# e$ r d dlZY ���w xY w# e$ r Y ���w xY w# ede j d z � e�xY w)� N)�SIGPIPE�SIG_IGN�
� �-� � zCUsage: %s <file with URLs to fetch> [<# of concurrent connections>]�#z doc_%03d.datz
no URLs giveni' z(invalid number of concurrent connectionsz!PycURL %s (compiled against 0x%x)z
----- Gettingz
URLs usingzconnections -----c � � e Zd Zd� Zd� Zy)� WorkerThreadc �P � t j j | � || _ y )N)� threading�Thread�__init__�queue)�selfr s �]/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/retriever.pyr zWorkerThread.__init__> s � ����!�!�$�'���
� c �� � | j j � \ }}t |d� }t
j � }|j t j |� |j t j d� |j t j d� |j t j d� |j t j d� |j t j d� |j t j |� |j! � |j- � |j- � t& j. j1 d� t& j. j+ � ���# t j $ r t �w xY w# dd l}|j% t& j( �� t& j( j+ � Y ��xY w) Nr �wb� � i, r )�file�.)r �
get_nowait�Queue�Empty�
SystemExit�open�pycurl�Curl�setopt�URL�FOLLOWLOCATION� MAXREDIRS�CONNECTTIMEOUT�TIMEOUT�NOSIGNAL� WRITEDATA�perform� traceback� print_exc�sys�stderr�flush�close�stdout�write)r �url�filename�fp�curlr+ s r �runzWorkerThread.runB sQ � ��
!� $�
�
� 5� 5� 7�
��X� �h��%�B��;�;�=�D� �K�K��
�
�C� (� �K�K��-�-�q� 1� �K�K��(�(�!� ,� �K�K��-�-�r� 2� �K�K����� ,� �K�K����� +� �K�K��(�(�"� -�
#�� � ��
�J�J�L� �H�H�J� �J�J� � �S� !� �J�J� � � �/ �� �;�;�
!� � �
!��
#� ��#�#����#�4��
�
� � �"�s � F �!F- �F*�-AG3N)�__name__�
__module__� __qualname__r r7 � r r r r = s � �� r r )%r- r r � ImportErrorr r �signalr r �num_conn�argv�stdin� readlines�urlsr �len�int�printr r3 �stripr4 �put�num_urls�min�version�COMPILE_LIBCURL_VERSION_NUMr r �threads�range�dummy�t�start�append�thread�joinr; r r �<module>rT s& �� ��� �$��'� �F�M�M�'�7�#� �� �
�x�x��{�c���y�y�"�"�$���C�H�H�Q�K� �*�*�,��
�3�8�8�}����s�x�x��{�#�� �� � �
�� �C�
�)�)�+�C� �#�a�&�C�-�� ��U�[�[�!1�A�!5�6�H� �I�I�s�H�o� � �
�{�{� #�O� #�{� �u�{�{� �� �x�� "���H� �� � I� I� I� � I� I� I� � �)�V�^�^�V�=_�=_�,`�`� a� �o�x� �x�9L� M� �9�#�#� �B
��
�8�_�E��U��A��G�G�I� �N�N�1�� � �F�
�K�K�M� ��s � ���� � �� �� � �
O�RU�RZ�RZ�[\�R]�
]�^�
��s. �G' � G7 �A:H �' G4�3G4�7H �?H � H __pycache__/opensocketexception.cpython-312.pyc 0000644 00000003673 15173153071 0015564 0 ustar 00 �
���g] � �� � d dl Z d dlZd dlZ G d� de� Zd� Z e j � Zej ej d� de_
ej ej d� � ej � y# e j $ rRZej d e j k( r ej r eej � n
ee� Y dZ[yY dZ[ydZ[ww xY w)� Nc � � e Zd Zy)�ConnectionRejectedN)�__name__�
__module__� __qualname__� � �g/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/opensocketexception.pyr r s � �r r c � � t j � dk r t d� | _ t j S |\ }}}}t j
|||� }|j
t
j t
j d� |S )Ng �?z3Rejecting connection attempt in opensocket callback� ) �randomr � exception�pycurl�
SOCKET_BAD�socket�
setsockopt�
SOL_SOCKET� SO_KEEPALIVE)�curl�purpose� curl_address�family�socktype�protocol�address�ss r
�
opensocketr sj � �
�}�}��� �+�,a�b���� � � �*6�'�F�H�h���
�
�f�h��1�A��L�L��"�"�F�$7�$7��;� �Hr zhttp://pycurl.ioc �$ � t t | |� S )N)r �c)r r s r
�<lambda>r s
� �Z��7�G� <r )r r
r � Exceptionr r �Curlr �setopt�URLr �OPENSOCKETFUNCTION�perform�error�e�args�E_COULDNT_CONNECT�printr r r
�<module>r, s� �� � � �� �
� �F�K�K�M�� ������"� #��� � ���� � �<�>���I�I�K��
�|�|� ��v�v�a�y�F�,�,�,����
�a�k�k��
�a��� ���s �-A> �>C �
AC�C __pycache__/sfquery.cpython-312.pyc 0000644 00000006017 15173153071 0013164 0 ustar 00 �
���g� � � � d dl Z d dlZd dlZ G d� dej � Zedk( �r� ee j � dk( rdZne j d Z ej � j d� Z
e
\ Z Z Z
ed � Zej# d � ej% e e
� ej' d
� rEe j( j+ d eej- � � z � e j. d� yej' de z � r]ej1 e� e j2 j+ ej- � � ej5 � e j. d � ye j( j+ d eej- � � z � e j. d� yy# ee j � dk r ed e j d z � e�e j d
Z e j d Z
Y ���xY w)� Nc � � e Zd Zd� Zd� Zd� Zy)�SourceForgeUserSessionc �: � | j dd|fd|fdddf� y)zEstablish a login session.zaccount/login.php�form_loginname�form_pw)� return_to� )� stay_in_ssl�1)�loginzLogin With SSLN)�post)�self�name�passwords �[/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/sfquery.pyr z SourceForgeUserSession.login s1 � � � � �%�)9�4�(@�)2�H�(=�(9�(<�(C� (E� F� c �& � | j d� y)zLog out of SourceForge.zaccount/logout.phpN��get)r s r �logoutz SourceForgeUserSession.logout s � � ���%�&r c �, � | j d|z � y )Nz!export/xml_export.php?group_id=%sr )r �numids r � fetch_xmlz SourceForgeUserSession.fetch_xml s � � ���4�u�<�=r N)�__name__�
__module__� __qualname__r r r � r r r r s � �F�'�>r r �__main__� �28236zsourceforge.net� z,Usage: %s <project id> <username> <password>� � zhttps://sourceforge.net/z Invalid Password or User Namez'Login/password not accepted (%d bytes)
zPersonal Page For: zUnexpected page (%d bytes)
)�sys�netrc�curl�Curlr r �len�argv�
project_id�authenticators�authr �accountr �print�
SystemExit�session�
set_verbosityr �answered�stderr�write�body�exitr �stdoutr r r r �<module>r8 s� �� � �
>�T�Y�Y�
>� �z��
�3�8�8�}��� �
��X�X�a�[�
� ��u�{�{�}�+�+�,=�>��"&� ��g�x� %�%?�@�G� ���!� � �M�M�$��!����7�8� �
�
���C�c�'�,�,�.�FY�Y�Z������ � � � �/�$�6� 7����*�%� �
�
���� � � �(���������� � �
�
���7��G�L�L�N�8K�K�L������ �A �� � �s�x�x�=�1� � �@�3�8�8�A�;�N� O� � ��x�x��{���8�8�A�;��s
�&F. �.AH ssh_keyfunction.py 0000644 00000000456 15173153071 0010341 0 ustar 00 import pycurl
sftp_server = 'sftp://web.sourceforge.net'
c = pycurl.Curl()
c.setopt(c.URL, sftp_server)
c.setopt(c.VERBOSE, True)
def keyfunction(known_key, found_key, match):
return c.KHSTAT_FINE
c.setopt(c.SSH_KNOWNHOSTS, '.known_hosts')
c.setopt(c.SSH_KEYFUNCTION, keyfunction)
c.perform()
file_upload.py 0000644 00000002233 15173153071 0007404 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
import os, sys
import pycurl
# Class which holds a file reference and the read callback
class FileReader:
def __init__(self, fp):
self.fp = fp
def read_callback(self, size):
return self.fp.read(size)
# Check commandline arguments
if len(sys.argv) < 3:
print("Usage: %s <url> <file to upload>" % sys.argv[0])
raise SystemExit
url = sys.argv[1]
filename = sys.argv[2]
if not os.path.exists(filename):
print("Error: the file '%s' does not exist" % filename)
raise SystemExit
# Initialize pycurl
c = pycurl.Curl()
c.setopt(pycurl.URL, url)
c.setopt(pycurl.UPLOAD, 1)
# Two versions with the same semantics here, but the filereader version
# is useful when you have to process the data which is read before returning
if 1:
c.setopt(pycurl.READFUNCTION, FileReader(open(filename, 'rb')).read_callback)
else:
c.setopt(pycurl.READFUNCTION, open(filename, 'rb').read)
# Set size of file to be uploaded.
filesize = os.path.getsize(filename)
c.setopt(pycurl.INFILESIZE, filesize)
# Start transfer
print('Uploading file %s to url %s' % (filename, url))
c.perform()
c.close()
linksys.py 0000644 00000052413 15173153072 0006623 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
#
# linksys.py -- program settings on a Linkys router
#
# This tool is designed to help you recover from the occasional episodes
# of catatonia that afflict Linksys boxes. It allows you to batch-program
# them rather than manually entering values to the Web interface. Commands
# are taken from the command line first, then standard input.
#
# The somewhat spotty coverage of status queries is because I only did the
# ones that were either (a) easy, or (b) necessary. If you want to know the
# status of the box, look at the web interface.
#
# This code has been tested against the following hardware:
#
# Hardware Firmware
# ---------- ---------------------
# BEFW11S4v2 1.44.2.1, Dec 20 2002
#
# The code is, of course, sensitive to changes in the names of CGI pages
# and field names.
#
# Note: to make the no-arguments form work, you'll need to have the following
# entry in your ~/.netrc file. If you have changed the router IP address or
# name/password, modify accordingly.
#
# machine 192.168.1.1
# login ""
# password admin
#
# By Eric S. Raymond, August April 2003. All rites reversed.
import sys, re, curl, exceptions
def print_stderr(arg):
sys.stderr.write(arg)
sys.stderr.write("\n")
class LinksysError(exceptions.Exception):
def __init__(self, *args):
self.args = args
class LinksysSession:
months = 'Jan|Feb|Mar|Apr|May|Jun|Jul|Aug|Sep|Oct|Nov|Dec'
WAN_CONNECT_AUTO = '1'
WAN_CONNECT_STATIC = '2'
WAN_CONNECT_PPOE = '3'
WAN_CONNECT_RAS = '4'
WAN_CONNECT_PPTP = '5'
WAN_CONNECT_HEARTBEAT = '6'
# Substrings to check for on each page load.
# This may enable us to detect when a firmware change has hosed us.
check_strings = {
"": "basic setup functions",
"Passwd.htm": "For security reasons,",
"DHCP.html": "You can configure the router to act as a DHCP",
"Log.html": "There are some log settings and lists in this page.",
"Forward.htm":"Port forwarding can be used to set up public services",
}
def __init__(self):
self.actions = []
self.host = "http://192.168.1.1"
self.verbosity = False
self.pagecache = {}
def set_verbosity(self, flag):
self.verbosity = flag
# This is not a performance hack -- we need the page cache to do
# sanity checks at configure time.
def cache_load(self, page):
if page not in self.pagecache:
fetch = curl.Curl(self.host)
fetch.set_verbosity(self.verbosity)
fetch.get(page)
self.pagecache[page] = fetch.body()
if fetch.answered("401"):
raise LinksysError("authorization failure.", True)
elif not fetch.answered(LinksysSession.check_strings[page]):
del self.pagecache[page]
raise LinksysError("check string for page %s missing!" % os.path.join(self.host, page), False)
fetch.close()
def cache_flush(self):
self.pagecache = {}
# Primitives
def screen_scrape(self, page, template):
self.cache_load(page)
match = re.compile(template).search(self.pagecache[page])
if match:
result = match.group(1)
else:
result = None
return result
def get_MAC_address(self, page, prefix):
return self.screen_scrape("", prefix+r":[^M]*\(MAC Address: *([^)]*)")
def set_flag(self, page, flag, value):
if value:
self.actions.append(page, flag, "1")
else:
self.actions.append(page, flag, "0")
def set_IP_address(self, page, cgi, role, ip):
ind = 0
for octet in ip.split("."):
self.actions.append(("", "F1", role + repr(ind+1), octet))
ind += 1
# Scrape configuration data off the main page
def get_firmware_version(self):
# This is fragile. There is no distinguishing tag before the firmware
# version, so we have to key off the pattern of the version number.
# Our model is ">1.44.2.1, Dec 20 2002<"
return self.screen_scrape("", ">([0-9.v]*, (" + \
LinksysSession.months + ")[^<]*)<", )
def get_LAN_MAC(self):
return self.get_MAC_address("", r"LAN IP Address")
def get_Wireless_MAC(self):
return self.get_MAC_address("", r"Wireless")
def get_WAN_MAC(self):
return self.get_MAC_address("", r"WAN Connection Type")
# Set configuration data on the main page
def set_host_name(self, name):
self.actions.append(("", "hostName", name))
def set_domain_name(self, name):
self.actions.append(("", "DomainName", name))
def set_LAN_IP(self, ip):
self.set_IP_address("", "ipAddr", ip)
def set_LAN_netmask(self, ip):
if not ip.startswith("255.255.255."):
raise ValueError
lastquad = ip.split(".")[-1]
if lastquad not in ("0", "128", "192", "240", "252"):
raise ValueError
self.actions.append("", "netMask", lastquad)
def set_wireless(self, flag):
self.set_flag("", "wirelessStatus")
def set_SSID(self, ssid):
self.actions.append(("", "wirelessESSID", ssid))
def set_SSID_broadcast(self, flag):
self.set_flag("", "broadcastSSID")
def set_channel(self, channel):
self.actions.append(("", "wirelessChannel", channel))
def set_WEP(self, flag):
self.set_flag("", "WepType")
# FIXME: Add support for setting WEP keys
def set_connection_type(self, type):
self.actions.append(("", "WANConnectionType", type))
def set_WAN_IP(self, ip):
self.set_IP_address("", "aliasIP", ip)
def set_WAN_netmask(self, ip):
self.set_IP_address("", "aliasMaskIP", ip)
def set_WAN_gateway_address(self, ip):
self.set_IP_address("", "routerIP", ip)
def set_DNS_server(self, index, ip):
self.set_IP_address("", "dns" + "ABC"[index], ip)
# Set configuration data on the password page
def set_password(self, str):
self.actions.append("Passwd.htm","sysPasswd", str)
self.actions.append("Passwd.htm","sysPasswdConfirm", str)
def set_UPnP(self, flag):
self.set_flag("Passwd.htm", "UPnP_Work")
def reset(self):
self.actions.append("Passwd.htm", "FactoryDefaults")
# DHCP features
def set_DHCP(self, flag):
if flag:
self.actions.append("DHCP.htm","dhcpStatus","Enable")
else:
self.actions.append("DHCP.htm","dhcpStatus","Disable")
def set_DHCP_starting_IP(self, val):
self.actions.append("DHCP.htm","dhcpS4", str(val))
def set_DHCP_users(self, val):
self.actions.append("DHCP.htm","dhcpLen", str(val))
def set_DHCP_lease_time(self, val):
self.actions.append("DHCP.htm","leaseTime", str(val))
def set_DHCP_DNS_server(self, index, ip):
self.set_IP_address("DHCP.htm", "dns" + "ABC"[index], ip)
# FIXME: add support for setting WINS key
# Logging features
def set_logging(self, flag):
if flag:
self.actions.append("Log.htm", "rLog", "Enable")
else:
self.actions.append("Log.htm", "rLog", "Disable")
def set_log_address(self, val):
self.actions.append("DHCP.htm","trapAddr3", str(val))
# The AOL parental control flag is not supported by design.
# FIXME: add Filters and other advanced features
def configure(self):
"Write configuration changes to the Linksys."
if self.actions:
fields = []
self.cache_flush()
for (page, field, value) in self.actions:
self.cache_load(page)
if self.pagecache[page].find(field) == -1:
print_stderr("linksys: field %s not found where expected in page %s!" % (field, os.path.join(self.host, page)))
continue
else:
fields.append((field, value))
# Clearing the action list before fieldsping is deliberate.
# Otherwise we could get permanently wedged by a 401.
self.actions = []
transaction = curl.Curl(self.host)
transaction.set_verbosity(self.verbosity)
transaction.get("Gozila.cgi", tuple(fields))
transaction.close()
if __name__ == "__main__":
import os, cmd
class LinksysInterpreter(cmd.Cmd):
"""Interpret commands to perform LinkSys programming actions."""
def __init__(self):
cmd.Cmd.__init__(self)
self.session = LinksysSession()
if os.isatty(0):
print("Type ? or `help' for help.")
self.prompt = self.session.host + ": "
else:
self.prompt = ""
print("Bar1")
def flag_command(self, func, line):
if line.strip() in ("on", "enable", "yes"):
func(True)
elif line.strip() in ("off", "disable", "no"):
func(False)
else:
print_stderr("linksys: unknown switch value")
return 0
def do_connect(self, line):
newhost = line.strip()
if newhost:
self.session.host = newhost
self.session.cache_flush()
self.prompt = self.session.host + ": "
else:
print(self.session.host)
return 0
def help_connect(self):
print("Usage: connect [<hostname-or-IP>]")
print("Connect to a Linksys by name or IP address.")
print("If no argument is given, print the current host.")
def do_status(self, line):
self.session.cache_load("")
if "" in self.session.pagecache:
print("Firmware:", self.session.get_firmware_version())
print("LAN MAC:", self.session.get_LAN_MAC())
print("Wireless MAC:", self.session.get_Wireless_MAC())
print("WAN MAC:", self.session.get_WAN_MAC())
print(".")
return 0
def help_status(self):
print("Usage: status")
print("The status command shows the status of the Linksys.")
print("It is mainly useful as a sanity check to make sure")
print("the box is responding correctly.")
def do_verbose(self, line):
self.flag_command(self.session.set_verbosity, line)
def help_verbose(self):
print("Usage: verbose {on|off|enable|disable|yes|no}")
print("Enables display of HTTP requests.")
def do_host(self, line):
self.session.set_host_name(line)
return 0
def help_host(self):
print("Usage: host <hostname>")
print("Sets the Host field to be queried by the ISP.")
def do_domain(self, line):
print("Usage: host <domainname>")
self.session.set_domain_name(line)
return 0
def help_domain(self):
print("Sets the Domain field to be queried by the ISP.")
def do_lan_address(self, line):
self.session.set_LAN_IP(line)
return 0
def help_lan_address(self):
print("Usage: lan_address <ip-address>")
print("Sets the LAN IP address.")
def do_lan_netmask(self, line):
self.session.set_LAN_netmask(line)
return 0
def help_lan_netmask(self):
print("Usage: lan_netmask <ip-mask>")
print("Sets the LAN subnetwork mask.")
def do_wireless(self, line):
self.flag_command(self.session.set_wireless, line)
return 0
def help_wireless(self):
print("Usage: wireless {on|off|enable|disable|yes|no}")
print("Switch to enable or disable wireless features.")
def do_ssid(self, line):
self.session.set_SSID(line)
return 0
def help_ssid(self):
print("Usage: ssid <string>")
print("Sets the SSID used to control wireless access.")
def do_ssid_broadcast(self, line):
self.flag_command(self.session.set_SSID_broadcast, line)
return 0
def help_ssid_broadcast(self):
print("Usage: ssid_broadcast {on|off|enable|disable|yes|no}")
print("Switch to enable or disable SSID broadcast.")
def do_channel(self, line):
self.session.set_channel(line)
return 0
def help_channel(self):
print("Usage: channel <number>")
print("Sets the wireless channel.")
def do_wep(self, line):
self.flag_command(self.session.set_WEP, line)
return 0
def help_wep(self):
print("Usage: wep {on|off|enable|disable|yes|no}")
print("Switch to enable or disable WEP security.")
def do_wan_type(self, line):
try:
type=eval("LinksysSession.WAN_CONNECT_"+line.strip().upper())
self.session.set_connection_type(type)
except ValueError:
print_stderr("linksys: unknown connection type.")
return 0
def help_wan_type(self):
print("Usage: wan_type {auto|static|ppoe|ras|pptp|heartbeat}")
print("Set the WAN connection type.")
def do_wan_address(self, line):
self.session.set_WAN_IP(line)
return 0
def help_wan_address(self):
print("Usage: wan_address <ip-address>")
print("Sets the WAN IP address.")
def do_wan_netmask(self, line):
self.session.set_WAN_netmask(line)
return 0
def help_wan_netmask(self):
print("Usage: wan_netmask <ip-mask>")
print("Sets the WAN subnetwork mask.")
def do_wan_gateway(self, line):
self.session.set_WAN_gateway(line)
return 0
def help_wan_gateway(self):
print("Usage: wan_gateway <ip-address>")
print("Sets the LAN subnetwork mask.")
def do_dns(self, line):
(index, address) = line.split()
if index in ("1", "2", "3"):
self.session.set_DNS_server(eval(index), address)
else:
print_stderr("linksys: server index out of bounds.")
return 0
def help_dns(self):
print("Usage: dns {1|2|3} <ip-mask>")
print("Sets a primary, secondary, or tertiary DNS server address.")
def do_password(self, line):
self.session.set_password(line)
return 0
def help_password(self):
print("Usage: password <string>")
print("Sets the router password.")
def do_upnp(self, line):
self.flag_command(self.session.set_UPnP, line)
return 0
def help_upnp(self):
print("Usage: upnp {on|off|enable|disable|yes|no}")
print("Switch to enable or disable Universal Plug and Play.")
def do_reset(self, line):
self.session.reset()
def help_reset(self):
print("Usage: reset")
print("Reset Linksys settings to factory defaults.")
def do_dhcp(self, line):
self.flag_command(self.session.set_DHCP, line)
def help_dhcp(self):
print("Usage: dhcp {on|off|enable|disable|yes|no}")
print("Switch to enable or disable DHCP features.")
def do_dhcp_start(self, line):
self.session.set_DHCP_starting_IP(line)
def help_dhcp_start(self):
print("Usage: dhcp_start <number>")
print("Set the start address of the DHCP pool.")
def do_dhcp_users(self, line):
self.session.set_DHCP_users(line)
def help_dhcp_users(self):
print("Usage: dhcp_users <number>")
print("Set number of address slots to allocate in the DHCP pool.")
def do_dhcp_lease(self, line):
self.session.set_DHCP_lease(line)
def help_dhcp_lease(self):
print("Usage: dhcp_lease <number>")
print("Set number of address slots to allocate in the DHCP pool.")
def do_dhcp_dns(self, line):
(index, address) = line.split()
if index in ("1", "2", "3"):
self.session.set_DHCP_DNS_server(eval(index), address)
else:
print_stderr("linksys: server index out of bounds.")
return 0
def help_dhcp_dns(self):
print("Usage: dhcp_dns {1|2|3} <ip-mask>")
print("Sets primary, secondary, or tertiary DNS server address.")
def do_logging(self, line):
self.flag_command(self.session.set_logging, line)
def help_logging(self):
print("Usage: logging {on|off|enable|disable|yes|no}")
print("Switch to enable or disable session logging.")
def do_log_address(self, line):
self.session.set_Log_address(line)
def help_log_address(self):
print("Usage: log_address <number>")
print("Set the last quad of the address to which to log.")
def do_configure(self, line):
self.session.configure()
return 0
def help_configure(self):
print("Usage: configure")
print("Writes the configuration to the Linksys.")
def do_cache(self, line):
print(self.session.pagecache)
def help_cache(self):
print("Usage: cache")
print("Display the page cache.")
def do_quit(self, line):
return 1
def help_quit(self, line):
print("The quit command ends your linksys session without")
print("writing configuration changes to the Linksys.")
def do_EOF(self, line):
print("")
self.session.configure()
return 1
def help_EOF(self):
print("The EOF command writes the configuration to the linksys")
print("and ends your session.")
def default(self, line):
"""Pass the command through to be executed by the shell."""
os.system(line)
return 0
def help_help(self):
print("On-line help is available through this command.")
print("? is a convenience alias for help.")
def help_introduction(self):
print("""\
This program supports changing the settings on Linksys blue-box routers. This
capability may come in handy when they freeze up and have to be reset. Though
it can be used interactively (and will command-prompt when standard input is a
terminal) it is really designed to be used in batch mode. Commands are taken
from the command line first, then standard input.
By default, it is assumed that the Linksys is at http://192.168.1.1, the
default LAN address. You can connect to a different address or IP with the
'connect' command. Note that your .netrc must contain correct user/password
credentials for the router. The entry corresponding to the defaults is:
machine 192.168.1.1
login ""
password admin
Most commands queue up changes but don't actually send them to the Linksys.
You can force pending changes to be written with 'configure'. Otherwise, they
will be shipped to the Linksys at the end of session (e.g. when the program
running in batch mode encounters end-of-file or you type a control-D). If you
end the session with `quit', pending changes will be discarded.
For more help, read the topics 'wan', 'lan', and 'wireless'.""")
def help_lan(self):
print("""\
The `lan_address' and `lan_netmask' commands let you set the IP location of
the Linksys on your LAN, or inside. Normally you'll want to leave these
untouched.""")
def help_wan(self):
print("""\
The WAN commands become significant if you are using the BEFSR41 or any of
the other Linksys boxes designed as DSL or cable-modem gateways. You will
need to use `wan_type' to declare how you expect to get your address.
If your ISP has issued you a static address, you'll need to use the
`wan_address', `wan_netmask', and `wan_gateway' commands to set the address
of the router as seen from the WAN, the outside. In this case you will also
need to use the `dns' command to declare which remote servers your DNS
requests should be forwarded to.
Some ISPs may require you to set host and domain for use with dynamic-address
allocation.""")
def help_wireless_desc(self):
print("""\
The channel, ssid, ssid_broadcast, wep, and wireless commands control
wireless routing.""")
def help_switches(self):
print("Switches may be turned on with 'on', 'enable', or 'yes'.")
print("Switches may be turned off with 'off', 'disable', or 'no'.")
print("Switch commands include: wireless, ssid_broadcast.")
def help_addresses(self):
print("An address argument must be a valid IP address;")
print("four decimal numbers separated by dots, each ")
print("between 0 and 255.")
def emptyline(self):
pass
interpreter = LinksysInterpreter()
for arg in sys.argv[1:]:
interpreter.onecmd(arg)
fatal = False
while not fatal:
try:
interpreter.cmdloop()
fatal = True
except LinksysError:
message, fatal = sys.exc_info()[1].args
print("linksys: " + message)
# The following sets edit modes for GNU EMACS
# Local Variables:
# mode:python
# End:
sfquery.py 0000644 00000004631 15173153072 0006624 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
#
# sfquery -- Source Forge query script using the ClientCGI high-level interface
#
# Retrieves a SourceForge XML export object for a given project.
# Specify the *numeric* project ID. the user name, and the password,
# as arguments. If you have a valid ~/.netrc entry for sourceforge.net,
# you can just give the project ID.
#
# By Eric S. Raymond, August 2002. All rites reversed.
import sys, netrc
import curl
class SourceForgeUserSession(curl.Curl):
# SourceForge-specific methods. Sensitive to changes in site design.
def login(self, name, password):
"Establish a login session."
self.post("account/login.php", (("form_loginname", name),
("form_pw", password),
("return_to", ""),
("stay_in_ssl", "1"),
("login", "Login With SSL")))
def logout(self):
"Log out of SourceForge."
self.get("account/logout.php")
def fetch_xml(self, numid):
self.get("export/xml_export.php?group_id=%s" % numid)
if __name__ == "__main__":
if len(sys.argv) == 1:
project_id = '28236' # PyCurl project ID
else:
project_id = sys.argv[1]
# Try to grab authenticators out of your .netrc
try:
auth = netrc.netrc().authenticators("sourceforge.net")
name, account, password = auth
except:
if len(sys.argv) < 4:
print("Usage: %s <project id> <username> <password>" % sys.argv[0])
raise SystemExit
name = sys.argv[2]
password = sys.argv[3]
session = SourceForgeUserSession("https://sourceforge.net/")
session.set_verbosity(0)
session.login(name, password)
# Login could fail.
if session.answered("Invalid Password or User Name"):
sys.stderr.write("Login/password not accepted (%d bytes)\n" % len(session.body()))
sys.exit(1)
# We'll see this if we get the right thing.
elif session.answered("Personal Page For: " + name):
session.fetch_xml(project_id)
sys.stdout.write(session.body())
session.logout()
sys.exit(0)
# Or maybe SourceForge has changed its site design so our check strings
# are no longer valid.
else:
sys.stderr.write("Unexpected page (%d bytes)\n"%len(session.body()))
sys.exit(1)
retriever.py 0000644 00000005151 15173153072 0007133 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
#
# Usage: python retriever.py <file with URLs to fetch> [<# of
# concurrent connections>]
#
import sys, threading
try:
import Queue
except ImportError:
import queue as Queue
import pycurl
# We should ignore SIGPIPE when using pycurl.NOSIGNAL - see
# the libcurl tutorial for more info.
try:
import signal
from signal import SIGPIPE, SIG_IGN
except ImportError:
pass
else:
signal.signal(SIGPIPE, SIG_IGN)
# Get args
num_conn = 10
try:
if sys.argv[1] == "-":
urls = sys.stdin.readlines()
else:
urls = open(sys.argv[1]).readlines()
if len(sys.argv) >= 3:
num_conn = int(sys.argv[2])
except:
print("Usage: %s <file with URLs to fetch> [<# of concurrent connections>]" % sys.argv[0])
raise SystemExit
# Make a queue with (url, filename) tuples
queue = Queue.Queue()
for url in urls:
url = url.strip()
if not url or url[0] == "#":
continue
filename = "doc_%03d.dat" % (len(queue.queue) + 1)
queue.put((url, filename))
# Check args
assert queue.queue, "no URLs given"
num_urls = len(queue.queue)
num_conn = min(num_conn, num_urls)
assert 1 <= num_conn <= 10000, "invalid number of concurrent connections"
print("PycURL %s (compiled against 0x%x)" % (pycurl.version, pycurl.COMPILE_LIBCURL_VERSION_NUM))
print("----- Getting", num_urls, "URLs using", num_conn, "connections -----")
class WorkerThread(threading.Thread):
def __init__(self, queue):
threading.Thread.__init__(self)
self.queue = queue
def run(self):
while 1:
try:
url, filename = self.queue.get_nowait()
except Queue.Empty:
raise SystemExit
fp = open(filename, "wb")
curl = pycurl.Curl()
curl.setopt(pycurl.URL, url)
curl.setopt(pycurl.FOLLOWLOCATION, 1)
curl.setopt(pycurl.MAXREDIRS, 5)
curl.setopt(pycurl.CONNECTTIMEOUT, 30)
curl.setopt(pycurl.TIMEOUT, 300)
curl.setopt(pycurl.NOSIGNAL, 1)
curl.setopt(pycurl.WRITEDATA, fp)
try:
curl.perform()
except:
import traceback
traceback.print_exc(file=sys.stderr)
sys.stderr.flush()
curl.close()
fp.close()
sys.stdout.write(".")
sys.stdout.flush()
# Start a bunch of threads
threads = []
for dummy in range(num_conn):
t = WorkerThread(queue)
t.start()
threads.append(t)
# Wait for all threads to finish
for thread in threads:
thread.join()
retriever-multi.py 0000644 00000006437 15173153073 0010274 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
#
# Usage: python retriever-multi.py <file with URLs to fetch> [<# of
# concurrent connections>]
#
import sys
import pycurl
# We should ignore SIGPIPE when using pycurl.NOSIGNAL - see
# the libcurl tutorial for more info.
try:
import signal
from signal import SIGPIPE, SIG_IGN
except ImportError:
pass
else:
signal.signal(SIGPIPE, SIG_IGN)
# Get args
num_conn = 10
try:
if sys.argv[1] == "-":
urls = sys.stdin.readlines()
else:
urls = open(sys.argv[1]).readlines()
if len(sys.argv) >= 3:
num_conn = int(sys.argv[2])
except:
print("Usage: %s <file with URLs to fetch> [<# of concurrent connections>]" % sys.argv[0])
raise SystemExit
# Make a queue with (url, filename) tuples
queue = []
for url in urls:
url = url.strip()
if not url or url[0] == "#":
continue
filename = "doc_%03d.dat" % (len(queue) + 1)
queue.append((url, filename))
# Check args
assert queue, "no URLs given"
num_urls = len(queue)
num_conn = min(num_conn, num_urls)
assert 1 <= num_conn <= 10000, "invalid number of concurrent connections"
print("PycURL %s (compiled against 0x%x)" % (pycurl.version, pycurl.COMPILE_LIBCURL_VERSION_NUM))
print("----- Getting", num_urls, "URLs using", num_conn, "connections -----")
# Pre-allocate a list of curl objects
m = pycurl.CurlMulti()
m.handles = []
for i in range(num_conn):
c = pycurl.Curl()
c.fp = None
c.setopt(pycurl.FOLLOWLOCATION, 1)
c.setopt(pycurl.MAXREDIRS, 5)
c.setopt(pycurl.CONNECTTIMEOUT, 30)
c.setopt(pycurl.TIMEOUT, 300)
c.setopt(pycurl.NOSIGNAL, 1)
m.handles.append(c)
# Main loop
freelist = m.handles[:]
num_processed = 0
while num_processed < num_urls:
# If there is an url to process and a free curl object, add to multi stack
while queue and freelist:
url, filename = queue.pop(0)
c = freelist.pop()
c.fp = open(filename, "wb")
c.setopt(pycurl.URL, url)
c.setopt(pycurl.WRITEDATA, c.fp)
m.add_handle(c)
# store some info
c.filename = filename
c.url = url
# Run the internal curl state machine for the multi stack
while 1:
ret, num_handles = m.perform()
if ret != pycurl.E_CALL_MULTI_PERFORM:
break
# Check for curl objects which have terminated, and add them to the freelist
while 1:
num_q, ok_list, err_list = m.info_read()
for c in ok_list:
c.fp.close()
c.fp = None
m.remove_handle(c)
print("Success:", c.filename, c.url, c.getinfo(pycurl.EFFECTIVE_URL))
freelist.append(c)
for c, errno, errmsg in err_list:
c.fp.close()
c.fp = None
m.remove_handle(c)
print("Failed: ", c.filename, c.url, errno, errmsg)
freelist.append(c)
num_processed = num_processed + len(ok_list) + len(err_list)
if num_q == 0:
break
# Currently no more I/O is pending, could do something in the meantime
# (display a progress bar, etc.).
# We just call select() to sleep until some more data is available.
m.select(1.0)
# Cleanup
for c in m.handles:
if c.fp is not None:
c.fp.close()
c.fp = None
c.close()
m.close()
smtp.py 0000644 00000002113 15173153073 0006103 0 ustar 00 # Based on the simple libcurl SMTP example:
# https://github.com/bagder/curl/blob/master/docs/examples/smtp-mail.c
# There are other SMTP examples in that directory that you may find helpful.
from . import localhost
import pycurl
try:
from io import BytesIO
except ImportError:
from StringIO import StringIO as BytesIO
import sys
PY3 = sys.version_info[0] > 2
mail_server = 'smtp://%s' % localhost
mail_from = 'sender@example.org'
mail_to = 'addressee@example.net'
c = pycurl.Curl()
c.setopt(c.URL, mail_server)
c.setopt(c.MAIL_FROM, mail_from)
c.setopt(c.MAIL_RCPT, [mail_to])
message = '''\
From: %s
To: %s
Subject: PycURL SMTP example
SMTP example via PycURL
''' % (mail_from, mail_to)
if PY3:
message = message.encode('ascii')
# libcurl does not perform buffering, therefore
# we need to wrap the message string into a BytesIO or StringIO.
io = BytesIO(message)
c.setopt(c.READDATA, io)
# If UPLOAD is not set, libcurl performs SMTP VRFY.
# Setting UPLOAD to True sends a message.
c.setopt(c.UPLOAD, True)
# Observe SMTP conversation.
c.setopt(c.VERBOSE, True)
c.perform()
quickstart/put_buffer.py 0000644 00000000730 15173153073 0011456 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
import pycurl
try:
from io import BytesIO
except ImportError:
from StringIO import StringIO as BytesIO
c = pycurl.Curl()
c.setopt(c.URL, 'https://httpbin.org/put')
c.setopt(c.UPLOAD, 1)
data = '{"json":true}'
# READDATA requires an IO-like object; a string is not accepted
# encode() is necessary for Python 3
buffer = BytesIO(data.encode('utf-8'))
c.setopt(c.READDATA, buffer)
c.perform()
c.close()
quickstart/follow_redirect.py 0000644 00000000372 15173153074 0012503 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
import pycurl
c = pycurl.Curl()
# Redirects to https://www.python.org/.
c.setopt(c.URL, 'http://www.python.org/')
# Follow redirect.
c.setopt(c.FOLLOWLOCATION, True)
c.perform()
c.close()
quickstart/file_upload_real_fancy.py 0000644 00000000743 15173153074 0013770 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
import pycurl
c = pycurl.Curl()
c.setopt(c.URL, 'https://httpbin.org/post')
c.setopt(c.HTTPPOST, [
('fileupload', (
# upload the contents of this file
c.FORM_FILE, __file__,
# specify a different file name for the upload
c.FORM_FILENAME, 'helloworld.py',
# specify a different content type
c.FORM_CONTENTTYPE, 'application/x-python',
)),
])
c.perform()
c.close()
quickstart/__pycache__/get.cpython-312.pyc 0000644 00000001574 15173153074 0014445 0 ustar 00 �
���gG � �j � d dl Z d dlmZ e� Z e j � Zej ej d� ej ej e� ej � ej � ej � Z eej! d� � y# e$ r d dlmZ Y ��w xY w)� N)�BytesIO)�StringIOzhttp://pycurl.io/z
iso-8859-1)�pycurl�ior � ImportErrorr �buffer�Curl�c�setopt�URL� WRITEDATA�perform�close�getvalue�body�print�decode� � �b/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/quickstart/get.py�<module>r s� ��
�-��
����F�K�K�M�� ������#� $� ������f� � � � � � ��� �
����� �d�k�k�,� � ��! � -�,�-�s �B$ �$ B2�1B2 quickstart/__pycache__/file_upload_real.cpython-312.pyc 0000644 00000001243 15173153074 0017145 0 ustar 00 �
���g# � � � d dl Z e j � Zej ej d� ej ej
dej effg� ej � ej � y)� Nzhttps://httpbin.org/post�
fileupload)
�pycurl�Curl�c�setopt�URL�HTTPPOST� FORM_FILE�__file__�perform�close� � �o/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/quickstart/file_upload_real.py�<module>r sk ��
��F�K�K�M�� ������*� +� ������� � � �X�� �� � � � � � ��� r quickstart/__pycache__/get_python2.cpython-312.pyc 0000644 00000001327 15173153075 0016125 0 ustar 00 �
���g� � �( � d dl Z d dlmZ e� Z e j � Zej ej d� ej ej e� ej � ej � ej � Z e e � y)� N)�StringIOzhttp://pycurl.io/)
�pycurlr �buffer�Curl�c�setopt�URL� WRITEDATA�perform�close�getvalue�body�print� � �j/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/quickstart/get_python2.py�<module>r so ��
� � ����F�K�K�M�� ������#� $� ������f� � � � � � ��� �
����� �d� r quickstart/__pycache__/file_upload_buffer.cpython-312.pyc 0000644 00000001372 15173153075 0017477 0 ustar 00 �
���g7 � � � d dl Z e j � Zej ej d� ej ej
dej dej dffg� ej � ej � y)� Nzhttps://httpbin.org/post�
fileuploadz
readme.txtzThis is a fancy readme file)
�pycurl�Curl�c�setopt�URL�HTTPPOST� FORM_BUFFER�FORM_BUFFERPTR�perform�close� � �q/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/quickstart/file_upload_buffer.py�<module>r sw ��
��F�K�K�M�� ������*� +� ������� �
�
�|� ���7�� �� � � � � � ��� r quickstart/__pycache__/response_headers.cpython-312.pyc 0000644 00000003651 15173153075 0017216 0 ustar 00 �
���g1 � �| � d dl Z d dlZ d dlmZ i Zd� Z e� Z e j � Z
e
j e
j d� e
j e
j ej � e
j e
j e� e
j! � e
j# � dZdev rDed j' � Z ej* de� Zer ej/ d� Z ed ez � e�
d
Z ed ez � ej3 � Z eej7 e� � y# e$ r
d dlmZ Y ��*w xY w) � N)�BytesIO)�StringIOc �� � | j d� } d| vry | j dd� \ }}|j � }|j � }|j � }|t |< y )N�
iso-8859-1�:� )�decode�split�strip�lower�headers)� header_line�name�values �o/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/quickstart/response_headers.py�header_functionr
si � � �$�$�\�2�K�
�+� �� �#�#�C��+�K�D�%�
�:�:�<�D� �K�K�M�E� �:�:�<�D� �G�D�M� zhttp://pycurl.ioz content-typez
charset=(\S+)r zDecoding using %sr zAssuming encoding is %s) �pycurl�re�ior � ImportErrorr r
r �buffer�Curl�c�setopt�URL�
WRITEFUNCTION�write�HEADERFUNCTION�perform�close�encodingr � content_type�search�match�group�print�getvalue�bodyr � r r �<module>r+ s( ��
� �-��
���8
����F�K�K�M�� ������"� #� ���� � �&�,�,� '� ���� � �?� +� � � � � ��� � ���W� ��>�*�0�0�2�L� �B�I�I�o�|� 4�E� ��;�;�q�>��
�!�H�,�-� �� �H� �
#�h�
.�/�
����� �d�k�k�(�� ��w � -�,�,�-�s �D, �, D;�:D; quickstart/__pycache__/get_python2_https.cpython-312.pyc 0000644 00000001560 15173153075 0017346 0 ustar 00 �
���g� � � � d dl Z d dlZd dlmZ e� Z e j � Zej
ej d� ej
ej e� ej
ej ej � � ej � ej � ej � Z ee� y)� N)�StringIOzhttp://pycurl.io/)�pycurl�certifir �buffer�Curl�c�setopt�URL� WRITEDATA�CAINFO�where�perform�close�getvalue�body�print� � �p/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/quickstart/get_python2_https.py�<module>r s� ��
� � � ����F�K�K�M�� ������#� $� ������f� � ������=�7�=�=�?� #� � � � � ��� �
����� �d� r quickstart/__pycache__/form_post.cpython-312.pyc 0000644 00000001451 15173153076 0015672 0 ustar 00 �
���g4 � �& � d dl Z d dlmZ e j
� Zej ej d� ddiZ ee � Z
ej ej e
� ej � ej � y# e$ r d dlmZ Y ��w xY w)� N)� urlencodezhttps://httpbin.org/post�field�value)�pycurl� urllib.parser � ImportError�urllib�Curl�c�setopt�URL� post_data�
postfields�
POSTFIELDS�perform�close� � �h/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/quickstart/form_post.py�<module>r s� ��
�!�&�
�F�K�K�M�� ������*� +�
�g� � �
�y�
!�
� ���� � �z� "� � � � � ��� ��! � !� �!�s �B � B�B quickstart/__pycache__/file_upload_real_fancy.cpython-312.pyc 0000644 00000001464 15173153076 0020334 0 ustar 00 �
���g� �
�, � d dl Z e j � Zej ej d� ej ej
dej eej dej dffg� ej � ej � y)� Nzhttps://httpbin.org/post�
fileuploadz
helloworld.pyzapplication/x-python) �pycurl�Curl�c�setopt�URL�HTTPPOST� FORM_FILE�__file__�
FORM_FILENAME�FORM_CONTENTTYPE�perform�close� � �u/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/quickstart/file_upload_real_fancy.py�<module>r s� ��
��F�K�K�M�� ������*� +� ������� � � �X� ��� � ��� 2�
� � � � � � � � ��� r quickstart/__pycache__/write_file.cpython-312.pyc 0000644 00000001264 15173153076 0016015 0 ustar 00 �
���ge � � � d dl Z edd� 5 Z e j � Zej ej d� ej ej e� ej � ej � ddd� y# 1 sw Y yxY w)� Nzout.html�wbzhttp://pycurl.io/)
�pycurl�open�f�Curl�c�setopt�URL� WRITEDATA�perform�close� � �i/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/quickstart/write_file.py�<module>r sh ��
�
�*�d��q��� � �
�A��H�H�Q�U�U�'�(��H�H�Q�[�[�!� ��I�I�K��G�G�I� ���s �A*B�B
quickstart/__pycache__/put_buffer.cpython-312.pyc 0000644 00000001640 15173153076 0016023 0 ustar 00 �
���g� � �x � d dl Z d dlmZ e j
� Zej ej d� ej ej d� dZ
ee
j d� � Z ej ej e � ej � ej � y# e$ r d dlmZ Y ��w xY w)� N)�BytesIO)�StringIOzhttps://httpbin.org/put� z
{"json":true}zutf-8)�pycurl�ior � ImportErrorr �Curl�c�setopt�URL�UPLOAD�data�encode�buffer�READDATA�perform�close� � �i/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/quickstart/put_buffer.py�<module>r s� ��
�-�� �F�K�K�M�� ������)� *� ������1� ���
����W�%� &�� ������V� � � � � � ��� �� � -�,�-�s �B+ �+ B9�8B9 quickstart/__pycache__/get_python3.cpython-312.pyc 0000644 00000001424 15173153077 0016126 0 ustar 00 �
���g� � �F � d dl Z d dlmZ e� Z e j � Zej
ej d� ej
ej e� ej � ej � ej � Z e
e j d� � y)� N)�BytesIOzhttp://pycurl.io/z
iso-8859-1)�pycurl�ior �buffer�Curl�c�setopt�URL� WRITEDATA�perform�close�getvalue�body�print�decode� � �j/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/quickstart/get_python3.py�<module>r sw ��
� � ����F�K�K�M�� ������#� $� ������f� � � � � � ��� �
����� �d�k�k�,� � r quickstart/__pycache__/follow_redirect.cpython-312.pyc 0000644 00000001115 15173153077 0017043 0 ustar 00 �
���g� � �� � d dl Z e j � Zej ej d� ej ej
d� ej
� ej � y)� Nzhttp://www.python.org/T)�pycurl�Curl�c�setopt�URL�FOLLOWLOCATION�perform�close� � �n/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/quickstart/follow_redirect.py�<module>r sP ��
��F�K�K�M�� ������(� )� ���� � �4� � � � � � ��� r quickstart/__pycache__/get_python3_https.cpython-312.pyc 0000644 00000001655 15173153077 0017356 0 ustar 00 �
���g� � � � d dl Z d dlZd dlmZ e� Z e j
� Zej ej d� ej ej e� ej ej ej � � ej � ej � ej � Z eej# d� � y)� N)�BytesIOzhttp://pycurl.io/z
iso-8859-1)�pycurl�certifi�ior �buffer�Curl�c�setopt�URL� WRITEDATA�CAINFO�where�perform�close�getvalue�body�print�decode� � �p/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/quickstart/get_python3_https.py�<module>r s� ��
� � � ����F�K�K�M�� ������#� $� ������f� � ������=�7�=�=�?� #� � � � � ��� �
����� �d�k�k�,� � r quickstart/__pycache__/put_file.cpython-312.pyc 0000644 00000001355 15173153077 0015475 0 ustar 00 �
���g, � �F � d dl Z e j � Zej ej d� ej ej
d� ee� Zej ej e� ej � ej � ej � y)� Nzhttps://httpbin.org/put� ) �pycurl�Curl�c�setopt�URL�UPLOAD�open�__file__�file�READDATA�perform�close� � �g/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/quickstart/put_file.py�<module>r sr ��
��F�K�K�M�� ������)� *� ������1� � �H�~�� ������T� � � � � � ��� � �
�
� r quickstart/__pycache__/response_info.cpython-312.pyc 0000644 00000001765 15173153077 0016544 0 ustar 00 �
���g� � � � d dl Z d dlmZ e� Z e j � Zej ej d� ej ej e� ej � e dej ej � z � e dej ej � z � ej! � y# e$ r d dlmZ Y ��w xY w)� N)�BytesIO)�StringIOzhttp://pycurl.io/z
Status: %dzTime: %f)�pycurl�ior � ImportErrorr �buffer�Curl�c�setopt�URL� WRITEDATA�perform�print�getinfo�
RESPONSE_CODE�
TOTAL_TIME�close� � �l/opt/hc_python/lib64/python3.12/site-packages/../../../share/doc/pycurl/examples/quickstart/response_info.py�<module>r s� ��
�-��
����F�K�K�M�� ������#� $� ������f� � � � � � �l�Q�Y�Y�q���/�/� 0� �j�1�9�9�Q�\�\�*�*� +� ��� �� � -�,�-�s �C � C�C quickstart/put_file.py 0000644 00000000454 15173153077 0011133 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
import pycurl
c = pycurl.Curl()
c.setopt(c.URL, 'https://httpbin.org/put')
c.setopt(c.UPLOAD, 1)
file = open(__file__)
c.setopt(c.READDATA, file)
c.perform()
c.close()
# File must be kept open while Curl object is using it
file.close()
quickstart/get_python3_https.py 0000644 00000000706 15173153077 0013011 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
import pycurl
import certifi
from io import BytesIO
buffer = BytesIO()
c = pycurl.Curl()
c.setopt(c.URL, 'http://pycurl.io/')
c.setopt(c.WRITEDATA, buffer)
c.setopt(c.CAINFO, certifi.where())
c.perform()
c.close()
body = buffer.getvalue()
# Body is a byte string.
# We have to know the encoding in order to print it to a text file
# such as standard output.
print(body.decode('iso-8859-1'))
quickstart/write_file.py 0000644 00000000545 15173153100 0011441 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
import pycurl
# As long as the file is opened in binary mode, both Python 2 and Python 3
# can write response body to it without decoding.
with open('out.html', 'wb') as f:
c = pycurl.Curl()
c.setopt(c.URL, 'http://pycurl.io/')
c.setopt(c.WRITEDATA, f)
c.perform()
c.close()
quickstart/get_python3.py 0000644 00000000623 15173153100 0011550 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
import pycurl
from io import BytesIO
buffer = BytesIO()
c = pycurl.Curl()
c.setopt(c.URL, 'http://pycurl.io/')
c.setopt(c.WRITEDATA, buffer)
c.perform()
c.close()
body = buffer.getvalue()
# Body is a byte string.
# We have to know the encoding in order to print it to a text file
# such as standard output.
print(body.decode('iso-8859-1'))
quickstart/form_post.py 0000644 00000001064 15173153100 0011315 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
import pycurl
try:
# python 3
from urllib.parse import urlencode
except ImportError:
# python 2
from urllib import urlencode
c = pycurl.Curl()
c.setopt(c.URL, 'https://httpbin.org/post')
post_data = {'field': 'value'}
# Form data must be provided already urlencoded.
postfields = urlencode(post_data)
# Sets request method to POST,
# Content-Type header to application/x-www-form-urlencoded
# and data to send in request body.
c.setopt(c.POSTFIELDS, postfields)
c.perform()
c.close()
quickstart/file_upload_buffer.py 0000644 00000000467 15173153100 0013127 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
import pycurl
c = pycurl.Curl()
c.setopt(c.URL, 'https://httpbin.org/post')
c.setopt(c.HTTPPOST, [
('fileupload', (
c.FORM_BUFFER, 'readme.txt',
c.FORM_BUFFERPTR, 'This is a fancy readme file',
)),
])
c.perform()
c.close()
quickstart/get_python2_https.py 0000644 00000000762 15173153100 0012775 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
import pycurl
import certifi
from StringIO import StringIO
buffer = StringIO()
c = pycurl.Curl()
c.setopt(c.URL, 'http://pycurl.io/')
c.setopt(c.WRITEDATA, buffer)
# For older PycURL versions:
#c.setopt(c.WRITEFUNCTION, buffer.write)
c.setopt(c.CAINFO, certifi.where())
c.perform()
c.close()
body = buffer.getvalue()
# Body is a string in some encoding.
# In Python 2, we can print it without knowing what the encoding is.
print(body)
quickstart/file_upload_real.py 0000644 00000000443 15173153100 0012573 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
import pycurl
c = pycurl.Curl()
c.setopt(c.URL, 'https://httpbin.org/post')
c.setopt(c.HTTPPOST, [
('fileupload', (
# upload the contents of this file
c.FORM_FILE, __file__,
)),
])
c.perform()
c.close()
quickstart/get_python2.py 0000644 00000000677 15173153100 0011560 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
import pycurl
from StringIO import StringIO
buffer = StringIO()
c = pycurl.Curl()
c.setopt(c.URL, 'http://pycurl.io/')
c.setopt(c.WRITEDATA, buffer)
# For older PycURL versions:
#c.setopt(c.WRITEFUNCTION, buffer.write)
c.perform()
c.close()
body = buffer.getvalue()
# Body is a string in some encoding.
# In Python 2, we can print it without knowing what the encoding is.
print(body)
quickstart/response_headers.py 0000644 00000004061 15173153100 0012636 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
import pycurl
import re
try:
from io import BytesIO
except ImportError:
from StringIO import StringIO as BytesIO
headers = {}
def header_function(header_line):
# HTTP standard specifies that headers are encoded in iso-8859-1.
# On Python 2, decoding step can be skipped.
# On Python 3, decoding step is required.
header_line = header_line.decode('iso-8859-1')
# Header lines include the first status line (HTTP/1.x ...).
# We are going to ignore all lines that don't have a colon in them.
# This will botch headers that are split on multiple lines...
if ':' not in header_line:
return
# Break the header line into header name and value.
name, value = header_line.split(':', 1)
# Remove whitespace that may be present.
# Header lines include the trailing newline, and there may be whitespace
# around the colon.
name = name.strip()
value = value.strip()
# Header names are case insensitive.
# Lowercase name here.
name = name.lower()
# Now we can actually record the header name and value.
headers[name] = value
buffer = BytesIO()
c = pycurl.Curl()
c.setopt(c.URL, 'http://pycurl.io')
c.setopt(c.WRITEFUNCTION, buffer.write)
# Set our header function.
c.setopt(c.HEADERFUNCTION, header_function)
c.perform()
c.close()
# Figure out what encoding was sent with the response, if any.
# Check against lowercased header name.
encoding = None
if 'content-type' in headers:
content_type = headers['content-type'].lower()
match = re.search('charset=(\S+)', content_type)
if match:
encoding = match.group(1)
print('Decoding using %s' % encoding)
if encoding is None:
# Default encoding for HTML is iso-8859-1.
# Other content types may have different default encoding,
# or in case of binary data, may have no encoding at all.
encoding = 'iso-8859-1'
print('Assuming encoding is %s' % encoding)
body = buffer.getvalue()
# Decode using the encoding we figured out.
print(body.decode(encoding))
quickstart/response_info.py 0000644 00000000762 15173153100 0012162 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
import pycurl
try:
from io import BytesIO
except ImportError:
from StringIO import StringIO as BytesIO
buffer = BytesIO()
c = pycurl.Curl()
c.setopt(c.URL, 'http://pycurl.io/')
c.setopt(c.WRITEDATA, buffer)
c.perform()
# HTTP response code, e.g. 200.
print('Status: %d' % c.getinfo(c.RESPONSE_CODE))
# Elapsed time for the transfer.
print('Time: %f' % c.getinfo(c.TOTAL_TIME))
# getinfo must be called before close.
c.close()
quickstart/get.py 0000644 00000001107 15173153101 0010063 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
import pycurl
try:
from io import BytesIO
except ImportError:
from StringIO import StringIO as BytesIO
buffer = BytesIO()
c = pycurl.Curl()
c.setopt(c.URL, 'http://pycurl.io/')
c.setopt(c.WRITEDATA, buffer)
# For older PycURL versions:
#c.setopt(c.WRITEFUNCTION, buffer.write)
c.perform()
c.close()
body = buffer.getvalue()
# Body is a string on Python 2 and a byte string on Python 3.
# If we know the encoding, we can always decode the body and
# end up with a Unicode string.
print(body.decode('iso-8859-1'))
basicfirst.py 0000644 00000001041 15173153101 0007240 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
import sys
import pycurl
PY3 = sys.version_info[0] > 2
class Test:
def __init__(self):
self.contents = ''
if PY3:
self.contents = self.contents.encode('ascii')
def body_callback(self, buf):
self.contents = self.contents + buf
sys.stderr.write("Testing %s\n" % pycurl.version)
t = Test()
c = pycurl.Curl()
c.setopt(c.URL, 'https://curl.haxx.se/dev/')
c.setopt(c.WRITEFUNCTION, t.body_callback)
c.perform()
c.close()
print(t.contents)
xmlrpc_curl.py 0000644 00000004203 15173153102 0007445 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
# We should ignore SIGPIPE when using pycurl.NOSIGNAL - see
# the libcurl tutorial for more info.
try:
import signal
from signal import SIGPIPE, SIG_IGN
except ImportError:
pass
else:
signal.signal(SIGPIPE, SIG_IGN)
try:
from cStringIO import StringIO
except ImportError:
try:
from StringIO import StringIO
except ImportError:
from io import StringIO
try:
import xmlrpclib
except ImportError:
import xmlrpc.client as xmlrpclib
import pycurl
import sys
PY3 = sys.version_info[0] > 2
class CURLTransport(xmlrpclib.Transport):
"""Handles a cURL HTTP transaction to an XML-RPC server."""
xmlrpc_h = [ "Content-Type: text/xml" ]
def __init__(self, username=None, password=None):
self.c = pycurl.Curl()
self.c.setopt(pycurl.POST, 1)
self.c.setopt(pycurl.NOSIGNAL, 1)
self.c.setopt(pycurl.CONNECTTIMEOUT, 30)
self.c.setopt(pycurl.HTTPHEADER, self.xmlrpc_h)
if username != None and password != None:
self.c.setopt(pycurl.USERPWD, '%s:%s' % (username, password))
self._use_datetime = False
def request(self, host, handler, request_body, verbose=0):
b = StringIO()
self.c.setopt(pycurl.URL, 'http://%s%s' % (host, handler))
self.c.setopt(pycurl.POSTFIELDS, request_body)
self.c.setopt(pycurl.WRITEFUNCTION, b.write)
self.c.setopt(pycurl.VERBOSE, verbose)
self.verbose = verbose
try:
self.c.perform()
except pycurl.error:
v = sys.exc_info()[1]
if PY3:
v = v.args
raise xmlrpclib.ProtocolError(
host + handler,
v[0], v[1], None
)
b.seek(0)
return self.parse_response(b)
if __name__ == "__main__":
## Test
server = xmlrpclib.ServerProxy("http://betty.userland.com",
transport=CURLTransport())
print(server)
try:
print(server.examples.getStateName(41))
except xmlrpclib.Error:
v = sys.exc_info()[1]
print("ERROR", v)
multi-socket_action-select.py 0000644 00000017477 15173153102 0012366 0 ustar 00 #! /usr/bin/env python
# -*- coding: utf-8 -*-
# vi:ts=4:et
# Retrieves a single URL using the CurlMulti.socket_action calls, using
# select as the I/O polling mechanism:
#
# First, create a Multi object, and set socket and timer callbacks on it.
# Observed side effect: this causes the timer callback to be immediately
# invoked with the zero value for the timeout.
#
# The timer callback is very simple - it stores the timeout value passed
# into it in the global state for future use by the select calls that
# we will be making.
#
# The socket callback is more complicated. Its job is to add and remove
# socket handles to/from the data structure that we use for waiting for
# activity on them. The callback is invoked with a socket handle and the
# needed action (add for reading, add for writing or remove).
# Since this script utilizes the select call for waiting for activity,
# the socket callback updates the list of sockets which we should be
# polling for readability and the list that we should be polling for
# writability, which are then passed to the select call (and both of the
# sets are passed as the sockets to wait for errors/exceptions on).
#
# Next, create a Curl object (mapping to a libcurl easy handle), set the URL
# we are going to retrieve as well as any transfer options. This script sets
# the timeout to 5 seconds to be able to test failing transfers easily.
#
# Add the Curl object to the Multi object.
#
# Invoke Multi.socket_action to start the retrieval operation.
# Observed side effect: this causes the timer callback to be invoked
# with a greater than zero value for the timeout.
#
# By now we should have initialized our own state, which this script does
# prior to invoking any libcurl functions. Importantly, the state includes
# the timeout value that was communicated to us by libcurl.
#
# Run a loop which waits for activity on any of the sockets used by libcurl.
# The sockets are set that the socket callback has produced as of the
# present moment; the timeout is the most recent timeout value received by
# the timer callback.
#
# Importantly, the loop should not simply sleep for the entire
# timeout interval, as that would cause the transfer to take a very long time.
# It is *required* to use something like a select call to wait for activity
# on any of the sockets currently active for *up to* the timeout value.
#
# The loop terminates when the number of active transfers (handles in libcurl
# parlance) reaches zero. This number is provided by each socket_action
# call, which is why each call (even the ones that are called due to
# timeout being reached, as opposed to any socket activity) must update
# the number of running handles.
#
# After the loop terminates, clean up everything: remove the easy object from
# the multi object, close the easy object, close the multi object.
import sys, select
import pycurl
from io import BytesIO
if len(sys.argv) > 1:
url = sys.argv[1]
else:
url = 'https://www.python.org'
state = {
'rlist': [],
'wlist': [],
'running': None,
'timeout': None,
'result': None,
# If the transfer failed, code and msg will be filled in.
'code': None,
'msg': None,
}
def socket_fn(what, sock_fd, multi, socketp):
if what == pycurl.POLL_IN or what == pycurl.POLL_INOUT:
state['rlist'].append(sock_fd)
elif what == pycurl.POLL_OUT or what == pycurl.POLL_INOUT:
state['wlist'].append(sock_fd)
elif what == pycurl.POLL_REMOVE:
if sock_fd in state['rlist']:
state['rlist'].remove(sock_fd)
if sock_fd in state['wlist']:
state['wlist'].remove(sock_fd)
else:
raise Exception("Unknown value of what: %s" % what)
def work(timeout):
rready, wready, xready = select.select(
state['rlist'], state['wlist'], set(state['rlist']) | set(state['wlist']), timeout)
if len(rready) == 0 and len(wready) == 0 and len(xready) == 0:
# The number of running handles must be updated after each
# call to socket_action, which includes those with the SOCKET_TIMEOUT
# argument (otherwise e.g. a transfer which failed due to
# exceeding the connection timeout would hang).
_, running = multi.socket_action(pycurl.SOCKET_TIMEOUT, 0)
else:
for sock_fd in rready:
# socket_action returns a tuple whose first element is always the
# CURLE_OK value (0), ignore it and use the second element only.
_, running = multi.socket_action(sock_fd, pycurl.CSELECT_IN)
for sock_fd in wready:
_, running = multi.socket_action(sock_fd, pycurl.CSELECT_OUT)
for sock_fd in xready:
_, running = multi.socket_action(sock_fd, pycurl.CSELECT_ERR)
# Since we are only performing a single transfer, we could call
# Multi.info_read after the I/O loop terminates.
# In practice, you would probably use socket_action with multiple
# transfers, and you may want to be notified about transfer completion
# as soon as the result is available.
if state['running'] is not None and running != state['running']:
# Some handle has completed.
#
# Note that socket_action was potentially called multiple times
# in this function (e.g. if both a read handle became ready and a
# different write handle became ready), therefore it is possible
# that multiple handles have completed. In this particular script
# we are only performing a single transfer (one
# Curl object / easy handle), therefore only one transfer can ever
# possibly complete.
qmsg, successes, failures = multi.info_read()
# We should have retrieved all of the available statuses, leaving
# none in the queue.
assert qmsg == 0
# We have only one transfer.
assert len(successes) == 1 and len(failures) == 0 or \
len(successes) == 0 and len(failures) == 1
if successes:
state['result'] = True
if failures:
state['result'] = False
# The failures array contains tuples of
# (easy object, CURLE code, error message).
_easy, state['code'], state['msg'] = failures[0]
state['running'] = running
def timer_fn(timeout_ms):
if timeout_ms < 0:
# libcurl passes a negative timeout value when no further
# calls should be made.
state['timeout'] = None
else:
state['timeout'] = timeout_ms / 1000.0
multi = pycurl.CurlMulti()
multi.setopt(pycurl.M_SOCKETFUNCTION, socket_fn)
multi.setopt(pycurl.M_TIMERFUNCTION, timer_fn)
easy = pycurl.Curl()
easy.setopt(pycurl.URL, url)
# Uncomment to see what libcurl is doing throughout the transfer.
#easy.setopt(pycurl.VERBOSE, 1)
easy.setopt(pycurl.CONNECTTIMEOUT, 5)
easy.setopt(pycurl.LOW_SPEED_TIME, 5)
easy.setopt(pycurl.LOW_SPEED_LIMIT, 1)
_io = BytesIO()
easy.setopt(pycurl.WRITEDATA, _io)
multi.add_handle(easy)
handles = multi.socket_action(pycurl.SOCKET_TIMEOUT, 0)
# This should invoke the timer function with a timeout value.
while True:
if state['running'] == 0:
break
else:
# By the time we get here, timer function should have been already
# invoked at least once so that we have a libcurl-supplied
# timeout value. But in case this hasn't happened, default the timeout
# to 1 second.
timeout = state['timeout']
if timeout is None:
raise Exception('Need to poll for I/O but the timeout is not set!')
work(timeout)
multi.remove_handle(easy)
easy.close()
multi.close()
# Uncomment to print the retrieved contents.
#print(_io.getvalue().decode())
if state['result'] is None:
raise Exception('Script finished without a result!')
if state['result']:
print('Transfer successful, retrieved %d bytes' % len(_io.getvalue()))
else:
print('Transfer failed with code %d: %s' % (state['code'], state['msg']))
