github-starred/Socio
2
0
Fork 0
mirror of https://github.com/Rolands-Laucis/Socio.git synced 2026-05-15 14:15:57 -06:00
Code Issues Projects Packages Wiki Activity Actions

extracted out the session class into a new file

Browse source
This commit is contained in:
Rolands 2022-12-08 14:49:45 +02:00
parent 90f95d854d
commit bc86f5e391
2 changed files with 69 additions and 60 deletions
Download patch file Download diff file Expand all files Collapse all files

63
core/core-session.js Normal file
View file

@ -0,0 +1,63 @@
"use strict";
//NB! some fields in these variables are private for safety reasons, but also bcs u shouldnt be altering them, only if through my defined ways. They are mostly expected to be constants.
//whereas public variables are free for you to alter freely at any time during runtime.
//Homo vitae commodatus non donatus est. - Man's life is lent, not given. /Syrus/
export class SocioSession {
//private:
#client_id = null //unique ID for this session for my own purposes
#ws = null
#hooks = {}//table_name:[{id, sql, params}]
#authenticated = false //usually boolean, but can be any truthy or falsy value to show the state of the session. Can be a token or smth for your own use, bcs the client will only receive a boolean
#perms = {} //verb:[tables strings] keeps a dict of access permissions of verb type and to which tables this session has been granted
//public:
ses_id = null //you are free to set this to whatever, so that you can later identify it by any means. Usually set it to whatever your session cookie is for this client on your web server
verbose = true
constructor(client_id = '', browser_ws_conn = null, { verbose = true, default_perms = {} } = {}) {
//private:
this.#client_id = client_id //unique ID for this session for my own purposes
this.#ws = browser_ws_conn
this.#hooks = {} //table_name:[sql strings]
this.#perms = default_perms
//public:
this.verbose = verbose
}
get client_id() { return this.#client_id }
//accepts infinite arguments of data to send and will append these params as new key:val pairs to the parent object
Send(kind = '', ...data) {//data is an array of parameters to this func, where every element (after first) is an object. First param can also not be an object in some cases
if (data.length < 1) soft_error('Not enough arguments to send data! kind;data:', kind, ...data) //the first argument must always be the data to send. Other params may be objects with aditional keys to be added in the future
this.#ws.send(JSON.stringify(Object.assign({}, { kind: kind, data: data[0] }, ...data.slice(1))))
if (this.verbose) info('sent:', kind, data)
}
get hook_tables() { return Object.keys(this.#hooks) }
GetHookObjs(table = '') { return this.#hooks[table] }
RegisterHook(table = '', id = '', sql = '', params = null) { //TODO this is actually very bad
if (this.HasPermFor('SELECT', table))
if (table in this.#hooks && !this.#hooks[table].find((t) => t.sql == sql && t.params == params))
this.#hooks[table].push({ id: id, sql: sql, params: params });
else
this.#hooks[table] = [{ id: id, sql: sql, params: params }];
// log('reg hook', table, this.#hooks[table])
}
get authenticated() { return this.#authenticated }
async Authenticate(auth_func, ...params) { //auth func can return any truthy or falsy value, the client will only receive a boolean, so its safe to set it to some credential or id or smth, as this would be accessible and useful to you when checking the session access to tables
return this.#authenticated = await auth_func(...params)
}
HasPermFor(verb = '', key = '') { return verb in this.#perms && this.#perms[verb].incudes(key) }
AddPermFor(verb = '', key = '') {
if (verb in this.#perms) {
if (!this.#perms[verb].includes(key))
this.#perms[verb].push(key);
}
else this.#perms[verb] = [key];
}
}

66
core/core.js
View file

@ -9,6 +9,7 @@ import { WebSocketServer } from 'ws'; //https://github.com/websockets/ws https:/
import { log, soft_error, info, setPrefix, setShowTime } from '@rolands/log'; setPrefix('Socio'); setShowTime(false); //for my logger
import { QueryIsSelect, ParseQueryTables, SocioArgsParse, SocioArgHas, ParseQueryVerb } from './utils.js'
import { UUID } from './secure.js'
import {SocioSession} from './core-session.js'
//NB! some fields in these variables are private for safety reasons, but also bcs u shouldnt be altering them, only if through my defined ways. They are mostly expected to be constants.
//whereas public variables are free for you to alter freely at any time during runtime.
@ -172,6 +173,11 @@ export class SocioServer{
try{
//a better algo: find all sqls that need to be rerun and run them once, then send result to all sessions that need it. Less DB usage.
const queries = {}
Object.values(this.#sessions).forEach(s => {
})
Object.values(this.#sessions).forEach(async (s) => {
tables.forEach(async (t) => {
if (s.hook_tables.includes(t)) {
@ -245,63 +251,3 @@ export class SocioServer{
else if (this.verbose) info(...args)
}
}
//Homo vitae commodatus non donatus est. - Man's life is lent, not given. /Syrus/
class SocioSession{
//private:
#client_id = null //unique ID for this session for my own purposes
#ws=null
#hooks = {}//table_name:[{id, sql, params}]
#authenticated=false //usually boolean, but can be any truthy or falsy value to show the state of the session. Can be a token or smth for your own use, bcs the client will only receive a boolean
#perms = {} //verb:[tables strings] keeps a dict of access permissions of verb type and to which tables this session has been granted
//public:
ses_id = null //you are free to set this to whatever, so that you can later identify it by any means. Usually set it to whatever your session cookie is for this client on your web server
verbose = true
constructor(client_id = '', browser_ws_conn = null, {verbose = true, default_perms={}} = {}){
//private:
this.#client_id = client_id //unique ID for this session for my own purposes
this.#ws = browser_ws_conn
this.#hooks = {} //table_name:[sql strings]
this.#perms = default_perms
//public:
this.verbose = verbose
}
get client_id(){return this.#client_id}
//accepts infinite arguments of data to send and will append these params as new key:val pairs to the parent object
Send(kind = '', ...data) {//data is an array of parameters to this func, where every element (after first) is an object. First param can also not be an object in some cases
if (data.length < 1) soft_error('Not enough arguments to send data! kind;data:', kind, ...data) //the first argument must always be the data to send. Other params may be objects with aditional keys to be added in the future
this.#ws.send(JSON.stringify(Object.assign({}, { kind: kind, data: data[0] }, ...data.slice(1))))
if (this.verbose) info('sent:',kind, data)
}
get hook_tables(){return Object.keys(this.#hooks)}
GetHookObjs(table = '') { return this.#hooks[table]}
RegisterHook(table = '', id = '', sql = '', params = null) { //TODO this is actually very bad
if (this.HasPermFor('SELECT', table))
if (table in this.#hooks && !this.#hooks[table].find((t) => t.sql == sql && t.params == params))
this.#hooks[table].push({ id: id, sql: sql, params: params });
else
this.#hooks[table] = [{ id: id, sql: sql, params: params }];
// log('reg hook', table, this.#hooks[table])
}
get authenticated(){return this.#authenticated}
async Authenticate(auth_func, ...params) { //auth func can return any truthy or falsy value, the client will only receive a boolean, so its safe to set it to some credential or id or smth, as this would be accessible and useful to you when checking the session access to tables
return this.#authenticated = await auth_func(...params)
}
HasPermFor(verb='', key='') {return verb in this.#perms && this.#perms[verb].incudes(key)}
AddPermFor(verb = '', key = ''){
if (verb in this.#perms) {
if (!this.#perms[verb].includes(key))
this.#perms[verb].push(key);
}
else this.#perms[verb] = [key];
}
}