circles now working ok in ui

This commit is contained in:
Kevin Froman 2019-07-28 22:00:38 -05:00
parent ccbf687ad1
commit 9933cd1b82
4 changed files with 68 additions and 11 deletions

View File

@ -19,9 +19,15 @@
''' '''
from flask import Response, request, redirect, Blueprint, abort from flask import Response, request, redirect, Blueprint, abort
from utils import identifyhome
import deadsimplekv as simplekv
flask_blueprint = Blueprint('flow', __name__) flask_blueprint = Blueprint('flow', __name__)
board_cache = simplekv.DeadSimpleKV(identifyhome.identify_home() + '/board-index.cache.json')
@flask_blueprint.route('/flow/getpostsbyboard/<board>') @flask_blueprint.route('/flow/getpostsbyboard/<board>')
def get_post_by_board(board): def get_post_by_board(board):
return Response('WIP') board_cache.refresh()
posts = board_cache.get(board)
if posts is None:
posts = ''
return Response(posts)

View File

@ -25,31 +25,36 @@ import logger, config, onionrblocks
from onionrutils import escapeansi, epoch, bytesconverter from onionrutils import escapeansi, epoch, bytesconverter
locale.setlocale(locale.LC_ALL, '') locale.setlocale(locale.LC_ALL, '')
from coredb import blockmetadb from coredb import blockmetadb
from utils import identifyhome, reconstructhash
import deadsimplekv as simplekv
sys.path.insert(0, os.path.dirname(os.path.realpath(__file__))) sys.path.insert(0, os.path.dirname(os.path.realpath(__file__)))
import flowapi # import after path insert import flowapi # import after path insert
flask_blueprint = flowapi.flask_blueprint flask_blueprint = flowapi.flask_blueprint
plugin_name = 'flow' plugin_name = 'flow'
PLUGIN_VERSION = '0.0.1' PLUGIN_VERSION = '0.0.1'
board_cache = simplekv.DeadSimpleKV(identifyhome.identify_home() + '/board-index.cache.json')
class OnionrFlow: class OnionrFlow:
def __init__(self): def __init__(self):
self.alreadyOutputed = [] self.alreadyOutputed = []
self.flowRunning = False self.flowRunning = False
self.channel = None self.channel = ""
return return
def start(self): def start(self):
logger.warn("Please note: everything said here is public, even if a random channel name is used.", terminal=True) logger.warn("Please note: everything said here is public, even if a random channel name is used.", terminal=True)
message = "" message = ""
self.flowRunning = True self.flowRunning = True
newThread = threading.Thread(target=self.showOutput, daemon=True)
newThread.start()
try: try:
self.channel = logger.readline("Enter a channel name or none for default:") self.channel = logger.readline("Enter a channel name or none for default:").strip()
except (KeyboardInterrupt, EOFError) as e: except (KeyboardInterrupt, EOFError) as e:
self.flowRunning = False self.flowRunning = False
newThread = threading.Thread(target=self.showOutput, daemon=True)
newThread.start()
while self.flowRunning: while self.flowRunning:
if self.channel == "":
self.channel = "global"
try: try:
message = logger.readline('\nInsert message into flow:').strip().replace('\n', '\\n').replace('\r', '\\r') message = logger.readline('\nInsert message into flow:').strip().replace('\n', '\\n').replace('\r', '\\r')
except EOFError: except EOFError:
@ -62,7 +67,7 @@ class OnionrFlow:
expireTime = epoch.get_epoch() + 43200 expireTime = epoch.get_epoch() + 43200
if len(message) > 0: if len(message) > 0:
logger.info('Inserting message as block...', terminal=True) logger.info('Inserting message as block...', terminal=True)
onionrblocks.insert(message, header='txt', expire=expireTime, meta={'ch': self.channel}) onionrblocks.insert(message, header='brd', expire=expireTime, meta={'ch': self.channel})
logger.info("Flow is exiting, goodbye", terminal=True) logger.info("Flow is exiting, goodbye", terminal=True)
return return
@ -72,7 +77,7 @@ class OnionrFlow:
time.sleep(1) time.sleep(1)
try: try:
while self.flowRunning: while self.flowRunning:
for block in blockmetadb.get_blocks_by_type('txt'): for block in blockmetadb.get_blocks_by_type('brd'):
if block in self.alreadyOutputed: if block in self.alreadyOutputed:
continue continue
block = Block(block) block = Block(block)
@ -105,3 +110,30 @@ def on_init(api, data = None):
api.commands.register('flow', flow.start) api.commands.register('flow', flow.start)
api.commands.register_help('flow', 'Open the flow messaging interface') api.commands.register_help('flow', 'Open the flow messaging interface')
return return
def on_processblocks(api, data=None):
b_hash = reconstructhash.deconstruct_hash(data['block'].hash) # Get the 0-truncated block hash
metadata = data['block'].bmetadata # Get the block metadata
# Validate the channel name is sane for caching
try:
ch = metadata['ch']
except KeyError:
ch = 'global'
ch_len = len(ch)
if len(metadata['ch']) == 0:
ch = 'global'
elif len(metadata['ch']) > 12:
return
existing_posts = board_cache.get(ch)
if existing_posts is None:
existing_posts = ''
else:
existing_posts += ','
check_list = existing_posts.split(',')
if len(check_list) > 30:
check_list.pop(0)
existing_posts = ','.join(check_list)
board_cache.put(ch, '%s%s' % (existing_posts, b_hash))
board_cache.flush()

View File

@ -4,6 +4,8 @@ var windowHeight = window.innerHeight;
webpassword = webpass webpassword = webpass
newPostForm = document.getElementById('addMsg') newPostForm = document.getElementById('addMsg')
firstLoad = true firstLoad = true
lastLoadedBoard = 'global'
function appendMessages(msg){ function appendMessages(msg){
var humanDate = new Date(0) var humanDate = new Date(0)
if (msg.length == 0){ if (msg.length == 0){
@ -53,14 +55,29 @@ function appendMessages(msg){
} }
function getBlocks(){ function getBlocks(){
var feed = document.getElementById("feed")
var ch = document.getElementById('feedIDInput').value
if (lastLoadedBoard !== ch){
while (feed.firstChild) {
feed.removeChild(feed.firstChild);
}
requested = [] // reset requested list
}
lastLoadedBoard = ch
if (document.getElementById('none') !== null){ if (document.getElementById('none') !== null){
document.getElementById('none').remove(); document.getElementById('none').remove();
} }
var feedText = httpGet('/getblocksbytype/txt') var feedText = httpGet('/flow/getpostsbyboard/' + ch)
var blockList = feedText.split(',').reverse() var blockList = feedText.split(',').reverse()
console.log(blockList)
for (i = 0; i < blockList.length; i++){ for (i = 0; i < blockList.length; i++){
while (blockList[i].length < 64) blockList[i] = "0" + blockList[i]
if (! requested.includes(blockList[i])){ if (! requested.includes(blockList[i])){
if (blockList[i].length == 0){
continue
}
bl = httpGet('/getblockdata/' + blockList[i]) bl = httpGet('/getblockdata/' + blockList[i])
appendMessages(bl) appendMessages(bl)
requested.push(blockList[i]) requested.push(blockList[i])
@ -75,7 +92,9 @@ document.getElementById('refreshFeed').onclick = function(){
newPostForm.onsubmit = function(){ newPostForm.onsubmit = function(){
var message = document.getElementById('newMsgText').value var message = document.getElementById('newMsgText').value
var postData = {'message': message, 'type': 'txt', 'encrypt': false} var channel = document.getElementById('feedIDInput').value
var meta = {'ch': channel}
var postData = {'message': message, 'type': 'txt', 'encrypt': false, 'meta': JSON.stringify(meta)}
postData = JSON.stringify(postData) postData = JSON.stringify(postData)
newPostForm.style.display = 'none' newPostForm.style.display = 'none'
fetch('/insertblock', { fetch('/insertblock', {

View File

@ -114,7 +114,7 @@
</div> </div>
<div class="content"> <div class="content">
<div id='feed'> <div id='feed'>
<span id='none'>None Yet :)</span> <span id='none'>None yet, try refreshing 😃</span>
<!--Message Items are appended here based on template--> <!--Message Items are appended here based on template-->
</div> </div>
</div> </div>