Deathangel908 / pychat

			room.save()

			room_id = room.id

			RoomUsers(user_id=self.user_id, room_id=room_id).save()

		return room_id

	def create_other_room(self, user_rooms, user_id):

		query_res = Room.users.through.objects.filter(user_id=user_id, room__in=user_rooms).values('room__id', 'room__disabled')

		if len(query_res) > 0:

			room = query_res[0]

			room_id = room['room__id']

			self.update_room(room_id, room['room__disabled'])

		else:

			room = Room()

			room.save()

			room_id = room.id

			RoomUsers.objects.bulk_create([

				RoomUsers(user_id=user_id, room_id=room_id),

		self.publish(self.add_user_to_room(room_id, user_id, users_in_room[user_id]), room_id)

		subscribe_message = self.invite_room_channel_message(room_id, user_id, room.name, users_in_room)

		self.publish(subscribe_message, RedisPrefix.generate_user(user_id), True)

	def create_self_room(self, user_rooms):

		rooms_ids = list([room['room_id'] for room in user_rooms])

		query_res = self.execute_query(SELECT_SELF_ROOM, [rooms_ids,])

		if len(query_res) > 0:

			room = query_res[0]

			room_id = room[0]

			self.update_room(room_id, room[1])

		else:

			room = Room()

			room.save()

			room_id = room.id