Skip to content

Commit

Permalink
fix get account peers
Browse files Browse the repository at this point in the history
Signed-off-by: bcmmbaga <[email protected]>
  • Loading branch information
bcmmbaga committed Feb 4, 2025
1 parent b1c4b99 commit 3ba1e45
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 6 deletions.
8 changes: 4 additions & 4 deletions management/server/http/handlers/groups/groups_handler.go
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ func (h *handler) getAllGroups(w http.ResponseWriter, r *http.Request) {
return
}

accountPeers, err := h.accountManager.GetPeers(r.Context(), accountID, userID)
accountPeers, err := h.accountManager.GetPeers(r.Context(), accountID, userID, "", "")
if err != nil {
util.WriteError(r.Context(), err, w)
return
Expand Down Expand Up @@ -154,7 +154,7 @@ func (h *handler) updateGroup(w http.ResponseWriter, r *http.Request) {
return
}

accountPeers, err := h.accountManager.GetPeers(r.Context(), accountID, userID)
accountPeers, err := h.accountManager.GetPeers(r.Context(), accountID, userID, "", "")
if err != nil {
util.WriteError(r.Context(), err, w)
return
Expand Down Expand Up @@ -213,7 +213,7 @@ func (h *handler) createGroup(w http.ResponseWriter, r *http.Request) {
return
}

accountPeers, err := h.accountManager.GetPeers(r.Context(), accountID, userID)
accountPeers, err := h.accountManager.GetPeers(r.Context(), accountID, userID, "", "")
if err != nil {
util.WriteError(r.Context(), err, w)
return
Expand Down Expand Up @@ -272,7 +272,7 @@ func (h *handler) getGroup(w http.ResponseWriter, r *http.Request) {
return
}

accountPeers, err := h.accountManager.GetPeers(r.Context(), accountID, userID)
accountPeers, err := h.accountManager.GetPeers(r.Context(), accountID, userID, "", "")
if err != nil {
util.WriteError(r.Context(), err, w)
return
Expand Down
2 changes: 1 addition & 1 deletion management/server/integrated_validator.go
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,7 @@ func (am *DefaultAccountManager) GetValidatedPeers(ctx context.Context, accountI
return err
}

peers, err = transaction.GetAccountPeers(ctx, store.LockingStrengthShare, accountID)
peers, err = transaction.GetAccountPeers(ctx, store.LockingStrengthShare, accountID, "", "")

Check failure on line 91 in management/server/integrated_validator.go

View workflow job for this annotation

GitHub Actions / test (sqlite)

too many arguments in call to transaction.GetAccountPeers
return err
})
if err != nil {
Expand Down
2 changes: 1 addition & 1 deletion management/server/peers/manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -50,5 +50,5 @@ func (m *managerImpl) GetAllPeers(ctx context.Context, accountID, userID string)
return nil, status.NewPermissionDeniedError()
}

return m.store.GetAccountPeers(ctx, store.LockingStrengthShare, accountID)
return m.store.GetAccountPeers(ctx, store.LockingStrengthShare, accountID, "", "")

Check failure on line 53 in management/server/peers/manager.go

View workflow job for this annotation

GitHub Actions / test (sqlite)

too many arguments in call to m.store.GetAccountPeers
}

0 comments on commit 3ba1e45

Please sign in to comment.