Update app.py
Browse files
app.py
CHANGED
|
@@ -493,29 +493,44 @@ def new_conversation():
|
|
| 493 |
return render_template('new_conversation.html')
|
| 494 |
|
| 495 |
|
|
|
|
|
|
|
| 496 |
@app.route('/downdb', methods=['GET'])
|
| 497 |
@login_required
|
| 498 |
-
|
| 499 |
def downdbur():
|
| 500 |
msgid = request.args.get('msg', '')
|
| 501 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 502 |
rp = loop.run_until_complete(downdb(msgid))
|
| 503 |
-
|
| 504 |
-
|
|
|
|
| 505 |
return '200'
|
| 506 |
return 'no'
|
| 507 |
|
|
|
|
| 508 |
@app.route('/updb', methods=['GET'])
|
| 509 |
@login_required
|
| 510 |
def updbur():
|
| 511 |
-
loop
|
|
|
|
|
|
|
|
|
|
|
|
|
| 512 |
rp = loop.run_until_complete(updb())
|
| 513 |
-
|
|
|
|
|
|
|
| 514 |
return '200'
|
| 515 |
return 'no'
|
| 516 |
|
| 517 |
|
| 518 |
|
|
|
|
| 519 |
@app.route('/conversation/<int:recipient_id>', methods=['GET', 'POST'])
|
| 520 |
@login_required
|
| 521 |
def conversation(recipient_id):
|
|
|
|
| 493 |
return render_template('new_conversation.html')
|
| 494 |
|
| 495 |
|
| 496 |
+
|
| 497 |
+
|
| 498 |
@app.route('/downdb', methods=['GET'])
|
| 499 |
@login_required
|
|
|
|
| 500 |
def downdbur():
|
| 501 |
msgid = request.args.get('msg', '')
|
| 502 |
+
|
| 503 |
+
# Create a new event loop for the current thread
|
| 504 |
+
loop = asyncio.new_event_loop()
|
| 505 |
+
asyncio.set_event_loop(loop)
|
| 506 |
+
|
| 507 |
+
# Run the async function
|
| 508 |
rp = loop.run_until_complete(downdb(msgid))
|
| 509 |
+
loop.close() # Close the loop when done
|
| 510 |
+
|
| 511 |
+
if rp == '2':
|
| 512 |
return '200'
|
| 513 |
return 'no'
|
| 514 |
|
| 515 |
+
|
| 516 |
@app.route('/updb', methods=['GET'])
|
| 517 |
@login_required
|
| 518 |
def updbur():
|
| 519 |
+
# Create a new event loop for the current thread
|
| 520 |
+
loop = asyncio.new_event_loop()
|
| 521 |
+
asyncio.set_event_loop(loop)
|
| 522 |
+
|
| 523 |
+
# Run the async function
|
| 524 |
rp = loop.run_until_complete(updb())
|
| 525 |
+
loop.close() # Close the loop when done
|
| 526 |
+
|
| 527 |
+
if rp == '2':
|
| 528 |
return '200'
|
| 529 |
return 'no'
|
| 530 |
|
| 531 |
|
| 532 |
|
| 533 |
+
|
| 534 |
@app.route('/conversation/<int:recipient_id>', methods=['GET', 'POST'])
|
| 535 |
@login_required
|
| 536 |
def conversation(recipient_id):
|