From 80c9353af45cdad05c13e4e4ded6bd485f67ca51 Mon Sep 17 00:00:00 2001
From: Your Name <you@example.com>
Date: Wed, 5 Aug 2026 20:03:27 +0500
Subject: [PATCH] hotfix: undefined constants in insta_parser

---
 src/vk_parser_app/workers/insta_parser.py | 28 +++++++++++++----------
 1 file changed, 16 insertions(+), 12 deletions(-)

diff --git a/src/vk_parser_app/workers/insta_parser.py b/src/vk_parser_app/workers/insta_parser.py
index e8f90ae..3b7a8a5 100644
--- a/src/vk_parser_app/workers/insta_parser.py
+++ b/src/vk_parser_app/workers/insta_parser.py
@@ -30,8 +30,10 @@ from loguru import logger
 from ..config import settings
 from ..constants import (
     PLATFORM_INSTAGRAM,
-    POST_STATUS_TRASH,
-    POST_STATUS_MEDIA_PENDING,
+    POST_STATUS_STORAGE_PENDING,
+    POST_STATUS_SKIPPED,
+    SOURCE_STATUS_ERROR,
+    SOURCE_STATUS_OK,
     WORKER_INSTA_PARSER,
 )
 from ..db import fetch_setting, fetch_int_setting, get_pool
@@ -108,12 +110,13 @@ class InstaParserWorker:
                 """
                 UPDATE sources
                 SET active = FALSE,
-                    status = 'error',
-                    status_msg = $1,
+                    status = $1,
+                    status_msg = $2,
                     last_checked_at = NOW(),
                     updated_at = NOW()
-                WHERE id = $2
+                WHERE id = $3
                 """,
+                SOURCE_STATUS_ERROR,
                 reason[:1000],
                 source_id,
             )
@@ -123,15 +126,16 @@ class InstaParserWorker:
             await conn.execute(
                 """
                 UPDATE sources
-                SET status = 'ok',
+                SET status = $1,
                     status_msg = NULL,
                     last_checked_at = NOW(),
                     last_parsed_at = COALESCE($2, last_parsed_at),
                     updated_at = NOW()
-                WHERE id = $1
+                WHERE id = $3
                 """,
-                source_id,
+                SOURCE_STATUS_OK,
                 last_parsed_at,
+                source_id,
             )
             
     async def save_cooldown(self, hours: int) -> None:
@@ -235,7 +239,7 @@ class InstaParserWorker:
                         str(v_url),
                     )
 
-                if status == POST_STATUS_MEDIA_PENDING:
+                if status == POST_STATUS_STORAGE_PENDING:
                     await conn.execute(
                         """
                         INSERT INTO jobs (job_type, entity_type, entity_id, payload, status)
@@ -334,16 +338,16 @@ class InstaParserWorker:
                 has_media = media_type in (1, 2, 8)
                 
                 if not has_media:
-                    if await self.save_post_and_media(source_id, post, POST_STATUS_TRASH, "no_media"):
+                    if await self.save_post_and_media(source_id, post, POST_STATUS_SKIPPED, "no_media"):
                         saved += 1
                     continue
                     
                 if len(text) < min_text_length:
-                    if await self.save_post_and_media(source_id, post, POST_STATUS_TRASH, "text_too_short"):
+                    if await self.save_post_and_media(source_id, post, POST_STATUS_SKIPPED, "text_too_short"):
                         saved += 1
                     continue
 
-                if await self.save_post_and_media(source_id, post, POST_STATUS_MEDIA_PENDING, None):
+                if await self.save_post_and_media(source_id, post, POST_STATUS_STORAGE_PENDING, None):
                     saved += 1
             except Exception as e:
                 logger.error(f"Failed to save insta post {post.get('pk')}: {e}")