commit a4ae9988a8f9391f2369ac031903ea1a5b4c413d · hailey.at/cocoon

+2 -2

cmd/cocoon/main.go

···

       9
        
       	"os"

     

       10
        
       	"time"

     

       11
        
       

     

       12
       -
       	"github.com/bluesky-social/indigo/atproto/crypto"

     

       13
        
       	"github.com/bluesky-social/indigo/atproto/syntax"

     

       14
        
       	"github.com/haileyok/cocoon/internal/helpers"

     

       15
        
       	"github.com/haileyok/cocoon/server"

     
···

       217
        
       		},

     

       218
        
       	},

     

       219
        
       	Action: func(cmd *cli.Context) error {

     

       220
       -
       		key, err := crypto.GeneratePrivateKeyK256()

     

       221
        
       		if err != nil {

     

       222
        
       			return err

     

       223
        
       		}

···

       9
        
       	"os"

     

       10
        
       	"time"

     

       11
        
       

     

       12
       +
       	"github.com/bluesky-social/indigo/atproto/atcrypto"

     

       13
        
       	"github.com/bluesky-social/indigo/atproto/syntax"

     

       14
        
       	"github.com/haileyok/cocoon/internal/helpers"

     

       15
        
       	"github.com/haileyok/cocoon/server"

     
···

       217
        
       		},

     

       218
        
       	},

     

       219
        
       	Action: func(cmd *cli.Context) error {

     

       220
       +
       		key, err := atcrypto.GeneratePrivateKeyK256()

     

       221
        
       		if err != nil {

     

       222
        
       			return err

     

       223
        
       		}

+1 -1

go.mod

···

       5
        
       require (

     

       6
        
       	github.com/Azure/go-autorest/autorest/to v0.4.1

     

       7
        
       	github.com/aws/aws-sdk-go v1.55.7

     

       8
       -
       	github.com/bluesky-social/indigo v0.0.0-20250924132341-b4dd6383c76f

     

       9
        
       	github.com/btcsuite/websocket v0.0.0-20150119174127-31079b680792

     

       10
        
       	github.com/domodwyer/mailyak/v3 v3.6.2

     

       11
        
       	github.com/go-pkgz/expirable-cache/v3 v3.0.0

···

       5
        
       require (

     

       6
        
       	github.com/Azure/go-autorest/autorest/to v0.4.1

     

       7
        
       	github.com/aws/aws-sdk-go v1.55.7

     

       8
       +
       	github.com/bluesky-social/indigo v0.0.0-20251009212240-20524de167fe

     

       9
        
       	github.com/btcsuite/websocket v0.0.0-20150119174127-31079b680792

     

       10
        
       	github.com/domodwyer/mailyak/v3 v3.6.2

     

       11
        
       	github.com/go-pkgz/expirable-cache/v3 v3.0.0

+2 -2

go.sum

···

       16
        
       github.com/beorn7/perks v1.0.1/go.mod h1:G2ZrVWU2WbWT9wwq4/hrbKbnv/1ERSJQ0ibhJ6rlkpw=

     

       17
        
       github.com/bitly/go-hostpool v0.0.0-20171023180738-a3a6125de932 h1:mXoPYz/Ul5HYEDvkta6I8/rnYM5gSdSV2tJ6XbZuEtY=

     

       18
        
       github.com/bitly/go-hostpool v0.0.0-20171023180738-a3a6125de932/go.mod h1:NOuUCSz6Q9T7+igc/hlvDOUdtWKryOrtFyIVABv/p7k=

     

       19
       -
       github.com/bluesky-social/indigo v0.0.0-20250924132341-b4dd6383c76f h1:DJufFBQBXlekAk1aZF9MgmmBmk1zBQNQOs0AZl2uUos=

     

       20
       -
       github.com/bluesky-social/indigo v0.0.0-20250924132341-b4dd6383c76f/go.mod h1:n6QE1NDPFoi7PRbMUZmc2y7FibCqiVU4ePpsvhHUBR8=

     

       21
        
       github.com/bmizerany/assert v0.0.0-20160611221934-b7ed37b82869 h1:DDGfHa7BWjL4YnC6+E63dPcxHo2sUxDIu8g3QgEJdRY=

     

       22
        
       github.com/bmizerany/assert v0.0.0-20160611221934-b7ed37b82869/go.mod h1:Ekp36dRnpXw/yCqJaO+ZrUyxD+3VXMFFr56k5XYrpB4=

     

       23
        
       github.com/btcsuite/websocket v0.0.0-20150119174127-31079b680792 h1:R8vQdOQdZ9Y3SkEwmHoWBmX1DNXhXZqlTpq6s4tyJGc=

···

       16
        
       github.com/beorn7/perks v1.0.1/go.mod h1:G2ZrVWU2WbWT9wwq4/hrbKbnv/1ERSJQ0ibhJ6rlkpw=

     

       17
        
       github.com/bitly/go-hostpool v0.0.0-20171023180738-a3a6125de932 h1:mXoPYz/Ul5HYEDvkta6I8/rnYM5gSdSV2tJ6XbZuEtY=

     

       18
        
       github.com/bitly/go-hostpool v0.0.0-20171023180738-a3a6125de932/go.mod h1:NOuUCSz6Q9T7+igc/hlvDOUdtWKryOrtFyIVABv/p7k=

     

       19
       +
       github.com/bluesky-social/indigo v0.0.0-20251009212240-20524de167fe h1:VBhaqE5ewQgXbY5SfSWFZC/AwHFo7cHxZKFYi2ce9Yo=

     

       20
       +
       github.com/bluesky-social/indigo v0.0.0-20251009212240-20524de167fe/go.mod h1:RuQVrCGm42QNsgumKaR6se+XkFKfCPNwdCiTvqKRUck=

     

       21
        
       github.com/bmizerany/assert v0.0.0-20160611221934-b7ed37b82869 h1:DDGfHa7BWjL4YnC6+E63dPcxHo2sUxDIu8g3QgEJdRY=

     

       22
        
       github.com/bmizerany/assert v0.0.0-20160611221934-b7ed37b82869/go.mod h1:Ekp36dRnpXw/yCqJaO+ZrUyxD+3VXMFFr56k5XYrpB4=

     

       23
        
       github.com/btcsuite/websocket v0.0.0-20150119174127-31079b680792 h1:R8vQdOQdZ9Y3SkEwmHoWBmX1DNXhXZqlTpq6s4tyJGc=

+2 -2

models/models.go

···

       5
        
       	"time"

     

       6
        
       

     

       7
        
       	"github.com/Azure/go-autorest/autorest/to"

     

       8
       -
       	"github.com/bluesky-social/indigo/atproto/crypto"

     

       9
        
       )

     

       10
        
       

     

       11
        
       type Repo struct {

     
···

       28
        
       }

     

       29
        
       

     

       30
        
       func (r *Repo) SignFor(ctx context.Context, did string, msg []byte) ([]byte, error) {

     

       31
       -
       	k, err := crypto.ParsePrivateBytesK256(r.SigningKey)

     

       32
        
       	if err != nil {

     

       33
        
       		return nil, err

     

       34
        
       	}

···

       5
        
       	"time"

     

       6
        
       

     

       7
        
       	"github.com/Azure/go-autorest/autorest/to"

     

       8
       +
       	"github.com/bluesky-social/indigo/atproto/atcrypto"

     

       9
        
       )

     

       10
        
       

     

       11
        
       type Repo struct {

     
···

       28
        
       }

     

       29
        
       

     

       30
        
       func (r *Repo) SignFor(ctx context.Context, did string, msg []byte) ([]byte, error) {

     

       31
       +
       	k, err := atcrypto.ParsePrivateBytesK256(r.SigningKey)

     

       32
        
       	if err != nil {

     

       33
        
       		return nil, err

     

       34
        
       	}

+5 -5

plc/client.go

···

       13
        
       	"net/url"

     

       14
        
       	"strings"

     

       15
        
       

     

       16
       -
       	"github.com/bluesky-social/indigo/atproto/crypto"

     

       17
        
       	"github.com/bluesky-social/indigo/util"

     

       18
        
       	"github.com/haileyok/cocoon/identity"

     

       19
        
       )

     
···

       22
        
       	h           *http.Client

     

       23
        
       	service     string

     

       24
        
       	pdsHostname string

     

       25
       -
       	rotationKey *crypto.PrivateKeyK256

     

       26
        
       }

     

       27
        
       

     

       28
        
       type ClientArgs struct {

     
···

       41
        
       		args.H = util.RobustHTTPClient()

     

       42
        
       	}

     

       43
        
       

     

       44
       -
       	rk, err := crypto.ParsePrivateBytesK256([]byte(args.RotationKey))

     

       45
        
       	if err != nil {

     

       46
        
       		return nil, err

     

       47
        
       	}

     
···

       54
        
       	}, nil

     

       55
        
       }

     

       56
        
       

     

       57
       -
       func (c *Client) CreateDID(sigkey *crypto.PrivateKeyK256, recovery string, handle string) (string, *Operation, error) {

     

       58
        
       	pubsigkey, err := sigkey.PublicKey()

     

       59
        
       	if err != nil {

     

       60
        
       		return "", nil, err

     
···

       107
        
       	return did, &op, nil

     

       108
        
       }

     

       109
        
       

     

       110
       -
       func (c *Client) SignOp(sigkey *crypto.PrivateKeyK256, op *Operation) error {

     

       111
        
       	b, err := op.MarshalCBOR()

     

       112
        
       	if err != nil {

     

       113
        
       		return err

···

       13
        
       	"net/url"

     

       14
        
       	"strings"

     

       15
        
       

     

       16
       +
       	"github.com/bluesky-social/indigo/atproto/atcrypto"

     

       17
        
       	"github.com/bluesky-social/indigo/util"

     

       18
        
       	"github.com/haileyok/cocoon/identity"

     

       19
        
       )

     
···

       22
        
       	h           *http.Client

     

       23
        
       	service     string

     

       24
        
       	pdsHostname string

     

       25
       +
       	rotationKey *atcrypto.PrivateKeyK256

     

       26
        
       }

     

       27
        
       

     

       28
        
       type ClientArgs struct {

     
···

       41
        
       		args.H = util.RobustHTTPClient()

     

       42
        
       	}

     

       43
        
       

     

       44
       +
       	rk, err := atcrypto.ParsePrivateBytesK256([]byte(args.RotationKey))

     

       45
        
       	if err != nil {

     

       46
        
       		return nil, err

     

       47
        
       	}

     
···

       54
        
       	}, nil

     

       55
        
       }

     

       56
        
       

     

       57
       +
       func (c *Client) CreateDID(sigkey *atcrypto.PrivateKeyK256, recovery string, handle string) (string, *Operation, error) {

     

       58
        
       	pubsigkey, err := sigkey.PublicKey()

     

       59
        
       	if err != nil {

     

       60
        
       		return "", nil, err

     
···

       107
        
       	return did, &op, nil

     

       108
        
       }

     

       109
        
       

     

       110
       +
       func (c *Client) SignOp(sigkey *atcrypto.PrivateKeyK256, op *Operation) error {

     

       111
        
       	b, err := op.MarshalCBOR()

     

       112
        
       	if err != nil {

     

       113
        
       		return err

+2 -2

plc/types.go

···

       3
        
       import (

     

       4
        
       	"encoding/json"

     

       5
        
       

     

       6
       -
       	"github.com/bluesky-social/indigo/atproto/data"

     

       7
        
       	"github.com/haileyok/cocoon/identity"

     

       8
        
       	cbg "github.com/whyrusleeping/cbor-gen"

     

       9
        
       )

     
···

       38
        
       		return nil, err

     

       39
        
       	}

     

       40
        
       

     

       41
       -
       	b, err = data.MarshalCBOR(m)

     

       42
        
       	if err != nil {

     

       43
        
       		return nil, err

     

       44
        
       	}

···

       3
        
       import (

     

       4
        
       	"encoding/json"

     

       5
        
       

     

       6
       +
       	"github.com/bluesky-social/indigo/atproto/atdata"

     

       7
        
       	"github.com/haileyok/cocoon/identity"

     

       8
        
       	cbg "github.com/whyrusleeping/cbor-gen"

     

       9
        
       )

     
···

       38
        
       		return nil, err

     

       39
        
       	}

     

       40
        
       

     

       41
       +
       	b, err = atdata.MarshalCBOR(m)

     

       42
        
       	if err != nil {

     

       43
        
       		return nil, err

     

       44
        
       	}

+2 -2

server/handle_identity_update_handle.go

···

       7
        
       

     

       8
        
       	"github.com/Azure/go-autorest/autorest/to"

     

       9
        
       	"github.com/bluesky-social/indigo/api/atproto"

     

       10
       -
       	"github.com/bluesky-social/indigo/atproto/crypto"

     

       11
        
       	"github.com/bluesky-social/indigo/events"

     

       12
        
       	"github.com/bluesky-social/indigo/util"

     

       13
        
       	"github.com/haileyok/cocoon/identity"

     
···

       66
        
       			Prev:                &latest.Cid,

     

       67
        
       		}

     

       68
        
       

     

       69
       -
       		k, err := crypto.ParsePrivateBytesK256(repo.SigningKey)

     

       70
        
       		if err != nil {

     

       71
        
       			s.logger.Error("error parsing signing key", "error", err)

     

       72
        
       			return helpers.ServerError(e, nil)

···

       7
        
       

     

       8
        
       	"github.com/Azure/go-autorest/autorest/to"

     

       9
        
       	"github.com/bluesky-social/indigo/api/atproto"

     

       10
       +
       	"github.com/bluesky-social/indigo/atproto/atcrypto"

     

       11
        
       	"github.com/bluesky-social/indigo/events"

     

       12
        
       	"github.com/bluesky-social/indigo/util"

     

       13
        
       	"github.com/haileyok/cocoon/identity"

     
···

       66
        
       			Prev:                &latest.Cid,

     

       67
        
       		}

     

       68
        
       

     

       69
       +
       		k, err := atcrypto.ParsePrivateBytesK256(repo.SigningKey)

     

       70
        
       		if err != nil {

     

       71
        
       			s.logger.Error("error parsing signing key", "error", err)

     

       72
        
       			return helpers.ServerError(e, nil)

+2 -2

server/handle_repo_get_record.go

···

       1
        
       package server

     

       2
        
       

     

       3
        
       import (

     

       4
       -
       	"github.com/bluesky-social/indigo/atproto/data"

     

       5
        
       	"github.com/bluesky-social/indigo/atproto/syntax"

     

       6
        
       	"github.com/haileyok/cocoon/models"

     

       7
        
       	"github.com/labstack/echo/v4"

     
···

       37
        
       		return err

     

       38
        
       	}

     

       39
        
       

     

       40
       -
       	val, err := data.UnmarshalCBOR(record.Value)

     

       41
        
       	if err != nil {

     

       42
        
       		return s.handleProxy(e) // TODO: this should be getting handled like...if we don't find it in the db. why doesn't it throw error up there?

     

       43
        
       	}

···

       1
        
       package server

     

       2
        
       

     

       3
        
       import (

     

       4
       +
       	"github.com/bluesky-social/indigo/atproto/atdata"

     

       5
        
       	"github.com/bluesky-social/indigo/atproto/syntax"

     

       6
        
       	"github.com/haileyok/cocoon/models"

     

       7
        
       	"github.com/labstack/echo/v4"

     
···

       37
        
       		return err

     

       38
        
       	}

     

       39
        
       

     

       40
       +
       	val, err := atdata.UnmarshalCBOR(record.Value)

     

       41
        
       	if err != nil {

     

       42
        
       		return s.handleProxy(e) // TODO: this should be getting handled like...if we don't find it in the db. why doesn't it throw error up there?

     

       43
        
       	}

+2 -2

server/handle_repo_list_records.go

···

       4
        
       	"strconv"

     

       5
        
       

     

       6
        
       	"github.com/Azure/go-autorest/autorest/to"

     

       7
       -
       	"github.com/bluesky-social/indigo/atproto/data"

     

       8
        
       	"github.com/bluesky-social/indigo/atproto/syntax"

     

       9
        
       	"github.com/haileyok/cocoon/internal/helpers"

     

       10
        
       	"github.com/haileyok/cocoon/models"

     
···

       100
        
       

     

       101
        
       	items := []ComAtprotoRepoListRecordsRecordItem{}

     

       102
        
       	for _, r := range records {

     

       103
       -
       		val, err := data.UnmarshalCBOR(r.Value)

     

       104
        
       		if err != nil {

     

       105
        
       			return err

     

       106
        
       		}

···

       4
        
       	"strconv"

     

       5
        
       

     

       6
        
       	"github.com/Azure/go-autorest/autorest/to"

     

       7
       +
       	"github.com/bluesky-social/indigo/atproto/atdata"

     

       8
        
       	"github.com/bluesky-social/indigo/atproto/syntax"

     

       9
        
       	"github.com/haileyok/cocoon/internal/helpers"

     

       10
        
       	"github.com/haileyok/cocoon/models"

     
···

       100
        
       

     

       101
        
       	items := []ComAtprotoRepoListRecordsRecordItem{}

     

       102
        
       	for _, r := range records {

     

       103
       +
       		val, err := atdata.UnmarshalCBOR(r.Value)

     

       104
        
       		if err != nil {

     

       105
        
       			return err

     

       106
        
       		}

+2 -2

server/handle_server_create_account.go

···

       9
        
       

     

       10
        
       	"github.com/Azure/go-autorest/autorest/to"

     

       11
        
       	"github.com/bluesky-social/indigo/api/atproto"

     

       12
       -
       	"github.com/bluesky-social/indigo/atproto/crypto"

     

       13
        
       	"github.com/bluesky-social/indigo/atproto/syntax"

     

       14
        
       	"github.com/bluesky-social/indigo/events"

     

       15
        
       	"github.com/bluesky-social/indigo/repo"

     
···

       125
        
       

     

       126
        
       	// TODO: unsupported domains

     

       127
        
       

     

       128
       -
       	k, err := crypto.GeneratePrivateKeyK256()

     

       129
        
       	if err != nil {

     

       130
        
       		s.logger.Error("error creating signing key", "endpoint", "com.atproto.server.createAccount", "error", err)

     

       131
        
       		return helpers.ServerError(e, nil)

···

       9
        
       

     

       10
        
       	"github.com/Azure/go-autorest/autorest/to"

     

       11
        
       	"github.com/bluesky-social/indigo/api/atproto"

     

       12
       +
       	"github.com/bluesky-social/indigo/atproto/atcrypto"

     

       13
        
       	"github.com/bluesky-social/indigo/atproto/syntax"

     

       14
        
       	"github.com/bluesky-social/indigo/events"

     

       15
        
       	"github.com/bluesky-social/indigo/repo"

     
···

       125
        
       

     

       126
        
       	// TODO: unsupported domains

     

       127
        
       

     

       128
       +
       	k, err := atcrypto.GeneratePrivateKeyK256()

     

       129
        
       	if err != nil {

     

       130
        
       		s.logger.Error("error creating signing key", "endpoint", "com.atproto.server.createAccount", "error", err)

     

       131
        
       		return helpers.ServerError(e, nil)

+7 -7

server/repo.go

···

       10
        
       

     

       11
        
       	"github.com/Azure/go-autorest/autorest/to"

     

       12
        
       	"github.com/bluesky-social/indigo/api/atproto"

     

       13
       -
       	"github.com/bluesky-social/indigo/atproto/data"

     

       14
        
       	"github.com/bluesky-social/indigo/atproto/syntax"

     

       15
        
       	"github.com/bluesky-social/indigo/carstore"

     

       16
        
       	"github.com/bluesky-social/indigo/events"

     
···

       72
        
       }

     

       73
        
       

     

       74
        
       func (mm *MarshalableMap) MarshalCBOR(w io.Writer) error {

     

       75
       -
       	data, err := data.MarshalCBOR(*mm)

     

       76
        
       	if err != nil {

     

       77
        
       		return err

     

       78
        
       	}

     
···

       133
        
       			if err != nil {

     

       134
        
       				return nil, err

     

       135
        
       			}

     

       136
       -
       			out, err := data.UnmarshalJSON(j)

     

       137
        
       			if err != nil {

     

       138
        
       				return nil, err

     

       139
        
       			}

     
···

       148
        
       			if err != nil {

     

       149
        
       				return nil, err

     

       150
        
       			}

     

       151
       -
       			d, err := data.MarshalCBOR(mm)

     

       152
        
       			if err != nil {

     

       153
        
       				return nil, err

     

       154
        
       			}

     
···

       189
        
       			if err != nil {

     

       190
        
       				return nil, err

     

       191
        
       			}

     

       192
       -
       			out, err := data.UnmarshalJSON(j)

     

       193
        
       			if err != nil {

     

       194
        
       				return nil, err

     

       195
        
       			}

     
···

       198
        
       			if err != nil {

     

       199
        
       				return nil, err

     

       200
        
       			}

     

       201
       -
       			d, err := data.MarshalCBOR(mm)

     

       202
        
       			if err != nil {

     

       203
        
       				return nil, err

     

       204
        
       			}

     
···

       415
        
       func getBlobCidsFromCbor(cbor []byte) ([]cid.Cid, error) {

     

       416
        
       	var cids []cid.Cid

     

       417
        
       

     

       418
       -
       	decoded, err := data.UnmarshalCBOR(cbor)

     

       419
        
       	if err != nil {

     

       420
        
       		return nil, fmt.Errorf("error unmarshaling cbor: %w", err)

     

       421
        
       	}

···

       10
        
       

     

       11
        
       	"github.com/Azure/go-autorest/autorest/to"

     

       12
        
       	"github.com/bluesky-social/indigo/api/atproto"

     

       13
       +
       	"github.com/bluesky-social/indigo/atproto/atdata"

     

       14
        
       	"github.com/bluesky-social/indigo/atproto/syntax"

     

       15
        
       	"github.com/bluesky-social/indigo/carstore"

     

       16
        
       	"github.com/bluesky-social/indigo/events"

     
···

       72
        
       }

     

       73
        
       

     

       74
        
       func (mm *MarshalableMap) MarshalCBOR(w io.Writer) error {

     

       75
       +
       	data, err := atdata.MarshalCBOR(*mm)

     

       76
        
       	if err != nil {

     

       77
        
       		return err

     

       78
        
       	}

     
···

       133
        
       			if err != nil {

     

       134
        
       				return nil, err

     

       135
        
       			}

     

       136
       +
       			out, err := atdata.UnmarshalJSON(j)

     

       137
        
       			if err != nil {

     

       138
        
       				return nil, err

     

       139
        
       			}

     
···

       148
        
       			if err != nil {

     

       149
        
       				return nil, err

     

       150
        
       			}

     

       151
       +
       			d, err := atdata.MarshalCBOR(mm)

     

       152
        
       			if err != nil {

     

       153
        
       				return nil, err

     

       154
        
       			}

     
···

       189
        
       			if err != nil {

     

       190
        
       				return nil, err

     

       191
        
       			}

     

       192
       +
       			out, err := atdata.UnmarshalJSON(j)

     

       193
        
       			if err != nil {

     

       194
        
       				return nil, err

     

       195
        
       			}

     
···

       198
        
       			if err != nil {

     

       199
        
       				return nil, err

     

       200
        
       			}

     

       201
       +
       			d, err := atdata.MarshalCBOR(mm)

     

       202
        
       			if err != nil {

     

       203
        
       				return nil, err

     

       204
        
       			}

     
···

       415
        
       func getBlobCidsFromCbor(cbor []byte) ([]cid.Cid, error) {

     

       416
        
       	var cids []cid.Cid

     

       417
        
       

     

       418
       +
       	decoded, err := atdata.UnmarshalCBOR(cbor)

     

       419
        
       	if err != nil {

     

       420
        
       		return nil, fmt.Errorf("error unmarshaling cbor: %w", err)

     

       421
        
       	}