diff --git a/src/twtxt.nim b/src/twtxt.nim index ab065bf..a9a78dc 100644 --- a/src/twtxt.nim +++ b/src/twtxt.nim @@ -69,13 +69,3 @@ proc updateTweetsByUser*(db: DBConn, username, url: string) {. gcsafe .} = except: discard except: 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]) diff --git a/src/worker.nim b/src/worker.nim index 0ba62e8..2efcbfd 100644 --- a/src/worker.nim +++ b/src/worker.nim @@ -1,5 +1,15 @@ 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() = let fname = "public" / "twtxt.txt"