update

CHANGELOG.md

@@ -2,19 +2,30 @@
 
 <!-- ... -->
 
-## v1.7.7~
+## v1.7.8~
 
 *??? ??, ????*
 
 <!-- ... -->
 
+## v1.7.7
+
+*December 11, 2024*
+
+### IMPROVEMENTS
+
+- `pkg/anonymity`: move from pkg/network/anonymity -> pkg/anonymity
+- `pkg/anonymity`: replace network.INode -> adapters.IAdapter
+
+<!-- ... -->
+
 ## v1.7.6
 
 *November 25, 2024*
 
 ### IMPROVEMENTS
 
-- Update `pkg/network/anonymity/queue`: add GetConsumersCap
+- `pkg/network/anonymity/queue`: add GetConsumersCap
 
 ### CHANGES
 

README.md

@@ -55,6 +55,9 @@
 		<a href="https://vk.me/join/6Px6b0Qh/uZIK4ixUYWQm4Krepzq5xbYjYw=">
         	<img src="https://img.shields.io/badge/вконтакте-%232E87FB.svg?&style=for-the-badge&logo=vk&logoColor=white" alt="VKontakte" />
 		</a>
+		<a href="https://t.me/+9Kcxr8NyeU8zZDZi">
+        	<img src="https://img.shields.io/badge/Telegram-2CA5E0?style=for-the-badge&logo=telegram&logoColor=white" alt="Telegram" />
+		</a>
 	</p>
 	About project
 </h2>

build/build.go

@@ -1,3 +1,3 @@
 package build
 
-const CVersion = "v1.7.6"
+const CVersion = "v1.7.7"

pkg/anonymity/adapters/adapter.go

@@ -0,0 +1,36 @@
+package adapters
+
+import (
+	"context"
+
+	net_message "github.com/number571/go-peer/pkg/network/message"
+)
+
+var (
+	_ IAdapter = &sAdapter{}
+)
+
+type (
+	iProducerF func(context.Context, net_message.IMessage) error
+	iConsumerF func(context.Context) (net_message.IMessage, error)
+)
+
+type sAdapter struct {
+	fProduce iProducerF
+	fConsume iConsumerF
+}
+
+func NewAdapterByFuncs(pProduce iProducerF, pConsume iConsumerF) IAdapter {
+	return &sAdapter{
+		fProduce: pProduce,
+		fConsume: pConsume,
+	}
+}
+
+func (p *sAdapter) Produce(pCtx context.Context, pMsg net_message.IMessage) error {
+	return p.fProduce(pCtx, pMsg)
+}
+
+func (p *sAdapter) Consume(pCtx context.Context) (net_message.IMessage, error) {
+	return p.fConsume(pCtx)
+}

pkg/anonymity/adapters/adapters_test.go

@@ -0,0 +1,50 @@
+package adapters
+
+import (
+	"bytes"
+	"context"
+	"testing"
+
+	"github.com/number571/go-peer/pkg/network/message"
+	"github.com/number571/go-peer/pkg/payload"
+)
+
+const (
+	tcMessage = "hello, world!"
+)
+
+func TestAdapter(t *testing.T) {
+	msgChan := make(chan message.IMessage, 1)
+	adapter := NewAdapterByFuncs(
+		func(_ context.Context, msg message.IMessage) error {
+			msgChan <- msg
+			return nil
+		},
+		func(_ context.Context) (message.IMessage, error) {
+			return <-msgChan, nil
+		},
+	)
+
+	ctx := context.Background()
+
+	err := adapter.Produce(ctx, message.NewMessage(
+		message.NewConstructSettings(&message.SConstructSettings{
+			FSettings: message.NewSettings(&message.SSettings{}),
+		}),
+		payload.NewPayload32(0x01, []byte(tcMessage)),
+	))
+	if err != nil {
+		t.Error(err)
+		return
+	}
+
+	msg, err := adapter.Consume(ctx)
+	if err != nil {
+		t.Error(err)
+		return
+	}
+	if !bytes.Equal(msg.GetPayload().GetBody(), []byte(tcMessage)) {
+		t.Error("consume invalid message")
+		return
+	}
+}

pkg/anonymity/adapters/types.go

@@ -0,0 +1,20 @@
+package adapters
+
+import (
+	"context"
+
+	net_message "github.com/number571/go-peer/pkg/network/message"
+)
+
+type IAdapter interface {
+	IProducer
+	IConsumer
+}
+
+type IProducer interface {
+	Produce(context.Context, net_message.IMessage) error
+}
+
+type IConsumer interface {
+	Consume(context.Context) (net_message.IMessage, error)
+}