🥇ऑटोप्रोविजनिंग येलिंक टी19 + डायनामिक एड्रेस बुक

जब मैं इस कंपनी के लिए काम करने आया, तो मेरे पास पहले से ही आईपी उपकरणों का कुछ डेटाबेस, तारांकन चिह्न वाले कई सर्वर और फ्रीबीपीएक्स के रूप में एक पैच था। इसके अलावा, एक एनालॉग पीबीएक्स सैमसंग आईडीसीएस500 समानांतर में काम करता था और सामान्य तौर पर, कंपनी में मुख्य संचार प्रणाली थी; आईपी टेलीफोनी केवल बिक्री विभाग के लिए काम करती थी। और सब कुछ इसी तरह पकता रहा, लेकिन एक दिन सभी को आईपी टेलीफोनी में स्थानांतरित करने का फरमान जारी किया गया, समय सीमा पर सहमति हुई, उपकरण खरीदे गए, और उद्यम को 21 वीं सदी में स्थानांतरित करने की योजना लागू की जाने लगी।
ऐसी स्थिति में सबसे पहली चीज जो चिंता पैदा करने लगती है वह है तेजी से बढ़ती टेलीफोन सेटों की संख्या जिन्हें किसी तरह प्रबंधित करने की जरूरत है, दूसरी चीज जो बहुत चिंताजनक थी वह थी फोन बुक। यदि एंडपॉइंट प्रबंधक हमें पहले वाले में मदद कर सकता है (जो, वैसे, FreePBX के नवीनतम संस्करणों से काट दिया गया था), तो पुस्तक के साथ कुछ प्रश्न उठे:

सबसे पहले, जब उपयोगकर्ताओं का स्थान/तरलता लगातार बदल रही हो तो इसकी सटीकता कैसे सुनिश्चित की जाए?
दूसरे, फोन को पूरी तरह से वैयक्तिकृत कैसे किया जाए। और हर बार संपर्क नाम नहीं भरते?

समस्या दिलचस्प थी, समाधान आने में देर नहीं लगी. अब मैं पूरी सूची दूंगा, और फिर हम इसे क्रम से देखेंगे।

from scapy.all import sniff
from scapy.layers.inet import IP
import mysql.connector
import ldap
import getpass
import tftpy
import requests
import os
import time
from string import replace

def conn_ldap(login):
    ad = ldap.initialize('ldap://***.local')
    ad.simple_bind_s('voip@***.local', 'password')
    basedn = 'OU=IT,DC=***,DC=LOCAL'
    basedn_user = 'OU=***,OU=***,DC=***,DC=LOCAL'
    scope = ldap.SCOPE_SUBTREE
    filterexp = "(&(sAMAccountName=" + login + ")(ObjectClass=person))"
    filterexp2 = "(&(ObjectClass=organizationUnit))"
    attrlist = ['cn']
    attrlist2 = ['OU']
    search = ad.search_s(basedn, scope, filterexp, attrlist)
    adname = search[0][1]['cn'][0].decode('utf-8')
    if adname == ' ':
        search = ad.search_s(basedn_user, scope, filterexp2, attrlist2)
        for i in range(1, len(search)+1):
            group = search[i][1]['ou'][0]
            basedn_user2 = 'OU='+group+','+basedn_user
            search = ad.search_s(basedn_user2, scope, filterexp, attrlist)
            adname = search[0][1]['cn'][0].decode('utf-8')
            if adname != ' ':
                return adname
        adname = search[0][1]['cn'][0].decode('utf-8')
    ad.unbind_s()
    return adname


def tftp_file_change(config,place,adname,current_account,current_account_password):

    client = tftpy.TftpClient("192.168.0.3", 69)
    client.download('template.cfg', place)
    fileread = open(place, 'r')
    line = fileread.readlines()
    fileread.close()
    line[5] = (('account.1.label = ').encode('utf-8') + adname.encode('utf-8') + 'n')
    line[2] = (('account.1.auth_name = ').encode('utf-8') + current_account.encode('utf-8') + 'n')
    line[3] = (('account.1.display_name = ').encode('utf-8') + current_account.encode('utf-8') + 'n')
    line[6] = (('account.1.password = ').encode('utf-8') + current_account_password[0][0] + 'n')
    filewrite = open(place, 'w')
    for i in line:
      filewrite.write(i)
    filewrite.close()
    print place
    print config
    client.upload(config,place)


def get_phone_inform(ipaddr):
    fileconf = requests.get('http://admin:admin@'+ipaddr+'/servlet?phonecfg=get[&accounts=1]')
    conf = fileconf.text.split('|')
    current_account = conf[2]
    return current_account


def sniff_frame():
    pcapf = sniff(count=1, timeout=70, filter="dst host 192.168.0.3 and port 5060")
    if len(pcapf) == 0:
        exit()
    frame = pcapf[0]
    macaddr = frame.src
    print macaddr[:8]
    if macaddr[:8] != '80:5e:c0':
        exit()
    ipaddr = frame[0][IP].src
    return macaddr, ipaddr


def conn_mysql(query,fquery,macaddr,qwery2):
    connect = mysql.connector.connect(host='192.168.0.3', database='voip', user='voip_wr', password='***')
    cursor = connect.cursor()
    cursor.execute(fquery)
    state = cursor.fetchall()
    state = bool(state[0][0])
    if state == True:
        cursor.execute(qwery2)
        connect.commit()
        connect.close()
    else:
        cursor.execute(query)
        connect.commit()
        connect.close()


def check_account(current_account):
    connect = mysql.connector.connect(host='192.168.0.3', database='asterisk', user='voip_wr', password='***')
    cursor = connect.cursor()
    qwery = 'select data from sip where id=' + current_account + ' and keyword="secret";'
    cursor.execute(qwery)
    password = cursor.fetchall()
    if password == ' ':
        exit()
    else:
        return password


if __name__ == '__main__':
    macaddr, ipaddr = sniff_frame()
    current_account = get_phone_inform(ipaddr)
    current_account_password = check_account(current_account)
    macaddr = macaddr.replace(':', '')
    ipaddr = ipaddr.decode('utf-8')
    adname = conn_ldap(getpass.getuser())
    query = 'INSERT INTO station (mac, ip, name, number) VALUES (' + '"' + macaddr + '",' + '"' + ipaddr + '",' + '"' + adname + '",' + '"' + get_phone_inform(ipaddr) + '"' + ')'
    qwery2 = 'UPDATE station SET ip=' + '"' + ipaddr + '"' + ', name=' + '"' + adname + '"' + ', number=' + '"' + get_phone_inform(ipaddr) + '"' + ' WHERE mac=' + '"' + macaddr + '"'
    fquery = 'SELECT EXISTS(SELECT mac FROM voip.station WHERE mac=' + '"' + macaddr + '")'
    query = query.encode('utf-8')
    fquery = fquery.encode('utf-8')
    config = macaddr + '.cfg'
    place = os.path.expanduser("~") + "" + "AppDataLocal" + config
    conn_mysql(query,fquery,macaddr,qwery2)
    tftp_file_change(config,place,adname,current_account,current_account_password)
    requests.get('http://admin:admin@'+ipaddr+'/cgi-bin/ConfigManApp.com?key=AutoP')
    requests.get('http://admin:admin@'+ipaddr+'/cgi-bin/ConfigManApp.com?key=Reboot')

प्रोग्राम उपयोगकर्ता के कंप्यूटर पर चलता है और काम करता है बशर्ते कि कंप्यूटर फोन के माध्यम से नेटवर्क से जुड़ा हो, क्योंकि येलिंक टी19 गेटवे के रूप में काम नहीं कर सकता है।

सबसे पहले, हमें यह समझने की जरूरत है कि क्या यह जुड़ा हुआ है? और हमारे फोन में कौन सा मैक और आईपी है।

def sniff_frame():
    pcapf = sniff(count=1, timeout=70, filter="dst host 192.168.0.3 and port 5060")
    if len(pcapf) == 0:
        exit()
    frame = pcapf[0]
    macaddr = frame.src
    print macaddr[:8]
    if macaddr[:8] != '80:5e:c0':
        exit()
    ipaddr = frame[0][IP].src
    return macaddr, ipaddr

यहां हम स्केपी फ्रेमवर्क से स्निफ़ फ़ंक्शन का उपयोग करते हैं, इसकी सहायता से हमें एक पूर्वनिर्धारित यूडीपी पैकेट प्राप्त होता है, 70 सेकंड प्रतीक्षा करें और यदि हम कुछ भी नहीं पकड़ पाते हैं, तो हम बाहर निकल जाते हैं।

count=1, timeout=70, filter="dst host 192.168.0.3 and port 5060"

इसके बाद, हम यह सुनिश्चित करते हैं कि डिवाइस वास्तव में येलिंक है और आवश्यक मान (आईपी और मैक) लौटाते हैं।

एक विशेष अनुरोध का उपयोग करके, हम फ़ोन पर चालू खाते का पता लगाते हैं। ऐसा करने के लिए, वर्तमान कॉन्फ़िगरेशन को फ़ोन से डाउनलोड किया जाता है और पार्स किया जाता है।

def get_phone_inform(ipaddr):
    fileconf = requests.get('http://admin:admin@'+ipaddr+'/servlet?phonecfg=get[&accounts=1]')
    conf = fileconf.text.split('|')
    current_account = conf[2]
    return current_account

इस खाते का पासवर्ड पता करें. ऐसा करने के लिए, हम asterisk.sip तालिका और उसमें मौजूद डेटा फ़ील्ड की ओर रुख करते हैं।

def check_account(current_account):
    connect = mysql.connector.connect(host='192.168.0.3', database='asterisk', user='voip_wr', password='***')
    cursor = connect.cursor()
    qwery = 'select data from sip where id=' + current_account + ' and keyword="secret";'
    cursor.execute(qwery)
    password = cursor.fetchall()
    if password == ' ':
        exit()
    else:
        return password

खैर, अंतिम चरण के लिए हम ldap AD से जुड़ते हैं और फ़ंक्शन के माध्यम से प्राप्त sAMAccountName का उपयोग करते हैं getpass.getuser() वर्तमान उपयोगकर्ता का सीएन लें (जिसमें आमतौर पर उपयोगकर्ता का पूरा नाम होता है)।

def conn_ldap(login):
    ad = ldap.initialize('ldap://***.local')
    ad.simple_bind_s('voip@***.local', 'password')
    basedn = 'OU=***,DC=***,DC=LOCAL'
    basedn_user = 'OU=***,OU=***,DC=***,DC=LOCAL'
    scope = ldap.SCOPE_SUBTREE
    filterexp = "(&(sAMAccountName=" + login + ")(ObjectClass=person))"
    filterexp2 = "(&(ObjectClass=organizationUnit))"
    attrlist = ['cn']
    attrlist2 = ['OU']
    search = ad.search_s(basedn, scope, filterexp, attrlist)
    adname = search[0][1]['cn'][0].decode('utf-8')
    if adname == ' ':
        search = ad.search_s(basedn_user, scope, filterexp2, attrlist2)
        for i in range(1, len(search)+1):
            group = search[i][1]['ou'][0]
            basedn_user2 = 'OU='+group+','+basedn_user
            search = ad.search_s(basedn_user2, scope, filterexp, attrlist)
            adname = search[0][1]['cn'][0].decode('utf-8')
            if adname != ' ':
                return adname
        adname = search[0][1]['cn'][0].decode('utf-8')
    ad.unbind_s()
    return adname

हम डेटाबेस में एक पूर्व-निर्मित तालिका से जुड़ते हैं (मैंने इसे वहां बनाया है) और वह सब कुछ दर्ज करते हैं जो हमने सीखा, अर्थात्: आईपी, मैक, उपयोगकर्ता नाम।

def conn_mysql(query,fquery,macaddr,qwery2):
    connect = mysql.connector.connect(host='192.168.0.3', database='voip', user='voip_wr', password='***')
    cursor = connect.cursor()
    cursor.execute(fquery)
    state = cursor.fetchall()
    state = bool(state[0][0])
    if state == True:
        cursor.execute(qwery2)
        connect.commit()
        connect.close()
    else:
        cursor.execute(query)
        connect.commit()
        connect.close()

हम यहां रुक सकते हैं, क्योंकि हमने पहले ही एक गतिशील पता पुस्तिका बना ली है, आप पूछ सकते हैं, लेकिन मैं आगे बढ़ गया और यहां उपकरणों के लिए ऑटो-प्रावधान जोड़ा।

ऐसा करने के लिए, पूर्व-कॉन्फ़िगर किए गए tftp सर्वर से एक टेम्पलेट कॉन्फ़िगरेशन डाउनलोड किया जाता है, जिसमें हम अपने परिवर्तन करते हैं और इसे mac.cfg के रूप में सहेजते हैं। यानी, येलिंक के लिए दो प्रकार के कॉन्फ़िगरेशन हैं, एक वैश्विक है, और दूसरा एक विशिष्ट फोन पर लागू होता है और इसका फॉर्म mac_phone.cfg होना चाहिए।

फ़ाइल में सभी परिवर्तन करने और इसे वापस tftp सर्वर पर सहेजने के बाद, हम फ़ोन को डिवाइस को प्रोविज़न करने और रीबूट करने का आदेश देते हैं।

def tftp_file_change(config,place,adname,current_account,current_account_password):

    client = tftpy.TftpClient("192.168.0.3", 69)
    client.download('template.cfg', place)
    fileread = open(place, 'r')
    line = fileread.readlines()
    fileread.close()
    line[5] = (('account.1.label = ').encode('utf-8') + adname.encode('utf-8') + 'n')
    line[2] = (('account.1.auth_name = ').encode('utf-8') + current_account.encode('utf-8') + 'n')
    line[3] = (('account.1.display_name = ').encode('utf-8') + current_account.encode('utf-8') + 'n')
    line[6] = (('account.1.password = ').encode('utf-8') + current_account_password[0][0] + 'n')
    filewrite = open(place, 'w')
    for i in line:
      filewrite.write(i)
    filewrite.close()
    print place
    print config
    client.upload(config,place)

requests.get('http://admin:admin@'+ipaddr+'/cgi-bin/ConfigManApp.com?key=AutoP')
requests.get('http://admin:admin@'+ipaddr+'/cgi-bin/ConfigManApp.com?key=Reboot')

डिवाइस को रिबूट करने के बाद, हमें फोन स्क्रीन पर हमारा पूरा नाम + डेटाबेस के रूप में हमेशा सही ढंग से भरी हुई पता पुस्तिका मिलती है, फिर सामग्री को गतिशील रूप से प्रदर्शित करने के लिए केवल XML और थोड़ा PHP जोड़ना बाकी है। ऐसे बहुत से उदाहरण हैं, यहां तक कि YEALINK के पास भी हैं।

पुनश्च: अधिक स्केलेबिलिटी के लिए, आप मुख्य सेटिंग्स (चर) को एक अलग फ़ाइल में ले जा सकते हैं।

स्रोत: www.habr.com

ऑटो प्रोविजनिंग येलिंक टी19 + डायनेमिक एड्रेस बुक

एक टिप्पणी जोड़ें उत्तर रद्द