(14 . 7)(14 . 7)
##############################################################################

# Version. If changing this program, always set this to same # as in MANIFEST
Ver = 597858
Ver = 684804

##############################################################################

(74 . 6)(74 . 7)
    DB_DEBUG    = cfg.get("db", "db_debug")
    # Logism:
    Base_URL    = cfg.get("logotron", "base_url")
    App_Root    = cfg.get("logotron", "app_root")
    Era         = int(cfg.get("logotron", "era"))
    NewChan_Idx = int(cfg.get("logotron", "newchan_idx"))
    Src_URL     = cfg.get("logotron", "src_url")
(142 . 7)(143 . 7)
def init_socket():
    global sock
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    

    # Disable Nagle's algorithm for transmit operations
    sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)
    # Disable Nagle's algorithm for receive operation, Linux-only
(150 . 7)(151 . 7)
        sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_QUICKACK, 1)
    except Exception as e:
        logging.warning(e)
    

    connected = False

def deinit_socket():
(250 . 32)(251 . 32)
    global time_last_conn
    global time_last_recv
    global sock
    

    # Initialize a socket
    init_socket()
    

    # Connect to one among the specified servers, in given priority :
    while not connected:
        connected = connect_any(Servers, Port)

    # Save time of last successful connect
    time_last_conn = datetime.now()
    

    # Auth to server
    send("NICK %s\r\n" % Nick)
    send("USER %s %s %s :%s\r\n" % (Nick, Nick, Nick, Nick))
    

    # If this is a production bot, rather than test, there will be a PW:
    if Pass != "":
        send("NICKSERV IDENTIFY %s %s\r\n" % (Nick, Pass))
    

    time.sleep(Join_Delay) # wait to join until fleanode eats auth
    

    # Join selected channels
    for chan in Channels:
        logging.info("Joining channel '%s'..." % chan)
        send("JOIN #%s\r\n" % chan)
    

    while connected:
        try:
            data = sock.recv(Buf_Size)
(355 . 7)(356 . 8)

# Get perma-URL corresponding to given log line
def line_url(l):
    return "{0}log/{1}/{2}#{3}".format(Base_URL,
    return "{0}{1}{2}/{3}#{4}".format(Base_URL,
                                       App_Root,
                                       l['chan'],
                                       l['t'].strftime(Date_Short_Format),
                                       l['idx'])
(378 . 7)(380 . 7)
    if arg == "":
        speak(chan, "Required argument: USER")
        return
    

    # Perform query:
    seen_line = query_db(
        '''select t, idx, payload, chan from loglines where
(387 . 7)(389 . 7)

    # Where output will go
    result = ""
    

    # If user has been seen in THE CURRENT chan:
    if seen_line != None:
        time_txt = seen_line['t'].strftime(Date_Long_Format)
(399 . 7)(401 . 7)
    else:
        # If user has never been seen in this chan:
        result = "The user %s has never been seen in #%s." % (arg, chan)
    

    # Speak the result into the chan where command was issued
    speak(chan, result)

(408 . 7)(410 . 7)
    if arg == "":
        speak(chan, "Required argument: USER")
        return
    

    # Perform query:
    seen_line = query_db(
        '''select t, idx, payload, chan from loglines where speaker=%s
(417 . 7)(419 . 7)

    # Where output will go
    result = ""
    

    # If user has been seen in ANY logged chan:
    if seen_line != None:
        time_txt = seen_line['t'].strftime(Date_Long_Format)
(474 . 20)(476 . 20)
            '''select idx from loglines where chan=%s
            and idx = (select max(idx) from loglines where chan=%s) ;''',
            [chan, chan], one=True)
        

        # Was this chan unseen previously?
        if last_idx == None:
            cur_idx = NewChan_Idx # Then use the config'd start index
        else:
            cur_idx = last_idx['idx'] + 1 # Otherwise, get the next idx
        

        logging.debug("Adding log line with index: %s" % cur_idx)

        # Set up the insert
        exec_db('''insert into loglines (idx, t, chan, era,
        speaker, self, payload) values (%s, %s, %s, %s, %s, %s, %s) ; ''',
                [cur_idx, time, chan, Era, speaker, action, payload])
        

        # Fire
        commit_db()
    except Exception as e:
(497 . 7)(499 . 10)


# RE for finding log refs
logref_re = re.compile(Base_URL + """log\/([^/]+)/[^/]+#(\d+)""")
if App_Root == '/':
    logref_re = re.compile(Base_URL + """([^/]+)/[^/]+#(\d+)""")
else:
    logref_re = re.compile(Base_URL + App_Root.strip('/') + """\/([^/]+)/[^/]+#(\d+)""")

# All valid received lines end up here
def eat_logline(user, chan, text, action):
(506 . 10)(511 . 10)
        logging.warning(
            "Received martian : '%s' : '%s'" % (chan, text))
        return
    

    # First, add the line to the log:
    save_line(datetime.now(), chan, user, action, text)
    

    # Then, see if the line was a command for this bot:
    if text.startswith(Prefix):
        cmd = text.partition(Prefix)[2].strip()
(555 . 7)(560 . 7)
                                                  time_txt,
                                                  ref_line['speaker'],
                                                  ref_line['payload'])
                

                # Speak the line echo into the chan where ref was seen
                speak(chan, my_line)