diff options
Diffstat (limited to 'lib/mongo.py')
| -rw-r--r-- | lib/mongo.py | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/lib/mongo.py b/lib/mongo.py index e429eea..2e971ed 100644 --- a/lib/mongo.py +++ b/lib/mongo.py @@ -56,17 +56,17 @@ def get_thread(table, start, end): def get_thread_length(table, thread_id): db = connection[table] - db.mails.create_index('Thread-ID') - db.mails.ensure_index('Thread-ID') - return db.mails.find({'Thread-ID': thread_id}).count() + db.mails.create_index('ThreadID') + db.mails.ensure_index('ThreadID') + return db.mails.find({'ThreadID': thread_id}).count() def get_thread_participants(table, thread_id): db = connection[table] - db.mails.create_index('Thread-ID') - db.mails.ensure_index('Thread-ID') + db.mails.create_index('ThreadID') + db.mails.ensure_index('ThreadID') authors = set() - for mail in db.mails.find({'Thread-ID': thread_id}): + for mail in db.mails.find({'ThreadID': thread_id}): authors.add(mail['From']) return len(authors) |