Feat/#7/localmessaging (#77)

* [#7] Improved messaging and refactored local messaging

* [#7] Updated gitignore

* [#7] messaging imporvements

* [#75] Fixed the bug

* [#76] Added Go report card

* [#76] Fixed released date

* [#76] Latest Version

* Fixed test case

Author: nandagopalan

.gitignore

@@ -5,4 +5,5 @@
 
 .DS_Store
 
-main.go
+main.go
+log-config.json

README.md

@@ -1,7 +1,7 @@
+[![report](https://img.shields.io/badge/go%20report-A+-brightgreen.svg?style=flat)](https://goreportcard.com/report/oss.nandlabs.io/golly)
 [![testing](https://img.shields.io/github/actions/workflow/status/nandlabs/golly/go_ci.yml?branch=main&event=push&color=228B22)](https://github.com/nandlabs/golly/actions?query=event%3Apush+branch%3Amain+)
-[![release](https://img.shields.io/github/v/release/nandlabs/golly?label=Latest&color=228B22)](https://github.com/nandlabs/golly/releases/latest)
-[![releaseDate](https://img.shields.io/github/release-date/nandlabs/golly?label=Released&color=228B22)](https://github.com/nandlabs/golly/releases/latest)
-![Go Version](https://img.shields.io/github/go-mod/go-version/nandlabs/golly?label=Go&color=00ADD8)
+[![release](https://img.shields.io/github/v/release/nandlabs/golly?label=latest&color=228B22)](https://github.com/nandlabs/golly/releases/latest)
+[![releaseDate](https://img.shields.io/github/release-date/nandlabs/golly?label=released&color=00ADD8)](https://github.com/nandlabs/golly/releases/latest)
 [![godoc](https://godoc.org/oss.nandlabs.io/golly?status.svg)](https://pkg.go.dev/oss.nandlabs.io/golly)
 
 # golly

config/attributes.go

@@ -1,6 +1,6 @@
 package config
 
-// Interface Attirbutes is the interface that represents the attributes of a message
+// Interface Attributes is the interface that represents the attributes of a message
 type Attributes interface {
 	// Set adds a new attribute to the message
 	Set(k string, v any)

config/environment.go

@@ -6,8 +6,8 @@ import (
 	"strconv"
 )
 
-//GetEnvAsString function will fetch the val from environment variable.
-//If the value is absent then it will return defaultVal supplied.
+// GetEnvAsString function will fetch the val from environment variable.
+// If the value is absent then it will return defaultVal supplied.
 func GetEnvAsString(key, defaultVal string) string {
 	if val, ok := os.LookupEnv(key); ok {
 		return val
@@ -16,35 +16,35 @@ func GetEnvAsString(key, defaultVal string) string {
 
 }
 
-//GetEnvAsInt function will fetch the val from environment variable and convert that to an integer.
-//If the value is absent then it will return defaultVal supplied.
+// GetEnvAsInt function will fetch the val from environment variable and convert that to an integer.
+// If the value is absent then it will return defaultVal supplied.
 func GetEnvAsInt(key string, defaultVal int) (int, error) {
 	if val, ok := os.LookupEnv(key); ok {
 		return strconv.Atoi(val)
 	}
 	return defaultVal, nil
 }
 
-//GetEnvAsInt64 function will fetch the val from environment variable and convert that to an integer of 64 bit.
-//If the value is absent then it will return defaultVal supplied.
+// GetEnvAsInt64 function will fetch the val from environment variable and convert that to an integer of 64 bit.
+// If the value is absent then it will return defaultVal supplied.
 func GetEnvAsInt64(key string, defaultVal int64) (int64, error) {
 	if val, ok := os.LookupEnv(key); ok {
 		return strconv.ParseInt(val, 10, 64)
 	}
 	return defaultVal, nil
 }
 
-//GetEnvAsDecimal function will fetch the val from environment variable and convert that to an float64.
-//If the value is absent then it will return defaultVal supplied.
+// GetEnvAsDecimal function will fetch the val from environment variable and convert that to an float64.
+// If the value is absent then it will return defaultVal supplied.
 func GetEnvAsDecimal(key string, defaultVal float64) (float64, error) {
 	if val, ok := os.LookupEnv(key); ok {
 		return strconv.ParseFloat(val, 64)
 	}
 	return defaultVal, nil
 }
 
-//GetEnvAsBool function will fetch the val from environment variable and convert that to an GetEnvAsBool.
-//If the value is absent then it will return defaultVal supplied.
+// GetEnvAsBool function will fetch the val from environment variable and convert that to an GetEnvAsBool.
+// If the value is absent then it will return defaultVal supplied.
 // Valid boolean vals are  1, t, T, TRUE, true, True, 0, f, F, FALSE, false, False.
 func GetEnvAsBool(key string, defaultVal bool) (bool, error) {
 	if val, ok := os.LookupEnv(key); ok {

ioutils/io_utils.go

@@ -5,3 +5,19 @@ import "io"
 var CloserFunc = func(closer io.Closer) {
 	_ = closer.Close()
 }
+
+func IsChanClosed[T any](ch chan T) (closed bool) {
+	select {
+	case <-ch:
+		closed = true
+	default:
+		closed = false
+	}
+	return
+}
+
+func CloseChannel[T any](ch chan T) {
+	if !IsChanClosed(ch) {
+		close(ch)
+	}
+}

l3/doc.go

@@ -1,2 +1,2 @@
-// Packge l3 provides multi level logging for Go applications.
+// Package l3 provides multi level logging for Go applications.
 package l3

l3/l3_config.go

@@ -1,6 +1,6 @@
 package l3
 
-//LogConfig - Configuration & Settings for the logger.
+// LogConfig - Configuration & Settings for the logger.
 type LogConfig struct {
 
 	//Format of the log. valid values are text,json
@@ -38,15 +38,15 @@ type PackageConfig struct {
 	Level string `json:"level" yaml:"level"`
 }
 
-//WriterConfig struct
+// WriterConfig struct
 type WriterConfig struct {
 	//File reference. Non mandatory but one of file or console logger is required.
 	File *FileConfig `json:"file,omitempty" yaml:"file,omitempty"`
 	//Console reference
 	Console *ConsoleConfig `json:"console,omitempty" yaml:"console,omitempty"`
 }
 
-//FileConfig - Configuration of file based logging
+// FileConfig - Configuration of file based logging
 type FileConfig struct {
 	//FilePath for the file based log writer
 	DefaultPath string `json:"defaultPath" yaml:"defaultPath"`

l3/logger.go

@@ -15,10 +15,10 @@ const (
 	Trace
 )
 
-//Level specifies the log level
+// Level specifies the log level
 type Level int
 
-//Levels of the logging by severity
+// Levels of the logging by severity
 var Levels = [...]string{
 	"OFF",
 	"ERROR",
@@ -38,7 +38,7 @@ var LevelsBytes = [...][]byte{
 	[]byte("TRACE"),
 }
 
-//LevelsMap of the logging by Level string Level type
+// LevelsMap of the logging by Level string Level type
 var LevelsMap = map[string]Level{
 	"OFF":   Off,
 	"ERROR": Err,

managers/item_manager_test.go

@@ -28,9 +28,10 @@ func TestItemManager_Items(t *testing.T) {
 	manager.Register("item3", 3)
 
 	items := manager.Items()
-	expectedItems := []int{1, 2, 3}
 
-	assert.Equal(t, expectedItems, items)
+	assert.ListHas(t, 1, items)
+	assert.ListHas(t, 2, items)
+	assert.ListHas(t, 3, items)
 }
 
 func TestItemManager_Items_Empty(t *testing.T) {

messaging/base_message.go

@@ -3,16 +3,22 @@ package messaging
 import (
 	"bytes"
 	"io"
-	"oss.nandlabs.io/golly/codec"
 	"reflect"
+
+	"oss.nandlabs.io/golly/codec"
 )
 
 type BaseMessage struct {
+	id          string
 	headers     map[string]interface{}
 	headerTypes map[string]reflect.Kind
 	body        *bytes.Buffer
 }
 
+func (bm *BaseMessage) Id() string {
+	return bm.id
+}
+
 func (bm *BaseMessage) SetBodyStr(input string) (n int, err error) {
 	n, err = bm.body.WriteString(input)
 	return