Pathogen
/
monolith
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Implement indexing into Apache Druid #1

Closed
m wants to merge 263 commits from druid into master
pull from: druid
merge into: Pathogen:master
Conversation 1 Commits 263 Files Changed 128 +8 -7
3 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit f6f515b308 - Show all commits

3
api/views.py
View File

@ -244,6 +244,9 @@ class API(object):
for conn in conns: for conn in conns:
conn.authenticated = False conn.authenticated = False
conn.regPing() conn.regPing()
elif func == "register":
for conn in conns:
regproc.registerAccount(conn.net, conn.num)
return dumps({"success": True}) return dumps({"success": True})
@app.route("/irc/network/<net>/", methods=["DELETE"]) @app.route("/irc/network/<net>/", methods=["DELETE"])

4
modules/provision.py
View File

@ -6,9 +6,7 @@ from utils.deliver_relay_commands import deliverRelayCommands
from utils.logging.log import warn from utils.logging.log import warn
def provisionUserNetworkData( def provisionUserNetworkData(num, nick, altnick, ident, realname, network, host, port, security):
num, nick, altnick, ident, realname, network, host, port, security
):
commands = {} commands = {}
stage2commands = {} stage2commands = {}
stage2commands["status"] = [] stage2commands["status"] = []

8
modules/regproc.py
View File

@ -2,7 +2,7 @@ from copy import deepcopy
from random import choice from random import choice
import main import main
from modules import provision, helpers from modules import provision
from utils.logging.debug import debug from utils.logging.debug import debug
from utils.logging.log import error from utils.logging.log import error
@ -89,7 +89,8 @@ def registerAccount(net, num):
error("Cannot register for %s: function disabled" % (net)) error("Cannot register for %s: function disabled" % (net))
return False return False
name = net + str(num) name = net + str(num)
main.IRCPool[name].msg(sinst["entity"], sinst["registermsg"]) if not main.IRCPool[name].authenticated:
main.IRCPool[name].msg(sinst["entity"], sinst["registermsg"])
def confirmAccount(net, num, token): def confirmAccount(net, num, token):
@ -123,15 +124,14 @@ def confirmRegistration(net, num, negativepass=None):
def attemptManualAuthentication(net, num): def attemptManualAuthentication(net, num):
sinst = substitute(net, num) sinst = substitute(net, num)
obj = main.network[net]
identifymsg = sinst["identifymsg"] identifymsg = sinst["identifymsg"]
entity = sinst["entity"] entity = sinst["entity"]
name = f"{net}{num}" name = f"{net}{num}"
print(f"SENDING `{identifymsg}` TO `{entity}` ON {name}")
if name not in main.IRCPool: if name not in main.IRCPool:
return return
main.IRCPool[name].msg(entity, identifymsg) main.IRCPool[name].msg(entity, identifymsg)
def enableAuthentication(net, num, jump=True, run_now=False): def enableAuthentication(net, num, jump=True, run_now=False):
obj = main.network[net] obj = main.network[net]
nick = main.alias[num]["nick"] nick = main.alias[num]["nick"]