Updated for error channel

PythonHacker24 · PythonHacker24 · commit 5c39313e26e7 · 2025-06-10T01:11:13.000+05:30
diff --git a/internal/transprocessor/perm-processor.go b/internal/transprocessor/perm-processor.go
@@ -12,8 +12,10 @@ import (
 )
 
 /* instanciate new permission processor */
-func NewPermProcessor() *PermProcessor {
-	return &PermProcessor{}
+func NewPermProcessor(errCh chan<-error) *PermProcessor {
+	return &PermProcessor{
+		errCh: errCh,
+	}
 }
 
 /* processor for permissions manager */
@@ -48,7 +50,9 @@ func (p *PermProcessor) Process(ctx context.Context, curSession *session.Session
 
 		/* for testing purposes only */
 		time.Sleep(5 * time.Second)
-		zap.L().Info("Completed Transaction")
+		zap.L().Info("Completed Transaction", 
+			zap.String("ID", transaction.ID.String()),
+		)
 	}
 
 	return nil

Original file line number	Diff line number	Diff line change
`@@ -12,8 +12,10 @@ import (`
`12`	`12`	`)`
`13`	`13`
`14`	`14`	`/* instanciate new permission processor */`
`15`		`-func NewPermProcessor() *PermProcessor {`
`16`		`- return &PermProcessor{}`
	`15`	`+func NewPermProcessor(errCh chan<-error) *PermProcessor {`
	`16`	`+ return &PermProcessor{`
	`17`	`+ errCh: errCh,`
	`18`	`+ }`
`17`	`19`	`}`
`18`	`20`
`19`	`21`	`/* processor for permissions manager */`
`@@ -48,7 +50,9 @@ func (p PermProcessor) Process(ctx context.Context, curSession session.Session`
`48`	`50`
`49`	`51`	`/* for testing purposes only */`
`50`	`52`	`time.Sleep(5 * time.Second)`
`51`		`- zap.L().Info("Completed Transaction")`
	`53`	`+ zap.L().Info("Completed Transaction",`
	`54`	`+ zap.String("ID", transaction.ID.String()),`
	`55`	`+ )`
`52`	`56`	`}`
`53`	`57`
`54`	`58`	`return nil`