* Rewrite worker

5 files changed, 38 insertions, 20 deletions

diff --git a/db/migrate/20130225123010_create_accounts.rb b/db/migrate/20130225123010_create_accounts.rb
index 6856539..9e96020 100644
--- a/db/migrate/20130225123010_create_accounts.rb
+++ b/db/migrate/20130225123010_create_accounts.rb
@@ -1,10 +1,13 @@
 class CreateAccounts < ActiveRecord::Migration
   def change
     create_table :accounts do |t|
-      t.string :oauth_token
-      t.string :oauth_token_secret
+      t.integer :user_id, :limit => 8, :null => false
+      t.string :oauth_token, :null => false
+      t.string :oauth_token_secret, :null => false
 
       t.timestamps
     end
+
+    add_index :accounts, :user_id, :unique => true
   end
 end
diff --git a/db/migrate/20130226150329_create_tweets.rb b/db/migrate/20130226150329_create_tweets.rb
index 393b26e..3c7138c 100644
--- a/db/migrate/20130226150329_create_tweets.rb
+++ b/db/migrate/20130226150329_create_tweets.rb
@@ -1,13 +1,15 @@
 class CreateTweets < ActiveRecord::Migration
   def change
     create_table :tweets do |t|
-      t.text :text
+      t.text :text, :null => false
       t.text :source
-      t.references :user, :limit => 8
+      t.references :user, :limit => 8, :null => false
       t.datetime :tweeted_at
 
-      t.integer :favorites_count
-      t.integer :retweets_count
+      t.integer :favorites_count, :default => 0
+      t.integer :retweets_count, :default => 0
     end
+
+    add_index :tweets, :user_id
   end
 end
diff --git a/db/migrate/20130226150829_create_favorites.rb b/db/migrate/20130226150829_create_favorites.rb
index d8b34fb..c972b92 100644
--- a/db/migrate/20130226150829_create_favorites.rb
+++ b/db/migrate/20130226150829_create_favorites.rb
@@ -1,8 +1,11 @@
 class CreateFavorites < ActiveRecord::Migration
   def change
     create_table :favorites do |t|
-      t.references :tweet, :limit => 8
-      t.references :user, :limit => 8
+      t.references :tweet, :limit => 8, :null => false
+      t.references :user, :limit => 8, :null => false
     end
+
+    add_index :favorites, [:tweet_id, :user_id], :unique => true
+    add_index :favorites, :tweet_id
   end
 end
diff --git a/db/migrate/20130226151042_create_retweets.rb b/db/migrate/20130226151042_create_retweets.rb
index a2eb3cf..6de664e 100644
--- a/db/migrate/20130226151042_create_retweets.rb
+++ b/db/migrate/20130226151042_create_retweets.rb
@@ -1,8 +1,10 @@
 class CreateRetweets < ActiveRecord::Migration
   def change
     create_table :retweets do |t|
-      t.references :tweet, :limit => 8
-      t.references :user, :limit => 8
+      t.references :tweet, :limit => 8, :null => false
+      t.references :user, :limit => 8, :null => false
     end
+
+    add_index :retweets, :tweet_id
   end
 end
diff --git a/db/schema.rb b/db/schema.rb
index 72fb1e1..4ec571b 100644
--- a/db/schema.rb
+++ b/db/schema.rb
@@ -14,29 +14,37 @@
 ActiveRecord::Schema.define(version: 20130226151042) do
 
   create_table "accounts", force: true do |t|
-    t.string   "oauth_token"
-    t.string   "oauth_token_secret"
+    t.integer  "user_id",            limit: 8, null: false
+    t.string   "oauth_token",                  null: false
+    t.string   "oauth_token_secret",           null: false
     t.datetime "created_at"
     t.datetime "updated_at"
   end
 
+  add_index "accounts", ["user_id"], name: "index_accounts_on_user_id", unique: true
+
   create_table "favorites", force: true do |t|
-    t.integer "tweet_id", limit: 8
-    t.integer "user_id",  limit: 8
+    t.integer "tweet_id", limit: 8, null: false
+    t.integer "user_id",  limit: 8, null: false
   end
 
+  add_index "favorites", ["tweet_id", "user_id"], name: "index_favorites_on_tweet_id_and_user_id", unique: true
+  add_index "favorites", ["tweet_id"], name: "index_favorites_on_tweet_id"
+
   create_table "retweets", force: true do |t|
-    t.integer "tweet_id", limit: 8
-    t.integer "user_id",  limit: 8
+    t.integer "tweet_id", limit: 8, null: false
+    t.integer "user_id",  limit: 8, null: false
   end
 
+  add_index "retweets", ["tweet_id"], name: "index_retweets_on_tweet_id"
+
   create_table "tweets", force: true do |t|
-    t.text     "text"
+    t.text     "text",                                  null: false
     t.text     "source"
-    t.integer  "user_id",         limit: 8
+    t.integer  "user_id",         limit: 8,             null: false
     t.datetime "tweeted_at"
-    t.integer  "favorites_count"
-    t.integer  "retweets_count"
+    t.integer  "favorites_count",           default: 0
+    t.integer  "retweets_count",            default: 0
   end
 
   create_table "users", force: true do |t|