Deathangel908 / pychat

			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

		if res_imgs:

			Image.objects.bulk_create(res_imgs)

		if fetched_messages:

			for m in fetched_messages:

				res_imgs.append(m)

	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]