mirror of
https://github.com/discourse/discourse.git
synced 2024-11-24 20:26:35 +08:00
27 lines
636 B
Ruby
27 lines
636 B
Ruby
|
module Import
|
||
|
|
|
||
|
|
class JsonDecoder
|
||
|
|
|
||
|
|
def initialize(input_filename)
|
||
|
|
@input_filename = input_filename
|
||
|
|
end
|
||
|
|
|
||
|
|
|
||
|
|
def input_stream
|
||
|
|
@input_stream ||= begin
|
||
|
|
File.open( @input_filename, 'rb' )
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
def start( opts )
|
||
|
|
@json = JSON.parse(input_stream.read)
|
||
|
|
opts[:callbacks][:schema_info].call( source: @json['schema']['source'], version: @json['schema']['version'], table_count: @json.keys.size - 1)
|
||
|
|
@json.each do |key, val|
|
||
|
|
next if key == 'schema'
|
||
|
|
opts[:callbacks][:table_data].call( key, val['fields'], val['rows'], val['row_count'] )
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
end
|
||
|
|
|
||
|
|
end
|