Phase 13: 10 ta yangi AI-Powered pro funksiyalar (Glitch, BG Remove, Style Transfer, Subtitle Translate va hk.) kiritildi

filters.py

@@ -895,3 +895,379 @@ def process_video_subtitle(video_path, output_path, progress_callback=None):
         if os.path.exists(temp_audio_path):
             try: os.remove(temp_audio_path)
             except: pass
+
+# ============================================================
+#  PHASE 13: GLITCH / MIRROR / WATERMARK / BG REMOVE / STYLE
+# ============================================================
+
+def apply_glitch_filter(image_path, output_path):
+    """Rasmga Glitch effekti qo'llaydi (RGB siljishi + noise)."""
+    try:
+        img = cv2.imread(os.path.abspath(image_path))
+        if img is None: return None
+        h, w = img.shape[:2]
+        
+        result = img.copy()
+        # RGB kanallari siljishi
+        shift = max(5, int(w * 0.02))
+        # Qizil kanalni o'ngga siljitish
+        result[:, shift:, 2] = img[:, :-shift, 2]
+        # Ko'k kanalni chapga siljitish
+        result[:, :-shift, 0] = img[:, shift:, 0]
+        
+        # Gorizontal chiziqlar (scan lines)
+        for y in range(0, h, max(3, h // 80)):
+            offset = np.random.randint(-shift, shift)
+            if 0 < y + 2 < h:
+                row = result[y:y+2].copy()
+                result[y:y+2] = np.roll(row, offset, axis=1)
+        
+        # Noise qo'shish
+        noise = np.random.randint(0, 25, img.shape, dtype='uint8')
+        result = cv2.add(result, noise)
+        
+        cv2.imwrite(os.path.abspath(output_path), result)
+        return output_path
+    except Exception as e:
+        logger.error(f"Glitch filter xatosi: {e}")
+        return None
+
+def apply_mirror_filter(image_path, output_path):
+    """Rasmga Mirror (oyna) effekti qo'llaydi."""
+    try:
+        img = cv2.imread(os.path.abspath(image_path))
+        if img is None: return None
+        h, w = img.shape[:2]
+        
+        # Chap yarmini olib, o'ng tomoniga aks ettirish
+        left_half = img[:, :w//2]
+        mirrored = cv2.flip(left_half, 1)
+        result = img.copy()
+        result[:, w//2:w//2+mirrored.shape[1]] = mirrored
+        
+        cv2.imwrite(os.path.abspath(output_path), result)
+        return output_path
+    except Exception as e:
+        logger.error(f"Mirror filter xatosi: {e}")
+        return None
+
+def process_video_glitch(video_path, output_path, progress_callback=None):
+    """Videoga Glitch effekti qo'llaydi."""
+    def glitch_frame(frame):
+        h, w = frame.shape[:2]
+        result = frame.copy()
+        shift = max(5, int(w * 0.02))
+        
+        result[:, shift:, 0] = frame[:, :-shift, 0]  # R shift
+        result[:, :-shift, 2] = frame[:, shift:, 2]   # B shift
+        
+        for y in range(0, h, max(3, h // 80)):
+            offset = np.random.randint(-shift, shift)
+            if 0 < y + 2 < h:
+                row = result[y:y+2].copy()
+                result[y:y+2] = np.roll(row, offset, axis=1)
+        
+        noise = np.random.randint(0, 15, frame.shape, dtype='uint8')
+        result = cv2.add(result, noise)
+        return result
+        
+    return _apply_video_transform(video_path, output_path, glitch_frame, progress_callback)
+
+def process_video_mirror(video_path, output_path, progress_callback=None):
+    """Videoga Mirror effekti qo'llaydi."""
+    def mirror_frame(frame):
+        h, w = frame.shape[:2]
+        left_half = frame[:, :w//2]
+        mirrored = cv2.flip(left_half, 1)
+        result = frame.copy()
+        result[:, w//2:w//2+mirrored.shape[1]] = mirrored
+        return result
+        
+    return _apply_video_transform(video_path, output_path, mirror_frame, progress_callback)
+
+def apply_watermark(image_path, output_path, text="@editfiltrbot"):
+    """Rasmga watermark (suv belgisi) qo'shadi."""
+    try:
+        from PIL import ImageFont, ImageDraw
+        img = Image.open(os.path.abspath(image_path)).convert("RGBA")
+        w, h = img.size
+        
+        # Shaffof qatlam yaratish
+        overlay = Image.new("RGBA", img.size, (0, 0, 0, 0))
+        draw = ImageDraw.Draw(overlay)
+        
+        font_size = max(14, int(min(w, h) * 0.04))
+        font_path = None
+        for fp in ["/usr/share/fonts/truetype/dejavu/DejaVuSans-Bold.ttf",
+                    "C:/Windows/Fonts/arialbd.ttf"]:
+            if os.path.exists(fp):
+                font_path = fp
+                break
+        
+        try:
+            font = ImageFont.truetype(font_path, font_size) if font_path else ImageFont.load_default()
+        except:
+            font = ImageFont.load_default()
+        
+        bbox = draw.textbbox((0, 0), text, font=font)
+        tw, th = bbox[2] - bbox[0], bbox[3] - bbox[1]
+        x = w - tw - 15
+        y = h - th - 15
+        
+        # Yarim-shaffof oq matn + qora soya
+        draw.text((x+1, y+1), text, font=font, fill=(0, 0, 0, 120))
+        draw.text((x, y), text, font=font, fill=(255, 255, 255, 160))
+        
+        result = Image.alpha_composite(img, overlay).convert("RGB")
+        result.save(os.path.abspath(output_path))
+        return output_path
+    except Exception as e:
+        logger.error(f"Watermark xatosi: {e}")
+        return None
+
+def process_video_watermark(video_path, output_path, progress_callback=None):
+    """Videoga watermark qo'shadi."""
+    from PIL import ImageFont, ImageDraw
+    
+    # Shrift va matn bir marta tayyorlanadi
+    text = "@editfiltrbot"
+    font_path = None
+    for fp in ["/usr/share/fonts/truetype/dejavu/DejaVuSans-Bold.ttf",
+                "C:/Windows/Fonts/arialbd.ttf"]:
+        if os.path.exists(fp):
+            font_path = fp
+            break
+    
+    def wm_frame(frame):
+        h, w = frame.shape[:2]
+        pil_img = Image.fromarray(frame).convert("RGBA")
+        overlay = Image.new("RGBA", pil_img.size, (0, 0, 0, 0))
+        draw = ImageDraw.Draw(overlay)
+        
+        font_size = max(14, int(min(w, h) * 0.04))
+        try:
+            font = ImageFont.truetype(font_path, font_size) if font_path else ImageFont.load_default()
+        except:
+            font = ImageFont.load_default()
+        
+        bbox = draw.textbbox((0, 0), text, font=font)
+        tw, th = bbox[2] - bbox[0], bbox[3] - bbox[1]
+        x, y = w - tw - 15, h - th - 15
+        
+        draw.text((x+1, y+1), text, font=font, fill=(0, 0, 0, 120))
+        draw.text((x, y), text, font=font, fill=(255, 255, 255, 160))
+        
+        result = Image.alpha_composite(pil_img, overlay).convert("RGB")
+        return np.array(result)
+        
+    return _apply_video_transform(video_path, output_path, wm_frame, progress_callback)
+
+def apply_bg_remove(image_path, output_path):
+    """Rasmdan fonni olib tashlaydi (shaffof PNG)."""
+    try:
+        from rembg import remove
+        
+        with open(os.path.abspath(image_path), 'rb') as inp:
+            input_data = inp.read()
+        
+        output_data = remove(input_data)
+        
+        # PNG sifatida saqlash (shaffof fon)
+        png_path = os.path.abspath(output_path).rsplit('.', 1)[0] + '.png'
+        with open(png_path, 'wb') as out:
+            out.write(output_data)
+        
+        return png_path
+    except ImportError:
+        logger.error("rembg kutubxonasi o'rnatilmagan.")
+        return None
+    except Exception as e:
+        logger.error(f"Background Remove xatosi: {e}")
+        return None
+
+def process_video_subtitle_translate(video_path, output_path, target_lang="uz", progress_callback=None):
+    """Videoga avtomatik subtitle + tarjima qo'shadi."""
+    from PIL import ImageFont, ImageDraw
+    
+    try:
+        video_path = os.path.abspath(video_path)
+        output_path = os.path.abspath(output_path)
+        
+        video = VideoFileClip(video_path)
+        
+        if video.duration > 300:
+            logger.warning(f"Video juda uzun: {video.duration:.0f}s")
+            video.close()
+            return None
+        
+        if video.audio is None:
+            video.close()
+            return None
+        
+        temp_audio = os.path.join(os.path.dirname(video_path), f"tmp_audio_tr_{os.getpid()}.wav")
+        video.audio.write_audiofile(temp_audio, fps=16000, nbytes=2, codec='pcm_s16le', logger=None)
+        video.close()
+        
+        if progress_callback:
+            progress_callback(10)
+        
+        # Whisper orqali nutq aniqlash
+        segments, lang = _transcribe_audio(temp_audio)
+        
+        if os.path.exists(temp_audio):
+            try: os.remove(temp_audio)
+            except: pass
+        
+        if not segments:
+            return None
+        
+        if progress_callback:
+            progress_callback(40)
+        
+        # Tarjima qilish
+        try:
+            from deep_translator import GoogleTranslator
+            translator = GoogleTranslator(source='auto', target=target_lang)
+            
+            for seg in segments:
+                if seg['text']:
+                    try:
+                        seg['text'] = translator.translate(seg['text'])
+                    except:
+                        pass  # Tarjima xato bo'lsa, asl matnni qoldirish
+        except ImportError:
+            logger.warning("deep-translator o'rnatilmagan, asl matn ishlatiladi.")
+        
+        if progress_callback:
+            progress_callback(55)
+        
+        # Shrift
+        font_path = None
+        for fp in ["/usr/share/fonts/truetype/dejavu/DejaVuSans-Bold.ttf",
+                    "/usr/share/fonts/truetype/freefont/FreeSansBold.ttf",
+                    "C:/Windows/Fonts/arialbd.ttf"]:
+            if os.path.exists(fp):
+                font_path = fp
+                break
+        
+        def subtitle_frame(get_frame, t):
+            frame = get_frame(t)
+            h, w = frame.shape[:2]
+            
+            current_text = None
+            for seg in segments:
+                if seg['start'] <= t <= seg['end']:
+                    current_text = seg['text']
+                    break
+            
+            if not current_text:
+                return frame
+            
+            pil_img = Image.fromarray(frame)
+            draw = ImageDraw.Draw(pil_img)
+            font_size = max(18, int(h * 0.04))
+            try:
+                font = ImageFont.truetype(font_path, font_size) if font_path else ImageFont.load_default()
+            except:
+                font = ImageFont.load_default()
+            
+            max_chars = max(20, int(w / (font_size * 0.55)))
+            lines = []
+            words = current_text.split()
+            current_line = ""
+            for word in words:
+                test = current_line + (" " if current_line else "") + word
+                if len(test) <= max_chars:
+                    current_line = test
+                else:
+                    if current_line:
+                        lines.append(current_line)
+                    current_line = word
+            if current_line:
+                lines.append(current_line)
+            
+            if not lines:
+                return frame
+            
+            line_height = font_size + 6
+            total_h = line_height * len(lines)
+            bg_y = h - total_h - 30
+            
+            overlay = np.array(pil_img)
+            overlay[bg_y:h-5, 10:w-10] = (overlay[bg_y:h-5, 10:w-10] * 0.3).astype(np.uint8)
+            pil_img = Image.fromarray(overlay)
+            draw = ImageDraw.Draw(pil_img)
+            
+            for i, line in enumerate(lines):
+                bbox = draw.textbbox((0, 0), line, font=font)
+                tx = (w - (bbox[2] - bbox[0])) // 2
+                ty = bg_y + 10 + (i * line_height)
+                draw.text((tx+2, ty+2), line, font=font, fill=(0, 0, 0))
+                draw.text((tx, ty), line, font=font, fill=(255, 255, 255))
+            
+            return np.array(pil_img)
+        
+        video = VideoFileClip(video_path)
+        from moviepy import VideoClip
+        
+        subtitled = VideoClip(
+            lambda t: subtitle_frame(video.get_frame, t),
+            duration=video.duration
+        )
+        
+        if video.audio:
+            subtitled = subtitled.with_audio(video.audio)
+        
+        audio_params = {"audio_codec": "aac"} if video.audio else {"audio": False}
+        subtitled.write_videofile(
+            output_path, codec="libx264", fps=video.fps or 24,
+            preset="ultrafast", threads=4, logger=None, **audio_params
+        )
+        
+        video.close()
+        subtitled.close()
+        
+        if progress_callback:
+            progress_callback(99)
+        
+        return output_path if os.path.exists(output_path) else None
+    except Exception as e:
+        logger.error(f"Subtitle Translate xatosi: {e}")
+        return None
+
+def apply_style_transfer(image_path, output_path, style="anime"):
+    """HF Inference API orqali rasmga badiiy uslub qo'llaydi."""
+    try:
+        from huggingface_hub import InferenceClient
+        
+        hf_token = os.environ.get("HF_TOKEN")
+        client = InferenceClient(token=hf_token)
+        
+        style_prompts = {
+            "anime": "anime style, vibrant colors, clean lines, studio ghibli",
+            "sketch": "pencil sketch, black and white drawing, detailed shading",
+            "oil": "oil painting style, thick brush strokes, impressionist",
+            "cartoon": "cartoon style, bold outlines, bright flat colors, pixar style"
+        }
+        
+        prompt = style_prompts.get(style, style_prompts["anime"])
+        
+        with open(os.path.abspath(image_path), 'rb') as f:
+            image_data = f.read()
+        
+        result = client.image_to_image(
+            image_data,
+            prompt=prompt,
+            model="timbrooks/instruct-pix2pix",
+            guidance_scale=7.5,
+            image_guidance_scale=1.5,
+        )
+        
+        result.save(os.path.abspath(output_path))
+        return output_path
+    except ImportError:
+        logger.error("huggingface_hub kutubxonasi o'rnatilmagan.")
+        return None
+    except Exception as e:
+        logger.error(f"Style Transfer xatosi: {e}")
+        return None

main.py

@@ -54,7 +54,11 @@ from filters import (
     process_video_bw, process_video_color_correct, process_video_remove_audio,
     process_video_trim, process_video_face_fix, process_video_auto_enhance,
     process_video_fps_boost, apply_nudenet_filter, process_video_nnsfw,
-    process_video_subtitle
+    process_video_subtitle,
+    apply_glitch_filter, apply_mirror_filter, apply_watermark, apply_bg_remove,
+    apply_style_transfer,
+    process_video_glitch, process_video_mirror, process_video_watermark,
+    process_video_subtitle_translate
 )
 from database import db
 from concurrent.futures import ThreadPoolExecutor
@@ -236,6 +240,22 @@ async def handle_photo(update: Update, context: ContextTypes.DEFAULT_TYPE):
             [
                 InlineKeyboardButton("🛡️ Media Shield", callback_data=f"n|p|{short_id}")
             ],
+            [
+                InlineKeyboardButton("🪄 Glitch", callback_data=f"gl|p|{short_id}"),
+                InlineKeyboardButton("🪞 Mirror", callback_data=f"mr|p|{short_id}")
+            ],
+            [
+                InlineKeyboardButton("🎨 Fon o'chirish", callback_data=f"bg|p|{short_id}"),
+                InlineKeyboardButton("📱 Watermark", callback_data=f"wm|p|{short_id}")
+            ],
+            [
+                InlineKeyboardButton("🖌️ Anime", callback_data=f"st_anime|p|{short_id}"),
+                InlineKeyboardButton("🖌️ Sketch", callback_data=f"st_sketch|p|{short_id}")
+            ],
+            [
+                InlineKeyboardButton("🖌️ Oil Paint", callback_data=f"st_oil|p|{short_id}"),
+                InlineKeyboardButton("🖌️ Cartoon", callback_data=f"st_cart|p|{short_id}")
+            ],
             [
                 InlineKeyboardButton("🔙 Bekor qilish", callback_data="nav|main")
             ]
@@ -295,6 +315,20 @@ async def handle_video(update: Update, context: ContextTypes.DEFAULT_TYPE):
             [
                 InlineKeyboardButton("📝 Auto-Subtitle", callback_data=f"sub|v|{short_id}")
             ],
+            [
+                InlineKeyboardButton("🪄 Glitch", callback_data=f"gl|v|{short_id}"),
+                InlineKeyboardButton("🪞 Mirror", callback_data=f"mr|v|{short_id}")
+            ],
+            [
+                InlineKeyboardButton("📱 Watermark", callback_data=f"wm|v|{short_id}")
+            ],
+            [
+                InlineKeyboardButton("🌐 Sub+O'zbek", callback_data=f"stuz|v|{short_id}"),
+                InlineKeyboardButton("🌐 Sub+Rus", callback_data=f"stru|v|{short_id}")
+            ],
+            [
+                InlineKeyboardButton("🌐 Sub+English", callback_data=f"sten|v|{short_id}")
+            ],
             [
                 InlineKeyboardButton("🔙 Bekor qilish", callback_data="nav|main")
             ]
@@ -391,13 +425,23 @@ async def button_handler(update: Update, context: ContextTypes.DEFAULT_TYPE):
                 func = {
                     "r": apply_retro_filter, "u": upscale_image, 
                     "f": apply_face_restore, "a": apply_auto_enhance,
-                    "n": apply_nudenet_filter
+                    "n": apply_nudenet_filter,
+                    "gl": apply_glitch_filter, "mr": apply_mirror_filter,
+                    "wm": apply_watermark, "bg": apply_bg_remove,
                 }.get(action)
-                if not func:
+                
+                # Style Transfer uchun alohida mantiq
+                if action.startswith("st_"):
+                    style = action.replace("st_", "").replace("cart", "cartoon")
+                    success_path = await loop.run_in_executor(
+                        executor, apply_style_transfer, input_path, output_path, style
+                    )
+                elif not func:
                     logger.error(f"Unknown action: {action}")
                     await context.bot.send_message(query.message.chat_id, "❌ Noma'lum amal.")
                     return
-                success_path = await loop.run_in_executor(executor, func, input_path, output_path)
+                else:
+                    success_path = await loop.run_in_executor(executor, func, input_path, output_path)
             else:
                 # FPS Boost uchun alohida mantiq
                 if action in ("fps30", "fps60", "fps120"):
@@ -418,9 +462,21 @@ async def button_handler(update: Update, context: ContextTypes.DEFAULT_TYPE):
                         "vf": process_video_face_fix,
                         "va": process_video_auto_enhance,
                         "n": process_video_nnsfw,
-                        "sub": process_video_subtitle
+                        "sub": process_video_subtitle,
+                        "gl": process_video_glitch,
+                        "mr": process_video_mirror,
+                        "wm": process_video_watermark
                     }
-                    func = video_funcs.get(action)
+                    
+                    # Subtitle Tarjima uchun alohida mantiq
+                    if action in ("stuz", "stru", "sten"):
+                        lang_map = {"stuz": "uz", "stru": "ru", "sten": "en"}
+                        target = lang_map[action]
+                        success_path = await loop.run_in_executor(
+                            executor, process_video_subtitle_translate, input_path, output_path, target, callback
+                        )
+                    else:
+                        func = video_funcs.get(action)
                     if not func:
                         logger.error(f"Unknown video action: {action}")
                         await context.bot.send_message(query.message.chat_id, "❌ Noma'lum video amali.")
@@ -437,8 +493,13 @@ async def button_handler(update: Update, context: ContextTypes.DEFAULT_TYPE):
                     "ra": "ovoz olib tashlash", "t": "kesish", "vf": "video face fix",
                     "va": "video auto enhance", "fps30": "30 FPS boost",
                     "fps60": "60 FPS boost", "fps120": "120 FPS boost",
-                    "n": "media shield",
-                    "sub": "auto-subtitle"
+                     "n": "media shield",
+                     "sub": "auto-subtitle",
+                     "gl": "glitch", "mr": "mirror",
+                     "wm": "watermark", "bg": "fon o'chirish",
+                     "st_anime": "AI anime", "st_sketch": "AI sketch",
+                     "st_oil": "AI oil paint", "st_cart": "AI cartoon",
+                     "stuz": "sub+o'zbek", "stru": "sub+rus", "sten": "sub+english"
                 }.get(action, f"filter_{action}")
                 db.log_history(query.from_user.id, "photo" if m_type == "p" else "video", f_name, file_id)
                 

requirements.txt

@@ -12,3 +12,6 @@ httpx[socks]
 nudenet
 onnxruntime
 faster-whisper
+rembg[cpu]
+deep-translator
+huggingface_hub