/
repo_acl_user_role.go
119 lines (85 loc) · 2.48 KB
/
repo_acl_user_role.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
package go_shopware_admin_sdk
import (
"net/http"
"time"
)
type AclUserRoleRepository ClientService
func (t AclUserRoleRepository) Search(ctx ApiContext, criteria Criteria) (*AclUserRoleCollection, *http.Response, error) {
req, err := t.Client.NewRequest(ctx, "POST", "/api/search/acl-user-role", criteria)
if err != nil {
return nil, nil, err
}
uResp := new(AclUserRoleCollection)
resp, err := t.Client.Do(ctx.Context, req, uResp)
if err != nil {
return nil, resp, err
}
return uResp, resp, nil
}
func (t AclUserRoleRepository) SearchAll(ctx ApiContext, criteria Criteria) (*AclUserRoleCollection, *http.Response, error) {
if criteria.Limit == 0 {
criteria.Limit = 50
}
if criteria.Page == 0 {
criteria.Page = 1
}
c, resp, err := t.Search(ctx, criteria)
if err != nil {
return c, resp, err
}
for {
criteria.Page++
nextC, nextResp, nextErr := t.Search(ctx, criteria)
if nextErr != nil {
return c, nextResp, nextErr
}
if len(nextC.Data) == 0 {
break
}
c.Data = append(c.Data, nextC.Data...)
}
c.Total = int64(len(c.Data))
return c, resp, err
}
func (t AclUserRoleRepository) SearchIds(ctx ApiContext, criteria Criteria) (*SearchIdsResponse, *http.Response, error) {
req, err := t.Client.NewRequest(ctx, "POST", "/api/search-ids/acl-user-role", criteria)
if err != nil {
return nil, nil, err
}
uResp := new(SearchIdsResponse)
resp, err := t.Client.Do(ctx.Context, req, uResp)
if err != nil {
return nil, resp, err
}
return uResp, resp, nil
}
func (t AclUserRoleRepository) Upsert(ctx ApiContext, entity []AclUserRole) (*http.Response, error) {
return t.Client.Bulk.Sync(ctx, map[string]SyncOperation{"acl_user_role": {
Entity: "acl_user_role",
Action: "upsert",
Payload: entity,
}})
}
func (t AclUserRoleRepository) Delete(ctx ApiContext, ids []string) (*http.Response, error) {
payload := make([]entityDelete, 0)
for _, id := range ids {
payload = append(payload, entityDelete{Id: id})
}
return t.Client.Bulk.Sync(ctx, map[string]SyncOperation{"acl_user_role": {
Entity: "acl_user_role",
Action: "delete",
Payload: payload,
}})
}
type AclUserRole struct {
User *User `json:"user,omitempty"`
AclRole *AclRole `json:"aclRole,omitempty"`
UserId string `json:"userId,omitempty"`
AclRoleId string `json:"aclRoleId,omitempty"`
CreatedAt time.Time `json:"createdAt,omitempty"`
UpdatedAt time.Time `json:"updatedAt,omitempty"`
}
type AclUserRoleCollection struct {
EntityCollection
Data []AclUserRole `json:"data"`
}