mirror of
https://github.com/discourse/discourse.git
synced 2024-11-26 22:23:45 +08:00
30990006a9
This reduces chances of errors where consumers of strings mutate inputs and reduces memory usage of the app. Test suite passes now, but there may be some stuff left, so we will run a few sites on a branch prior to merging
97 lines
2.3 KiB
Ruby
97 lines
2.3 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
require_relative './quandora_question.rb'
|
|
require File.expand_path(File.dirname(__FILE__) + "/../base.rb")
|
|
|
|
class ImportScripts::Quandora < ImportScripts::Base
|
|
|
|
JSON_FILES_DIR = "output"
|
|
|
|
def initialize
|
|
super
|
|
@system_user = Discourse.system_user
|
|
@questions = []
|
|
Dir.foreach(JSON_FILES_DIR) do |filename|
|
|
next if filename == ('.') || filename == ('..')
|
|
question = File.read JSON_FILES_DIR + '/' + filename
|
|
@questions << question
|
|
end
|
|
end
|
|
|
|
def execute
|
|
puts "", "Importing from Quandora..."
|
|
import_questions @questions
|
|
EmailToken.delete_all
|
|
puts "", "Done"
|
|
end
|
|
|
|
def import_questions(questions)
|
|
topics = 0
|
|
total = questions.size
|
|
|
|
questions.each do |question|
|
|
q = QuandoraQuestion.new question
|
|
import_users q.users
|
|
created_topic = import_topic q.topic
|
|
if created_topic
|
|
import_posts q.replies, created_topic.topic_id
|
|
end
|
|
topics += 1
|
|
print_status topics, total
|
|
end
|
|
puts "", "Imported #{topics} topics."
|
|
end
|
|
|
|
def import_users(users)
|
|
users.each do |user|
|
|
create_user user, user[:id]
|
|
end
|
|
end
|
|
|
|
def import_topic(topic)
|
|
post = nil
|
|
if post_id = post_id_from_imported_post_id(topic[:id])
|
|
post = Post.find(post_id) # already imported this topic
|
|
else
|
|
topic[:user_id] = user_id_from_imported_user_id(topic[:author_id]) || -1
|
|
topic[:category] = 'quandora-import'
|
|
|
|
post = create_post(topic, topic[:id])
|
|
|
|
unless post.is_a?(Post)
|
|
puts "Error creating topic #{topic[:id]}. Skipping."
|
|
puts post.inspect
|
|
end
|
|
end
|
|
|
|
post
|
|
end
|
|
|
|
def import_posts(posts, topic_id)
|
|
posts.each do |post|
|
|
import_post post, topic_id
|
|
end
|
|
end
|
|
|
|
def import_post(post, topic_id)
|
|
if post_id_from_imported_post_id(post[:id])
|
|
return # already imported
|
|
end
|
|
post[:topic_id] = topic_id
|
|
post[:user_id] = user_id_from_imported_user_id(post[:author_id]) || -1
|
|
new_post = create_post post, post[:id]
|
|
unless new_post.is_a?(Post)
|
|
puts "Error creating post #{post[:id]}. Skipping."
|
|
puts new_post.inspect
|
|
end
|
|
end
|
|
|
|
def file_full_path(relpath)
|
|
File.join JSON_FILES_DIR, relpath.split("?").first
|
|
end
|
|
end
|
|
|
|
if __FILE__ == $0
|
|
ImportScripts::Quandora.new.perform
|
|
end
|