remove unused salesforce streaming code

openstax · Jan 23, 2024 · a6431fb · a6431fb
1 parent 790a898
commit a6431fb
Show file tree

Hide file tree

Showing 13 changed files with 11 additions and 365 deletions.
diff --git a/app/models/push_topic.rb b/app/models/push_topic.rb
diff --git a/app/models/salesforce_streaming_replay.rb b/app/models/salesforce_streaming_replay.rb
diff --git a/app/services/contact_parser.rb b/app/services/contact_parser.rb
diff --git a/app/services/lead_parser.rb b/app/services/lead_parser.rb
diff --git a/app/services/salesforce_contact_replay_handler.rb b/app/services/salesforce_contact_replay_handler.rb
diff --git a/app/services/salesforce_subscriber.rb b/app/services/salesforce_subscriber.rb
diff --git a/db/migrate/20240123173834_drop_streaming_tables.rb b/db/migrate/20240123173834_drop_streaming_tables.rb
@@ -0,0 +1,10 @@
+class DropStreamingTables < ActiveRecord::Migration[5.2]
+  def up
+    drop_table :salesforce_streaming_replays
+    drop_table :push_topics
+  end
+
+  def down
+    raise ActiveRecord::IrreversibleMigration
+  end
+end
diff --git a/db/schema.rb b/db/schema.rb
@@ -10,7 +10,7 @@
 #
 # It's strongly recommended that you check this file into your version control system.
 
-ActiveRecord::Schema.define(version: 2023_10_04_175741) do
+ActiveRecord::Schema.define(version: 2024_01_23_173834) do
 
   # These are extensions that must be enabled in order to support this database
   enable_extension "citext"
@@ -348,19 +348,6 @@
     t.index ["contact_info_kind"], name: "index_pre_auth_states_on_contact_info_kind"
   end
 
-  create_table "push_topics", force: :cascade do |t|
-    t.string "topic_salesforce_id"
-    t.string "topic_name"
-  end
-
-  create_table "salesforce_streaming_replays", force: :cascade do |t|
-    t.bigint "push_topics_id"
-    t.datetime "created_at", null: false
-    t.datetime "updated_at", null: false
-    t.integer "replay_id"
-    t.index ["push_topics_id"], name: "index_salesforce_streaming_replays_on_push_topics_id"
-  end
-
   create_table "schools", force: :cascade do |t|
     t.string "salesforce_id", null: false
     t.string "name", null: false
@@ -502,7 +489,6 @@
   add_foreign_key "external_ids", "users"
   add_foreign_key "oauth_access_grants", "oauth_applications", column: "application_id"
   add_foreign_key "oauth_access_tokens", "oauth_applications", column: "application_id"
-  add_foreign_key "salesforce_streaming_replays", "push_topics", column: "push_topics_id"
   add_foreign_key "users", "oauth_applications", column: "source_application_id"
   add_foreign_key "users", "schools"
 end
diff --git a/lib/tasks/streaming.rake b/lib/tasks/streaming.rake
diff --git a/spec/factories/push_topic.rb b/spec/factories/push_topic.rb
diff --git a/spec/factories/salesforce_streaming_replays.rb b/spec/factories/salesforce_streaming_replays.rb
diff --git a/spec/models/push_topic.rb b/spec/models/push_topic.rb