backend

README

backend

migrate create -ext sql -dir db/migrations -seq create_initial_tables
sqlc generate
migrate -database "postgres://mootslive:mootslive@localhost:5432/mootslive" -path db/migrations up

Helpful resources:

• https://www.sqlstyle.guide/

Documentation

Index

• func NewAuthEngine(signingKey []byte, queries db.TXQuerier) *authEngine
• type AdminServerHandler
  • func (as *AdminServerHandler) GetStatus(ctx context.Context, req *connect.Request[mootslivepbv1.GetStatusRequest]) (*connect.Response[mootslivepbv1.GetStatusResponse], error)
• type SpotifyPoller
  • func NewSpotifyPoller(log *slog.Logger, queries db.TXQuerier) *SpotifyPoller
  • func (sp *SpotifyPoller) Run(ctx context.Context) error
  • func (sp *SpotifyPoller) ScanAccount(ctx context.Context, spotifyUserID string) error
• type UserServiceHandler
  • func NewUserServiceHandler(queries db.TXQuerier, log *slog.Logger, authEngine *authEngine) *UserServiceHandler
  • func (us *UserServiceHandler) BeginTwitterAuth(ctx context.Context, ...) (*connect.Response[mootslivepbv1.BeginTwitterAuthResponse], error)
  • func (us *UserServiceHandler) FinishTwitterAuth(ctx context.Context, ...) (*connect.Response[mootslivepbv1.FinishTwitterAuthResponse], error)
  • func (us *UserServiceHandler) GetMe(ctx context.Context, req *connect.Request[mootslivepbv1.GetMeRequest]) (*connect.Response[mootslivepbv1.GetMeResponse], error)
  • func (us *UserServiceHandler) ListListens(ctx context.Context, req *connect.Request[mootslivepbv1.ListListensRequest]) (*connect.Response[mootslivepbv1.ListListensResponse], error)

Functions

func NewAuthEngine

func NewAuthEngine(signingKey []byte, queries db.TXQuerier) *authEngine

Types

type AdminServerHandler

type AdminServerHandler struct {
	mootslivepbv1connect.UnimplementedAdminServiceHandler
}

func (*AdminServerHandler) GetStatus

func (as *AdminServerHandler) GetStatus(
	ctx context.Context,
	req *connect.Request[mootslivepbv1.GetStatusRequest],
) (*connect.Response[mootslivepbv1.GetStatusResponse], error)

type SpotifyPoller

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

func NewSpotifyPoller

func NewSpotifyPoller(log *slog.Logger, queries db.TXQuerier) *SpotifyPoller

func (*SpotifyPoller) Run

func (sp *SpotifyPoller) Run(ctx context.Context) error

func (*SpotifyPoller) ScanAccount

func (sp *SpotifyPoller) ScanAccount(
	ctx context.Context, spotifyUserID string,
) error

type UserServiceHandler

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

func NewUserServiceHandler

func NewUserServiceHandler(
	queries db.TXQuerier,
	log *slog.Logger,
	authEngine *authEngine,
) *UserServiceHandler

func (*UserServiceHandler) BeginTwitterAuth

func (us *UserServiceHandler) BeginTwitterAuth(
	ctx context.Context,
	req *connect.Request[mootslivepbv1.BeginTwitterAuthRequest],
) (*connect.Response[mootslivepbv1.BeginTwitterAuthResponse], error)

func (*UserServiceHandler) FinishTwitterAuth

func (us *UserServiceHandler) FinishTwitterAuth(
	ctx context.Context,
	req *connect.Request[mootslivepbv1.FinishTwitterAuthRequest],
) (*connect.Response[mootslivepbv1.FinishTwitterAuthResponse], error)

func (*UserServiceHandler) GetMe

func (us *UserServiceHandler) GetMe(
	ctx context.Context,
	req *connect.Request[mootslivepbv1.GetMeRequest],
) (*connect.Response[mootslivepbv1.GetMeResponse], error)

func (*UserServiceHandler) ListListens

func (us *UserServiceHandler) ListListens(
	ctx context.Context,
	req *connect.Request[mootslivepbv1.ListListensRequest],
) (*connect.Response[mootslivepbv1.ListListensResponse], error)