apollo/enbas
1
0
Fork 0
Code Issues 4 Pull requests Projects Activity Actions

add support at the client level

Browse source
This commit is contained in:
Dan Anglin 2024-03-03 13:57:24 +00:00
parent 4f694465bf
commit 7f86c593fa
Signed by: dananglin
GPG key ID: 0C1D44CFBEE68638
1 changed files with 72 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

78
internal/client/lists.go
View file

@ -44,7 +44,7 @@ func (g *Client) GetList(listID string) (model.List, error) {
}
func (g *Client) CreateList(title string, repliesPolicy model.ListRepliesPolicy) (model.List, error) {
params := struct {
form := struct {
Title string `json:"title"`
RepliesPolicy model.ListRepliesPolicy `json:"replies_policy"`
}{
@ -52,9 +52,9 @@ func (g *Client) CreateList(title string, repliesPolicy model.ListRepliesPolicy)
RepliesPolicy: repliesPolicy,
}
data, err := json.Marshal(params)
data, err := json.Marshal(form)
if err != nil {
return model.List{}, fmt.Errorf("unable to marshal the request body; %w", err)
return model.List{}, fmt.Errorf("unable to marshal the form; %w", err)
}
requestBody := bytes.NewBuffer(data)
@ -73,7 +73,7 @@ func (g *Client) CreateList(title string, repliesPolicy model.ListRepliesPolicy)
}
func (g *Client) UpdateList(listToUpdate model.List) (model.List, error) {
params := struct {
form := struct {
Title string `json:"title"`
RepliesPolicy model.ListRepliesPolicy `json:"replies_policy"`
}{
@ -81,9 +81,9 @@ func (g *Client) UpdateList(listToUpdate model.List) (model.List, error) {
RepliesPolicy: listToUpdate.RepliesPolicy,
}
data, err := json.Marshal(params)
data, err := json.Marshal(form)
if err != nil {
return model.List{}, fmt.Errorf("unable to marshal the request body; %w", err)
return model.List{}, fmt.Errorf("unable to marshal the form; %w", err)
}
requestBody := bytes.NewBuffer(data)
@ -106,3 +106,69 @@ func (g *Client) DeleteList(listID string) error {
return g.sendRequest(http.MethodDelete, url, nil, nil)
}
func (g *Client) AddAccountsToList(listID string, accountIDs []string) error {
form := struct {
AccountIDs []string `json:"account_ids"`
}{
AccountIDs: accountIDs,
}
data, err := json.Marshal(form)
if err != nil {
return fmt.Errorf("unable to marshal the form; %w", err)
}
requestBody := bytes.NewBuffer(data)
url := g.Authentication.Instance + listPath + "/" + listID + "/accounts"
if err := g.sendRequest(http.MethodPost, url, requestBody, nil); err != nil {
return fmt.Errorf(
"received an error after sending the request to add the accounts to the list; %w",
err,
)
}
return nil
}
func (g *Client) RemoveAccountsFromList(listID string, accountIDs []string) error {
form := struct {
AccountIDs []string `json:"account_ids"`
}{
AccountIDs: accountIDs,
}
data, err := json.Marshal(form)
if err != nil {
return fmt.Errorf("unable to marshal the form; %w", err)
}
requestBody := bytes.NewBuffer(data)
url := g.Authentication.Instance + listPath + "/" + listID + "/accounts"
if err := g.sendRequest(http.MethodDelete, url, requestBody, nil); err != nil {
return fmt.Errorf(
"received an error after sending the request to remove the accounts from the list; %w",
err,
)
}
return nil
}
func (g *Client) GetAccountsFromList(listID string, limit int) ([]model.Account, error) {
path := fmt.Sprintf("%s/%s/accounts?limit=%d", listPath, listID, limit)
url := g.Authentication.Instance + path
var accounts []model.Account
if err := g.sendRequest(http.MethodGet, url, nil, &accounts); err != nil {
return nil, fmt.Errorf(
"received an error after sending the request to get the accounts from the list; %w",
err,
)
}
return accounts, nil
}