No need to pass remote url when deleting (remote) subscriber.

This commit is contained in:
Joachim Bauch 2024-04-18 14:06:11 +02:00
parent cfcb09b382
commit db4527544d
No known key found for this signature in database
GPG key ID: 77C1D22D53E15F02
2 changed files with 3 additions and 10 deletions

View file

@ -228,12 +228,9 @@ func (m *CommandProxyClientMessage) CheckValid() error {
return fmt.Errorf("stream type missing")
}
if m.RemoteUrl != "" {
// TODO: Enable once subscriber deletion provides this value.
/*
if m.RemoteToken == "" {
return fmt.Errorf("remote token type missing")
}
*/
if m.RemoteToken == "" {
return fmt.Errorf("remote token type missing")
}
remoteUrl, err := url.Parse(m.RemoteUrl)
if err != nil {

View file

@ -263,10 +263,6 @@ func (s *mcuProxySubscriber) Close(ctx context.Context) {
ClientId: s.proxyId,
},
}
if s.publisherConn != nil {
msg.Command.RemoteUrl = s.publisherConn.rawUrl
// TODO: Add remote token for this subscriber.
}
if response, err := s.conn.performSyncRequest(ctx, msg); err != nil {
if s.publisherConn != nil {