70 lines
2.4 KiB
C#
70 lines
2.4 KiB
C#
using System;
|
|
using System.Threading.Tasks;
|
|
using LeanCloud;
|
|
using LeanCloud.Storage;
|
|
using LeanCloud.LiveQuery;
|
|
|
|
using static System.Console;
|
|
|
|
namespace LiveQueryApp {
|
|
class Program {
|
|
static void Main(string[] args) {
|
|
WriteLine("Hello World!");
|
|
|
|
SingleThreadSynchronizationContext.Run(async () => {
|
|
LCLogger.LogDelegate += Print;
|
|
LCApplication.Initialize("ikGGdRE2YcVOemAaRbgp1xGJ-gzGzoHsz",
|
|
"NUKmuRbdAhg1vrb2wexYo1jo",
|
|
"https://ikggdre2.lc-cn-n1-shared.com");
|
|
|
|
await LCUser.Login("hello", "world");
|
|
LCQuery<LCUser> userQuery = LCUser.GetQuery();
|
|
userQuery.WhereEqualTo("username", "hello");
|
|
LCLiveQuery userLiveQuery = await userQuery.Subscribe();
|
|
userLiveQuery.OnLogin = (user) => {
|
|
WriteLine($"login: {user.Username}");
|
|
};
|
|
|
|
LCQuery<LCObject> query = new LCQuery<LCObject>("Account");
|
|
query.WhereGreaterThan("balance", 100);
|
|
LCLiveQuery liveQuery = await query.Subscribe();
|
|
liveQuery.OnCreate = (obj) => {
|
|
WriteLine($"create: {obj}");
|
|
};
|
|
liveQuery.OnUpdate = (obj, keys) => {
|
|
WriteLine($"update: {obj}");
|
|
WriteLine(keys.Count);
|
|
};
|
|
liveQuery.OnDelete = (objId) => {
|
|
WriteLine($"delete: {objId}");
|
|
};
|
|
liveQuery.OnEnter = (obj, keys) => {
|
|
WriteLine($"enter: {obj}");
|
|
WriteLine(keys.Count);
|
|
};
|
|
liveQuery.OnLeave = (obj, keys) => {
|
|
WriteLine($"leave: {obj}");
|
|
WriteLine(keys.Count);
|
|
};
|
|
});
|
|
}
|
|
|
|
private static void Print(LCLogLevel level, string info) {
|
|
switch (level) {
|
|
case LCLogLevel.Debug:
|
|
WriteLine($"[DEBUG] {info}\n");
|
|
break;
|
|
case LCLogLevel.Warn:
|
|
WriteLine($"[WARNING] {info}\n");
|
|
break;
|
|
case LCLogLevel.Error:
|
|
WriteLine($"[ERROR] {info}\n");
|
|
break;
|
|
default:
|
|
WriteLine(info);
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|