from flask import Flask, render_template, request, redirect, url_for, flash, session, jsonify

from ldap3 import Server, Connection, ALL_ATTRIBUTES, SUBTREE

import paramiko

import re

app = Flask(__name__)

app.secret_key = 'calvo'

# Função de autenticação LDAP

def authenticate(username, password):

domain = 'digitalup.intranet'

server = Server(domain, get_info=ALL_ATTRIBUTES)

user = f'{username}@{domain}'

conn = Connection(server, user=user, password=password)

try:

if conn.bind():

conn.search(search_base='DC=digitalup,DC=intranet',

search_filter=f'(sAMAccountName={username})',

attributes=['cn', 'homePhone', 'telephoneNumber'])

if len(conn.entries) > 0:

user_info = conn.entries[0]

print(user_info)

full_name = user_info.cn.value if hasattr(user_info, 'cn') else None

phone_number = user_info.homePhone[0] if hasattr(user_info, 'homePhone') and user_info.homePhone else None

if not phone_number:

phone_number = user_info.telephoneNumber[0] if hasattr(user_info, 'telephoneNumber') and user_info.telephoneNumber else None

session['logged_in'] = True

session['username'] = username

session['full_name'] = full_name

session['phone_number'] = phone_number

return True

else:

return False

else:

return False

except Exception as e:

print(f"Erro de autenticação LDAP: {e}")

return False

finally:

conn.unbind()

import paramiko

import re

def get_secret_for_phone_number(phone_number):

hostname = '192.168.15.252'

port = 22

username = 'root'

password = 'Dydf%hhffjk5s588ik2u@ud7aDF'

file_path = '/etc/asterisk/sip_additional.conf'

try:

client = paramiko.SSHClient()

client.set_missing_host_key_policy(paramiko.AutoAddPolicy())

client.connect(hostname, port, username, password)

stdin, stdout, stderr = client.exec_command(f'cat {file_path}')

file_content = stdout.read().decode()

error_message = stderr.read().decode()

if error_message:

print(f"Erro ao ler o arquivo: {error_message}")

return None

sections = re.split(r'\n(?=\[\d+\])', file_content)

for section in sections:

if f'dial=SIP/{phone_number}' in section:

match = re.search(r'secret=([^ \n]+)', section)

if match:

return match.group(1)

return None

except paramiko.SSHException as e:

print(f"Erro de SSH: {e}")

return None

except Exception as e:

print(f"Erro: {e}")

return None

finally:

client.close()

from ldap3 import Server, Connection, SUBTREE, ALL_ATTRIBUTES

def get_all_callerid():

ldap_server = 'digitalup.intranet'

ldap_user = 'administrator@digitalup.intranet'

ldap_password = '&ajhsRlm88s!@SF'

base_dn = 'DC=digitalup,DC=intranet'

try:

server = Server(ldap_server, get_info=ALL_ATTRIBUTES)

conn = Connection(server, user=ldap_user, password=ldap_password, auto_bind=True)

# Buscar todas as pastas (unidades organizacionais)

conn.search(search_base=base_dn,

search_filter='(objectClass=organizationalUnit)',

search_scope=SUBTREE,

attributes=['distinguishedName', 'name'])

ou_dict = {}

for entry in conn.entries:

ou_dn = str(entry.distinguishedName)

ou_name = str(entry.name)

ou_dict[ou_dn] = ou_name

# Buscar todos os usuários com homePhone preenchido

conn.search(search_base=base_dn,

search_filter='(&(objectClass=person)(homePhone=*))',

search_scope=SUBTREE,

attributes=['cn', 'homePhone', 'distinguishedName'])

callerid_info = []

for entry in conn.entries:

name = str(entry.cn)

home_phone = str(entry.homePhone)

user_dn = str(entry.distinguishedName)

# Determinar a pasta (setor) do usuário

sector_name = 'Desconhecido'

for ou_dn, ou_name in ou_dict.items():

if user_dn.startswith(ou_dn):

sector_name = ou_name

break

callerid_info.append((name, home_phone, sector_name))

return callerid_info if callerid_info else None

except Exception as e:

print(f"Erro: {e}")

return None

@app.after_request

def add_cache_control_headers(resp):

resp.headers["Cache-Control"] = "no-cache, no-store, must-revalidate"

resp.headers["Pragma"] = "no-cache"

resp.headers["Expires"] = "0"

return resp

@app.route('/', methods=['GET', 'POST'])

def login():

if 'logged_in' in session and session['logged_in']:

return redirect(url_for('home'))

if request.method == 'POST':

username = request.form['username']

password = request.form['password']

if authenticate(username, password):

return redirect(url_for('home'))

else:

flash('Credenciais inválidas. Tente novamente.', 'error')

return render_template('login.html')

@app.route('/home')

def home():

if not session.get('logged_in'):

return redirect(url_for('login'))

full_name = session.get('full_name', 'Usuário')

phone_number = session.get('phone_number', 'Não disponível')

# Obter o segredo para o número de telefone

secret = get_secret_for_phone_number(phone_number) if phone_number != 'Não disponível' else 'Não disponível'

# Obter todas as informações de callerid

callerid_info = get_all_callerid()

# Passar a lista de callerid_info diretamente para o template

return render_template(

'index.html',

full_name=full_name,

phone_number=phone_number,

secret=secret,

callerid_info=callerid_info

)

from flask import jsonify

@app.route('/get_user_info', methods=['GET'])

def get_user_info():

if not session.get('logged_in'):

return jsonify({'error': 'Usuário não autenticado'}), 401

phone_number = session.get('phone_number', 'Não disponível')

secret = get_secret_for_phone_number(phone_number) if phone_number != 'Não disponível' else 'Não disponível'

return jsonify({

'phone_number': phone_number,

'secret': secret

})

@app.route('/logout', methods=['POST'])

def logout():

session.pop('logged_in', None)

session.pop('username', None)

session.pop('full_name', None)

session.pop('phone_number', None)

return redirect(url_for('login'))

if __name__ == '__main__':

app.run(debug=True, host="0.0.0.0", port=5000)