Refs #6133; Exports naive implementation

3 files changed, 120 insertions, 4 deletions

diff --git a/db/migrate/20180306152953_update_imports_names.rb b/db/migrate/20180306152953_update_imports_names.rb
index 086d5ce5a..42129a580 100644
--- a/db/migrate/20180306152953_update_imports_names.rb
+++ b/db/migrate/20180306152953_update_imports_names.rb
@@ -1,8 +1,13 @@
 class UpdateImportsNames < ActiveRecord::Migration
   def change
     Import::Base.all.pluck(:type).uniq.each do |type|
-      next if type =~ /^Imports/
+      next if type =~ /^Import/
       Import::Base.where(type: type).update_all type: "Import::#{type.gsub 'Import', ''}"
     end
+
+    Import::Base.all.pluck(:parent_type).uniq.each do |type|
+      next if type =~ /^Import/
+      Import::Base.where(parent_type: type).update_all parent_type: "Import::#{type.gsub 'Import', ''}"
+    end
   end
 end
diff --git a/db/migrate/20180307071448_create_new_exports.rb b/db/migrate/20180307071448_create_new_exports.rb
new file mode 100644
index 000000000..74921d108
--- /dev/null
+++ b/db/migrate/20180307071448_create_new_exports.rb
@@ -0,0 +1,56 @@
+class CreateNewExports < ActiveRecord::Migration
+  def change
+    create_table :exports do |t|
+      t.string   "status"
+      t.string   "current_step_id"
+      t.float    "current_step_progress"
+      t.integer  "workbench_id",          limit: 8
+      t.integer  "referential_id",        limit: 8
+      t.string   "name"
+      t.datetime "created_at"
+      t.datetime "updated_at"
+      t.string   "file"
+      t.datetime "started_at"
+      t.datetime "ended_at"
+      t.string   "token_upload"
+      t.string   "type"
+      t.integer  "parent_id",             limit: 8
+      t.string   "parent_type"
+      t.datetime "notified_parent_at"
+      t.integer  "current_step",          default: 0
+      t.integer  "total_steps",           default: 0
+      t.string   "creator"
+    end
+
+    add_index "exports", ["referential_id"], name: "index_exports_on_referential_id", using: :btree
+    add_index "exports", ["workbench_id"], name: "index_exports_on_workbench_id", using: :btree
+
+    create_table "export_messages", id: :bigserial, force: :cascade do |t|
+      t.string   "criticity"
+      t.string   "message_key"
+      t.hstore   "message_attributes"
+      t.integer  "export_id",           limit: 8
+      t.integer  "resource_id",         limit: 8
+      t.datetime "created_at"
+      t.datetime "updated_at"
+      t.hstore   "resource_attributes"
+    end
+
+    add_index "export_messages", ["export_id"], name: "index_export_messages_on_export_id", using: :btree
+    add_index "export_messages", ["resource_id"], name: "index_export_messages_on_resource_id", using: :btree
+
+    create_table "export_resources", id: :bigserial, force: :cascade do |t|
+      t.integer  "export_id",     limit: 8
+      t.string   "status"
+      t.datetime "created_at"
+      t.datetime "updated_at"
+      t.string   "resource_type"
+      t.string   "reference"
+      t.string   "name"
+      t.hstore   "metrics"
+    end
+
+    add_index "export_resources", ["export_id"], name: "index_export_resources_on_export_id", using: :btree
+
+  end
+end
diff --git a/db/schema.rb b/db/schema.rb
index 53dbaceb2..094d2cb02 100644
--- a/db/schema.rb
+++ b/db/schema.rb
@@ -11,13 +11,14 @@
 #
 # It's strongly recommended that you check this file into your version control system.
 
-ActiveRecord::Schema.define(version: 20180306152953) do
+ActiveRecord::Schema.define(version: 20180307071448) do
 
   # These are extensions that must be enabled in order to support this database
   enable_extension "plpgsql"
-  enable_extension "postgis"
   enable_extension "hstore"
+  enable_extension "postgis"
   enable_extension "unaccent"
+  enable_extension "objectid"
 
   create_table "access_links", id: :bigserial, force: :cascade do |t|
     t.integer  "access_point_id",                        limit: 8
@@ -90,9 +91,9 @@ ActiveRecord::Schema.define(version: 20180306152953) do
     t.integer   "organisation_id", limit: 8
     t.datetime  "created_at"
     t.datetime  "updated_at"
-    t.integer   "workgroup_id",    limit: 8
     t.integer   "int_day_types"
     t.date      "excluded_dates",                            array: true
+    t.integer   "workgroup_id",    limit: 8
   end
 
   add_index "calendars", ["organisation_id"], name: "index_calendars_on_organisation_id", using: :btree
@@ -119,6 +120,7 @@ ActiveRecord::Schema.define(version: 20180306152953) do
     t.datetime "updated_at"
     t.date     "end_date"
     t.string   "date_type"
+    t.string   "mode"
   end
 
   add_index "clean_ups", ["referential_id"], name: "index_clean_ups_on_referential_id", using: :btree
@@ -299,6 +301,58 @@ ActiveRecord::Schema.define(version: 20180306152953) do
 
   add_index "custom_fields", ["resource_type"], name: "index_custom_fields_on_resource_type", using: :btree
 
+  create_table "export_messages", id: :bigserial, force: :cascade do |t|
+    t.string   "criticity"
+    t.string   "message_key"
+    t.hstore   "message_attributes"
+    t.integer  "export_id",           limit: 8
+    t.integer  "resource_id",         limit: 8
+    t.datetime "created_at"
+    t.datetime "updated_at"
+    t.hstore   "resource_attributes"
+  end
+
+  add_index "export_messages", ["export_id"], name: "index_export_messages_on_export_id", using: :btree
+  add_index "export_messages", ["resource_id"], name: "index_export_messages_on_resource_id", using: :btree
+
+  create_table "export_resources", id: :bigserial, force: :cascade do |t|
+    t.integer  "export_id",     limit: 8
+    t.string   "status"
+    t.datetime "created_at"
+    t.datetime "updated_at"
+    t.string   "resource_type"
+    t.string   "reference"
+    t.string   "name"
+    t.hstore   "metrics"
+  end
+
+  add_index "export_resources", ["export_id"], name: "index_export_resources_on_export_id", using: :btree
+
+  create_table "exports", id: :bigserial, force: :cascade do |t|
+    t.string   "status"
+    t.string   "current_step_id"
+    t.float    "current_step_progress"
+    t.integer  "workbench_id",          limit: 8
+    t.integer  "referential_id",        limit: 8
+    t.string   "name"
+    t.datetime "created_at"
+    t.datetime "updated_at"
+    t.string   "file"
+    t.datetime "started_at"
+    t.datetime "ended_at"
+    t.string   "token_upload"
+    t.string   "type"
+    t.integer  "parent_id",             limit: 8
+    t.string   "parent_type"
+    t.datetime "notified_parent_at"
+    t.integer  "current_step",                    default: 0
+    t.integer  "total_steps",                     default: 0
+    t.string   "creator"
+  end
+
+  add_index "exports", ["referential_id"], name: "index_exports_on_referential_id", using: :btree
+  add_index "exports", ["workbench_id"], name: "index_exports_on_workbench_id", using: :btree
+
   create_table "facilities", id: :bigserial, force: :cascade do |t|
     t.integer  "stop_area_id",       limit: 8
     t.integer  "line_id",            limit: 8
@@ -753,6 +807,7 @@ ActiveRecord::Schema.define(version: 20180306152953) do
     t.datetime "created_at"
     t.datetime "updated_at"
     t.string   "objectid_format"
+    t.string   "registration_number_format"
   end
 
   create_table "stop_areas", id: :bigserial, force: :cascade do |t|