photoIso.rb

# encoding: utf-8
require './plurk.rb'
require './setting.rb'
require './log.rb'
require 'time'
require 'net/http'
require 'open-uri'
require 'exifr'

class PhotoIso
	REGEXP_CHANNEL = /^CometChannel\.scriptCallback\((.*)\);/
	attr_reader :setting
	
	def initialize(m)
		puts m + " loaded..."
		@setting = Setting.new
		@plurkApi = Plurk.new(@setting.api_key, @setting.api_secret)
		@plurkApi.authorize(@setting.token_key, @setting.token_secret)
		@me = @plurkApi.post '/APP/Users/me'
		puts "My id is #{@me["id"]}"
	end
	public
	
	def listenChannel
			
		getChannel while @channelUri.nil?
		getChannel if @channelOffset == -3
		params = { :channel => @channelName, :offset => @channelOffset }
		params = params.map { |k,v| "#{k}=#{v}" }.join('&')
		uri = URI.parse(@channelUri + "?" + params)
		http = Net::HTTP.new(uri.host, uri.port)
		http.read_timeout = 170
		retryGetting = 0
		begin
			res = http.start do |h|
				h.get(uri.path+"?"+params)
			end
		rescue
			retryGetting += 1
			sleep 3
			if retryGetting == 5
				getChannel
				return false
			end
			retry
		end
		res = REGEXP_CHANNEL.match res.body
		json = JSON.parse res[1]

		readed = []
		@channelOffset = json["new_offset"].to_i
		return if json["data"].nil?

		json["data"].each do |plurk|
			case plurk["type"]
			when "new_response"
			when "new_plurk"
				responseNewPlurk plurk
			when "friendship_request"
				p "friend request"
			end
		end
	end

	def addPlurk(content, options = {})
		options = { qualifier: ':', lang: 'tr_ch' }.merge options
		begin
			json = @plurkApi.post '/APP/Timeline/plurkAdd', options.merge(content: content)
			log %(#{Time.now.to_s} [EVENT] add Plurk: #{content})
		rescue
			str = %(#{Time.now.to_s} [ERROR] Adding plurk has error: #{$!.to_s})
			if json
				str << "(#{json["error_text"]})" if json.key? "error_text"
			end
			log str
			sleep 120
			retry
		end
		return json
	end

	def addPrivatePlurk(content, user_id, options = {})
		options = { qualifier: ':', lang: 'tr_ch' }.merge options
		begin
			json = @plurkApi.post '/APP/Timeline/plurkAdd', options.merge(content: content, limited_to: [[user_id]])
			log %(#{Time.now.to_s} [EVENT] add PrivatePlurk: #{content})
		rescue
			str = %(#{Time.now.to_s} [ERROR] Adding private plurk has error: #{$!.to_s})
			if json
				str << "(#{json["error_text"]})" if json.key? "error_text"
			end
			log str
			sleep 120
			retry
		end
	end

	def responsePlurk(plurk_id, content, options = {})
		
		if content != ""
		
			options = { qualifier: ':', lang: 'tr_ch' }.merge options
			begin
				log %(#{Time.now.to_s} [EVENT] Responsing plurk: #{content})
				res = @plurkApi.post '/APP/Responses/responseAdd', options.merge(plurk_id: plurk_id, content: content)
				
				log %(#{Time.now.to_s} [EVENT] Responsing plurk response: #{res})
			rescue
				log %(#{Time.now.to_s} [ERROR] Responsing plurk has error: #{$!.to_s})
			end
		end
	end

	def checkUnreadPlurk
		json = @plurkApi.post '/APP/Timeline/getUnreadPlurks', limit: 20
		return if json["plurks"].nil?

		json["plurks"].each do |plurk|
			responseNewPlurk plurk
		end
	end
	
	def addAllAsFriends
		 json = @plurkApi.post '/APP/Alerts/addAllAsFriends'
	end
	
	def getUnreadPlurk
		begin 
			json = @plurkApi.post '/APP/Timeline/getUnreadPlurks'
			log %(#{Time.now.to_s} [EVENT] get UnreadPlurk: #{json})
		rescue
			log %(#{Time.now.to_s} [ERROR] Getting unread plurks has error: #{$!.to_s})
			sleep 5
			retry
		end

		return json
	end

	private

	def responsed?(plurk_id)
		begin
			json = @plurkApi.post '/APP/Responses/get', plurk_id: plurk_id
		rescue
			log %(#{Time.now.to_s} [ERROR] Getting response has error: #{$!.to_s})
			sleep 5
			retry
		end
		json["responses"].each do |res|
			return false if res["user_id"] == @me["id"] 
		end
		true
	end

	def responseNewPlurk(plurk)
		return unless responsed? plurk["plurk_id"]
		resp = []
		
		case plurk["content_raw"]
		when /http[s]*:\/\/emos.plurk.com[\S]*.((jpg)|(jpeg))/
			imageUrl = $&.to_s
			log %(#{Time.now.to_s} [EVENT] New image: #{imageUrl} form #{plurk["plurk_id"].to_s})
			log %(\tBut it is Emoticons)
			return
		when /http[s]*:\/\/[\S]*.((jpg)|(jpeg))/
			imageUrl = $&.to_s
		
			log %(#{Time.now.to_s} [EVENT] New image: #{imageUrl} form #{plurk["plurk_id"].to_s})
			
			#load the image file
			begin
				open('image.jpg', 'wb') do |file|
					if imageUrl =~ /https:\/\/[\S]*/
						file << open(imageUrl,{ssl_verify_mode: OpenSSL::SSL::VERIFY_NONE}).read
					else
						file << open(imageUrl,).read
					end
				end
				log %(#{Time.now.to_s} [EVENT] Load image: #{imageUrl})
			rescue
				log %(#{Time.now.to_s} [ERROR] Load image #{imageUrl} has error: #{$!.to_s})
				return
			end
			
			#read the EXIF info and put it in the response string
			readEXIF =~ /([\S\s]+)##([\S\s]*)|(你的照片沒有EXIF資訊歐 OAO[\S\s]*)/
			res1 = $1
			res2 = $2
			res3 = $3
		
			if res1 != nil
				resp << res1 
				p resp
				responsePlurk(plurk["plurk_id"], resp * " ")
			end
			if res2 != nil
				resp = []
				resp << res2
                                p resp
				responsePlurk(plurk["plurk_id"], resp * " ")

			end
			if res3 != nil
				resp = []
				resp << res3
				p resp
                                responsePlurk(plurk["plurk_id"], resp * " ")				
			end
			
		end
		return if resp.empty?
		#responsePlurk(plurk["plurk_id"], resp * " ")
		@plurkApi.post '/APP/Timeline/mutePlurks', ids: [[plurk["plurk_id"]]]
	end

	def getChannel
		begin
			resp = @plurkApi.post("/APP/Realtime/getUserChannel")
		rescue Timeout::Error
			sleep 2 # let it take a rest
			retry
		end
		if resp["comet_server"].nil?
			log %(#{Time.now.to_s} [ERROR] Failed to get channel.)
			return false
		end
		@channelUri = resp["comet_server"]
		@channelName = resp["channel_name"]
		@channelOffset = -1
		
		log %(#{Time.now.to_s} [EVENT] Get channel uri: #{@channelUri})
		log %(#{Time.now.to_s} [EVENT] Get channel name: #{@channelName})
		return true
	end
	
	def readEXIF
		begin 
			@setting.read
			s = ""
			a = EXIFR::JPEG.new('./image.jpg')
			if a.exif?
				if @setting.time == "true"
					s += "拍攝日期：#{a.date_time.to_s}\n" unless a.date_time.nil?
				end
				if @setting.size == "true"
					s += "照片大小：#{a.width} * #{a.height}\n" unless a.width.nil? or a.height.nil?
				end
				if @setting.exposure_time == "true"
                                        s += "快門時間：#{( a.exif.exposure_time.to_r.rationalize(10**-8))}\n" unless a.exif.exposure_time.nil?
                                end
				if @setting.f_number == "true"
					s += "光圈大小：F #{a.exif.f_number.to_s}\n" unless a.exif.f_number.nil?
				end
				if @setting.focal_length == "true"
					s += "焦距：#{a.exif.focal_length.to_f.to_s}mm\n" unless a.exif.focal_length.nil? 
				end
				
				if @setting.ISO == "true"
					s += "ISO值：#{a.exif.iso_speed_ratings.to_s}\n" unless a.exif.iso_speed_ratings.nil?
				end
				if @setting.white_balance == "true"
					s += "白平衡：#{a.exif.white_balance.to_s}\n" unless a.exif.white_balance.nil?
				end
				if @setting.model == "true"
					s += "設備：" unless a.exif.make.nil? and a.exif.model.nil?
					s += "#{a.exif.make.to_s} " unless a.exif.make.nil?
					s += "#{a.exif.model.to_s}" unless a.exif.model.nil?
				end

				#s += "##"
				if @setting.GPS == "true"
                                        s += "拍攝地點： " unless a.gps_longitude.nil? and a.gps_latitude.nil?
                                        s += "#{a.gps_longitude_ref.to_s} #{a.gps_longitude.to_f.round(4)} " unless a.gps_longitude.nil?
                                        s += "#{a.gps_latitude_ref.to_s} #{a.gps_latitude.to_f.round(4)} \n" unless a.gps_latitude.nil?
                                        #s += "https://www.google.com/maps/place/#{a.gps_longitude_ref.to_s}#{a.gps_longitude.to_f}+#{a.gps_latitude_ref.to_s}#{a.gps_latitude.to_f} \n" unless a.gps_longitude.nil? and a.gps_latitude.nil?
                                        s += "海拔#{a.gps_altitude.to_f.round(3)}公尺\n" unless a.gps_altitude.nil?
                                end
				s += "##"
				
				if @setting.GPS == "true"
					s += "https://www.google.com/maps/place/#{a.gps_longitude_ref.to_s}#{a.gps_longitude.to_f}+#{a.gps_latitude_ref.to_s}#{a.gps_latitude.to_f} \n" unless a.gps_longitude.nil? and a.gps_latitude.nil?
				end
			else
				if @setting.size == "true"
					s += "你的照片沒有EXIF資訊歐 OAO\n"
					s += "照片大小：#{a.width} * #{a.height}\n" unless a.width.nil? or a.height.nil?
				end
			end	
			
			return s
		rescue
			log %(#{Time.now.to_s} [ERROR] Make response string has error: #{$!.to_s})
			s = "喔哦 出了一些問題"
			return s
		end	
	end
end