2019-09-28 21:43:25 -05:00
import * as db from "./database"
2019-12-21 08:59:35 -06:00
import { config } from "./config" ;
2020-06-27 08:34:09 -05:00
import { unlink } from "fs" ;
2019-09-28 21:43:25 -05:00
2020-06-27 08:34:09 -05:00
async function register ( name : string , password : string , confirm : string ) : Promise < object > {
2019-12-21 08:59:35 -06:00
if ( ! config [ 'satyr' ] [ 'registration' ] ) return { "error" : "registration disabled" } ;
2019-10-05 14:34:57 -05:00
if ( name . includes ( ';' ) || name . includes ( ' ' ) || name . includes ( '\'' ) ) return { "error" : "illegal characters" } ;
if ( password !== confirm ) return { "error" : "mismatched passwords" } ;
2019-12-21 08:59:35 -06:00
for ( let i = 0 ; i < config [ ' satyr ' ] [ ' restrictedNames ' ] .length ; i + + ) {
if ( name === config [ 'satyr' ] [ 'restrictedNames' ] [ i ] ) return { "error" : "restricted name" } ;
2019-09-28 21:43:25 -05:00
}
2019-10-05 14:34:57 -05:00
let r : boolean = await db . addUser ( name , password ) ;
2019-10-17 16:01:35 -05:00
if ( r ) {
let k = await db . query ( 'select stream_key from users where username=' + db . raw . escape ( name ) ) ;
return k ;
}
2019-10-05 14:34:57 -05:00
return { "error" : "" } ;
2019-09-28 21:43:25 -05:00
}
2020-06-27 08:34:09 -05:00
async function update ( fields : object ) : Promise < object > {
2019-12-03 19:51:14 -06:00
if ( ! fields [ 'title' ] && ! fields [ 'bio' ] && ( fields [ 'rec' ] !== 'true' && fields [ 'rec' ] !== 'false' ) ) return { "error" : "no valid fields specified" } ;
let qs : string = "" ;
let f : boolean = false ;
if ( fields [ 'title' ] ) { qs += ' user_meta.title=' + db . raw . escape ( fields [ 'title' ] ) ; f = true ; }
if ( fields [ 'bio' ] ) {
if ( f ) qs += ',' ;
qs += ' user_meta.about=' + db . raw . escape ( fields [ 'bio' ] ) ;
f = true ;
}
if ( typeof ( fields [ 'rec' ] ) === 'boolean' || typeof ( fields [ 'rec' ] ) === 'number' ) {
if ( f ) qs += ',' ;
qs += ' users.record_flag=' + db . raw . escape ( fields [ 'rec' ] ) ;
}
await db . query ( 'UPDATE users,user_meta SET' + qs + ' WHERE users.username=' + db . raw . escape ( fields [ 'name' ] ) + ' AND user_meta.username=' + db . raw . escape ( fields [ 'name' ] ) ) ;
2019-10-05 14:34:57 -05:00
return { "success" : "" } ;
2019-09-28 21:43:25 -05:00
}
2020-06-27 08:34:09 -05:00
async function updateChat ( fields : object ) : Promise < object > {
2020-06-26 06:07:33 -05:00
await db . query ( 'UPDATE chat_integration SET xmpp=' + db . raw . escape ( fields [ 'xmpp' ] ) + ', discord=' + db . raw . escape ( fields [ 'discord' ] ) + ', irc=' + db . raw . escape ( fields [ 'irc' ] ) + ', twitch=' + db . raw . escape ( fields [ 'twitch' ] ) + ' WHERE username=' + db . raw . escape ( fields [ 'name' ] ) ) ;
return { "success" : "" } ;
}
2019-09-28 21:43:25 -05:00
2020-06-27 08:34:09 -05:00
async function changepwd ( name : string , password : string , newpwd : string ) : Promise < object > {
2019-12-03 19:51:14 -06:00
if ( ! name || ! password || ! newpwd ) return { "error" : "Insufficient parameters" } ;
2019-10-05 14:34:57 -05:00
let auth : boolean = await db . validatePassword ( name , password ) ;
if ( ! auth ) return { "error" : "Username or Password Incorrect" } ;
let newhash : string = await db . hash ( newpwd ) ;
await db . query ( 'UPDATE users set password_hash=' + db . raw . escape ( newhash ) + 'where username=' + db . raw . escape ( name ) + ' limit 1' ) ;
return { "success" : "" } ;
2019-09-28 21:43:25 -05:00
}
2020-06-27 08:34:09 -05:00
async function changesk ( name : string ) : Promise < object > {
2019-10-05 14:34:57 -05:00
let key : string = await db . genKey ( ) ;
await db . query ( 'UPDATE users set stream_key=' + db . raw . escape ( key ) + 'where username=' + db . raw . escape ( name ) + ' limit 1' ) ;
return { "success" : key } ;
2019-09-28 21:43:25 -05:00
}
2019-12-03 19:51:14 -06:00
async function login ( name : string , password : string ) {
if ( ! name || ! password ) return { "error" : "Insufficient parameters" } ;
let auth : boolean = await db . validatePassword ( name , password ) ;
if ( ! auth ) return { "error" : "Username or Password Incorrect" } ;
return false ;
}
2020-06-27 08:34:09 -05:00
async function deleteVODs ( vodlist : Array < string > , username : string ) : Promise < object > {
for ( var i = 0 ; i < vodlist.length ; i + + ) {
unlink ( './site/live/' + username + '/' + vodlist [ i ] , ( ) = > { } ) ;
}
return { "success" : "" } ;
}
export { register , update , changepwd , changesk , login , updateChat , deleteVODs } ;