Deathangel908 / pychat

		connection_id = in_message[VarNames.CONNECTION_ID]

		self_status = self.sync_redis.shget(connection_id, self.id)

		if self_status == WebRtcRedisStates.RESPONDED:

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

			channel_status = self.sync_redis.shgetall(connection_id)

			del channel_status[self.id]

			message = {

				VarNames.EVENT: Actions.ACCEPT_CALL,

				VarNames.USER_ID: self.user_id,

				VarNames.CONNECTION_ID: connection_id,

				VarNames.WEBRTC_OPPONENT_ID: self.id,

				VarNames.HANDLER_NAME: HandlerNames.WEBRTC_TRANSFER,

			}

			for key in channel_status:

				if channel_status[key] != WebRtcRedisStates.CLOSED:

					self.publish(message, key)

		else:

			raise ValidationError("Invalid channel status")

	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.do_db(message_db.save)

		db_images = self.save_images(raw_imgs, message_db.id)

		prepared_message = self.create_send_message(

			message_db,

			Actions.PRINT_MESSAGE,

			self.prepare_img(db_images, message_db.id)

		)

		self.publish(prepared_message, channel)

	def close_file_connection(self, in_message):

		connection_id = in_message[VarNames.CONNECTION_ID]

		self_channel_status = self.sync_redis.shget(connection_id, self.id)

		if not self_channel_status:

			raise Exception("Access Denied")

		if self_channel_status != WebRtcRedisStates.CLOSED:

			sender_id = self.sync_redis.shget(WEBRTC_CONNECTION, connection_id)

			if sender_id == self.id:

				self.close_file_sender(connection_id)

			else:

				self.close_file_receiver(connection_id, in_message, sender_id)

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

	def close_call_connection(self, in_message):

		connection_id = in_message[VarNames.CONNECTION_ID]