File: //usr/lib/python3/dist-packages/hgext/zeroconf/__pycache__/__init__.cpython-310.pyc
o
�]Lb� � @ s& d Z ddlmZ ddlZddlZddlZddlmZ ddlm Z m
Z
m Z m Z m
Z
mZmZ ddlmZ dZdadad d
� Zd d � Zd
d� ZG dd� de�Zdd� Zdd� Z dd� Z dd� Z dd� Z dd � Z e �!e d e � e �!ejd e � e �!ejd e � e �!ejd e � e �!e d!e � e �!ed"e� dS )#a� discover and advertise repositories on the local network
The zeroconf extension will advertise :hg:`serve` instances over
DNS-SD so that they can be discovered using the :hg:`paths` command
without knowing the server's IP address.
To allow other people to discover your repository using run
:hg:`serve` in your repository::
$ cd test
$ hg serve
You can discover Zeroconf-enabled repositories by running
:hg:`paths`::
$ hg paths
zc-test = http://example.com:8000/test
� )�absolute_importN� )�Zeroconf)�dispatch�encoding�
extensions�hg�pycompat�rcutil�ui)�servers ships-with-hg-corec C s� zt � t jt j�} | �d� | �� d }|W S t jy Y nw zt �t �� �d d }d|v r3d}|�d�s;|W S W n t j t j
fyK d}Y nw zt � t jt j�} | �d� | �� d }|W S t jym Y |S w )N)�1.0.0.1r r � �:z 127.0.0.1�127.)r
r ) �socket�AF_INET�
SOCK_DGRAM�connect� getsockname�error�
gethostbyaddr� gethostname�
startswith�gaierror�herror)�s�ip�dumbip� r �9/usr/lib/python3/dist-packages/hgext/zeroconf/__init__.py�getip7 s6
�
��
�r! c
C s� t st� }|�d�r d S t�|�at�|�a t�� �d�d }|d }d|| f } tj dt
� | d �|||d| d �tddd
�}t � |� tj d t
� | d �|||d| d �tddd
�}t � |� d S )
Nr �.r z.localz%s-%ss _http._tcp.local.z._http._tcp.local.� /)� descriptions path)r �port�
properties�address�weight�priority� _hg._tcp.local.z._hg._tcp.local.)
r r! r r � inet_aton�localipr r �split� ServiceInfor �bytestr�registerService)�name�desc�pathr% r �hostname�host�svcr r r �publishW s>
�
�
r7 c C s6 | ||�}|j }z|j}W nE tyR |�� �(}|jp"tj�|j�}|j �
ddd�� d�}|j �
dd�} | s9|} W d � n1 sCw Y t || ||� Y |S w |j �
ddd�� d�d }
|D ]6\}}|j �
� } t�� rz| �tj�|dd�� tj�|�}|
| � d�}| �
dd�} | s�|} t || ||� qb|S )Ns webs prefix� r# r$ s .hgs hgrc)r% �repos�AttributeError� _obtainrepo�reponame�osr3 �basename�rootr �config�stripr7 �copyr
�
use_repo_hgrc�
readconfig�join) �
create_serverr �app�httpdr% r9 �repor1 r3 r2 �prefix�ur r r �zc_create_server� s8
� ��
rL c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�listenerc C s
i | _ d S �N)�found)�selfr r r �__init__� s
zlistener.__init__c C s" t |�| jv r| jt |�= d S d S rN )�reprrO �rP r �typer1 r r r �
removeService� s �zlistener.removeServicec C s |� ||�| jt|�< d S rN )�getServiceInforO rR rS r r r �
addService� s zlistener.addServiceN)�__name__�
__module__� __qualname__rQ rU rW r r r r rM � s rM c c s� � t � } | �d�r d S t�| �}t� }t�|d|� t�d� |�� |j� � D ](}|j
d |j
� d�� }dt �
|j�|j|j�dd�f }d| t�|�fV q(d S ) Nr r* r � .zhttp://%s:%s%sr3 �/� zc-)r! r r rM �ServiceBrowser�time�sleep�closerO �valuesr1 �indexr � inet_ntoar' r% r& �getr r/ )r r �l�valuer1 �urlr r r �
getzcpaths� s$ �
��ri c O sL |dkr|� d�rt� D ] \}}||kr| S q | |||g|�R i |��S �N� pathsr] �r ri )�origrP �section�key�args�kwargsr1 r3 r r r r@ � s �r@ c O s. | ||g|�R i |��}|dkr|t � 7 }|S )Nrk )ri )rm rP rn rp rq r9 r r r � configitems� s
rr c
O s\ | |||g|�R i |��\}}|dkr*|� d�r*t� D ]\}} ||kr)| |f S q||fS rj rl )
rm rP rn r1 rp rq �opt�sub�zcname�zcurlr r r �configsuboptions� s �rw c C s0 t � D ]\}}||kr|�tj� S q| |�S rN )ri �encoder )rm �sourcer1 r3 r r r � defaultdest� s
�rz c C s0 z| ||||�W t rt �� S S t rt �� w w rN )r ra )rm r �options�cmd�cmdfuncr r r �cleanupafterdispatch� s
�
�r~ s _runcommands configs configitemss configsuboptionss defaultdests
create_server)"�__doc__�
__future__r r= r r_ � r � mercurialr r r r r r
r �uimod�mercurial.hgwebr � servermod�
testedwithr, r! r7 rL �objectrM ri r@ rr rw rz r~ � wrapfunctionr r r r �<module> s6 $ )"