Implement indexing into Apache Druid #1

Closed
m wants to merge 263 commits from druid into master
3 changed files with 9 additions and 6 deletions
Showing only changes of commit 2c3d83fe9a - Show all commits

View File

@ -1,7 +1,8 @@
from json import dumps
import main
from modules import chankeep
from modules import helpers
from json import dumps
class DedupCommand:
def __init__(self, *args):

View File

@ -1,6 +1,5 @@
import main
from modules import chankeep
from utils.logging.debug import debug

View File

@ -55,8 +55,7 @@ def substitute(net, num, token=None):
email = f"{alias['nickname']}@{domain}"
gotemail = True
if not gotemail:
error(f"Could not get email for {net} - {num}")
return False
inst["email"] = False
nickname = alias["nick"]
# username = nickname + "/" + net
password = main.network[net].aliases[num]["password"]
@ -73,7 +72,8 @@ def substitute(net, num, token=None):
inst[i] = inst[i].replace("{nickname}", nickname)
inst[i] = inst[i].replace("{curnick}", curnick)
inst[i] = inst[i].replace("{password}", password)
inst[i] = inst[i].replace("{email}", email)
if gotemail:
inst[i] = inst[i].replace("{email}", email)
if token:
inst[i] = inst[i].replace("{token}", token)
return inst
@ -85,6 +85,9 @@ def registerAccount(net, num):
if not sinst:
error(f"Register account failed for {net} - {num}")
return
if not sinst["email"]:
error(f"Could not get email for {net} - {num}")
return
if not sinst["register"]:
error("Cannot register for %s: function disabled" % (net))
return False