Bugs - Githubissues

itlsoft / lb

0 stars 0 forks source link

Bugs #7

Open itlsoft opened 8 months ago

itlsoft commented 3 months ago

import logging
import requests
import threading
from queue import Queue
from time import sleep
from requests.auth import HTTPBasicAuth

class HttpLogger(logging.Logger):
    def __init__(self, name, level=logging.NOTSET, endpoint='http://localhost:5000/log', batch_interval=300, username=None, password=None):
        super().__init__(name, level)
        self.endpoint = endpoint
        self.batch_interval = batch_interval  # Czas w sekundach między wysyłkami zbiorczymi
        self.info_queue = Queue()
        self.username = username
        self.password = password
        self._start_batching_thread()

    def _start_batching_thread(self):
        threading.Thread(target=self._batch_sender, daemon=True).start()

    def _batch_sender(self):
        while True:
            sleep(self.batch_interval)
            if not self.info_queue.empty():
                logs_to_send = []
                while not self.info_queue.empty():
                    logs_to_send.append(self.info_queue.get())

                # Wysłanie zbiorczego requestu
                try:
                    response = requests.post(
                        self.endpoint,
                        json={"logs": logs_to_send},
                        auth=HTTPBasicAuth(self.username, self.password)
                    )
                    if response.status_code != 200:
                        self.error(f"Failed to send batch logs: {response.status_code} - {response.text}")
                except requests.RequestException as e:
                    self.error(f"Failed to send batch logs: {e}")

    def error(self, msg, category_id=None, app_name=None, *args, **kwargs):
        super().error(msg, *args, **kwargs)
        # Wykonanie HTTP requestu przy logowaniu błędu
        if category_id and app_name:
            try:
                response = requests.post(
                    self.endpoint,
                    json={
                        "error": msg,
                        "category_id": category_id,
                        "app_name": app_name
                    },
                    auth=HTTPBasicAuth(self.username, self.password)
                )
                if response.status_code != 200:
                    super().error(f"Failed to send error log: {response.status_code} - {response.text}")
            except requests.RequestException as e:
                super().error(f"Failed to send error log: {e}")

    def info(self, msg, category_id=None, app_name=None, *args, **kwargs):
        super().info(msg, *args, **kwargs)
        # Zbieranie logów do zbiorczego wysłania
        if category_id and app_name:
            self.info_queue.put({
                "info": msg,
                "category_id": category_id,
                "app_name": app_name
            })

# Funkcja do konfiguracji loggera
def setup_logger(name, endpoint='http://localhost:5000/log', batch_interval=300, username='admin', password='password'):
    logger = HttpLogger(name, endpoint=endpoint, batch_interval=batch_interval, username=username, password=password)
    handler = logging.StreamHandler()
    formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
    handler.setFormatter(formatter)
    logger.addHandler(handler)
    return logger

if __name__ == "__main__":
    logger = setup_logger('my_app_logger', endpoint='http://localhost:5000/log', username='admin', password='password')

    # Przykład użycia
    logger.error('This is an error', 2, 'APP ABC')
    logger.info('This is an info message', 4, 'APP DEF')

itlsoft commented 3 months ago

if __name__ == "__main__":
    logger = setup_logger('my_app_logger', endpoint='http://your-endpoint.com/log', batch_interval=300)

    # Przykład użycia
    logger.error('This is an error', 2, 'APP ABC')
    logger.info('This is an info message', 4, 'APP DEF')

itlsoft commented 3 months ago

from flask import Flask, request, jsonify, Response
from functools import wraps
import json
import os

app = Flask(__name__)

# Zdefiniowane dane do autoryzacji
USERNAME = 'admin'
PASSWORD = 'password'

# Funkcja autoryzacji Basic Auth
def authenticate():
    return Response(
        'Authentication required', 401,
        {'WWW-Authenticate': 'Basic realm="Login Required"'})

def requires_auth(f):
    @wraps(f)
    def decorated(*args, **kwargs):
        auth = request.authorization
        if not auth or not (auth.username == USERNAME and auth.password == PASSWORD):
            return authenticate()
        return f(*args, **kwargs)
    return decorated

# Endpoint do odbierania logów
@app.route('/log', methods=['POST'])
@requires_auth
def receive_log():
    data = request.json

    # Ścieżka do pliku JSON
    file_path = r'C:\app\data.json'

    # Sprawdzanie, czy plik istnieje. Jeśli nie, to tworzymy pustą listę.
    if not os.path.exists(file_path):
        with open(file_path, 'w') as f:
            json.dump([], f)

    # Wczytywanie istniejących danych
    with open(file_path, 'r') as f:
        logs = json.load(f)

    # Dodawanie nowych danych
    logs.append(data)

    # Zapis zaktualizowanych danych do pliku
    with open(file_path, 'w') as f:
        json.dump(logs, f, indent=4)

    return jsonify({"message": "Log received successfully"}), 200

if __name__ == '__main__':
    app.run(host='0.0.0.0', port=5000)

itlsoft commented 3 months ago

DECLARE @procName NVARCHAR(255)
DECLARE @sqlCmd NVARCHAR(MAX)

DECLARE cur CURSOR FOR
SELECT name
FROM sys.procedures
WHERE name LIKE 'sp_Q%'

OPEN cur
FETCH NEXT FROM cur INTO @procName

WHILE @@FETCH_STATUS = 0
BEGIN
    -- Sprawdzenie czy użytkownik Dsecr ma już uprawnienia EXECUTE do danej procedury
    IF EXISTS (
        SELECT 1
        FROM sys.database_permissions p
        JOIN sys.objects o ON p.major_id = o.object_id
        JOIN sys.schemas s ON o.schema_id = s.schema_id
        WHERE p.grantee_principal_id = USER_ID('Dsecr')
        AND o.name = @procName
        AND p.permission_name = 'EXECUTE'
        AND p.state_desc = 'GRANT'
    )
    BEGIN
        PRINT 'User Dsecr already has access to ' + @procName
    END
    ELSE
    BEGIN
        -- Dodanie uprawnień EXECUTE dla użytkownika Dsecr
        SET @sqlCmd = 'GRANT EXECUTE ON ' + QUOTENAME(@procName) + ' TO Dsecr'
        EXEC sp_executesql @sqlCmd
        PRINT 'New access has been added for ' + @procName
    END

    FETCH NEXT FROM cur INTO @procName
END

CLOSE cur
DEALLOCATE cur

itlsoft commented 3 months ago

20240822_201054

itlsoft commented 3 months ago

import requests
import smtplib
from sqlalchemy.exc import SQLAlchemyError

def request_a():
    try:
        response = requests.get("http://example.com/api")
        response.raise_for_status()  # Zgłaszaj wyjątek, jeśli status != 200
        return response.json()
    except requests.exceptions.RequestException as e:
        # Logowanie błędu lub inne działania
        raise Exception(f"RequestA failed: {str(e)}")  # Rzuć wyjątek do obsługi w trigger()

def request_b():
    try:
        response = requests.post("http://example.com/api", json={})
        response.raise_for_status()
        return response.json()
    except requests.exceptions.RequestException as e:
        raise Exception(f"RequestB failed: {str(e)}")

def sql_update_a(session):
    try:
        # Przykład aktualizacji SQLAlchemy
        session.query(MyModel).filter_by(id=1).update({"field": "value"})
        session.commit()
    except SQLAlchemyError as e:
        session.rollback()  # Cofnij transakcję w razie błędu
        raise Exception(f"SqlUpdateA failed: {str(e)}")

def sql_update_b(session):
    try:
        session.query(AnotherModel).filter_by(id=2).update({"field": "value"})
        session.commit()
    except SQLAlchemyError as e:
        session.rollback()
        raise Exception(f"SqlUpdateB failed: {str(e)}")

def send_email_a():
    try:
        # Przykład wysyłania e-maila (może być inne API SMTP)
        smtp_server = smtplib.SMTP('smtp.example.com', 587)
        smtp_server.sendmail("from@example.com", "to@example.com", "Email body")
        smtp_server.quit()
    except smtplib.SMTPException as e:
        raise Exception(f"SendEmailA failed: {str(e)}")

def send_email_b():
    try:
        smtp_server = smtplib.SMTP('smtp.example.com', 587)
        smtp_server.sendmail("from@example.com", "to@example.com", "Email body")
        smtp_server.quit()
    except smtplib.SMTPException as e:
        raise Exception(f"SendEmailB failed: {str(e)}")

itlsoft commented 3 months ago

$(document).ready(function() {
    // Funkcja do aktualizacji wartości pól i tekstu HTML
    $('input[name="rdelegate"]').change(function() {
        // Znajdź wybraną opcję radio i przypisane do niej pola hidden
        var selectedOption = $('input[name="rdelegate"]:checked').closest('label');
        var semailValue = selectedOption.find('input[id^="semail"]').val();
        var sNameValue = selectedOption.find('input[id^="sName"]').val();

        // Ustaw wartość w polu hidden o id="semail"
        $('#semail').val(semailValue);

        // Ustaw tę samą wartość w polu hidden o id="demail"
        $('#demail').val($('#semail').val());

        // Ustaw wartość jako tekst HTML w elemencie z klasą "delegatedperson"
        $('.delegatedperson').html(sNameValue);
    });
});