Deathangel908 / pychat

	# 	else:

	# 		raise ValidationError("Invalid channel status")

	def accept_call(self, in_message):

		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]

				self.close_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]

		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.")

	def cancel_call_connection(self, in_message):

		connection_id = in_message[VarNames.CONNECTION_ID]