a082cf3a77
* Able to authenticate user against IndieAuth. For #1273 * WIP server indieauth endpoint. For https://github.com/owncast/owncast/issues/1272 * Add migration to remove access tokens from user * Add authenticated bool to user for display purposes * Add indieauth modal and auth flair to display names. For #1273 * Validate URLs and display errors * Renames, cleanups * Handle relative auth endpoint paths. Add error handling for missing redirects. * Disallow using display names in use by registered users. Closes #1810 * Verify code verifier via code challenge on callback * Use relative path to authorization_endpoint * Post-rebase fixes * Use a timestamp instead of a bool for authenticated * Propertly handle and display error in modal * Use auth'ed timestamp to derive authenticated flag to display in chat * Fediverse chat auth via OTP * Increase validity time just in case * Add fediverse auth into auth modal * Text, validation, cleanup updates for fedi auth * Fix typo * Remove unused images * Remove unused file * Add chat display name to auth modal text
57 lines
1.7 KiB
Go
57 lines
1.7 KiB
Go
package activitypub
|
|
|
|
import (
|
|
"github.com/owncast/owncast/activitypub/crypto"
|
|
"github.com/owncast/owncast/activitypub/inbox"
|
|
"github.com/owncast/owncast/activitypub/outbox"
|
|
"github.com/owncast/owncast/activitypub/persistence"
|
|
"github.com/owncast/owncast/activitypub/workerpool"
|
|
|
|
"github.com/owncast/owncast/core/data"
|
|
"github.com/owncast/owncast/models"
|
|
log "github.com/sirupsen/logrus"
|
|
)
|
|
|
|
// Start will initialize and start the federation support.
|
|
func Start(datastore *data.Datastore) {
|
|
persistence.Setup(datastore)
|
|
workerpool.InitOutboundWorkerPool()
|
|
inbox.InitInboxWorkerPool()
|
|
StartRouter()
|
|
|
|
// Generate the keys for signing federated activity if needed.
|
|
if data.GetPrivateKey() == "" {
|
|
privateKey, publicKey, err := crypto.GenerateKeys()
|
|
_ = data.SetPrivateKey(string(privateKey))
|
|
_ = data.SetPublicKey(string(publicKey))
|
|
if err != nil {
|
|
log.Errorln("Unable to get private key", err)
|
|
}
|
|
}
|
|
}
|
|
|
|
// SendLive will send a "Go Live" message to followers.
|
|
func SendLive() error {
|
|
return outbox.SendLive()
|
|
}
|
|
|
|
// SendPublicFederatedMessage will send an arbitrary provided message to followers.
|
|
func SendPublicFederatedMessage(message string) error {
|
|
return outbox.SendPublicMessage(message)
|
|
}
|
|
|
|
// SendDirectFederatedMessage will send a direct message to a single account.
|
|
func SendDirectFederatedMessage(message, account string) error {
|
|
return outbox.SendDirectMessageToAccount(message, account)
|
|
}
|
|
|
|
// GetFollowerCount will return the local tracked follower count.
|
|
func GetFollowerCount() (int64, error) {
|
|
return persistence.GetFollowerCount()
|
|
}
|
|
|
|
// GetPendingFollowRequests will return the pending follow requests.
|
|
func GetPendingFollowRequests() ([]models.Follower, error) {
|
|
return persistence.GetPendingFollowRequests()
|
|
}
|