forked from Silverfish/proton-bridge
GODT-2312: used space is properly updated.
This commit is contained in:
File diff suppressed because it is too large
Load Diff
@ -448,6 +448,7 @@ message UserEvent {
|
||||
UserDisconnectedEvent userDisconnected = 2;
|
||||
UserChangedEvent userChanged = 3;
|
||||
UserBadEvent userBadEvent = 4;
|
||||
UsedBytesChangedEvent usedBytesChangedEvent= 5;
|
||||
}
|
||||
}
|
||||
|
||||
@ -468,6 +469,11 @@ message UserBadEvent {
|
||||
string errorMessage = 2;
|
||||
}
|
||||
|
||||
message UsedBytesChangedEvent {
|
||||
string userID = 1;
|
||||
int64 usedBytes = 2;
|
||||
}
|
||||
|
||||
//**********************************************************
|
||||
// Generic errors
|
||||
//**********************************************************
|
||||
|
||||
@ -177,6 +177,10 @@ func NewUserBadEvent(userID string, errorMessage string) *StreamEvent {
|
||||
return userEvent(&UserEvent{Event: &UserEvent_UserBadEvent{UserBadEvent: &UserBadEvent{UserID: userID, ErrorMessage: errorMessage}}})
|
||||
}
|
||||
|
||||
func NewUsedBytesChangedEvent(userID string, usedBytes int) *StreamEvent {
|
||||
return userEvent(&UserEvent{Event: &UserEvent_UsedBytesChangedEvent{UsedBytesChangedEvent: &UsedBytesChangedEvent{UserID: userID, UsedBytes: int64(usedBytes)}}})
|
||||
}
|
||||
|
||||
func NewGenericErrorEvent(errorCode ErrorCode) *StreamEvent {
|
||||
return genericErrorEvent(&GenericErrorEvent{Code: errorCode})
|
||||
}
|
||||
|
||||
@ -305,6 +305,9 @@ func (s *Service) watchEvents() {
|
||||
case events.AddressModeChanged:
|
||||
_ = s.SendEvent(NewUserChangedEvent(event.UserID))
|
||||
|
||||
case events.UsedSpaceChanged:
|
||||
_ = s.SendEvent(NewUsedBytesChangedEvent(event.UserID, event.UsedSpace))
|
||||
|
||||
case events.UserDeauth:
|
||||
// This is the event the GUI cares about.
|
||||
_ = s.SendEvent(NewUserChangedEvent(event.UserID))
|
||||
|
||||
@ -174,6 +174,7 @@ func (s *Service) StartEventTest() error { //nolint:funlen
|
||||
NewUserToggleSplitModeFinishedEvent("userID"),
|
||||
NewUserDisconnectedEvent("username"),
|
||||
NewUserChangedEvent("userID"),
|
||||
NewUsedBytesChangedEvent("userID", 1000),
|
||||
}
|
||||
|
||||
for _, event := range events {
|
||||
|
||||
Reference in New Issue
Block a user