app.py

#!/usr/bin/env python3

from simple_websocket_server import WebSocketServer, WebSocket
import http.server as SimpleHTTPServer
import socketserver as SocketServer
import logging
import time
import sys
import os
import psycopg2
from threading import Thread

from concurrent import futures

PORT = 8000
WS_PORT = 8001
GRPC_PORT = 8082

class GetHandler(
        SimpleHTTPServer.SimpleHTTPRequestHandler
        ):

    def do_GET(self):
        #raise Exception("Exception!")
        logging.error(self.headers)
        path = os.environ.get('TEST_ENV_PATH', 'not_replaced_PATH')
        if path != 'not_replaced_PATH':
            logging.error('TEST_ENV_PATH: ' + path)
            with open(path, "r") as f:
                logging.error('file content: ' + f.read())
        else:
            logging.error('TEST_ENV_PATH: not_replaced_PATH')
        # test alias
        logging.error('TEST_ENV_PATH_ALIAS: ' + os.environ.get('TEST_ENV_PATH_ALIAS', 'not_replaced_PATH_ALIAS'))
        logging.error('TEST_CONCATENATION: ' + os.environ.get('TEST_CONCAT', 'not_replaced_concat'))
        logging.error('DB NAME: ' + os.environ.get('DB_DBNAME', 'not_replaced_db_name'))
        logging.error('DB HOST: ' + os.environ.get('DB_HOST', 'not_replaced_db_host'))
        logging.error('DB PORT: ' + os.environ.get('DB_PORT', 'not_replaced_db_port'))
        logging.error('DB USER: ' + os.environ.get('DB_USER', 'not_replaced_db_user'))
        logging.error('DB PSW: ' + os.environ.get('DB_PASSWORD', 'not_replaced_db_password'))
        logging.error('FILE_PATH: ' + os.environ.get('FILE_PATH', 'not_replaced_file_path'))
        #try:
        #    f = open(os.environ.get('FILE_PATH', 'not_replaced_file_path'), "r")
         #   logging.error('here')
         #   print(f.read())
         #   logging.error('here2')
        #    logging.error('FILE_CONTENT: ' + f.read())
         #   logging.error('here3')
        #except (Exception, psycopg2.DatabaseError) as error:
        #    logging.error('FILE_CONTENT: ' + "exception")
        SimpleHTTPServer.SimpleHTTPRequestHandler.do_GET(self)
        try:
            conn = psycopg2.connect(
            database=os.environ.get('DB_DBNAME', 'f'), user=os.environ.get('DB_USER', 'f'), password=os.environ.get('DB_PASSWORD', 'f'), host=os.environ.get('DB_HOST', 'f'), port= os.environ.get('DB_PORT', 81)
            ) 
            logging.error('Connected logged')
        except (Exception, psycopg2.DatabaseError) as error:
            logging.error('Error logged: ')
        
    def do_POST(self):
        logging.error(self.headers)
        logging.error(os.environ.get('PRINT_VAR', '/home/username/'))
    
    def do_HEAD(self):
        sys.exit(1)

#time.sleep(60)
#raise Exception("Exception!")
class SimpleEcho(WebSocket):
    def handle(self):
        # echo message back to client
        self.send_message(self.data)

    def connected(self):
        print(self.address, 'connected')

    def handle_close(self):
        print(self.address, 'closed')


Handler = GetHandler

httpd = SocketServer.TCPServer(("", PORT), Handler)
server = WebSocketServer('0.0.0.0', WS_PORT, SimpleEcho)

print("Serving on port d :8000")
httpd.serve_forever()