Worked on function for adding transaction and components of scheduler and session

Author: PythonHacker24

cmd/laclm/main.go

@@ -13,14 +13,15 @@ import (
 	"github.com/MakeNowJust/heredoc"
 	"github.com/joho/godotenv"
 	"github.com/spf13/cobra"
-	"go.uber.org/zap"
 	"go.uber.org/automaxprocs/maxprocs"
+	"go.uber.org/zap"
 
 	"github.com/PythonHacker24/linux-acl-management-backend/api/routes"
 	"github.com/PythonHacker24/linux-acl-management-backend/config"
 	"github.com/PythonHacker24/linux-acl-management-backend/internal/scheduler"
 	"github.com/PythonHacker24/linux-acl-management-backend/internal/scheduler/fcfs"
 	"github.com/PythonHacker24/linux-acl-management-backend/internal/session"
+	"github.com/PythonHacker24/linux-acl-management-backend/internal/transprocessor"
 	"github.com/PythonHacker24/linux-acl-management-backend/internal/utils"
 )
 
@@ -119,19 +120,28 @@ func run(ctx context.Context) error {
 	)
 
 	/* RULE: complete backend system must initiate before http server starts */
+	
+	/* DATABASE CONNECTIONS MUST BE MADE BEFORE SCHEDULER STARTS */
 
 	/* 
 		initializing schedular 
 		scheduler uses context to quit - part of waitgroup
 		propogates error through error channel
 	*/
 	errCh := make(chan error, 1)
+
+	/* create a session manager */
 	sessionManager := session.NewManager()
 
+	/* create a permissions processor */
+	permProcessor := transprocessor.NewPermProcessor()
+
 	/* currently FCFS scheduler */
-	transSched := fcfs.NewFCFSScheduler(sessionManager)
+	transSched := fcfs.NewFCFSScheduler(sessionManager, permProcessor)
+
+	/* initialize the scheduler */
 	scheduler.InitSchedular(ctx, transSched, &wg, errCh)
-		
+
 	/* setting up http mux and routes */
 	mux := http.NewServeMux()
 

internal/auth/service.go

@@ -73,3 +73,25 @@ func (m *Manager) ExpireSession(username string) {
 	/* remove session from sessionsMap */
 	delete(m.sessionsMap, username)
 }
+
+/* add transaction to a session */
+func (m *Manager) AddTransaction(username string, txn interface{}) error {
+	/* thread safety the manager mutex */
+	m.mutex.Lock()
+	defer m.mutex.Unlock()
+
+	/* get the session from sessions map with O(1) runtime */
+	session, exists := m.sessionsMap[username]
+	if !exists {
+		return fmt.Errorf("Session not found")
+	}
+
+	/* thread safety for the session */
+	session.Mutex.Lock()
+	defer session.Mutex.Unlock()
+
+	/* push transaction into the queue from back */
+	session.TransactionQueue.PushBack(txn)
+
+	return nil
+}

internal/session/manager.go

@@ -36,6 +36,11 @@ func (p *PermProcessor) Process(ctx context.Context, curSession *session.Session
 			)
 			return ctx.Err()
 		default:
+			/*
+				permprocessor hands over transactions to remoteprocessor/localprocessor depending upon request
+				remoteprocessor -> handles permissions on remote servers
+				localprocessor -> handles permissions on local system (where this backend is deployed)
+			*/
 			_ = transaction		
 	}