make vendor

Author: PythonHacker24

api/routes/routes.go

@@ -179,8 +179,8 @@ func RegisterRoutes(mux *http.ServeMux, sessionManager *session.Manager) {
 		),
 	)
 
-	/* 
-		for fetching list of users matching the query in the LDAP server 
+	/*
+		for fetching list of users matching the query in the LDAP server
 		supports URL params: q (Query)
 	*/
 	mux.Handle("GET /users/ldap/search", http.HandlerFunc(
@@ -193,7 +193,7 @@ func RegisterRoutes(mux *http.ServeMux, sessionManager *session.Manager) {
 			allowedHeaders,
 		),
 	))
-	
+
 	/* handle OPTIONS preflight requests for /users/ldap/search */
 	mux.HandleFunc("OPTIONS /users/ldap/search",
 		middleware.CORSMiddleware(
@@ -209,8 +209,8 @@ func RegisterRoutes(mux *http.ServeMux, sessionManager *session.Manager) {
 		),
 	)
 
-	/* 
-		websocket connection for streaming user session data from Redis 
+	/*
+		websocket connection for streaming user session data from Redis
 		supports URL pamars: token (JWT authentication)
 	*/
 	mux.Handle("/users/session", http.HandlerFunc(
@@ -220,8 +220,8 @@ func RegisterRoutes(mux *http.ServeMux, sessionManager *session.Manager) {
 		),
 	))
 
-	/* 
-		websocket connection for streaming user transactions data from Redis 
+	/*
+		websocket connection for streaming user transactions data from Redis
 		supports URL pamars: token (JWT authentication)
 	*/
 	mux.Handle("/users/transactions/results", http.HandlerFunc(
@@ -230,8 +230,8 @@ func RegisterRoutes(mux *http.ServeMux, sessionManager *session.Manager) {
 		),
 	))
 
-	/* 
-		websocket connection for streaming user transactions data from Redis 
+	/*
+		websocket connection for streaming user transactions data from Redis
 		supports URL pamars: token (JWT authentication)
 	*/
 	mux.Handle("/users/transactions/pending", http.HandlerFunc(
@@ -304,7 +304,7 @@ func RegisterRoutes(mux *http.ServeMux, sessionManager *session.Manager) {
 			),
 			allowedOrigin,
 			allowedMethods,
-			allowedHeaders,	
+			allowedHeaders,
 		),
 	))
 

cmd/laclm/main.go

@@ -11,14 +11,14 @@ import (
 	"time"
 
 	"github.com/MakeNowJust/heredoc"
+	"github.com/jackc/pgx/v5/pgxpool"
 	"github.com/joho/godotenv"
 	"github.com/spf13/cobra"
 	"go.uber.org/automaxprocs/maxprocs"
 	"go.uber.org/zap"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/credentials/insecure"
 	"google.golang.org/grpc/keepalive"
-	"github.com/jackc/pgx/v5/pgxpool"
 
 	"github.com/PythonHacker24/linux-acl-management-backend/api/routes"
 	"github.com/PythonHacker24/linux-acl-management-backend/config"

config/app.go

@@ -13,7 +13,7 @@ type App struct {
 	DebugMode      bool   `yaml:"debug_mode,omitempty"`
 	SessionTimeout int    `yaml:"session_timeout,omitempty"`
 	BasePath       string `yaml:"base_path,omitempty"`
-	MaxWorkers	   int 	  `yaml:"max_workers,omitempty"`
+	MaxWorkers     int    `yaml:"max_workers,omitempty"`
 }
 
 /* normalization function */

config/backend_security.go

@@ -11,7 +11,7 @@ type BackendSecurity struct {
 	JWTTokenSecret string `yaml:"jwt_secret_token,omitempty"`
 
 	/* make this obselete */
-	JWTExpiry      int    `yaml:"jwt_expiry,omitempty"`
+	JWTExpiry int `yaml:"jwt_expiry,omitempty"`
 }
 
 /* normalization function */

config/database.go

@@ -10,7 +10,7 @@ import (
 /* database parameters */
 type Database struct {
 	TransactionLogRedis TransactionLogRedis `yaml:"transaction_log_redis,omitempty"`
-	ArchivalPQ			ArchivalPQ			`yaml:"archival_postgres,omitempty"`
+	ArchivalPQ          ArchivalPQ          `yaml:"archival_postgres,omitempty"`
 }
 
 /* transaction log redis parameters */
@@ -22,12 +22,12 @@ type TransactionLogRedis struct {
 
 /* archival PostgreSQL parameters */
 type ArchivalPQ struct {
-	Host		string 	`yaml:"host,omitempty"` 
-	Port		int		`yaml:"port,omitempty"`
-	User		string 	`yaml:"user,omitempty"`
-	Password	string 	`yaml:"password,omitempty"`
-	DBName		string 	`yaml:"dbname,omitempty"`
-	SSLMode		string 	`yaml:"sslmode,omitempty"`
+	Host     string `yaml:"host,omitempty"`
+	Port     int    `yaml:"port,omitempty"`
+	User     string `yaml:"user,omitempty"`
+	Password string `yaml:"password,omitempty"`
+	DBName   string `yaml:"dbname,omitempty"`
+	SSLMode  string `yaml:"sslmode,omitempty"`
 }
 
 /* normalization function for database */
@@ -41,7 +41,7 @@ func (d *Database) Normalize() error {
 	/* check if PostgreSQL parameters are valid */
 	err = d.ArchivalPQ.Normalize()
 	if err != nil {
-		return err 
+		return err
 	}
 
 	return nil
@@ -73,33 +73,33 @@ func (a *ArchivalPQ) Normalize() error {
 
 	/* return localhost if empty */
 	if a.Host == "" {
-        a.Host = "localhost"
-    }
+		a.Host = "localhost"
+	}
 
 	/* return default port if empty */
-    if a.Port == 0 {
-        a.Port = 5432
-    }
+	if a.Port == 0 {
+		a.Port = 5432
+	}
 
 	/* username is mandatory */
-    if a.User == "" {
-        return errors.New("Database username is not set in the configuration.")
-    }
+	if a.User == "" {
+		return errors.New("Database username is not set in the configuration.")
+	}
 
 	/* dbname is mandatory */
-    if a.DBName == "" {
-        return errors.New("Database name (dbname) is not set in the configuration.")
-    }
+	if a.DBName == "" {
+		return errors.New("Database name (dbname) is not set in the configuration.")
+	}
 
 	/* sslmode is disabled by default */
-    if a.SSLMode == "" {
-        a.SSLMode = "disable"
-    }
+	if a.SSLMode == "" {
+		a.SSLMode = "disable"
+	}
 
 	/* empty password but give a warning */
-    if a.Password == "" {
-        fmt.Printf("Warning: Connecting to PostgreSQL without a password. Consider using one for security.\n\n")
-    }
+	if a.Password == "" {
+		fmt.Printf("Warning: Connecting to PostgreSQL without a password. Consider using one for security.\n\n")
+	}
 
-    return nil
+	return nil
 }

internal/auth/handler.go

@@ -44,7 +44,7 @@ func LoginHandler(sessionManager *session.Manager) http.HandlerFunc {
 			return
 		}
 
-		/* 
+		/*
 			check if the session already exists in the manager.
 			if it exists, refresh it's timer and return a jwt token
 		*/
@@ -85,7 +85,7 @@ func LoginHandler(sessionManager *session.Manager) http.HandlerFunc {
 /* handles user logout and expire session */
 func LogoutHandler(sessionManager *session.Manager) http.HandlerFunc {
 	return func(w http.ResponseWriter, r *http.Request) {
-		
+
 		/* authenticate the request through JWT */
 		username, _, err := token.ExtractDataFromRequest(r)
 		if err != nil {

internal/grpcpool/clientpool.go

@@ -8,18 +8,18 @@ import (
 
 /* creates a new client pool */
 func NewClientPool(opts ...grpc.DialOption) *ClientPool {
-    return &ClientPool{
-        conns:       make(map[string]*grpc.ClientConn),
-        dialOptions: opts,
-		stopCh: 	 make(chan struct{}),
-    }
+	return &ClientPool{
+		conns:       make(map[string]*grpc.ClientConn),
+		dialOptions: opts,
+		stopCh:      make(chan struct{}),
+	}
 }
 
-/* 
-	creates a connection to given server 
+/*
+	creates a connection to given server
 	allows multiple connections to be established to daemons for any transactions in execution
 */
-func (p *ClientPool) GetConn(addr string, errCh chan<-error) (*grpc.ClientConn, error) {
+func (p *ClientPool) GetConn(addr string, errCh chan<- error) (*grpc.ClientConn, error) {
 	/* check if connection exists or not */
 	p.mu.RLock()
 	conn, exists := p.conns[addr]
@@ -37,33 +37,33 @@ func (p *ClientPool) GetConn(addr string, errCh chan<-error) (*grpc.ClientConn,
 	/* double check again (might been created between if exists and this line) */
 	conn, exists = p.conns[addr]
 	if exists {
-        return conn, nil
-    }
+		return conn, nil
+	}
 
 	/* create a new client for gRPC server */
 	newConn, err := grpc.NewClient(addr, p.dialOptions...)
-    if err != nil {
+	if err != nil {
 		return nil, fmt.Errorf("failed to add new connection: %w", err)
-    }
+	}
 
 	/* add connection to the pool */
-    p.conns[addr] = newConn
+	p.conns[addr] = newConn
 
 	/*
 		in case of connection issues, it will remove itself from connection pool
-		when connection is demanded again, whole logic written above will be executed again 
+		when connection is demanded again, whole logic written above will be executed again
 	*/
 	go p.MonitorHealth(addr, newConn, errCh)
-	
+
 	/* return connection */
-    return newConn, nil
+	return newConn, nil
 }
 
-/* 
+/*
 	close all connections in the pool
 	call this while error channel exists
 */
-func (p *ClientPool) CloseAll(errCh chan<-error) {
+func (p *ClientPool) CloseAll(errCh chan<- error) {
 	p.mu.Lock()
 	defer p.mu.Unlock()
 

internal/grpcpool/model.go

@@ -1,14 +1,14 @@
 package grpcpool
 
 import (
-	"sync"
 	"google.golang.org/grpc"
+	"sync"
 )
 
 /* gRPC connection pool for daemons */
 type ClientPool struct {
-    mu          sync.RWMutex
-    conns       map[string]*grpc.ClientConn
-    dialOptions []grpc.DialOption
-	stopCh 		chan struct{}
+	mu          sync.RWMutex
+	conns       map[string]*grpc.ClientConn
+	dialOptions []grpc.DialOption
+	stopCh      chan struct{}
 }

internal/grpcpool/monitor.go

@@ -11,9 +11,9 @@ import (
 )
 
 /* monitor gRPC connections */
-func (p *ClientPool) MonitorHealth(addr string, conn *grpc.ClientConn, errCh chan<-error) {
+func (p *ClientPool) MonitorHealth(addr string, conn *grpc.ClientConn, errCh chan<- error) {
 	/* TODO: make it configurable */
-	ticker := time.NewTicker(10 * time.Second)	
+	ticker := time.NewTicker(10 * time.Second)
 	defer ticker.Stop()
 
 	for {
@@ -23,16 +23,16 @@ func (p *ClientPool) MonitorHealth(addr string, conn *grpc.ClientConn, errCh cha
 		case <-ticker.C:
 			ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
 			pingClient := pb.NewPingServiceClient(conn)
-            _, err := pingClient.Ping(ctx, &pb.PingRequest{})
-            cancel()
-			
+			_, err := pingClient.Ping(ctx, &pb.PingRequest{})
+			cancel()
+
 			if err != nil {
-				errCh <- fmt.Errorf("ping failed for daemon at %s: %w", addr, err) 
+				errCh <- fmt.Errorf("ping failed for daemon at %s: %w", addr, err)
 
 				p.mu.Lock()
-                conn.Close()
-                delete(p.conns, addr)
-                p.mu.Unlock()
+				conn.Close()
+				delete(p.conns, addr)
+				p.mu.Unlock()
 
 				return
 			} else {

internal/scheduler/fcfs/fcfs.go

@@ -93,7 +93,7 @@ func (f *FCFSScheduler) Run(ctx context.Context) error {
 
 				/* we assume the transaction has been processed -> updated Redis */
 				transaction.Status = types.StatusSuccess
-				
+
 				/* update duration of transaction execution */
 				elapsed := time.Since(transaction.Timestamp)
 				transaction.DurationMs = elapsed.Milliseconds()