forked from openiap/opencore
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathUser.ts
More file actions
132 lines (127 loc) · 5.99 KB
/
Copy pathUser.ts
File metadata and controls
132 lines (127 loc) · 5.99 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
import { Base } from "./base";
import { Rolemember, Role } from "./Role";
import { DatabaseConnection } from "./DatabaseConnection";
import { TokenUser } from "./TokenUser";
import { Crypt } from "./Crypt";
import { Config } from "./Config";
export class FederationId {
constructor(id: string, issuer: string) {
this.id = id; this.issuer = issuer;
}
public id: string;
public issuer: string;
}
export class User extends Base {
constructor() {
super();
this._type = "user";
}
static assign<T>(o: T): T {
var newo: User = new User();
return Object.assign(newo, o);
}
lastseen: Date;
username: string;
passwordhash: string;
sid: string;
firebasetoken: string;
onesignalid: string;
federationids: FederationId[] = [];
roles: Rolemember[] = [];
HasRoleName(name: string): Boolean {
var hits: Rolemember[] = this.roles.filter(member => member.name === name);
return (hits.length === 1);
}
HasRoleId(id: string): boolean {
var hits: Rolemember[] = this.roles.filter(member => member._id === id);
return (hits.length === 1);
}
public async Save(jwt: string): Promise<void> {
if (this._id === null || this._id === undefined) {
var temp: User = await Config.db.InsertOne(this, "users", 0, false, jwt);
this._id = temp._id;
} else {
await Config.db.UpdateOne(null, this, "users", 0, false, jwt);
}
}
public static async FindByUsernameOrId(username: string, id: string): Promise<User> {
console.log({ $or: [{ username: username }, { _id: id }] });
var items: User[] = await Config.db.query<User>({ $or: [{ username: new RegExp(["^", username, "$"].join(""), "i") }, { _id: id }] },
null, 1, 0, null, "users", TokenUser.rootToken());
if (items === null || items === undefined || items.length === 0) { return null; }
var result: User = User.assign(items[0]);
await result.DecorateWithRoles();
return result;
}
public static async FindByUsername(username: string): Promise<User> {
var items: User[] = await Config.db.query<User>({ username: new RegExp(["^", username, "$"].join(""), "i") }, null, 1, 0, null, "users", TokenUser.rootToken());
if (items === null || items === undefined || items.length === 0) { return null; }
var result: User = User.assign(items[0]);
await result.DecorateWithRoles();
return result;
}
public static async FindByUsernameOrFederationid(username: string): Promise<User> {
var items: User[] = await Config.db.query<User>({
$or:
[
{ username: new RegExp(["^", username, "$"].join(""), "i") },
{ federationids: { $elemMatch: { id: new RegExp(["^", username, "$"].join(""), "i") } } }
]
}, null, 1, 0, null, "users", TokenUser.rootToken());
if (items === null || items === undefined || items.length === 0) { return null; }
var result: User = User.assign(items[0]);
await result.DecorateWithRoles();
return result;
}
public async SetPassword(password: string): Promise<void> {
this.passwordhash = await Crypt.hash(password);
if (!(this.ValidatePassword(password))) { throw new Error("Failed validating password after hasing"); }
console.log(password + " / " + this.passwordhash);
}
public async ValidatePassword(password: string): Promise<boolean> {
console.log(password + " / " + this.passwordhash);
return await Crypt.compare(password, this.passwordhash);
}
public async DecorateWithRoles(): Promise<void> {
let query: any = { _type: "role" };
var _roles: Role[] = await Config.db.query<Role>(query, null, 500, 0, null, "users", TokenUser.rootToken());
if (_roles.length === 0 && this.username !== "root") {
throw new Error("System has no roles !!!!!!");
}
this.roles = [];
_roles.forEach(role => {
var isMember: number = -1;
if (role.members !== undefined) { isMember = role.members.map(function (e: Rolemember): string { return e._id; }).indexOf(this._id); }
var beenAdded: number = this.roles.map(function (e: Rolemember): string { return e._id; }).indexOf(this._id);
if (isMember > -1 && beenAdded === -1) {
this.roles.push(new Rolemember(role.name, role._id));
}
});
let foundone: boolean = true;
while (foundone) {
foundone = false;
this.roles.forEach(userrole => {
_roles.forEach(role => {
var isMember: number = -1;
if (role.members !== undefined) { isMember = role.members.map(function (e: Rolemember): string { return e._id; }).indexOf(userrole._id); }
var beenAdded: number = this.roles.map(function (e: Rolemember): string { return e._id; }).indexOf(role._id);
if (isMember > -1 && beenAdded === -1) {
this.roles.push(new Rolemember(role.name, role._id));
foundone = true;
}
});
});
}
}
public static async ensureUser(name: string, username: string, password: string, id: string): Promise<User> {
var user: User = await User.FindByUsernameOrId(username, id);
if (user !== null && (user._id === id || id === null)) { return user; }
if (user !== null && id !== null) { await Config.db.DeleteOne(user._id, "users", TokenUser.rootToken()); }
user = new User(); user._id = id; user.name = name; user.username = username;
if (password === null || password === undefined || password === "") { password = Math.random().toString(36).substr(2, 9); }
await user.SetPassword(password);
user = await Config.db.InsertOne(user, "users", 0, false, TokenUser.rootToken());
user = User.assign(user);
return user;
}
}