Skip to content
GitLab
Explore
Sign in
Primary navigation
Search or go to…
Project
client
Manage
Activity
Members
Labels
Plan
Issues
Issue boards
Milestones
Wiki
Code
Merge requests
Repository
Branches
Commits
Tags
Repository graph
Compare revisions
Snippets
Deploy
Releases
Package Registry
Container Registry
Model registry
Operate
Terraform modules
Analyze
Contributor analytics
Model experiments
Help
Help
Support
GitLab documentation
Compare GitLab plans
Community forum
Contribute to GitLab
Provide feedback
Keyboard shortcuts
?
Snippets
Groups
Projects
Show more breadcrumbs
elixxir
client
Merge requests
!354
Channels impl
Code
Review changes
Check out branch
Download
Patches
Plain diff
Merged
Channels impl
channelsImpl
into
project/Channels
Overview
42
Commits
162
Pipelines
0
Changes
52
Merged
Benjamin Wenger
requested to merge
channelsImpl
into
project/Channels
2 years ago
Overview
42
Commits
162
Pipelines
0
Changes
6
Expand
0
0
Merge request reports
Compare
version 15
version 52
c847a8d6
2 years ago
version 51
3c910849
2 years ago
version 50
0a1932b2
2 years ago
version 49
a2593e6e
2 years ago
version 48
d3027a2b
2 years ago
version 47
8730b939
2 years ago
version 46
8e90c2bc
2 years ago
version 45
72374d06
2 years ago
version 44
d6ec5a34
2 years ago
version 43
08da968c
2 years ago
version 42
41425fe9
2 years ago
version 41
9c452b29
2 years ago
version 40
af5c6fdf
2 years ago
version 39
a2e6d33d
2 years ago
version 38
147e94cf
2 years ago
version 37
147e94cf
2 years ago
version 36
87eb4045
2 years ago
version 35
87062fc9
2 years ago
version 34
730c44f3
2 years ago
version 33
9b6db62d
2 years ago
version 32
e442a896
2 years ago
version 31
ad488f14
2 years ago
version 30
e8b6ad4f
2 years ago
version 29
da59983e
2 years ago
version 28
3ba34b5d
2 years ago
version 27
e28e12d6
2 years ago
version 26
170d37d3
2 years ago
version 25
e6266d2e
2 years ago
version 24
66ae7eb4
2 years ago
version 23
b58c6e71
2 years ago
version 22
6ffe5f27
2 years ago
version 21
47f0c723
2 years ago
version 20
a9dc61fe
2 years ago
version 19
156bef3d
2 years ago
version 18
ce10f748
2 years ago
version 17
beaf4ced
2 years ago
version 16
82c93936
2 years ago
version 15
7633d35e
2 years ago
version 14
6ccae24b
2 years ago
version 13
df06fbbd
2 years ago
version 12
45811782
2 years ago
version 11
fff7fe73
2 years ago
version 10
a4e5f641
2 years ago
version 9
a3a13a55
2 years ago
version 8
d7008cbc
2 years ago
version 7
78add3b2
2 years ago
version 6
791dd6bf
2 years ago
version 5
0322142f
2 years ago
version 4
1d29bc16
2 years ago
version 3
2f78a773
2 years ago
version 2
60acb356
2 years ago
version 1
0c7763ba
2 years ago
project/Channels (base)
and
version 16
latest version
9fb54e0e
162 commits,
2 years ago
version 52
c847a8d6
161 commits,
2 years ago
version 51
3c910849
133 commits,
2 years ago
version 50
0a1932b2
132 commits,
2 years ago
version 49
a2593e6e
131 commits,
2 years ago
version 48
d3027a2b
130 commits,
2 years ago
version 47
8730b939
129 commits,
2 years ago
version 46
8e90c2bc
128 commits,
2 years ago
version 45
72374d06
127 commits,
2 years ago
version 44
d6ec5a34
126 commits,
2 years ago
version 43
08da968c
125 commits,
2 years ago
version 42
41425fe9
124 commits,
2 years ago
version 41
9c452b29
123 commits,
2 years ago
version 40
af5c6fdf
122 commits,
2 years ago
version 39
a2e6d33d
121 commits,
2 years ago
version 38
147e94cf
120 commits,
2 years ago
version 37
147e94cf
137 commits,
2 years ago
version 36
87eb4045
136 commits,
2 years ago
version 35
87062fc9
135 commits,
2 years ago
version 34
730c44f3
134 commits,
2 years ago
version 33
9b6db62d
133 commits,
2 years ago
version 32
e442a896
132 commits,
2 years ago
version 31
ad488f14
131 commits,
2 years ago
version 30
e8b6ad4f
130 commits,
2 years ago
version 29
da59983e
129 commits,
2 years ago
version 28
3ba34b5d
128 commits,
2 years ago
version 27
e28e12d6
127 commits,
2 years ago
version 26
170d37d3
125 commits,
2 years ago
version 25
e6266d2e
124 commits,
2 years ago
version 24
66ae7eb4
123 commits,
2 years ago
version 23
b58c6e71
122 commits,
2 years ago
version 22
6ffe5f27
121 commits,
2 years ago
version 21
47f0c723
120 commits,
2 years ago
version 20
a9dc61fe
118 commits,
2 years ago
version 19
156bef3d
116 commits,
2 years ago
version 18
ce10f748
115 commits,
2 years ago
version 17
beaf4ced
114 commits,
2 years ago
version 16
82c93936
112 commits,
2 years ago
version 15
7633d35e
111 commits,
2 years ago
version 14
6ccae24b
109 commits,
2 years ago
version 13
df06fbbd
108 commits,
2 years ago
version 12
45811782
107 commits,
2 years ago
version 11
fff7fe73
106 commits,
2 years ago
version 10
a4e5f641
105 commits,
2 years ago
version 9
a3a13a55
103 commits,
2 years ago
version 8
d7008cbc
100 commits,
2 years ago
version 7
78add3b2
99 commits,
2 years ago
version 6
791dd6bf
98 commits,
2 years ago
version 5
0322142f
96 commits,
2 years ago
version 4
1d29bc16
95 commits,
2 years ago
version 3
2f78a773
94 commits,
2 years ago
version 2
60acb356
38 commits,
2 years ago
version 1
0c7763ba
37 commits,
2 years ago
Show latest version
6 files
+
83
−
77
Inline
Compare changes
Side-by-side
Inline
Show whitespace changes
Show one file at a time
Files
6
Search (e.g. *.vue) (Ctrl+P)
channels/adminListener.go
+
12
−
12
Options
@@ -10,8 +10,8 @@ import (
"gitlab.com/xx_network/primitives/id"
)
//
the
adminListener adheres to the broadcast listener interface and is used
//
when
admin messages are received on the channel
// adminListener adheres to the broadcast listener interface and is used
when
// admin messages are received on the channel
.
type
adminListener
struct
{
chID
*
id
.
ID
trigger
triggerAdminEventFunc
@@ -20,28 +20,28 @@ type adminListener struct {
func
(
al
*
adminListener
)
Listen
(
payload
[]
byte
,
receptionID
receptionID
.
EphemeralIdentity
,
round
rounds
.
Round
)
{
//Remove the padding
//
Remove the padding
payloadUnpadded
,
err
:=
broadcast
.
DecodeSizedBroadcast
(
payload
)
if
err
!=
nil
{
jww
.
WARN
.
Printf
(
"Failed to strip the padding on User Message "
+
"on channel %s"
,
al
.
chID
)
jww
.
WARN
.
Printf
(
"
Failed to strip the padding on User Message
on channel %s"
,
al
.
chID
)
return
}
//
g
et the message ID
//
G
et the message ID
msgID
:=
channel
.
MakeMessageID
(
payloadUnpadded
)
//Decode the message as a channel message
//
Decode the message as a channel message
cm
:=
&
ChannelMessage
{}
if
err
=
proto
.
Unmarshal
(
payloadUnpadded
,
cm
);
err
!=
nil
{
jww
.
WARN
.
Printf
(
"Failed to unmarshal Channel Message from Admin"
+
"
on
channel %s"
,
al
.
chID
)
jww
.
WARN
.
Printf
(
"Failed to unmarshal Channel Message from Admin
on
"
+
"channel %s"
,
al
.
chID
)
return
}
/*CRYPTOGRAPHICALLY RELEVANT CHECKS*/
/*
CRYPTOGRAPHICALLY RELEVANT CHECKS
*/
//
c
heck the round to ensure the message is not a replay
//
C
heck the round to ensure
that
the message is not a replay
if
id
.
Round
(
cm
.
RoundID
)
!=
round
.
ID
{
jww
.
WARN
.
Printf
(
"The round message %s send on %s referenced "
+
"(%d) was not the same as the round the message was found on (%d)"
,
@@ -49,7 +49,7 @@ func (al *adminListener) Listen(payload []byte,
return
}
//Submit the message to the event model for listening
//
Submit the message to the event model for listening
al
.
trigger
(
al
.
chID
,
cm
,
msgID
,
receptionID
,
round
)
return
Loading