opensource/supermq
1
0
Fork 0
mirror of https://github.com/absmach/supermq.git synced 2026-06-23 06:20:18 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

NOISSUE - Update CI tools (#2314)

Browse Source 
Signed-off-by: Dusan Borovcanin <borovcanindusan1@gmail.com>
This commit is contained in:
Dušan Borovčanin
2024-06-25 13:45:11 +02:00
committed by GitHub
parent d19a2e4337
commit be9bc22df4
44 changed files with 132 additions and 104 deletions
Download Patch File Download Diff File Expand all files Collapse all files
.github/workflows/check-generated-files.yml
+4 -4
View File
@@ -79,9 +79,9 @@ jobs:
- name: Set up protoc
if: steps.changes.outputs.proto == 'true'
run: |
PROTOC_VERSION=25.3
PROTOC_GEN_VERSION=v1.32.0
PROTOC_GRPC_VERSION=v1.3.0
PROTOC_VERSION=27.1
PROTOC_GEN_VERSION=v1.34.2
PROTOC_GRPC_VERSION=v1.4.0
# Download and install protoc
PROTOC_ZIP=protoc-$PROTOC_VERSION-linux-x86_64.zip
@@ -118,7 +118,7 @@ jobs:
- name: Check Mocks are up to Date
if: steps.changes.outputs.mocks == 'true'
run: |
MOCKERY_VERSION=v2.42.3
MOCKERY_VERSION=v2.43.2
go install github.com/vektra/mockery/v2@$MOCKERY_VERSION
mv ./pkg/sdk/mocks/sdk.go ./pkg/sdk/mocks/sdk.go.tmp
.github/workflows/tests.yml
+1 -1
View File
@@ -26,7 +26,7 @@ jobs:
- name: golangci-lint
uses: golangci/golangci-lint-action@v6
with:
version: v1.57.2
version: v1.59.1
- name: Build all Binaries
run: |
Makefile
+1 -1
View File
@@ -23,7 +23,7 @@ DOCKER_PROJECT ?= $(shell echo $(subst $(space),,$(USER_REPO)) | tr -c -s '[:aln
DOCKER_COMPOSE_COMMANDS_SUPPORTED := up down config
DEFAULT_DOCKER_COMPOSE_COMMAND := up
GRPC_MTLS_CERT_FILES_EXISTS = 0
MOCKERY_VERSION=v2.42.3
MOCKERY_VERSION=v2.43.2
ifneq ($(MG_MESSAGE_BROKER_TYPE),)
MG_MESSAGE_BROKER_TYPE := $(MG_MESSAGE_BROKER_TYPE)
else
auth.pb.go
+32 -32
View File
@@ -3,8 +3,8 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.32.0
// protoc v4.25.3
// protoc-gen-go v1.34.2
// protoc v5.27.1
// source: auth.proto
package magistrala
@@ -2334,7 +2334,7 @@ func file_auth_proto_rawDescGZIP() []byte {
}
var file_auth_proto_msgTypes = make([]protoimpl.MessageInfo, 26)
var file_auth_proto_goTypes = []interface{}{
var file_auth_proto_goTypes = []any{
(*Token)(nil), // 0: magistrala.Token
(*IdentityReq)(nil), // 1: magistrala.IdentityReq
(*IdentityRes)(nil), // 2: magistrala.IdentityRes
@@ -2410,7 +2410,7 @@ func file_auth_proto_init() {
return
}
if !protoimpl.UnsafeEnabled {
file_auth_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[0].Exporter = func(v any, i int) any {
switch v := v.(*Token); i {
case 0:
return &v.state
@@ -2422,7 +2422,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[1].Exporter = func(v any, i int) any {
switch v := v.(*IdentityReq); i {
case 0:
return &v.state
@@ -2434,7 +2434,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[2].Exporter = func(v any, i int) any {
switch v := v.(*IdentityRes); i {
case 0:
return &v.state
@@ -2446,7 +2446,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[3].Exporter = func(v any, i int) any {
switch v := v.(*IssueReq); i {
case 0:
return &v.state
@@ -2458,7 +2458,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[4].Exporter = func(v any, i int) any {
switch v := v.(*RefreshReq); i {
case 0:
return &v.state
@@ -2470,7 +2470,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[5].Exporter = func(v any, i int) any {
switch v := v.(*AuthorizeReq); i {
case 0:
return &v.state
@@ -2482,7 +2482,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[6].Exporter = func(v any, i int) any {
switch v := v.(*AuthorizeRes); i {
case 0:
return &v.state
@@ -2494,7 +2494,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[7].Exporter = func(v any, i int) any {
switch v := v.(*AddPolicyReq); i {
case 0:
return &v.state
@@ -2506,7 +2506,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[8].Exporter = func(v any, i int) any {
switch v := v.(*AddPoliciesReq); i {
case 0:
return &v.state
@@ -2518,7 +2518,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[9].Exporter = func(v any, i int) any {
switch v := v.(*AddPolicyRes); i {
case 0:
return &v.state
@@ -2530,7 +2530,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[10].Exporter = func(v any, i int) any {
switch v := v.(*AddPoliciesRes); i {
case 0:
return &v.state
@@ -2542,7 +2542,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[11].Exporter = func(v any, i int) any {
switch v := v.(*DeletePolicyFilterReq); i {
case 0:
return &v.state
@@ -2554,7 +2554,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[12].Exporter = func(v any, i int) any {
switch v := v.(*DeletePolicyFilterRes); i {
case 0:
return &v.state
@@ -2566,7 +2566,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[13].Exporter = func(v any, i int) any {
switch v := v.(*DeletePoliciesReq); i {
case 0:
return &v.state
@@ -2578,7 +2578,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[14].Exporter = func(v any, i int) any {
switch v := v.(*DeletePolicyReq); i {
case 0:
return &v.state
@@ -2590,7 +2590,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[15].Exporter = func(v any, i int) any {
switch v := v.(*DeletePoliciesRes); i {
case 0:
return &v.state
@@ -2602,7 +2602,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[16].Exporter = func(v any, i int) any {
switch v := v.(*ListObjectsReq); i {
case 0:
return &v.state
@@ -2614,7 +2614,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[17].Exporter = func(v any, i int) any {
switch v := v.(*ListObjectsRes); i {
case 0:
return &v.state
@@ -2626,7 +2626,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[18].Exporter = func(v any, i int) any {
switch v := v.(*CountObjectsReq); i {
case 0:
return &v.state
@@ -2638,7 +2638,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[19].Exporter = func(v any, i int) any {
switch v := v.(*CountObjectsRes); i {
case 0:
return &v.state
@@ -2650,7 +2650,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[20].Exporter = func(v any, i int) any {
switch v := v.(*ListSubjectsReq); i {
case 0:
return &v.state
@@ -2662,7 +2662,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[21].Exporter = func(v any, i int) any {
switch v := v.(*ListSubjectsRes); i {
case 0:
return &v.state
@@ -2674,7 +2674,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[22].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[22].Exporter = func(v any, i int) any {
switch v := v.(*CountSubjectsReq); i {
case 0:
return &v.state
@@ -2686,7 +2686,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[23].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[23].Exporter = func(v any, i int) any {
switch v := v.(*CountSubjectsRes); i {
case 0:
return &v.state
@@ -2698,7 +2698,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[24].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[24].Exporter = func(v any, i int) any {
switch v := v.(*ListPermissionsReq); i {
case 0:
return &v.state
@@ -2710,7 +2710,7 @@ func file_auth_proto_init() {
return nil
}
}
file_auth_proto_msgTypes[25].Exporter = func(v interface{}, i int) interface{} {
file_auth_proto_msgTypes[25].Exporter = func(v any, i int) any {
switch v := v.(*ListPermissionsRes); i {
case 0:
return &v.state
@@ -2723,9 +2723,9 @@ func file_auth_proto_init() {
}
}
}
file_auth_proto_msgTypes[0].OneofWrappers = []interface{}{}
file_auth_proto_msgTypes[3].OneofWrappers = []interface{}{}
file_auth_proto_msgTypes[4].OneofWrappers = []interface{}{}
file_auth_proto_msgTypes[0].OneofWrappers = []any{}
file_auth_proto_msgTypes[3].OneofWrappers = []any{}
file_auth_proto_msgTypes[4].OneofWrappers = []any{}
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
auth/mocks/agent.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
auth/mocks/authz.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
auth/mocks/domains.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
auth/mocks/keys.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
auth/mocks/service.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
auth_grpc.pb.go
+48 -20
View File
@@ -3,8 +3,8 @@
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.3.0
// - protoc v4.25.3
// - protoc-gen-go-grpc v1.4.0
// - protoc v5.27.1
// source: auth.proto
package magistrala
@@ -18,8 +18,8 @@ import (
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
// Requires gRPC-Go v1.62.0 or later.
const _ = grpc.SupportPackageIsVersion8
const (
AuthzService_Authorize_FullMethodName = "/magistrala.AuthzService/Authorize"
@@ -28,6 +28,9 @@ const (
// AuthzServiceClient is the client API for AuthzService 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.
//
// AuthzService is a service that provides authentication and authorization
// functionalities for the things service.
type AuthzServiceClient interface {
// Authorize checks if the subject is authorized to perform
// the action on the object.
@@ -43,8 +46,9 @@ func NewAuthzServiceClient(cc grpc.ClientConnInterface) AuthzServiceClient {
}
func (c *authzServiceClient) Authorize(ctx context.Context, in *AuthorizeReq, opts ...grpc.CallOption) (*AuthorizeRes, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(AuthorizeRes)
err := c.cc.Invoke(ctx, AuthzService_Authorize_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, AuthzService_Authorize_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -54,6 +58,9 @@ func (c *authzServiceClient) Authorize(ctx context.Context, in *AuthorizeReq, op
// AuthzServiceServer is the server API for AuthzService service.
// All implementations must embed UnimplementedAuthzServiceServer
// for forward compatibility
//
// AuthzService is a service that provides authentication and authorization
// functionalities for the things service.
type AuthzServiceServer interface {
// Authorize checks if the subject is authorized to perform
// the action on the object.
@@ -136,6 +143,9 @@ const (
// AuthServiceClient is the client API for AuthService 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.
//
// AuthService is a service that provides authentication and authorization
// functionalities for the users service.
type AuthServiceClient interface {
Issue(ctx context.Context, in *IssueReq, opts ...grpc.CallOption) (*Token, error)
Refresh(ctx context.Context, in *RefreshReq, opts ...grpc.CallOption) (*Token, error)
@@ -163,8 +173,9 @@ func NewAuthServiceClient(cc grpc.ClientConnInterface) AuthServiceClient {
}
func (c *authServiceClient) Issue(ctx context.Context, in *IssueReq, opts ...grpc.CallOption) (*Token, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Token)
err := c.cc.Invoke(ctx, AuthService_Issue_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, AuthService_Issue_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -172,8 +183,9 @@ func (c *authServiceClient) Issue(ctx context.Context, in *IssueReq, opts ...grp
}
func (c *authServiceClient) Refresh(ctx context.Context, in *RefreshReq, opts ...grpc.CallOption) (*Token, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Token)
err := c.cc.Invoke(ctx, AuthService_Refresh_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, AuthService_Refresh_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -181,8 +193,9 @@ func (c *authServiceClient) Refresh(ctx context.Context, in *RefreshReq, opts ..
}
func (c *authServiceClient) Identify(ctx context.Context, in *IdentityReq, opts ...grpc.CallOption) (*IdentityRes, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(IdentityRes)
err := c.cc.Invoke(ctx, AuthService_Identify_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, AuthService_Identify_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -190,8 +203,9 @@ func (c *authServiceClient) Identify(ctx context.Context, in *IdentityReq, opts
}
func (c *authServiceClient) Authorize(ctx context.Context, in *AuthorizeReq, opts ...grpc.CallOption) (*AuthorizeRes, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(AuthorizeRes)
err := c.cc.Invoke(ctx, AuthService_Authorize_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, AuthService_Authorize_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -199,8 +213,9 @@ func (c *authServiceClient) Authorize(ctx context.Context, in *AuthorizeReq, opt
}
func (c *authServiceClient) AddPolicy(ctx context.Context, in *AddPolicyReq, opts ...grpc.CallOption) (*AddPolicyRes, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(AddPolicyRes)
err := c.cc.Invoke(ctx, AuthService_AddPolicy_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, AuthService_AddPolicy_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -208,8 +223,9 @@ func (c *authServiceClient) AddPolicy(ctx context.Context, in *AddPolicyReq, opt
}
func (c *authServiceClient) AddPolicies(ctx context.Context, in *AddPoliciesReq, opts ...grpc.CallOption) (*AddPoliciesRes, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(AddPoliciesRes)
err := c.cc.Invoke(ctx, AuthService_AddPolicies_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, AuthService_AddPolicies_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -217,8 +233,9 @@ func (c *authServiceClient) AddPolicies(ctx context.Context, in *AddPoliciesReq,
}
func (c *authServiceClient) DeletePolicyFilter(ctx context.Context, in *DeletePolicyFilterReq, opts ...grpc.CallOption) (*DeletePolicyFilterRes, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(DeletePolicyFilterRes)
err := c.cc.Invoke(ctx, AuthService_DeletePolicyFilter_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, AuthService_DeletePolicyFilter_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -226,8 +243,9 @@ func (c *authServiceClient) DeletePolicyFilter(ctx context.Context, in *DeletePo
}
func (c *authServiceClient) DeletePolicies(ctx context.Context, in *DeletePoliciesReq, opts ...grpc.CallOption) (*DeletePoliciesRes, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(DeletePoliciesRes)
err := c.cc.Invoke(ctx, AuthService_DeletePolicies_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, AuthService_DeletePolicies_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -235,8 +253,9 @@ func (c *authServiceClient) DeletePolicies(ctx context.Context, in *DeletePolici
}
func (c *authServiceClient) ListObjects(ctx context.Context, in *ListObjectsReq, opts ...grpc.CallOption) (*ListObjectsRes, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(ListObjectsRes)
err := c.cc.Invoke(ctx, AuthService_ListObjects_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, AuthService_ListObjects_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -244,8 +263,9 @@ func (c *authServiceClient) ListObjects(ctx context.Context, in *ListObjectsReq,
}
func (c *authServiceClient) ListAllObjects(ctx context.Context, in *ListObjectsReq, opts ...grpc.CallOption) (*ListObjectsRes, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(ListObjectsRes)
err := c.cc.Invoke(ctx, AuthService_ListAllObjects_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, AuthService_ListAllObjects_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -253,8 +273,9 @@ func (c *authServiceClient) ListAllObjects(ctx context.Context, in *ListObjectsR
}
func (c *authServiceClient) CountObjects(ctx context.Context, in *CountObjectsReq, opts ...grpc.CallOption) (*CountObjectsRes, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(CountObjectsRes)
err := c.cc.Invoke(ctx, AuthService_CountObjects_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, AuthService_CountObjects_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -262,8 +283,9 @@ func (c *authServiceClient) CountObjects(ctx context.Context, in *CountObjectsRe
}
func (c *authServiceClient) ListSubjects(ctx context.Context, in *ListSubjectsReq, opts ...grpc.CallOption) (*ListSubjectsRes, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(ListSubjectsRes)
err := c.cc.Invoke(ctx, AuthService_ListSubjects_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, AuthService_ListSubjects_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -271,8 +293,9 @@ func (c *authServiceClient) ListSubjects(ctx context.Context, in *ListSubjectsRe
}
func (c *authServiceClient) ListAllSubjects(ctx context.Context, in *ListSubjectsReq, opts ...grpc.CallOption) (*ListSubjectsRes, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(ListSubjectsRes)
err := c.cc.Invoke(ctx, AuthService_ListAllSubjects_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, AuthService_ListAllSubjects_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -280,8 +303,9 @@ func (c *authServiceClient) ListAllSubjects(ctx context.Context, in *ListSubject
}
func (c *authServiceClient) CountSubjects(ctx context.Context, in *CountSubjectsReq, opts ...grpc.CallOption) (*CountSubjectsRes, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(CountSubjectsRes)
err := c.cc.Invoke(ctx, AuthService_CountSubjects_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, AuthService_CountSubjects_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -289,8 +313,9 @@ func (c *authServiceClient) CountSubjects(ctx context.Context, in *CountSubjects
}
func (c *authServiceClient) ListPermissions(ctx context.Context, in *ListPermissionsReq, opts ...grpc.CallOption) (*ListPermissionsRes, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(ListPermissionsRes)
err := c.cc.Invoke(ctx, AuthService_ListPermissions_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, AuthService_ListPermissions_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -300,6 +325,9 @@ func (c *authServiceClient) ListPermissions(ctx context.Context, in *ListPermiss
// AuthServiceServer is the server API for AuthService service.
// All implementations must embed UnimplementedAuthServiceServer
// for forward compatibility
//
// AuthService is a service that provides authentication and authorization
// functionalities for the users service.
type AuthServiceServer interface {
Issue(context.Context, *IssueReq) (*Token, error)
Refresh(context.Context, *RefreshReq) (*Token, error)
bootstrap/mocks/configs.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
bootstrap/mocks/service.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
certs/mocks/certs.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
certs/mocks/pki.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
certs/mocks/service.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
consumers/notifiers/mocks/notifier.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
consumers/notifiers/mocks/repository.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
consumers/notifiers/mocks/service.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
invitations/mocks/repository.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
invitations/mocks/service.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
lora/mocks/routes.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
mqtt/mocks/events.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
pkg/events/mocks/publisher.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
pkg/events/mocks/subscriber.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
pkg/groups/mocks/repository.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
pkg/groups/mocks/service.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
pkg/messaging/message.pb.go
+4 -4
View File
@@ -3,8 +3,8 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.32.0
// protoc v4.25.3
// protoc-gen-go v1.34.2
// protoc v5.27.1
// source: pkg/messaging/message.proto
package messaging
@@ -144,7 +144,7 @@ func file_pkg_messaging_message_proto_rawDescGZIP() []byte {
}
var file_pkg_messaging_message_proto_msgTypes = make([]protoimpl.MessageInfo, 1)
var file_pkg_messaging_message_proto_goTypes = []interface{}{
var file_pkg_messaging_message_proto_goTypes = []any{
(*Message)(nil), // 0: messaging.Message
}
var file_pkg_messaging_message_proto_depIdxs = []int32{
@@ -161,7 +161,7 @@ func file_pkg_messaging_message_proto_init() {
return
}
if !protoimpl.UnsafeEnabled {
file_pkg_messaging_message_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
file_pkg_messaging_message_proto_msgTypes[0].Exporter = func(v any, i int) any {
switch v := v.(*Message); i {
case 0:
return &v.state
pkg/messaging/mocks/pubsub.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
pkg/oauth2/mocks/provider.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
pkg/sdk/mocks/sdk.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
provision/mocks/service.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
readers/mocks/messages.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
scripts/ci.sh
+5 -5
View File
@@ -4,11 +4,11 @@
# This script contains commands to be executed by the CI tool.
NPROC=$(nproc)
GO_VERSION=1.21.3
PROTOC_VERSION=23.3
PROTOC_GEN_VERSION=v1.31.0
PROTOC_GRPC_VERSION=v1.3.0
GOLANGCI_LINT_VERSION=v1.52.1
GO_VERSION=1.22.4
PROTOC_VERSION=27.1
PROTOC_GEN_VERSION=v1.34.2
PROTOC_GRPC_VERSION=v1.4.0
GOLANGCI_LINT_VERSION=v1.59.1
function version_gt() { test "$(printf '%s\n' "$@" | sort -V | head -n 1)" != "$1"; }
things/mocks/cache.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
things/mocks/repository.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
things/mocks/service.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
twins/mocks/cache.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
twins/mocks/repository.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
twins/mocks/service.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
twins/mocks/states.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
users/mocks/emailer.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
users/mocks/hasher.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
users/mocks/repository.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines
users/mocks/service.go
+1 -1
View File
@@ -1,4 +1,4 @@
// Code generated by mockery v2.42.3. DO NOT EDIT.
// Code generated by mockery v2.43.2. DO NOT EDIT.
// Copyright (c) Abstract Machines