bunch of refactoring, add getProfiles

api/server/actorgetprofile.go

···
 		return ErrInternalServerErr
 	}
 
-	profile, err := s.client.Profile.GetProfile(ctx, &vyletdatabase.GetProfileRequest{
+	resp, err := s.client.Profile.GetProfile(ctx, &vyletdatabase.GetProfileRequest{
 		Did: did,
 	})
 	if err != nil {
 		logger.Error("error getting profile", "err", err)
 		return ErrInternalServerErr
 	}
-	if profile.Error != nil {
-		if client.IsNotFoundError(profile.Error) {
+	if resp.Error != nil {
+		if client.IsNotFoundError(resp.Error) {
 			return ErrNotFound
 		}
 
-		logger.Error("error getting profile", "err", *profile.Error)
+		logger.Error("error getting profile", "err", *resp.Error)
 		return ErrInternalServerErr
 	}
 
 	pv := vylet.ActorDefs_ProfileView{
 		Did:         did,
 		Handle:      handle,
-		Description: profile.Description,
-		DisplayName: profile.DisplayName,
-		Avatar:      profile.Avatar,
-		CreatedAt:   profile.CreatedAt.AsTime().Format(time.RFC3339Nano),
-		IndexedAt:   profile.IndexedAt.AsTime().Format(time.RFC3339Nano),
+		Avatar:      resp.Profile.Avatar,
+		Description: resp.Profile.Description,
+		DisplayName: resp.Profile.DisplayName,
+		Pronouns:    resp.Profile.Pronouns,
+		CreatedAt:   resp.Profile.CreatedAt.AsTime().Format(time.RFC3339Nano),
+		IndexedAt:   resp.Profile.IndexedAt.AsTime().Format(time.RFC3339Nano),
 		Viewer: &vylet.ActorDefs_ViewerState{
 			BlockedBy:  new(bool),
 			Blocking:   new(string),
···
 			Following:  new(string),
 			Muted:      new(bool),
 		},
-		Pronouns: new(string),
 	}
 
 	return e.JSON(200, pv)

api/server/actorgetprofiles.go

···
+package server
+
+import (
+	"sync"
+	"time"
+
+	"github.com/labstack/echo/v4"
+	"github.com/vylet-app/go/database/client"
+	vyletdatabase "github.com/vylet-app/go/database/proto"
+	"github.com/vylet-app/go/generated/vylet"
+)
+
+type ActorGetProfilesInput struct {
+	Dids []string `query:"dids"`
+}
+
+func (s *Server) handleGetProfiles(e echo.Context) error {
+	ctx := e.Request().Context()
+	logger := s.logger.With("name", "handleActorGetProfiles")
+
+	var input ActorGetProfilesInput
+	if err := e.Bind(&input); err != nil {
+		return ErrInternalServerErr
+	}
+
+	if len(input.Dids) == 0 {
+		return NewValidationError("dids", "at least one DID is required")
+	}
+
+	if len(input.Dids) > 25 {
+		return NewValidationError("dids", "at most 25 DIDs may be supplied")
+	}
+
+	logger = logger.With("dids", input.Dids)
+
+	resp, err := s.client.Profile.GetProfiles(ctx, &vyletdatabase.GetProfilesRequest{
+		Dids: input.Dids,
+	})
+	if err != nil {
+		logger.Error("error getting profile", "err", err)
+		return ErrInternalServerErr
+	}
+	if resp.Error != nil {
+		if client.IsNotFoundError(resp.Error) {
+			return ErrNotFound
+		}
+
+		logger.Error("error getting profile", "err", *resp.Error)
+		return ErrInternalServerErr
+	}
+
+	profiles := make([]vylet.ActorDefs_ProfileView, 0, len(resp.Profiles))
+	var wg sync.WaitGroup
+	var lk sync.Mutex
+	for _, profile := range resp.Profiles {
+		wg.Go(func() {
+			_, handle, err := s.fetchDidHandleFromActor(ctx, profile.Did)
+			if err != nil {
+				s.logger.Error("error getting handle for did", "did", profile.Did, "err", err)
+				return
+			}
+
+			lk.Lock()
+			defer lk.Unlock()
+			profiles = append(profiles, vylet.ActorDefs_ProfileView{
+				Did:         profile.Did,
+				Handle:      handle,
+				Avatar:      profile.Avatar,
+				Description: profile.Description,
+				DisplayName: profile.DisplayName,
+				Pronouns:    profile.Pronouns,
+				CreatedAt:   profile.CreatedAt.AsTime().Format(time.RFC3339Nano),
+				IndexedAt:   profile.IndexedAt.AsTime().Format(time.RFC3339Nano),
+				Viewer: &vylet.ActorDefs_ViewerState{
+					BlockedBy:  new(bool),
+					Blocking:   new(string),
+					FollowedBy: new(string),
+					Following:  new(string),
+					Muted:      new(bool),
+				},
+			})
+		})
+	}
+	wg.Wait()
+
+	return e.JSON(200, profiles)
+}

api/server/server.go

···
 func (s *Server) registerHandlers() {
 	// app.vylet.actor
 	s.echo.GET("/xrpc/app.vylet.actor.getProfile", s.handleGetProfile)
+	s.echo.GET("/xrpc/app.vylet.actor.getProfiles", s.handleGetProfiles)
 }
 
 func (s *Server) errorHandler(err error, c echo.Context) {

database/client/client.go

···
 type Client struct {
 	client  *grpc.ClientConn
 	Profile vyletdatabase.ProfileServiceClient
+	Post    vyletdatabase.PostServiceClient
 }
 
 type Args struct {

database/proto/post.pb.go

···
+// Code generated by protoc-gen-go. DO NOT EDIT.
+// versions:
+// 	protoc-gen-go v1.36.6
+// 	protoc        (unknown)
+// source: post.proto
+
+package vyletdatabase
+
+import (
+	_ "buf.build/gen/go/bufbuild/protovalidate/protocolbuffers/go/buf/validate"
+	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
+	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
+	timestamppb "google.golang.org/protobuf/types/known/timestamppb"
+	reflect "reflect"
+	sync "sync"
+	unsafe "unsafe"
+)
+
+const (
+	// Verify that this generated code is sufficiently up-to-date.
+	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
+	// Verify that runtime/protoimpl is sufficiently up-to-date.
+	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
+)
+
+type Image struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	Cid           string                 `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
+	Alt           *string                `protobuf:"bytes,2,opt,name=alt,proto3,oneof" json:"alt,omitempty"`
+	Width         *int64                 `protobuf:"varint,3,opt,name=width,proto3,oneof" json:"width,omitempty"`
+	Height        *int64                 `protobuf:"varint,4,opt,name=height,proto3,oneof" json:"height,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *Image) Reset() {
+	*x = Image{}
+	mi := &file_post_proto_msgTypes[0]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *Image) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*Image) ProtoMessage() {}
+
+func (x *Image) ProtoReflect() protoreflect.Message {
+	mi := &file_post_proto_msgTypes[0]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use Image.ProtoReflect.Descriptor instead.
+func (*Image) Descriptor() ([]byte, []int) {
+	return file_post_proto_rawDescGZIP(), []int{0}
+}
+
+func (x *Image) GetCid() string {
+	if x != nil {
+		return x.Cid
+	}
+	return ""
+}
+
+func (x *Image) GetAlt() string {
+	if x != nil && x.Alt != nil {
+		return *x.Alt
+	}
+	return ""
+}
+
+func (x *Image) GetWidth() int64 {
+	if x != nil && x.Width != nil {
+		return *x.Width
+	}
+	return 0
+}
+
+func (x *Image) GetHeight() int64 {
+	if x != nil && x.Height != nil {
+		return *x.Height
+	}
+	return 0
+}
+
+type Post struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	Uri           string                 `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
+	Images        []*Image               `protobuf:"bytes,2,rep,name=images,proto3" json:"images,omitempty"`
+	Caption       *string                `protobuf:"bytes,3,opt,name=caption,proto3,oneof" json:"caption,omitempty"`
+	Facets        []byte                 `protobuf:"bytes,4,opt,name=facets,proto3,oneof" json:"facets,omitempty"`
+	CreatedAt     *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
+	IndexedAt     *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=indexed_at,json=indexedAt,proto3" json:"indexed_at,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *Post) Reset() {
+	*x = Post{}
+	mi := &file_post_proto_msgTypes[1]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *Post) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*Post) ProtoMessage() {}
+
+func (x *Post) ProtoReflect() protoreflect.Message {
+	mi := &file_post_proto_msgTypes[1]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use Post.ProtoReflect.Descriptor instead.
+func (*Post) Descriptor() ([]byte, []int) {
+	return file_post_proto_rawDescGZIP(), []int{1}
+}
+
+func (x *Post) GetUri() string {
+	if x != nil {
+		return x.Uri
+	}
+	return ""
+}
+
+func (x *Post) GetImages() []*Image {
+	if x != nil {
+		return x.Images
+	}
+	return nil
+}
+
+func (x *Post) GetCaption() string {
+	if x != nil && x.Caption != nil {
+		return *x.Caption
+	}
+	return ""
+}
+
+func (x *Post) GetFacets() []byte {
+	if x != nil {
+		return x.Facets
+	}
+	return nil
+}
+
+func (x *Post) GetCreatedAt() *timestamppb.Timestamp {
+	if x != nil {
+		return x.CreatedAt
+	}
+	return nil
+}
+
+func (x *Post) GetIndexedAt() *timestamppb.Timestamp {
+	if x != nil {
+		return x.IndexedAt
+	}
+	return nil
+}
+
+type CreatePostRequest struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	Post          *Post                  `protobuf:"bytes,1,opt,name=post,proto3" json:"post,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *CreatePostRequest) Reset() {
+	*x = CreatePostRequest{}
+	mi := &file_post_proto_msgTypes[2]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *CreatePostRequest) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*CreatePostRequest) ProtoMessage() {}
+
+func (x *CreatePostRequest) ProtoReflect() protoreflect.Message {
+	mi := &file_post_proto_msgTypes[2]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use CreatePostRequest.ProtoReflect.Descriptor instead.
+func (*CreatePostRequest) Descriptor() ([]byte, []int) {
+	return file_post_proto_rawDescGZIP(), []int{2}
+}
+
+func (x *CreatePostRequest) GetPost() *Post {
+	if x != nil {
+		return x.Post
+	}
+	return nil
+}
+
+type CreatePostResponse struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	Error         *string                `protobuf:"bytes,1,opt,name=error,proto3,oneof" json:"error,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *CreatePostResponse) Reset() {
+	*x = CreatePostResponse{}
+	mi := &file_post_proto_msgTypes[3]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *CreatePostResponse) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*CreatePostResponse) ProtoMessage() {}
+
+func (x *CreatePostResponse) ProtoReflect() protoreflect.Message {
+	mi := &file_post_proto_msgTypes[3]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use CreatePostResponse.ProtoReflect.Descriptor instead.
+func (*CreatePostResponse) Descriptor() ([]byte, []int) {
+	return file_post_proto_rawDescGZIP(), []int{3}
+}
+
+func (x *CreatePostResponse) GetError() string {
+	if x != nil && x.Error != nil {
+		return *x.Error
+	}
+	return ""
+}
+
+type DeletePostRequest struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	Uri           string                 `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *DeletePostRequest) Reset() {
+	*x = DeletePostRequest{}
+	mi := &file_post_proto_msgTypes[4]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *DeletePostRequest) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*DeletePostRequest) ProtoMessage() {}
+
+func (x *DeletePostRequest) ProtoReflect() protoreflect.Message {
+	mi := &file_post_proto_msgTypes[4]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use DeletePostRequest.ProtoReflect.Descriptor instead.
+func (*DeletePostRequest) Descriptor() ([]byte, []int) {
+	return file_post_proto_rawDescGZIP(), []int{4}
+}
+
+func (x *DeletePostRequest) GetUri() string {
+	if x != nil {
+		return x.Uri
+	}
+	return ""
+}
+
+type DeletePostResponse struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	Error         *string                `protobuf:"bytes,1,opt,name=error,proto3,oneof" json:"error,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *DeletePostResponse) Reset() {
+	*x = DeletePostResponse{}
+	mi := &file_post_proto_msgTypes[5]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *DeletePostResponse) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*DeletePostResponse) ProtoMessage() {}
+
+func (x *DeletePostResponse) ProtoReflect() protoreflect.Message {
+	mi := &file_post_proto_msgTypes[5]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use DeletePostResponse.ProtoReflect.Descriptor instead.
+func (*DeletePostResponse) Descriptor() ([]byte, []int) {
+	return file_post_proto_rawDescGZIP(), []int{5}
+}
+
+func (x *DeletePostResponse) GetError() string {
+	if x != nil && x.Error != nil {
+		return *x.Error
+	}
+	return ""
+}
+
+type GetPostRequest struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	Uri           string                 `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *GetPostRequest) Reset() {
+	*x = GetPostRequest{}
+	mi := &file_post_proto_msgTypes[6]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *GetPostRequest) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*GetPostRequest) ProtoMessage() {}
+
+func (x *GetPostRequest) ProtoReflect() protoreflect.Message {
+	mi := &file_post_proto_msgTypes[6]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use GetPostRequest.ProtoReflect.Descriptor instead.
+func (*GetPostRequest) Descriptor() ([]byte, []int) {
+	return file_post_proto_rawDescGZIP(), []int{6}
+}
+
+func (x *GetPostRequest) GetUri() string {
+	if x != nil {
+		return x.Uri
+	}
+	return ""
+}
+
+type GetPostResponse struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	Error         *string                `protobuf:"bytes,1,opt,name=error,proto3,oneof" json:"error,omitempty"`
+	Post          *Post                  `protobuf:"bytes,2,opt,name=post,proto3,oneof" json:"post,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *GetPostResponse) Reset() {
+	*x = GetPostResponse{}
+	mi := &file_post_proto_msgTypes[7]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *GetPostResponse) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*GetPostResponse) ProtoMessage() {}
+
+func (x *GetPostResponse) ProtoReflect() protoreflect.Message {
+	mi := &file_post_proto_msgTypes[7]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use GetPostResponse.ProtoReflect.Descriptor instead.
+func (*GetPostResponse) Descriptor() ([]byte, []int) {
+	return file_post_proto_rawDescGZIP(), []int{7}
+}
+
+func (x *GetPostResponse) GetError() string {
+	if x != nil && x.Error != nil {
+		return *x.Error
+	}
+	return ""
+}
+
+func (x *GetPostResponse) GetPost() *Post {
+	if x != nil {
+		return x.Post
+	}
+	return nil
+}
+
+type GetPostsRequest struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	Uris          []string               `protobuf:"bytes,1,rep,name=uris,proto3" json:"uris,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *GetPostsRequest) Reset() {
+	*x = GetPostsRequest{}
+	mi := &file_post_proto_msgTypes[8]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *GetPostsRequest) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*GetPostsRequest) ProtoMessage() {}
+
+func (x *GetPostsRequest) ProtoReflect() protoreflect.Message {
+	mi := &file_post_proto_msgTypes[8]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use GetPostsRequest.ProtoReflect.Descriptor instead.
+func (*GetPostsRequest) Descriptor() ([]byte, []int) {
+	return file_post_proto_rawDescGZIP(), []int{8}
+}
+
+func (x *GetPostsRequest) GetUris() []string {
+	if x != nil {
+		return x.Uris
+	}
+	return nil
+}
+
+type GetPostsResponse struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	Error         *string                `protobuf:"bytes,1,opt,name=error,proto3,oneof" json:"error,omitempty"`
+	Posts         []*Post                `protobuf:"bytes,2,rep,name=posts,proto3" json:"posts,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *GetPostsResponse) Reset() {
+	*x = GetPostsResponse{}
+	mi := &file_post_proto_msgTypes[9]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *GetPostsResponse) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*GetPostsResponse) ProtoMessage() {}
+
+func (x *GetPostsResponse) ProtoReflect() protoreflect.Message {
+	mi := &file_post_proto_msgTypes[9]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use GetPostsResponse.ProtoReflect.Descriptor instead.
+func (*GetPostsResponse) Descriptor() ([]byte, []int) {
+	return file_post_proto_rawDescGZIP(), []int{9}
+}
+
+func (x *GetPostsResponse) GetError() string {
+	if x != nil && x.Error != nil {
+		return *x.Error
+	}
+	return ""
+}
+
+func (x *GetPostsResponse) GetPosts() []*Post {
+	if x != nil {
+		return x.Posts
+	}
+	return nil
+}
+
+var File_post_proto protoreflect.FileDescriptor
+
+const file_post_proto_rawDesc = "" +
+	"\n" +
+	"\n" +
+	"post.proto\x12\rvyletdatabase\x1a\x1bbuf/validate/validate.proto\x1a\x1fgoogle/protobuf/timestamp.proto\"\x8d\x01\n" +
+	"\x05Image\x12\x18\n" +
+	"\x03cid\x18\x01 \x01(\tB\x06\xbaH\x03\xc8\x01\x01R\x03cid\x12\x15\n" +
+	"\x03alt\x18\x02 \x01(\tH\x00R\x03alt\x88\x01\x01\x12\x19\n" +
+	"\x05width\x18\x03 \x01(\x03H\x01R\x05width\x88\x01\x01\x12\x1b\n" +
+	"\x06height\x18\x04 \x01(\x03H\x02R\x06height\x88\x01\x01B\x06\n" +
+	"\x04_altB\b\n" +
+	"\x06_widthB\t\n" +
+	"\a_height\"\x97\x02\n" +
+	"\x04Post\x12\x18\n" +
+	"\x03uri\x18\x01 \x01(\tB\x06\xbaH\x03\xc8\x01\x01R\x03uri\x12,\n" +
+	"\x06images\x18\x02 \x03(\v2\x14.vyletdatabase.ImageR\x06images\x12\x1d\n" +
+	"\acaption\x18\x03 \x01(\tH\x00R\acaption\x88\x01\x01\x12\x1b\n" +
+	"\x06facets\x18\x04 \x01(\fH\x01R\x06facets\x88\x01\x01\x129\n" +
+	"\n" +
+	"created_at\x18\x05 \x01(\v2\x1a.google.protobuf.TimestampR\tcreatedAt\x129\n" +
+	"\n" +
+	"indexed_at\x18\x06 \x01(\v2\x1a.google.protobuf.TimestampR\tindexedAtB\n" +
+	"\n" +
+	"\b_captionB\t\n" +
+	"\a_facets\"<\n" +
+	"\x11CreatePostRequest\x12'\n" +
+	"\x04post\x18\x01 \x01(\v2\x13.vyletdatabase.PostR\x04post\"9\n" +
+	"\x12CreatePostResponse\x12\x19\n" +
+	"\x05error\x18\x01 \x01(\tH\x00R\x05error\x88\x01\x01B\b\n" +
+	"\x06_error\"-\n" +
+	"\x11DeletePostRequest\x12\x18\n" +
+	"\x03uri\x18\x01 \x01(\tB\x06\xbaH\x03\xc8\x01\x01R\x03uri\"9\n" +
+	"\x12DeletePostResponse\x12\x19\n" +
+	"\x05error\x18\x01 \x01(\tH\x00R\x05error\x88\x01\x01B\b\n" +
+	"\x06_error\"*\n" +
+	"\x0eGetPostRequest\x12\x18\n" +
+	"\x03uri\x18\x01 \x01(\tB\x06\xbaH\x03\xc8\x01\x01R\x03uri\"m\n" +
+	"\x0fGetPostResponse\x12\x19\n" +
+	"\x05error\x18\x01 \x01(\tH\x00R\x05error\x88\x01\x01\x12,\n" +
+	"\x04post\x18\x02 \x01(\v2\x13.vyletdatabase.PostH\x01R\x04post\x88\x01\x01B\b\n" +
+	"\x06_errorB\a\n" +
+	"\x05_post\"-\n" +
+	"\x0fGetPostsRequest\x12\x1a\n" +
+	"\x04uris\x18\x01 \x03(\tB\x06\xbaH\x03\xc8\x01\x01R\x04uris\"b\n" +
+	"\x10GetPostsResponse\x12\x19\n" +
+	"\x05error\x18\x01 \x01(\tH\x00R\x05error\x88\x01\x01\x12)\n" +
+	"\x05posts\x18\x02 \x03(\v2\x13.vyletdatabase.PostR\x05postsB\b\n" +
+	"\x06_error2\xca\x02\n" +
+	"\vPostService\x12Q\n" +
+	"\n" +
+	"CreatePost\x12 .vyletdatabase.CreatePostRequest\x1a!.vyletdatabase.CreatePostResponse\x12Q\n" +
+	"\n" +
+	"DeletePost\x12 .vyletdatabase.DeletePostRequest\x1a!.vyletdatabase.DeletePostResponse\x12H\n" +
+	"\aGetPost\x12\x1d.vyletdatabase.GetPostRequest\x1a\x1e.vyletdatabase.GetPostResponse\x12K\n" +
+	"\bGetPosts\x12\x1e.vyletdatabase.GetPostsRequest\x1a\x1f.vyletdatabase.GetPostsResponseB\x84\x01\n" +
+	"\x11com.vyletdatabaseB\tPostProtoP\x01Z\x10./;vyletdatabase\xa2\x02\x03VXX\xaa\x02\rVyletdatabase\xca\x02\rVyletdatabase\xe2\x02\x19Vyletdatabase\\GPBMetadata\xea\x02\rVyletdatabaseb\x06proto3"
+
+var (
+	file_post_proto_rawDescOnce sync.Once
+	file_post_proto_rawDescData []byte
+)
+
+func file_post_proto_rawDescGZIP() []byte {
+	file_post_proto_rawDescOnce.Do(func() {
+		file_post_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_post_proto_rawDesc), len(file_post_proto_rawDesc)))
+	})
+	return file_post_proto_rawDescData
+}
+
+var file_post_proto_msgTypes = make([]protoimpl.MessageInfo, 10)
+var file_post_proto_goTypes = []any{
+	(*Image)(nil),                 // 0: vyletdatabase.Image
+	(*Post)(nil),                  // 1: vyletdatabase.Post
+	(*CreatePostRequest)(nil),     // 2: vyletdatabase.CreatePostRequest
+	(*CreatePostResponse)(nil),    // 3: vyletdatabase.CreatePostResponse
+	(*DeletePostRequest)(nil),     // 4: vyletdatabase.DeletePostRequest
+	(*DeletePostResponse)(nil),    // 5: vyletdatabase.DeletePostResponse
+	(*GetPostRequest)(nil),        // 6: vyletdatabase.GetPostRequest
+	(*GetPostResponse)(nil),       // 7: vyletdatabase.GetPostResponse
+	(*GetPostsRequest)(nil),       // 8: vyletdatabase.GetPostsRequest
+	(*GetPostsResponse)(nil),      // 9: vyletdatabase.GetPostsResponse
+	(*timestamppb.Timestamp)(nil), // 10: google.protobuf.Timestamp
+}
+var file_post_proto_depIdxs = []int32{
+	0,  // 0: vyletdatabase.Post.images:type_name -> vyletdatabase.Image
+	10, // 1: vyletdatabase.Post.created_at:type_name -> google.protobuf.Timestamp
+	10, // 2: vyletdatabase.Post.indexed_at:type_name -> google.protobuf.Timestamp
+	1,  // 3: vyletdatabase.CreatePostRequest.post:type_name -> vyletdatabase.Post
+	1,  // 4: vyletdatabase.GetPostResponse.post:type_name -> vyletdatabase.Post
+	1,  // 5: vyletdatabase.GetPostsResponse.posts:type_name -> vyletdatabase.Post
+	2,  // 6: vyletdatabase.PostService.CreatePost:input_type -> vyletdatabase.CreatePostRequest
+	4,  // 7: vyletdatabase.PostService.DeletePost:input_type -> vyletdatabase.DeletePostRequest
+	6,  // 8: vyletdatabase.PostService.GetPost:input_type -> vyletdatabase.GetPostRequest
+	8,  // 9: vyletdatabase.PostService.GetPosts:input_type -> vyletdatabase.GetPostsRequest
+	3,  // 10: vyletdatabase.PostService.CreatePost:output_type -> vyletdatabase.CreatePostResponse
+	5,  // 11: vyletdatabase.PostService.DeletePost:output_type -> vyletdatabase.DeletePostResponse
+	7,  // 12: vyletdatabase.PostService.GetPost:output_type -> vyletdatabase.GetPostResponse
+	9,  // 13: vyletdatabase.PostService.GetPosts:output_type -> vyletdatabase.GetPostsResponse
+	10, // [10:14] is the sub-list for method output_type
+	6,  // [6:10] is the sub-list for method input_type
+	6,  // [6:6] is the sub-list for extension type_name
+	6,  // [6:6] is the sub-list for extension extendee
+	0,  // [0:6] is the sub-list for field type_name
+}
+
+func init() { file_post_proto_init() }
+func file_post_proto_init() {
+	if File_post_proto != nil {
+		return
+	}
+	file_post_proto_msgTypes[0].OneofWrappers = []any{}
+	file_post_proto_msgTypes[1].OneofWrappers = []any{}
+	file_post_proto_msgTypes[3].OneofWrappers = []any{}
+	file_post_proto_msgTypes[5].OneofWrappers = []any{}
+	file_post_proto_msgTypes[7].OneofWrappers = []any{}
+	file_post_proto_msgTypes[9].OneofWrappers = []any{}
+	type x struct{}
+	out := protoimpl.TypeBuilder{
+		File: protoimpl.DescBuilder{
+			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
+			RawDescriptor: unsafe.Slice(unsafe.StringData(file_post_proto_rawDesc), len(file_post_proto_rawDesc)),
+			NumEnums:      0,
+			NumMessages:   10,
+			NumExtensions: 0,
+			NumServices:   1,
+		},
+		GoTypes:           file_post_proto_goTypes,
+		DependencyIndexes: file_post_proto_depIdxs,
+		MessageInfos:      file_post_proto_msgTypes,
+	}.Build()
+	File_post_proto = out.File
+	file_post_proto_goTypes = nil
+	file_post_proto_depIdxs = nil
+}

database/proto/post.proto

···
+syntax = "proto3";
+
+package vyletdatabase;
+option go_package = "./;vyletdatabase";
+
+import "buf/validate/validate.proto";
+
+import "google/protobuf/timestamp.proto";
+
+service PostService {
+  rpc CreatePost(CreatePostRequest) returns (CreatePostResponse);
+  rpc DeletePost(DeletePostRequest) returns (DeletePostResponse);
+
+  rpc GetPost(GetPostRequest) returns (GetPostResponse);
+  rpc GetPosts(GetPostsRequest) returns (GetPostsResponse);
+}
+
+message Image {
+  string cid = 1 [
+    (buf.validate.field).required = true
+  ];
+  optional string alt = 2;
+  optional int64 width = 3;
+  optional int64 height = 4;
+}
+
+message Post {
+  string uri = 1 [
+    (buf.validate.field).required = true
+  ];
+  repeated Image images = 2;
+  optional string caption = 3;
+  optional bytes facets = 4;
+  google.protobuf.Timestamp created_at = 5;
+  google.protobuf.Timestamp indexed_at = 6;
+}
+
+message CreatePostRequest {
+  Post post = 1;
+}
+
+message CreatePostResponse {
+  optional string error = 1;
+}
+
+message DeletePostRequest {
+  string uri = 1 [
+    (buf.validate.field).required = true
+  ];
+}
+
+message DeletePostResponse {
+  optional string error = 1;
+}
+
+message GetPostRequest {
+  string uri = 1 [
+    (buf.validate.field).required = true
+  ];
+}
+
+message GetPostResponse {
+  optional string error = 1;
+  optional Post post = 2;
+}
+
+message GetPostsRequest {
+  repeated string uris = 1 [
+    (buf.validate.field).required = true
+  ];
+}
+
+message GetPostsResponse {
+  optional string error = 1;
+  repeated Post posts = 2;
+}

database/proto/post_grpc.pb.go

···
+// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
+// versions:
+// - protoc-gen-go-grpc v1.6.0
+// - protoc             (unknown)
+// source: post.proto
+
+package vyletdatabase
+
+import (
+	context "context"
+	grpc "google.golang.org/grpc"
+	codes "google.golang.org/grpc/codes"
+	status "google.golang.org/grpc/status"
+)
+
+// This is a compile-time assertion to ensure that this generated file
+// is compatible with the grpc package it is being compiled against.
+// Requires gRPC-Go v1.64.0 or later.
+const _ = grpc.SupportPackageIsVersion9
+
+const (
+	PostService_CreatePost_FullMethodName = "/vyletdatabase.PostService/CreatePost"
+	PostService_DeletePost_FullMethodName = "/vyletdatabase.PostService/DeletePost"
+	PostService_GetPost_FullMethodName    = "/vyletdatabase.PostService/GetPost"
+	PostService_GetPosts_FullMethodName   = "/vyletdatabase.PostService/GetPosts"
+)
+
+// PostServiceClient is the client API for PostService service.
+//
+// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
+type PostServiceClient interface {
+	CreatePost(ctx context.Context, in *CreatePostRequest, opts ...grpc.CallOption) (*CreatePostResponse, error)
+	DeletePost(ctx context.Context, in *DeletePostRequest, opts ...grpc.CallOption) (*DeletePostResponse, error)
+	GetPost(ctx context.Context, in *GetPostRequest, opts ...grpc.CallOption) (*GetPostResponse, error)
+	GetPosts(ctx context.Context, in *GetPostsRequest, opts ...grpc.CallOption) (*GetPostsResponse, error)
+}
+
+type postServiceClient struct {
+	cc grpc.ClientConnInterface
+}
+
+func NewPostServiceClient(cc grpc.ClientConnInterface) PostServiceClient {
+	return &postServiceClient{cc}
+}
+
+func (c *postServiceClient) CreatePost(ctx context.Context, in *CreatePostRequest, opts ...grpc.CallOption) (*CreatePostResponse, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+	out := new(CreatePostResponse)
+	err := c.cc.Invoke(ctx, PostService_CreatePost_FullMethodName, in, out, cOpts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *postServiceClient) DeletePost(ctx context.Context, in *DeletePostRequest, opts ...grpc.CallOption) (*DeletePostResponse, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+	out := new(DeletePostResponse)
+	err := c.cc.Invoke(ctx, PostService_DeletePost_FullMethodName, in, out, cOpts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *postServiceClient) GetPost(ctx context.Context, in *GetPostRequest, opts ...grpc.CallOption) (*GetPostResponse, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+	out := new(GetPostResponse)
+	err := c.cc.Invoke(ctx, PostService_GetPost_FullMethodName, in, out, cOpts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *postServiceClient) GetPosts(ctx context.Context, in *GetPostsRequest, opts ...grpc.CallOption) (*GetPostsResponse, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+	out := new(GetPostsResponse)
+	err := c.cc.Invoke(ctx, PostService_GetPosts_FullMethodName, in, out, cOpts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+// PostServiceServer is the server API for PostService service.
+// All implementations must embed UnimplementedPostServiceServer
+// for forward compatibility.
+type PostServiceServer interface {
+	CreatePost(context.Context, *CreatePostRequest) (*CreatePostResponse, error)
+	DeletePost(context.Context, *DeletePostRequest) (*DeletePostResponse, error)
+	GetPost(context.Context, *GetPostRequest) (*GetPostResponse, error)
+	GetPosts(context.Context, *GetPostsRequest) (*GetPostsResponse, error)
+	mustEmbedUnimplementedPostServiceServer()
+}
+
+// UnimplementedPostServiceServer must be embedded to have
+// forward compatible implementations.
+//
+// NOTE: this should be embedded by value instead of pointer to avoid a nil
+// pointer dereference when methods are called.
+type UnimplementedPostServiceServer struct{}
+
+func (UnimplementedPostServiceServer) CreatePost(context.Context, *CreatePostRequest) (*CreatePostResponse, error) {
+	return nil, status.Error(codes.Unimplemented, "method CreatePost not implemented")
+}
+func (UnimplementedPostServiceServer) DeletePost(context.Context, *DeletePostRequest) (*DeletePostResponse, error) {
+	return nil, status.Error(codes.Unimplemented, "method DeletePost not implemented")
+}
+func (UnimplementedPostServiceServer) GetPost(context.Context, *GetPostRequest) (*GetPostResponse, error) {
+	return nil, status.Error(codes.Unimplemented, "method GetPost not implemented")
+}
+func (UnimplementedPostServiceServer) GetPosts(context.Context, *GetPostsRequest) (*GetPostsResponse, error) {
+	return nil, status.Error(codes.Unimplemented, "method GetPosts not implemented")
+}
+func (UnimplementedPostServiceServer) mustEmbedUnimplementedPostServiceServer() {}
+func (UnimplementedPostServiceServer) testEmbeddedByValue()                     {}
+
+// UnsafePostServiceServer may be embedded to opt out of forward compatibility for this service.
+// Use of this interface is not recommended, as added methods to PostServiceServer will
+// result in compilation errors.
+type UnsafePostServiceServer interface {
+	mustEmbedUnimplementedPostServiceServer()
+}
+
+func RegisterPostServiceServer(s grpc.ServiceRegistrar, srv PostServiceServer) {
+	// If the following call panics, it indicates UnimplementedPostServiceServer was
+	// embedded by pointer and is nil.  This will cause panics if an
+	// unimplemented method is ever invoked, so we test this at initialization
+	// time to prevent it from happening at runtime later due to I/O.
+	if t, ok := srv.(interface{ testEmbeddedByValue() }); ok {
+		t.testEmbeddedByValue()
+	}
+	s.RegisterService(&PostService_ServiceDesc, srv)
+}
+
+func _PostService_CreatePost_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(CreatePostRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(PostServiceServer).CreatePost(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: PostService_CreatePost_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(PostServiceServer).CreatePost(ctx, req.(*CreatePostRequest))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _PostService_DeletePost_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(DeletePostRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(PostServiceServer).DeletePost(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: PostService_DeletePost_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(PostServiceServer).DeletePost(ctx, req.(*DeletePostRequest))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _PostService_GetPost_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetPostRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(PostServiceServer).GetPost(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: PostService_GetPost_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(PostServiceServer).GetPost(ctx, req.(*GetPostRequest))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _PostService_GetPosts_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetPostsRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(PostServiceServer).GetPosts(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: PostService_GetPosts_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(PostServiceServer).GetPosts(ctx, req.(*GetPostsRequest))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+// PostService_ServiceDesc is the grpc.ServiceDesc for PostService service.
+// It's only intended for direct use with grpc.RegisterService,
+// and not to be introspected or modified (even as a copy)
+var PostService_ServiceDesc = grpc.ServiceDesc{
+	ServiceName: "vyletdatabase.PostService",
+	HandlerType: (*PostServiceServer)(nil),
+	Methods: []grpc.MethodDesc{
+		{
+			MethodName: "CreatePost",
+			Handler:    _PostService_CreatePost_Handler,
+		},
+		{
+			MethodName: "DeletePost",
+			Handler:    _PostService_DeletePost_Handler,
+		},
+		{
+			MethodName: "GetPost",
+			Handler:    _PostService_GetPost_Handler,
+		},
+		{
+			MethodName: "GetPosts",
+			Handler:    _PostService_GetPosts_Handler,
+		},
+	},
+	Streams:  []grpc.StreamDesc{},
+	Metadata: "post.proto",
+}

database/proto/profile.pb.go

···
 	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
 )
 
-type GetProfileRequest struct {
+type Profile struct {
 	state         protoimpl.MessageState `protogen:"open.v1"`
 	Did           string                 `protobuf:"bytes,1,opt,name=did,proto3" json:"did,omitempty"`
+	DisplayName   *string                `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3,oneof" json:"display_name,omitempty"`
+	Description   *string                `protobuf:"bytes,3,opt,name=description,proto3,oneof" json:"description,omitempty"`
+	Pronouns      *string                `protobuf:"bytes,4,opt,name=pronouns,proto3,oneof" json:"pronouns,omitempty"`
+	Avatar        *string                `protobuf:"bytes,5,opt,name=avatar,proto3,oneof" json:"avatar,omitempty"`
+	CreatedAt     *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
+	IndexedAt     *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=indexed_at,json=indexedAt,proto3" json:"indexed_at,omitempty"`
 	unknownFields protoimpl.UnknownFields
 	sizeCache     protoimpl.SizeCache
 }
 
-func (x *GetProfileRequest) Reset() {
-	*x = GetProfileRequest{}
+func (x *Profile) Reset() {
+	*x = Profile{}
 	mi := &file_profile_proto_msgTypes[0]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
 
-func (x *GetProfileRequest) String() string {
+func (x *Profile) String() string {
 	return protoimpl.X.MessageStringOf(x)
 }
 
-func (*GetProfileRequest) ProtoMessage() {}
+func (*Profile) ProtoMessage() {}
 
-func (x *GetProfileRequest) ProtoReflect() protoreflect.Message {
+func (x *Profile) ProtoReflect() protoreflect.Message {
 	mi := &file_profile_proto_msgTypes[0]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
···
 	return mi.MessageOf(x)
 }
 
-// Deprecated: Use GetProfileRequest.ProtoReflect.Descriptor instead.
-func (*GetProfileRequest) Descriptor() ([]byte, []int) {
+// Deprecated: Use Profile.ProtoReflect.Descriptor instead.
+func (*Profile) Descriptor() ([]byte, []int) {
 	return file_profile_proto_rawDescGZIP(), []int{0}
 }
 
-func (x *GetProfileRequest) GetDid() string {
-	if x != nil {
-		return x.Did
-	}
-	return ""
-}
-
-type GetProfileResponse struct {
-	state         protoimpl.MessageState `protogen:"open.v1"`
-	Error         *string                `protobuf:"bytes,1,opt,name=error,proto3,oneof" json:"error,omitempty"`
-	Did           string                 `protobuf:"bytes,2,opt,name=did,proto3" json:"did,omitempty"`
-	DisplayName   *string                `protobuf:"bytes,3,opt,name=display_name,json=displayName,proto3,oneof" json:"display_name,omitempty"`
-	Description   *string                `protobuf:"bytes,4,opt,name=description,proto3,oneof" json:"description,omitempty"`
-	Pronouns      *string                `protobuf:"bytes,5,opt,name=pronouns,proto3,oneof" json:"pronouns,omitempty"`
-	Avatar        *string                `protobuf:"bytes,6,opt,name=avatar,proto3,oneof" json:"avatar,omitempty"`
-	CreatedAt     *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3,oneof" json:"created_at,omitempty"`
-	IndexedAt     *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=indexed_at,json=indexedAt,proto3" json:"indexed_at,omitempty"`
-	unknownFields protoimpl.UnknownFields
-	sizeCache     protoimpl.SizeCache
-}
-
-func (x *GetProfileResponse) Reset() {
-	*x = GetProfileResponse{}
-	mi := &file_profile_proto_msgTypes[1]
-	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
-	ms.StoreMessageInfo(mi)
-}
-
-func (x *GetProfileResponse) String() string {
-	return protoimpl.X.MessageStringOf(x)
-}
-
-func (*GetProfileResponse) ProtoMessage() {}
-
-func (x *GetProfileResponse) ProtoReflect() protoreflect.Message {
-	mi := &file_profile_proto_msgTypes[1]
-	if x != nil {
-		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
-		if ms.LoadMessageInfo() == nil {
-			ms.StoreMessageInfo(mi)
-		}
-		return ms
-	}
-	return mi.MessageOf(x)
-}
-
-// Deprecated: Use GetProfileResponse.ProtoReflect.Descriptor instead.
-func (*GetProfileResponse) Descriptor() ([]byte, []int) {
-	return file_profile_proto_rawDescGZIP(), []int{1}
-}
-
-func (x *GetProfileResponse) GetError() string {
-	if x != nil && x.Error != nil {
-		return *x.Error
-	}
-	return ""
-}
-
-func (x *GetProfileResponse) GetDid() string {
+func (x *Profile) GetDid() string {
 	if x != nil {
 		return x.Did
 	}
 	return ""
 }
 
-func (x *GetProfileResponse) GetDisplayName() string {
+func (x *Profile) GetDisplayName() string {
 	if x != nil && x.DisplayName != nil {
 		return *x.DisplayName
 	}
 	return ""
 }
 
-func (x *GetProfileResponse) GetDescription() string {
+func (x *Profile) GetDescription() string {
 	if x != nil && x.Description != nil {
 		return *x.Description
 	}
 	return ""
 }
 
-func (x *GetProfileResponse) GetPronouns() string {
+func (x *Profile) GetPronouns() string {
 	if x != nil && x.Pronouns != nil {
 		return *x.Pronouns
 	}
 	return ""
 }
 
-func (x *GetProfileResponse) GetAvatar() string {
+func (x *Profile) GetAvatar() string {
 	if x != nil && x.Avatar != nil {
 		return *x.Avatar
 	}
 	return ""
 }
 
-func (x *GetProfileResponse) GetCreatedAt() *timestamppb.Timestamp {
+func (x *Profile) GetCreatedAt() *timestamppb.Timestamp {
 	if x != nil {
 		return x.CreatedAt
 	}
 	return nil
 }
 
-func (x *GetProfileResponse) GetIndexedAt() *timestamppb.Timestamp {
+func (x *Profile) GetIndexedAt() *timestamppb.Timestamp {
 	if x != nil {
 		return x.IndexedAt
 	}
···
 
 type CreateProfileRequest struct {
 	state         protoimpl.MessageState `protogen:"open.v1"`
-	Did           string                 `protobuf:"bytes,1,opt,name=did,proto3" json:"did,omitempty"`
-	CreatedAt     *string                `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3,oneof" json:"created_at,omitempty"`
-	DisplayName   *string                `protobuf:"bytes,3,opt,name=display_name,json=displayName,proto3,oneof" json:"display_name,omitempty"`
-	Description   *string                `protobuf:"bytes,4,opt,name=description,proto3,oneof" json:"description,omitempty"`
-	Pronouns      *string                `protobuf:"bytes,5,opt,name=pronouns,proto3,oneof" json:"pronouns,omitempty"`
-	Avatar        *string                `protobuf:"bytes,6,opt,name=avatar,proto3,oneof" json:"avatar,omitempty"`
+	Profile       *Profile               `protobuf:"bytes,1,opt,name=profile,proto3" json:"profile,omitempty"`
 	unknownFields protoimpl.UnknownFields
 	sizeCache     protoimpl.SizeCache
 }
 
 func (x *CreateProfileRequest) Reset() {
 	*x = CreateProfileRequest{}
-	mi := &file_profile_proto_msgTypes[2]
+	mi := &file_profile_proto_msgTypes[1]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
···
 func (*CreateProfileRequest) ProtoMessage() {}
 
 func (x *CreateProfileRequest) ProtoReflect() protoreflect.Message {
-	mi := &file_profile_proto_msgTypes[2]
+	mi := &file_profile_proto_msgTypes[1]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
···
 
 // Deprecated: Use CreateProfileRequest.ProtoReflect.Descriptor instead.
 func (*CreateProfileRequest) Descriptor() ([]byte, []int) {
-	return file_profile_proto_rawDescGZIP(), []int{2}
+	return file_profile_proto_rawDescGZIP(), []int{1}
 }
 
-func (x *CreateProfileRequest) GetDid() string {
+func (x *CreateProfileRequest) GetProfile() *Profile {
 	if x != nil {
-		return x.Did
+		return x.Profile
 	}
-	return ""
-}
-
-func (x *CreateProfileRequest) GetCreatedAt() string {
-	if x != nil && x.CreatedAt != nil {
-		return *x.CreatedAt
-	}
-	return ""
-}
-
-func (x *CreateProfileRequest) GetDisplayName() string {
-	if x != nil && x.DisplayName != nil {
-		return *x.DisplayName
-	}
-	return ""
-}
-
-func (x *CreateProfileRequest) GetDescription() string {
-	if x != nil && x.Description != nil {
-		return *x.Description
-	}
-	return ""
-}
-
-func (x *CreateProfileRequest) GetPronouns() string {
-	if x != nil && x.Pronouns != nil {
-		return *x.Pronouns
-	}
-	return ""
-}
-
-func (x *CreateProfileRequest) GetAvatar() string {
-	if x != nil && x.Avatar != nil {
-		return *x.Avatar
-	}
-	return ""
+	return nil
 }
 
 type CreateProfileResponse struct {
···
 
 func (x *CreateProfileResponse) Reset() {
 	*x = CreateProfileResponse{}
-	mi := &file_profile_proto_msgTypes[3]
+	mi := &file_profile_proto_msgTypes[2]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
···
 func (*CreateProfileResponse) ProtoMessage() {}
 
 func (x *CreateProfileResponse) ProtoReflect() protoreflect.Message {
-	mi := &file_profile_proto_msgTypes[3]
+	mi := &file_profile_proto_msgTypes[2]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
···
 
 // Deprecated: Use CreateProfileResponse.ProtoReflect.Descriptor instead.
 func (*CreateProfileResponse) Descriptor() ([]byte, []int) {
-	return file_profile_proto_rawDescGZIP(), []int{3}
+	return file_profile_proto_rawDescGZIP(), []int{2}
 }
 
 func (x *CreateProfileResponse) GetError() string {
···
 
 func (x *DeleteProfileRequest) Reset() {
 	*x = DeleteProfileRequest{}
-	mi := &file_profile_proto_msgTypes[4]
+	mi := &file_profile_proto_msgTypes[3]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
···
 func (*DeleteProfileRequest) ProtoMessage() {}
 
 func (x *DeleteProfileRequest) ProtoReflect() protoreflect.Message {
-	mi := &file_profile_proto_msgTypes[4]
+	mi := &file_profile_proto_msgTypes[3]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
···
 
 // Deprecated: Use DeleteProfileRequest.ProtoReflect.Descriptor instead.
 func (*DeleteProfileRequest) Descriptor() ([]byte, []int) {
-	return file_profile_proto_rawDescGZIP(), []int{4}
+	return file_profile_proto_rawDescGZIP(), []int{3}
 }
 
 func (x *DeleteProfileRequest) GetDid() string {
···
 
 func (x *DeleteProfileResponse) Reset() {
 	*x = DeleteProfileResponse{}
-	mi := &file_profile_proto_msgTypes[5]
+	mi := &file_profile_proto_msgTypes[4]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
···
 func (*DeleteProfileResponse) ProtoMessage() {}
 
 func (x *DeleteProfileResponse) ProtoReflect() protoreflect.Message {
-	mi := &file_profile_proto_msgTypes[5]
+	mi := &file_profile_proto_msgTypes[4]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
···
 
 // Deprecated: Use DeleteProfileResponse.ProtoReflect.Descriptor instead.
 func (*DeleteProfileResponse) Descriptor() ([]byte, []int) {
+	return file_profile_proto_rawDescGZIP(), []int{4}
+}
+
+func (x *DeleteProfileResponse) GetError() string {
+	if x != nil && x.Error != nil {
+		return *x.Error
+	}
+	return ""
+}
+
+type GetProfileRequest struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	Did           string                 `protobuf:"bytes,1,opt,name=did,proto3" json:"did,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *GetProfileRequest) Reset() {
+	*x = GetProfileRequest{}
+	mi := &file_profile_proto_msgTypes[5]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *GetProfileRequest) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*GetProfileRequest) ProtoMessage() {}
+
+func (x *GetProfileRequest) ProtoReflect() protoreflect.Message {
+	mi := &file_profile_proto_msgTypes[5]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use GetProfileRequest.ProtoReflect.Descriptor instead.
+func (*GetProfileRequest) Descriptor() ([]byte, []int) {
 	return file_profile_proto_rawDescGZIP(), []int{5}
 }
 
-func (x *DeleteProfileResponse) GetError() string {
+func (x *GetProfileRequest) GetDid() string {
+	if x != nil {
+		return x.Did
+	}
+	return ""
+}
+
+type GetProfileResponse struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	Error         *string                `protobuf:"bytes,1,opt,name=error,proto3,oneof" json:"error,omitempty"`
+	Profile       *Profile               `protobuf:"bytes,2,opt,name=profile,proto3,oneof" json:"profile,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *GetProfileResponse) Reset() {
+	*x = GetProfileResponse{}
+	mi := &file_profile_proto_msgTypes[6]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *GetProfileResponse) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*GetProfileResponse) ProtoMessage() {}
+
+func (x *GetProfileResponse) ProtoReflect() protoreflect.Message {
+	mi := &file_profile_proto_msgTypes[6]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use GetProfileResponse.ProtoReflect.Descriptor instead.
+func (*GetProfileResponse) Descriptor() ([]byte, []int) {
+	return file_profile_proto_rawDescGZIP(), []int{6}
+}
+
+func (x *GetProfileResponse) GetError() string {
+	if x != nil && x.Error != nil {
+		return *x.Error
+	}
+	return ""
+}
+
+func (x *GetProfileResponse) GetProfile() *Profile {
+	if x != nil {
+		return x.Profile
+	}
+	return nil
+}
+
+type GetProfilesRequest struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	Dids          []string               `protobuf:"bytes,1,rep,name=dids,proto3" json:"dids,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *GetProfilesRequest) Reset() {
+	*x = GetProfilesRequest{}
+	mi := &file_profile_proto_msgTypes[7]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *GetProfilesRequest) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*GetProfilesRequest) ProtoMessage() {}
+
+func (x *GetProfilesRequest) ProtoReflect() protoreflect.Message {
+	mi := &file_profile_proto_msgTypes[7]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use GetProfilesRequest.ProtoReflect.Descriptor instead.
+func (*GetProfilesRequest) Descriptor() ([]byte, []int) {
+	return file_profile_proto_rawDescGZIP(), []int{7}
+}
+
+func (x *GetProfilesRequest) GetDids() []string {
+	if x != nil {
+		return x.Dids
+	}
+	return nil
+}
+
+type GetProfilesResponse struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	Error         *string                `protobuf:"bytes,1,opt,name=error,proto3,oneof" json:"error,omitempty"`
+	Profiles      []*Profile             `protobuf:"bytes,2,rep,name=profiles,proto3" json:"profiles,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *GetProfilesResponse) Reset() {
+	*x = GetProfilesResponse{}
+	mi := &file_profile_proto_msgTypes[8]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *GetProfilesResponse) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*GetProfilesResponse) ProtoMessage() {}
+
+func (x *GetProfilesResponse) ProtoReflect() protoreflect.Message {
+	mi := &file_profile_proto_msgTypes[8]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use GetProfilesResponse.ProtoReflect.Descriptor instead.
+func (*GetProfilesResponse) Descriptor() ([]byte, []int) {
+	return file_profile_proto_rawDescGZIP(), []int{8}
+}
+
+func (x *GetProfilesResponse) GetError() string {
 	if x != nil && x.Error != nil {
 		return *x.Error
 	}
 	return ""
 }
 
+func (x *GetProfilesResponse) GetProfiles() []*Profile {
+	if x != nil {
+		return x.Profiles
+	}
+	return nil
+}
+
 var File_profile_proto protoreflect.FileDescriptor
 
 const file_profile_proto_rawDesc = "" +
 	"\n" +
-	"\rprofile.proto\x12\rvyletdatabase\x1a\x1bbuf/validate/validate.proto\x1a\x1fgoogle/protobuf/timestamp.proto\"-\n" +
-	"\x11GetProfileRequest\x12\x18\n" +
-	"\x03did\x18\x01 \x01(\tB\x06\xbaH\x03\xc8\x01\x01R\x03did\"\xa3\x03\n" +
-	"\x12GetProfileResponse\x12\x19\n" +
-	"\x05error\x18\x01 \x01(\tH\x00R\x05error\x88\x01\x01\x12\x18\n" +
-	"\x03did\x18\x02 \x01(\tB\x06\xbaH\x03\xc8\x01\x01R\x03did\x12&\n" +
-	"\fdisplay_name\x18\x03 \x01(\tH\x01R\vdisplayName\x88\x01\x01\x12%\n" +
-	"\vdescription\x18\x04 \x01(\tH\x02R\vdescription\x88\x01\x01\x12\x1f\n" +
-	"\bpronouns\x18\x05 \x01(\tH\x03R\bpronouns\x88\x01\x01\x12\x1b\n" +
-	"\x06avatar\x18\x06 \x01(\tH\x04R\x06avatar\x88\x01\x01\x12>\n" +
+	"\rprofile.proto\x12\rvyletdatabase\x1a\x1bbuf/validate/validate.proto\x1a\x1fgoogle/protobuf/timestamp.proto\"\xdf\x02\n" +
+	"\aProfile\x12\x18\n" +
+	"\x03did\x18\x01 \x01(\tB\x06\xbaH\x03\xc8\x01\x01R\x03did\x12&\n" +
+	"\fdisplay_name\x18\x02 \x01(\tH\x00R\vdisplayName\x88\x01\x01\x12%\n" +
+	"\vdescription\x18\x03 \x01(\tH\x01R\vdescription\x88\x01\x01\x12\x1f\n" +
+	"\bpronouns\x18\x04 \x01(\tH\x02R\bpronouns\x88\x01\x01\x12\x1b\n" +
+	"\x06avatar\x18\x05 \x01(\tH\x03R\x06avatar\x88\x01\x01\x129\n" +
 	"\n" +
-	"created_at\x18\a \x01(\v2\x1a.google.protobuf.TimestampH\x05R\tcreatedAt\x88\x01\x01\x129\n" +
+	"created_at\x18\x06 \x01(\v2\x1a.google.protobuf.TimestampR\tcreatedAt\x129\n" +
 	"\n" +
-	"indexed_at\x18\b \x01(\v2\x1a.google.protobuf.TimestampR\tindexedAtB\b\n" +
-	"\x06_errorB\x0f\n" +
+	"indexed_at\x18\a \x01(\v2\x1a.google.protobuf.TimestampR\tindexedAtB\x0f\n" +
 	"\r_display_nameB\x0e\n" +
 	"\f_descriptionB\v\n" +
 	"\t_pronounsB\t\n" +
-	"\a_avatarB\r\n" +
-	"\v_created_at\"\xa9\x02\n" +
-	"\x14CreateProfileRequest\x12\x18\n" +
-	"\x03did\x18\x01 \x01(\tB\x06\xbaH\x03\xc8\x01\x01R\x03did\x12\"\n" +
-	"\n" +
-	"created_at\x18\x02 \x01(\tH\x00R\tcreatedAt\x88\x01\x01\x12&\n" +
-	"\fdisplay_name\x18\x03 \x01(\tH\x01R\vdisplayName\x88\x01\x01\x12%\n" +
-	"\vdescription\x18\x04 \x01(\tH\x02R\vdescription\x88\x01\x01\x12\x1f\n" +
-	"\bpronouns\x18\x05 \x01(\tH\x03R\bpronouns\x88\x01\x01\x12\x1b\n" +
-	"\x06avatar\x18\x06 \x01(\tH\x04R\x06avatar\x88\x01\x01B\r\n" +
-	"\v_created_atB\x0f\n" +
-	"\r_display_nameB\x0e\n" +
-	"\f_descriptionB\v\n" +
-	"\t_pronounsB\t\n" +
-	"\a_avatar\"<\n" +
+	"\a_avatar\"H\n" +
+	"\x14CreateProfileRequest\x120\n" +
+	"\aprofile\x18\x01 \x01(\v2\x16.vyletdatabase.ProfileR\aprofile\"<\n" +
 	"\x15CreateProfileResponse\x12\x19\n" +
 	"\x05error\x18\x01 \x01(\tH\x00R\x05error\x88\x01\x01B\b\n" +
 	"\x06_error\"0\n" +
···
 	"\x03did\x18\x01 \x01(\tB\x06\xbaH\x03\xc8\x01\x01R\x03did\"<\n" +
 	"\x15DeleteProfileResponse\x12\x19\n" +
 	"\x05error\x18\x01 \x01(\tH\x00R\x05error\x88\x01\x01B\b\n" +
-	"\x06_error2\x9b\x02\n" +
-	"\x0eProfileService\x12Q\n" +
+	"\x06_error\"-\n" +
+	"\x11GetProfileRequest\x12\x18\n" +
+	"\x03did\x18\x01 \x01(\tB\x06\xbaH\x03\xc8\x01\x01R\x03did\"|\n" +
+	"\x12GetProfileResponse\x12\x19\n" +
+	"\x05error\x18\x01 \x01(\tH\x00R\x05error\x88\x01\x01\x125\n" +
+	"\aprofile\x18\x02 \x01(\v2\x16.vyletdatabase.ProfileH\x01R\aprofile\x88\x01\x01B\b\n" +
+	"\x06_errorB\n" +
 	"\n" +
-	"GetProfile\x12 .vyletdatabase.GetProfileRequest\x1a!.vyletdatabase.GetProfileResponse\x12Z\n" +
-	"\rDeleteProfile\x12#.vyletdatabase.DeleteProfileRequest\x1a$.vyletdatabase.DeleteProfileResponse\x12Z\n" +
-	"\rCreateProfile\x12#.vyletdatabase.CreateProfileRequest\x1a$.vyletdatabase.CreateProfileResponseB\x87\x01\n" +
+	"\b_profile\"0\n" +
+	"\x12GetProfilesRequest\x12\x1a\n" +
+	"\x04dids\x18\x01 \x03(\tB\x06\xbaH\x03\xc8\x01\x01R\x04dids\"n\n" +
+	"\x13GetProfilesResponse\x12\x19\n" +
+	"\x05error\x18\x01 \x01(\tH\x00R\x05error\x88\x01\x01\x122\n" +
+	"\bprofiles\x18\x02 \x03(\v2\x16.vyletdatabase.ProfileR\bprofilesB\b\n" +
+	"\x06_error2\xcd\x03\n" +
+	"\x0eProfileService\x12Z\n" +
+	"\rCreateProfile\x12#.vyletdatabase.CreateProfileRequest\x1a$.vyletdatabase.CreateProfileResponse\x12Z\n" +
+	"\rUpdateProfile\x12#.vyletdatabase.CreateProfileRequest\x1a$.vyletdatabase.CreateProfileResponse\x12Z\n" +
+	"\rDeleteProfile\x12#.vyletdatabase.DeleteProfileRequest\x1a$.vyletdatabase.DeleteProfileResponse\x12Q\n" +
+	"\n" +
+	"GetProfile\x12 .vyletdatabase.GetProfileRequest\x1a!.vyletdatabase.GetProfileResponse\x12T\n" +
+	"\vGetProfiles\x12!.vyletdatabase.GetProfilesRequest\x1a\".vyletdatabase.GetProfilesResponseB\x87\x01\n" +
 	"\x11com.vyletdatabaseB\fProfileProtoP\x01Z\x10./;vyletdatabase\xa2\x02\x03VXX\xaa\x02\rVyletdatabase\xca\x02\rVyletdatabase\xe2\x02\x19Vyletdatabase\\GPBMetadata\xea\x02\rVyletdatabaseb\x06proto3"
 
 var (
···
 	return file_profile_proto_rawDescData
 }
 
-var file_profile_proto_msgTypes = make([]protoimpl.MessageInfo, 6)
+var file_profile_proto_msgTypes = make([]protoimpl.MessageInfo, 9)
 var file_profile_proto_goTypes = []any{
-	(*GetProfileRequest)(nil),     // 0: vyletdatabase.GetProfileRequest
-	(*GetProfileResponse)(nil),    // 1: vyletdatabase.GetProfileResponse
-	(*CreateProfileRequest)(nil),  // 2: vyletdatabase.CreateProfileRequest
-	(*CreateProfileResponse)(nil), // 3: vyletdatabase.CreateProfileResponse
-	(*DeleteProfileRequest)(nil),  // 4: vyletdatabase.DeleteProfileRequest
-	(*DeleteProfileResponse)(nil), // 5: vyletdatabase.DeleteProfileResponse
-	(*timestamppb.Timestamp)(nil), // 6: google.protobuf.Timestamp
+	(*Profile)(nil),               // 0: vyletdatabase.Profile
+	(*CreateProfileRequest)(nil),  // 1: vyletdatabase.CreateProfileRequest
+	(*CreateProfileResponse)(nil), // 2: vyletdatabase.CreateProfileResponse
+	(*DeleteProfileRequest)(nil),  // 3: vyletdatabase.DeleteProfileRequest
+	(*DeleteProfileResponse)(nil), // 4: vyletdatabase.DeleteProfileResponse
+	(*GetProfileRequest)(nil),     // 5: vyletdatabase.GetProfileRequest
+	(*GetProfileResponse)(nil),    // 6: vyletdatabase.GetProfileResponse
+	(*GetProfilesRequest)(nil),    // 7: vyletdatabase.GetProfilesRequest
+	(*GetProfilesResponse)(nil),   // 8: vyletdatabase.GetProfilesResponse
+	(*timestamppb.Timestamp)(nil), // 9: google.protobuf.Timestamp
 }
 var file_profile_proto_depIdxs = []int32{
-	6, // 0: vyletdatabase.GetProfileResponse.created_at:type_name -> google.protobuf.Timestamp
-	6, // 1: vyletdatabase.GetProfileResponse.indexed_at:type_name -> google.protobuf.Timestamp
-	0, // 2: vyletdatabase.ProfileService.GetProfile:input_type -> vyletdatabase.GetProfileRequest
-	4, // 3: vyletdatabase.ProfileService.DeleteProfile:input_type -> vyletdatabase.DeleteProfileRequest
-	2, // 4: vyletdatabase.ProfileService.CreateProfile:input_type -> vyletdatabase.CreateProfileRequest
-	1, // 5: vyletdatabase.ProfileService.GetProfile:output_type -> vyletdatabase.GetProfileResponse
-	5, // 6: vyletdatabase.ProfileService.DeleteProfile:output_type -> vyletdatabase.DeleteProfileResponse
-	3, // 7: vyletdatabase.ProfileService.CreateProfile:output_type -> vyletdatabase.CreateProfileResponse
-	5, // [5:8] is the sub-list for method output_type
-	2, // [2:5] is the sub-list for method input_type
-	2, // [2:2] is the sub-list for extension type_name
-	2, // [2:2] is the sub-list for extension extendee
-	0, // [0:2] is the sub-list for field type_name
+	9,  // 0: vyletdatabase.Profile.created_at:type_name -> google.protobuf.Timestamp
+	9,  // 1: vyletdatabase.Profile.indexed_at:type_name -> google.protobuf.Timestamp
+	0,  // 2: vyletdatabase.CreateProfileRequest.profile:type_name -> vyletdatabase.Profile
+	0,  // 3: vyletdatabase.GetProfileResponse.profile:type_name -> vyletdatabase.Profile
+	0,  // 4: vyletdatabase.GetProfilesResponse.profiles:type_name -> vyletdatabase.Profile
+	1,  // 5: vyletdatabase.ProfileService.CreateProfile:input_type -> vyletdatabase.CreateProfileRequest
+	1,  // 6: vyletdatabase.ProfileService.UpdateProfile:input_type -> vyletdatabase.CreateProfileRequest
+	3,  // 7: vyletdatabase.ProfileService.DeleteProfile:input_type -> vyletdatabase.DeleteProfileRequest
+	5,  // 8: vyletdatabase.ProfileService.GetProfile:input_type -> vyletdatabase.GetProfileRequest
+	7,  // 9: vyletdatabase.ProfileService.GetProfiles:input_type -> vyletdatabase.GetProfilesRequest
+	2,  // 10: vyletdatabase.ProfileService.CreateProfile:output_type -> vyletdatabase.CreateProfileResponse
+	2,  // 11: vyletdatabase.ProfileService.UpdateProfile:output_type -> vyletdatabase.CreateProfileResponse
+	4,  // 12: vyletdatabase.ProfileService.DeleteProfile:output_type -> vyletdatabase.DeleteProfileResponse
+	6,  // 13: vyletdatabase.ProfileService.GetProfile:output_type -> vyletdatabase.GetProfileResponse
+	8,  // 14: vyletdatabase.ProfileService.GetProfiles:output_type -> vyletdatabase.GetProfilesResponse
+	10, // [10:15] is the sub-list for method output_type
+	5,  // [5:10] is the sub-list for method input_type
+	5,  // [5:5] is the sub-list for extension type_name
+	5,  // [5:5] is the sub-list for extension extendee
+	0,  // [0:5] is the sub-list for field type_name
 }
 
 func init() { file_profile_proto_init() }
···
 	if File_profile_proto != nil {
 		return
 	}
-	file_profile_proto_msgTypes[1].OneofWrappers = []any{}
+	file_profile_proto_msgTypes[0].OneofWrappers = []any{}
 	file_profile_proto_msgTypes[2].OneofWrappers = []any{}
-	file_profile_proto_msgTypes[3].OneofWrappers = []any{}
-	file_profile_proto_msgTypes[5].OneofWrappers = []any{}
+	file_profile_proto_msgTypes[4].OneofWrappers = []any{}
+	file_profile_proto_msgTypes[6].OneofWrappers = []any{}
+	file_profile_proto_msgTypes[8].OneofWrappers = []any{}
 	type x struct{}
 	out := protoimpl.TypeBuilder{
 		File: protoimpl.DescBuilder{
 			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
 			RawDescriptor: unsafe.Slice(unsafe.StringData(file_profile_proto_rawDesc), len(file_profile_proto_rawDesc)),
 			NumEnums:      0,
-			NumMessages:   6,
+			NumMessages:   9,
 			NumExtensions: 0,
 			NumServices:   1,
 		},

database/proto/profile.proto

···
 import "google/protobuf/timestamp.proto";
 
 service ProfileService {
+  rpc CreateProfile(CreateProfileRequest) returns (CreateProfileResponse);
+  rpc UpdateProfile(CreateProfileRequest) returns (CreateProfileResponse);
+  rpc DeleteProfile(DeleteProfileRequest) returns (DeleteProfileResponse);
+
   rpc GetProfile(GetProfileRequest) returns (GetProfileResponse);
-  rpc DeleteProfile(DeleteProfileRequest) returns (DeleteProfileResponse);
-  rpc CreateProfile(CreateProfileRequest) returns (CreateProfileResponse);
+  rpc GetProfiles(GetProfilesRequest) returns (GetProfilesResponse);
 }
 
-message GetProfileRequest {
+message Profile {
   string did = 1 [
     (buf.validate.field).required = true
   ];
+  optional string display_name = 2;
+  optional string description = 3;
+  optional string pronouns = 4;
+  optional string avatar = 5;
+  google.protobuf.Timestamp created_at = 6;
+  google.protobuf.Timestamp indexed_at = 7;
 }
 
-message GetProfileResponse {
+message CreateProfileRequest {
+  Profile profile = 1;
+}
+
+message CreateProfileResponse {
   optional string error = 1;
+}
 
-  string did = 2 [
+message DeleteProfileRequest {
+  string did = 1 [
     (buf.validate.field).required = true
   ];
-  optional string display_name = 3;
-  optional string description = 4;
-  optional string pronouns = 5;
-  optional string avatar = 6;
-  optional google.protobuf.Timestamp created_at = 7;
-  google.protobuf.Timestamp indexed_at = 8;
+}
+
+message DeleteProfileResponse {
+  optional string error = 1;
 }
 
-message CreateProfileRequest {
+message GetProfileRequest {
   string did = 1 [
     (buf.validate.field).required = true
   ];
-  optional string created_at = 2;
-  optional string display_name = 3;
-  optional string description = 4;
-  optional string pronouns = 5;
-  optional string avatar = 6;
 }
 
-message CreateProfileResponse {
+message GetProfileResponse {
   optional string error = 1;
+  optional Profile profile = 2;
 }
 
-message DeleteProfileRequest {
-  string did = 1 [
+message GetProfilesRequest {
+  repeated string dids = 1 [
     (buf.validate.field).required = true
   ];
 }
 
-message DeleteProfileResponse {
+message GetProfilesResponse {
   optional string error = 1;
+  repeated Profile profiles = 2;
 }

database/proto/profile_grpc.pb.go

···
 const _ = grpc.SupportPackageIsVersion9
 
 const (
+	ProfileService_CreateProfile_FullMethodName = "/vyletdatabase.ProfileService/CreateProfile"
+	ProfileService_UpdateProfile_FullMethodName = "/vyletdatabase.ProfileService/UpdateProfile"
+	ProfileService_DeleteProfile_FullMethodName = "/vyletdatabase.ProfileService/DeleteProfile"
 	ProfileService_GetProfile_FullMethodName    = "/vyletdatabase.ProfileService/GetProfile"
-	ProfileService_DeleteProfile_FullMethodName = "/vyletdatabase.ProfileService/DeleteProfile"
-	ProfileService_CreateProfile_FullMethodName = "/vyletdatabase.ProfileService/CreateProfile"
+	ProfileService_GetProfiles_FullMethodName   = "/vyletdatabase.ProfileService/GetProfiles"
 )
 
 // ProfileServiceClient is the client API for ProfileService service.
 //
 // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
 type ProfileServiceClient interface {
+	CreateProfile(ctx context.Context, in *CreateProfileRequest, opts ...grpc.CallOption) (*CreateProfileResponse, error)
+	UpdateProfile(ctx context.Context, in *CreateProfileRequest, opts ...grpc.CallOption) (*CreateProfileResponse, error)
+	DeleteProfile(ctx context.Context, in *DeleteProfileRequest, opts ...grpc.CallOption) (*DeleteProfileResponse, error)
 	GetProfile(ctx context.Context, in *GetProfileRequest, opts ...grpc.CallOption) (*GetProfileResponse, error)
-	DeleteProfile(ctx context.Context, in *DeleteProfileRequest, opts ...grpc.CallOption) (*DeleteProfileResponse, error)
-	CreateProfile(ctx context.Context, in *CreateProfileRequest, opts ...grpc.CallOption) (*CreateProfileResponse, error)
+	GetProfiles(ctx context.Context, in *GetProfilesRequest, opts ...grpc.CallOption) (*GetProfilesResponse, error)
 }
 
 type profileServiceClient struct {
···
 	return &profileServiceClient{cc}
 }
 
-func (c *profileServiceClient) GetProfile(ctx context.Context, in *GetProfileRequest, opts ...grpc.CallOption) (*GetProfileResponse, error) {
+func (c *profileServiceClient) CreateProfile(ctx context.Context, in *CreateProfileRequest, opts ...grpc.CallOption) (*CreateProfileResponse, error) {
 	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
-	out := new(GetProfileResponse)
-	err := c.cc.Invoke(ctx, ProfileService_GetProfile_FullMethodName, in, out, cOpts...)
+	out := new(CreateProfileResponse)
+	err := c.cc.Invoke(ctx, ProfileService_CreateProfile_FullMethodName, in, out, cOpts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *profileServiceClient) UpdateProfile(ctx context.Context, in *CreateProfileRequest, opts ...grpc.CallOption) (*CreateProfileResponse, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+	out := new(CreateProfileResponse)
+	err := c.cc.Invoke(ctx, ProfileService_UpdateProfile_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
···
 	return out, nil
 }
 
-func (c *profileServiceClient) CreateProfile(ctx context.Context, in *CreateProfileRequest, opts ...grpc.CallOption) (*CreateProfileResponse, error) {
+func (c *profileServiceClient) GetProfile(ctx context.Context, in *GetProfileRequest, opts ...grpc.CallOption) (*GetProfileResponse, error) {
 	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
-	out := new(CreateProfileResponse)
-	err := c.cc.Invoke(ctx, ProfileService_CreateProfile_FullMethodName, in, out, cOpts...)
+	out := new(GetProfileResponse)
+	err := c.cc.Invoke(ctx, ProfileService_GetProfile_FullMethodName, in, out, cOpts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *profileServiceClient) GetProfiles(ctx context.Context, in *GetProfilesRequest, opts ...grpc.CallOption) (*GetProfilesResponse, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+	out := new(GetProfilesResponse)
+	err := c.cc.Invoke(ctx, ProfileService_GetProfiles_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
···
 // All implementations must embed UnimplementedProfileServiceServer
 // for forward compatibility.
 type ProfileServiceServer interface {
+	CreateProfile(context.Context, *CreateProfileRequest) (*CreateProfileResponse, error)
+	UpdateProfile(context.Context, *CreateProfileRequest) (*CreateProfileResponse, error)
+	DeleteProfile(context.Context, *DeleteProfileRequest) (*DeleteProfileResponse, error)
 	GetProfile(context.Context, *GetProfileRequest) (*GetProfileResponse, error)
-	DeleteProfile(context.Context, *DeleteProfileRequest) (*DeleteProfileResponse, error)
-	CreateProfile(context.Context, *CreateProfileRequest) (*CreateProfileResponse, error)
+	GetProfiles(context.Context, *GetProfilesRequest) (*GetProfilesResponse, error)
 	mustEmbedUnimplementedProfileServiceServer()
 }
 
···
 // pointer dereference when methods are called.
 type UnimplementedProfileServiceServer struct{}
 
-func (UnimplementedProfileServiceServer) GetProfile(context.Context, *GetProfileRequest) (*GetProfileResponse, error) {
-	return nil, status.Error(codes.Unimplemented, "method GetProfile not implemented")
+func (UnimplementedProfileServiceServer) CreateProfile(context.Context, *CreateProfileRequest) (*CreateProfileResponse, error) {
+	return nil, status.Error(codes.Unimplemented, "method CreateProfile not implemented")
+}
+func (UnimplementedProfileServiceServer) UpdateProfile(context.Context, *CreateProfileRequest) (*CreateProfileResponse, error) {
+	return nil, status.Error(codes.Unimplemented, "method UpdateProfile not implemented")
 }
 func (UnimplementedProfileServiceServer) DeleteProfile(context.Context, *DeleteProfileRequest) (*DeleteProfileResponse, error) {
 	return nil, status.Error(codes.Unimplemented, "method DeleteProfile not implemented")
 }
-func (UnimplementedProfileServiceServer) CreateProfile(context.Context, *CreateProfileRequest) (*CreateProfileResponse, error) {
-	return nil, status.Error(codes.Unimplemented, "method CreateProfile not implemented")
+func (UnimplementedProfileServiceServer) GetProfile(context.Context, *GetProfileRequest) (*GetProfileResponse, error) {
+	return nil, status.Error(codes.Unimplemented, "method GetProfile not implemented")
+}
+func (UnimplementedProfileServiceServer) GetProfiles(context.Context, *GetProfilesRequest) (*GetProfilesResponse, error) {
+	return nil, status.Error(codes.Unimplemented, "method GetProfiles not implemented")
 }
 func (UnimplementedProfileServiceServer) mustEmbedUnimplementedProfileServiceServer() {}
 func (UnimplementedProfileServiceServer) testEmbeddedByValue()                        {}
···
 	s.RegisterService(&ProfileService_ServiceDesc, srv)
 }
 
-func _ProfileService_GetProfile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(GetProfileRequest)
+func _ProfileService_CreateProfile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(CreateProfileRequest)
 	if err := dec(in); err != nil {
 		return nil, err
 	}
 	if interceptor == nil {
-		return srv.(ProfileServiceServer).GetProfile(ctx, in)
+		return srv.(ProfileServiceServer).CreateProfile(ctx, in)
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: ProfileService_GetProfile_FullMethodName,
+		FullMethod: ProfileService_CreateProfile_FullMethodName,
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(ProfileServiceServer).GetProfile(ctx, req.(*GetProfileRequest))
+		return srv.(ProfileServiceServer).CreateProfile(ctx, req.(*CreateProfileRequest))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _ProfileService_UpdateProfile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(CreateProfileRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(ProfileServiceServer).UpdateProfile(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: ProfileService_UpdateProfile_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(ProfileServiceServer).UpdateProfile(ctx, req.(*CreateProfileRequest))
 	}
 	return interceptor(ctx, in, info, handler)
 }
···
 	return interceptor(ctx, in, info, handler)
 }
 
-func _ProfileService_CreateProfile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
-	in := new(CreateProfileRequest)
+func _ProfileService_GetProfile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetProfileRequest)
 	if err := dec(in); err != nil {
 		return nil, err
 	}
 	if interceptor == nil {
-		return srv.(ProfileServiceServer).CreateProfile(ctx, in)
+		return srv.(ProfileServiceServer).GetProfile(ctx, in)
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: ProfileService_CreateProfile_FullMethodName,
+		FullMethod: ProfileService_GetProfile_FullMethodName,
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		return srv.(ProfileServiceServer).CreateProfile(ctx, req.(*CreateProfileRequest))
+		return srv.(ProfileServiceServer).GetProfile(ctx, req.(*GetProfileRequest))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _ProfileService_GetProfiles_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetProfilesRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(ProfileServiceServer).GetProfiles(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: ProfileService_GetProfiles_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(ProfileServiceServer).GetProfiles(ctx, req.(*GetProfilesRequest))
 	}
 	return interceptor(ctx, in, info, handler)
 }
···
 	HandlerType: (*ProfileServiceServer)(nil),
 	Methods: []grpc.MethodDesc{
 		{
-			MethodName: "GetProfile",
-			Handler:    _ProfileService_GetProfile_Handler,
+			MethodName: "CreateProfile",
+			Handler:    _ProfileService_CreateProfile_Handler,
+		},
+		{
+			MethodName: "UpdateProfile",
+			Handler:    _ProfileService_UpdateProfile_Handler,
 		},
 		{
 			MethodName: "DeleteProfile",
 			Handler:    _ProfileService_DeleteProfile_Handler,
 		},
 		{
-			MethodName: "CreateProfile",
-			Handler:    _ProfileService_CreateProfile_Handler,
+			MethodName: "GetProfile",
+			Handler:    _ProfileService_GetProfile_Handler,
+		},
+		{
+			MethodName: "GetProfiles",
+			Handler:    _ProfileService_GetProfiles_Handler,
 		},
 	},
 	Streams:  []grpc.StreamDesc{},

database/server/post.go

···
+package server
+
+import (
+	"context"
+
+	vyletdatabase "github.com/vylet-app/go/database/proto"
+)
+
+func (s *Server) CreatePost(ctx context.Context, req *vyletdatabase.CreatePostRequest) (*vyletdatabase.CreatePostResponse, error) {
+	// logger := s.logger.With("name", "CreateProfile")
+	// now := time.Now().UTC()
+	//
+	// if err := s.cqlSession.Query(
+	// 	`
+	// 	INSERT INTO profiles
+	// 		(did, display_name, description, pronouns, avatar, created_at, indexed_at, updated_at)
+	// 	VALUES
+	// 		(?, ?, ?, ?, ?, ?, ?, ?)
+	// 	`,
+	// 	req.Profile.Did,
+	// 	req.Profile.DisplayName,
+	// 	req.Profile.Description,
+	// 	req.Profile.Pronouns,
+	// 	req.Profile.Avatar,
+	// 	req.Profile.CreatedAt.AsTime(),
+	// 	now,
+	// 	now,
+	// ).WithContext(ctx).Exec(); err != nil {
+	// 	logger.Error("failed to create profile", "did", req.Profile.Did, "err", err)
+	// 	return &vyletdatabase.CreateProfileResponse{
+	// 		Error: helpers.ToStringPtr(err.Error()),
+	// 	}, nil
+	// }
+
+	return &vyletdatabase.CreatePostResponse{}, nil
+}
+
+func (s *Server) DeletePost(ctx context.Context, req *vyletdatabase.DeletePostRequest) (*vyletdatabase.DeletePostResponse, error) {
+	// logger := s.logger.With("name", "DeleteProfile")
+	//
+	// if err := s.cqlSession.Query(
+	// 	`
+	// 	DELETE FROM profiles
+	// 	WHERE
+	// 		did = ?
+	// 	`,
+	// 	req.Did,
+	// ).WithContext(ctx).Exec(); err != nil {
+	// 	logger.Error("failed to delete profile", "did", req.Did, "err", err)
+	// 	return &vyletdatabase.DeleteProfileResponse{
+	// 		Error: helpers.ToStringPtr(err.Error()),
+	// 	}, nil
+	// }
+
+	return &vyletdatabase.DeletePostResponse{}, nil
+}
+
+func (s *Server) GetPost(ctx context.Context, req *vyletdatabase.GetPostRequest) (*vyletdatabase.GetPostResponse, error) {
+	// logger := s.logger.With("name", "GetProfile")
+	//
+	// resp := &vyletdatabase.GetProfileResponse{
+	// 	Profile: &vyletdatabase.Profile{},
+	// }
+	// var createdAt, indexedAt time.Time
+	//
+	// if err := s.cqlSession.Query(
+	// 	`SELECT
+	// 		did,
+	// 		display_name,
+	// 		description,
+	// 		pronouns,
+	// 		avatar,
+	// 		created_at,
+	// 		indexed_at
+	// 	FROM profiles
+	// 	WHERE
+	// 		did = ?
+	// 	`,
+	// 	req.Did,
+	// ).WithContext(ctx).Scan(
+	// 	&resp.Profile.Did,
+	// 	&resp.Profile.DisplayName,
+	// 	&resp.Profile.Description,
+	// 	&resp.Profile.Pronouns,
+	// 	&resp.Profile.Avatar,
+	// 	&createdAt,
+	// 	&indexedAt,
+	// ); err != nil {
+	// 	logger.Error("failed to get profile", "did", req.Did, "err", err)
+	// 	return &vyletdatabase.GetProfileResponse{
+	// 		Error: helpers.ToStringPtr(err.Error()),
+	// 	}, nil
+	// }
+	//
+	// resp.Profile.CreatedAt = timestamppb.New(createdAt)
+	// resp.Profile.IndexedAt = timestamppb.New(indexedAt)
+
+	return nil, nil
+}
+
+func (s *Server) GetPosts(ctx context.Context, req *vyletdatabase.GetPostsRequest) (*vyletdatabase.GetPostsResponse, error) {
+	return nil, nil
+}

database/server/profile.go

···
 
 func (s *Server) CreateProfile(ctx context.Context, req *vyletdatabase.CreateProfileRequest) (*vyletdatabase.CreateProfileResponse, error) {
 	logger := s.logger.With("name", "CreateProfile")
-
-	var createdAt string
-	if req.CreatedAt != nil {
-		createdAt = *req.CreatedAt
-	}
-
 	now := time.Now().UTC()
-
-	createdAtTime, err := time.Parse(time.RFC3339Nano, createdAt)
-	if err != nil {
-		createdAtTime = now
-	}
 
 	if err := s.cqlSession.Query(
 		`
···
 		VALUES
 			(?, ?, ?, ?, ?, ?, ?, ?)
 		`,
-		req.Did,
-		req.DisplayName,
-		req.Description,
-		req.Pronouns,
-		req.Avatar,
-		createdAtTime,
+		req.Profile.Did,
+		req.Profile.DisplayName,
+		req.Profile.Description,
+		req.Profile.Pronouns,
+		req.Profile.Avatar,
+		req.Profile.CreatedAt.AsTime(),
 		now,
 		now,
 	).WithContext(ctx).Exec(); err != nil {
-		logger.Error("failed to create profile", "did", req.Did, "err", err)
+		logger.Error("failed to create profile", "did", req.Profile.Did, "err", err)
 		return &vyletdatabase.CreateProfileResponse{
 			Error: helpers.ToStringPtr(err.Error()),
 		}, nil
···
 	return &vyletdatabase.CreateProfileResponse{}, nil
 }
 
+func (s *Server) UpdateProfile(ctx context.Context, req *vyletdatabase.CreateProfileRequest) (*vyletdatabase.CreateProfileResponse, error) {
+	logger := s.logger.With("name", "UpdateProfile")
+
+	now := time.Now().UTC()
+
+	if err := s.cqlSession.Query(
+		`
+		UPDATE profiles
+		SET
+			display_name = ?,
+			description = ?,
+			pronouns = ?,
+			avatar = ?,
+			updated_at = ?
+		WHERE
+			did = ?
+		`,
+		req.Profile.DisplayName,
+		req.Profile.Description,
+		req.Profile.Pronouns,
+		req.Profile.Avatar,
+		now,
+		req.Profile.Did,
+	).WithContext(ctx).Exec(); err != nil {
+		logger.Error("failed to create profile", "did", req.Profile.Did, "err", err)
+		return &vyletdatabase.CreateProfileResponse{
+			Error: helpers.ToStringPtr(err.Error()),
+		}, nil
+	}
+
+	return &vyletdatabase.CreateProfileResponse{}, nil
+}
+
+func (s *Server) DeleteProfile(ctx context.Context, req *vyletdatabase.DeleteProfileRequest) (*vyletdatabase.DeleteProfileResponse, error) {
+	logger := s.logger.With("name", "DeleteProfile")
+
+	if err := s.cqlSession.Query(
+		`
+		DELETE FROM profiles
+		WHERE
+			did = ?
+		`,
+		req.Did,
+	).WithContext(ctx).Exec(); err != nil {
+		logger.Error("failed to delete profile", "did", req.Did, "err", err)
+		return &vyletdatabase.DeleteProfileResponse{
+			Error: helpers.ToStringPtr(err.Error()),
+		}, nil
+	}
+
+	return &vyletdatabase.DeleteProfileResponse{}, nil
+}
+
 func (s *Server) GetProfile(ctx context.Context, req *vyletdatabase.GetProfileRequest) (*vyletdatabase.GetProfileResponse, error) {
 	logger := s.logger.With("name", "GetProfile")
 
-	resp := &vyletdatabase.GetProfileResponse{}
+	resp := &vyletdatabase.GetProfileResponse{
+		Profile: &vyletdatabase.Profile{},
+	}
 	var createdAt, indexedAt time.Time
 
 	if err := s.cqlSession.Query(
 		`SELECT
-			did, display_name, description, pronouns, avatar, created_at, indexed_at
+			did,
+			display_name,
+			description,
+			pronouns,
+			avatar,
+			created_at,
+			indexed_at
 		FROM profiles
-		WHERE did = ?
+		WHERE
+			did = ?
 		`,
 		req.Did,
 	).WithContext(ctx).Scan(
-		&resp.Did,
-		&resp.DisplayName,
-		&resp.Description,
-		&resp.Pronouns,
-		&resp.Avatar,
+		&resp.Profile.Did,
+		&resp.Profile.DisplayName,
+		&resp.Profile.Description,
+		&resp.Profile.Pronouns,
+		&resp.Profile.Avatar,
 		&createdAt,
 		&indexedAt,
 	); err != nil {
···
 		}, nil
 	}
 
-	resp.CreatedAt = timestamppb.New(createdAt)
-	resp.IndexedAt = timestamppb.New(indexedAt)
+	resp.Profile.CreatedAt = timestamppb.New(createdAt)
+	resp.Profile.IndexedAt = timestamppb.New(indexedAt)
 
 	return resp, nil
 }
 
-func (s *Server) DeleteProfile(ctx context.Context, req *vyletdatabase.DeleteProfileRequest) (*vyletdatabase.DeleteProfileResponse, error) {
-	logger := s.logger.With("name", "DeleteProfile")
+func (s *Server) GetProfiles(ctx context.Context, req *vyletdatabase.GetProfilesRequest) (*vyletdatabase.GetProfilesResponse, error) {
+	logger := s.logger.With("name", "GetProfiles")
 
-	if err := s.cqlSession.Query(
-		`
-		DELETE FROM profiles WHERE did = ?
+	resp := &vyletdatabase.GetProfilesResponse{
+		Profiles: make([]*vyletdatabase.Profile, 0, len(req.Dids)),
+	}
+
+	iter := s.cqlSession.Query(
+		`SELECT
+			did,
+			display_name,
+			description,
+			pronouns,
+			avatar,
+			created_at,
+			indexed_at
+		FROM profiles
+		WHERE
+			did IN ?
 		`,
-		req.Did,
-	).WithContext(ctx).Exec(); err != nil {
-		logger.Error("failed to delete profile", "did", req.Did, "err", err)
-		return &vyletdatabase.DeleteProfileResponse{
+		req.Dids,
+	).WithContext(ctx).Iter()
+
+	var createdAt, indexedAt time.Time
+	for {
+		profile := &vyletdatabase.Profile{}
+
+		if !iter.Scan(
+			&profile.Did,
+			&profile.DisplayName,
+			&profile.Description,
+			&profile.Pronouns,
+			&profile.Avatar,
+			&createdAt,
+			&indexedAt,
+		) {
+			break
+		}
+
+		profile.CreatedAt = timestamppb.New(createdAt)
+		profile.IndexedAt = timestamppb.New(indexedAt)
+
+		resp.Profiles = append(resp.Profiles, profile)
+	}
+
+	if err := iter.Close(); err != nil {
+		logger.Error("failed to get profiles", "dids", req.Dids, "err", err)
+		return &vyletdatabase.GetProfilesResponse{
 			Error: helpers.ToStringPtr(err.Error()),
 		}, nil
 	}
 
-	return &vyletdatabase.DeleteProfileResponse{}, nil
+	return resp, nil
 }

database/server/server.go

···
 
 type Server struct {
 	vyletdatabase.UnimplementedProfileServiceServer
+	vyletdatabase.UnimplementedPostServiceServer
 
 	logger *slog.Logger
 
···
 
 func (s *Server) registerServices() {
 	vyletdatabase.RegisterProfileServiceServer(s.grpcServer, s)
+	vyletdatabase.RegisterPostServiceServer(s.grpcServer, s)
 	reflection.Register(s.grpcServer)
 }
 

generated/vylet/actorgetProfiles.go

···
+// Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT.
+
+// Lexicon schema: app.vylet.actor.getProfiles
+
+package vylet
+
+import (
+	"context"
+
+	lexutil "github.com/bluesky-social/indigo/lex/util"
+)
+
+// ActorGetProfiles_Output is the output of a app.vylet.actor.getProfiles call.
+type ActorGetProfiles_Output struct {
+	Profiles []*ActorDefs_ProfileView `json:"profiles" cborgen:"profiles"`
+}
+
+// ActorGetProfiles calls the XRPC method "app.vylet.actor.getProfiles".
+func ActorGetProfiles(ctx context.Context, c lexutil.LexClient, dids []string) (*ActorGetProfiles_Output, error) {
+	var out ActorGetProfiles_Output
+
+	params := map[string]interface{}{}
+	params["dids"] = dids
+	if err := c.LexDo(ctx, lexutil.Query, "", "app.vylet.actor.getProfiles", params, nil, &out); err != nil {
+		return nil, err
+	}
+
+	return &out, nil
+}

generated/vylet/actorprofile.go

···
 	LexiconTypeID string `json:"$type" cborgen:"$type,const=app.vylet.actor.profile"`
 	// avatar: Small image to be displayed next to posts from account.
 	Avatar    *lexutil.LexBlob `json:"avatar,omitempty" cborgen:"avatar,omitempty"`
-	CreatedAt *string          `json:"createdAt,omitempty" cborgen:"createdAt,omitempty"`
+	CreatedAt string           `json:"createdAt" cborgen:"createdAt"`
 	// description: Free-form profile description text.
 	Description *string `json:"description,omitempty" cborgen:"description,omitempty"`
 	DisplayName *string `json:"displayName,omitempty" cborgen:"displayName,omitempty"`

generated/vylet/cbor_gen.go

···
 		fieldCount--
 	}
 
-	if t.CreatedAt == nil {
-		fieldCount--
-	}
-
 	if t.Description == nil {
 		fieldCount--
 	}
···
 	}
 
 	// t.CreatedAt (string) (string)
-	if t.CreatedAt != nil {
+	if len("createdAt") > 1000000 {
+		return xerrors.Errorf("Value in field \"createdAt\" was too long")
+	}
 
-		if len("createdAt") > 1000000 {
-			return xerrors.Errorf("Value in field \"createdAt\" was too long")
-		}
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("createdAt"))); err != nil {
+		return err
+	}
+	if _, err := cw.WriteString(string("createdAt")); err != nil {
+		return err
+	}
 
-		if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("createdAt"))); err != nil {
-			return err
-		}
-		if _, err := cw.WriteString(string("createdAt")); err != nil {
-			return err
-		}
+	if len(t.CreatedAt) > 1000000 {
+		return xerrors.Errorf("Value in field t.CreatedAt was too long")
+	}
 
-		if t.CreatedAt == nil {
-			if _, err := cw.Write(cbg.CborNull); err != nil {
-				return err
-			}
-		} else {
-			if len(*t.CreatedAt) > 1000000 {
-				return xerrors.Errorf("Value in field t.CreatedAt was too long")
-			}
-
-			if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(*t.CreatedAt))); err != nil {
-				return err
-			}
-			if _, err := cw.WriteString(string(*t.CreatedAt)); err != nil {
-				return err
-			}
-		}
+	if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(t.CreatedAt))); err != nil {
+		return err
+	}
+	if _, err := cw.WriteString(string(t.CreatedAt)); err != nil {
+		return err
 	}
 
 	// t.Description (string) (string)
···
 		case "createdAt":
 
 			{
-				b, err := cr.ReadByte()
+				sval, err := cbg.ReadStringWithMax(cr, 1000000)
 				if err != nil {
 					return err
 				}
-				if b != cbg.CborNull[0] {
-					if err := cr.UnreadByte(); err != nil {
-						return err
-					}
 
-					sval, err := cbg.ReadStringWithMax(cr, 1000000)
-					if err != nil {
-						return err
-					}
-
-					t.CreatedAt = (*string)(&sval)
-				}
+				t.CreatedAt = string(sval)
 			}
 			// t.Description (string) (string)
 		case "description":

indexer/actorprofile.go

···
 	"context"
 	"encoding/json"
 	"fmt"
+	"time"
 
 	vyletkafka "github.com/vylet-app/go/bus/proto"
 	vyletdatabase "github.com/vylet-app/go/database/proto"
 	"github.com/vylet-app/go/generated/vylet"
 	"github.com/vylet-app/go/internal/helpers"
+	"google.golang.org/protobuf/types/known/timestamppb"
 )
 
 func (s *Server) handleActorProfile(ctx context.Context, evt *vyletkafka.FirehoseEvent) error {
 	var rec vylet.ActorProfile
 	op := evt.Commit
-
 	switch op.Operation {
 	case vyletkafka.CommitOperation_COMMIT_OPERATION_CREATE:
 		if err := json.Unmarshal(op.Record, &rec); err != nil {
 			return fmt.Errorf("failed to unmarshal profile record: %w", err)
 		}
 
+		createdAtTime, err := time.Parse(time.RFC3339Nano, rec.CreatedAt)
+		if err != nil {
+			return fmt.Errorf("failed to parse time in record: %w", err)
+		}
+
 		req := vyletdatabase.CreateProfileRequest{
-			Did:         evt.Did,
-			DisplayName: rec.DisplayName,
-			Description: rec.Description,
-			Pronouns:    rec.Pronouns,
-			CreatedAt:   rec.CreatedAt,
+			Profile: &vyletdatabase.Profile{
+				Did:         evt.Did,
+				DisplayName: rec.DisplayName,
+				Description: rec.Description,
+				Pronouns:    rec.Pronouns,
+				CreatedAt:   timestamppb.New(createdAtTime),
+			},
 		}
 
 		if rec.Avatar != nil {
-			req.Avatar = helpers.ToStringPtr(rec.Avatar.Ref.String())
+			req.Profile.Avatar = helpers.ToStringPtr(rec.Avatar.Ref.String())
 		}
 
 		resp, err := s.db.Profile.CreateProfile(ctx, &req)
···
 			return fmt.Errorf("error creating profile: %s", *resp.Error)
 		}
 	case vyletkafka.CommitOperation_COMMIT_OPERATION_UPDATE:
-		return fmt.Errorf("unhandled operation")
+		if err := json.Unmarshal(op.Record, &rec); err != nil {
+			return fmt.Errorf("failed to unmarshal profile record: %w", err)
+		}
+
+		req := vyletdatabase.CreateProfileRequest{
+			Profile: &vyletdatabase.Profile{
+				Did:         evt.Did,
+				DisplayName: rec.DisplayName,
+				Description: rec.Description,
+				Pronouns:    rec.Pronouns,
+			},
+		}
+
+		if rec.Avatar != nil {
+			req.Profile.Avatar = helpers.ToStringPtr(rec.Avatar.Ref.String())
+		}
+
+		resp, err := s.db.Profile.UpdateProfile(ctx, &req)
+		if err != nil {
+			return fmt.Errorf("failed to create update profile request: %w", err)
+		}
+		if resp.Error != nil {
+			return fmt.Errorf("error updating profile: %w", err)
+		}
 	case vyletkafka.CommitOperation_COMMIT_OPERATION_DELETE:
 		resp, err := s.db.Profile.DeleteProfile(ctx, &vyletdatabase.DeleteProfileRequest{
 			Did: evt.Did,

indexer/feedpost.go

···
+package indexer
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"time"
+
+	vyletkafka "github.com/vylet-app/go/bus/proto"
+	vyletdatabase "github.com/vylet-app/go/database/proto"
+	"github.com/vylet-app/go/generated/vylet"
+	"google.golang.org/protobuf/types/known/timestamppb"
+)
+
+func (s *Server) handleFeedPost(ctx context.Context, evt *vyletkafka.FirehoseEvent) error {
+	var rec vylet.FeedPost
+	op := evt.Commit
+	uri := firehoseEventToUri(evt)
+	switch op.Operation {
+	case vyletkafka.CommitOperation_COMMIT_OPERATION_CREATE:
+		if err := json.Unmarshal(op.Record, &rec); err != nil {
+			return fmt.Errorf("failed to unmarshal post record: %w", err)
+		}
+
+		createdAtTime, err := time.Parse(time.RFC3339Nano, rec.CreatedAt)
+		if err != nil {
+			return fmt.Errorf("failed to parse time from record: %w", err)
+		}
+
+		var images []*vyletdatabase.Image
+		if rec.Media == nil || rec.Media.MediaImages == nil || len(rec.Media.MediaImages.Images) == 0 {
+			return fmt.Errorf("invalid post, missing or empty images")
+		}
+
+		for _, img := range rec.Media.MediaImages.Images {
+			dbimg := &vyletdatabase.Image{
+				Cid: img.Image.Ref.String(),
+				Alt: &img.Alt,
+			}
+			if img.AspectRatio != nil {
+				dbimg.Width = &img.AspectRatio.Width
+				dbimg.Height = &img.AspectRatio.Height
+			}
+			images = append(images, dbimg)
+		}
+
+		req := vyletdatabase.CreatePostRequest{
+			Post: &vyletdatabase.Post{
+				Uri:       uri,
+				Images:    images,
+				Caption:   rec.Caption,
+				CreatedAt: timestamppb.New(createdAtTime),
+			},
+		}
+
+		if rec.Facets != nil {
+			b, err := json.Marshal(rec.Facets)
+			if err != nil {
+				return fmt.Errorf("failed to marshal facets: %w", err)
+			}
+			req.Post.Facets = b
+		}
+
+		resp, err := s.db.Post.CreatePost(ctx, &req)
+		if err != nil {
+			return fmt.Errorf("failed to create create post request: %w", err)
+		}
+		if resp.Error != nil {
+			return fmt.Errorf("error creating post: %s", *resp.Error)
+		}
+	case vyletkafka.CommitOperation_COMMIT_OPERATION_UPDATE:
+		return fmt.Errorf("unsupported post update event")
+	case vyletkafka.CommitOperation_COMMIT_OPERATION_DELETE:
+		resp, err := s.db.Post.DeletePost(ctx, &vyletdatabase.DeletePostRequest{
+			Uri: uri,
+		})
+		if err != nil {
+			return fmt.Errorf("failed to create delete post request: %w", err)
+		}
+		if resp.Error != nil {
+			return fmt.Errorf("error deleting post %s", *resp.Error)
+		}
+	}
+
+	return nil
+}

indexer/helpers.go

···
+package indexer
+
+import (
+	"fmt"
+
+	vyletkafka "github.com/vylet-app/go/bus/proto"
+)
+
+func firehoseEventToUri(evt *vyletkafka.FirehoseEvent) string {
+	return fmt.Sprintf("at://%s/%s/%s", evt.Did, evt.Commit.Collection, evt.Commit.Rkey)
+}