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 +1 -4
2 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 7ef76d1424 - Show all commits

3
api/views.py
View File

@ -214,7 +214,6 @@ class API(object):
if net not in main.network.keys(): if net not in main.network.keys():
return dumps({"success": False, "reason": "no such net."}) return dumps({"success": False, "reason": "no such net."})
nets = [net] nets = [net]
print("NETS", nets)
for net_name in nets: for net_name in nets:
conns = helpers.get_connected_relays(net_name) conns = helpers.get_connected_relays(net_name)
if not conns: if not conns:
@ -228,14 +227,12 @@ class API(object):
conn.regPing(reset=True) conn.regPing(reset=True)
elif func == "register": elif func == "register":
for conn in conns: for conn in conns:
print("REGISTER ACCOUNT", conn.net, conn.num)
regproc.registerAccount(conn.net, conn.num) regproc.registerAccount(conn.net, conn.num)
return dumps({"success": True}) return dumps({"success": True})
@app.route("/irc/network/<net>/", methods=["POST"]) @app.route("/irc/network/<net>/", methods=["POST"])
@login_required @login_required
def irc_network(self, request, net): def irc_network(self, request, net):
print("IRC_NETWORK")
if net not in main.network.keys(): if net not in main.network.keys():
return dumps({"success": False, "reason": "no such net."}) return dumps({"success": False, "reason": "no such net."})
inst = main.network[net] inst = main.network[net]

2
modules/regproc.py
View File

@ -35,7 +35,7 @@ def selectInst(net):
if i not in inst: if i not in inst:
inst[i] = main.irc["_"][i] inst[i] = main.irc["_"][i]
else: else:
inst = main.irc["_"] inst = deepcopy(main.irc["_"])
return inst return inst