Use buf for proto api

api/buf.gen.yaml

+version: v1
+managed:
+  enabled: true
+  go_package_prefix:
+    default: code.fbi.h-da.de/demoquandt/proto-kms/gen/proto/go
+plugins:
+  - plugin: buf.build/grpc/go
+    out: gen/proto/go
+    opt:
+      - paths=source_relative
+  - plugin: buf.build/protocolbuffers/go
+    out: gen/proto/go
+    opt:
+      - paths=source_relative

api/buf.work.yaml

+version: v1
+directories:
+    - kmsetsi
+    - kmsintercom

kmsetsiproto/kmsetsiproto_grpc.pb.go → api/gen/proto/go/kmsetsi/kmsetsiproto_grpc.pb.go

 // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
 // versions:
-// - protoc-gen-go-grpc v1.2.0
-// - protoc             v3.21.12
-// source: kmsetsiproto.proto
+// - protoc-gen-go-grpc v1.3.0
+// - protoc             (unknown)
+// source: kmsetsi/kmsetsiproto.proto
 
-package kmsetsiproto
+package kmsetsi
 
 import (
 	context "context"
@@ -18,6 +18,15 @@ import (
 // Requires gRPC-Go v1.32.0 or later.
 const _ = grpc.SupportPackageIsVersion7
 
+const (
+	KmsETSI_ETSICapabilities_FullMethodName         = "/kmsetsi.KmsETSI/ETSICapabilities"
+	KmsETSI_ETSIGetQuantumInterfaces_FullMethodName = "/kmsetsi.KmsETSI/ETSIGetQuantumInterfaces"
+	KmsETSI_ETSIAddKMSPeer_FullMethodName           = "/kmsetsi.KmsETSI/ETSIAddKMSPeer"
+	KmsETSI_ETSIRemoveKMSPeer_FullMethodName        = "/kmsetsi.KmsETSI/ETSIRemoveKMSPeer"
+	KmsETSI_ETSIGetPeerList_FullMethodName          = "/kmsetsi.KmsETSI/ETSIGetPeerList"
+	KmsETSI_ETSIGetEncryptKeys256Bit_FullMethodName = "/kmsetsi.KmsETSI/ETSIGetEncryptKeys256Bit"
+)
+
 // KmsETSIClient is the client API for KmsETSI service.
 //
 // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
@@ -41,7 +50,7 @@ func NewKmsETSIClient(cc grpc.ClientConnInterface) KmsETSIClient {
 
 func (c *kmsETSIClient) ETSICapabilities(ctx context.Context, in *ETSICapabilitiesRequest, opts ...grpc.CallOption) (*ETSICapabilitiesReply, error) {
 	out := new(ETSICapabilitiesReply)
-	err := c.cc.Invoke(ctx, "/kmsetsiproto.KmsETSI/ETSICapabilities", in, out, opts...)
+	err := c.cc.Invoke(ctx, KmsETSI_ETSICapabilities_FullMethodName, in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -50,7 +59,7 @@ func (c *kmsETSIClient) ETSICapabilities(ctx context.Context, in *ETSICapabiliti
 
 func (c *kmsETSIClient) ETSIGetQuantumInterfaces(ctx context.Context, in *ETSIKMSQuantumInterfaceListRequest, opts ...grpc.CallOption) (*ETSIKMSQuantumInterfaceListReply, error) {
 	out := new(ETSIKMSQuantumInterfaceListReply)
-	err := c.cc.Invoke(ctx, "/kmsetsiproto.KmsETSI/ETSIGetQuantumInterfaces", in, out, opts...)
+	err := c.cc.Invoke(ctx, KmsETSI_ETSIGetQuantumInterfaces_FullMethodName, in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -59,7 +68,7 @@ func (c *kmsETSIClient) ETSIGetQuantumInterfaces(ctx context.Context, in *ETSIKM
 
 func (c *kmsETSIClient) ETSIAddKMSPeer(ctx context.Context, in *ETSIKMSPeerRequest, opts ...grpc.CallOption) (*ETSIKMSPeerReply, error) {
 	out := new(ETSIKMSPeerReply)
-	err := c.cc.Invoke(ctx, "/kmsetsiproto.KmsETSI/ETSIAddKMSPeer", in, out, opts...)
+	err := c.cc.Invoke(ctx, KmsETSI_ETSIAddKMSPeer_FullMethodName, in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -68,7 +77,7 @@ func (c *kmsETSIClient) ETSIAddKMSPeer(ctx context.Context, in *ETSIKMSPeerReque
 
 func (c *kmsETSIClient) ETSIRemoveKMSPeer(ctx context.Context, in *ETSIKMSPeerRequest, opts ...grpc.CallOption) (*ETSIKMSPeerReply, error) {
 	out := new(ETSIKMSPeerReply)
-	err := c.cc.Invoke(ctx, "/kmsetsiproto.KmsETSI/ETSIRemoveKMSPeer", in, out, opts...)
+	err := c.cc.Invoke(ctx, KmsETSI_ETSIRemoveKMSPeer_FullMethodName, in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -77,7 +86,7 @@ func (c *kmsETSIClient) ETSIRemoveKMSPeer(ctx context.Context, in *ETSIKMSPeerRe
 
 func (c *kmsETSIClient) ETSIGetPeerList(ctx context.Context, in *ETSIKMSPeerListRequest, opts ...grpc.CallOption) (*ETSIKMSPeerListReply, error) {
 	out := new(ETSIKMSPeerListReply)
-	err := c.cc.Invoke(ctx, "/kmsetsiproto.KmsETSI/ETSIGetPeerList", in, out, opts...)
+	err := c.cc.Invoke(ctx, KmsETSI_ETSIGetPeerList_FullMethodName, in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -86,7 +95,7 @@ func (c *kmsETSIClient) ETSIGetPeerList(ctx context.Context, in *ETSIKMSPeerList
 
 func (c *kmsETSIClient) ETSIGetEncryptKeys256Bit(ctx context.Context, in *ETSIGetEncryptKeys256BitRequest, opts ...grpc.CallOption) (*ETSIGetEncryptKeys256BitReply, error) {
 	out := new(ETSIGetEncryptKeys256BitReply)
-	err := c.cc.Invoke(ctx, "/kmsetsiproto.KmsETSI/ETSIGetEncryptKeys256Bit", in, out, opts...)
+	err := c.cc.Invoke(ctx, KmsETSI_ETSIGetEncryptKeys256Bit_FullMethodName, in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -152,7 +161,7 @@ func _KmsETSI_ETSICapabilities_Handler(srv interface{}, ctx context.Context, dec
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: "/kmsetsiproto.KmsETSI/ETSICapabilities",
+		FullMethod: KmsETSI_ETSICapabilities_FullMethodName,
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(KmsETSIServer).ETSICapabilities(ctx, req.(*ETSICapabilitiesRequest))
@@ -170,7 +179,7 @@ func _KmsETSI_ETSIGetQuantumInterfaces_Handler(srv interface{}, ctx context.Cont
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: "/kmsetsiproto.KmsETSI/ETSIGetQuantumInterfaces",
+		FullMethod: KmsETSI_ETSIGetQuantumInterfaces_FullMethodName,
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(KmsETSIServer).ETSIGetQuantumInterfaces(ctx, req.(*ETSIKMSQuantumInterfaceListRequest))
@@ -188,7 +197,7 @@ func _KmsETSI_ETSIAddKMSPeer_Handler(srv interface{}, ctx context.Context, dec f
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: "/kmsetsiproto.KmsETSI/ETSIAddKMSPeer",
+		FullMethod: KmsETSI_ETSIAddKMSPeer_FullMethodName,
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(KmsETSIServer).ETSIAddKMSPeer(ctx, req.(*ETSIKMSPeerRequest))
@@ -206,7 +215,7 @@ func _KmsETSI_ETSIRemoveKMSPeer_Handler(srv interface{}, ctx context.Context, de
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: "/kmsetsiproto.KmsETSI/ETSIRemoveKMSPeer",
+		FullMethod: KmsETSI_ETSIRemoveKMSPeer_FullMethodName,
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(KmsETSIServer).ETSIRemoveKMSPeer(ctx, req.(*ETSIKMSPeerRequest))
@@ -224,7 +233,7 @@ func _KmsETSI_ETSIGetPeerList_Handler(srv interface{}, ctx context.Context, dec
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: "/kmsetsiproto.KmsETSI/ETSIGetPeerList",
+		FullMethod: KmsETSI_ETSIGetPeerList_FullMethodName,
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(KmsETSIServer).ETSIGetPeerList(ctx, req.(*ETSIKMSPeerListRequest))
@@ -242,7 +251,7 @@ func _KmsETSI_ETSIGetEncryptKeys256Bit_Handler(srv interface{}, ctx context.Cont
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: "/kmsetsiproto.KmsETSI/ETSIGetEncryptKeys256Bit",
+		FullMethod: KmsETSI_ETSIGetEncryptKeys256Bit_FullMethodName,
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(KmsETSIServer).ETSIGetEncryptKeys256Bit(ctx, req.(*ETSIGetEncryptKeys256BitRequest))
@@ -254,7 +263,7 @@ func _KmsETSI_ETSIGetEncryptKeys256Bit_Handler(srv interface{}, ctx context.Cont
 // It's only intended for direct use with grpc.RegisterService,
 // and not to be introspected or modified (even as a copy)
 var KmsETSI_ServiceDesc = grpc.ServiceDesc{
-	ServiceName: "kmsetsiproto.KmsETSI",
+	ServiceName: "kmsetsi.KmsETSI",
 	HandlerType: (*KmsETSIServer)(nil),
 	Methods: []grpc.MethodDesc{
 		{
@@ -283,5 +292,5 @@ var KmsETSI_ServiceDesc = grpc.ServiceDesc{
 		},
 	},
 	Streams:  []grpc.StreamDesc{},
-	Metadata: "kmsetsiproto.proto",
+	Metadata: "kmsetsi/kmsetsiproto.proto",
 }

kmsintercomproto/kmsintercom_grpc.pb.go → api/gen/proto/go/kmsintercom/kmsintercom_grpc.pb.go

 // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
 // versions:
-// - protoc-gen-go-grpc v1.2.0
-// - protoc             v3.19.4
-// source: kmsintercom.proto
+// - protoc-gen-go-grpc v1.3.0
+// - protoc             (unknown)
+// source: kmsintercom/kmsintercom.proto
 
-package kmsintercomproto
+package kmsintercom
 
 import (
 	context "context"
@@ -18,6 +18,11 @@ import (
 // Requires gRPC-Go v1.32.0 or later.
 const _ = grpc.SupportPackageIsVersion7
 
+const (
+	KmsTalker_InterComCapabilities_FullMethodName                = "/kmsintercom.KmsTalker/InterComCapabilities"
+	KmsTalker_InterComKeyTransportSessionHandling_FullMethodName = "/kmsintercom.KmsTalker/InterComKeyTransportSessionHandling"
+)
+
 // KmsTalkerClient is the client API for KmsTalker service.
 //
 // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
@@ -36,7 +41,7 @@ func NewKmsTalkerClient(cc grpc.ClientConnInterface) KmsTalkerClient {
 
 func (c *kmsTalkerClient) InterComCapabilities(ctx context.Context, in *InterComCapabilitiesRequest, opts ...grpc.CallOption) (*InterComCapabilitiesReply, error) {
 	out := new(InterComCapabilitiesReply)
-	err := c.cc.Invoke(ctx, "/kmsintercomproto.KmsTalker/InterComCapabilities", in, out, opts...)
+	err := c.cc.Invoke(ctx, KmsTalker_InterComCapabilities_FullMethodName, in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -45,7 +50,7 @@ func (c *kmsTalkerClient) InterComCapabilities(ctx context.Context, in *InterCom
 
 func (c *kmsTalkerClient) InterComKeyTransportSessionHandling(ctx context.Context, in *InterComKeyTransportSessionHandlingRequest, opts ...grpc.CallOption) (*InterComKeyTransportSessionHandlingReply, error) {
 	out := new(InterComKeyTransportSessionHandlingReply)
-	err := c.cc.Invoke(ctx, "/kmsintercomproto.KmsTalker/InterComKeyTransportSessionHandling", in, out, opts...)
+	err := c.cc.Invoke(ctx, KmsTalker_InterComKeyTransportSessionHandling_FullMethodName, in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -94,7 +99,7 @@ func _KmsTalker_InterComCapabilities_Handler(srv interface{}, ctx context.Contex
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: "/kmsintercomproto.KmsTalker/InterComCapabilities",
+		FullMethod: KmsTalker_InterComCapabilities_FullMethodName,
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(KmsTalkerServer).InterComCapabilities(ctx, req.(*InterComCapabilitiesRequest))
@@ -112,7 +117,7 @@ func _KmsTalker_InterComKeyTransportSessionHandling_Handler(srv interface{}, ctx
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: "/kmsintercomproto.KmsTalker/InterComKeyTransportSessionHandling",
+		FullMethod: KmsTalker_InterComKeyTransportSessionHandling_FullMethodName,
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(KmsTalkerServer).InterComKeyTransportSessionHandling(ctx, req.(*InterComKeyTransportSessionHandlingRequest))
@@ -124,7 +129,7 @@ func _KmsTalker_InterComKeyTransportSessionHandling_Handler(srv interface{}, ctx
 // It's only intended for direct use with grpc.RegisterService,
 // and not to be introspected or modified (even as a copy)
 var KmsTalker_ServiceDesc = grpc.ServiceDesc{
-	ServiceName: "kmsintercomproto.KmsTalker",
+	ServiceName: "kmsintercom.KmsTalker",
 	HandlerType: (*KmsTalkerServer)(nil),
 	Methods: []grpc.MethodDesc{
 		{
@@ -137,5 +142,5 @@ var KmsTalker_ServiceDesc = grpc.ServiceDesc{
 		},
 	},
 	Streams:  []grpc.StreamDesc{},
-	Metadata: "kmsintercom.proto",
+	Metadata: "kmsintercom/kmsintercom.proto",
 }

api/kmsetsi/kmsetsi/buf.lock

+# Generated by buf. DO NOT EDIT.
+version: v1

api/kmsetsi/kmsetsi/buf.yaml

+version: v1
+lint:
+  use:
+    - DEFAULT
+breaking:
+  use:
+    - FILE

kmsetsiproto/kmsetsiproto.proto → api/kmsetsi/kmsetsi/kmsetsiproto.proto

 syntax = "proto3";
 
-option go_package = "code.fbi.h-da.de/demoquandt/proto-kms/kmsetsiproto";
-
-package kmsetsiproto;
+package kmsetsi;
 
 service KmsETSI {
 	// Sends a greeting

api/kmsintercom/kmsintercom/buf.lock

+# Generated by buf. DO NOT EDIT.
+version: v1

api/kmsintercom/kmsintercom/buf.yaml

+version: v1
+lint:
+  use:
+    - DEFAULT
+breaking:
+  use:
+    - FILE

kmsintercomproto/kmsintercom.proto → api/kmsintercom/kmsintercom/kmsintercom.proto

 syntax = "proto3";
 
-option go_package = "code.fbi.h-da.de/demoquandt/proto-kms/kmsintercomproto";
-
-package kmsintercomproto;
+package kmsintercom;
 
 service KmsTalker {
 	rpc InterComCapabilities (InterComCapabilitiesRequest) returns (InterComCapabilitiesReply) {}
@@ -14,7 +12,7 @@ service KmsTalker {
 message InterComCapabilitiesRequest {
 	string myKmsName = 1;
   }
-  
+
 // The response message containing the replying kms' name.
 message InterComCapabilitiesReply {
 	string peerKmsName= 1;
@@ -25,9 +23,8 @@ message InterComCapabilitiesReply {
 message InterComKeyTransportSessionHandlingRequest {
 	string requestedKey = 1;
   }
-  
+
 // The response message containing the replying kms' name.
 message InterComKeyTransportSessionHandlingReply {
 	string usedKey = 1;
 }
-

kms/kms.go

@@ -11,8 +11,8 @@ import (
 	"sync"
 	"time"
 
-	pbETSI "code.fbi.h-da.de/demoquandt/proto-kms/kmsetsiproto"
-	pbIC "code.fbi.h-da.de/demoquandt/proto-kms/kmsintercomproto"
+	pbETSI "code.fbi.h-da.de/demoquandt/proto-kms/api/gen/proto/go/kmsetsi"
+	pbIC "code.fbi.h-da.de/demoquandt/proto-kms/api/gen/proto/go/kmsintercom"
 	"code.fbi.h-da.de/demoquandt/proto-kms/quantumlayer"
 	"github.com/google/uuid"
 )

kms/kmsetsi.go

@@ -8,7 +8,7 @@ import (
 	"log"
 	"net"
 
-	pb "code.fbi.h-da.de/demoquandt/proto-kms/kmsetsiproto"
+	pb "code.fbi.h-da.de/demoquandt/proto-kms/api/gen/proto/go/kmsetsi"
 	"google.golang.org/grpc"
 )
 

kms/kmsintercom.go

@@ -7,7 +7,7 @@ import (
 	"log"
 	"net"
 
-	pb "code.fbi.h-da.de/demoquandt/proto-kms/kmsintercomproto"
+	pb "code.fbi.h-da.de/demoquandt/proto-kms/api/gen/proto/go/kmsintercom"
 	"google.golang.org/grpc"
 )
 

kms/kmspeers.go

@@ -6,7 +6,7 @@ import (
 	"net"
 	"time"
 
-	pb "code.fbi.h-da.de/demoquandt/proto-kms/kmsetsiproto"
+	pb "code.fbi.h-da.de/demoquandt/proto-kms/api/gen/proto/go/kmsetsi"
 	"github.com/google/uuid"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/credentials/insecure"
@@ -102,7 +102,6 @@ func (ph *kmsPeer) PeerHandler(kmsName string) {
 		}
 
 	}
-
 }
 
 func (ph *kmsPeer) GetKmsPeerStatus() KmsPeerStatus {

kmsetsiproto/kmsetsiproto.go

-package kmsetsiproto

kmsintercomproto/kmsintercomproto.go

-package kmsintercomproto