repository

type InMemorySessionStore struct {
	// contains filtered or unexported fields
}

type MessageStore interface {
	SendMessage(ctx context.Context, message *model.Message) error
	ListMessages(ctx context.Context, id uuid.UUID, createdAt time.Time, pageSize int) ([]model.Message, error)
	ListMessagesFirst(ctx context.Context, id uuid.UUID, pageSize int) ([]model.Message, error)
}

type PostgresMessageStore struct {
	// contains filtered or unexported fields
}

type PostgresRoomStore struct {
	// contains filtered or unexported fields
}

type PostgresUserStore struct {
	// contains filtered or unexported fields
}

type RefreshTokenPostgresStore struct {
	// contains filtered or unexported fields
}

type RefreshTokenStore interface {
	Add(ctx context.Context, token *model.RefreshToken) error
	Delete(ctx context.Context, token uuid.UUID) error
	Get(ctx context.Context, token uuid.UUID) (*model.RefreshToken, error)
}

type RoomStore interface {
	AddAndSendMessage(ctx context.Context, room *model.Room, message *model.Message) (*model.Room, error)
	Add(ctx context.Context, room *model.Room) error
	Get(ctx context.Context, id uuid.UUID) (*model.Room, error)
	FindDialogRoom(ctx context.Context, userId1, userId2 uuid.UUID) (*model.Room, error)
	UsersInRoom(ctx context.Context, id uuid.UUID) ([]uuid.UUID, error)
	FindByIds(ctx context.Context, ids ...uuid.UUID) ([]model.User, error)
	ListRooms(ctx context.Context, userId uuid.UUID, lastMessageDate time.Time, pageSize int) ([]model.Room, error)
	ListRoomsFirst(ctx context.Context, userId uuid.UUID, pageSize int) ([]model.Room, error)
}

type SessionStore interface {
	Add(session *model.Session) error
	Send(id uuid.UUID, messageStream *pb.MessageStreamResponse) error
	Delete(id uuid.UUID)
}

type UserStore interface {
	Save(ctx context.Context, user *model.User) error
	Find(ctx context.Context, id uuid.UUID) (*model.User, error)
	FindByUsername(ctx context.Context, username string) (*model.User, error)
}