bridge

Documentation

Index

• type Announcer
  • func NewAnnouncer(notifySvc *notifyapp.NotifyService, repo *adminpg.Repo) *Announcer
  • func (a *Announcer) AllActiveUserIDs(ctx context.Context) ([]string, error)
  • func (a *Announcer) Notify(ctx context.Context, in app.NotifyInput) error
• type BillingOps
  • func (b *BillingOps) AdminCancelPendingOrder(ctx context.Context, actor *webx.Principal, orderID string) error
  • func (b *BillingOps) AdminCancelSubscription(ctx context.Context, actor *webx.Principal, workspaceID string) error
  • func (b *BillingOps) AdminUpdatePlan(ctx context.Context, actor *webx.Principal, code string, ...) (app.AdminPlanView, error)
  • func (b *BillingOps) BillingConfig(ctx context.Context) (app.AdminBillingConfig, error)
  • func (b *BillingOps) ListAllOrders(ctx context.Context, workspaceID, status string, limit, offset int) ([]app.AdminOrder, int, error)
  • func (b *BillingOps) ListPaymentEvents(ctx context.Context, workspaceID string, limit, offset int) ([]app.AdminPaymentEvent, int, error)
  • func (b *BillingOps) ListPlanCodes(ctx context.Context) ([]string, error)
  • func (b *BillingOps) ListPlanViews(ctx context.Context) ([]app.AdminPlanView, error)
  • func (b *BillingOps) MarkOrderPaid(ctx context.Context, actor *webx.Principal, orderID string) error
  • func (b *BillingOps) RunExpiryNow(ctx context.Context) (int, error)
  • func (b *BillingOps) RunOverageNow(ctx context.Context) (int, error)
  • func (b *BillingOps) TestChannelConnection(ctx context.Context, channel string) error
• type UserOps
  • func NewUserOps(sessions *identityapp.SessionService, tokens *identityapp.TokenService, ...) *UserOps
  • func (u *UserOps) DeleteAccount(ctx context.Context, actorEmail, userID string) error
  • func (u *UserOps) GetUser(ctx context.Context, userID string) (app.AdminUser, bool, error)
  • func (u *UserOps) ListPATs(ctx context.Context, userID string) ([]app.AdminPAT, error)
  • func (u *UserOps) ListSessions(ctx context.Context, userID string) ([]app.UserSession, error)
  • func (u *UserOps) MarkEmailVerified(ctx context.Context, userID string) error
  • func (u *UserOps) ResendEmailVerification(ctx context.Context, userID, email string) error
  • func (u *UserOps) RevokeAllSessions(ctx context.Context, userID string) error
  • func (u *UserOps) RevokePAT(ctx context.Context, userID, patID string) error
  • func (u *UserOps) RevokeSessionByID(ctx context.Context, userID, sessionID string) error
  • func (u *UserOps) SendPasswordReset(ctx context.Context, email string) error
• type WebhookOps
  • func (w *WebhookOps) AdminRedeliver(ctx context.Context, deliveryID string) (app.AdminWebhookDelivery, error)
  • func (w *WebhookOps) ListAllDeliveries(ctx context.Context, workspaceID, status string, limit, offset int) ([]app.AdminWebhookDelivery, int, error)
• type WorkspaceLister
  • func NewWorkspaceLister(repo *adminpg.Repo) *WorkspaceLister
  • func (w *WorkspaceLister) ListUserWorkspaces(ctx context.Context, userID string) ([]app.AdminUserWorkspace, error)
• type WsOps
  • func (w *WsOps) DeleteWorkspace(ctx context.Context, actor *webx.Principal, wsID string) error
  • func (w *WsOps) RemoveMember(ctx context.Context, actor *webx.Principal, wsID, targetUserID string) error
  • func (w *WsOps) TransferOwnership(ctx context.Context, actor *webx.Principal, wsID, newOwnerUserID string) error
  • func (w *WsOps) UpdateMemberRole(ctx context.Context, actor *webx.Principal, wsID, targetUserID, newRole string) error

Types

type Announcer

type Announcer struct {
	NotifySvc *notifyapp.NotifyService
	Repo      *adminpg.Repo
}

func NewAnnouncer

func NewAnnouncer(notifySvc *notifyapp.NotifyService, repo *adminpg.Repo) *Announcer

func (*Announcer) AllActiveUserIDs

func (a *Announcer) AllActiveUserIDs(ctx context.Context) ([]string, error)

func (*Announcer) Notify

func (a *Announcer) Notify(ctx context.Context, in app.NotifyInput) error

type BillingOps

type BillingOps struct {
	Svc *billingapp.BillingAdminService
}

func (*BillingOps) AdminCancelPendingOrder

func (b *BillingOps) AdminCancelPendingOrder(ctx context.Context, actor *webx.Principal, orderID string) error

func (*BillingOps) AdminCancelSubscription

func (b *BillingOps) AdminCancelSubscription(ctx context.Context, actor *webx.Principal, workspaceID string) error

func (*BillingOps) AdminUpdatePlan

func (b *BillingOps) AdminUpdatePlan(ctx context.Context, actor *webx.Principal, code string, in app.AdminPlanUpdateInput) (app.AdminPlanView, error)

func (*BillingOps) BillingConfig

func (b *BillingOps) BillingConfig(ctx context.Context) (app.AdminBillingConfig, error)

func (*BillingOps) ListAllOrders

func (b *BillingOps) ListAllOrders(ctx context.Context, workspaceID, status string, limit, offset int) ([]app.AdminOrder, int, error)

func (*BillingOps) ListPaymentEvents

func (b *BillingOps) ListPaymentEvents(ctx context.Context, workspaceID string, limit, offset int) ([]app.AdminPaymentEvent, int, error)

func (*BillingOps) ListPlanCodes

func (b *BillingOps) ListPlanCodes(ctx context.Context) ([]string, error)

func (*BillingOps) ListPlanViews

func (b *BillingOps) ListPlanViews(ctx context.Context) ([]app.AdminPlanView, error)

func (*BillingOps) MarkOrderPaid

func (b *BillingOps) MarkOrderPaid(ctx context.Context, actor *webx.Principal, orderID string) error

func (*BillingOps) RunExpiryNow

func (b *BillingOps) RunExpiryNow(ctx context.Context) (int, error)

func (*BillingOps) RunOverageNow

func (b *BillingOps) RunOverageNow(ctx context.Context) (int, error)

func (*BillingOps) TestChannelConnection

func (b *BillingOps) TestChannelConnection(ctx context.Context, channel string) error

type UserOps

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

func NewUserOps

func NewUserOps(
	sessions *identityapp.SessionService,
	tokens *identityapp.TokenService,
	account *identityapp.AccountService,
	adminRepo *adminpg.Repo,
) *UserOps

func (*UserOps) DeleteAccount

func (u *UserOps) DeleteAccount(ctx context.Context, actorEmail, userID string) error

func (*UserOps) GetUser

func (u *UserOps) GetUser(ctx context.Context, userID string) (app.AdminUser, bool, error)

func (*UserOps) ListPATs

func (u *UserOps) ListPATs(ctx context.Context, userID string) ([]app.AdminPAT, error)

func (*UserOps) ListSessions

func (u *UserOps) ListSessions(ctx context.Context, userID string) ([]app.UserSession, error)

func (*UserOps) MarkEmailVerified

func (u *UserOps) MarkEmailVerified(ctx context.Context, userID string) error

func (*UserOps) ResendEmailVerification

func (u *UserOps) ResendEmailVerification(ctx context.Context, userID, email string) error

func (*UserOps) RevokeAllSessions

func (u *UserOps) RevokeAllSessions(ctx context.Context, userID string) error

func (*UserOps) RevokePAT

func (u *UserOps) RevokePAT(ctx context.Context, userID, patID string) error

func (*UserOps) RevokeSessionByID

func (u *UserOps) RevokeSessionByID(ctx context.Context, userID, sessionID string) error

func (*UserOps) SendPasswordReset

func (u *UserOps) SendPasswordReset(ctx context.Context, email string) error

type WebhookOps

type WebhookOps struct{ Svc *webhooksapp.WebhookService }

func (*WebhookOps) AdminRedeliver

func (w *WebhookOps) AdminRedeliver(ctx context.Context, deliveryID string) (app.AdminWebhookDelivery, error)

func (*WebhookOps) ListAllDeliveries

func (w *WebhookOps) ListAllDeliveries(ctx context.Context, workspaceID, status string, limit, offset int) ([]app.AdminWebhookDelivery, int, error)

type WorkspaceLister

type WorkspaceLister struct{ Repo *adminpg.Repo }

func NewWorkspaceLister

func NewWorkspaceLister(repo *adminpg.Repo) *WorkspaceLister

func (*WorkspaceLister) ListUserWorkspaces

func (w *WorkspaceLister) ListUserWorkspaces(ctx context.Context, userID string) ([]app.AdminUserWorkspace, error)

type WsOps

type WsOps struct {
	Svc *workspaceapp.WorkspaceService
}

func (*WsOps) DeleteWorkspace

func (w *WsOps) DeleteWorkspace(ctx context.Context, actor *webx.Principal, wsID string) error

func (*WsOps) RemoveMember

func (w *WsOps) RemoveMember(ctx context.Context, actor *webx.Principal, wsID, targetUserID string) error

func (*WsOps) TransferOwnership

func (w *WsOps) TransferOwnership(ctx context.Context, actor *webx.Principal, wsID, newOwnerUserID string) error

func (*WsOps) UpdateMemberRole

func (w *WsOps) UpdateMemberRole(ctx context.Context, actor *webx.Principal, wsID, targetUserID, newRole string) error