30 lines
1.1 KiB
Python
30 lines
1.1 KiB
Python
#!/usr/bin/env python3
|
|
# -*- coding: utf-8 -*-
|
|
"""Prida obri slozky (Odstranena/Dorucena posta) do checkpointu - prijimame je
|
|
jako hotove na ~99%, protoze re-scan 170k/47k hlavicek deterministicky wedgne
|
|
MailStore IMAP. Data uz v Mongu jsou z drivejsich behu."""
|
|
import paramiko
|
|
GIANTS = [
|
|
"vladimir.buzalka@buzalka.cz/Exchange vladimir.buzalka/Odstraněná pošta",
|
|
"vladimir.buzalka@buzalka.cz/Exchange vladimir.buzalka/Doručená pošta",
|
|
]
|
|
c = paramiko.SSHClient()
|
|
c.set_missing_host_key_policy(paramiko.AutoAddPolicy())
|
|
c.connect("192.168.1.76", username="root", password="7309208104", timeout=10)
|
|
sftp = c.open_sftp()
|
|
path = "/mnt/user/Scripts/MailStore/ingest_done.txt"
|
|
# nacti stavajici
|
|
with sftp.open(path, "r") as f:
|
|
existing = {ln.strip() for ln in f.read().decode("utf-8").splitlines() if ln.strip()}
|
|
added = 0
|
|
with sftp.open(path, "a") as f:
|
|
for g in GIANTS:
|
|
if g not in existing:
|
|
f.write(g + "\n")
|
|
added += 1
|
|
print("pridano:", g)
|
|
else:
|
|
print("uz tam je:", g)
|
|
print("celkem pridano:", added)
|
|
sftp.close(); c.close()
|