this repo has no description
update indigo pkg names
+36
-36
+2
-2
atproto/netclient/record.go
+2
-2
atproto/netclient/record.go
···
8
8
"log/slog"
9
9
"net/http"
10
10
11
-
"github.com/bluesky-social/indigo/atproto/data"
11
+
"github.com/bluesky-social/indigo/atproto/atdata"
12
12
"github.com/bluesky-social/indigo/atproto/repo"
13
13
"github.com/bluesky-social/indigo/atproto/syntax"
14
14
)
···
125
125
// TODO: `GetRecordBytes` does not currently verify record CID, but unpacking CAR file should have done that? but need to confirm CAR implementation does this
126
126
127
127
// check that record CBOR is valid, even if we don't return it
128
-
rdata, err := data.UnmarshalCBOR(rbytes)
128
+
rdata, err := atdata.UnmarshalCBOR(rbytes)
129
129
if err != nil {
130
130
return "", fmt.Errorf("failed to parse record CBOR (%s): %w", did, err)
131
131
}
+3
-3
atproto/pdsclient/examples_test.go
+3
-3
atproto/pdsclient/examples_test.go
···
5
5
"context"
6
6
"fmt"
7
7
8
-
"github.com/bluesky-social/indigo/atproto/client"
8
+
"github.com/bluesky-social/indigo/atproto/atclient"
9
9
"github.com/bluesky-social/indigo/atproto/syntax"
10
10
)
11
11
12
12
func ExamplePDSClient_CreateRecord() {
13
13
ctx := context.Background()
14
14
pc := PDSClient{
15
-
APIClient: client.NewAPIClient("https://pds.example.com"),
15
+
APIClient: atclient.NewAPIClient("https://pds.example.com"),
16
16
AccountDID: syntax.DID("did:web:example.com"),
17
17
}
18
18
···
31
31
func ExamplePDSClient_UploadBlob() {
32
32
ctx := context.Background()
33
33
pc := PDSClient{
34
-
APIClient: client.NewAPIClient("https://pds.example.com"),
34
+
APIClient: atclient.NewAPIClient("https://pds.example.com"),
35
35
AccountDID: syntax.DID("did:web:example.com"),
36
36
}
37
37
+4
-4
atproto/pdsclient/pdsclient.go
+4
-4
atproto/pdsclient/pdsclient.go
···
7
7
"io"
8
8
"net/http"
9
9
10
-
"github.com/bluesky-social/indigo/atproto/client"
11
-
"github.com/bluesky-social/indigo/atproto/data"
10
+
"github.com/bluesky-social/indigo/atproto/atclient"
11
+
"github.com/bluesky-social/indigo/atproto/atdata"
12
12
"github.com/bluesky-social/indigo/atproto/syntax"
13
13
)
14
14
···
57
57
// TODO: ApplyWrites (?)
58
58
59
59
type uploadBlobResp struct {
60
-
Blob data.Blob `json:"blob"`
60
+
Blob atdata.Blob `json:"blob"`
61
61
}
62
62
63
-
func (pc *PDSClient) UploadBlob(ctx context.Context, mimeType string, input io.Reader) (*data.Blob, error) {
63
+
func (pc *PDSClient) UploadBlob(ctx context.Context, mimeType string, input io.Reader) (*atdata.Blob, error) {
64
64
65
65
endpoint := syntax.NSID("com.atproto.repo.uploadBlob")
66
66
req := client.NewAPIRequest(http.MethodPost, endpoint, input)
+3
-3
cmd/glot/compat.go
+3
-3
cmd/glot/compat.go
···
8
8
"reflect"
9
9
"sort"
10
10
11
-
"github.com/bluesky-social/indigo/atproto/data"
11
+
"github.com/bluesky-social/indigo/atproto/atdata"
12
12
"github.com/bluesky-social/indigo/atproto/lexicon"
13
13
"github.com/bluesky-social/indigo/atproto/syntax"
14
14
···
45
45
return nil
46
46
}
47
47
48
-
localData, err := data.UnmarshalJSON(localJSON)
48
+
localData, err := atdata.UnmarshalJSON(localJSON)
49
49
if err != nil {
50
50
return err
51
51
}
52
-
remoteData, err := data.UnmarshalJSON(remoteJSON)
52
+
remoteData, err := atdata.UnmarshalJSON(remoteJSON)
53
53
if err != nil {
54
54
return err
55
55
}
+3
-3
cmd/glot/diff.go
+3
-3
cmd/glot/diff.go
···
6
6
"fmt"
7
7
"reflect"
8
8
9
-
"github.com/bluesky-social/indigo/atproto/data"
9
+
"github.com/bluesky-social/indigo/atproto/atdata"
10
10
"github.com/bluesky-social/indigo/atproto/syntax"
11
11
12
12
"github.com/urfave/cli/v3"
···
40
40
return nil
41
41
}
42
42
43
-
local, err := data.UnmarshalJSON(localJSON)
43
+
local, err := atdata.UnmarshalJSON(localJSON)
44
44
if err != nil {
45
45
return err
46
46
}
47
-
remote, err := data.UnmarshalJSON(remoteJSON)
47
+
remote, err := atdata.UnmarshalJSON(remoteJSON)
48
48
if err != nil {
49
49
return err
50
50
}
+2
-2
cmd/glot/new.go
+2
-2
cmd/glot/new.go
···
7
7
"fmt"
8
8
"os"
9
9
10
-
"github.com/bluesky-social/indigo/atproto/data"
10
+
"github.com/bluesky-social/indigo/atproto/atdata"
11
11
"github.com/bluesky-social/indigo/atproto/syntax"
12
12
13
13
"github.com/urfave/cli/v3"
···
91
91
return fmt.Errorf("unknown schema template: %s", schemaType)
92
92
}
93
93
94
-
d, err := data.UnmarshalJSON(orig)
94
+
d, err := atdata.UnmarshalJSON(orig)
95
95
if err != nil {
96
96
fmt.Println(orig)
97
97
fmt.Println(tmplRecord)
+5
-5
cmd/glot/publish.go
+5
-5
cmd/glot/publish.go
···
12
12
"sort"
13
13
14
14
"github.com/bluesky-social/indigo/api/agnostic"
15
-
"github.com/bluesky-social/indigo/atproto/client"
16
-
"github.com/bluesky-social/indigo/atproto/data"
15
+
"github.com/bluesky-social/indigo/atproto/atclient"
16
+
"github.com/bluesky-social/indigo/atproto/atdata"
17
17
"github.com/bluesky-social/indigo/atproto/identity"
18
18
"github.com/bluesky-social/indigo/atproto/syntax"
19
19
···
177
177
continue
178
178
}
179
179
180
-
local, err := data.UnmarshalJSON(localJSON)
180
+
local, err := atdata.UnmarshalJSON(localJSON)
181
181
if err != nil {
182
182
return err
183
183
}
184
-
remote, err := data.UnmarshalJSON(remoteJSON)
184
+
remote, err := atdata.UnmarshalJSON(remoteJSON)
185
185
if err != nil {
186
186
return err
187
187
}
···
216
216
217
217
func publishSchema(ctx context.Context, c *client.APIClient, nsid syntax.NSID, schemaJSON json.RawMessage) error {
218
218
219
-
d, err := data.UnmarshalJSON(schemaJSON)
219
+
d, err := atdata.UnmarshalJSON(schemaJSON)
220
220
if err != nil {
221
221
return err
222
222
}
+3
-3
cmd/glot/pull.go
+3
-3
cmd/glot/pull.go
···
9
9
"path"
10
10
11
11
"github.com/bluesky-social/indigo/api/agnostic"
12
-
"github.com/bluesky-social/indigo/atproto/client"
12
+
"github.com/bluesky-social/indigo/atproto/atclient"
13
+
"github.com/bluesky-social/indigo/atproto/atdata"
13
14
"github.com/bluesky-social/indigo/atproto/identity"
14
-
"github.com/bluesky-social/indigo/atproto/data"
15
15
"github.com/bluesky-social/indigo/atproto/lexicon"
16
16
"github.com/bluesky-social/indigo/atproto/syntax"
17
17
"tangled.sh/bnewbold.net/cobalt/atproto/netclient"
···
122
122
}
123
123
124
124
// remove $type (from record)
125
-
d, err := data.UnmarshalJSON(rec)
125
+
d, err := atdata.UnmarshalJSON(rec)
126
126
if err != nil {
127
127
return err
128
128
}
+4
-4
cmd/glot/status.go
+4
-4
cmd/glot/status.go
···
13
13
"sort"
14
14
15
15
"github.com/bluesky-social/indigo/api/agnostic"
16
-
"github.com/bluesky-social/indigo/atproto/client"
17
-
"github.com/bluesky-social/indigo/atproto/data"
16
+
"github.com/bluesky-social/indigo/atproto/atclient"
17
+
"github.com/bluesky-social/indigo/atproto/atdata"
18
18
"github.com/bluesky-social/indigo/atproto/identity"
19
19
"github.com/bluesky-social/indigo/atproto/lexicon"
20
20
"github.com/bluesky-social/indigo/atproto/syntax"
···
83
83
return nil
84
84
}
85
85
86
-
local, err := data.UnmarshalJSON(localJSON)
86
+
local, err := atdata.UnmarshalJSON(localJSON)
87
87
if err != nil {
88
88
return err
89
89
}
90
-
remote, err := data.UnmarshalJSON(remoteJSON)
90
+
remote, err := atdata.UnmarshalJSON(remoteJSON)
91
91
if err != nil {
92
92
return err
93
93
}
+1
-1
cmd/glot/unpublish.go
+1
-1
cmd/glot/unpublish.go
···
6
6
"sort"
7
7
8
8
comatproto "github.com/bluesky-social/indigo/api/atproto"
9
-
"github.com/bluesky-social/indigo/atproto/client"
9
+
"github.com/bluesky-social/indigo/atproto/atclient"
10
10
"github.com/bluesky-social/indigo/atproto/identity"
11
11
"github.com/bluesky-social/indigo/atproto/syntax"
12
12
+3
-3
cmd/lexidex/load.go
+3
-3
cmd/lexidex/load.go
···
12
12
"path/filepath"
13
13
"strings"
14
14
15
-
"github.com/bluesky-social/indigo/atproto/data"
15
+
"github.com/bluesky-social/indigo/atproto/atdata"
16
16
"github.com/bluesky-social/indigo/atproto/lexicon"
17
17
"github.com/bluesky-social/indigo/atproto/syntax"
18
18
···
48
48
}
49
49
50
50
// compute CID
51
-
rec, err := data.UnmarshalJSON(raw)
51
+
rec, err := atdata.UnmarshalJSON(raw)
52
52
if err != nil {
53
53
return err
54
54
}
55
-
cbytes, err := data.MarshalCBOR(rec)
55
+
cbytes, err := atdata.MarshalCBOR(rec)
56
56
if err != nil {
57
57
return err
58
58
}
+3
-3
cmd/slinky/main.go
+3
-3
cmd/slinky/main.go
···
9
9
"sync"
10
10
11
11
comatproto "github.com/bluesky-social/indigo/api/atproto"
12
-
"github.com/bluesky-social/indigo/atproto/client"
13
-
"github.com/bluesky-social/indigo/atproto/data"
12
+
"github.com/bluesky-social/indigo/atproto/atclient"
13
+
"github.com/bluesky-social/indigo/atproto/atdata"
14
14
"github.com/bluesky-social/indigo/atproto/repo"
15
15
"github.com/bluesky-social/indigo/atproto/syntax"
16
16
"tangled.sh/bnewbold.net/cobalt/atproto/netclient"
···
228
228
return err
229
229
}
230
230
231
-
recVal, err := data.UnmarshalCBOR(recBytes)
231
+
recVal, err := atdata.UnmarshalCBOR(recBytes)
232
232
if err != nil {
233
233
return err
234
234
}