2021-04-01 20:46:45 +02:00
/ *
GoToSocial
Copyright ( C ) 2021 GoToSocial Authors admin @ gotosocial . org
This program is free software : you can redistribute it and / or modify
it under the terms of the GNU Affero General Public License as published by
the Free Software Foundation , either version 3 of the License , or
( at your option ) any later version .
This program is distributed in the hope that it will be useful ,
but WITHOUT ANY WARRANTY ; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE . See the
GNU Affero General Public License for more details .
You should have received a copy of the GNU Affero General Public License
along with this program . If not , see < http : //www.gnu.org/licenses/>.
* /
2021-05-15 11:58:11 +02:00
package federation
2021-04-01 20:46:45 +02:00
import (
"context"
2021-05-21 15:48:26 +02:00
"encoding/json"
2021-04-01 20:46:45 +02:00
"errors"
2021-05-08 14:25:55 +02:00
"fmt"
2021-04-01 20:46:45 +02:00
"net/url"
"sync"
"github.com/go-fed/activity/pub"
2021-05-15 11:58:11 +02:00
"github.com/go-fed/activity/streams"
2021-04-01 20:46:45 +02:00
"github.com/go-fed/activity/streams/vocab"
2021-05-15 11:58:11 +02:00
"github.com/google/uuid"
2021-05-08 14:25:55 +02:00
"github.com/sirupsen/logrus"
2021-04-01 20:46:45 +02:00
"github.com/superseriousbusiness/gotosocial/internal/config"
2021-05-15 11:58:11 +02:00
"github.com/superseriousbusiness/gotosocial/internal/db"
2021-05-08 14:25:55 +02:00
"github.com/superseriousbusiness/gotosocial/internal/gtsmodel"
2021-05-15 11:58:11 +02:00
"github.com/superseriousbusiness/gotosocial/internal/typeutils"
2021-05-08 14:25:55 +02:00
"github.com/superseriousbusiness/gotosocial/internal/util"
2021-04-01 20:46:45 +02:00
)
2021-05-21 15:48:26 +02:00
type FederatingDB interface {
pub . Database
Undo ( ctx context . Context , undo vocab . ActivityStreamsUndo ) error
Accept ( ctx context . Context , accept vocab . ActivityStreamsAccept ) error
}
2021-04-01 20:46:45 +02:00
// FederatingDB uses the underlying DB interface to implement the go-fed pub.Database interface.
// It doesn't care what the underlying implementation of the DB interface is, as long as it works.
type federatingDB struct {
2021-05-15 11:58:11 +02:00
locks * sync . Map
db db . DB
config * config . Config
log * logrus . Logger
typeConverter typeutils . TypeConverter
2021-04-01 20:46:45 +02:00
}
2021-05-21 15:48:26 +02:00
// NewFederatingDB returns a FederatingDB interface using the given database, config, and logger.
func NewFederatingDB ( db db . DB , config * config . Config , log * logrus . Logger ) FederatingDB {
2021-04-01 20:46:45 +02:00
return & federatingDB {
2021-05-15 11:58:11 +02:00
locks : new ( sync . Map ) ,
db : db ,
config : config ,
log : log ,
typeConverter : typeutils . NewConverter ( config , db ) ,
2021-04-01 20:46:45 +02:00
}
}
/ *
GO - FED DB INTERFACE - IMPLEMENTING FUNCTIONS
* /
2021-04-20 18:14:23 +02:00
// Lock takes a lock for the object at the specified id. If an error
// is returned, the lock must not have been taken.
//
// The lock must be able to succeed for an id that does not exist in
// the database. This means acquiring the lock does not guarantee the
// entry exists in the database.
//
// Locks are encouraged to be lightweight and in the Go layer, as some
// processes require tight loops acquiring and releasing locks.
//
// Used to ensure race conditions in multiple requests do not occur.
func ( f * federatingDB ) Lock ( c context . Context , id * url . URL ) error {
2021-04-01 20:46:45 +02:00
// Before any other Database methods are called, the relevant `id`
// entries are locked to allow for fine-grained concurrency.
// Strategy: create a new lock, if stored, continue. Otherwise, lock the
// existing mutex.
mu := & sync . Mutex { }
mu . Lock ( ) // Optimistically lock if we do store it.
i , loaded := f . locks . LoadOrStore ( id . String ( ) , mu )
if loaded {
mu = i . ( * sync . Mutex )
mu . Lock ( )
}
return nil
}
2021-04-20 18:14:23 +02:00
// Unlock makes the lock for the object at the specified id available.
// If an error is returned, the lock must have still been freed.
//
// Used to ensure race conditions in multiple requests do not occur.
func ( f * federatingDB ) Unlock ( c context . Context , id * url . URL ) error {
2021-04-01 20:46:45 +02:00
// Once Go-Fed is done calling Database methods, the relevant `id`
// entries are unlocked.
i , ok := f . locks . Load ( id . String ( ) )
if ! ok {
return errors . New ( "missing an id in unlock" )
}
mu := i . ( * sync . Mutex )
mu . Unlock ( )
return nil
}
2021-04-20 18:14:23 +02:00
// InboxContains returns true if the OrderedCollection at 'inbox'
// contains the specified 'id'.
//
// The library makes this call only after acquiring a lock first.
func ( f * federatingDB ) InboxContains ( c context . Context , inbox , id * url . URL ) ( contains bool , err error ) {
2021-05-15 11:58:11 +02:00
l := f . log . WithFields (
logrus . Fields {
"func" : "InboxContains" ,
"id" : id . String ( ) ,
} ,
)
l . Debugf ( "entering INBOXCONTAINS function with for inbox %s and id %s" , inbox . String ( ) , id . String ( ) )
2021-05-08 14:25:55 +02:00
if ! util . IsInboxPath ( inbox ) {
return false , fmt . Errorf ( "%s is not an inbox URI" , inbox . String ( ) )
}
2021-05-15 11:58:11 +02:00
activityI := c . Value ( util . APActivity )
if activityI == nil {
return false , fmt . Errorf ( "no activity was set for id %s" , id . String ( ) )
2021-05-08 14:25:55 +02:00
}
2021-05-15 11:58:11 +02:00
activity , ok := activityI . ( pub . Activity )
if ! ok || activity == nil {
return false , fmt . Errorf ( "could not parse contextual activity for id %s" , id . String ( ) )
2021-05-08 14:25:55 +02:00
}
2021-05-15 11:58:11 +02:00
l . Debugf ( "activity type %s for id %s" , activity . GetTypeName ( ) , id . String ( ) )
return false , nil
2021-05-08 14:25:55 +02:00
2021-05-15 11:58:11 +02:00
// if err := f.db.GetByID(statusID, >smodel.Status{}); err != nil {
// if _, ok := err.(db.ErrNoEntries); ok {
// // we don't have it
// return false, nil
// }
// // actual error
// return false, fmt.Errorf("error getting status from db: %s", err)
// }
// // we must have it
// return true, nil
2021-04-01 20:46:45 +02:00
}
2021-04-20 18:14:23 +02:00
// GetInbox returns the first ordered collection page of the outbox at
// the specified IRI, for prepending new items.
//
// The library makes this call only after acquiring a lock first.
func ( f * federatingDB ) GetInbox ( c context . Context , inboxIRI * url . URL ) ( inbox vocab . ActivityStreamsOrderedCollectionPage , err error ) {
2021-05-15 11:58:11 +02:00
l := f . log . WithFields (
logrus . Fields {
"func" : "GetInbox" ,
} ,
)
l . Debugf ( "entering GETINBOX function with inboxIRI %s" , inboxIRI . String ( ) )
return streams . NewActivityStreamsOrderedCollectionPage ( ) , nil
2021-04-01 20:46:45 +02:00
}
2021-04-20 18:14:23 +02:00
// SetInbox saves the inbox value given from GetInbox, with new items
// prepended. Note that the new items must not be added as independent
// database entries. Separate calls to Create will do that.
//
// The library makes this call only after acquiring a lock first.
func ( f * federatingDB ) SetInbox ( c context . Context , inbox vocab . ActivityStreamsOrderedCollectionPage ) error {
2021-05-15 11:58:11 +02:00
l := f . log . WithFields (
logrus . Fields {
"func" : "SetInbox" ,
} ,
)
l . Debug ( "entering SETINBOX function" )
2021-04-01 20:46:45 +02:00
return nil
}
2021-05-08 14:25:55 +02:00
// Owns returns true if the IRI belongs to this instance, and if
// the database has an entry for the IRI.
2021-04-20 18:14:23 +02:00
// The library makes this call only after acquiring a lock first.
2021-05-08 14:25:55 +02:00
func ( f * federatingDB ) Owns ( c context . Context , id * url . URL ) ( bool , error ) {
2021-05-15 11:58:11 +02:00
l := f . log . WithFields (
logrus . Fields {
"func" : "Owns" ,
"id" : id . String ( ) ,
} ,
)
l . Debugf ( "entering OWNS function with id %s" , id . String ( ) )
2021-05-08 14:25:55 +02:00
// if the id host isn't this instance host, we don't own this IRI
if id . Host != f . config . Host {
2021-05-15 11:58:11 +02:00
l . Debugf ( "we DO NOT own activity because the host is %s not %s" , id . Host , f . config . Host )
2021-05-08 14:25:55 +02:00
return false , nil
}
2021-05-15 11:58:11 +02:00
// apparently it belongs to this host, so what *is* it?
2021-05-08 14:25:55 +02:00
// check if it's a status, eg /users/example_username/statuses/SOME_UUID_OF_A_STATUS
if util . IsStatusesPath ( id ) {
_ , uid , err := util . ParseStatusesPath ( id )
if err != nil {
return false , fmt . Errorf ( "error parsing statuses path for url %s: %s" , id . String ( ) , err )
}
2021-05-21 15:48:26 +02:00
if err := f . db . GetWhere ( [ ] db . Where { { Key : "uri" , Value : uid } } , & gtsmodel . Status { } ) ; err != nil {
2021-05-15 11:58:11 +02:00
if _ , ok := err . ( db . ErrNoEntries ) ; ok {
2021-05-08 14:25:55 +02:00
// there are no entries for this status
return false , nil
}
// an actual error happened
return false , fmt . Errorf ( "database error fetching status with id %s: %s" , uid , err )
}
2021-05-15 11:58:11 +02:00
l . Debug ( "we DO own this" )
2021-05-08 14:25:55 +02:00
return true , nil
}
// check if it's a user, eg /users/example_username
if util . IsUserPath ( id ) {
username , err := util . ParseUserPath ( id )
if err != nil {
return false , fmt . Errorf ( "error parsing statuses path for url %s: %s" , id . String ( ) , err )
}
if err := f . db . GetLocalAccountByUsername ( username , & gtsmodel . Account { } ) ; err != nil {
2021-05-15 11:58:11 +02:00
if _ , ok := err . ( db . ErrNoEntries ) ; ok {
2021-05-08 14:25:55 +02:00
// there are no entries for this username
return false , nil
}
// an actual error happened
return false , fmt . Errorf ( "database error fetching account with username %s: %s" , username , err )
}
2021-05-15 11:58:11 +02:00
l . Debug ( "we DO own this" )
2021-05-08 14:25:55 +02:00
return true , nil
}
return false , fmt . Errorf ( "could not match activityID: %s" , id . String ( ) )
2021-04-01 20:46:45 +02:00
}
2021-04-20 18:14:23 +02:00
// ActorForOutbox fetches the actor's IRI for the given outbox IRI.
//
// The library makes this call only after acquiring a lock first.
func ( f * federatingDB ) ActorForOutbox ( c context . Context , outboxIRI * url . URL ) ( actorIRI * url . URL , err error ) {
2021-05-15 11:58:11 +02:00
l := f . log . WithFields (
logrus . Fields {
"func" : "ActorForOutbox" ,
"inboxIRI" : outboxIRI . String ( ) ,
} ,
)
l . Debugf ( "entering ACTORFOROUTBOX function with outboxIRI %s" , outboxIRI . String ( ) )
2021-05-08 14:25:55 +02:00
if ! util . IsOutboxPath ( outboxIRI ) {
return nil , fmt . Errorf ( "%s is not an outbox URI" , outboxIRI . String ( ) )
}
acct := & gtsmodel . Account { }
2021-05-21 15:48:26 +02:00
if err := f . db . GetWhere ( [ ] db . Where { { Key : "outbox_uri" , Value : outboxIRI . String ( ) } } , acct ) ; err != nil {
2021-05-15 11:58:11 +02:00
if _ , ok := err . ( db . ErrNoEntries ) ; ok {
2021-05-08 14:25:55 +02:00
return nil , fmt . Errorf ( "no actor found that corresponds to outbox %s" , outboxIRI . String ( ) )
}
return nil , fmt . Errorf ( "db error searching for actor with outbox %s" , outboxIRI . String ( ) )
}
return url . Parse ( acct . URI )
2021-04-01 20:46:45 +02:00
}
2021-04-20 18:14:23 +02:00
// ActorForInbox fetches the actor's IRI for the given outbox IRI.
//
// The library makes this call only after acquiring a lock first.
func ( f * federatingDB ) ActorForInbox ( c context . Context , inboxIRI * url . URL ) ( actorIRI * url . URL , err error ) {
2021-05-15 11:58:11 +02:00
l := f . log . WithFields (
logrus . Fields {
"func" : "ActorForInbox" ,
"inboxIRI" : inboxIRI . String ( ) ,
} ,
)
l . Debugf ( "entering ACTORFORINBOX function with inboxIRI %s" , inboxIRI . String ( ) )
2021-05-08 14:25:55 +02:00
if ! util . IsInboxPath ( inboxIRI ) {
return nil , fmt . Errorf ( "%s is not an inbox URI" , inboxIRI . String ( ) )
}
acct := & gtsmodel . Account { }
2021-05-21 15:48:26 +02:00
if err := f . db . GetWhere ( [ ] db . Where { { Key : "inbox_uri" , Value : inboxIRI . String ( ) } } , acct ) ; err != nil {
2021-05-15 11:58:11 +02:00
if _ , ok := err . ( db . ErrNoEntries ) ; ok {
2021-05-08 14:25:55 +02:00
return nil , fmt . Errorf ( "no actor found that corresponds to inbox %s" , inboxIRI . String ( ) )
}
return nil , fmt . Errorf ( "db error searching for actor with inbox %s" , inboxIRI . String ( ) )
}
return url . Parse ( acct . URI )
2021-04-01 20:46:45 +02:00
}
2021-04-20 18:14:23 +02:00
// OutboxForInbox fetches the corresponding actor's outbox IRI for the
// actor's inbox IRI.
//
// The library makes this call only after acquiring a lock first.
func ( f * federatingDB ) OutboxForInbox ( c context . Context , inboxIRI * url . URL ) ( outboxIRI * url . URL , err error ) {
2021-05-15 11:58:11 +02:00
l := f . log . WithFields (
logrus . Fields {
"func" : "OutboxForInbox" ,
"inboxIRI" : inboxIRI . String ( ) ,
} ,
)
l . Debugf ( "entering OUTBOXFORINBOX function with inboxIRI %s" , inboxIRI . String ( ) )
2021-05-08 14:25:55 +02:00
if ! util . IsInboxPath ( inboxIRI ) {
return nil , fmt . Errorf ( "%s is not an inbox URI" , inboxIRI . String ( ) )
}
acct := & gtsmodel . Account { }
2021-05-21 15:48:26 +02:00
if err := f . db . GetWhere ( [ ] db . Where { { Key : "inbox_uri" , Value : inboxIRI . String ( ) } } , acct ) ; err != nil {
2021-05-15 11:58:11 +02:00
if _ , ok := err . ( db . ErrNoEntries ) ; ok {
2021-05-08 14:25:55 +02:00
return nil , fmt . Errorf ( "no actor found that corresponds to inbox %s" , inboxIRI . String ( ) )
}
return nil , fmt . Errorf ( "db error searching for actor with inbox %s" , inboxIRI . String ( ) )
}
return url . Parse ( acct . OutboxURI )
2021-04-01 20:46:45 +02:00
}
2021-04-20 18:14:23 +02:00
// Exists returns true if the database has an entry for the specified
// id. It may not be owned by this application instance.
//
// The library makes this call only after acquiring a lock first.
func ( f * federatingDB ) Exists ( c context . Context , id * url . URL ) ( exists bool , err error ) {
2021-05-15 11:58:11 +02:00
l := f . log . WithFields (
logrus . Fields {
"func" : "Exists" ,
"id" : id . String ( ) ,
} ,
)
l . Debugf ( "entering EXISTS function with id %s" , id . String ( ) )
2021-04-01 20:46:45 +02:00
return false , nil
}
2021-04-20 18:14:23 +02:00
// Get returns the database entry for the specified id.
//
// The library makes this call only after acquiring a lock first.
func ( f * federatingDB ) Get ( c context . Context , id * url . URL ) ( value vocab . Type , err error ) {
2021-05-15 11:58:11 +02:00
l := f . log . WithFields (
logrus . Fields {
"func" : "Get" ,
"id" : id . String ( ) ,
} ,
)
l . Debug ( "entering GET function" )
if util . IsUserPath ( id ) {
acct := & gtsmodel . Account { }
2021-05-21 15:48:26 +02:00
if err := f . db . GetWhere ( [ ] db . Where { { Key : "uri" , Value : id . String ( ) } } , acct ) ; err != nil {
2021-05-15 11:58:11 +02:00
return nil , err
}
2021-05-21 15:48:26 +02:00
l . Debug ( "is user path! returning account" )
2021-05-15 11:58:11 +02:00
return f . typeConverter . AccountToAS ( acct )
}
2021-04-01 20:46:45 +02:00
return nil , nil
}
2021-04-20 18:14:23 +02:00
// Create adds a new entry to the database which must be able to be
// keyed by its id.
//
// Note that Activity values received from federated peers may also be
// created in the database this way if the Federating Protocol is
// enabled. The client may freely decide to store only the id instead of
// the entire value.
//
// The library makes this call only after acquiring a lock first.
//
// Under certain conditions and network activities, Create may be called
// multiple times for the same ActivityStreams object.
2021-05-17 19:06:58 +02:00
func ( f * federatingDB ) Create ( ctx context . Context , asType vocab . Type ) error {
2021-05-15 11:58:11 +02:00
l := f . log . WithFields (
logrus . Fields {
"func" : "Create" ,
"asType" : asType . GetTypeName ( ) ,
} ,
)
2021-05-21 15:48:26 +02:00
m , err := streams . Serialize ( asType )
if err != nil {
return err
}
b , err := json . Marshal ( m )
if err != nil {
return err
}
l . Debugf ( "received CREATE asType %s" , string ( b ) )
2021-05-15 11:58:11 +02:00
2021-05-17 19:06:58 +02:00
targetAcctI := ctx . Value ( util . APAccount )
if targetAcctI == nil {
l . Error ( "target account wasn't set on context" )
2021-05-21 15:48:26 +02:00
return nil
2021-05-17 19:06:58 +02:00
}
targetAcct , ok := targetAcctI . ( * gtsmodel . Account )
if ! ok {
l . Error ( "target account was set on context but couldn't be parsed" )
2021-05-21 15:48:26 +02:00
return nil
2021-05-17 19:06:58 +02:00
}
fromFederatorChanI := ctx . Value ( util . APFromFederatorChanKey )
if fromFederatorChanI == nil {
l . Error ( "from federator channel wasn't set on context" )
2021-05-21 15:48:26 +02:00
return nil
2021-05-17 19:06:58 +02:00
}
fromFederatorChan , ok := fromFederatorChanI . ( chan gtsmodel . FromFederator )
if ! ok {
l . Error ( "from federator channel was set on context but couldn't be parsed" )
2021-05-21 15:48:26 +02:00
return nil
2021-05-17 19:06:58 +02:00
}
2021-05-21 15:48:26 +02:00
switch asType . GetTypeName ( ) {
2021-05-15 11:58:11 +02:00
case gtsmodel . ActivityStreamsCreate :
create , ok := asType . ( vocab . ActivityStreamsCreate )
if ! ok {
return errors . New ( "could not convert type to create" )
}
object := create . GetActivityStreamsObject ( )
for objectIter := object . Begin ( ) ; objectIter != object . End ( ) ; objectIter = objectIter . Next ( ) {
2021-05-21 15:48:26 +02:00
switch objectIter . GetType ( ) . GetTypeName ( ) {
2021-05-15 11:58:11 +02:00
case gtsmodel . ActivityStreamsNote :
note := objectIter . GetActivityStreamsNote ( )
status , err := f . typeConverter . ASStatusToStatus ( note )
if err != nil {
return fmt . Errorf ( "error converting note to status: %s" , err )
}
if err := f . db . Put ( status ) ; err != nil {
2021-05-21 15:48:26 +02:00
if _ , ok := err . ( db . ErrAlreadyExists ) ; ok {
return nil
}
2021-05-15 11:58:11 +02:00
return fmt . Errorf ( "database error inserting status: %s" , err )
}
2021-05-17 19:06:58 +02:00
fromFederatorChan <- gtsmodel . FromFederator {
2021-05-21 15:48:26 +02:00
APObjectType : gtsmodel . ActivityStreamsNote ,
APActivityType : gtsmodel . ActivityStreamsCreate ,
GTSModel : status ,
ReceivingAccount : targetAcct ,
2021-05-17 19:06:58 +02:00
}
2021-05-15 11:58:11 +02:00
}
}
case gtsmodel . ActivityStreamsFollow :
follow , ok := asType . ( vocab . ActivityStreamsFollow )
if ! ok {
return errors . New ( "could not convert type to follow" )
}
followRequest , err := f . typeConverter . ASFollowToFollowRequest ( follow )
if err != nil {
return fmt . Errorf ( "could not convert Follow to follow request: %s" , err )
}
if err := f . db . Put ( followRequest ) ; err != nil {
return fmt . Errorf ( "database error inserting follow request: %s" , err )
}
2021-05-17 19:06:58 +02:00
if ! targetAcct . Locked {
2021-05-21 15:48:26 +02:00
if _ , err := f . db . AcceptFollowRequest ( followRequest . AccountID , followRequest . TargetAccountID ) ; err != nil {
2021-05-17 19:06:58 +02:00
return fmt . Errorf ( "database error accepting follow request: %s" , err )
}
}
2021-05-15 11:58:11 +02:00
}
2021-04-01 20:46:45 +02:00
return nil
}
2021-04-20 18:14:23 +02:00
// Update sets an existing entry to the database based on the value's
// id.
//
// Note that Activity values received from federated peers may also be
// updated in the database this way if the Federating Protocol is
// enabled. The client may freely decide to store only the id instead of
// the entire value.
//
// The library makes this call only after acquiring a lock first.
2021-05-21 15:48:26 +02:00
func ( f * federatingDB ) Update ( ctx context . Context , asType vocab . Type ) error {
2021-05-15 11:58:11 +02:00
l := f . log . WithFields (
logrus . Fields {
"func" : "Update" ,
"asType" : asType . GetTypeName ( ) ,
} ,
)
2021-05-21 15:48:26 +02:00
m , err := streams . Serialize ( asType )
if err != nil {
return err
}
b , err := json . Marshal ( m )
if err != nil {
return err
}
l . Debugf ( "received UPDATE asType %s" , string ( b ) )
receivingAcctI := ctx . Value ( util . APAccount )
if receivingAcctI == nil {
l . Error ( "receiving account wasn't set on context" )
}
receivingAcct , ok := receivingAcctI . ( * gtsmodel . Account )
if ! ok {
l . Error ( "receiving account was set on context but couldn't be parsed" )
}
fromFederatorChanI := ctx . Value ( util . APFromFederatorChanKey )
if fromFederatorChanI == nil {
l . Error ( "from federator channel wasn't set on context" )
}
fromFederatorChan , ok := fromFederatorChanI . ( chan gtsmodel . FromFederator )
if ! ok {
l . Error ( "from federator channel was set on context but couldn't be parsed" )
}
switch asType . GetTypeName ( ) {
case gtsmodel . ActivityStreamsUpdate :
update , ok := asType . ( vocab . ActivityStreamsCreate )
if ! ok {
return errors . New ( "could not convert type to create" )
}
object := update . GetActivityStreamsObject ( )
for objectIter := object . Begin ( ) ; objectIter != object . End ( ) ; objectIter = objectIter . Next ( ) {
switch objectIter . GetType ( ) . GetTypeName ( ) {
case string ( gtsmodel . ActivityStreamsPerson ) :
person := objectIter . GetActivityStreamsPerson ( )
updatedAcct , err := f . typeConverter . ASRepresentationToAccount ( person )
if err != nil {
return fmt . Errorf ( "error converting person to account: %s" , err )
}
if err := f . db . Put ( updatedAcct ) ; err != nil {
return fmt . Errorf ( "database error inserting updated account: %s" , err )
}
fromFederatorChan <- gtsmodel . FromFederator {
APObjectType : gtsmodel . ActivityStreamsProfile ,
APActivityType : gtsmodel . ActivityStreamsUpdate ,
GTSModel : updatedAcct ,
ReceivingAccount : receivingAcct ,
}
case string ( gtsmodel . ActivityStreamsApplication ) :
application := objectIter . GetActivityStreamsApplication ( )
updatedAcct , err := f . typeConverter . ASRepresentationToAccount ( application )
if err != nil {
return fmt . Errorf ( "error converting person to account: %s" , err )
}
if err := f . db . Put ( updatedAcct ) ; err != nil {
return fmt . Errorf ( "database error inserting updated account: %s" , err )
}
fromFederatorChan <- gtsmodel . FromFederator {
APObjectType : gtsmodel . ActivityStreamsProfile ,
APActivityType : gtsmodel . ActivityStreamsUpdate ,
GTSModel : updatedAcct ,
ReceivingAccount : receivingAcct ,
}
}
}
}
2021-04-01 20:46:45 +02:00
return nil
}
2021-04-20 18:14:23 +02:00
// Delete removes the entry with the given id.
//
// Delete is only called for federated objects. Deletes from the Social
// Protocol instead call Update to create a Tombstone.
//
// The library makes this call only after acquiring a lock first.
func ( f * federatingDB ) Delete ( c context . Context , id * url . URL ) error {
2021-05-15 11:58:11 +02:00
l := f . log . WithFields (
logrus . Fields {
"func" : "Delete" ,
"id" : id . String ( ) ,
} ,
)
l . Debugf ( "received DELETE id %s" , id . String ( ) )
2021-04-01 20:46:45 +02:00
return nil
}
2021-04-20 18:14:23 +02:00
// GetOutbox returns the first ordered collection page of the outbox
// at the specified IRI, for prepending new items.
//
// The library makes this call only after acquiring a lock first.
func ( f * federatingDB ) GetOutbox ( c context . Context , outboxIRI * url . URL ) ( inbox vocab . ActivityStreamsOrderedCollectionPage , err error ) {
2021-05-15 11:58:11 +02:00
l := f . log . WithFields (
logrus . Fields {
"func" : "GetOutbox" ,
} ,
)
l . Debug ( "entering GETOUTBOX function" )
2021-05-21 15:48:26 +02:00
return streams . NewActivityStreamsOrderedCollectionPage ( ) , nil
2021-04-01 20:46:45 +02:00
}
2021-04-20 18:14:23 +02:00
// SetOutbox saves the outbox value given from GetOutbox, with new items
// prepended. Note that the new items must not be added as independent
// database entries. Separate calls to Create will do that.
//
// The library makes this call only after acquiring a lock first.
func ( f * federatingDB ) SetOutbox ( c context . Context , outbox vocab . ActivityStreamsOrderedCollectionPage ) error {
2021-05-15 11:58:11 +02:00
l := f . log . WithFields (
logrus . Fields {
"func" : "SetOutbox" ,
} ,
)
l . Debug ( "entering SETOUTBOX function" )
2021-04-01 20:46:45 +02:00
return nil
}
2021-04-20 18:14:23 +02:00
// NewID creates a new IRI id for the provided activity or object. The
// implementation does not need to set the 'id' property and simply
// needs to determine the value.
//
// The go-fed library will handle setting the 'id' property on the
// activity or object provided with the value returned.
func ( f * federatingDB ) NewID ( c context . Context , t vocab . Type ) ( id * url . URL , err error ) {
2021-05-15 11:58:11 +02:00
l := f . log . WithFields (
logrus . Fields {
"func" : "NewID" ,
"asType" : t . GetTypeName ( ) ,
} ,
)
2021-05-21 15:48:26 +02:00
m , err := streams . Serialize ( t )
if err != nil {
return nil , err
}
b , err := json . Marshal ( m )
if err != nil {
return nil , err
}
l . Debugf ( "received NEWID request for asType %s" , string ( b ) )
2021-05-15 11:58:11 +02:00
2021-05-21 15:48:26 +02:00
switch t . GetTypeName ( ) {
case gtsmodel . ActivityStreamsFollow :
// FOLLOW
// ID might already be set on a follow we've created, so check it here and return it if it is
follow , ok := t . ( vocab . ActivityStreamsFollow )
if ! ok {
return nil , errors . New ( "newid: follow couldn't be parsed into vocab.ActivityStreamsFollow" )
}
idProp := follow . GetJSONLDId ( )
if idProp != nil {
if idProp . IsIRI ( ) {
return idProp . GetIRI ( ) , nil
}
}
// it's not set so create one based on the actor set on the follow (ie., the followER not the followEE)
actorProp := follow . GetActivityStreamsActor ( )
if actorProp != nil {
for iter := actorProp . Begin ( ) ; iter != actorProp . End ( ) ; iter = iter . Next ( ) {
// take the IRI of the first actor we can find (there should only be one)
if iter . IsIRI ( ) {
actorAccount := & gtsmodel . Account { }
if err := f . db . GetWhere ( [ ] db . Where { { Key : "uri" , Value : iter . GetIRI ( ) . String ( ) } } , actorAccount ) ; err == nil { // if there's an error here, just use the fallback behavior -- we don't need to return an error here
return url . Parse ( util . GenerateURIForFollow ( actorAccount . Username , f . config . Protocol , f . config . Host ) )
}
}
}
}
case gtsmodel . ActivityStreamsNote :
// NOTE aka STATUS
// ID might already be set on a note we've created, so check it here and return it if it is
note , ok := t . ( vocab . ActivityStreamsNote )
if ! ok {
return nil , errors . New ( "newid: follow couldn't be parsed into vocab.ActivityStreamsNote" )
}
idProp := note . GetJSONLDId ( )
if idProp != nil {
if idProp . IsIRI ( ) {
return idProp . GetIRI ( ) , nil
}
}
}
// fallback default behavior: just return a random UUID after our protocol and host
return url . Parse ( fmt . Sprintf ( "%s://%s/%s" , f . config . Protocol , f . config . Host , uuid . NewString ( ) ) )
2021-04-01 20:46:45 +02:00
}
2021-04-20 18:14:23 +02:00
// Followers obtains the Followers Collection for an actor with the
// given id.
//
// If modified, the library will then call Update.
//
// The library makes this call only after acquiring a lock first.
func ( f * federatingDB ) Followers ( c context . Context , actorIRI * url . URL ) ( followers vocab . ActivityStreamsCollection , err error ) {
2021-05-15 11:58:11 +02:00
l := f . log . WithFields (
logrus . Fields {
"func" : "Followers" ,
"actorIRI" : actorIRI . String ( ) ,
} ,
)
l . Debugf ( "entering FOLLOWERS function with actorIRI %s" , actorIRI . String ( ) )
acct := & gtsmodel . Account { }
2021-05-21 15:48:26 +02:00
if err := f . db . GetWhere ( [ ] db . Where { { Key : "uri" , Value : actorIRI . String ( ) } } , acct ) ; err != nil {
2021-05-15 11:58:11 +02:00
return nil , fmt . Errorf ( "db error getting account with uri %s: %s" , actorIRI . String ( ) , err )
}
acctFollowers := [ ] gtsmodel . Follow { }
if err := f . db . GetFollowersByAccountID ( acct . ID , & acctFollowers ) ; err != nil {
return nil , fmt . Errorf ( "db error getting followers for account id %s: %s" , acct . ID , err )
}
followers = streams . NewActivityStreamsCollection ( )
items := streams . NewActivityStreamsItemsProperty ( )
for _ , follow := range acctFollowers {
gtsFollower := & gtsmodel . Account { }
if err := f . db . GetByID ( follow . AccountID , gtsFollower ) ; err != nil {
return nil , fmt . Errorf ( "db error getting account id %s: %s" , follow . AccountID , err )
}
uri , err := url . Parse ( gtsFollower . URI )
if err != nil {
return nil , fmt . Errorf ( "error parsing %s as url: %s" , gtsFollower . URI , err )
}
items . AppendIRI ( uri )
}
followers . SetActivityStreamsItems ( items )
return
2021-04-01 20:46:45 +02:00
}
2021-04-20 18:14:23 +02:00
// Following obtains the Following Collection for an actor with the
// given id.
//
// If modified, the library will then call Update.
//
// The library makes this call only after acquiring a lock first.
2021-05-15 11:58:11 +02:00
func ( f * federatingDB ) Following ( c context . Context , actorIRI * url . URL ) ( following vocab . ActivityStreamsCollection , err error ) {
l := f . log . WithFields (
logrus . Fields {
"func" : "Following" ,
"actorIRI" : actorIRI . String ( ) ,
} ,
)
l . Debugf ( "entering FOLLOWING function with actorIRI %s" , actorIRI . String ( ) )
acct := & gtsmodel . Account { }
2021-05-21 15:48:26 +02:00
if err := f . db . GetWhere ( [ ] db . Where { { Key : "uri" , Value : actorIRI . String ( ) } } , acct ) ; err != nil {
2021-05-15 11:58:11 +02:00
return nil , fmt . Errorf ( "db error getting account with uri %s: %s" , actorIRI . String ( ) , err )
}
acctFollowing := [ ] gtsmodel . Follow { }
if err := f . db . GetFollowingByAccountID ( acct . ID , & acctFollowing ) ; err != nil {
return nil , fmt . Errorf ( "db error getting following for account id %s: %s" , acct . ID , err )
}
following = streams . NewActivityStreamsCollection ( )
items := streams . NewActivityStreamsItemsProperty ( )
for _ , follow := range acctFollowing {
gtsFollowing := & gtsmodel . Account { }
if err := f . db . GetByID ( follow . AccountID , gtsFollowing ) ; err != nil {
return nil , fmt . Errorf ( "db error getting account id %s: %s" , follow . AccountID , err )
}
uri , err := url . Parse ( gtsFollowing . URI )
if err != nil {
return nil , fmt . Errorf ( "error parsing %s as url: %s" , gtsFollowing . URI , err )
}
items . AppendIRI ( uri )
}
following . SetActivityStreamsItems ( items )
return
2021-04-01 20:46:45 +02:00
}
2021-04-20 18:14:23 +02:00
// Liked obtains the Liked Collection for an actor with the
// given id.
//
// If modified, the library will then call Update.
//
// The library makes this call only after acquiring a lock first.
2021-05-15 11:58:11 +02:00
func ( f * federatingDB ) Liked ( c context . Context , actorIRI * url . URL ) ( liked vocab . ActivityStreamsCollection , err error ) {
l := f . log . WithFields (
logrus . Fields {
"func" : "Liked" ,
"actorIRI" : actorIRI . String ( ) ,
} ,
)
l . Debugf ( "entering LIKED function with actorIRI %s" , actorIRI . String ( ) )
2021-04-01 20:46:45 +02:00
return nil , nil
}
2021-05-21 15:48:26 +02:00
/ *
CUSTOM FUNCTIONALITY FOR GTS
* /
func ( f * federatingDB ) Undo ( ctx context . Context , undo vocab . ActivityStreamsUndo ) error {
l := f . log . WithFields (
logrus . Fields {
"func" : "Undo" ,
"asType" : undo . GetTypeName ( ) ,
} ,
)
m , err := streams . Serialize ( undo )
if err != nil {
return err
}
b , err := json . Marshal ( m )
if err != nil {
return err
}
l . Debugf ( "received UNDO asType %s" , string ( b ) )
targetAcctI := ctx . Value ( util . APAccount )
if targetAcctI == nil {
l . Error ( "UNDO: target account wasn't set on context" )
return nil
}
targetAcct , ok := targetAcctI . ( * gtsmodel . Account )
if ! ok {
l . Error ( "UNDO: target account was set on context but couldn't be parsed" )
return nil
}
undoObject := undo . GetActivityStreamsObject ( )
if undoObject == nil {
return errors . New ( "UNDO: no object set on vocab.ActivityStreamsUndo" )
}
for iter := undoObject . Begin ( ) ; iter != undoObject . End ( ) ; iter = iter . Next ( ) {
switch iter . GetType ( ) . GetTypeName ( ) {
case string ( gtsmodel . ActivityStreamsFollow ) :
// UNDO FOLLOW
ASFollow , ok := iter . GetType ( ) . ( vocab . ActivityStreamsFollow )
if ! ok {
return errors . New ( "UNDO: couldn't parse follow into vocab.ActivityStreamsFollow" )
}
// make sure the actor owns the follow
if ! sameActor ( undo . GetActivityStreamsActor ( ) , ASFollow . GetActivityStreamsActor ( ) ) {
return errors . New ( "UNDO: follow actor and activity actor not the same" )
}
// convert the follow to something we can understand
gtsFollow , err := f . typeConverter . ASFollowToFollow ( ASFollow )
if err != nil {
return fmt . Errorf ( "UNDO: error converting asfollow to gtsfollow: %s" , err )
}
// make sure the addressee of the original follow is the same as whatever inbox this landed in
if gtsFollow . TargetAccountID != targetAcct . ID {
return errors . New ( "UNDO: follow object account and inbox account were not the same" )
}
// delete any existing FOLLOW
if err := f . db . DeleteWhere ( [ ] db . Where { { Key : "uri" , Value : gtsFollow . URI } } , & gtsmodel . Follow { } ) ; err != nil {
return fmt . Errorf ( "UNDO: db error removing follow: %s" , err )
}
// delete any existing FOLLOW REQUEST
if err := f . db . DeleteWhere ( [ ] db . Where { { Key : "uri" , Value : gtsFollow . URI } } , & gtsmodel . FollowRequest { } ) ; err != nil {
return fmt . Errorf ( "UNDO: db error removing follow request: %s" , err )
}
l . Debug ( "follow undone" )
return nil
case string ( gtsmodel . ActivityStreamsLike ) :
// UNDO LIKE
case string ( gtsmodel . ActivityStreamsAnnounce ) :
// UNDO BOOST/REBLOG/ANNOUNCE
}
}
return nil
}
func ( f * federatingDB ) Accept ( ctx context . Context , accept vocab . ActivityStreamsAccept ) error {
l := f . log . WithFields (
logrus . Fields {
"func" : "Accept" ,
"asType" : accept . GetTypeName ( ) ,
} ,
)
m , err := streams . Serialize ( accept )
if err != nil {
return err
}
b , err := json . Marshal ( m )
if err != nil {
return err
}
l . Debugf ( "received ACCEPT asType %s" , string ( b ) )
inboxAcctI := ctx . Value ( util . APAccount )
if inboxAcctI == nil {
l . Error ( "ACCEPT: inbox account wasn't set on context" )
return nil
}
inboxAcct , ok := inboxAcctI . ( * gtsmodel . Account )
if ! ok {
l . Error ( "ACCEPT: inbox account was set on context but couldn't be parsed" )
return nil
}
acceptObject := accept . GetActivityStreamsObject ( )
if acceptObject == nil {
return errors . New ( "ACCEPT: no object set on vocab.ActivityStreamsUndo" )
}
for iter := acceptObject . Begin ( ) ; iter != acceptObject . End ( ) ; iter = iter . Next ( ) {
switch iter . GetType ( ) . GetTypeName ( ) {
case string ( gtsmodel . ActivityStreamsFollow ) :
// ACCEPT FOLLOW
asFollow , ok := iter . GetType ( ) . ( vocab . ActivityStreamsFollow )
if ! ok {
return errors . New ( "ACCEPT: couldn't parse follow into vocab.ActivityStreamsFollow" )
}
// convert the follow to something we can understand
gtsFollow , err := f . typeConverter . ASFollowToFollow ( asFollow )
if err != nil {
return fmt . Errorf ( "ACCEPT: error converting asfollow to gtsfollow: %s" , err )
}
// make sure the addressee of the original follow is the same as whatever inbox this landed in
if gtsFollow . AccountID != inboxAcct . ID {
return errors . New ( "ACCEPT: follow object account and inbox account were not the same" )
}
_ , err = f . db . AcceptFollowRequest ( gtsFollow . AccountID , gtsFollow . TargetAccountID )
return err
}
}
return nil
}