fix(proto): forgor to commit source

agent/go.mod

@@ -3,7 +3,7 @@ module gitea.d3m0k1d.ru/d3m0k1d/HellreigN/agent
 go 1.26.1
 
 require (
-	gitea.d3m0k1d.ru/d3m0k1d/HellreigN/proto v0.0.0-20260403205628-0f9697f6f32e
+	gitea.d3m0k1d.ru/d3m0k1d/HellreigN/proto v0.0.0-20260403214837-94be9799f47d
 	golang.org/x/sync v0.20.0
 )
 

agent/go.sum

@@ -1,5 +1,9 @@
+gitea.d3m0k1d.ru/d3m0k1d/HellreigN v0.0.0-20260403210401-a6212c89fc0e/go.mod h1:dXlVaOzoQVl3cOgArvPXcMQsoamUiIi4DHwDp7GtzQU=
 gitea.d3m0k1d.ru/d3m0k1d/HellreigN/proto v0.0.0-20260403205628-0f9697f6f32e h1:aMvfJ7c0LvxIiyBy9tJDxIkP0daHbW4ZOx+06JgRM90=
 gitea.d3m0k1d.ru/d3m0k1d/HellreigN/proto v0.0.0-20260403205628-0f9697f6f32e/go.mod h1:1DByetpOnW2+AjM8ZWbJ1Xfzprus8fBie2AMUP/YHHA=
+gitea.d3m0k1d.ru/d3m0k1d/HellreigN/proto v0.0.0-20260403210401-a6212c89fc0e/go.mod h1:1DByetpOnW2+AjM8ZWbJ1Xfzprus8fBie2AMUP/YHHA=
+gitea.d3m0k1d.ru/d3m0k1d/HellreigN/proto v0.0.0-20260403214837-94be9799f47d h1:oBBLU8/nhXgOr0Z/M/t4pYj3KjuRj8AI15J0RJCiRt8=
+gitea.d3m0k1d.ru/d3m0k1d/HellreigN/proto v0.0.0-20260403214837-94be9799f47d/go.mod h1:FEPB3qn+wXkes/eArIMdq1/3CbHnSDUxsUtXhC8mgOg=
 github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=
 github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
 github.com/go-logr/logr v1.4.3 h1:CjnDlHq8ikf6E492q6eKboGOC0T8CDaOvkHCIg8idEI=

agent/internal/client/commander.go

@@ -0,0 +1,79 @@
+package client
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"io"
+	"log"
+	"sync"
+
+	"gitea.d3m0k1d.ru/d3m0k1d/HellreigN/agent/internal/commander"
+	"gitea.d3m0k1d.ru/d3m0k1d/HellreigN/proto/proto"
+	"golang.org/x/sync/errgroup"
+	"google.golang.org/grpc"
+	"google.golang.org/grpc/credentials"
+)
+
+type CommanderClient struct {
+	cmder *commander.Commander
+	wg    *sync.WaitGroup
+}
+
+func New(
+	cmder *commander.Commander,
+	wg *sync.WaitGroup,
+) CommanderClient {
+	return CommanderClient{cmder, wg}
+}
+func (self *CommanderClient) HandleCommands(ctx context.Context, srvAddr string, tc credentials.TransportCredentials) error {
+	cli, err := grpc.NewClient(srvAddr, grpc.WithTransportCredentials(tc))
+	if err != nil {
+		return fmt.Errorf("Failed to connect to gRPC: %w", err)
+	}
+	ccli := proto.NewCommanderClient(cli)
+	bidi, err := ccli.Stream(ctx)
+	if err != nil {
+		return err
+	}
+	wg := new(errgroup.Group)
+	wg.Go(self.recv(bidi))
+	// wg.Go(self.send(bidi))
+	err = wg.Wait()
+	self.wg.Wait()
+	return err
+}
+
+func (self *CommanderClient) recv(bidi grpc.BidiStreamingClient[proto.FinishedCommand, proto.Command]) func() error {
+	return func() error {
+		for {
+			msg, err := bidi.Recv()
+			if err != nil {
+				if errors.Is(err, io.EOF) {
+					return nil
+				}
+				return err
+			}
+			self.wg.Go(func() {
+				func() error {
+
+					fc, err := self.cmder.Execute(msg)
+					if err != nil {
+						return err
+					}
+					return bidi.Send(fc)
+				}()
+				if err != nil {
+					log.Println(err)
+				}
+			})
+
+		}
+	}
+}
+
+// func (self *God) send(bidi grpc.BidiStreamingClient[proto.FinishedCommand, proto.Command]) func() error {
+// 	return func() error {
+// 		return nil
+// 	}
+// }

proto/hellreign.proto

@@ -16,7 +16,7 @@ message CollectorResponse {
 }
 
 service Commander {
-	rpc Stream(stream Command) returns (stream FinishedCommand);
+	rpc Stream(stream FinishedCommand) returns (stream Command);
 }
 
 message Command {