# HBLink User Managment Server from flask import Flask, render_template_string, request, make_response, jsonify, render_template, Markup, flash, redirect, url_for, current_app from flask_sqlalchemy import SQLAlchemy from flask_user import login_required, UserManager, UserMixin, user_registered, roles_required from werkzeug.security import check_password_hash from flask_login import current_user, login_user, logout_user from wtforms import StringField, SubmitField import requests import base64, hashlib from dmr_utils3.utils import int_id, bytes_4 from config import * import ast import json import datetime, time from flask_babelex import Babel import libscrc import random from flask_mail import Message, Mail from socket import gethostbyname try: from gen_script_template import gen_script except: pass import os, ast ##import hb_config Sscript_links = {} ##def gen_passphrase(dmr_id): ## _new_peer_id = bytes_4(int(str(dmr_id)[:7])) ## b_list = create_app().get_burnlist() ## print(_new_peer_id) #### try: ## #if get_burnlist()[_new_peer_id] != 0: ## for ui in b_list: ## if b_list != 0: ## calc_passphrase = base64.b64encode(bytes.fromhex(str(hex(libscrc.ccitt((_new_peer_id) + get_burnlist()[_new_peer_id].to_bytes(2, 'big') + burn_int.to_bytes(2, 'big') + append_int.to_bytes(2, 'big') + bytes.fromhex(str(hex(libscrc.posix((_new_peer_id) + get_burnlist()[_new_peer_id].to_bytes(2, 'big') + burn_int.to_bytes(2, 'big') + append_int.to_bytes(2, 'big'))))[2:].zfill(8)))))[2:].zfill(4)) + (_new_peer_id) + get_burnlist()[_new_peer_id].to_bytes(2, 'big') + burn_int.to_bytes(2, 'big') + append_int.to_bytes(2, 'big') + bytes.fromhex(str(hex(libscrc.posix((_new_peer_id) + get_burnlist()[_new_peer_id].to_bytes(2, 'big') + burn_int.to_bytes(2, 'big') + append_int.to_bytes(2, 'big'))))[2:].zfill(8))) #### except: ## else: ## calc_passphrase = base64.b64encode(bytes.fromhex(str(hex(libscrc.ccitt((_new_peer_id) + append_int.to_bytes(2, 'big') + bytes.fromhex(str(hex(libscrc.posix((_new_peer_id) + append_int.to_bytes(2, 'big'))))[2:].zfill(8)))))[2:].zfill(4)) + (_new_peer_id) + append_int.to_bytes(2, 'big') + bytes.fromhex(str(hex(libscrc.posix((_new_peer_id) + append_int.to_bytes(2, 'big'))))[2:].zfill(8))) #### print(calc_passphrase) ## if use_short_passphrase == True: ## return str(calc_passphrase)[-9:-1] ## elif use_short_passphrase ==False: ## return str(calc_passphrase)[2:-1] # Query radioid.net for list of IDs def get_ids(callsign): try: url = "https://www.radioid.net" response = requests.get(url+"/api/dmr/user/?callsign=" + callsign) result = response.json() ## print(result) # id_list = [] id_list = {} f_name = result['results'][0]['fname'] l_name = result['results'][0]['surname'] try: city = str(result['results'][0]['city'] + ', ' + result['results'][0]['state'] + ', ' + result['results'][0]['country']) except: city = result['results'][0]['country'] for i in result['results']: id_list[i['id']] = 0 return str([id_list, f_name, l_name, city]) except: return str([{}, '', '', '']) # Return string in NATO phonetics def convert_nato(string): d_nato = { 'A': 'ALPHA', 'B': 'BRAVO', 'C': 'CHARLIE', 'D': 'DELTA', 'E': 'ECHO', 'F': 'FOXTROT', 'G': 'GOLF', 'H': 'HOTEL', 'I': 'INDIA', 'J': 'JULIETT','K': 'KILO', 'L': 'LIMA', 'M': 'MIKE', 'N': 'NOVEMBER','O': 'OSCAR', 'P': 'PAPA', 'Q': 'QUEBEC', 'R': 'ROMEO', 'S': 'SIERRA', 'T': 'TANGO', 'U': 'UNIFORM', 'V': 'VICTOR', 'W': 'WHISKEY', 'X': 'X-RAY', 'Y': 'YANKEE', 'Z': 'ZULU', '0': 'zero(0)', '1': 'one(1)', '2': 'two(2)', '3': 'three(3)', '4': 'four(4)', '5': 'five(5)', '6': 'six(6)', '7': 'seven(7)', '8': 'eight(8)', '9': 'nine(9)', 'a': 'alpha', 'b': 'bravo', 'c': 'charlie', 'd': 'delta', 'e': 'echo', 'f': 'foxtrot', 'g': 'golf', 'h': 'hotel', 'i': 'india', 'j': 'juliett','k': 'kilo', 'l': 'lima', 'm': 'mike', 'n': 'november','o': 'oscar', 'p': 'papa', 'q': 'quebec', 'r': 'romeo', 's': 'sierra', 't': 'tango', 'u': 'uniform', 'v': 'victor', 'w': 'whiskey', 'x': 'x-ray', 'y': 'yankee', 'z': 'Zulu'} ns = '' for c in string: try: ns = ns + d_nato[c] + ' ' except: ns = ns + c + ' ' return ns # Class-based application configuration class ConfigClass(object): from config import MAIL_SERVER, MAIL_PORT, MAIL_USE_SSL, MAIL_USE_TLS, MAIL_USERNAME, MAIL_PASSWORD, MAIL_DEFAULT_SENDER, USER_ENABLE_EMAIL, USER_ENABLE_USERNAME, USER_REQUIRE_RETYPE_PASSWORD, USER_ENABLE_CHANGE_USERNAME, USER_ENABLE_MULTIPLE_EMAILS, USER_ENABLE_CONFIRM_EMAIL, USER_ENABLE_REGISTER, USER_AUTO_LOGIN_AFTER_CONFIRM, USER_SHOW_USERNAME_DOES_NOT_EXIST """ Flask application config """ # Flask settings SECRET_KEY = secret_key # Flask-SQLAlchemy settings SQLALCHEMY_DATABASE_URI = db_location # File-based SQL database SQLALCHEMY_TRACK_MODIFICATIONS = False # Avoids SQLAlchemy warning # Flask-User settings USER_APP_NAME = title # Shown in and email templates and page footers USER_EMAIL_SENDER_EMAIL = MAIL_DEFAULT_SENDER USER_EDIT_USER_PROFILE_TEMPLATE = 'flask_user/edit_user_profile.html' # Setup Flask-User def create_app(): """ Flask application factory """ # Create Flask app load app.config mail = Mail() app = Flask(__name__) app.config.from_object(__name__+'.ConfigClass') # Initialize Flask-BabelEx babel = Babel(app) # Initialize Flask-SQLAlchemy db = SQLAlchemy(app) # Define the User data-model. # NB: Make sure to add flask_user UserMixin !!! class User(db.Model, UserMixin): __tablename__ = 'users' id = db.Column(db.Integer, primary_key=True) active = db.Column('is_active', db.Boolean(), nullable=False, server_default='1') # User authentication information. The collation='NOCASE' is required # to search case insensitively when USER_IFIND_MODE is 'nocase_collation'. username = db.Column(db.String(100, collation='NOCASE'), nullable=False, unique=True) password = db.Column(db.String(255), nullable=False, server_default='') email_confirmed_at = db.Column(db.DateTime()) email = db.Column(db.String(255, collation='NOCASE'), nullable=False, unique=True) # User information first_name = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') last_name = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') dmr_ids = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') city = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') notes = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') #Used for initial approval initial_admin_approved = db.Column('initial_admin_approved', db.Boolean(), nullable=False, server_default='1') # Define the relationship to Role via UserRoles roles = db.relationship('Role', secondary='user_roles') # Define the Role data-model class Role(db.Model): __tablename__ = 'roles' id = db.Column(db.Integer(), primary_key=True) name = db.Column(db.String(50), unique=True) # Define the UserRoles association table class UserRoles(db.Model): __tablename__ = 'user_roles' id = db.Column(db.Integer(), primary_key=True) user_id = db.Column(db.Integer(), db.ForeignKey('users.id', ondelete='CASCADE')) role_id = db.Column(db.Integer(), db.ForeignKey('roles.id', ondelete='CASCADE')) class BurnList(db.Model): __tablename__ = 'burn_list' dmr_id = db.Column(db.Integer(), unique=True, primary_key=True) version = db.Column(db.Integer(), primary_key=True) class AuthLog(db.Model): __tablename__ = 'auth_log' login_dmr_id = db.Column(db.Integer(), primary_key=True) login_time = db.Column(db.DateTime(), primary_key=True) peer_ip = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') server_name = db.Column(db.Integer(), primary_key=True) login_auth_method = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') portal_username = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') login_type = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') class mmdvmPeer(db.Model): __tablename__ = 'MMDVM_peers' id = db.Column(db.Integer(), primary_key=True) name = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') enabled = db.Column(db.Boolean(), nullable=False, server_default='1') loose = db.Column(db.Boolean(), nullable=False, server_default='1') ip = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='127.0.0.1') port = db.Column(db.Integer(), primary_key=False) master_ip = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') master_port = db.Column(db.Integer(), primary_key=False) passphrase = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') callsign = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') radio_id = db.Column(db.Integer(), primary_key=False) rx_freq = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') tx_freq = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') tx_power = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') color_code = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') latitude = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') longitude = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') height = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') location = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') description = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') slots = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') url = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') software_id = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') package_id = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') group_hangtime = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') options = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') use_acl = db.Column(db.Boolean(), nullable=False, server_default='0') sub_acl = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') tg1_acl = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') tg2_acl = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') server = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') class xlxPeer(db.Model): __tablename__ = 'XLX_peers' id = db.Column(db.Integer(), primary_key=True) name = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') enabled = db.Column(db.Boolean(), nullable=False, server_default='1') loose = db.Column(db.Boolean(), nullable=False, server_default='1') ip = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='127.0.0.1') port = db.Column(db.Integer(), primary_key=False) master_ip = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') master_port = db.Column(db.Integer(), primary_key=False) passphrase = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') callsign = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') radio_id = db.Column(db.Integer(), primary_key=False) rx_freq = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') tx_freq = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') tx_power = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') color_code = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') latitude = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') longitude = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') height = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') location = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') description = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') slots = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') url = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') software_id = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') package_id = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') group_hangtime = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') xlxmodule = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') options = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') use_acl = db.Column(db.Boolean(), nullable=False, server_default='0') sub_acl = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') tg1_acl = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') tg2_acl = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') server = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') class ServerList(db.Model): __tablename__ = 'server_list' name = db.Column(db.String(100, collation='NOCASE'), unique=True, primary_key=True) secret = db.Column(db.String(255), nullable=False, server_default='') public_list = db.Column(db.Boolean(), nullable=False, server_default='1') id = db.Column(db.Integer(), primary_key=False) ip = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') port = db.Column(db.Integer(), primary_key=False) global_path = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='./') global_ping_time = db.Column(db.Integer(), primary_key=False) global_max_missed = db.Column(db.Integer(), primary_key=False) global_use_acl = db.Column(db.Boolean(), nullable=False, server_default='1') global_reg_acl = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='PERMIT:ALL') global_sub_acl = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='DENY:1') global_tg1_acl = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='PERMIT:ALL') global_tg2_acl = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='PERMIT:ALL') ai_try_download = db.Column(db.Boolean(), nullable=False, server_default='1') ai_path = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='./') ai_peer_file = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='peer_ids.json') ai_subscriber_file = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='subscriber_ids.json') ai_tgid_file = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='talkgroup_ids.json') ai_peer_url = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='https://www.radioid.net/static/rptrs.json') ai_subs_url = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='https://www.radioid.net/static/users.json') ai_stale = db.Column(db.Integer(), primary_key=False, server_default='7') # Pull from config file for now ## um_append_int = db.Column(db.Integer(), primary_key=False, server_default='2') um_shorten_passphrase = db.Column(db.Boolean(), nullable=False, server_default='0') um_burn_file = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='./burned_ids.txt') # Pull from config file for now ## um_burn_int = db.Column(db.Integer(), primary_key=False, server_default='6') report_enable = db.Column(db.Boolean(), nullable=False, server_default='1') report_interval = db.Column(db.Integer(), primary_key=False, server_default='60') report_port = db.Column(db.Integer(), primary_key=False, server_default='4321') report_clients =db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='127.0.0.1') class MasterList(db.Model): __tablename__ = 'master_list' id = db.Column(db.Integer(), primary_key=True) name = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') static_positions = db.Column(db.Boolean(), nullable=False, server_default='0') repeat = db.Column(db.Boolean(), nullable=False, server_default='1') max_peers = db.Column(db.Integer(), primary_key=False, server_default='10') ip = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') port = db.Column(db.Integer(), primary_key=False) enable_um = db.Column(db.Boolean(), nullable=False, server_default='1') passphrase = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') group_hang_time = db.Column(db.Integer(), primary_key=False, server_default='5') use_acl = db.Column(db.Boolean(), nullable=False, server_default='1') reg_acl = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') sub_acl = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') tg1_acl = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') tg2_acl = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') class BridgeRules(db.Model): __tablename__ = 'bridge_rules' id = db.Column(db.Integer(), primary_key=True) bridge_name = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') system_name = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') ts = db.Column(db.Integer(), primary_key=False) tg = db.Column(db.Integer(), primary_key=False) active = db.Column(db.Boolean(), nullable=False, server_default='1') timeout = db.Column(db.Integer(), primary_key=False) to_type = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') on = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') off = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') reset = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') server_list = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') class ExcludeUnit(db.Model): __tablename__ = 'exclude_unit' id = db.Column(db.Integer(), primary_key=True) system_name = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') server = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') class ServerMisc(db.Model): __tablename__ = 'server_misc' id = db.Column(db.Integer(), primary_key=True) server = db.Column(db.String(100, collation='NOCASE'), nullable=False, server_default='') unit_time = db.Column(db.Integer(), primary_key=False) # Customize Flask-User class CustomUserManager(UserManager): # Override or extend the default login view method def login_view(self): """Prepare and process the login form.""" # Authenticate username/email and login authenticated users. safe_next_url = self._get_safe_next_url('next', self.USER_AFTER_LOGIN_ENDPOINT) safe_reg_next = self._get_safe_next_url('reg_next', self.USER_AFTER_REGISTER_ENDPOINT) # Immediately redirect already logged in users if self.call_or_get(current_user.is_authenticated) and self.USER_AUTO_LOGIN_AT_LOGIN: return redirect(safe_next_url) # Initialize form login_form = self.LoginFormClass(request.form) # for login.html register_form = self.RegisterFormClass() # for login_or_register.html if request.method != 'POST': login_form.next.data = register_form.next.data = safe_next_url login_form.reg_next.data = register_form.reg_next.data = safe_reg_next # Process valid POST if request.method == 'POST' and login_form.validate(): # Retrieve User user = None user_email = None if self.USER_ENABLE_USERNAME: # Find user record by username user = self.db_manager.find_user_by_username(login_form.username.data) # Find user record by email (with form.username) if not user and self.USER_ENABLE_EMAIL: user, user_email = self.db_manager.get_user_and_user_email_by_email(login_form.username.data) else: # Find user by email (with form.email) user, user_email = self.db_manager.get_user_and_user_email_by_email(login_form.email.data) #Add aditional message if not user.initial_admin_approved: flash('You account is waiting for approval from an administrator. See the Help page for more information. You will receive an email when your account is approved.', 'success') if user: # Log user in safe_next_url = self.make_safe_url(login_form.next.data) return self._do_login_user(user, safe_next_url, login_form.remember_me.data) # Render form self.prepare_domain_translations() template_filename = self.USER_LOGIN_AUTH0_TEMPLATE if self.USER_ENABLE_AUTH0 else self.USER_LOGIN_TEMPLATE return render_template(template_filename, form=login_form, login_form=login_form, register_form=register_form) #user_manager = UserManager(app, db, User) user_manager = CustomUserManager(app, db, User) # Create all database tables db.create_all() if not User.query.filter(User.username == 'admin').first(): user = User( username='admin', email='admin@no.reply', email_confirmed_at=datetime.datetime.utcnow(), password=user_manager.hash_password('admin'), initial_admin_approved = True, notes='Default admin account created during installation.' ) user.roles.append(Role(name='Admin')) user.roles.append(Role(name='User')) db.session.add(user) db.session.commit() # Query radioid.net for list of DMR IDs, then add to DB @user_registered.connect_via(app) def _after_user_registered_hook(sender, user, **extra): edit_user = User.query.filter(User.username == user.username).first() radioid_data = ast.literal_eval(get_ids(user.username)) edit_user.dmr_ids = str(radioid_data[0]) edit_user.first_name = str(radioid_data[1]) edit_user.last_name = str(radioid_data[2]) edit_user.city = str(radioid_data[3]) user_role = UserRoles( user_id=edit_user.id, role_id=2, ) db.session.add(user_role) if default_account_state == False: edit_user.active = default_account_state edit_user.initial_admin_approved = False db.session.commit() def gen_passphrase(dmr_id): _new_peer_id = bytes_4(int(str(dmr_id)[:7])) trimmed_id = int(str(dmr_id)[:7]) b_list = get_burnlist() print(b_list) burned = False for ui in b_list.items(): print(ui) #print(b_list) if ui[0] == trimmed_id: if ui[0] != 0: calc_passphrase = base64.b64encode(bytes.fromhex(str(hex(libscrc.ccitt((_new_peer_id) + b_list[trimmed_id].to_bytes(2, 'big') + burn_int.to_bytes(2, 'big') + append_int.to_bytes(2, 'big') + bytes.fromhex(str(hex(libscrc.posix((_new_peer_id) + b_list[trimmed_id].to_bytes(2, 'big') + burn_int.to_bytes(2, 'big') + append_int.to_bytes(2, 'big'))))[2:].zfill(8)))))[2:].zfill(4)) + (_new_peer_id) + b_list[trimmed_id].to_bytes(2, 'big') + burn_int.to_bytes(2, 'big') + append_int.to_bytes(2, 'big') + bytes.fromhex(str(hex(libscrc.posix((_new_peer_id) + b_list[trimmed_id].to_bytes(2, 'big') + burn_int.to_bytes(2, 'big') + append_int.to_bytes(2, 'big'))))[2:].zfill(8))) burned = True if burned == False: calc_passphrase = base64.b64encode(bytes.fromhex(str(hex(libscrc.ccitt((_new_peer_id) + append_int.to_bytes(2, 'big') + bytes.fromhex(str(hex(libscrc.posix((_new_peer_id) + append_int.to_bytes(2, 'big'))))[2:].zfill(8)))))[2:].zfill(4)) + (_new_peer_id) + append_int.to_bytes(2, 'big') + bytes.fromhex(str(hex(libscrc.posix((_new_peer_id) + append_int.to_bytes(2, 'big'))))[2:].zfill(8))) if use_short_passphrase == True: return str(calc_passphrase)[-9:-1] elif use_short_passphrase ==False: return str(calc_passphrase)[2:-1] def update_from_radioid(callsign): edit_user = User.query.filter(User.username == callsign).first() #edit_user.dmr_ids = str(ast.literal_eval(get_ids(callsign))[0]) radioid_dict = ast.literal_eval(get_ids(callsign))[0] db_id_dict = ast.literal_eval(edit_user.dmr_ids) new_id_dict = db_id_dict.copy() for i in radioid_dict.items(): if i[0] in db_id_dict: pass elif i[0] not in db_id_dict: new_id_dict[i[0]] = 0 edit_user.dmr_ids = str(new_id_dict) edit_user.first_name = str(ast.literal_eval(get_ids(callsign))[1]) edit_user.last_name = str(ast.literal_eval(get_ids(callsign))[2]) edit_user.city = str(ast.literal_eval(get_ids(callsign))[3]) db.session.commit() # The Home page is accessible to anyone @app.route('/') def home_page(): #content = Markup('Index') return render_template('index.html') #, markup_content = content) @app.route('/help') def help_page(): #content = Markup('Index') return render_template('help.html') @app.route('/generate_passphrase/pi-star', methods = ['GET']) @login_required def gen_pi_star(): try: u = current_user ## print(u.username) id_dict = ast.literal_eval(u.dmr_ids) #u = User.query.filter_by(username=user).first() ## print(user_id) ## print(request.args.get('mode')) ## if request.args.get('mode') == 'generated': content = '''

Pi-Star Instructions

 

1: Log into your Pi-Star device.
2: Change to Read-Write mode of the device by issuing the command:

rpi-rw


3a: Change to the root user by issuing the command:

sudo su -


3b: Now type pwd and verify you get a return indicating you are in the /root directory. If you are in the wrong directory, it is because you're not following the instructions and syntax above! This is a show stopper, and your attempt to load the files correctly, will fail !

4: Issue one of the commands below for the chosen DMR ID:

Note: Link can be used only once. To run the script again, simply reload the page and paste a new command into the command line.

''' for i in id_dict.items(): #if i[1] == '': link_num = str(random.randint(1,99999999)).zfill(8) + str(time.time()) + str(random.randint(1,99999999)).zfill(8) script_links[i[0]] = link_num content = content + '''\n

DMR ID: ''' + str(i[0]) + ''':

bash <(curl -s "''' + str(url) + '/get_script?dmr_id=' + str(i[0]) + '&number=' + str(link_num) + '''")

 

''' #else: # content = content + '''\n

Error

''' content = content + '''\n


5: When asked for server ports, use the information above to populate the correct fields.
6: Reboot your Pi-Star device

 

''' except: content = Markup('No DMR IDs found or other error.') #return str(content) return render_template('flask_user_layout.html', markup_content = Markup(content)) @app.route('/generate_passphrase', methods = ['GET']) @login_required def gen(): #print(str(gen_passphrase(3153591))) #(int(i[0]))) try: #content = Markup('The HTML String') #user_id = request.args.get('user_id') u = current_user ## print(u.username) id_dict = ast.literal_eval(u.dmr_ids) #u = User.query.filter_by(username=user).first() ## print(user_id) ## print(request.args.get('mode')) ## if request.args.get('mode') == 'generated': #print(id_dict) content = '\n' for i in id_dict.items(): if isinstance(i[1], int) == True and i[1] != 0: link_num = str(random.randint(1,99999999)).zfill(8) + str(time.time()) + str(random.randint(1,99999999)).zfill(8) script_links[i[0]] = link_num #print(script_links) content = content + '''\n

Your passphrase for ''' + str(i[0]) + ''':

Copy and paste: ''' + str(gen_passphrase(int(i[0]))) + '''

Phonetically spelled: ''' + convert_nato(str(gen_passphrase(int(i[0])))) + '''

 

''' elif i[1] == 0: link_num = str(random.randint(1,99999999)).zfill(8) + str(time.time()) + str(random.randint(1,99999999)).zfill(8) script_links[i[0]] = link_num #print(script_links) content = content + '''\n

Your passphrase for ''' + str(i[0]) + ''':

Copy and paste: ''' + str(gen_passphrase(int(i[0]))) + '''

Phonetically spelled: ''' + convert_nato(str(gen_passphrase(int(i[0])))) + '''

 

''' elif i[1] == '': content = content + '''

Your passphrase for ''' + str(i[0]) + ''':

Copy and paste: ''' + legacy_passphrase + '''

Phonetically spelled: ''' + convert_nato(legacy_passphrase) + '''

 

''' else: content = content + '''

Your passphrase for ''' + str(i[0]) + ''':

Copy and paste: ''' + str(i[1]) + '''

Phonetically spelled: ''' + convert_nato(str(i[1])) + '''

 

''' #content = content + '\n\n' + str(script_links[i[0]]) except: content = Markup('No DMR IDs found or other error.') #return str(content) return render_template('view_passphrase.html', markup_content = Markup(content)) ## # The Members page is only accessible to authenticated users via the @login_required decorator ## @app.route('/members') ## @login_required # User must be authenticated ## def member_page(): ## content = 'Mem only' ## return render_template('flask_user_layout.html', markup_content = content) @app.route('/update_ids', methods=['POST', 'GET']) @login_required # User must be authenticated def update_info(): #print(request.args.get('callsign')) #print(current_user.username) if request.args.get('callsign') == current_user.username or request.args.get('callsign') and request.args.get('callsign') != current_user.username and current_user.has_roles('Admin'): content = '

Updated your information.

' update_from_radioid(request.args.get('callsign')) else: content = '''

Use this page to sync changes from RadioID.net with this system (such as a new DMR ID, name change, etc.).

Updating your information from RadioID.net will overwrite any custom authentication passphrases, your city, and name in the database. Are you sure you want to continue?

 

Yes, update my information.

''' return render_template('flask_user_layout.html', markup_content = Markup(content)) @app.route('/email_user', methods=['POST', 'GET']) @roles_required('Admin') @login_required # User must be authenticated def email_user(): if request.method == 'GET' and request.args.get('callsign'): content = '''

Send email to user: ''' + request.args.get('callsign') + '''

 

''' elif request.method == 'POST': # and request.form.get('callsign') and request.form.get('subject') and request.form.get('message'): u = User.query.filter_by(username=request.args.get('callsign')).first() msg = Message(recipients=[u.email], subject=request.form.get('subject'), body=request.form.get('message')) mail.send(msg) content = '

Sent email to: ' + u.email + '

' else: content = '''

Find user in "List Users", then click on the email link.'

''' return render_template('flask_user_layout.html', markup_content = Markup(content)) @app.route('/list_users') @roles_required('Admin') @login_required # User must be authenticated def list_users(): u = User.query.all() # Broken for now, link taken out -

List/edit users:

 

Enter Callsign

u_list = '''

 

''' for i in u: u_list = u_list + ''' '''+ '\n' content = u_list + '''
Callsign Name Enabled DMR ID:Authentication Notes
 ''' + str(i.username) + '''   ''' + str(i.first_name) + ' ' + str(i.last_name) + '''   ''' + str(i.active) + '''   ''' + str(i.dmr_ids) + '''   ''' + str(i.notes) + ''' 

 

''' return render_template('flask_user_layout.html', markup_content = Markup(content)) @app.route('/approve_users', methods=['POST', 'GET']) @login_required @roles_required('Admin') # Use of @roles_required decorator def approve_list(): u = User.query.all() wait_list = '''

Users waiting for approval:

 

''' for i in u: ## print(i.username) ## print(i.initial_admin_approved) if i.initial_admin_approved == False: wait_list = wait_list+ ''' '''+ '\n' content = wait_list + '''
Callsign Name Enabled DMR ID:Authentication
 ''' + str(i.username) + '''   ''' + str(i.first_name) + ' ' + str(i.last_name) + '''   ''' + str(i.active) + '''   ''' + str(i.dmr_ids) + ''' 

 

''' return render_template('flask_user_layout.html', markup_content = Markup(content)) # The Admin page requires an 'Admin' role. @app.route('/edit_user', methods=['POST', 'GET']) @login_required @roles_required('Admin') # Use of @roles_required decorator def admin_page(): #print(request.args.get('callsign')) #print(request.args.get('callsign')) ## if request.method == 'POST' and request.form.get('callsign'): ## #result = request.json ## callsign = request.form.get('callsign') ## u = User.query.filter_by(username=callsign).first() ## content = u.dmr_ids if request.method == 'POST' and request.args.get('callsign') == None: content = 'Not found' elif request.method == 'POST' and request.args.get('callsign') and request.form.get('user_status'): user = request.args.get('callsign') #print(user) edit_user = User.query.filter(User.username == user).first() content = '' if request.form.get('user_status') != edit_user.active: if request.form.get('user_status') == "True": edit_user.active = True content = content + '''

User ''' + str(user) + ''' has been enabled.

\n''' if request.form.get('user_status') == "False": edit_user.active = False content = content + '''

User ''' + str(user) + ''' has been disabled.

\n''' ## print(request.form.get('username')) if user != request.form.get('username'): #### #print(edit_user.username) content = content + '''

User ''' + str(user) + ''' changed to ''' + request.form.get('username') + '''.

\n''' edit_user.username = request.form.get('username') if request.form.get('email') != edit_user.email: edit_user.email = request.form.get('email') content = content + '''

Changed email for user: ''' + str(user) + ''' to ''' + request.form.get('email') + '''

\n''' if request.form.get('notes') != edit_user.notes: edit_user.notes = request.form.get('notes') content = content + '''

Changed notes for user: ''' + str(user) + '''.

\n''' if request.form.get('password') != '': edit_user.password = user_manager.hash_password(request.form.get('password')) content = content + '''

Changed password for user: ''' + str(user) + '''

\n''' if request.form.get('dmr_ids') != edit_user.dmr_ids: edit_user.dmr_ids = request.form.get('dmr_ids') dmr_auth_dict = ast.literal_eval(request.form.get('dmr_ids')) for id_user in dmr_auth_dict: if isinstance(dmr_auth_dict[id_user], int) == True and dmr_auth_dict[id_user] != 0: #print('burn it') if id_user in get_burnlist(): ## print('burned') if get_burnlist()[id_user] != dmr_auth_dict[id_user]: ## print('update vers') update_burnlist(id_user, dmr_auth_dict[id_user]) else: pass ## print('no update') else: add_burnlist(id_user, dmr_auth_dict[id_user]) ## print('not in list, adding') elif isinstance(dmr_auth_dict[id_user], int) == False and id_user in get_burnlist(): delete_burnlist(id_user) ## print('remove from burn list - string') elif dmr_auth_dict[id_user] == 0: ## print('remove from burn list') if id_user in get_burnlist(): delete_burnlist(id_user) content = content + '''

Changed authentication settings for user: ''' + str(user) + '''

\n''' db.session.commit() #edit_user = User.query.filter(User.username == request.args.get('callsign')).first() elif request.method == 'GET' and request.args.get('callsign') and request.args.get('delete_user') == 'true': delete_user = User.query.filter(User.username == request.args.get('callsign')).first() db.session.delete(delete_user) db.session.commit() content = '''

Deleted user: ''' + str(delete_user.username) + '''

\n''' elif request.method == 'GET' and request.args.get('callsign') and request.args.get('make_user_admin') == 'true': u = User.query.filter_by(username=request.args.get('callsign')).first() u_role = UserRoles.query.filter_by(user_id=u.id).first() u_role.role_id = 1 db.session.commit() content = '''

User now Admin: ''' + str(request.args.get('callsign')) + '''

\n''' elif request.method == 'GET' and request.args.get('callsign') and request.args.get('make_user_admin') == 'false': u = User.query.filter_by(username=request.args.get('callsign')).first() u_role = UserRoles.query.filter_by(user_id=u.id).first() u_role.role_id = 2 db.session.commit() content = '''

Admin now a user: ''' + str(request.args.get('callsign') ) + '''

\n''' elif request.method == 'GET' and request.args.get('callsign') and request.args.get('admin_approve') == 'true': edit_user = User.query.filter(User.username == request.args.get('callsign')).first() edit_user.active = True edit_user.initial_admin_approved = True db.session.commit() msg = Message(recipients=[edit_user.email], subject='Account Approval - ' + title, body='''You are receiving this message because an administrator has approved your account. You may now login and view your MMDVM passphrase(s).''') mail.send(msg) content = '''

User approved: ''' + str(request.args.get('callsign')) + '''

\n''' elif request.method == 'GET' and request.args.get('callsign') and request.args.get('email_verified') == 'true': edit_user = User.query.filter(User.username == request.args.get('callsign')).first() edit_user.email_confirmed_at = datetime.datetime.utcnow() db.session.commit() content = '''

Email verified for: ''' + str(request.args.get('callsign')) + '''

\n''' elif request.method == 'POST' and request.form.get('callsign') and not request.form.get('user_status') or request.method == 'GET' and request.args.get('callsign'):# and request.form.get('user_status') : if request.args.get('callsign'): callsign = request.args.get('callsign') if request.form.get('callsign'): callsign = request.form.get('callsign') u = User.query.filter_by(username=callsign).first() confirm_link = '' if u.email_confirmed_at == None: confirm_link = '''

Verify email - ''' + str(u.username) + '''

\n''' u_role = UserRoles.query.filter_by(user_id=u.id).first() if u_role.role_id == 2: # Link to promote to Admin role_link = '''

Give Admin role: ''' + str(u.username) + '''

\n''' if u_role.role_id == 1: # Link to promote to User role_link = '''

Revert to User role: ''' + str(u.username) + '''

\n''' id_dict = ast.literal_eval(u.dmr_ids) passphrase_list = ''' ''' for i in id_dict.items(): print(i[1]) if isinstance(i[1], int) == True: passphrase_list = passphrase_list + ''' \n''' if i[1] == '': passphrase_list = passphrase_list + ''' \n''' if not isinstance(i[1], int) == True and i[1] != '': passphrase_list = passphrase_list + ''' \n''' passphrase_list = passphrase_list + '
DMR ID Passphrase
''' + str(i[0]) + ''' ''' + str(gen_passphrase(int(i[0]))) + '''
''' + str(i[0]) + ''' ''' + legacy_passphrase + '''
''' + str(i[0]) + ''' ''' + str(i[1]) + '''
' content = '''

 

First Name Last Name
 ''' + u.first_name + '''  ''' + u.last_name + '''
City ''' + u.city + '''

 

''' + passphrase_list + '''

 Options for: ''' + u.username + ''' 

 

Update from RadioID.net

 		  ''' + confirm_link + ''' 

Email confirmed: ''' + str(u.email_confirmed_at) + '''
 

Send user an email

 		  ''' + role_link + ''' 
 

View user auth log

 		  

Deleted user

 











 

 Passphrase Authentication Method Key

Calculated Legacy (config) Custom
0 - default,
1-999 - new calculation		 '' 'passphrase'

{DMR ID: Method, 2nd DMR ID: Method}

Example:
{1234567: '', 134568: 0, 1234569: 'passphr8s3'}

''' else: content = '''

 

''' return render_template('flask_user_layout.html', markup_content = Markup(content)) @app.route('/get_script') def get_script(): dmr_id = int(request.args.get('dmr_id')) number = float(request.args.get('number')) #print(type(script_links[dmr_id])) u = User.query.filter(User.dmr_ids.contains(request.args.get('dmr_id'))).first() #print(u.dmr_ids) if authorized_peer(dmr_id)[1] == 0: passphrase = gen_passphrase(dmr_id) elif authorized_peer(dmr_id)[1] != 0 and isinstance(authorized_peer(dmr_id)[1], int) == True: passphrase = gen_passphrase(dmr_id) elif authorized_peer(dmr_id)[1] == '': passphrase = legacy_passphrase print(passphrase) elif authorized_peer(dmr_id)[1] != '' or authorized_peer(dmr_id)[1] != 0: passphrase = authorized_peer(dmr_id)[1] #try: if dmr_id in script_links and number == float(script_links[dmr_id]): script_links.pop(dmr_id) return str(gen_script(dmr_id, passphrase)) #except: #else: #content = 'Link used or other error.' #return content #return render_template('flask_user_layout.html', markup_content = content, logo = logo) def authorized_peer(peer_id): try: u = User.query.filter(User.dmr_ids.contains(str(peer_id))).first() login_passphrase = ast.literal_eval(u.dmr_ids) return [u.is_active, login_passphrase[peer_id], str(u.username)] except: return [False] @app.route('/auth_log', methods=['POST', 'GET']) @login_required # User must be authenticated @roles_required('Admin') def all_auth_list(): if request.args.get('flush_db') == 'true': content = '''

Flushed entire auth DB.

\n''' authlog_flush() elif request.args.get('flush_user_db') == 'true' and request.args.get('portal_username'): content = '''

Flushed auth DB for: ''' + request.args.get('portal_username') + '''

\n''' authlog_flush_user(request.args.get('portal_username')) elif request.args.get('flush_db_mmdvm') == 'true' and request.args.get('mmdvm_server'): content = '''

Flushed auth DB for: ''' + request.args.get('mmdvm_server') + '''

\n''' authlog_flush_mmdvm_server(request.args.get('mmdvm_server')) elif request.args.get('flush_db_ip') == 'true' and request.args.get('peer_ip'): content = '''

Flushed auth DB for: ''' + request.args.get('peer_ip') + '''

\n''' authlog_flush_ip(request.args.get('peer_ip')) elif request.args.get('flush_dmr_id_db') == 'true' and request.args.get('dmr_id'): content = '''

Flushed auth DB for: ''' + request.args.get('dmr_id') + '''

\n''' authlog_flush_dmr_id(request.args.get('dmr_id')) elif request.args.get('portal_username') and not request.args.get('flush_user_db') and not request.args.get('flush_dmr_id_db') or request.args.get('dmr_id') and not request.args.get('flush_user_db') and not request.args.get('flush_dmr_id_db'): if request.args.get('portal_username'): ## s_filter = portal_username=request.args.get('portal_username') a = AuthLog.query.filter_by(portal_username=request.args.get('portal_username')).order_by(AuthLog.login_time.desc()).all() g_arg = request.args.get('portal_username') f_link = '''

Flush auth log for: ''' + request.args.get('portal_username') + '''

''' elif request.args.get('dmr_id'): ## s_filter = login_dmr_id=request.args.get('dmr_id') a = AuthLog.query.filter_by(login_dmr_id=request.args.get('dmr_id')).order_by(AuthLog.login_time.desc()).all() g_arg = request.args.get('dmr_id') f_link = '''

Flush auth log for: ''' + request.args.get('dmr_id') + '''

''' ## print(s_filter) ## a = AuthLog.query.filter_by(s_filter).order_by(AuthLog.login_dmr_id.desc()).all() content = '''

 

Log for: ''' + g_arg + '''

''' + f_link + ''' \n''' for i in a: if i.login_type == 'Attempt': content = content + ''' ''' if i.login_type == 'Confirmed': content = content + ''' ''' if i.login_type == 'Failed': content = content + ''' ''' content = content + '

 DMR ID 

 Portal Username 

 Login IP 

 Passphrase 

 Server 

 Time (UTC) 

 Login Status 
 ''' + str(i.login_dmr_id) + '''    ''' + i.portal_username + '''    ''' + str(i.peer_ip) + '''   ''' + i.login_auth_method + '''   ''' + str(i.server_name) + '''   ''' + str(i.login_time) + '''   ''' + str(i.login_type) + ''' 
 ''' + str(i.login_dmr_id) + '''   ''' + i.portal_username + '''    ''' + str(i.peer_ip) + '''   ''' + i.login_auth_method + '''   ''' + str(i.server_name) + '''   ''' + str(i.login_time) + '''   ''' + str(i.login_type) + ''' 
 ''' + str(i.login_dmr_id) + '''   ''' + i.portal_username + '''    ''' + str(i.peer_ip) + '''   ''' + i.login_auth_method + '''   ''' + str(i.server_name) + '''   ''' + str(i.login_time) + '''   ''' + str(i.login_type) + ''' 
' elif request.args.get('mmdvm_server') and not request.args.get('flush_db_mmdvm'): a = AuthLog.query.filter_by(server_name=request.args.get('mmdvm_server')).order_by(AuthLog.login_time.desc()).all() content = '''

 

Flush authentication log for server: ''' + request.args.get('mmdvm_server') + '''

Log for MMDVM server: ''' + request.args.get('mmdvm_server') + '''

\n''' for i in a: if i.login_type == 'Attempt': content = content + ''' ''' if i.login_type == 'Confirmed': content = content + ''' ''' if i.login_type == 'Failed': content = content + ''' ''' content = content + '

 DMR ID 

 Portal Username 

 Login IP 

 Passphrase 

 Server 

 Time (UTC) 

 Login Status 
 ''' + str(i.login_dmr_id) + '''    ''' + i.portal_username + '''    ''' + str(i.peer_ip) + '''   ''' + i.login_auth_method + '''   ''' + i.server_name + '''   ''' + str(i.login_time) + '''   ''' + str(i.login_type) + ''' 
 ''' + str(i.login_dmr_id) + '''   ''' + i.portal_username + '''    ''' + str(i.peer_ip) + '''   ''' + i.login_auth_method + '''   ''' + i.server_name + '''   ''' + str(i.login_time) + '''   ''' + str(i.login_type) + ''' 
 ''' + str(i.login_dmr_id) + '''   ''' + i.portal_username + '''    ''' + str(i.peer_ip) + '''   ''' + i.login_auth_method + '''   ''' + i.server_name + '''   ''' + str(i.login_time) + '''   ''' + str(i.login_type) + ''' 
' elif request.args.get('peer_ip') and not request.args.get('flush_db_ip'): a = AuthLog.query.filter_by(peer_ip=request.args.get('peer_ip')).order_by(AuthLog.login_time.desc()).all() content = '''

 

Flush authentication log for IP: ''' + request.args.get('peer_ip') + '''

Log for IP address: ''' + request.args.get('peer_ip') + '''

\n''' for i in a: if i.login_type == 'Attempt': content = content + ''' ''' if i.login_type == 'Confirmed': content = content + ''' ''' if i.login_type == 'Failed': content = content + ''' ''' content = content + '

 DMR ID 

 Portal Username 

 Login IP 

 Passphrase 

 Server 

 Time (UTC) 

 Login Status 
 ''' + str(i.login_dmr_id) + '''    ''' + i.portal_username + '''   ''' + i.peer_ip + '''   ''' + i.login_auth_method + '''   ''' + str(i.server_name) + '''   ''' + str(i.login_time) + '''   ''' + str(i.login_type) + ''' 
 ''' + str(i.login_dmr_id) + '''   ''' + i.portal_username + '''   ''' + i.peer_ip + '''   ''' + i.login_auth_method + '''   ''' + str(i.server_name) + '''   ''' + str(i.login_time) + '''   ''' + str(i.login_type) + ''' 
 ''' + str(i.login_dmr_id) + '''   ''' + i.portal_username + '''   ''' + i.peer_ip + '''   ''' + i.login_auth_method + '''   ''' + str(i.server_name) + '''   ''' + str(i.login_time) + '''   ''' + str(i.login_type) + ''' 
' else: #a = AuthLog.query.all() ## a = AuthLog.query.order_by(AuthLog.login_time.desc()).limit(300).all() a = AuthLog.query.order_by(AuthLog.login_time.desc()).all() recent_list = [] ## r = AuthLog.query.order_by(AuthLog.login_dmr_id.desc()).all() content = '''

 

Flush entire authentication log

Un-registered authentication attempts

Authentication log by DMR ID

\n''' for i in a: if i.login_dmr_id not in recent_list: recent_list.append(i.login_dmr_id) if i.login_type == 'Attempt': content = content + ''' ''' if i.login_type == 'Confirmed': content = content + ''' ''' if i.login_type == 'Failed': content = content + ''' ''' content = content + '

 DMR ID 

 Portal Username 

 Login IP 

 Passphrase 

 Server 

 Time (UTC) 

 Last Login Status 
 ''' + str(i.login_dmr_id) + '''   ''' + i.portal_username + '''    ''' + str(i.peer_ip) + '''   ''' + i.login_auth_method + '''   ''' + str(i.server_name) + '''   ''' + str(i.login_time) + '''   ''' + str(i.login_type) + ''' 
 ''' + str(i.login_dmr_id) + '''   ''' + i.portal_username + '''    ''' + str(i.peer_ip) + '''   ''' + i.login_auth_method + '''   ''' + str(i.server_name) + '''   ''' + str(i.login_time) + '''   ''' + str(i.login_type) + ''' 
 ''' + str(i.login_dmr_id) + '''   ''' + i.portal_username + '''    ''' + str(i.peer_ip) + '''   ''' + i.login_auth_method + '''   ''' + str(i.server_name) + '''   ''' + str(i.login_time) + '''   ''' + str(i.login_type) + ''' 
' return render_template('flask_user_layout.html', markup_content = Markup(content)) @app.route('/test') def test_peer(): #user = User( # username='admin3', # email_confirmed_at=datetime.datetime.utcnow(), # password=user_manager.hash_password('admin'), # ) #user.roles.append(Role(name='Admin')) #user.roles.append(Role(name='User')) #user.add_roles('Admin') #db.session.add(user) #db.session.commit() u = User.query.filter_by(username='kf7eel').first() #u = Role.query.all() ## u = User.query.filter(User.dmr_ids.contains('3153591')).first() #u = User.query.all() ## #tu = User.query().all() #### print((tu.dmr_ids)) #### #print(tu.dmr_ids) #### return str(tu.dmr_ids) #str(get_ids('kf7eel')) ## login_passphrase = ast.literal_eval(u.dmr_ids) ## print('|' + login_passphrase[3153591] + '|') ## #print(u.dmr_ids) ## #tu.dmr_ids = 'jkgfldj' ## #db.session.commit() ## return str(u.dmr_ids) ## u = User.query.filter(User.dmr_ids.contains('3153591')).first() ## #tu = User.query.all() ## #tu = User.query().all() #### print((tu.dmr_ids)) #### #print(tu.dmr_ids) #### return str(tu.dmr_ids) #str(get_ids('kf7eel')) ## print(u) ## login_passphrase = ast.literal_eval(u.dmr_ids) ## ## #tu.dmr_ids = 'jkgfldj' ## #db.session.commit() ## return str([u.is_active, login_passphrase[3153591]]) #edit_user = User.query.filter(User.username == 'bob').first() #edit_user.active = False #db.session.commit() #print((current_user.has_roles('Admin'))) #u.roles.append(Role(name='Admin')) #print((current_user.has_roles('Admin'))) #db.session.commit() #db.session.add(u) #db.session.commit() ## admin_role = UserRoles( ## user_id=3, ## role_id=1, ## ) ## user_role = UserRoles( ## user_id=3, ## role_id=2, ## ) ## db.session.add(user_role) ## db.session.add(admin_role) ## db.session.commit() #print(role) ## for i in u: ## print(i.username) #u = User.query.filter_by(username='kf7eel').first() #print(u.id) #u_role = UserRoles.query.filter_by(user_id=u.id).first() #if u_role.role_id == 2: # print('userhasjkdhfdsejksfdahjkdhjklhjkhjkl') ## print(u.has_roles('Admin')) #u_role.role_id = 1 #print(u) # for i in u: ##print(i.initial_admin_approved) #if not i.initial_admin_approved: #print(i.username) # print(i) #u_role = UserRoles.query.filter_by(id=2).first().role_id #u_role = 1 # db.session.commit() #u_role = UserRoles.query.filter_by(id=u.id).first().role_id #print(u_role) #return str(u) ## if not u.active: ## flash('We come in peace', 'success') ## content = 'hello' #add ## burn_list = BurnList( ## dmr_id=3153595, ## version=1, ## ) ## db.session.add(burn_list) ## db.session.commit() ## #generate dict ## b = BurnList.query.all() ## print(b) ## burn_dict = {} ## for i in b: ## print(i.dmr_id) ## burn_dict[i.dmr_id] = i.version ## content = burn_dict ## # delete #### delete_b = BurnList.query.filter_by(dmr_id=3153591).first() #### db.session.delete(delete_b) #### db.session.commit() ## a = AuthLog.query.all() ## print(a) ## authlog_flush() peer_delete('mmdvm', 1) return render_template('flask_user_layout.html', markup_content = Markup(content)) def get_peer_configs(_server_name): mmdvm_pl = mmdvmPeer.query.filter_by(server=_server_name).all() xlx_pl = xlxPeer.query.filter_by(server=_server_name).all() print(mmdvm_pl) peer_config_list = {} for i in mmdvm_pl: print(i) ## print(i.master_ip) peer_config_list.update({i.name: { 'MODE': 'PEER', 'ENABLED': i.enabled, 'LOOSE': i.loose, 'SOCK_ADDR': (gethostbyname(i.ip), i.port), 'IP': i.ip, 'PORT': i.port, 'MASTER_SOCKADDR': (gethostbyname(i.master_ip), i.master_port), 'MASTER_IP': i.master_ip, 'MASTER_PORT': i.master_port, 'PASSPHRASE': bytes((i.passphrase), 'utf-8'), 'CALLSIGN': bytes((i.callsign).ljust(8)[:8], 'utf-8'), 'RADIO_ID': int(i.radio_id), #int(i.radio_id).to_bytes(4, 'big'), 'RX_FREQ': bytes((i.rx_freq).ljust(9)[:9], 'utf-8'), 'TX_FREQ': bytes((i.tx_freq).ljust(9)[:9], 'utf-8'), 'TX_POWER': bytes((i.tx_power).rjust(2,'0'), 'utf-8'), 'COLORCODE': bytes((i.color_code).rjust(2,'0'), 'utf-8'), 'LATITUDE': bytes((i.latitude).ljust(8)[:8], 'utf-8'), 'LONGITUDE': bytes((i.longitude).ljust(9)[:9], 'utf-8'), 'HEIGHT': bytes((i.height).rjust(3,'0'), 'utf-8'), 'LOCATION': bytes((i.location).ljust(20)[:20], 'utf-8'), 'DESCRIPTION': bytes((i.description).ljust(19)[:19], 'utf-8'), 'SLOTS': bytes((i.slots), 'utf-8'), 'URL': bytes((i.url).ljust(124)[:124], 'utf-8'), 'SOFTWARE_ID': bytes((i.software_id).ljust(40)[:40], 'utf-8'), 'PACKAGE_ID': bytes((i.package_id).ljust(40)[:40], 'utf-8'), 'GROUP_HANGTIME': i.group_hangtime, 'OPTIONS': b''.join([b'Type=HBlink;', bytes(i.options, 'utf-8')]), 'USE_ACL': i.use_acl, 'SUB_ACL': i.sub_acl, 'TG1_ACL': i.tg1_acl, 'TG2_ACL': i.tg2_acl }}) for i in xlx_pl: peer_config_list.update({i: { 'MODE': 'XLX', 'ENABLED': i.enabled, 'LOOSE': i.loose, 'SOCK_ADDR': (gethostbyname(i.ip), i.port), 'IP': i.ip, 'PORT': i.port, 'MASTER_SOCKADDR': (gethostbyname(i.master_ip), i.master_port), 'MASTER_IP': i.master_ip, 'MASTER_PORT': i.master_port, 'PASSPHRASE': bytes((i.passphrase), 'utf-8'), 'CALLSIGN': bytes((i.callsign).ljust(8)[:8], 'utf-8'), 'RADIO_ID': int(i.radio_id), 'RX_FREQ': bytes((i.rx_freq).ljust(9)[:9], 'utf-8'), 'TX_FREQ': bytes((i.tx_freq).ljust(9)[:9], 'utf-8'), 'TX_POWER': bytes((i.tx_power).rjust(2,'0'), 'utf-8'), 'COLORCODE': bytes((i.color_code).rjust(2,'0'), 'utf-8'), 'LATITUDE': bytes((i.latitude).ljust(8)[:8], 'utf-8'), 'LONGITUDE': bytes((i.longitude).ljust(9)[:9], 'utf-8'), 'HEIGHT': bytes((i.height).rjust(3,'0'), 'utf-8'), 'LOCATION': bytes((i.location).ljust(20)[:20], 'utf-8'), 'DESCRIPTION': bytes((i.description).ljust(19)[:19], 'utf-8'), 'SLOTS': bytes((i.slots), 'utf-8'), 'URL': bytes((i.url).ljust(124)[:124], 'utf-8'), 'SOFTWARE_ID': bytes((i.software_id).ljust(40)[:40], 'utf-8'), 'PACKAGE_ID': bytes((i.package_id).ljust(40)[:40], 'utf-8'), 'GROUP_HANGTIME': i.group_hangtime, 'XLXMODULE': i.xlxmodule, 'OPTIONS': b''.join([b'Type=HBlink;', bytes(i.options, 'utf-8')]), 'USE_ACL': i.use_acl, 'SUB_ACL': i.sub_acl, 'TG1_ACL': i.tg1_acl, 'TG2_ACL': i.tg2_acl }}) print((peer_config_list)) return peer_config_list def get_burnlist(): b = BurnList.query.all() #print(b) burn_dict = {} for i in b: #print(i.dmr_id) burn_dict[i.dmr_id] = i.version return burn_dict def add_burnlist(_dmr_id, _version): burn_list = BurnList( dmr_id=_dmr_id, version=_version, ) db.session.add(burn_list) db.session.commit() def update_burnlist(_dmr_id, _version): update_b = BurnList.query.filter_by(dmr_id=_dmr_id).first() update_b.version=_version db.session.commit() def delete_burnlist(_dmr_id): delete_b = BurnList.query.filter_by(dmr_id=_dmr_id).first() db.session.delete(delete_b) db.session.commit() def authlog_add(_dmr_id, _peer_ip, _server_name, _portal_username, _auth_method, _login_type): auth_log_add = AuthLog( login_dmr_id=_dmr_id, login_time=datetime.datetime.utcnow(), portal_username = _portal_username, peer_ip = _peer_ip, server_name = _server_name, login_auth_method=_auth_method, login_type=_login_type ) db.session.add(auth_log_add) db.session.commit() def authlog_flush(): AuthLog.query.delete() db.session.commit() def authlog_flush_user(_user): flush_e = AuthLog.query.filter_by(portal_username=_user).all() for i in flush_e: db.session.delete(i) db.session.commit() def authlog_flush_dmr_id(_dmr_id): flush_e = AuthLog.query.filter_by(login_dmr_id=_dmr_id).all() for i in flush_e: db.session.delete(i) db.session.commit() def authlog_flush_mmdvm_server(_mmdvm_serv): flush_e = AuthLog.query.filter_by(server_name=_mmdvm_serv).all() for i in flush_e: db.session.delete(i) db.session.commit() def authlog_flush_ip(_ip): flush_e = AuthLog.query.filter_by(peer_ip=_ip).all() for i in flush_e: db.session.delete(i) db.session.commit() ## def peer_delete(_mode, _id): ## if _mode == 'xlx': ## p = xlxPeer.query.filter_by(id=_id).first() ## if _mode == 'mmdvm': ## p = mmdvmPeer.query.filter_by(id=_id).first() ## db.session.delete(p) ## db.session.commit() def server_delete(_name): s = ServerList.query.filter_by(name=_name).first() db.session.delete(s) db.session.commit() def peer_delete(_mode, _server, _name): print(_server) print(_name) if _mode == 'mmdvm': p = mmdvmPeer.query.filter_by(server=_server).filter_by(name=_name).first() if _mode == 'xlx': p = xlxPeer.query.filter_by(server=_server).filter_by(name=_name).first() db.session.delete(p) db.session.commit() def shared_secrets(): s = ServerList.query.all() #filter_by(name=_name).first() r_list = [] for i in s: r_list.append(str(i.secret)) return r_list def server_get(_name): ## print(_name) #s = ServerList.query.filter_by(name=_name).first() # print(s.name) i = ServerList.query.filter_by(name=_name).first() ## print(i.name) s_config = {} s_config['GLOBAL'] = {} s_config['REPORTS'] = {} s_config['ALIASES'] = {} s_config['USER_MANAGER'] = {} s_config['GLOBAL'].update({ 'PATH': i.global_path, 'PING_TIME': i.global_ping_time, 'MAX_MISSED': i.global_max_missed, 'USE_ACL': i.global_use_acl, 'REG_ACL': i.global_reg_acl, 'SUB_ACL': i.global_sub_acl, 'TG1_ACL': i.global_tg1_acl, 'TG2_ACL': i.global_tg2_acl }) s_config['REPORTS'].update({ 'REPORT': i.report_enable, 'REPORT_INTERVAL': i.report_interval, 'REPORT_PORT': i.report_port, 'REPORT_CLIENTS': i.report_clients.split(',') }) s_config['ALIASES'].update({ 'TRY_DOWNLOAD':i.ai_try_download, 'PATH': i.ai_path, 'PEER_FILE': i.ai_peer_file, 'SUBSCRIBER_FILE': i.ai_subscriber_file, 'TGID_FILE': i.ai_tgid_file, 'PEER_URL': i.ai_peer_url, 'SUBSCRIBER_URL': i.ai_subs_url, 'STALE_TIME': i.ai_stale * 86400, }) s_config['USER_MANAGER'].update({ 'APPEND_INT': append_int, 'SHORTEN_PASSPHRASE': i.um_shorten_passphrase, 'BURN_FILE': i.um_burn_file, 'BURN_INT': burn_int, }) print(s_config['REPORTS']) return s_config def server_edit(_name, _secret, _ip, _public_list, _port, _global_path, _global_ping_time, _global_max_missed, _global_use_acl, _global_reg_acl, _global_sub_acl, _global_tg1_acl, _global_tg2_acl, _ai_subscriber_file, _ai_try_download, _ai_path, _ai_peer_file, _ai_tgid_file, _ai_peer_url, _ai_subs_url, _ai_stale, _um_shorten_passphrase, _um_burn_file, _report_enable, _report_interval, _report_port, _report_clients): s = ServerList.query.filter_by(name=_name).first() if _secret == '': s.secret = s.secret else: s.secret = hashlib.sha256(_secret.encode()).hexdigest() s.public_list = _public_list s.ip = _ip s.port = _port s.global_path =_global_path s.global_ping_time = _global_ping_time s.global_max_missed = _global_max_missed s.global_use_acl = _global_use_acl s.global_reg_acl = _global_reg_acl s.global_sub_acl = _global_sub_acl s.global_tg1_acl = _global_tg1_acl s.global_tg2_acl = _global_tg2_acl s.ai_try_download = _ai_try_download s.ai_path = _ai_path s.ai_peer_file = _ai_peer_file s.ai_subscriber_file = _ai_subscriber_file s.ai_tgid_file = _ai_tgid_file s.ai_peer_url = _ai_peer_url s.ai_subs_url = _ai_subs_url s.ai_stale = _ai_stale # Pull from config file for now ## um_append_int = db.Column(db.Integer(), primary_key=False, server_default='2') s.um_shorten_passphrase = _um_shorten_passphrase s.um_burn_file = _um_burn_file # Pull from config file for now ## um_burn_int = db.Column(db.Integer(), primary_key=False, server_default='6') s.report_enable = _report_enable s.report_interval = _report_interval s.report_port = _report_port s.report_clients = _report_clients db.session.commit() def server_add(_name, _secret, _ip, _public_list, _port, _global_path, _global_ping_time, _global_max_missed, _global_use_acl, _global_reg_acl, _global_sub_acl, _global_tg1_acl, _global_tg2_acl, _ai_subscriber_file, _ai_try_download, _ai_path, _ai_peer_file, _ai_tgid_file, _ai_peer_url, _ai_subs_url, _ai_stale, _um_shorten_passphrase, _um_burn_file, _report_enable, _report_interval, _report_port, _report_clients): add_server = ServerList( name = _name, secret = hashlib.sha256(_secret.encode()).hexdigest(), public_list = _public_list, ip = _ip, port = _port, global_path =_global_path, global_ping_time = _global_ping_time, global_max_missed = _global_max_missed, global_use_acl = _global_use_acl, global_reg_acl = _global_reg_acl, global_sub_acl = _global_sub_acl, global_tg1_acl = _global_tg1_acl, global_tg2_acl = _global_tg2_acl, ai_try_download = _ai_try_download, ai_path = _ai_path, ai_peer_file = _ai_peer_file, ai_subscriber_file = _ai_subscriber_file, ai_tgid_file = _ai_tgid_file, ai_peer_url = _ai_peer_url, ai_subs_url = _ai_subs_url, ai_stale = _ai_stale, # Pull from config file for now ## um_append_int = db.Column(db.Integer(), primary_key=False, server_default='2') um_shorten_passphrase = _um_shorten_passphrase, um_burn_file = _um_burn_file, # Pull from config file for now ## um_burn_int = db.Column(db.Integer(), primary_key=False, server_default='6') report_enable = _report_enable, report_interval = _report_interval, report_port = _report_port, report_clients = _report_clients ) db.session.add(add_server) db.session.commit() def peer_add(_mode, _name, _enabled, _loose, _ip, _port, _master_ip, _master_port, _passphrase, _callsign, _radio_id, _rx, _tx, _tx_power, _cc, _lat, _lon, _height, _loc, _desc, _slots, _url, _grp_hang, _xlx_mod, _opt, _use_acl, _sub_acl, _1_acl, _2_acl, _svr): if _mode == 'xlx': xlx_peer_add = xlxPeer( name = _name, enabled = _enabled, loose = _loose, ip = _ip, port = _port, master_ip = _master_ip, master_port = _master_port, passphrase = _passphrase, callsign = _callsign, radio_id = _radio_id, rx_freq = _rx, tx_freq = _tx, tx_power = _tx_power, color_code = _cc, latitude = _lat, longitude = _lon, height = _height, location = _loc, description = _desc, slots = _slots, xlxmodule = _xlx_mod, url = _url, software_id = 'HBNet', package_id = 'v1', group_hangtime = _grp_hang, use_acl = _use_acl, sub_acl = _sub_acl, tg1_acl = _1_acl, tg2_acl = _2_acl, server = _svr ) db.session.add(xlx_peer_add) db.session.commit() if _mode == 'mmdvm': mmdvm_peer_add = mmdvmPeer( name = _name, enabled = _enabled, loose = _loose, ip = _ip, port = _port, master_ip = _master_ip, master_port = _master_port, passphrase = _passphrase, callsign = _callsign, radio_id = _radio_id, rx_freq = _rx, tx_freq = _tx, tx_power = _tx_power, color_code = _cc, latitude = _lat, longitude = _lon, height = _height, location = _loc, description = _desc, slots = _slots, url = _url, software_id = 'HBNet', package_id = 'v1', group_hangtime = _grp_hang, use_acl = _use_acl, sub_acl = _sub_acl, tg1_acl = _1_acl, tg2_acl = _2_acl, server = _svr ) db.session.add(mmdvm_peer_add) db.session.commit() def peer_edit(_mode, _server, _name, _enabled, _loose, _ip, _port, _master_ip, _master_port, _passphrase, _callsign, _radio_id, _rx, _tx, _tx_power, _cc, _lat, _lon, _height, _loc, _desc, _slots, _url, _grp_hang, _xlx_mod, _opt, _use_acl, _sub_acl, _1_acl, _2_acl): ## print(_mode) if _mode == 'mmdvm': print(_server) print(_name) ## print(_name) ## s = mmdvmPeer.query.filter_by(server=_server).filter_by(name=_name).first() p = mmdvmPeer.query.filter_by(server=_server).filter_by(name=_name).first() ## print(p) p.enabled = _enabled p.loose = _loose p.ip = _ip p.port = _port p.master_ip = _master_ip p.master_port = _master_port p.passphrase = _passphrase p.callsign = _callsign p.radio_id = _radio_id p.rx_freq = _rx p.tx_freq = _tx p.tx_power = _tx_power p.color_code = _cc p.latitude = _lat p.longitude = _lon p.height = _height p.location = _loc p.description = _desc p.slots = _slots p.url = _url p.software_id = 'HBNet' p.package_id = 'v1' p.group_hangtime = _grp_hang p.use_acl = _use_acl p.sub_acl = _sub_acl p.tg1_acl = _1_acl p.tg2_acl = _2_acl db.session.commit() # Test server configs @app.route('/edit_server', methods=['POST', 'GET']) @login_required @roles_required('Admin') def edit_server_db(): # Edit server if request.args.get('save_mode'):# == 'new' and request.form.get('server_name'): _port = int(request.form.get('server_port')) _global_ping_time = int(request.form.get('ping_time')) _global_max_missed = int(request.form.get('max_missed')) _ai_stale = int(request.form.get('stale_days')) _report_interval = int(request.form.get('report_interval')) _report_port = int(request.form.get('report_port')) if request.form.get('use_acl') == 'True': _global_use_acl = True if request.form.get('aliases_enabled') == 'True': _ai_try_download = True if request.form.get('um_shorten_passphrase') == 'True': _um_shorten_passphrase = True if request.form.get('report') == 'True': _report_enabled = True if request.form.get('public_list') == 'True': public_list = True else: _global_use_acl = False _ai_try_download = False _um_shorten_passphrase = False _report_enabled = False public_list = False if request.args.get('save_mode') == 'new': server_add(request.form.get('server_name'), request.form.get('server_secret'), request.form.get('server_ip'), public_list, _port, request.form.get('global_path'), _global_ping_time, _global_max_missed, _global_use_acl, request.form.get('reg_acl'), request.form.get('sub_acl'), request.form.get('global_ts1_acl'), request.form.get('global_ts2_acl'), request.form.get('sub_file'), _ai_try_download, request.form.get('aliases_path'), request.form.get('peer_file'), request.form.get('tgid_file'), request.form.get('peer_url'), request.form.get('sub_url'), _ai_stale, _um_shorten_passphrase, request.form.get('um_burn_file'), _report_enabled, _report_interval, _report_port, request.form.get('report_clients')) content = 'attempt save' if request.args.get('save_mode') == 'edit': server_edit(request.form.get('server_name'), request.form.get('server_secret'), request.form.get('server_ip'), public_list, _port, request.form.get('global_path'), _global_ping_time, _global_max_missed, _global_use_acl, request.form.get('reg_acl'), request.form.get('sub_acl'), request.form.get('global_ts1_acl'), request.form.get('global_ts2_acl'), request.form.get('sub_file'), _ai_try_download, request.form.get('aliases_path'), request.form.get('peer_file'), request.form.get('tgid_file'), request.form.get('peer_url'), request.form.get('sub_url'), _ai_stale, _um_shorten_passphrase, request.form.get('um_burn_file'), _report_enabled, _report_interval, _report_port, request.form.get('report_clients')) content = 'attempt edit save' elif request.args.get('delete_server'): server_delete(request.args.get('delete_server')) content = 'deleted server' content = 'deleted ' + request.args.get('delete_server') elif request.args.get('edit_server'): s = ServerList.query.filter_by(name=request.args.get('edit_server')).first() content = '''

 

Delete server

 

Server

 Server Name:  ''' + str(s.name) + '''
 Server Secret:  
 Host (IP/DNS, for listing on passphrase page):  
 Port (for listing on passphrase page):  
 Public list:  

Global

 Path:  
 Ping Time:  
 Max Missed:  
 Use ACLs:  
 Regular ACLs:  
 Subscriber ACSs:  
 Timeslot 1 ACLs:  
 Timeslot 2 ACLs:  

 

Reports

 Enable:  
 Interval:  
 Port:  
 Clients:  

 

Aliases

 Download:  
 Path:  
 Peer File:  
 Subscriber File:  
 Talkgroup ID File:  
 Peer URL:  
 Subscriber URL:  
 Stale time(days):  

 

User Manager

 Use short passphrase:
 Burned IDs File:  

 

 

''' # Add new server elif request.args.get('add'): # == 'yes': content = '''

 

Server

 Server Name:  
 Server Secret:  
 Host (IP/DNS):  
 Port:  
 Public list:  

Global

 Path:  
 Ping Time:  
 Max Missed:  
 Use ACLs:  
 Regular ACLs:  
 Subscriber ACSs:  
 Timeslot 1 ACLs:  
 Timeslot 2 ACLs:  

 

Reports

 Enable:  
 Interval:  
 Port:  
 Clients:  

 

Aliases

 Download:  
 Path:  
 Peer File:  
 Subscriber File:  
 Talkgroup ID File:  
 Peer URL:  
 Subscriber URL:  
 Stale time(days):  

 

User Manager

 Use short passphrase:
 Burned IDs File:  

 

 

''' else: all_s = ServerList.query.all() p_list = '''

View/Edit Servers

Add Server Config
''' for s in all_s: p_list = p_list + ''' \n ''' p_list = p_list + '''
Name
''' + str(s.name) + '''
''' content = p_list return render_template('flask_user_layout.html', markup_content = Markup(content)) @app.route('/edit_peer', methods=['POST', 'GET']) @login_required @roles_required('Admin') def test_peer_db(): if request.args.get('save_mode'): if request.form.get('enabled') == 'true': peer_enabled = True ## if request.form.get('loose') == 'true': ## peer_loose = True if request.form.get('use_acl') == 'true': use_acl = True else: ## peer_loose = False peer_enabled = False use_acl = False peer_loose = True if request.args.get('save_mode') == 'mmdvm_peer': peer_add('mmdvm', request.form.get('name_text'), peer_enabled, peer_loose, request.form.get('ip'), request.form.get('port'), request.form.get('master_ip'), request.form.get('master_port'), request.form.get('passphrase'), request.form.get('callsign'), request.form.get('radio_id'), request.form.get('rx'), request.form.get('tx'), request.form.get('tx_power'), request.form.get('cc'), request.form.get('lat'), request.form.get('lon'), request.form.get('height'), request.form.get('location'), request.form.get('description'), request.form.get('slots'), request.form.get('url'), request.form.get('group_hangtime'), 'MMDVM', request.form.get('options'), use_acl, request.form.get('sub_acl'), request.form.get('tgid_ts1_acl'), request.form.get('tgid_ts2_acl'), request.form.get('server')) content = 'saved mmdvm peer' if request.args.get('save_mode') == 'xlx_peer': peer_add('xlx', request.form.get('name_text'), peer_enabled, peer_loose, request.form.get('ip'), request.form.get('port'), request.form.get('master_ip'), request.form.get('master_port'), request.form.get('passphrase'), request.form.get('callsign'), request.form.get('radio_id'), request.form.get('rx'), request.form.get('tx'), request.form.get('tx_power'), request.form.get('cc'), request.form.get('lat'), request.form.get('lon'), request.form.get('height'), request.form.get('location'), request.form.get('description'), request.form.get('slots'), request.form.get('url'), request.form.get('group_hangtime'), request.form.get('xlxmodule'), request.form.get('options'), use_acl, request.form.get('sub_acl'), request.form.get('tgid_ts1_acl'), request.form.get('tgid_ts2_acl'), request.form.get('server')) content = 'saved xlx peer' elif request.args.get('add') == 'mmdvm' or request.args.get('add') == 'xlx': s = ServerList.query.all() if request.args.get('add') == 'mmdvm': mode = 'MMDVM' submit_link = 'edit_peer?save_mode=mmdvm_peer' xlx_module = '' if request.args.get('add') == 'xlx': xlx_module = '''  XLX Module:   ''' mode = 'XLX' submit_link = 'edit_peer?save_mode=xlx_peer' server_options = '' for i in s: server_options = server_options + '''\n''' content = '''

 

Add an ''' + mode + ''' peer

''' + xlx_module + '''
Assign to Server:  
Connection Name:  
 Active:  
 IP:  
 Port:  
 Passphrase:  
 Master IP:  
 Master Port:  
 Callsign:  
 Radio ID:  
 Transmit Frequency:  
 Receive Frequency:  
 Transmit Power:  
 Color Code:  
 Slots:  
 Latitude:  
 Longitude:  
 Height  
 Location:  
 Description:  
 URL:  
 Group Hangtime:  
 Options:  
 Use ACLs:  
 Subscriber ACLs:  
 Talkgroup Slot 1 ACLs:  
 Talkgroup Slot 2 ACLs:  

 

''' ## elif request.args.get('edit_server') and request.args.get('edit_peer') and request.args.get('mode') == 'mmdvm': elif request.args.get('delete_peer') and request.args.get('peer_server'): print(request.args.get('peer_server')) print(request.args.get('delete_peer')) peer_delete(request.args.get('mode'), request.args.get('peer_server'), request.args.get('delete_peer')) content = 'deleted peer' elif request.args.get('edit_mmdvm') == 'save': ## print(request.form.get('enabled')) if request.form.get('enabled') == 'True': peer_enabled = True ## if request.form.get('loose') == 'true': ## peer_loose = True if request.form.get('use_acl') == 'True': use_acl = True else: ## peer_loose = False peer_enabled = False use_acl = False peer_loose = True ## print(peer_enabled) print(request.args.get('server')) peer_edit('mmdvm', request.args.get('server'), request.form.get('name_text'), peer_enabled, peer_loose, request.form.get('ip'), request.form.get('port'), request.form.get('master_ip'), request.form.get('master_port'), request.form.get('passphrase'), request.form.get('callsign'), request.form.get('radio_id'), request.form.get('rx'), request.form.get('tx'), request.form.get('tx_power'), request.form.get('cc'), request.form.get('lat'), request.form.get('lon'), request.form.get('height'), request.form.get('location'), request.form.get('description'), request.form.get('slots'), request.form.get('url'), request.form.get('group_hangtime'), 'MMDVM', request.form.get('options'), use_acl, request.form.get('sub_acl'), request.form.get('tgid_ts1_acl'), request.form.get('tgid_ts2_acl')) content = 'save edit' elif request.args.get('server') and request.args.get('peer_name') and request.args.get('mode'): # and request.args.get('edit_peer') and request.args.get('mode') == 'mmdvm': if request.args.get('mode') == 'mmdvm': p = mmdvmPeer.query.filter_by(server=request.args.get('server')).filter_by(name=request.args.get('peer_name')).first() xlx_module = '' mode = "MMDVM" if request.args.get('mode') == 'xlx': p = xlxPeer.query.filter_by(server=request.args.get('server')).filter_by(name=request.args.get('peer_name')).first() xlx_module = '''  XLX Module:   ''' mode = "XLX" content = '''

 

View/Edit an ''' + mode + ''' peer

Delete peer

''' + xlx_module + '''
Connection Name:  
 Active:  
 IP:  
 Port:  
 Passphrase:  
 Master IP:  
 Master Port:  
 Callsign:  
 Radio ID:  
 Transmit Frequency:  
 Receive Frequency:  
 Transmit Power:  
 Color Code:  
 Slots:  
 Latitude:  
 Longitude:  
 Height  
 Location:  
 Description:  
 URL:  
 Group Call Hangtime:  
 Options:  
 Use ACLs:  
 Subscriber ACLs:  
 Talkgroup Slot 1 ACLs:  
 Talkgroup Slot 2 ACLs:  

 

 

''' else: all_s = ServerList.query.all() p_list = '' for s in all_s: print(s.name) p_list = p_list + '''

Server: ''' + str(s.name) + '''

\n ''' all_p = mmdvmPeer.query.filter_by(server=s.name).all() all_x = xlxPeer.query.filter_by(server=s.name).all() for p in all_p: p_list = p_list + ''' \n ''' for x in all_x: p_list = p_list + ''' \n ''' p_list = p_list + '''
Name Mode
''' + str(p.name) + ''' MMDVM
''' + str(x.name) + ''' XLX
\n''' content = '''

View/Edit Peers

Add MMDVM peer Add XLX peer

 

''' + p_list return render_template('flask_user_layout.html', markup_content = Markup(content)) @app.route('/manage_masters', methods=['POST', 'GET']) def manage_masters(): if request.args.get('add'): print('yay') @app.route('/add_user', methods=['POST', 'GET']) @login_required @roles_required('Admin') def add_admin(): if request.method == 'GET': content = '''






 

''' elif request.method == 'POST' and request.form.get('username'): if not User.query.filter(User.username == request.form.get('username')).first(): radioid_data = ast.literal_eval(get_ids(request.form.get('username'))) user = User( username=request.form.get('username'), email=request.form.get('email'), email_confirmed_at=datetime.datetime.utcnow(), password=user_manager.hash_password(request.form.get('password')), dmr_ids = str(radioid_data[0]), initial_admin_approved = True, first_name = str(radioid_data[1]), last_name = str(radioid_data[2]), city = str(radioid_data[3]) ) db.session.add(user) u = User.query.filter_by(username=request.form.get('username')).first() user_role = UserRoles( user_id=u.id, role_id=2, ) db.session.add(user_role) db.session.commit() content = '''

Created user: ''' + str(request.form.get('username')) + '''

\n''' elif User.query.filter(User.username == request.form.get('username')).first(): content = 'Existing user: ' + str(request.form.get('username') + '. New user not created.') return render_template('flask_user_layout.html', markup_content = Markup(content)) @app.route('/auth', methods=['POST']) def auth(): hblink_req = request.json print((hblink_req)) if hblink_req['secret'] in shared_secrets(): if 'login_id' in hblink_req and 'login_confirmed' not in hblink_req: if type(hblink_req['login_id']) == int: if authorized_peer(hblink_req['login_id'])[0]: if isinstance(authorized_peer(hblink_req['login_id'])[1], int) == True: authlog_add(hblink_req['login_id'], hblink_req['login_ip'], hblink_req['login_server'], authorized_peer(hblink_req['login_id'])[2], gen_passphrase(hblink_req['login_id']), 'Attempt') response = jsonify( allow=True, mode='normal', ) elif authorized_peer(hblink_req['login_id'])[1] == '': authlog_add(hblink_req['login_id'], hblink_req['login_ip'], hblink_req['login_server'], authorized_peer(hblink_req['login_id'])[2], 'Config Passphrase: ' + legacy_passphrase, 'Attempt') response = jsonify( allow=True, mode='legacy', ) elif authorized_peer(hblink_req['login_id'])[1] != '' or isinstance(authorized_peer(hblink_req['login_id'])[1], int) == False: authlog_add(hblink_req['login_id'], hblink_req['login_ip'], hblink_req['login_server'], authorized_peer(hblink_req['login_id'])[2], authorized_peer(hblink_req['login_id'])[1], 'Attempt') print(authorized_peer(hblink_req['login_id'])) response = jsonify( allow=True, mode='override', value=authorized_peer(hblink_req['login_id'])[1] ) elif authorized_peer(hblink_req['login_id'])[0] == False: print('log fail') authlog_add(hblink_req['login_id'], hblink_req['login_ip'], hblink_req['login_server'], 'Not Registered', '-', 'Failed') response = jsonify( allow=False) elif not type(hblink_req['login_id']) == int: user = hblink_req['login_id'] u = User.query.filter_by(username=user).first() if not u: msg = jsonify(auth=False, reason='User not found') response = make_response(msg, 401) if u: u_role = UserRoles.query.filter_by(user_id=u.id).first() password = user_manager.verify_password(hblink_req['password'], u.password) if u_role.role_id == 2: role = 'user' if u_role.role_id == 1: role = 'admin' if password: response = jsonify(auth=True, role=role) else: msg = jsonify(auth=False, reason='Incorrect password') response = make_response(msg, 401) elif 'login_id' in hblink_req and 'login_confirmed' in hblink_req: if hblink_req['old_auth'] == True: authlog_add(hblink_req['login_id'], hblink_req['login_ip'], hblink_req['login_server'], authorized_peer(hblink_req['login_id'])[2], 'CONFIG, NO UMS', 'Confirmed') else: authlog_add(hblink_req['login_id'], hblink_req['login_ip'], hblink_req['login_server'], authorized_peer(hblink_req['login_id'])[2], 'USER MANAGER', 'Confirmed') response = jsonify( logged=True ) elif 'burn_list' in hblink_req: # ['burn_list']: # == 'burn_list': response = jsonify( burn_list=get_burnlist() ) elif hblink_req['get_config']: # == 'burn_list': test_parsed = ast.literal_eval(os.popen('cat ./test_parsed.txt').read()) ## print((test_parsed)) try: response = jsonify( config=server_get(hblink_req['get_config']), peers=get_peer_configs(hblink_req['get_config']) ) except: message = jsonify(message='Config error') response = make_response(message, 401) else: message = jsonify(message='Authentication error') response = make_response(message, 401) return response return app if __name__ == '__main__': app = create_app() app.run(debug = True, port=ums_port, host=ums_host)