Code Duplication    Length = 12-15 lines in 2 locations

chat/tornado/message_handler.py 2 locations

@@ 361-375 (lines=15) @@
358
			)
359
			self.publish(self.create_send_message(message, Actions.DELETE_MESSAGE, None, js_id), message.room_id)
360
		elif giphy_match is not None:
361
			self.edit_message_giphy(giphy_match, message, js_id)
362
		else:
363
			self.edit_message_edit(data, message, js_id)
364
365
	def edit_message_giphy(self, giphy_match, message, js_id):
366
		def edit_glyphy(message, giphy):
367
			do_db(Message.objects.filter(id=message.id).update, content=message.content, symbol=message.symbol, giphy=giphy,
368
					edited_times=message.edited_times)
369
			message.giphy = giphy
370
			self.publish(self.create_send_message(message, Actions.EDIT_MESSAGE, None, js_id), message.room_id)
371
372
		self.search_giphy(message, giphy_match, edit_glyphy)
373
374
	def edit_message_edit(self, data, message, js_id):
375
		action = Actions.EDIT_MESSAGE
376
		message.giphy = None
377
		files = UploadedFile.objects.filter(id__in=data.get(VarNames.FILES), user_id=self.user_id)
378
		if files:
@@ 459-470 (lines=12) @@
456
457
	def retry_file_connection(self, in_message):
458
		connection_id = in_message[VarNames.CONNECTION_ID]
459
		opponent_ws_id = in_message[VarNames.WEBRTC_OPPONENT_ID]
460
		sender_ws_id = self.sync_redis.shget(WEBRTC_CONNECTION, connection_id)
461
		receiver_ws_status = self.sync_redis.shget(connection_id, opponent_ws_id)
462
		if receiver_ws_status == WebRtcRedisStates.READY and self.id == sender_ws_id:
463
			self.publish(self.retry_file(connection_id), opponent_ws_id)
464
		else:
465
			raise ValidationError("Invalid channel status.")
466
467
	def reply_file_connection(self, in_message):
468
		connection_id = in_message[VarNames.CONNECTION_ID]
469
		sender_ws_id = self.sync_redis.shget(WEBRTC_CONNECTION, connection_id)
470
		sender_ws_status = self.sync_redis.shget(connection_id, sender_ws_id)
471
		self_ws_status = self.sync_redis.shget(connection_id, self.id)
472
		if sender_ws_status == WebRtcRedisStates.READY and self_ws_status == WebRtcRedisStates.OFFERED:
473
			self.async_redis_publisher.hset(connection_id, self.id, WebRtcRedisStates.RESPONDED)