this repo has no description
fixup encoding type params
+21
-18
+15
-12
api/atproto.go
+15
-12
api/atproto.go
···
20
20
Did string `json:"did"`
21
21
}
22
22
23
+
const (
24
+
encJson = "application/json"
25
+
)
26
+
23
27
func (atp *ATProto) CreateSession(ctx context.Context, handle, password string) (*CreateSessionResp, error) {
24
28
body := map[string]string{
25
29
"handle": handle,
···
27
31
}
28
32
29
33
var resp CreateSessionResp
30
-
if err := atp.C.Do(ctx, xrpc.Procedure, "com.atproto.session.create", nil, body, &resp); err != nil {
34
+
if err := atp.C.Do(ctx, xrpc.Procedure, encJson, "com.atproto.session.create", nil, body, &resp); err != nil {
31
35
return nil, err
32
36
}
33
37
···
54
58
}
55
59
56
60
var resp CreateAccountResp
57
-
if err := atp.C.Do(ctx, xrpc.Procedure, "com.atproto.account.create", nil, body, &resp); err != nil {
61
+
if err := atp.C.Do(ctx, xrpc.Procedure, encJson, "com.atproto.account.create", nil, body, &resp); err != nil {
58
62
return nil, err
59
63
}
60
64
···
79
83
}
80
84
81
85
var out CreateRecordResponse
82
-
if err := atp.C.Do(ctx, xrpc.Procedure, "com.atproto.repo.createRecord", nil, body, &out); err != nil {
86
+
if err := atp.C.Do(ctx, xrpc.Procedure, encJson, "com.atproto.repo.createRecord", nil, body, &out); err != nil {
83
87
return nil, err
84
88
}
85
89
···
95
99
}
96
100
97
101
out := new(bytes.Buffer)
98
-
if err := atp.C.Do(ctx, xrpc.Query, "com.atproto.sync.getRepo", params, nil, out); err != nil {
102
+
if err := atp.C.Do(ctx, xrpc.Query, encJson, "com.atproto.sync.getRepo", params, nil, out); err != nil {
99
103
return nil, err
100
104
}
101
105
···
110
114
var out struct {
111
115
Root string `json:"root"`
112
116
}
113
-
if err := atp.C.Do(ctx, xrpc.Query, "com.atproto.sync.getRoot", params, nil, &out); err != nil {
117
+
if err := atp.C.Do(ctx, xrpc.Query, encJson, "com.atproto.sync.getRoot", params, nil, &out); err != nil {
114
118
return "", err
115
119
}
116
120
···
125
129
var out struct {
126
130
Did string `json:"did"`
127
131
}
128
-
if err := atp.C.Do(ctx, xrpc.Query, "com.atproto.handle.resolve", params, nil, &out); err != nil {
132
+
if err := atp.C.Do(ctx, xrpc.Query, encJson, "com.atproto.handle.resolve", params, nil, &out); err != nil {
129
133
return "", err
130
134
}
131
135
···
135
139
136
140
func (atp *ATProto) SessionRefresh(ctx context.Context) (*xrpc.AuthInfo, error) {
137
141
var out xrpc.AuthInfo
138
-
if err := atp.C.Do(ctx, xrpc.Procedure, "com.atproto.session.refresh", nil, nil, &out); err != nil {
142
+
if err := atp.C.Do(ctx, xrpc.Procedure, encJson, "com.atproto.session.refresh", nil, nil, &out); err != nil {
139
143
return nil, err
140
144
}
141
145
···
143
147
}
144
148
145
149
type RecordResponse[T JsonLD] struct {
146
-
Uri string `json:"uri"`
147
-
Cid string `json:"cid"`
148
-
Value T `json:"value"`
149
-
150
+
Uri string `json:"uri"`
151
+
Cid string `json:"cid"`
152
+
Value T `json:"value"`
150
153
}
151
154
152
155
func RepoGetRecord[T JsonLD](atp *ATProto, ctx context.Context, user string, collection string, rkey string) (*RecordResponse[T], error) {
···
157
160
}
158
161
159
162
var out RecordResponse[T]
160
-
if err := atp.C.Do(ctx, xrpc.Query, "com.atproto.repo.getRecord", params, nil, &out); err != nil {
163
+
if err := atp.C.Do(ctx, xrpc.Query, encJson, "com.atproto.repo.getRecord", params, nil, &out); err != nil {
161
164
return nil, err
162
165
}
163
166
+5
-5
api/bsky.go
+5
-5
api/bsky.go
···
83
83
}
84
84
85
85
var out GetTimelineResp
86
-
if err := b.C.Do(ctx, xrpc.Query, "app.bsky.feed.getTimeline", params, nil, &out); err != nil {
86
+
if err := b.C.Do(ctx, xrpc.Query, encJson, "app.bsky.feed.getTimeline", params, nil, &out); err != nil {
87
87
return nil, err
88
88
}
89
89
···
101
101
}
102
102
103
103
var out GetTimelineResp
104
-
if err := b.C.Do(ctx, xrpc.Query, "app.bsky.feed.getAuthorFeed", params, nil, &out); err != nil {
104
+
if err := b.C.Do(ctx, xrpc.Query, encJson, "app.bsky.feed.getAuthorFeed", params, nil, &out); err != nil {
105
105
return nil, err
106
106
}
107
107
···
137
137
}
138
138
139
139
var out GetSuggestionsResp
140
-
if err := b.C.Do(ctx, xrpc.Query, "app.bsky.actor.getSuggestions", params, nil, &out); err != nil {
140
+
if err := b.C.Do(ctx, xrpc.Query, "", "app.bsky.actor.getSuggestions", params, nil, &out); err != nil {
141
141
return nil, err
142
142
}
143
143
···
151
151
}
152
152
153
153
var out map[string]interface{}
154
-
if err := b.C.Do(ctx, xrpc.Procedure, "app.bsky.feed.setVote", nil, body, &out); err != nil {
154
+
if err := b.C.Do(ctx, xrpc.Procedure, encJson, "app.bsky.feed.setVote", nil, body, &out); err != nil {
155
155
return err
156
156
}
157
157
···
177
177
}
178
178
179
179
var out GetFollowsResp
180
-
if err := b.C.Do(ctx, xrpc.Query, "app.bsky.graph.getFollows", params, nil, &out); err != nil {
180
+
if err := b.C.Do(ctx, xrpc.Query, "", "app.bsky.graph.getFollows", params, nil, &out); err != nil {
181
181
return nil, err
182
182
}
183
183