স্বয়ংক্রিয় ব্যবস্থা ইয়েলিঙ্ক T19 + গতিশীল ঠিকানা বই

যখন আমি এই কোম্পানির জন্য কাজ করতে এসেছি, তখন আমার কাছে ইতিমধ্যেই আইপি ডিভাইসের কিছু ডাটাবেস, তারকাচিহ্ন সহ বেশ কয়েকটি সার্ভার এবং FreeBPX আকারে একটি প্যাচ ছিল। এছাড়াও, একটি অ্যানালগ PBX Samsung IDCS500 সমান্তরালভাবে কাজ করেছিল এবং সাধারণভাবে, কোম্পানির প্রধান যোগাযোগ ব্যবস্থা ছিল; আইপি টেলিফোনি শুধুমাত্র বিক্রয় বিভাগের জন্য কাজ করেছিল। এবং সবকিছু এইভাবে রান্না করা অব্যাহত থাকত, তবে একদিন সূক্ষ্ম দিন প্রত্যেককে আইপি টেলিফোনিতে স্থানান্তর করার জন্য একটি ডিক্রি দেওয়া হয়েছিল, সময়সীমা সম্মত হয়েছিল, সরঞ্জাম কেনা হয়েছিল এবং এন্টারপ্রাইজটিকে 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')

প্রোগ্রামটি ব্যবহারকারীর কম্পিউটারে চলে এবং কাজ করে যদি কম্পিউটারটি একটি ফোনের মাধ্যমে নেটওয়ার্কের সাথে সংযুক্ত থাকে, যেহেতু Yealink T19 একটি গেটওয়ে হিসাবে কাজ করতে পারে না।

প্রথমত, আমাদের বুঝতে হবে এটি সংযুক্ত কিনা? এবং আমাদের ফোনে কী কী ম্যাক এবং আইপি রয়েছে।

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

এখানে আমরা স্কাপি ফ্রেমওয়ার্ক থেকে স্নিফ ফাংশন ব্যবহার করি, এর সাহায্যে আমরা একটি পূর্বনির্ধারিত udp প্যাকেট পাই, 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() বর্তমান ব্যবহারকারীর cn নিন (যাতে সাধারণত ব্যবহারকারীর পুরো নাম থাকে)।

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

আমরা ডাটাবেসের একটি পূর্ব-তৈরি টেবিলের সাথে সংযোগ করি (আমি এটি সেখানে তৈরি করেছি) এবং আমরা যা শিখেছি তা লিখি, যথা: ip, mac, username।

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 ফর্মের হওয়া উচিত।

ফাইলের সমস্ত পরিবর্তন এবং এটি টিএফটিপি সার্ভারে সংরক্ষণ করার পরে, আমরা ডিভাইসটিকে প্রভিশন এবং রিবুট করার জন্য ফোনকে কমান্ড দিই।

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')

ডিভাইসটি রিবুট করার পরে, আমরা ফোনের স্ক্রিনে আমাদের পুরো নাম পাই + একটি ডাটাবেসের আকারে একটি সর্বদা সঠিকভাবে পূরণ করা ঠিকানা বই, তারপরে যা অবশিষ্ট থাকে তা হল এক্সএমএল যোগ করা এবং বিষয়বস্তুটি গতিশীলভাবে প্রদর্শন করার জন্য সামান্য পিএইচপি। এরকম অনেক উদাহরণ আছে, এমনকি YEALINK নিজেও সেগুলি আছে৷

PS: বৃহত্তর মাপযোগ্যতার জন্য, আপনি একটি পৃথক ফাইলে প্রধান সেটিংস (ভেরিয়েবল) সরাতে পারেন।

উত্স: www.habr.com