import os
import sqlite3
from datetime import datetime, timezone
import asyncio
from telethon import TelegramClient
from telethon.tl.types import DocumentAttributeFilename
import time

# Telegram bilgileri
api_id = 106101
api_hash = '7b0c7355ceaf469e5402'
chat_link = 'https://t.me/+lB'

# Yerel klasör
YEREL_KLASOR = r"F:\Al1999-2024 part1"

# Veritabanı dosyası
DB_DOSYA = 'telegram_dosya_hafiza.db' # İstersen yolunu değiştir

def veritabani_olustur():
conn = sqlite3.connect(DB_DOSYA)
cursor = conn.cursor()
cursor.execute('''
CREATE TABLE IF NOT EXISTS dosyalar (
isim TEXT,
boyut INTEGER,
PRIMARY KEY (isim, boyut)
)
''')
cursor.execute('''
CREATE TABLE IF NOT EXISTS meta (
anahtar TEXT PRIMARY KEY,
deger TEXT
)
''')
conn.commit()
conn.close()

def son_tarama_tarihi_al():
conn = sqlite3.connect(DB_DOSYA)
cursor = conn.cursor()
cursor.execute('SELECT deger FROM meta WHERE anahtar = "son_tarama"')
sonuc = cursor.fetchone()
conn.close()
if sonuc:
return datetime.fromisoformat(sonuc[0]).replace(tzinfo=timezone.utc)
else:
return datetime(2000, 1, 1, tzinfo=timezone.utc)

def son_tarama_tarihi_kaydet(tarih):
conn = sqlite3.connect(DB_DOSYA)
cursor = conn.cursor()
cursor.execute('INSERT OR REPLACE INTO meta (anahtar, deger) VALUES ("son_tarama", ?)',
(tarih.isoformat(),))
conn.commit()
conn.close()

def veritabani_kayit_sayisi():
conn = sqlite3.connect(DB_DOSYA)
cursor = conn.cursor()
cursor.execute('SELECT COUNT(*) FROM dosyalar')
sayi = cursor.fetchone()[0]
conn.close()
return sayi

async def telegram_dosya_hafiza_guncelle(client):
veritabani_olustur()
conn = sqlite3.connect(DB_DOSYA)
cursor = conn.cursor()

try:
entity = await client.get_entity(chat_link)
print(f"Chat bulundu: {entity.title}")
except Exception as e:
print(f"Chat bulunamadı! Hata: {e}")
conn.close()
return

baslangic_tarihi = son_tarama_tarihi_al()
bitis_tarihi = datetime.now(timezone.utc)

print(f"Sadece {baslangic_tarihi.strftime('%Y-%m-%d')} sonrası yeni dosyalar taranıyor...")

eklenen_sayisi = 0
en_son_tarih = baslangic_tarihi

async for message in client.iter_messages(entity, limit=None):
if message.date bitis_tarihi:
continue

if message.date > en_son_tarih:
en_son_tarih = message.date

if message.media and hasattr(message.media, 'document'):
doc = message.media.document
file_name = "İsim_Bulunamadı"
for attr in doc.attributes:
if isinstance(attr, DocumentAttributeFilename):
file_name = attr.file_name
break

boyut = doc.size

try:
cursor.execute('INSERT OR IGNORE INTO dosyalar (isim, boyut) VALUES (?, ?)', (file_name, boyut))
if cursor.rowcount > 0:
eklenen_sayisi += 1
except Exception as e:
print(f"Ekleme hatası: {e}")

conn.commit()
conn.close()

if eklenen_sayisi > 0:
print(f"{eklenen_sayisi} yeni dosya hafızaya eklendi.")
son_tarama_tarihi_kaydet(en_son_tarih)
print("Son tarama tarihi güncellendi.")
else:
print("Yeni dosya bulunamadı.")

print(f"Toplam hafızada kayıt: {veritabani_kayit_sayisi()}")

def yerel_dosya_kontrol_et_ve_sil():
if not os.path.exists(YEREL_KLASOR):
print(f"Klasör bulunamadı: {YEREL_KLASOR}")
return

conn = sqlite3.connect(DB_DOSYA)
cursor = conn.cursor()

silinen_sayisi = 0
for dosya_adi in os.listdir(YEREL_KLASOR):
dosya_yolu = os.path.join(YEREL_KLASOR, dosya_adi)
if not os.path.isfile(dosya_yolu):
continue

# Sadece .zip dosyalarını kontrol et (istersen kaldırabilirsin)
if not dosya_adi.lower().endswith('.zip'):
continue

boyut = os.path.getsize(dosya_yolu)

cursor.execute('SELECT 1 FROM dosyalar WHERE isim = ? AND boyut = ?', (dosya_adi, boyut))
if cursor.fetchone():
try:
os.remove(dosya_yolu)
gb = boyut / (1024**3)
print(f"Silindi: {dosya_adi} ({gb:.2f} GB)")
silinen_sayisi += 1
except Exception as e:
print(f"Silme hatası ({dosya_adi}): {e}")

conn.close()
print(f"\nİşlem tamamlandı. Toplam {silinen_sayisi} dosya otomatik silindi.")

async def main():
print("Telegram'a bağlanılıyor...")
client = TelegramClient('session', api_id, api_hash)
await client.start()
print("Bağlantı başarılı!")

await telegram_dosya_hafiza_guncelle(client)

while True:
print("\n" + "="*60)
print(f"{datetime.now().strftime('%Y-%m-%d %H:%M:%S')} - Yerel klasör kontrol ediliyor...")
yerel_dosya_kontrol_et_ve_sil()
print("60 saniye bekleniyor...\n")
time.sleep(60)

if __name__ == '__main__':
asyncio.run(main())