ftnlocal.py

#!/usr/local/bin/python3 -bb

""" process local mail """

import ftnconfig
import ftnexport
import ftnimport
import ftnaccess
import time
from ftn.ftn import *

from badwriter import BadWriter

#localmsgs=BadWriter(LOCALNETMAIL, os.path.join(LOCALNETMAIL, "next"), "msg")

def subscribe(db, sess, node, targetdomain, pattern):
    r = []
    for target in ftnexport.get_matching_targets(db, targetdomain, pattern):
        try:
          r.append(sess.add_subscription(None, targetdomain, target, node) + ": " + target)
        except FTNNoAddressInBase:
          r.append("no such area: " + target)
        except FTNAlreadySubscribed:
          r.append("seems you are uplink for it: " + target)
    if len(r)==0:
          r.append("no matching area: " + pattern)
    return r

def unsubscribe(db, sess, node, targetdomain, pattern):
    r = []
    for target in ftnexport.get_matching_targets(db, targetdomain, pattern):
        try:
          r.append(sess.remove_subscription(targetdomain, target, node) + ": " + target)
        except FTNNoAddressInBase:
          r.append("no such area: " + target)
    if len(r)==0:
          r.append("no matching area: " + pattern)
    return r

def reset(db, sess, node, targetdomain, arg):
    r = []
    pattern, timestamp = map(str.strip, arg.split(" ", 1))
    for target in ftnexport.get_matching_targets(db, targetdomain, pattern):
        try:
          r.append(sess.reset_subscription(targetdomain, target, node, timestamp) + ": " + target)
        except FTNNoAddressInBase:
          r.append("no such area: " + target)
    if len(r)==0:
          r.append("no matching area: " + pattern)
    return r

def fix(db, sess, src, srcname, destname, domain, password, msgid, cmdtext, is_local):
  dom, text = db.prepare("select domain, text from addresses where id=$1").first(src)
  if dom != db.FTN_domains["node"]:
    raise FTNFail("not our domain")
  print("*fix for:", text)
  link_id, addr_id, myaddr_id = ftnaccess.check_link(db, text, password, True)
  if myaddr_id is None:
    reply=["wrong password"]
    raise(Exception("cannot find my address to reply to *fix message"))
  elif link_id is None:
    reply=["unknown link"]
  elif not is_local:
    reply=["request delivered not directly, please consider changing the password"]
  else:
    reply=[]
    for cmd in map(str.strip, cmdtext.upper().strip().split("\n")):
      if cmd.startswith("---"):
        break
      elif len(cmd)==0:
        continue
      elif cmd.startswith("%PING"):
        reply.append("NOP: "+cmd)
      elif cmd.startswith("%QUERY"):
        for area in ftnexport.get_node_subscriptions(db, text, domain):
          reply.append(area)
      elif cmd.startswith("%HELP"):
        reply.append("Use following command:")
        reply.append("  %QUERY          -- list of subscribed areas")
        reply.append("  %LIST           -- list of all areas")
        reply.append("  +areaname       -- subscribe, or:")
        reply.append("  areaname        -- subscribe")
        reply.append("  -areaname       -- unsubscribe")
        reply.append("        you can use ? to substitite any one character an area name")
        reply.append("        or * to substitude any number of any characters in area name")
        reply.append("        areaname must be UPPERCASE")
        reply.append("  %RESET area YYYY-MM-DD -- reset area to specified date")
        reply.append("")
      elif cmd.startswith("%LIST"):
        for area in ftnexport.get_all_targets(db, domain):
          reply.append(area)
      elif cmd.startswith("%AVAIL"):
        reply.append("Sorry not implemented: "+cmd)
      elif cmd.startswith("%PAUSE"):
        reply.append("Sorry not implemented: "+cmd)
      elif cmd.startswith("%RESET"):
        reply += reset(db, sess, text, domain, cmd[7:])
      elif cmd.startswith("-"):
        reply += unsubscribe(db, sess, text, domain, cmd[1:])
      elif cmd.startswith("+"):
        reply += subscribe(db, sess, text, domain, cmd[1:])
      elif cmd.startswith("%"):
        reply.append("Unknown command: "+cmd)
        print(cmd)
#        1/0
      else:
        reply+=subscribe(db, sess, text, domain, cmd)

  reply.append("")
  print("*fix reply from:", myaddr_id, ftnconfig.get_taddr(db, myaddr_id))
  sess.send_message(ftnconfig.get_taddr(db, myaddr_id), destname+" Robot", ("node", text), srcname, msgid, "report", "\n".join(reply), sendmode="direct")
  print(reply)


#for s in ftnexport.get_node_subscriptions(db, "2:5020/4441", "echo"):
#  print(db.prepare("select a.domain, a.text from addresses a, subscriptions s where s.id=$1 and a.id=s.target")(s)[0])
#exit()

db = ftnconfig.connectdb()

fixes_e = []
fixes_f = []

for me in ftnconfig.my_addrs(db):
 print(time.asctime(), "start ftnlocal for", me)



 for id_msg, src, dest, msgid, header, body, origcharset, recvfrom in ftnexport.get_subscriber_messages_n(db, me, db.FTN_domains["node"]):

  is_local = src==recvfrom

  if header.find("recipientname").text.lower() == "areafix":
    fixes_e.append((id_msg, src, time.mktime(time.strptime(header.find("date").text, "%d %b %y  %H:%M:%S")), 
        header.find("sendername").text, header.find("subject").text, msgid, body, is_local))

  elif header.find("recipientname").text.lower() in ("filefix", "allfix"):
    fixes_f.append((id_msg, src, time.mktime(time.strptime(header.find("date").text, "%d %b %y  %H:%M:%S")), 
        header.find("sendername").text, header.find("subject").text, msgid, body, is_local))

  else:
    continue

    # leave all other in database for sysop

    srca=db.prepare("select domain, text from addresses where id=$1").first(src)
    dsta=db.prepare("select domain, text from addresses where id=$1").first(dest)

    print(srca)

    m, mcharset = ftnexport.denormalize_message(
        (db.FTN_backdomains[srca[0]], srca[1]),
        (db.FTN_backdomains[dsta[0]], dsta[1]),
        msgid, header, body, origcharset)

    my.append((id_msg, time.mktime(time.strptime(header.find("date").text, "%d %b %y  %H:%M:%S")), m))

    print("*************"+str(id_msg)+"*"+msgid+"*****************")
    print("From:", header.find("sendername").text, src)
    print("To  :", header.find("recipientname").text, dest)
    print("Date:", header.find("date").text)
    #print("Subj:", header.find("subject").text)
#    print(body)
    # process
    # if fail abort
    # if ok update watermark update_subscription_watermark(db, localnetmailsubscription, id_msg)


fixes_e.sort(key = lambda x: x[2])
fixes_f.sort(key = lambda x: x[2])
#my.sort(key = lambda x: x[1])

#for id_msg, _, m in my:
#  localmsgs.write(m.pack(), None)
#  db.prepare("update messages set processed=1 where id=$1")(id_msg)

for id_msg, src, _, sn, h, mi, b, is_local in fixes_e:
  with ftnimport.session(db) as sess:
    print("fix:", sess, src, sn, "AreaFix", "echo", h, mi, b, is_local)
    try:
      fix(db, sess, src, sn, "AreaFix", "echo", h, mi, b, is_local)
      db.prepare("update messages set processed=1 where id=$1")(id_msg)
    except Exception as e:
      print(e)
      continue
    

for id_msg, src, _, sn, h, mi, b, is_local in fixes_f:
  with ftnimport.session(db) as sess:
    print("fix:", sess, src, sn, "AreaFix", "echo", h, mi, b, is_local)
    try:
      fix(db, sess, src, sn, "FileFix", "fileecho", h, mi, b, is_local)
      db.prepare("update messages set processed=1 where id=$1")(id_msg)
    except Exception as e:
      print(e)
      continue

exit()

#for s in ftnexport.get_node_subscriptions(db, "2:5020/12000", "node"):
#  print(db.prepare("select a.domain, a.text from addresses a, subscriptions s where s.id=$1 and a.id=s.target")(s)[0])


for sub_id, target_id, lastsent in ftnexport.get_node_subscriptions(db, ADDRESS, "node"):
  print(sub_id, ": mail directed to", 
        db.prepare("select a.domain, a.text from addresses a, subscriptions s where s.id=$1 and a.id=s.target").first(sub_id))
  
  for id_msg, srcdom, srctext, msgid, header, body, recvfrom in ftnexport.get_messages(db, target_id, lastsent):
    print("*************"+str(id_msg)+"*"+msgid+"*****************")
    print("From:", header.find("sendername").text.encode("utf-8"), srcdom,srctext)
    print("To  :", header.find("recipientname").text.encode("utf-8"), "node",ADDRESS)
    print("Date:", header.find("date").text.encode("utf-8"))
    print("Subj:", header.find("subject").text.encode("utf-8"))
    print(body.encode("utf-8"))
    # process
    # if fail abort
    # if ok update watermark update_subscription_watermark(db, localnetmailsubscription, id_msg)