cadey
/
twtxtlist
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

lookup tweets in parallel

This commit is contained in:
Christine Dodrill 2016-02-11 13:34:11 -08:00
parent ac6dd0f0e3
commit 2e5c37a97c
2 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/twtxt.nim
View File

@ -69,13 +69,3 @@ proc updateTweetsByUser*(db: DBConn, username, url: string) {. gcsafe .} =
except: discard except: discard
except: except:
echo getCurrentExceptionMsg() echo getCurrentExceptionMsg()
proc updateTweetsOnce*() {. gcsafe .} =
var db = open("./data/twtxt.db", nil, nil, nil)
var users = db.getAllRows sql"select * from users where username != 'twtxtlist'"
for user in users.items():
echo "updating " & $user
db.updateTweetsByUser(user[1], user[2])

10
src/worker.nim
View File

@ -1,5 +1,15 @@
import db_sqlite, os, streams, threadpool, twtxt import db_sqlite, os, streams, threadpool, twtxt
proc updateTweetsOnce() {. gcsafe .} =
var db = open("./data/twtxt.db", nil, nil, nil)
var users = db.getAllRows sql"select * from users where username != 'twtxtlist'"
for user in users.items():
echo "updating " & $user
spawn db.updateTweetsByUser(user[1], user[2])
proc updateSystemUser() = proc updateSystemUser() =
let let
fname = "public" / "twtxt.txt" fname = "public" / "twtxt.txt"