anchor.diff:  	}
   
   	static Future<Item> takeItemFromUser(String email, int slot, int subSlot, int count) async {
  -		await _aquireLock(email);
  +		if (!(await _aquireLock(email))) {
  +			return null;
  +		}
  +
   		WebSocket userSocket = StreetUpdateHandler.userSockets[email];
   		InventoryV2 inv = await getInventory(email);
   		Item itemTaken = await inv._takeItem(slot, subSlot, count, email);
  
positive.code: 			types = validTypes;
  		}
  
  		await _aquireLock(email);
  		WebSocket userSocket = StreetUpdateHandler.userSockets[email];
  		InventoryV2 inv = await getInventory(email);
  
  
negative.code: 
  	///Returns the number of items successfully added to the user's inventory
  	static Future<int> addItemToUser(String email, Map item, int count,	[String fromObject = "_self"]) async {
  		if (!(await _aquireLock(email))) {
  			return 0;
  		}
  
  		WebSocket userSocket = StreetUpdateHandler.userSockets[email];
  		InventoryV2 inv = await getInventory(email);
  		int added = await inv._addItem(item, count, email);
  		await fireInventoryAtUser(userSocket, email, update: true);
  		if (added > 0) {
  			String itemType = item['itemType'];
  			messageBus.publish(new RequirementProgress('getItem_$itemType', email, count: count));
  			if (itemType == 'pick' || itemType == 'fancy_pick') {
  				QuestEndpoint.questLogCache[email]?.offerQuest('Q6');
  			}
  		}
  