From 2e5c37a97c7495395e17b19f7d2330bb0a7a8a92 Mon Sep 17 00:00:00 2001 From: Christine Dodrill Date: Thu, 11 Feb 2016 13:34:11 -0800 Subject: [PATCH] lookup tweets in parallel --- src/twtxt.nim | 10 ---------- src/worker.nim | 10 ++++++++++ 2 files changed, 10 insertions(+), 10 deletions(-) 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"