|
|
@@ -1,194 +1,330 @@
|
|
|
// CloudObject.ts
|
|
|
export class CloudObject {
|
|
|
- className: string;
|
|
|
- id: string | null = null;
|
|
|
- createdAt:any;
|
|
|
- updatedAt:any;
|
|
|
- data: Record<string, any> = {};
|
|
|
-
|
|
|
- constructor(className: string) {
|
|
|
- this.className = className;
|
|
|
- }
|
|
|
+ className: string;
|
|
|
+ id: string | null = null;
|
|
|
+ createdAt: any;
|
|
|
+ updatedAt: any;
|
|
|
+ data: Record<string, any> = {};
|
|
|
|
|
|
- toPointer() {
|
|
|
- return { "__type": "Pointer", "className": this.className, "objectId": this.id };
|
|
|
- }
|
|
|
+ constructor(className: string) {
|
|
|
+ this.className = className;
|
|
|
+ }
|
|
|
|
|
|
- set(json: Record<string, any>) {
|
|
|
- Object.keys(json).forEach(key => {
|
|
|
- if (["objectId", "id", "createdAt", "updatedAt", "ACL"].indexOf(key) > -1) {
|
|
|
- return;
|
|
|
- }
|
|
|
- this.data[key] = json[key];
|
|
|
- });
|
|
|
- }
|
|
|
+ toPointer() {
|
|
|
+ return { __type: 'Pointer', className: this.className, objectId: this.id };
|
|
|
+ }
|
|
|
+
|
|
|
+ set(json: Record<string, any>) {
|
|
|
+ Object.keys(json).forEach((key) => {
|
|
|
+ if (
|
|
|
+ ['objectId', 'id', 'createdAt', 'updatedAt', 'ACL'].indexOf(key) > -1
|
|
|
+ ) {
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ this.data[key] = json[key];
|
|
|
+ });
|
|
|
+ }
|
|
|
+
|
|
|
+ get(key: string) {
|
|
|
+ return this.data[key] || null;
|
|
|
+ }
|
|
|
|
|
|
- get(key: string) {
|
|
|
- return this.data[key] || null;
|
|
|
+ async save() {
|
|
|
+ let method = 'POST';
|
|
|
+ let url = `http://dev.fmode.cn:1337/parse/classes/${this.className}`;
|
|
|
+
|
|
|
+ // 更新
|
|
|
+ if (this.id) {
|
|
|
+ url += `/${this.id}`;
|
|
|
+ method = 'PUT';
|
|
|
}
|
|
|
|
|
|
- async save() {
|
|
|
- let method = "POST";
|
|
|
- let url = `http://dev.fmode.cn:1337/parse/classes/${this.className}`;
|
|
|
-
|
|
|
- // 更新
|
|
|
- if (this.id) {
|
|
|
- url += `/${this.id}`;
|
|
|
- method = "PUT";
|
|
|
- }
|
|
|
-
|
|
|
- const body = JSON.stringify(this.data);
|
|
|
- const response = await fetch(url, {
|
|
|
- headers: {
|
|
|
- "content-type": "application/json;charset=UTF-8",
|
|
|
- "x-parse-application-id": "dev"
|
|
|
- },
|
|
|
- body: body,
|
|
|
- method: method,
|
|
|
- mode: "cors",
|
|
|
- credentials: "omit"
|
|
|
- });
|
|
|
-
|
|
|
- const result = await response?.json();
|
|
|
- if (result?.error) {
|
|
|
- console.error(result?.error);
|
|
|
- }
|
|
|
- if (result?.objectId) {
|
|
|
- this.id = result?.objectId;
|
|
|
- }
|
|
|
- return this;
|
|
|
+ const body = JSON.stringify(this.data);
|
|
|
+ const response = await fetch(url, {
|
|
|
+ headers: {
|
|
|
+ 'content-type': 'application/json;charset=UTF-8',
|
|
|
+ 'x-parse-application-id': 'dev',
|
|
|
+ },
|
|
|
+ body: body,
|
|
|
+ method: method,
|
|
|
+ mode: 'cors',
|
|
|
+ credentials: 'omit',
|
|
|
+ });
|
|
|
+
|
|
|
+ const result = await response?.json();
|
|
|
+ if (result?.error) {
|
|
|
+ console.error(result?.error);
|
|
|
}
|
|
|
+ if (result?.objectId) {
|
|
|
+ this.id = result?.objectId;
|
|
|
+ }
|
|
|
+ return this;
|
|
|
+ }
|
|
|
+
|
|
|
+ async destroy() {
|
|
|
+ if (!this.id) return;
|
|
|
+ const response = await fetch(
|
|
|
+ `http://dev.fmode.cn:1337/parse/classes/${this.className}/${this.id}`,
|
|
|
+ {
|
|
|
+ headers: {
|
|
|
+ 'x-parse-application-id': 'dev',
|
|
|
+ },
|
|
|
+ body: null,
|
|
|
+ method: 'DELETE',
|
|
|
+ mode: 'cors',
|
|
|
+ credentials: 'omit',
|
|
|
+ }
|
|
|
+ );
|
|
|
|
|
|
- async destroy() {
|
|
|
- if (!this.id) return;
|
|
|
- const response = await fetch(`http://dev.fmode.cn:1337/parse/classes/${this.className}/${this.id}`, {
|
|
|
- headers: {
|
|
|
- "x-parse-application-id": "dev"
|
|
|
- },
|
|
|
- body: null,
|
|
|
- method: "DELETE",
|
|
|
- mode: "cors",
|
|
|
- credentials: "omit"
|
|
|
- });
|
|
|
-
|
|
|
- const result = await response?.json();
|
|
|
- if (result) {
|
|
|
- this.id = null;
|
|
|
- }
|
|
|
- return true;
|
|
|
+ const result = await response?.json();
|
|
|
+ if (result) {
|
|
|
+ this.id = null;
|
|
|
}
|
|
|
+ return true;
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
// CloudQuery.ts
|
|
|
export class CloudQuery {
|
|
|
- className: string;
|
|
|
- whereOptions: Record<string, any> = {};
|
|
|
+ className: string;
|
|
|
+ whereOptions: Record<string, any> = {};
|
|
|
+
|
|
|
+ constructor(className: string) {
|
|
|
+ this.className = className;
|
|
|
+ }
|
|
|
+
|
|
|
+ greaterThan(key: string, value: any) {
|
|
|
+ if (!this.whereOptions[key]) this.whereOptions[key] = {};
|
|
|
+ this.whereOptions[key]['$gt'] = value;
|
|
|
+ }
|
|
|
+
|
|
|
+ greaterThanAndEqualTo(key: string, value: any) {
|
|
|
+ if (!this.whereOptions[key]) this.whereOptions[key] = {};
|
|
|
+ this.whereOptions[key]['$gte'] = value;
|
|
|
+ }
|
|
|
+
|
|
|
+ lessThan(key: string, value: any) {
|
|
|
+ if (!this.whereOptions[key]) this.whereOptions[key] = {};
|
|
|
+ this.whereOptions[key]['$lt'] = value;
|
|
|
+ }
|
|
|
+
|
|
|
+ lessThanAndEqualTo(key: string, value: any) {
|
|
|
+ if (!this.whereOptions[key]) this.whereOptions[key] = {};
|
|
|
+ this.whereOptions[key]['$lte'] = value;
|
|
|
+ }
|
|
|
+
|
|
|
+ equalTo(key: string, value: any) {
|
|
|
+ this.whereOptions[key] = value;
|
|
|
+ }
|
|
|
+
|
|
|
+ async get(id: string) {
|
|
|
+ const url = `http://dev.fmode.cn:1337/parse/classes/${this.className}/${id}?`;
|
|
|
+
|
|
|
+ const response = await fetch(url, {
|
|
|
+ headers: {
|
|
|
+ 'if-none-match': 'W/"1f0-ghxH2EwTk6Blz0g89ivf2adBDKY"',
|
|
|
+ 'x-parse-application-id': 'dev',
|
|
|
+ },
|
|
|
+ body: null,
|
|
|
+ method: 'GET',
|
|
|
+ mode: 'cors',
|
|
|
+ credentials: 'omit',
|
|
|
+ });
|
|
|
|
|
|
- constructor(className: string) {
|
|
|
- this.className = className;
|
|
|
+ const json = await response?.json();
|
|
|
+ return json || {};
|
|
|
+ }
|
|
|
+
|
|
|
+ async find() {
|
|
|
+ let url = `http://dev.fmode.cn:1337/parse/classes/${this.className}?`;
|
|
|
+
|
|
|
+ if (Object.keys(this.whereOptions).length) {
|
|
|
+ const whereStr = JSON.stringify(this.whereOptions);
|
|
|
+ url += `where=${whereStr}`;
|
|
|
}
|
|
|
|
|
|
- greaterThan(key: string, value: any) {
|
|
|
- if (!this.whereOptions[key]) this.whereOptions[key] = {};
|
|
|
- this.whereOptions[key]["$gt"] = value;
|
|
|
+ const response = await fetch(url, {
|
|
|
+ headers: {
|
|
|
+ 'if-none-match': 'W/"1f0-ghxH2EwTk6Blz0g89ivf2adBDKY"',
|
|
|
+ 'x-parse-application-id': 'dev',
|
|
|
+ },
|
|
|
+ body: null,
|
|
|
+ method: 'GET',
|
|
|
+ mode: 'cors',
|
|
|
+ credentials: 'omit',
|
|
|
+ });
|
|
|
+
|
|
|
+ const json = await response?.json();
|
|
|
+ let list = json?.results || [];
|
|
|
+ let objList = list.map((item: any) => this.dataToObj(item));
|
|
|
+ return objList || [];
|
|
|
+ }
|
|
|
+
|
|
|
+ async first() {
|
|
|
+ let url = `http://dev.fmode.cn:1337/parse/classes/${this.className}?`;
|
|
|
+
|
|
|
+ if (Object.keys(this.whereOptions).length) {
|
|
|
+ const whereStr = JSON.stringify(this.whereOptions);
|
|
|
+ url += `where=${whereStr}`;
|
|
|
}
|
|
|
|
|
|
- greaterThanAndEqualTo(key: string, value: any) {
|
|
|
- if (!this.whereOptions[key]) this.whereOptions[key] = {};
|
|
|
- this.whereOptions[key]["$gte"] = value;
|
|
|
+ const response = await fetch(url, {
|
|
|
+ headers: {
|
|
|
+ 'if-none-match': 'W/"1f0-ghxH2EwTk6Blz0g89ivf2adBDKY"',
|
|
|
+ 'x-parse-application-id': 'dev',
|
|
|
+ },
|
|
|
+ body: null,
|
|
|
+ method: 'GET',
|
|
|
+ mode: 'cors',
|
|
|
+ credentials: 'omit',
|
|
|
+ });
|
|
|
+
|
|
|
+ const json = await response?.json();
|
|
|
+ const exists = json?.results?.[0] || null;
|
|
|
+ if (exists) {
|
|
|
+ let existsObject = this.dataToObj(exists);
|
|
|
+ return existsObject;
|
|
|
}
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ dataToObj(exists: any): CloudObject {
|
|
|
+ let existsObject = new CloudObject(this.className);
|
|
|
+ existsObject.set(exists);
|
|
|
+ existsObject.id = exists.objectId;
|
|
|
+ existsObject.createdAt = exists.createdAt;
|
|
|
+ existsObject.updatedAt = exists.updatedAt;
|
|
|
+ return existsObject;
|
|
|
+ }
|
|
|
+}
|
|
|
|
|
|
- lessThan(key: string, value: any) {
|
|
|
- if (!this.whereOptions[key]) this.whereOptions[key] = {};
|
|
|
- this.whereOptions[key]["$lt"] = value;
|
|
|
+//CloudQuery.ts
|
|
|
+// CloudUser.ts
|
|
|
+export class CloudUser extends CloudObject {
|
|
|
+ constructor() {
|
|
|
+ super('_User'); // 假设用户类在Parse中是"_User"
|
|
|
+ // 读取用户缓存信息
|
|
|
+ let userCacheStr = localStorage.getItem('NCloud/dev/User');
|
|
|
+ if (userCacheStr) {
|
|
|
+ let userData = JSON.parse(userCacheStr);
|
|
|
+ // 设置用户信息
|
|
|
+ this.id = userData?.objectId;
|
|
|
+ this.sessionToken = userData?.sessionToken;
|
|
|
+ this.data = userData; // 保存用户数据
|
|
|
}
|
|
|
+ }
|
|
|
|
|
|
- lessThanAndEqualTo(key: string, value: any) {
|
|
|
- if (!this.whereOptions[key]) this.whereOptions[key] = {};
|
|
|
- this.whereOptions[key]["$lte"] = value;
|
|
|
+ sessionToken: string | null = '';
|
|
|
+ /** 获取当前用户信息 */
|
|
|
+ async current() {
|
|
|
+ if (!this.sessionToken) {
|
|
|
+ console.error('用户未登录');
|
|
|
+ return null;
|
|
|
}
|
|
|
|
|
|
- equalTo(key: string, value: any) {
|
|
|
- this.whereOptions[key] = value;
|
|
|
+ const response = await fetch(`http://dev.fmode.cn:1337/parse/users/me`, {
|
|
|
+ headers: {
|
|
|
+ 'x-parse-application-id': 'dev',
|
|
|
+ 'x-parse-session-token': this.sessionToken, // 使用sessionToken进行身份验证
|
|
|
+ },
|
|
|
+ method: 'GET',
|
|
|
+ });
|
|
|
+
|
|
|
+ const result = await response?.json();
|
|
|
+ if (result?.error) {
|
|
|
+ console.error(result?.error);
|
|
|
+ return null;
|
|
|
}
|
|
|
+ return result;
|
|
|
+ }
|
|
|
|
|
|
- async get(id: string) {
|
|
|
- const url = `http://dev.fmode.cn:1337/parse/classes/${this.className}/${id}?`;
|
|
|
-
|
|
|
- const response = await fetch(url, {
|
|
|
- headers: {
|
|
|
- "if-none-match": "W/\"1f0-ghxH2EwTk6Blz0g89ivf2adBDKY\"",
|
|
|
- "x-parse-application-id": "dev"
|
|
|
- },
|
|
|
- body: null,
|
|
|
- method: "GET",
|
|
|
- mode: "cors",
|
|
|
- credentials: "omit"
|
|
|
- });
|
|
|
-
|
|
|
- const json = await response?.json();
|
|
|
- return json || {};
|
|
|
+ /** 登录 */
|
|
|
+ async login(username: string, password: string): Promise<CloudUser | null> {
|
|
|
+ const response = await fetch(`http://dev.fmode.cn:1337/parse/login`, {
|
|
|
+ headers: {
|
|
|
+ 'x-parse-application-id': 'dev',
|
|
|
+ 'Content-Type': 'application/json',
|
|
|
+ },
|
|
|
+ body: JSON.stringify({ username, password }),
|
|
|
+ method: 'POST',
|
|
|
+ });
|
|
|
+
|
|
|
+ const result = await response?.json();
|
|
|
+ if (result?.error) {
|
|
|
+ console.error(result?.error);
|
|
|
+ return null;
|
|
|
}
|
|
|
|
|
|
- async find() {
|
|
|
- let url = `http://dev.fmode.cn:1337/parse/classes/${this.className}?`;
|
|
|
-
|
|
|
- if (Object.keys(this.whereOptions).length) {
|
|
|
- const whereStr = JSON.stringify(this.whereOptions);
|
|
|
- url += `where=${whereStr}`;
|
|
|
- }
|
|
|
-
|
|
|
- const response = await fetch(url, {
|
|
|
- headers: {
|
|
|
- "if-none-match": "W/\"1f0-ghxH2EwTk6Blz0g89ivf2adBDKY\"",
|
|
|
- "x-parse-application-id": "dev"
|
|
|
- },
|
|
|
- body: null,
|
|
|
- method: "GET",
|
|
|
- mode: "cors",
|
|
|
- credentials: "omit"
|
|
|
- });
|
|
|
-
|
|
|
- const json = await response?.json();
|
|
|
- let list = json?.results || []
|
|
|
- let objList = list.map((item:any)=>this.dataToObj(item))
|
|
|
- return objList || [];
|
|
|
+ // 设置用户信息
|
|
|
+ this.id = result?.objectId;
|
|
|
+ this.sessionToken = result?.sessionToken;
|
|
|
+ this.data = result; // 保存用户数据
|
|
|
+ // 缓存用户信息
|
|
|
+ console.log(result);
|
|
|
+ localStorage.setItem('NCloud/dev/User', JSON.stringify(result));
|
|
|
+ return this;
|
|
|
+ }
|
|
|
+
|
|
|
+ /** 登出 */
|
|
|
+ async logout() {
|
|
|
+ if (!this.sessionToken) {
|
|
|
+ console.error('用户未登录');
|
|
|
+ return;
|
|
|
}
|
|
|
|
|
|
- async first() {
|
|
|
- let url = `http://dev.fmode.cn:1337/parse/classes/${this.className}?`;
|
|
|
-
|
|
|
- if (Object.keys(this.whereOptions).length) {
|
|
|
- const whereStr = JSON.stringify(this.whereOptions);
|
|
|
- url += `where=${whereStr}`;
|
|
|
- }
|
|
|
-
|
|
|
- const response = await fetch(url, {
|
|
|
- headers: {
|
|
|
- "if-none-match": "W/\"1f0-ghxH2EwTk6Blz0g89ivf2adBDKY\"",
|
|
|
- "x-parse-application-id": "dev"
|
|
|
- },
|
|
|
- body: null,
|
|
|
- method: "GET",
|
|
|
- mode: "cors",
|
|
|
- credentials: "omit"
|
|
|
- });
|
|
|
-
|
|
|
- const json = await response?.json();
|
|
|
- const exists = json?.results?.[0] || null;
|
|
|
- if (exists) {
|
|
|
- let existsObject = this.dataToObj(exists)
|
|
|
- return existsObject;
|
|
|
- }
|
|
|
- return null
|
|
|
+ const response = await fetch(`http://dev.fmode.cn:1337/parse/logout`, {
|
|
|
+ headers: {
|
|
|
+ 'x-parse-application-id': 'dev',
|
|
|
+ 'x-parse-session-token': this.sessionToken,
|
|
|
+ },
|
|
|
+ method: 'POST',
|
|
|
+ });
|
|
|
+
|
|
|
+ const result = await response?.json();
|
|
|
+ if (result?.error) {
|
|
|
+ console.error(result?.error);
|
|
|
+ return false;
|
|
|
}
|
|
|
|
|
|
- dataToObj(exists:any):CloudObject{
|
|
|
- let existsObject = new CloudObject(this.className);
|
|
|
- existsObject.set(exists);
|
|
|
- existsObject.id = exists.objectId;
|
|
|
- existsObject.createdAt = exists.createdAt;
|
|
|
- existsObject.updatedAt = exists.updatedAt;
|
|
|
- return existsObject;
|
|
|
+ // 清除用户信息
|
|
|
+ localStorage.removeItem('NCloud/dev/User');
|
|
|
+ this.id = null;
|
|
|
+ this.sessionToken = null;
|
|
|
+ this.data = {};
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ /** 注册 */
|
|
|
+ async signUp(
|
|
|
+ username: string,
|
|
|
+ password: string,
|
|
|
+ additionalData: Record<string, any> = {}
|
|
|
+ ) {
|
|
|
+ const userData = {
|
|
|
+ username,
|
|
|
+ password,
|
|
|
+ ...additionalData, // 合并额外的用户数据
|
|
|
+ };
|
|
|
+
|
|
|
+ const response = await fetch(`http://dev.fmode.cn:1337/parse/users`, {
|
|
|
+ headers: {
|
|
|
+ 'x-parse-application-id': 'dev',
|
|
|
+ 'Content-Type': 'application/json',
|
|
|
+ },
|
|
|
+ body: JSON.stringify(userData),
|
|
|
+ method: 'POST',
|
|
|
+ });
|
|
|
+
|
|
|
+ const result = await response?.json();
|
|
|
+ if (result?.error) {
|
|
|
+ console.error(result?.error);
|
|
|
+ return null;
|
|
|
}
|
|
|
-}
|
|
|
+
|
|
|
+ // 设置用户信息
|
|
|
+ this.id = result?.objectId;
|
|
|
+ this.sessionToken = result?.sessionToken;
|
|
|
+ this.data = result; // 保存用户数据
|
|
|
+ return this;
|
|
|
+ }
|
|
|
+}
|
布丁撞奶茶