158 lines
4.5 KiB
Python
Executable File
158 lines
4.5 KiB
Python
Executable File
# MIT License
|
|
#
|
|
# Copyright (c) 2016-2022 Mark Qvist / unsigned.io
|
|
#
|
|
# Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
# of this software and associated documentation files (the "Software"), to deal
|
|
# in the Software without restriction, including without limitation the rights
|
|
# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
|
# copies of the Software, and to permit persons to whom the Software is
|
|
# furnished to do so, subject to the following conditions:
|
|
#
|
|
# The above copyright notice and this permission notice shall be included in all
|
|
# copies or substantial portions of the Software.
|
|
#
|
|
# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
|
# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
|
|
# SOFTWARE.
|
|
|
|
import os
|
|
import sys
|
|
import glob
|
|
import time
|
|
import random
|
|
import threading
|
|
|
|
from ._version import __version__
|
|
|
|
from .Reticulum import Reticulum
|
|
from .Identity import Identity
|
|
from .Link import Link, RequestReceipt
|
|
from .Transport import Transport
|
|
from .Destination import Destination
|
|
from .Packet import Packet
|
|
from .Packet import PacketReceipt
|
|
from .Resource import Resource, ResourceAdvertisement
|
|
|
|
modules = glob.glob(os.path.dirname(__file__)+"/*.py")
|
|
__all__ = [ os.path.basename(f)[:-3] for f in modules if not f.endswith('__init__.py')]
|
|
|
|
LOG_CRITICAL = 0
|
|
LOG_ERROR = 1
|
|
LOG_WARNING = 2
|
|
LOG_NOTICE = 3
|
|
LOG_INFO = 4
|
|
LOG_VERBOSE = 5
|
|
LOG_DEBUG = 6
|
|
LOG_EXTREME = 7
|
|
|
|
LOG_STDOUT = 0x91
|
|
LOG_FILE = 0x92
|
|
|
|
LOG_MAXSIZE = 5*1024*1024
|
|
|
|
loglevel = LOG_NOTICE
|
|
logfile = None
|
|
logdest = LOG_STDOUT
|
|
logtimefmt = "%Y-%m-%d %H:%M:%S"
|
|
|
|
random.seed(os.urandom(10))
|
|
|
|
_always_override_destination = False
|
|
|
|
logging_lock = threading.Lock()
|
|
|
|
def loglevelname(level):
|
|
if (level == LOG_CRITICAL):
|
|
return "Critical"
|
|
if (level == LOG_ERROR):
|
|
return "Error"
|
|
if (level == LOG_WARNING):
|
|
return "Warning"
|
|
if (level == LOG_NOTICE):
|
|
return "Notice"
|
|
if (level == LOG_INFO):
|
|
return "Info"
|
|
if (level == LOG_VERBOSE):
|
|
return "Verbose"
|
|
if (level == LOG_DEBUG):
|
|
return "Debug"
|
|
if (level == LOG_EXTREME):
|
|
return "Extra"
|
|
|
|
return "Unknown"
|
|
|
|
def version():
|
|
return __version__
|
|
|
|
def host_os():
|
|
from .vendor.platformutils import get_platform
|
|
return get_platform()
|
|
|
|
def timestamp_str(time_s):
|
|
timestamp = time.localtime(time_s)
|
|
return time.strftime(logtimefmt, timestamp)
|
|
|
|
def log(msg, level=3, _override_destination = False):
|
|
global _always_override_destination
|
|
|
|
if loglevel >= level:
|
|
logstring = "["+timestamp_str(time.time())+"] ["+loglevelname(level)+"] "+msg
|
|
logging_lock.acquire()
|
|
|
|
if (logdest == LOG_STDOUT or _always_override_destination or _override_destination):
|
|
print(logstring)
|
|
logging_lock.release()
|
|
|
|
elif (logdest == LOG_FILE and logfile != None):
|
|
try:
|
|
file = open(logfile, "a")
|
|
file.write(logstring+"\n")
|
|
file.close()
|
|
|
|
if os.path.getsize(logfile) > LOG_MAXSIZE:
|
|
prevfile = logfile+".1"
|
|
if os.path.isfile(prevfile):
|
|
os.unlink(prevfile)
|
|
os.rename(logfile, prevfile)
|
|
|
|
logging_lock.release()
|
|
except Exception as e:
|
|
logging_lock.release()
|
|
_always_override_destination = True
|
|
log("Exception occurred while writing log message to log file: "+str(e), LOG_CRITICAL)
|
|
log("Dumping future log events to console!", LOG_CRITICAL)
|
|
log(msg, level)
|
|
|
|
|
|
def rand():
|
|
result = random.random()
|
|
return result
|
|
|
|
def hexrep(data, delimit=True):
|
|
try:
|
|
iter(data)
|
|
except TypeError:
|
|
data = [data]
|
|
|
|
delimiter = ":"
|
|
if not delimit:
|
|
delimiter = ""
|
|
hexrep = delimiter.join("{:02x}".format(c) for c in data)
|
|
return hexrep
|
|
|
|
def prettyhexrep(data):
|
|
delimiter = ""
|
|
hexrep = "<"+delimiter.join("{:02x}".format(c) for c in data)+">"
|
|
return hexrep
|
|
|
|
def panic():
|
|
os._exit(255)
|
|
|
|
def exit():
|
|
print("")
|
|
sys.exit(0) |