public void DecrementUnreadMessages(string appName, ObjectId userId, int decrementBy)
 {
     var dataBase = _serverWrapper.ServerConnection.GetDatabase(appName);
     var collection = dataBase.GetCollection<DatingBookUserInfo>(DATING_BOOK_USERS_COLLECTION_NAME);
     var selectQuery = Query.EQ("_id", userId);
     collection.Update(selectQuery, Update.Inc("new_messages", -decrementBy));
 }

 /// <summary>
 /// 查询角色下面所有用户
 /// </summary>
 /// <param name="UserRoleId"></param>
 /// <returns>返回所有用户</returns>
 public BsonArray UserInRole(ObjectId UserRoleId)
 {
     BsonDocument Query = new BsonDocument {
         { "UserRole", UserRoleId}
     };
     return GetUsersToArray(Query);
 }

        public DatingBookUserInfo GetDatingBookUserInfo(string appName, ObjectId userId)
        {
            var datingBookUserInfo = _userDataProvider.GetDatingBookUserInfoByFacebookId(appName, userId);

            if (datingBookUserInfo == null)
                return null;

            if (!CheckIfUserPictureExist(appName, datingBookUserInfo))
                DownloadUserPicture(appName, datingBookUserInfo);

            datingBookUserInfo.LastVisit = DateTime.Now;
            ObjectId visitId = ObjectId.Empty;
            var whiteList = _userDataProvider.GetUsersWhitelist(appName);

            if (!whiteList.Exists((usr) => usr == datingBookUserInfo.FacebookId))
            {
                BsonDocument visit = new BsonDocument();
                visit.Add("dating_book_id", datingBookUserInfo.ObjectId);
                visit.Add("entered_at", datingBookUserInfo.LastVisit);
                visitId = _userDataProvider.InsertVisit(appName, visit);
            }

            datingBookUserInfo = _userDataProvider.UpdateDatingBookLastVisit(appName, datingBookUserInfo, visitId);

            var userEventInfo = new UserEventInfo
            {
                UserId = datingBookUserInfo.ObjectId,
                EventType = 1,
                DateCreated = DateTime.Now
            };

            _userDataProvider.InsertUserEvent(appName, userEventInfo);

            return datingBookUserInfo;
        }

 public void ObjectIdWithDifferentValuesAreNotEqual()
 {
     var a = new ObjectId("4b883faad657000000002665");
     var b = new ObjectId("4b883faad657000000002666");
     Assert.NotEqual(a, b);
     Assert.True(a != b);
 }

        public dynamic GetSessionDetails(string appName, ObjectId from, string to)
        {
            MessageSessionInfo session = _userMessagesDataProvider.GetSession(appName, CalculateSessionId(from.ToString(), to));
            ObjectId fromWho = ObjectId.Empty;

            if (from == session.User1)
            {
                fromWho = session.User1;
            }
            else if (from == session.User2)
            {
                fromWho = session.User2;
            }
            if (fromWho == ObjectId.Empty)
            {
                return new
                {
                    error = "1"
                };
            }
            var toUser = _userDataProvider.GetDatingBookUserInfo(appName, session.User1 == from ? session.User2 : session.User1, "facebook_user_id", "user_id", "picture", "location", "fname", "real_birthday");
            return new
            {
                from = from.ToString(),
                to = toUser.Id.ToString(),
                to_picture = GenerateUserProfilePictureUrl(appName, toUser, 45, 55),
                to_location = toUser.Location,
                to_name = toUser.FirstName,
                to_age = (int)(Math.Round((DateTime.Now.Subtract(toUser.RealBirthday).TotalDays) / 365)),
                session_updated = session.LastUpdated.ToString("dd/MM/yyyy dddd hh:mm")
            };
        }

        public void TestFromRqlIds()
        {
            var rqlIds = new RqlId[]
            {
                new RqlId("$0"),
                new RqlId("$0"),
                new RqlId("$1F2mgA9gNyZtkTIf6"),
                new RqlId("$1Ad4Xro7A6yeAl77J")  // This one caused problems

            };

            var objIds = new ObjectId[]
            {
                ObjectId.Empty,
                new ObjectId(0, 0, 0, 0),
                new ObjectId("8000000000006400c800ffff"),
                new ObjectId("53d5244dec98e866c0d800f4")
            };

            for (int i = 0; i < rqlIds.Length; i++)
            {
                var objId = rqlIds[i].ToObjectId();
                var rqlId = objId.ToRqlId();
                var objId2 = rqlId.ToObjectId();

                Assert.AreEqual(rqlIds[i], rqlId, "ObjectId value {0}", i);
                Assert.AreEqual(objIds[i], objId2, "RqlId value {0}", i);
            }
        }

        public ActionResult Delete(ObjectId id)
        {
            var collection = Database.GetCollection<ProfileProperty>("ProfileProperty");
            collection.Remove(Query.EQ("_id", id));

            return RedirectToAction("Index");
        }

        public void GivenAMongoMessageDataRepository_WhenPuttingMessageDataWithExpiration()
        {
            var db = new MongoClient().GetDatabase("messagedatastoretests");
            _bucket = new GridFSBucket(db);

            _now = DateTime.UtcNow;
            SystemDateTime.Set(_now);

            var fixture = new Fixture();

            var resolver = new Mock<IMongoMessageUriResolver>();
            resolver.Setup(x => x.Resolve(It.IsAny<ObjectId>()))
                .Callback((ObjectId id) => _id = id);

            var nameCreator = new Mock<IFileNameCreator>();
            nameCreator.Setup(x => x.CreateFileName())
                .Returns(fixture.Create<string>());
            
            var sut = new MongoMessageDataRepository(resolver.Object, _bucket, nameCreator.Object);
            _expectedTtl = TimeSpan.FromHours(1);

            using (var stream = new MemoryStream(fixture.Create<byte[]>()))
            {
                sut.Put(stream, _expectedTtl).GetAwaiter().GetResult();
            }
        }

        public DatingBookUserInfo UpsertDatingBookUserInfo(string appName, ObjectId userId, DatingBookUserInfo datingBookUserInfo)
        {
            datingBookUserInfo = _userDataProvider.UpsertDatingbookUserInfo(appName, userId, datingBookUserInfo);

            if (datingBookUserInfo.IsNew)
            {
                if (!CheckIfUserPictureExist(appName, datingBookUserInfo))
                    DownloadUserPicture(appName, datingBookUserInfo);

                var userEventInfo = new UserEventInfo
                {
                    UserId = datingBookUserInfo.ObjectId,
                    EventType = 0,
                    DateCreated = DateTime.Now
                };

                _userDataProvider.InsertUserEvent(appName, userEventInfo);

                datingBookUserInfo.IsNew = false;
            }

            datingBookUserInfo.LastVisit = DateTime.Now;
            datingBookUserInfo = _userDataProvider.UpdateDatingBookLastVisit(appName, datingBookUserInfo);

            return datingBookUserInfo;
        }

 public FetchHeadRecord(ObjectId newValue, bool notForMerge, string sourceName, URIish sourceUri)
 {
     NewValue = newValue;
     NotForMerge = notForMerge;
     SourceName = sourceName;
     SourceURI = sourceUri;
 }

 public ReadRangeRequest(ObjectId objectIdentifier, PropertyIdentifier propertyIdentifier, Option<uint> propertyArrayIndex, Option<RangeType> range)
 {
     this.ObjectIdentifier = objectIdentifier;
     this.PropertyIdentifier = propertyIdentifier;
     this.PropertyArrayIndex = propertyArrayIndex;
     this.Range = range;
 }

        static void Main(string[] args)
        {
            var client = new MongoClient();
            var db = client.GetDatabase("CustomerDb");
            var CustColl = db.GetCollection<Customer>("Customer");

            // query customer
            var customerID = new ObjectId("xxx");

            var customers = CustColl
                            .Find(c => c.Id == customerID)
                            .SortBy(c => c.fullName)
                            .Limit(3)
                            .ToListAsync()
                            .Result;

            foreach (var customer in customers)
            {
                Console.WriteLine(customer.fullName);
            }

            //Update Customer
            var cust = customers.First();
            cust.fullName = cust.fullName.ToUpper();
        }

 public MockCommit(ObjectId id = null)
 {
     idEx = id ?? new ObjectId(Guid.NewGuid().ToString().Replace("-", "")+ "00000000");
     MessageEx = "";
     ParentsEx = new List<Commit> { null };
     CommitterEx = new Signature("Joe", "[email protected]", DateTimeOffset.Now);
 }

 public IAmRequest(ObjectId iAmDeviceIdentifier, uint maxAPDULengthAccepted, Segmentation segmentationSupported, uint vendorID)
 {
     this.IAmDeviceIdentifier = iAmDeviceIdentifier;
     this.MaxAPDULengthAccepted = maxAPDULengthAccepted;
     this.SegmentationSupported = segmentationSupported;
     this.VendorID = vendorID;
 }

 //
 // GET: /Project/Details/5
 public ActionResult Details(ObjectId id)
 {
     var project = session.GetById<Project>(id);
     ViewBag.ProjectConfigurations =
         session.GetAll<Configuration>().Where(c => c.ProjectId == project.Id).ToArray();
     return View(project);
 }

 public Comment(String contentID)
 {
     try
     {
         Comment obj = new Comment();
         MongoDatabase md = MongoDBHelper.MongoDB;
         MongoCollection<Comment> mc = md.GetCollection<Comment>(Comment.GetCollectionName());
         obj = mc.FindOne(Query.EQ("_id", ObjectId.Parse(contentID)));
         this._id = obj._id;
         this.MemberID = obj.MemberID;
         this.Creater = new Moooyo.BiZ.Creater.Creater(obj.MemberID);
         this.CommentToID = obj.CommentToID;
         this.Content = obj.Content;
         this.CreatedTime = obj.CreatedTime;
         this.UpdateTime = obj.UpdateTime;
         this.CommentType = obj.CommentType;
         this.DeleteFlag = obj.DeleteFlag;
     }
     catch (System.Exception err)
     {
         throw new CBB.ExceptionHelper.OperationException(
             CBB.ExceptionHelper.ErrType.SystemErr,
             CBB.ExceptionHelper.ErrNo.DBOperationError,
             err);
     }
 }

        public void TestFromObjectIds()
        {
            var objIds = new ObjectId[]
            {
                ObjectId.Empty,
                new ObjectId(0, 0, 0, 0),
                new ObjectId(0, 100, 200, 65535),
                new ObjectId(int.MaxValue, 0xffffff, short.MaxValue, 0xffffff),
            };

            var rqlIds = new RqlId[]
            {
                new RqlId("$0"),
                new RqlId("$0"),
                new RqlId("$1F2mgA9gNyZtkTId2"),
                new RqlId("$1F2si9jk4p8AzQuuP")
            };

            for (int i = 0; i < objIds.Length; i++)
            {
                var rqlId = objIds[i].ToRqlId();
                var objId = rqlId.ToObjectId();
                var rqlId2 = objId.ToRqlId();

                Assert.AreEqual(objIds[i], objId, "ObjectId value {0}", i);
                Assert.AreEqual(rqlIds[i], rqlId2, "RqlId value {0}", i);
            }
        }

        public static void PublishChatMessages(this BahamutPubSubService service, ObjectId senderId, ShareChat chat, ChatMessage msg)
        {
            foreach (var user in chat.UserIds)
            {
                if (user != senderId)
                {

                    var idstr = user.ToString();
                    var cacheModel = new BahamutCacheModel
                    {
                        AppUniqueId = Startup.Appname,
                        CacheDateTime = DateTime.UtcNow,
                        UniqueId = idstr,
                        DeserializableString = msg.Id.ToString(),
                        Type = ChatMessage.NotifyType,
                        ExtraInfo = chat.Id.ToString()
                    };
                    Startup.ServicesProvider.GetBahamutCacheService().PushCacheModelToList(cacheModel);
                    var pbModel = new BahamutPublishModel
                    {
                        NotifyType = "Toronto",
                        ToUser = idstr,
                        CustomCmd = "UsrNewMsg",
                        NotifyInfo = JsonConvert.SerializeObject(new { LocKey = "NEW_MSG_NOTIFICATION" })
                    };
                    Startup.ServicesProvider.GetBahamutPubSubService().PublishBahamutUserNotifyMessage(PublishConstants.NotifyId, pbModel);
                }
            }
        }

        public PersistentFiddlerSession GetSessionWithId(string id)
        {
            var repo = new MongoRepository.MongoRepository<PersistentFiddlerSession>();

            var resultSession = repo.GetById(id);

            if (null == resultSession)
            {
                throw new KeyNotFoundException(string.Format("Could not find a session id '{0}'", id));
            }

            // checked if actual data is compressed vs expected length
            //if (resultSession.Len > resultSession.Data.Length)
            //{
            //    var uncompressed = Utility.UnZip(resultSession.Data);
            //    resultSession.Data = uncompressed;
            //}

            var gridFsId = new ObjectId(resultSession.Data);

            var sessions = LoadSessionsFromGridFs(gridFsId);

            resultSession.SetSession(sessions[0]);
            return resultSession;
        }

        public EmailTracking Get(ObjectId id)
        {
            var query = Builders<EmailTracking>.Filter.Eq(e => e.Id, id);
            var temp = _collection.Find(query).ToListAsync();

            return temp.Result.FirstOrDefault();
        }