Deathangel908 / pychat

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

			self.publish({

				VarNames.EVENT: Actions.ACCEPT_FILE,

				VarNames.CONNECTION_ID: connection_id,

				VarNames.WEBRTC_OPPONENT_ID: self.id,

				VarNames.HANDLER_NAME: HandlerNames.PEER_CONNECTION,

			}, sender_ws_id)

		else:

			raise ValidationError("Invalid channel status")

	# todo

	# we can use channel_status = self.sync_redis.shgetall(connection_id)

	# and then self.async_redis_publisher.hset(connection_id, self.id, WebRtcRedisStates.READY)

	# if we shgetall and only then do async hset

	# we can catch an issue when 2 concurrent users accepted the call

	# but we didn't  send them ACCEPT_CALL as they both were in status 'offered'

	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,

	def parse_imgs(self, imgs, mess_id):

		res_imgs = []

		if not imgs:

			return res_imgs

		fetch = False

		for k in imgs:

			b64 = imgs[k].get(VarNames.IMG_B64)

			if b64:

				img = extract_photo(imgs[k][VarNames.IMG_B64], imgs[k][VarNames.IMG_FILE_NAME])

				res_imgs.append(Image(message_id=mess_id, img=img, symbol=k))

			else:

				fetch = True

		self.merge_came_imgs_with_db(fetch, mess_id, res_imgs)

		return res_imgs

	def merge_came_imgs_with_db(self, fetch, mess_id, res_imgs):

		fetched_messages = None

		if fetch:

			fetched_messages = Image.objects.filter(message_id=mess_id)

		if res_imgs:

			Image.objects.bulk_create(res_imgs)

		if fetched_messages:

			for m in fetched_messages: