Deathangel908 / pychat

		room.save()

		message = self.unsubscribe_direct_message(room_id)

		self.publish(message, room_id, True)

	def edit_message(self, data):

		js_id = data[VarNames.JS_MESSAGE_ID]

		message = do_db(Message.objects.get, id=data[VarNames.MESSAGE_ID])

		validate_edit_message(self.user_id, message)

		message.content = data[VarNames.CONTENT]

		MessageHistory(message=message, content=message.content, giphy=message.giphy).save()

		message.edited_times += 1

		giphy_match = self.isGiphy(data[VarNames.CONTENT])

		if message.content is None:

			Message.objects.filter(id=data[VarNames.MESSAGE_ID]).update(deleted=True, edited_times=message.edited_times)

			self.publish(self.create_send_message(message, Actions.DELETE_MESSAGE, None, js_id), message.room_id)

		elif giphy_match is not None:

			self.edit_message_giphy(giphy_match, message, js_id)

		else:

			self.edit_message_edit(data, message, js_id)

	def edit_message_giphy(self, giphy_match, message, js_id):

			return True

		self.sync_redis.hset(connection_id, self.id, WebRtcRedisStates.OFFERED)

	def offer_webrtc_connection(self, in_message):

		room_id = in_message[VarNames.CHANNEL]

		content = in_message.get(VarNames.CONTENT)

		qued_id = in_message[VarNames.WEBRTC_QUED_ID]

		connection_id = id_generator(RedisPrefix.CONNECTION_ID_LENGTH)

		# use list because sets dont have 1st element which is offerer

		self.async_redis_publisher.hset(WEBRTC_CONNECTION, connection_id, self.id)

		self.async_redis_publisher.hset(connection_id, self.id, WebRtcRedisStates.READY)

		opponents_message = self.offer_webrtc(content, connection_id, room_id, in_message[VarNames.EVENT])

		self_message = self.set_connection_id(qued_id, connection_id)

		self.ws_write(self_message)

		self.logger.info('!! Offering a webrtc, connection_id %s', connection_id)

		self.publish(opponents_message, room_id, True)

	def retry_file_connection(self, in_message):