docs: update readme

README.md

@@ -8,9 +8,9 @@ This tool performs destructive operations. Only use it if you intend to erase da
 
 ## Requirements
 
-We're using [`uv`](https://github.com/astral-sh/uv) for dependency and virtual environment management.
+Check `pyproject.toml`.
 
-You can setup the project (aka create a virtual environment and install dependencies) with :
+You can use `uv` to install dependencies:
 
 ```bash
 git clone https://git.kharec.info/Kharec/skywipe.git
@@ -64,13 +64,17 @@ BE SURE TO USE A [BLUESKY APP PASSWORD](https://blueskyfeeds.com/faq-app-passwor
 - [x] handle configuration logic
 - [x] sign in to at protocol
 - [x] delete posts in batch
-- [ ] only delete posts with media
+- [x] only delete posts with media
 - [ ] remove likes
 - [ ] remove reposts
 - [ ] unfollow accounts
 - [ ] make `all` run the other commands
 - [ ] add simple progress and logging
 - [ ] add safeguards like confirmations and clear dry-run info
+
+Once it's done, we'll think:
+
+- [ ] decent code architecture
 - [ ] installation and run process
 
 ## License

skywipe/commands.py

@@ -3,6 +3,7 @@
 from typing import Callable, Dict, Optional
 from skywipe.configure import Configuration
 from skywipe.posts import delete_posts
+from skywipe.medias import delete_posts_with_medias
 
 
 CommandHandler = Callable[[], None]
@@ -58,7 +59,7 @@ def run_posts():
 
 
 def run_medias():
-    print("Command 'medias' is not yet implemented.")
+    delete_posts_with_medias()
 
 
 def run_likes():

skywipe/medias.py

@@ -0,0 +1,96 @@
+"""Media post deletion module for Skywipe"""
+
+import time
+from skywipe.auth import Auth
+from skywipe.configure import Configuration
+
+
+def has_media_embed(post_record):
+    embed = getattr(post_record, 'embed', None)
+    if not embed:
+        return False
+
+    embed_type = getattr(embed, 'py_type', None)
+    media_types = {
+        'app.bsky.embed.images',
+        'app.bsky.embed.video',
+        'app.bsky.embed.external'
+    }
+
+    if embed_type:
+        embed_type_base = embed_type.split('#')[0]
+
+        if embed_type_base in media_types:
+            return True
+
+        if embed_type_base in ('app.bsky.embed.recordWithMedia', 'app.bsky.embed.record_with_media'):
+            media = getattr(embed, 'media', None)
+            if media:
+                media_type = getattr(media, 'py_type', None)
+                if media_type:
+                    media_type_base = media_type.split('#')[0]
+                    if media_type_base in media_types:
+                        return True
+
+    for attr in ('images', 'video', 'external'):
+        if hasattr(embed, attr):
+            return True
+        if isinstance(embed, dict) and embed.get(attr):
+            return True
+    return False
+
+
+def delete_posts_with_medias():
+    auth = Auth()
+    client = auth.login()
+    config = Configuration()
+    config_data = config.load()
+
+    batch_size = config_data.get("batch_size", 10)
+    delay = config_data.get("delay", 1)
+    verbose = config_data.get("verbose", False)
+
+    if verbose:
+        print(
+            f"Starting media post deletion with batch_size={batch_size}, delay={delay}s")
+
+    did = client.me.did
+    cursor = None
+    total_deleted = 0
+
+    while True:
+        if cursor:
+            response = client.get_author_feed(
+                actor=did, limit=batch_size, cursor=cursor)
+        else:
+            response = client.get_author_feed(actor=did, limit=batch_size)
+
+        posts = response.feed
+        if not posts:
+            break
+
+        for post in posts:
+            post_record = post.post
+
+            if not has_media_embed(post_record):
+                if verbose:
+                    print(f"Skipping post without media: {post_record.uri}")
+                continue
+
+            try:
+                client.delete_post(post_record.uri)
+                total_deleted += 1
+                if verbose:
+                    print(f"Deleted post with media: {post_record.uri}")
+            except Exception as e:
+                if verbose:
+                    print(f"Error deleting post {post_record.uri}: {e}")
+
+        cursor = response.cursor
+        if not cursor:
+            break
+
+        if delay > 0:
+            time.sleep(delay)
+
+    print(f"Deleted {total_deleted} posts with media.")