Deathangel908 / pychat

		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 reply_call_connection(self, in_message):

		self.send_call_answer(in_message, WebRtcRedisStates.RESPONDED, Actions.REPLY_CALL_CONNECTION)

	def send_call_answer(self, in_message, status_set, reply_action):

		connection_id = in_message[VarNames.CONNECTION_ID]

		conn_users = self.sync_redis.shgetall(connection_id)

		if conn_users[self.id] == WebRtcRedisStates.OFFERED:

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

			del conn_users[self.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]

		conn_users = self.sync_redis.shgetall(connection_id)

		if conn_users[self.id] in [WebRtcRedisStates.READY, WebRtcRedisStates.RESPONDED]:

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

			del conn_users[self.id]

			message = {

				VarNames.EVENT: Actions.CLOSE_CALL_CONNECTION,

				VarNames.CONNECTION_ID: connection_id,

				VarNames.USER_ID: self.user_id,

				VarNames.WEBRTC_OPPONENT_ID: self.id,

				VarNames.HANDLER_NAME: HandlerNames.PEER_CONNECTION,

			}

			for user in conn_users:

				if conn_users[user] != WebRtcRedisStates.CLOSED:

					self.publish(message, user)

		else:

			raise ValidationError("Invalid channel status.")