add: session_manager

index.js

@@ -13,7 +13,11 @@ export {
  input_processor,
  form_processor,
 
- format_message
+ format_message,
+
+ InMemorySessionManager,
+
+ process_w_session
 }
 
 /**
@@ -674,4 +678,71 @@ function format_message(message, parameters){
  }
 
  return result;
+}
+
+
+class InMemorySessionManager {
+ #sessions = new Map();
+
+ /**
+ * 
+ * @param {string} identifier 
+ * @returns {object}
+ */
+ get_session(identifier){
+ return this.#sessions.get(identifier);
+ }
+
+ /**
+ * 
+ * @param {string} identifier 
+ * @param {string} message 
+ * @param {object} parameters 
+ */
+ save_session(identifier, message, parameters){
+ this.#sessions.set(identifier, {message: message, parameters: parameters});
+ }
+
+ /**
+ * 
+ * @param {identifier} identifier 
+ */
+ close(identifier){
+ this.#sessions.delete(identifier);
+ }
+
+ get sessions(){
+ return this.#sessions;
+ }
+}
+
+
+/**
+ * 
+ * @param {__lottus} bot 
+ * @param {InMemorySessionManager} session_manager 
+ * @param {string} identifier 
+ * @param {object} request 
+ * @returns {object}
+ */
+async function process_w_session(bot, session_manager, identifier, request){
+ let session = session_manager.get_session(identifier);
+
+ if(!session){
+ session = {message: null, parameters: null};
+ }
+
+ if(session.parameters){
+ request.parameters = {...request.parameters, ...session.parameters};
+ }
+
+ session.message = await bot.process(request, session.message);
+ session.parameters = {...session.parameters, ...session.message.parameters};
+ session_manager.save_session(identifier, session.message, session.parameters);
+
+ if(session.message.close){
+ session_manager.close(identifier);
+ }
+
+ return session;
 }