diff --git a/client/react-native/common/components/Screens/Settings/Devtools/EventList.js b/client/react-native/common/components/Screens/Settings/Devtools/EventList.js index 41b31c931a..e810a72be8 100644 --- a/client/react-native/common/components/Screens/Settings/Devtools/EventList.js +++ b/client/react-native/common/components/Screens/Settings/Devtools/EventList.js @@ -13,8 +13,9 @@ import { } from '../../../Library' import { QueryReducer } from '../../../../relay' import { colors } from '../../../../constants' -import { fragments, queries } from '../../../../graphql' +import { fragments, mutations, queries } from '../../../../graphql' import { marginLeft, padding } from '../../../../styles' +import Button from '../../../Library/Button' const Item = fragments.Event(({ data, navigation }) => ( { value: 2, label: 'AckedAt is defined' }, ]} /> + diff --git a/client/react-native/common/graphql/mutations/DebugRequeueAll.js b/client/react-native/common/graphql/mutations/DebugRequeueAll.js new file mode 100644 index 0000000000..dfd7e3794c --- /dev/null +++ b/client/react-native/common/graphql/mutations/DebugRequeueAll.js @@ -0,0 +1,15 @@ +import { graphql } from 'react-relay' + +import { commit } from '../../relay' + +const DebugRequeueAllMutation = graphql` + mutation DebugRequeueAllMutation($t: Bool!) { + DebugRequeueAll(T: $t) { + T + } + } +` + +export default { + commit: (input, configs) => commit(DebugRequeueAllMutation, 'DebugRequeueAll', input, configs), +} diff --git a/client/react-native/common/graphql/mutations/index.js b/client/react-native/common/graphql/mutations/index.js index 09af49e630..ee228497f2 100644 --- a/client/react-native/common/graphql/mutations/index.js +++ b/client/react-native/common/graphql/mutations/index.js @@ -7,3 +7,4 @@ export conversationCreate from './ConversationCreate' export conversationAddMessage from './ConversationAddMessage' export conversationInvite from './ConversationInvite' export debugRequeueEvent from './DebugRequeueEvent' +export debugRequeueAll from './DebugRequeueAll' diff --git a/client/react-native/common/schema.graphql b/client/react-native/common/schema.graphql index d340b11f86..363e3c625a 100644 --- a/client/react-native/common/schema.graphql +++ b/client/react-native/common/schema.graphql @@ -780,6 +780,9 @@ type Mutation { DebugRequeueEvent( eventId: ID! ): BertyP2pEventPayload + DebugRequeueAll( + T: Bool! + ): BertyNodeVoidPayload } type Subscription { diff --git a/core/api/node/graphql/graph/generated/generated.go b/core/api/node/graphql/graph/generated/generated.go index 19366e2010..850bf408a1 100644 --- a/core/api/node/graphql/graph/generated/generated.go +++ b/core/api/node/graphql/graph/generated/generated.go @@ -584,6 +584,7 @@ type ComplexityRoot struct { GenerateFakeData func(childComplexity int, T bool) int RunIntegrationTests func(childComplexity int, name string) int DebugRequeueEvent func(childComplexity int, eventId string) int + DebugRequeueAll func(childComplexity int, T bool) int } Query struct { @@ -673,6 +674,7 @@ type MutationResolver interface { GenerateFakeData(ctx context.Context, T bool) (*node.Void, error) RunIntegrationTests(ctx context.Context, name string) (*node.IntegrationTestOutput, error) DebugRequeueEvent(ctx context.Context, eventId string) (*p2p.Event, error) + DebugRequeueAll(ctx context.Context, T bool) (*node.Void, error) } type QueryResolver interface { Node(ctx context.Context, id string) (models.Node, error) @@ -1393,6 +1395,21 @@ func field_Mutation_DebugRequeueEvent_args(rawArgs map[string]interface{}) (map[ } +func field_Mutation_DebugRequeueAll_args(rawArgs map[string]interface{}) (map[string]interface{}, error) { + args := map[string]interface{}{} + var arg0 bool + if tmp, ok := rawArgs["T"]; ok { + var err error + arg0, err = models.UnmarshalBool(tmp) + if err != nil { + return nil, err + } + } + args["T"] = arg0 + return args, nil + +} + func field_Query_node_args(rawArgs map[string]interface{}) (map[string]interface{}, error) { args := map[string]interface{}{} var arg0 string @@ -4760,6 +4777,18 @@ func (e *executableSchema) Complexity(typeName, field string, childComplexity in return e.complexity.Mutation.DebugRequeueEvent(childComplexity, args["eventId"].(string)), true + case "Mutation.DebugRequeueAll": + if e.complexity.Mutation.DebugRequeueAll == nil { + break + } + + args, err := field_Mutation_DebugRequeueAll_args(rawArgs) + if err != nil { + return 0, false + } + + return e.complexity.Mutation.DebugRequeueAll(childComplexity, args["T"].(bool)), true + case "Query.node": if e.complexity.Query.Node == nil { break @@ -16673,6 +16702,8 @@ func (ec *executionContext) _Mutation(ctx context.Context, sel ast.SelectionSet) out.Values[i] = ec._Mutation_RunIntegrationTests(ctx, field) case "DebugRequeueEvent": out.Values[i] = ec._Mutation_DebugRequeueEvent(ctx, field) + case "DebugRequeueAll": + out.Values[i] = ec._Mutation_DebugRequeueAll(ctx, field) default: panic("unknown field " + strconv.Quote(field.Name)) } @@ -17025,6 +17056,37 @@ func (ec *executionContext) _Mutation_DebugRequeueEvent(ctx context.Context, fie return ec._BertyP2pEventPayload(ctx, field.Selections, res) } +// nolint: vetshadow +func (ec *executionContext) _Mutation_DebugRequeueAll(ctx context.Context, field graphql.CollectedField) graphql.Marshaler { + rawArgs := field.ArgumentMap(ec.Variables) + args, err := field_Mutation_DebugRequeueAll_args(rawArgs) + if err != nil { + ec.Error(ctx, err) + return graphql.Null + } + rctx := &graphql.ResolverContext{ + Object: "Mutation", + Args: args, + Field: field, + } + ctx = graphql.WithResolverContext(ctx, rctx) + resTmp := ec.FieldMiddleware(ctx, nil, func(rctx context.Context) (interface{}, error) { + ctx = rctx // use context from middleware stack in children + return ec.resolvers.Mutation().DebugRequeueAll(rctx, args["T"].(bool)) + }) + if resTmp == nil { + return graphql.Null + } + res := resTmp.(*node.Void) + rctx.Result = res + + if res == nil { + return graphql.Null + } + + return ec._BertyNodeVoidPayload(ctx, field.Selections, res) +} + var queryImplementors = []string{"Query"} // nolint: gocyclo, errcheck, gas, goconst @@ -20429,6 +20491,9 @@ type Mutation { DebugRequeueEvent( eventId: ID! ): BertyP2pEventPayload + DebugRequeueAll( + T: Bool! + ): BertyNodeVoidPayload } type Subscription { diff --git a/core/api/node/graphql/resolver.go b/core/api/node/graphql/resolver.go index 93299d3ced..ef1c2c482e 100644 --- a/core/api/node/graphql/resolver.go +++ b/core/api/node/graphql/resolver.go @@ -242,6 +242,10 @@ func (r *mutationResolver) DebugRequeueEvent(ctx context.Context, eventID string }) } +func (r *mutationResolver) DebugRequeueAll(ctx context.Context, T bool) (*node.Void, error) { + return r.client.DebugRequeueAll(ctx, &node.Void{}) +} + type queryResolver struct{ *Resolver } func (r *queryResolver) Node(ctx context.Context, id string) (models.Node, error) { diff --git a/core/api/node/graphql/service.gen.graphql b/core/api/node/graphql/service.gen.graphql index d340b11f86..363e3c625a 100644 --- a/core/api/node/graphql/service.gen.graphql +++ b/core/api/node/graphql/service.gen.graphql @@ -780,6 +780,9 @@ type Mutation { DebugRequeueEvent( eventId: ID! ): BertyP2pEventPayload + DebugRequeueAll( + T: Bool! + ): BertyNodeVoidPayload } type Subscription { diff --git a/core/api/node/service.pb.go b/core/api/node/service.pb.go index 8519c1e02a..6c99f30287 100644 --- a/core/api/node/service.pb.go +++ b/core/api/node/service.pb.go @@ -59,7 +59,7 @@ func (x NullableTrueFalse) String() string { return proto.EnumName(NullableTrueFalse_name, int32(x)) } func (NullableTrueFalse) EnumDescriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{0} + return fileDescriptor_service_6c73ec8858dca0fe, []int{0} } type ProtocolsOutput struct { @@ -73,7 +73,7 @@ func (m *ProtocolsOutput) Reset() { *m = ProtocolsOutput{} } func (m *ProtocolsOutput) String() string { return proto.CompactTextString(m) } func (*ProtocolsOutput) ProtoMessage() {} func (*ProtocolsOutput) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{0} + return fileDescriptor_service_6c73ec8858dca0fe, []int{0} } func (m *ProtocolsOutput) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -120,7 +120,7 @@ func (m *AppVersionOutput) Reset() { *m = AppVersionOutput{} } func (m *AppVersionOutput) String() string { return proto.CompactTextString(m) } func (*AppVersionOutput) ProtoMessage() {} func (*AppVersionOutput) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{1} + return fileDescriptor_service_6c73ec8858dca0fe, []int{1} } func (m *AppVersionOutput) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -167,7 +167,7 @@ func (m *PingDestination) Reset() { *m = PingDestination{} } func (m *PingDestination) String() string { return proto.CompactTextString(m) } func (*PingDestination) ProtoMessage() {} func (*PingDestination) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{2} + return fileDescriptor_service_6c73ec8858dca0fe, []int{2} } func (m *PingDestination) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -215,7 +215,7 @@ func (m *ContactRequestInput) Reset() { *m = ContactRequestInput{} } func (m *ContactRequestInput) String() string { return proto.CompactTextString(m) } func (*ContactRequestInput) ProtoMessage() {} func (*ContactRequestInput) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{3} + return fileDescriptor_service_6c73ec8858dca0fe, []int{3} } func (m *ContactRequestInput) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -270,7 +270,7 @@ func (m *ConversationAddMessageInput) Reset() { *m = ConversationAddMess func (m *ConversationAddMessageInput) String() string { return proto.CompactTextString(m) } func (*ConversationAddMessageInput) ProtoMessage() {} func (*ConversationAddMessageInput) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{4} + return fileDescriptor_service_6c73ec8858dca0fe, []int{4} } func (m *ConversationAddMessageInput) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -324,7 +324,7 @@ func (m *EventStreamInput) Reset() { *m = EventStreamInput{} } func (m *EventStreamInput) String() string { return proto.CompactTextString(m) } func (*EventStreamInput) ProtoMessage() {} func (*EventStreamInput) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{5} + return fileDescriptor_service_6c73ec8858dca0fe, []int{5} } func (m *EventStreamInput) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -376,7 +376,7 @@ func (m *EventListInput) Reset() { *m = EventListInput{} } func (m *EventListInput) String() string { return proto.CompactTextString(m) } func (*EventListInput) ProtoMessage() {} func (*EventListInput) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{6} + return fileDescriptor_service_6c73ec8858dca0fe, []int{6} } func (m *EventListInput) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -438,7 +438,7 @@ func (m *EventEdge) Reset() { *m = EventEdge{} } func (m *EventEdge) String() string { return proto.CompactTextString(m) } func (*EventEdge) ProtoMessage() {} func (*EventEdge) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{7} + return fileDescriptor_service_6c73ec8858dca0fe, []int{7} } func (m *EventEdge) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -493,7 +493,7 @@ func (m *EventListConnection) Reset() { *m = EventListConnection{} } func (m *EventListConnection) String() string { return proto.CompactTextString(m) } func (*EventListConnection) ProtoMessage() {} func (*EventListConnection) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{8} + return fileDescriptor_service_6c73ec8858dca0fe, []int{8} } func (m *EventListConnection) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -548,7 +548,7 @@ func (m *ContactListInput) Reset() { *m = ContactListInput{} } func (m *ContactListInput) String() string { return proto.CompactTextString(m) } func (*ContactListInput) ProtoMessage() {} func (*ContactListInput) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{9} + return fileDescriptor_service_6c73ec8858dca0fe, []int{9} } func (m *ContactListInput) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -603,7 +603,7 @@ func (m *ContactEdge) Reset() { *m = ContactEdge{} } func (m *ContactEdge) String() string { return proto.CompactTextString(m) } func (*ContactEdge) ProtoMessage() {} func (*ContactEdge) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{10} + return fileDescriptor_service_6c73ec8858dca0fe, []int{10} } func (m *ContactEdge) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -658,7 +658,7 @@ func (m *ContactListConnection) Reset() { *m = ContactListConnection{} } func (m *ContactListConnection) String() string { return proto.CompactTextString(m) } func (*ContactListConnection) ProtoMessage() {} func (*ContactListConnection) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{11} + return fileDescriptor_service_6c73ec8858dca0fe, []int{11} } func (m *ContactListConnection) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -713,7 +713,7 @@ func (m *ConversationListInput) Reset() { *m = ConversationListInput{} } func (m *ConversationListInput) String() string { return proto.CompactTextString(m) } func (*ConversationListInput) ProtoMessage() {} func (*ConversationListInput) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{12} + return fileDescriptor_service_6c73ec8858dca0fe, []int{12} } func (m *ConversationListInput) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -768,7 +768,7 @@ func (m *ConversationEdge) Reset() { *m = ConversationEdge{} } func (m *ConversationEdge) String() string { return proto.CompactTextString(m) } func (*ConversationEdge) ProtoMessage() {} func (*ConversationEdge) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{13} + return fileDescriptor_service_6c73ec8858dca0fe, []int{13} } func (m *ConversationEdge) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -823,7 +823,7 @@ func (m *ConversationListConnection) Reset() { *m = ConversationListConn func (m *ConversationListConnection) String() string { return proto.CompactTextString(m) } func (*ConversationListConnection) ProtoMessage() {} func (*ConversationListConnection) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{14} + return fileDescriptor_service_6c73ec8858dca0fe, []int{14} } func (m *ConversationListConnection) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -879,7 +879,7 @@ func (m *ConversationCreateInput) Reset() { *m = ConversationCreateInput func (m *ConversationCreateInput) String() string { return proto.CompactTextString(m) } func (*ConversationCreateInput) ProtoMessage() {} func (*ConversationCreateInput) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{15} + return fileDescriptor_service_6c73ec8858dca0fe, []int{15} } func (m *ConversationCreateInput) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -941,7 +941,7 @@ func (m *ConversationManageMembersInput) Reset() { *m = ConversationMana func (m *ConversationManageMembersInput) String() string { return proto.CompactTextString(m) } func (*ConversationManageMembersInput) ProtoMessage() {} func (*ConversationManageMembersInput) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{16} + return fileDescriptor_service_6c73ec8858dca0fe, []int{16} } func (m *ConversationManageMembersInput) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1002,7 +1002,7 @@ func (m *Pagination) Reset() { *m = Pagination{} } func (m *Pagination) String() string { return proto.CompactTextString(m) } func (*Pagination) ProtoMessage() {} func (*Pagination) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{17} + return fileDescriptor_service_6c73ec8858dca0fe, []int{17} } func (m *Pagination) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1089,7 +1089,7 @@ func (m *PageInfo) Reset() { *m = PageInfo{} } func (m *PageInfo) String() string { return proto.CompactTextString(m) } func (*PageInfo) ProtoMessage() {} func (*PageInfo) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{18} + return fileDescriptor_service_6c73ec8858dca0fe, []int{18} } func (m *PageInfo) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1164,7 +1164,7 @@ func (m *IntegrationTestInput) Reset() { *m = IntegrationTestInput{} } func (m *IntegrationTestInput) String() string { return proto.CompactTextString(m) } func (*IntegrationTestInput) ProtoMessage() {} func (*IntegrationTestInput) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{19} + return fileDescriptor_service_6c73ec8858dca0fe, []int{19} } func (m *IntegrationTestInput) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1215,7 +1215,7 @@ func (m *IntegrationTestOutput) Reset() { *m = IntegrationTestOutput{} } func (m *IntegrationTestOutput) String() string { return proto.CompactTextString(m) } func (*IntegrationTestOutput) ProtoMessage() {} func (*IntegrationTestOutput) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{20} + return fileDescriptor_service_6c73ec8858dca0fe, []int{20} } func (m *IntegrationTestOutput) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1290,7 +1290,7 @@ func (m *Void) Reset() { *m = Void{} } func (m *Void) String() string { return proto.CompactTextString(m) } func (*Void) ProtoMessage() {} func (*Void) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{21} + return fileDescriptor_service_6c73ec8858dca0fe, []int{21} } func (m *Void) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1337,7 +1337,7 @@ func (m *DebugEventRequeueInput) Reset() { *m = DebugEventRequeueInput{} func (m *DebugEventRequeueInput) String() string { return proto.CompactTextString(m) } func (*DebugEventRequeueInput) ProtoMessage() {} func (*DebugEventRequeueInput) Descriptor() ([]byte, []int) { - return fileDescriptor_service_f3089a28368086f5, []int{22} + return fileDescriptor_service_6c73ec8858dca0fe, []int{22} } func (m *DebugEventRequeueInput) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1439,6 +1439,7 @@ type ServiceClient interface { RunIntegrationTests(ctx context.Context, in *IntegrationTestInput, opts ...grpc.CallOption) (*IntegrationTestOutput, error) DebugPing(ctx context.Context, in *PingDestination, opts ...grpc.CallOption) (*Void, error) DebugRequeueEvent(ctx context.Context, in *DebugEventRequeueInput, opts ...grpc.CallOption) (*p2p.Event, error) + DebugRequeueAll(ctx context.Context, in *Void, opts ...grpc.CallOption) (*Void, error) DeviceInfos(ctx context.Context, in *Void, opts ...grpc.CallOption) (*deviceinfo.DeviceInfos, error) AppVersion(ctx context.Context, in *Void, opts ...grpc.CallOption) (*AppVersionOutput, error) Peers(ctx context.Context, in *Void, opts ...grpc.CallOption) (*p2p.Peers, error) @@ -1748,6 +1749,15 @@ func (c *serviceClient) DebugRequeueEvent(ctx context.Context, in *DebugEventReq return out, nil } +func (c *serviceClient) DebugRequeueAll(ctx context.Context, in *Void, opts ...grpc.CallOption) (*Void, error) { + out := new(Void) + err := c.cc.Invoke(ctx, "/berty.node.Service/DebugRequeueAll", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + func (c *serviceClient) DeviceInfos(ctx context.Context, in *Void, opts ...grpc.CallOption) (*deviceinfo.DeviceInfos, error) { out := new(deviceinfo.DeviceInfos) err := c.cc.Invoke(ctx, "/berty.node.Service/DeviceInfos", in, out, opts...) @@ -1886,6 +1896,7 @@ type ServiceServer interface { RunIntegrationTests(context.Context, *IntegrationTestInput) (*IntegrationTestOutput, error) DebugPing(context.Context, *PingDestination) (*Void, error) DebugRequeueEvent(context.Context, *DebugEventRequeueInput) (*p2p.Event, error) + DebugRequeueAll(context.Context, *Void) (*Void, error) DeviceInfos(context.Context, *Void) (*deviceinfo.DeviceInfos, error) AppVersion(context.Context, *Void) (*AppVersionOutput, error) Peers(context.Context, *Void) (*p2p.Peers, error) @@ -2309,6 +2320,24 @@ func _Service_DebugRequeueEvent_Handler(srv interface{}, ctx context.Context, de return interceptor(ctx, in, info, handler) } +func _Service_DebugRequeueAll_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(Void) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(ServiceServer).DebugRequeueAll(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/berty.node.Service/DebugRequeueAll", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(ServiceServer).DebugRequeueAll(ctx, req.(*Void)) + } + return interceptor(ctx, in, info, handler) +} + func _Service_DeviceInfos_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(Void) if err := dec(in); err != nil { @@ -2517,6 +2546,10 @@ var _Service_serviceDesc = grpc.ServiceDesc{ MethodName: "DebugRequeueEvent", Handler: _Service_DebugRequeueEvent_Handler, }, + { + MethodName: "DebugRequeueAll", + Handler: _Service_DebugRequeueAll_Handler, + }, { MethodName: "DeviceInfos", Handler: _Service_DeviceInfos_Handler, @@ -6754,118 +6787,119 @@ var ( ErrIntOverflowService = fmt.Errorf("proto: integer overflow") ) -func init() { proto.RegisterFile("api/node/service.proto", fileDescriptor_service_f3089a28368086f5) } +func init() { proto.RegisterFile("api/node/service.proto", fileDescriptor_service_6c73ec8858dca0fe) } -var fileDescriptor_service_f3089a28368086f5 = []byte{ - // 1755 bytes of a gzipped FileDescriptorProto +var fileDescriptor_service_6c73ec8858dca0fe = []byte{ + // 1765 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x58, 0xcd, 0x6f, 0xe3, 0xc6, 0x15, 0x5f, 0x6e, 0xa4, 0xb5, 0xf4, 0xe4, 0x5d, 0x6b, 0xc7, 0x1f, 0x91, 0x14, 0xc7, 0xf6, 0xb2, 0x45, 0xeb, 0xba, 0x89, 0x94, 0x6a, 0x81, 0x7e, 0x21, 0x28, 0x60, 0x5b, 0xce, 0xd6, 0x68, 0x9d, 0x3a, 0x5c, 0x77, 0x03, 0x04, 0x05, 0x84, 0x11, 0xf9, 0x44, 0xb1, 0x96, 0x49, 0x86, 0x1c, 0x3a, - 0x36, 0x72, 0x68, 0x2f, 0x05, 0xd2, 0x4b, 0x51, 0xf4, 0xd4, 0x43, 0xff, 0x8a, 0x1e, 0xfa, 0x27, - 0x14, 0x39, 0x16, 0xfb, 0x07, 0xa4, 0xc1, 0xf6, 0xd8, 0x8b, 0x7b, 0xed, 0xa9, 0x98, 0x0f, 0x52, - 0x43, 0x89, 0xd2, 0xee, 0x76, 0x93, 0x93, 0x38, 0x6f, 0xde, 0xe7, 0xef, 0x0d, 0xe7, 0xfd, 0x44, - 0xd8, 0xa0, 0xa1, 0xd7, 0xf1, 0x03, 0x07, 0x3b, 0x31, 0x46, 0x97, 0x9e, 0x8d, 0xed, 0x30, 0x0a, - 0x58, 0x40, 0x60, 0x80, 0x11, 0xbb, 0x6e, 0xf3, 0x9d, 0x96, 0xc9, 0x75, 0x84, 0x78, 0x90, 0x0c, - 0x3b, 0x6e, 0x44, 0xc3, 0xd1, 0xc7, 0xe3, 0xf4, 0x57, 0xea, 0xb7, 0x56, 0x85, 0x4e, 0x37, 0xec, - 0xe0, 0x25, 0xfa, 0x4c, 0x09, 0xd7, 0x53, 0xe1, 0x05, 0xb2, 0xc8, 0xb3, 0x63, 0x25, 0x26, 0xa9, - 0x38, 0x44, 0x8c, 0x94, 0x6c, 0x0d, 0x7d, 0xe6, 0xb1, 0xeb, 0x8e, 0x1d, 0xf8, 0x8c, 0xda, 0xa9, - 0x83, 0xe6, 0x44, 0x7a, 0x89, 0x51, 0x4c, 0x99, 0x17, 0xf8, 0x53, 0x06, 0x17, 0x18, 0xc7, 0xd4, - 0x55, 0x69, 0xb7, 0xb6, 0xc3, 0x73, 0xb7, 0xe3, 0x20, 0x2f, 0xc4, 0xf3, 0x87, 0x81, 0xf6, 0x98, - 0x9a, 0xb9, 0x81, 0x1b, 0x88, 0xc7, 0x0e, 0x7f, 0x4a, 0xcd, 0xdc, 0x20, 0x70, 0xc7, 0x38, 0x29, - 0x92, 0x79, 0x17, 0x18, 0x33, 0x7a, 0x11, 0x4a, 0x05, 0xb3, 0x03, 0x2b, 0xa7, 0xfc, 0xc1, 0x0e, - 0xc6, 0xf1, 0x2f, 0x12, 0x16, 0x26, 0x8c, 0x6c, 0x42, 0x35, 0x4c, 0x45, 0x0d, 0x63, 0xe7, 0xb5, - 0xdd, 0xaa, 0x35, 0x11, 0x98, 0x6f, 0x41, 0x7d, 0x3f, 0x0c, 0x9f, 0x60, 0x14, 0x7b, 0x81, 0xaf, - 0x2c, 0x1a, 0xb0, 0x74, 0x29, 0x05, 0x0d, 0x63, 0xc7, 0xd8, 0xad, 0x5a, 0xe9, 0xd2, 0x7c, 0x08, - 0x2b, 0xa7, 0x9e, 0xef, 0xf6, 0x30, 0x66, 0x9e, 0x2f, 0xaa, 0x24, 0x3b, 0x50, 0x73, 0x26, 0x4b, - 0x65, 0xa0, 0x8b, 0x4c, 0x84, 0xd5, 0x43, 0x89, 0x96, 0x85, 0x1f, 0x27, 0x18, 0xb3, 0x63, 0x9f, - 0x47, 0xe9, 0xc0, 0x92, 0x02, 0x51, 0x18, 0xd5, 0xba, 0xeb, 0x6d, 0xd9, 0x4b, 0x09, 0x58, 0x3b, - 0xb5, 0x49, 0xb5, 0xc8, 0x9b, 0x00, 0x9e, 0xcf, 0xa2, 0xa0, 0xcf, 0xf0, 0x8a, 0x35, 0x6e, 0x8b, - 0x40, 0x55, 0x21, 0x39, 0xc3, 0x2b, 0x66, 0xfe, 0xc1, 0x80, 0x37, 0x0e, 0x35, 0xfc, 0xf7, 0x1d, - 0xe7, 0x44, 0x62, 0x2e, 0xe3, 0xfd, 0x04, 0x96, 0xf5, 0xf6, 0xa8, 0xa0, 0xad, 0x99, 0xa0, 0x99, - 0x86, 0x95, 0xd3, 0xe7, 0xf9, 0xaa, 0x1e, 0x8a, 0xd8, 0x33, 0xf9, 0xaa, 0x60, 0x56, 0xaa, 0x65, - 0xbe, 0x0b, 0xf5, 0x23, 0x7e, 0xc8, 0x1e, 0xb3, 0x08, 0xe9, 0x85, 0x4c, 0x62, 0x17, 0xee, 0x0c, - 0xbd, 0x31, 0xc3, 0x48, 0x85, 0xaf, 0x2b, 0x1f, 0x61, 0x37, 0x6c, 0x0b, 0x65, 0x4b, 0xed, 0x9b, - 0x7f, 0x37, 0xe0, 0x9e, 0x90, 0xfc, 0xdc, 0x4b, 0x11, 0x7b, 0x61, 0x63, 0x72, 0x0a, 0xeb, 0x81, - 0x3f, 0xbe, 0xee, 0x7f, 0xe2, 0xb1, 0x51, 0x90, 0xb0, 0x3e, 0xb5, 0xcf, 0xd1, 0xe9, 0x53, 0x89, - 0xda, 0xbd, 0xee, 0x9b, 0xed, 0xc9, 0x5b, 0xd3, 0x7e, 0x3f, 0x19, 0x8f, 0xe9, 0x60, 0x8c, 0x67, - 0x51, 0x82, 0xef, 0xd1, 0x71, 0x8c, 0x16, 0xe1, 0xb6, 0x1f, 0x4a, 0xd3, 0x7d, 0x6e, 0xb9, 0xcf, - 0xc8, 0x0f, 0xa1, 0x12, 0x52, 0x97, 0xb7, 0x14, 0x1b, 0xb6, 0x88, 0xbe, 0xa1, 0x3b, 0x39, 0x95, - 0x7b, 0x5e, 0xe0, 0x1f, 0x94, 0x6e, 0x6e, 0x9a, 0x86, 0x95, 0x69, 0x9b, 0xc7, 0x50, 0x15, 0xc9, - 0x1d, 0x39, 0x2e, 0x92, 0x6f, 0x42, 0x89, 0xeb, 0xcf, 0x2d, 0x40, 0xec, 0x92, 0x0d, 0xb8, 0x63, - 0x27, 0x51, 0x1c, 0x44, 0xaa, 0xcb, 0x6a, 0x65, 0x7e, 0x0a, 0xab, 0x19, 0x24, 0x87, 0x81, 0xef, - 0xa3, 0x2d, 0x3a, 0xf3, 0x5d, 0x28, 0xa3, 0xe3, 0xa2, 0x3c, 0xdd, 0x93, 0xbe, 0x88, 0xc4, 0xb2, - 0xd0, 0x96, 0xd4, 0x21, 0x3f, 0x80, 0x6a, 0x48, 0x5d, 0xec, 0xf3, 0x77, 0x4d, 0x55, 0xb2, 0x36, - 0x55, 0x09, 0x1e, 0xfb, 0xc3, 0xe0, 0xa0, 0xf4, 0xd9, 0x7f, 0x54, 0x1d, 0x62, 0x6d, 0x7e, 0x0a, - 0x75, 0x75, 0x24, 0x27, 0x1d, 0x79, 0x7b, 0xaa, 0x23, 0x73, 0x8e, 0x70, 0xda, 0x96, 0xff, 0x1f, - 0xc4, 0x53, 0xa8, 0x29, 0x67, 0x02, 0xc6, 0xef, 0xe4, 0x60, 0x9c, 0x13, 0x75, 0x31, 0x96, 0xbf, - 0x81, 0x75, 0xad, 0x1c, 0x0d, 0xcd, 0xb7, 0xf3, 0x68, 0xbe, 0xae, 0x67, 0xa8, 0xe5, 0xf0, 0xca, - 0x78, 0xfe, 0xce, 0x10, 0x19, 0x64, 0x2f, 0xd8, 0x04, 0xd5, 0xee, 0x14, 0xaa, 0x8b, 0xde, 0xd1, - 0x57, 0x87, 0xf6, 0x23, 0xd1, 0xd7, 0xcc, 0xa3, 0xc0, 0xb7, 0x9d, 0xc3, 0x77, 0x51, 0xfc, 0xc5, - 0x20, 0xff, 0xde, 0x80, 0xd6, 0x74, 0x8d, 0x1a, 0xd4, 0xdd, 0x3c, 0xd4, 0x9b, 0x53, 0x50, 0xe7, - 0x72, 0x7a, 0x65, 0xbc, 0xaf, 0xe0, 0x75, 0xdd, 0xe7, 0x61, 0x84, 0x94, 0xa9, 0xab, 0xf1, 0x7b, - 0x50, 0x51, 0x97, 0xec, 0xf4, 0x3b, 0x34, 0x75, 0xa4, 0x32, 0x35, 0xb2, 0x06, 0x65, 0xe6, 0xb1, - 0x31, 0xaa, 0x82, 0xe5, 0x42, 0x48, 0x83, 0xd0, 0xb3, 0x1b, 0xaf, 0x29, 0x29, 0x5f, 0x98, 0x7f, - 0x31, 0x60, 0x4b, 0x0f, 0x7d, 0x42, 0x7d, 0xea, 0xe2, 0x09, 0x5e, 0x0c, 0x30, 0x8a, 0xbf, 0x9a, - 0xcb, 0xf9, 0xc7, 0xfc, 0x72, 0x16, 0xfe, 0x1a, 0xb7, 0x45, 0x01, 0x3b, 0xf3, 0x4d, 0x65, 0x60, - 0x2b, 0x35, 0x30, 0xff, 0x66, 0x00, 0x4c, 0xce, 0x07, 0x69, 0x42, 0x25, 0x88, 0x1c, 0x8c, 0xfa, - 0x83, 0xeb, 0x74, 0xfc, 0x89, 0xf5, 0xc1, 0x35, 0x9f, 0x40, 0x72, 0xcb, 0xc1, 0xd8, 0x16, 0x95, - 0x57, 0xac, 0xaa, 0x90, 0xf4, 0x30, 0xb6, 0x49, 0x0b, 0xca, 0x43, 0x2f, 0x8a, 0x59, 0xa3, 0xb6, - 0x63, 0xec, 0x96, 0x0f, 0x4a, 0xbf, 0xe5, 0x0d, 0x90, 0x22, 0xbe, 0x47, 0x87, 0xfc, 0x48, 0x2f, - 0x73, 0x97, 0xe9, 0x9e, 0x10, 0x91, 0x06, 0x94, 0xc6, 0x34, 0x66, 0x8d, 0xbb, 0x9a, 0x99, 0x90, - 0x90, 0x4d, 0xb8, 0x33, 0xc0, 0x61, 0x10, 0x61, 0xe3, 0x9e, 0x66, 0xa6, 0x64, 0xe6, 0x5f, 0x0d, - 0xa8, 0xa4, 0xed, 0x26, 0x0f, 0x60, 0x39, 0x66, 0x34, 0x62, 0x7d, 0x75, 0x10, 0xd5, 0x20, 0x16, - 0xb2, 0x43, 0x21, 0xe2, 0xe9, 0xa3, 0xef, 0xf4, 0x73, 0x27, 0xb5, 0x8a, 0xbe, 0xa3, 0xb6, 0x4d, - 0xb8, 0x3b, 0xa2, 0x71, 0xdf, 0xc7, 0x2b, 0xd6, 0xe7, 0xa7, 0x46, 0x34, 0xb1, 0x62, 0xd5, 0x46, - 0x34, 0x7e, 0x1f, 0xaf, 0x18, 0x8f, 0x44, 0xf6, 0xe0, 0x3e, 0xd7, 0x09, 0x23, 0xbc, 0xf4, 0x82, - 0x24, 0x96, 0x7a, 0x25, 0xa1, 0xb7, 0x32, 0xa2, 0xf1, 0xa9, 0x92, 0x0b, 0xdd, 0x35, 0x28, 0xdb, - 0x41, 0xe2, 0xb3, 0x46, 0x79, 0xc7, 0xd8, 0xbd, 0x6b, 0xc9, 0x85, 0xb9, 0x07, 0x6b, 0xc7, 0x3e, - 0x43, 0x37, 0x12, 0x68, 0x9f, 0x65, 0x74, 0x80, 0x40, 0xc9, 0xa7, 0x17, 0xa8, 0xf2, 0x16, 0xcf, - 0xe6, 0xbf, 0x0d, 0x58, 0x9f, 0x52, 0x56, 0x14, 0xa5, 0x40, 0x9b, 0xd3, 0x96, 0x38, 0xb1, 0x6d, - 0x8c, 0x63, 0xd5, 0x9a, 0x74, 0xa9, 0x08, 0xcd, 0x20, 0x88, 0x51, 0x1d, 0xcc, 0x74, 0x49, 0x0e, - 0x01, 0x04, 0x42, 0x72, 0x3a, 0x96, 0xd4, 0xa9, 0x93, 0x2c, 0xab, 0x9d, 0xb2, 0xac, 0xf6, 0x59, - 0xca, 0xb2, 0x0e, 0x2a, 0x9f, 0x7f, 0xb1, 0x7d, 0xeb, 0x8f, 0xff, 0xdc, 0x36, 0xac, 0xaa, 0xb2, - 0xdb, 0x67, 0xe4, 0x08, 0x6a, 0x43, 0xcf, 0xf7, 0xe2, 0x91, 0xf4, 0x52, 0x7e, 0x09, 0x2f, 0x90, - 0x1a, 0xee, 0x33, 0x73, 0x0d, 0x4a, 0x4f, 0x02, 0xcf, 0x21, 0xcb, 0x60, 0x9c, 0x89, 0xc2, 0x2a, - 0x96, 0x71, 0x66, 0xf6, 0x60, 0xa3, 0x87, 0x83, 0xc4, 0x95, 0xf3, 0x91, 0x13, 0xa8, 0x44, 0xbd, - 0xb5, 0x7b, 0x50, 0x11, 0x24, 0xb6, 0xef, 0x39, 0x12, 0x87, 0x83, 0x95, 0x2f, 0x6f, 0x9a, 0xc6, - 0xb3, 0x2f, 0xb6, 0x97, 0x84, 0xf2, 0x71, 0xcf, 0x5a, 0x12, 0x0a, 0xc7, 0xce, 0x5e, 0x17, 0xee, - 0xcf, 0xcc, 0x79, 0x52, 0x81, 0x12, 0x17, 0xd6, 0x6f, 0xf1, 0x27, 0x2e, 0xae, 0x1b, 0xa4, 0x0a, - 0x65, 0xb1, 0x59, 0xbf, 0xdd, 0xfd, 0xd3, 0x2a, 0x2c, 0x3d, 0x96, 0x64, 0x9b, 0x74, 0xe1, 0xf6, - 0x71, 0x8f, 0xd4, 0xf5, 0x8b, 0x86, 0xe7, 0xda, 0x5a, 0xd1, 0x26, 0xf8, 0x29, 0x62, 0x64, 0x56, - 0x9f, 0xde, 0x34, 0xcb, 0x1f, 0x24, 0x18, 0x5d, 0x93, 0x0f, 0xa0, 0xa6, 0xf1, 0x1f, 0xb2, 0x39, - 0x33, 0x96, 0x35, 0x62, 0xd4, 0x9a, 0xa1, 0x02, 0x66, 0xfd, 0xe9, 0x4d, 0x73, 0xf9, 0x71, 0x32, - 0x88, 0xed, 0xc8, 0x0b, 0x79, 0xfb, 0xdf, 0x31, 0x88, 0xa7, 0xb8, 0x04, 0xbf, 0x47, 0x49, 0x6b, - 0xc6, 0x61, 0x36, 0x42, 0x0a, 0xdc, 0xbd, 0x95, 0x25, 0xf6, 0xdf, 0x9b, 0xe6, 0x76, 0xa1, 0xe9, - 0xe4, 0x66, 0x7e, 0xc7, 0x20, 0x3f, 0x82, 0xca, 0x23, 0x64, 0x62, 0x8f, 0xcc, 0x78, 0x2b, 0xf0, - 0xaf, 0x15, 0xfe, 0x04, 0xee, 0xe5, 0x09, 0x2f, 0xd9, 0x2e, 0x18, 0xa2, 0x3a, 0x19, 0x6e, 0x15, - 0xdf, 0xb7, 0xe6, 0xf2, 0xd3, 0x9b, 0x66, 0xe5, 0x24, 0x61, 0xf2, 0x66, 0xb2, 0x60, 0x4d, 0x6d, - 0xec, 0xdb, 0x36, 0x86, 0x99, 0xf7, 0x62, 0xe3, 0x17, 0xf3, 0xf9, 0x33, 0xb8, 0x9b, 0xe5, 0x73, - 0x11, 0x5c, 0xe2, 0x57, 0xe4, 0xec, 0x97, 0xa1, 0x43, 0xd9, 0xab, 0x39, 0x63, 0x19, 0xe5, 0x11, - 0xdd, 0xde, 0x2c, 0x80, 0x70, 0xd2, 0xef, 0x39, 0x1e, 0xdb, 0x7a, 0xd3, 0x1f, 0xcc, 0xf1, 0x90, - 0x6b, 0xfb, 0x11, 0xc0, 0x23, 0x64, 0x6a, 0xf7, 0x25, 0xf3, 0xd7, 0x8e, 0x80, 0x0d, 0x64, 0x76, - 0xd8, 0x92, 0x6f, 0xcc, 0x1b, 0xf0, 0xda, 0x30, 0x6e, 0x2d, 0x18, 0x7a, 0x53, 0x08, 0x7d, 0x66, - 0xe4, 0xa9, 0x8b, 0xc0, 0xe9, 0xc1, 0xbc, 0x18, 0x13, 0xb0, 0x16, 0x45, 0x78, 0xa8, 0x23, 0xf6, - 0xad, 0x45, 0xbe, 0x72, 0xb0, 0xfd, 0x3a, 0x5f, 0xef, 0xb1, 0x7f, 0xe9, 0x31, 0x24, 0x7b, 0xf3, - 0xec, 0x67, 0x19, 0xc0, 0x4b, 0x94, 0x7d, 0x2e, 0xfe, 0x4f, 0x4e, 0xc8, 0xd1, 0x95, 0x3d, 0x4e, - 0x9c, 0xaf, 0x2b, 0x18, 0x85, 0x8d, 0xe2, 0x3f, 0x95, 0xe4, 0xdb, 0xf3, 0xe2, 0x4d, 0xfd, 0xf1, - 0x2c, 0xb8, 0x2b, 0xf2, 0x21, 0xce, 0x60, 0x45, 0x1e, 0xb9, 0x09, 0x9d, 0x59, 0x90, 0xdf, 0xc2, - 0xdc, 0xb5, 0x13, 0x38, 0x84, 0xf5, 0x29, 0xaf, 0x12, 0x01, 0xf2, 0x5c, 0x66, 0xd4, 0x7a, 0xae, - 0x86, 0x1e, 0xe7, 0x21, 0xd4, 0x7e, 0x4a, 0x7d, 0x67, 0x8c, 0xcf, 0xbb, 0x2a, 0xb3, 0xa1, 0x61, - 0xde, 0x22, 0x3d, 0xa8, 0x3f, 0x42, 0x1f, 0x23, 0xca, 0xf0, 0x3d, 0x7a, 0x8e, 0x3d, 0xca, 0x68, - 0xc1, 0x70, 0x99, 0xb5, 0xcc, 0x03, 0x37, 0x82, 0x55, 0x2b, 0xf1, 0xa7, 0x08, 0x42, 0x9c, 0x15, - 0x28, 0xcc, 0x8a, 0xb8, 0x46, 0xeb, 0xc1, 0x02, 0x0d, 0x49, 0x30, 0xa6, 0x22, 0xbd, 0x0b, 0x55, - 0x31, 0x84, 0x4f, 0x3d, 0xdf, 0x25, 0x6f, 0xe4, 0xe8, 0x76, 0xfe, 0x73, 0x48, 0x61, 0xb5, 0x1f, - 0xc2, 0x7d, 0x61, 0xad, 0xa6, 0xb7, 0x04, 0xca, 0xd4, 0x15, 0x8b, 0x27, 0xfc, 0x73, 0x4f, 0xce, - 0x09, 0xd4, 0x7a, 0xe2, 0xc3, 0x11, 0x67, 0x80, 0x71, 0x01, 0x82, 0x69, 0xa1, 0xe1, 0xb9, 0xdb, - 0xd6, 0x3e, 0x31, 0x69, 0x46, 0x7a, 0x2b, 0x1f, 0x01, 0x4c, 0xbe, 0x05, 0x15, 0x78, 0xcb, 0x5d, - 0xc1, 0xd3, 0x5f, 0x8d, 0x74, 0x47, 0xdf, 0x87, 0x32, 0x27, 0x03, 0xf1, 0x82, 0x9e, 0xa6, 0x84, - 0x21, 0x97, 0x40, 0x0f, 0xaa, 0xd9, 0xd7, 0x2b, 0x32, 0x4d, 0x2d, 0x5a, 0x79, 0xdc, 0xf3, 0x5f, - 0xb9, 0x74, 0x2f, 0xbf, 0x82, 0xfa, 0x49, 0xe0, 0x7b, 0x2c, 0x88, 0x0e, 0xa8, 0xef, 0x7c, 0xe2, - 0x39, 0x6c, 0x44, 0x9a, 0x9a, 0xb3, 0x4c, 0xfa, 0x98, 0x51, 0x16, 0xb7, 0xe6, 0x6f, 0x15, 0x52, - 0x90, 0x23, 0x58, 0x56, 0xde, 0xe7, 0x95, 0x38, 0xc3, 0x89, 0x8a, 0xdc, 0x70, 0x88, 0xa8, 0xef, - 0xd9, 0x2f, 0x74, 0xec, 0x27, 0xc5, 0x1d, 0xec, 0x7d, 0xfe, 0x6c, 0xcb, 0xf8, 0xc7, 0xb3, 0x2d, - 0xe3, 0xcb, 0x67, 0x5b, 0xc6, 0x9f, 0xff, 0xb5, 0x75, 0xeb, 0xa3, 0x86, 0xd4, 0x66, 0x68, 0x8f, - 0x3a, 0x76, 0x10, 0x61, 0x27, 0xfd, 0x52, 0x3a, 0xb8, 0x23, 0xa8, 0xe7, 0xc3, 0xff, 0x05, 0x00, - 0x00, 0xff, 0xff, 0xc8, 0x14, 0x30, 0xc7, 0x3c, 0x15, 0x00, 0x00, + 0x36, 0x72, 0x68, 0x2f, 0x05, 0xd2, 0x4b, 0xd1, 0x63, 0x0f, 0xfd, 0x2b, 0x7a, 0xe8, 0x9f, 0x50, + 0xe4, 0x58, 0xec, 0xa5, 0xb7, 0x34, 0xd8, 0x1e, 0x7b, 0x71, 0xaf, 0x3d, 0x15, 0xf3, 0x41, 0x6a, + 0x28, 0x51, 0xda, 0xdd, 0x6c, 0x7a, 0x12, 0xe7, 0xcd, 0xfb, 0xfc, 0xbd, 0xe1, 0xbc, 0x9f, 0x08, + 0x1b, 0x34, 0xf4, 0x3a, 0x7e, 0xe0, 0x60, 0x27, 0xc6, 0xe8, 0xd2, 0xb3, 0xb1, 0x1d, 0x46, 0x01, + 0x0b, 0x08, 0x0c, 0x30, 0x62, 0xd7, 0x6d, 0xbe, 0xd3, 0x32, 0xb9, 0x8e, 0x10, 0x0f, 0x92, 0x61, + 0xc7, 0x8d, 0x68, 0x38, 0xfa, 0x78, 0x9c, 0xfe, 0x4a, 0xfd, 0xd6, 0xaa, 0xd0, 0xe9, 0x86, 0x1d, + 0xbc, 0x44, 0x9f, 0x29, 0xe1, 0x7a, 0x2a, 0xbc, 0x40, 0x16, 0x79, 0x76, 0xac, 0xc4, 0x24, 0x15, + 0x87, 0x88, 0x91, 0x92, 0xad, 0xa1, 0xcf, 0x3c, 0x76, 0xdd, 0xb1, 0x03, 0x9f, 0x51, 0x3b, 0x75, + 0xd0, 0x9c, 0x48, 0x2f, 0x31, 0x8a, 0x29, 0xf3, 0x02, 0x7f, 0xca, 0xe0, 0x02, 0xe3, 0x98, 0xba, + 0x2a, 0xed, 0xd6, 0x76, 0x78, 0xee, 0x76, 0x1c, 0xe4, 0x85, 0x78, 0xfe, 0x30, 0xd0, 0x1e, 0x53, + 0x33, 0x37, 0x70, 0x03, 0xf1, 0xd8, 0xe1, 0x4f, 0xa9, 0x99, 0x1b, 0x04, 0xee, 0x18, 0x27, 0x45, + 0x32, 0xef, 0x02, 0x63, 0x46, 0x2f, 0x42, 0xa9, 0x60, 0x76, 0x60, 0xe5, 0x94, 0x3f, 0xd8, 0xc1, + 0x38, 0xfe, 0x45, 0xc2, 0xc2, 0x84, 0x91, 0x4d, 0xa8, 0x86, 0xa9, 0xa8, 0x61, 0xec, 0xbc, 0xb6, + 0x5b, 0xb5, 0x26, 0x02, 0xf3, 0x2d, 0xa8, 0xef, 0x87, 0xe1, 0x13, 0x8c, 0x62, 0x2f, 0xf0, 0x95, + 0x45, 0x03, 0x96, 0x2e, 0xa5, 0xa0, 0x61, 0xec, 0x18, 0xbb, 0x55, 0x2b, 0x5d, 0x9a, 0x0f, 0x61, + 0xe5, 0xd4, 0xf3, 0xdd, 0x1e, 0xc6, 0xcc, 0xf3, 0x45, 0x95, 0x64, 0x07, 0x6a, 0xce, 0x64, 0xa9, + 0x0c, 0x74, 0x91, 0x89, 0xb0, 0x7a, 0x28, 0xd1, 0xb2, 0xf0, 0xe3, 0x04, 0x63, 0x76, 0xec, 0xf3, + 0x28, 0x1d, 0x58, 0x52, 0x20, 0x0a, 0xa3, 0x5a, 0x77, 0xbd, 0x2d, 0x7b, 0x29, 0x01, 0x6b, 0xa7, + 0x36, 0xa9, 0x16, 0x79, 0x13, 0xc0, 0xf3, 0x59, 0x14, 0xf4, 0x19, 0x5e, 0xb1, 0xc6, 0x6d, 0x11, + 0xa8, 0x2a, 0x24, 0x67, 0x78, 0xc5, 0xcc, 0x3f, 0x18, 0xf0, 0xc6, 0xa1, 0x86, 0xff, 0xbe, 0xe3, + 0x9c, 0x48, 0xcc, 0x65, 0xbc, 0x9f, 0xc0, 0xb2, 0xde, 0x1e, 0x15, 0xb4, 0x35, 0x13, 0x34, 0xd3, + 0xb0, 0x72, 0xfa, 0x3c, 0x5f, 0xd5, 0x43, 0x11, 0x7b, 0x26, 0x5f, 0x15, 0xcc, 0x4a, 0xb5, 0xcc, + 0x77, 0xa1, 0x7e, 0xc4, 0x0f, 0xd9, 0x63, 0x16, 0x21, 0xbd, 0x90, 0x49, 0xec, 0xc2, 0x9d, 0xa1, + 0x37, 0x66, 0x18, 0xa9, 0xf0, 0x75, 0xe5, 0x23, 0xec, 0x86, 0x6d, 0xa1, 0x6c, 0xa9, 0x7d, 0xf3, + 0x6f, 0x06, 0xdc, 0x13, 0x92, 0x9f, 0x7b, 0x29, 0x62, 0x2f, 0x6c, 0x4c, 0x4e, 0x61, 0x3d, 0xf0, + 0xc7, 0xd7, 0xfd, 0x4f, 0x3c, 0x36, 0x0a, 0x12, 0xd6, 0xa7, 0xf6, 0x39, 0x3a, 0x7d, 0x2a, 0x51, + 0xbb, 0xd7, 0x7d, 0xb3, 0x3d, 0x79, 0x6b, 0xda, 0xef, 0x27, 0xe3, 0x31, 0x1d, 0x8c, 0xf1, 0x2c, + 0x4a, 0xf0, 0x3d, 0x3a, 0x8e, 0xd1, 0x22, 0xdc, 0xf6, 0x43, 0x69, 0xba, 0xcf, 0x2d, 0xf7, 0x19, + 0xf9, 0x21, 0x54, 0x42, 0xea, 0xf2, 0x96, 0x62, 0xc3, 0x16, 0xd1, 0x37, 0x74, 0x27, 0xa7, 0x72, + 0xcf, 0x0b, 0xfc, 0x83, 0xd2, 0xcd, 0x4d, 0xd3, 0xb0, 0x32, 0x6d, 0xf3, 0x18, 0xaa, 0x22, 0xb9, + 0x23, 0xc7, 0x45, 0xf2, 0x4d, 0x28, 0x71, 0xfd, 0xb9, 0x05, 0x88, 0x5d, 0xb2, 0x01, 0x77, 0xec, + 0x24, 0x8a, 0x83, 0x48, 0x75, 0x59, 0xad, 0xcc, 0x4f, 0x61, 0x35, 0x83, 0xe4, 0x30, 0xf0, 0x7d, + 0xb4, 0x45, 0x67, 0xbe, 0x0b, 0x65, 0x74, 0x5c, 0x94, 0xa7, 0x7b, 0xd2, 0x17, 0x91, 0x58, 0x16, + 0xda, 0x92, 0x3a, 0xe4, 0x07, 0x50, 0x0d, 0xa9, 0x8b, 0x7d, 0xfe, 0xae, 0xa9, 0x4a, 0xd6, 0xa6, + 0x2a, 0xc1, 0x63, 0x7f, 0x18, 0x1c, 0x94, 0x3e, 0xfb, 0x8f, 0xaa, 0x43, 0xac, 0xcd, 0x4f, 0xa1, + 0xae, 0x8e, 0xe4, 0xa4, 0x23, 0x6f, 0x4f, 0x75, 0x64, 0xce, 0x11, 0x4e, 0xdb, 0xf2, 0xd5, 0x41, + 0x3c, 0x85, 0x9a, 0x72, 0x26, 0x60, 0xfc, 0x4e, 0x0e, 0xc6, 0x39, 0x51, 0x17, 0x63, 0xf9, 0x1b, + 0x58, 0xd7, 0xca, 0xd1, 0xd0, 0x7c, 0x3b, 0x8f, 0xe6, 0xeb, 0x7a, 0x86, 0x5a, 0x0e, 0xaf, 0x8c, + 0xe7, 0xef, 0x0c, 0x91, 0x41, 0xf6, 0x82, 0x4d, 0x50, 0xed, 0x4e, 0xa1, 0xba, 0xe8, 0x1d, 0x7d, + 0x75, 0x68, 0x3f, 0x12, 0x7d, 0xcd, 0x3c, 0x0a, 0x7c, 0xdb, 0x39, 0x7c, 0x17, 0xc5, 0x5f, 0x0c, + 0xf2, 0xef, 0x0d, 0x68, 0x4d, 0xd7, 0xa8, 0x41, 0xdd, 0xcd, 0x43, 0xbd, 0x39, 0x05, 0x75, 0x2e, + 0xa7, 0x57, 0xc6, 0xfb, 0x0a, 0x5e, 0xd7, 0x7d, 0x1e, 0x46, 0x48, 0x99, 0xba, 0x1a, 0xbf, 0x07, + 0x15, 0x75, 0xc9, 0x4e, 0xbf, 0x43, 0x53, 0x47, 0x2a, 0x53, 0x23, 0x6b, 0x50, 0x66, 0x1e, 0x1b, + 0xa3, 0x2a, 0x58, 0x2e, 0x84, 0x34, 0x08, 0x3d, 0xbb, 0xf1, 0x9a, 0x92, 0xf2, 0x85, 0xf9, 0x67, + 0x03, 0xb6, 0xf4, 0xd0, 0x27, 0xd4, 0xa7, 0x2e, 0x9e, 0xe0, 0xc5, 0x00, 0xa3, 0xf8, 0xeb, 0xb9, + 0x9c, 0x7f, 0xcc, 0x2f, 0x67, 0xe1, 0xaf, 0x71, 0x5b, 0x14, 0xb0, 0x33, 0xdf, 0x54, 0x06, 0xb6, + 0x52, 0x03, 0xf3, 0xaf, 0x06, 0xc0, 0xe4, 0x7c, 0x90, 0x26, 0x54, 0x82, 0xc8, 0xc1, 0xa8, 0x3f, + 0xb8, 0x4e, 0xc7, 0x9f, 0x58, 0x1f, 0x5c, 0xf3, 0x09, 0x24, 0xb7, 0x1c, 0x8c, 0x6d, 0x51, 0x79, + 0xc5, 0xaa, 0x0a, 0x49, 0x0f, 0x63, 0x9b, 0xb4, 0xa0, 0x3c, 0xf4, 0xa2, 0x98, 0x35, 0x6a, 0x3b, + 0xc6, 0x6e, 0xf9, 0xa0, 0xf4, 0x5b, 0xde, 0x00, 0x29, 0xe2, 0x7b, 0x74, 0xc8, 0x8f, 0xf4, 0x32, + 0x77, 0x99, 0xee, 0x09, 0x11, 0x69, 0x40, 0x69, 0x4c, 0x63, 0xd6, 0xb8, 0xab, 0x99, 0x09, 0x09, + 0xd9, 0x84, 0x3b, 0x03, 0x1c, 0x06, 0x11, 0x36, 0xee, 0x69, 0x66, 0x4a, 0x66, 0xfe, 0xc5, 0x80, + 0x4a, 0xda, 0x6e, 0xf2, 0x00, 0x96, 0x63, 0x46, 0x23, 0xd6, 0x57, 0x07, 0x51, 0x0d, 0x62, 0x21, + 0x3b, 0x14, 0x22, 0x9e, 0x3e, 0xfa, 0x4e, 0x3f, 0x77, 0x52, 0xab, 0xe8, 0x3b, 0x6a, 0xdb, 0x84, + 0xbb, 0x23, 0x1a, 0xf7, 0x7d, 0xbc, 0x62, 0x7d, 0x7e, 0x6a, 0x44, 0x13, 0x2b, 0x56, 0x6d, 0x44, + 0xe3, 0xf7, 0xf1, 0x8a, 0xf1, 0x48, 0x64, 0x0f, 0xee, 0x73, 0x9d, 0x30, 0xc2, 0x4b, 0x2f, 0x48, + 0x62, 0xa9, 0x57, 0x12, 0x7a, 0x2b, 0x23, 0x1a, 0x9f, 0x2a, 0xb9, 0xd0, 0x5d, 0x83, 0xb2, 0x1d, + 0x24, 0x3e, 0x6b, 0x94, 0x77, 0x8c, 0xdd, 0xbb, 0x96, 0x5c, 0x98, 0x7b, 0xb0, 0x76, 0xec, 0x33, + 0x74, 0x23, 0x81, 0xf6, 0x59, 0x46, 0x07, 0x08, 0x94, 0x7c, 0x7a, 0x81, 0x2a, 0x6f, 0xf1, 0x6c, + 0xfe, 0xdb, 0x80, 0xf5, 0x29, 0x65, 0x45, 0x51, 0x0a, 0xb4, 0x39, 0x6d, 0x89, 0x13, 0xdb, 0xc6, + 0x38, 0x56, 0xad, 0x49, 0x97, 0x8a, 0xd0, 0x0c, 0x82, 0x18, 0xd5, 0xc1, 0x4c, 0x97, 0xe4, 0x10, + 0x40, 0x20, 0x24, 0xa7, 0x63, 0x49, 0x9d, 0x3a, 0xc9, 0xb2, 0xda, 0x29, 0xcb, 0x6a, 0x9f, 0xa5, + 0x2c, 0xeb, 0xa0, 0xf2, 0xf9, 0x17, 0xdb, 0xb7, 0xfe, 0xf8, 0xcf, 0x6d, 0xc3, 0xaa, 0x2a, 0xbb, + 0x7d, 0x46, 0x8e, 0xa0, 0x36, 0xf4, 0x7c, 0x2f, 0x1e, 0x49, 0x2f, 0xe5, 0x97, 0xf0, 0x02, 0xa9, + 0xe1, 0x3e, 0x33, 0xd7, 0xa0, 0xf4, 0x24, 0xf0, 0x1c, 0xb2, 0x0c, 0xc6, 0x99, 0x28, 0xac, 0x62, + 0x19, 0x67, 0x66, 0x0f, 0x36, 0x7a, 0x38, 0x48, 0x5c, 0x39, 0x1f, 0x39, 0x81, 0x4a, 0xd4, 0x5b, + 0xbb, 0x07, 0x15, 0x41, 0x62, 0xfb, 0x9e, 0x23, 0x71, 0x38, 0x58, 0xf9, 0xf2, 0xa6, 0x69, 0x3c, + 0xfb, 0x62, 0x7b, 0x49, 0x28, 0x1f, 0xf7, 0xac, 0x25, 0xa1, 0x70, 0xec, 0xec, 0x75, 0xe1, 0xfe, + 0xcc, 0x9c, 0x27, 0x15, 0x28, 0x71, 0x61, 0xfd, 0x16, 0x7f, 0xe2, 0xe2, 0xba, 0x41, 0xaa, 0x50, + 0x16, 0x9b, 0xf5, 0xdb, 0xdd, 0x7f, 0xac, 0xc2, 0xd2, 0x63, 0x49, 0xb6, 0x49, 0x17, 0x6e, 0x1f, + 0xf7, 0x48, 0x5d, 0xbf, 0x68, 0x78, 0xae, 0xad, 0x15, 0x6d, 0x82, 0x9f, 0x22, 0x46, 0x66, 0xf5, + 0xe9, 0x4d, 0xb3, 0xfc, 0x41, 0x82, 0xd1, 0x35, 0xf9, 0x00, 0x6a, 0x1a, 0xff, 0x21, 0x9b, 0x33, + 0x63, 0x59, 0x23, 0x46, 0xad, 0x19, 0x2a, 0x60, 0xd6, 0x9f, 0xde, 0x34, 0x97, 0x1f, 0x27, 0x83, + 0xd8, 0x8e, 0xbc, 0x90, 0xb7, 0xff, 0x1d, 0x83, 0x78, 0x8a, 0x4b, 0xf0, 0x7b, 0x94, 0xb4, 0x66, + 0x1c, 0x66, 0x23, 0xa4, 0xc0, 0xdd, 0x5b, 0x59, 0x62, 0xff, 0xbd, 0x69, 0x6e, 0x17, 0x9a, 0x4e, + 0x6e, 0xe6, 0x77, 0x0c, 0xf2, 0x23, 0xa8, 0x3c, 0x42, 0x26, 0xf6, 0xc8, 0x8c, 0xb7, 0x02, 0xff, + 0x5a, 0xe1, 0x4f, 0xe0, 0x5e, 0x9e, 0xf0, 0x92, 0xed, 0x82, 0x21, 0xaa, 0x93, 0xe1, 0x56, 0xf1, + 0x7d, 0x6b, 0x2e, 0x3f, 0xbd, 0x69, 0x56, 0x4e, 0x12, 0x26, 0x6f, 0x26, 0x0b, 0xd6, 0xd4, 0xc6, + 0xbe, 0x6d, 0x63, 0x98, 0x79, 0x2f, 0x36, 0x7e, 0x31, 0x9f, 0x3f, 0x83, 0xbb, 0x59, 0x3e, 0x17, + 0xc1, 0x25, 0x7e, 0x4d, 0xce, 0x7e, 0x19, 0x3a, 0x94, 0xbd, 0x9a, 0x33, 0x96, 0x51, 0x1e, 0xd1, + 0xed, 0xcd, 0x02, 0x08, 0x27, 0xfd, 0x9e, 0xe3, 0xb1, 0xad, 0x37, 0xfd, 0xc1, 0x1c, 0x0f, 0xb9, + 0xb6, 0x1f, 0x01, 0x3c, 0x42, 0xa6, 0x76, 0x5f, 0x32, 0x7f, 0xed, 0x08, 0xd8, 0x40, 0x66, 0x87, + 0x2d, 0xf9, 0xc6, 0xbc, 0x01, 0xaf, 0x0d, 0xe3, 0xd6, 0x82, 0xa1, 0x37, 0x85, 0xd0, 0x67, 0x46, + 0x9e, 0xba, 0x08, 0x9c, 0x1e, 0xcc, 0x8b, 0x31, 0x01, 0x6b, 0x51, 0x84, 0x87, 0x3a, 0x62, 0xdf, + 0x5a, 0xe4, 0x2b, 0x07, 0xdb, 0xaf, 0xf3, 0xf5, 0x1e, 0xfb, 0x97, 0x1e, 0x43, 0xb2, 0x37, 0xcf, + 0x7e, 0x96, 0x01, 0xbc, 0x44, 0xd9, 0xe7, 0xe2, 0xff, 0xe4, 0x84, 0x1c, 0x5d, 0xd9, 0xe3, 0xc4, + 0xf9, 0x7f, 0x05, 0xa3, 0xb0, 0x51, 0xfc, 0xa7, 0x92, 0x7c, 0x7b, 0x5e, 0xbc, 0xa9, 0x3f, 0x9e, + 0x05, 0x77, 0x45, 0x3e, 0xc4, 0x19, 0xac, 0xc8, 0x23, 0x37, 0xa1, 0x33, 0x0b, 0xf2, 0x5b, 0x98, + 0xbb, 0x76, 0x02, 0x87, 0xb0, 0x3e, 0xe5, 0x55, 0x22, 0x40, 0x9e, 0xcb, 0x8c, 0x5a, 0xcf, 0xd5, + 0xd0, 0xe3, 0x3c, 0x84, 0xda, 0x4f, 0xa9, 0xef, 0x8c, 0xf1, 0x79, 0x57, 0x65, 0x36, 0x34, 0xcc, + 0x5b, 0xa4, 0x07, 0xf5, 0x47, 0xe8, 0x63, 0x44, 0x19, 0xbe, 0x47, 0xcf, 0xb1, 0x47, 0x19, 0x2d, + 0x18, 0x2e, 0xb3, 0x96, 0x79, 0xe0, 0x46, 0xb0, 0x6a, 0x25, 0xfe, 0x14, 0x41, 0x88, 0xb3, 0x02, + 0x85, 0x59, 0x11, 0xd7, 0x68, 0x3d, 0x58, 0xa0, 0x21, 0x09, 0xc6, 0x54, 0xa4, 0x77, 0xa1, 0x2a, + 0x86, 0xf0, 0xa9, 0xe7, 0xbb, 0xe4, 0x8d, 0x1c, 0xdd, 0xce, 0x7f, 0x0e, 0x29, 0xac, 0xf6, 0x43, + 0xb8, 0x2f, 0xac, 0xd5, 0xf4, 0x96, 0x40, 0x99, 0xba, 0x62, 0xf1, 0x84, 0x7f, 0xee, 0xc9, 0x39, + 0x84, 0x15, 0xdd, 0xf1, 0xfe, 0x78, 0xfc, 0x15, 0x50, 0x3c, 0x81, 0x5a, 0x4f, 0x7c, 0x7d, 0xe2, + 0x34, 0x32, 0x2e, 0x70, 0x90, 0xa2, 0x15, 0x9e, 0xbb, 0x6d, 0xed, 0x3b, 0x95, 0x66, 0xa4, 0x9f, + 0x87, 0x47, 0x00, 0x93, 0x0f, 0x4a, 0x05, 0xde, 0x72, 0xf7, 0xf8, 0xf4, 0xa7, 0x27, 0xdd, 0xd1, + 0xf7, 0xa1, 0xcc, 0x19, 0x45, 0xbc, 0xa0, 0xa4, 0x94, 0x75, 0xe4, 0x12, 0xe8, 0x41, 0x35, 0xfb, + 0x04, 0x46, 0xa6, 0xf9, 0x49, 0x2b, 0xdf, 0xbc, 0xfc, 0xa7, 0x32, 0xdd, 0xcb, 0xaf, 0xa0, 0x7e, + 0x12, 0xf8, 0x1e, 0x0b, 0xa2, 0x03, 0xea, 0x3b, 0x9f, 0x78, 0x0e, 0x1b, 0x91, 0xa6, 0xe6, 0x2c, + 0x93, 0x3e, 0x66, 0x94, 0xc5, 0xad, 0xf9, 0x5b, 0x85, 0x3c, 0xe6, 0x08, 0x96, 0x95, 0xf7, 0x79, + 0x25, 0xce, 0x10, 0xab, 0x22, 0x37, 0x1c, 0x22, 0xea, 0x7b, 0xf6, 0x0b, 0x75, 0x7d, 0x52, 0xdc, + 0xc1, 0xde, 0xe7, 0xcf, 0xb6, 0x8c, 0xbf, 0x3f, 0xdb, 0x32, 0xbe, 0x7c, 0xb6, 0x65, 0xfc, 0xe9, + 0x5f, 0x5b, 0xb7, 0x3e, 0x6a, 0x48, 0x6d, 0x86, 0xf6, 0xa8, 0x63, 0x07, 0x11, 0x76, 0xd2, 0xcf, + 0xad, 0x83, 0x3b, 0x82, 0xbf, 0x3e, 0xfc, 0x5f, 0x00, 0x00, 0x00, 0xff, 0xff, 0xdc, 0xe5, 0xbe, + 0x0c, 0x81, 0x15, 0x00, 0x00, } diff --git a/core/api/node/service.proto b/core/api/node/service.proto index c22cdcf524..33ca614f46 100644 --- a/core/api/node/service.proto +++ b/core/api/node/service.proto @@ -119,6 +119,10 @@ service Service { option (gql.graphql_type) = "Mutation"; }; + rpc DebugRequeueAll (Void) returns (Void) { + option (gql.graphql_type) = "Mutation"; + }; + rpc DeviceInfos (Void) returns (berty.pkg.deviceinfo.DeviceInfos) { option (gql.graphql_type) = "Query"; }; diff --git a/core/node/nodeapi_devtools.go b/core/node/nodeapi_devtools.go index 0760a07fe6..8e647ab4dd 100644 --- a/core/node/nodeapi_devtools.go +++ b/core/node/nodeapi_devtools.go @@ -189,3 +189,11 @@ func (n *Node) DebugRequeueEvent(_ context.Context, input *node.DebugEventRequeu return &event, nil } + +func (n *Node) DebugRequeueAll(_ context.Context, _ *node.Void) (*node.Void, error) { + if _, err := n.EventsRetry(time.Now()); err != nil { + return nil, errors.Wrap(err, "unable to requeue events") + } + + return &node.Void{}, nil +}