gtsocial-umbx

Unnamed repository; edit this file 'description' to name the repository.
Log | Files | Refs | README | LICENSE

following.go (2057B)


      1 // GoToSocial
      2 // Copyright (C) GoToSocial Authors admin@gotosocial.org
      3 // SPDX-License-Identifier: AGPL-3.0-or-later
      4 //
      5 // This program is free software: you can redistribute it and/or modify
      6 // it under the terms of the GNU Affero General Public License as published by
      7 // the Free Software Foundation, either version 3 of the License, or
      8 // (at your option) any later version.
      9 //
     10 // This program is distributed in the hope that it will be useful,
     11 // but WITHOUT ANY WARRANTY; without even the implied warranty of
     12 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
     13 // GNU Affero General Public License for more details.
     14 //
     15 // You should have received a copy of the GNU Affero General Public License
     16 // along with this program.  If not, see <http://www.gnu.org/licenses/>.
     17 
     18 package federatingdb
     19 
     20 import (
     21 	"context"
     22 	"fmt"
     23 	"net/url"
     24 
     25 	"github.com/superseriousbusiness/activity/streams/vocab"
     26 	"github.com/superseriousbusiness/gotosocial/internal/log"
     27 )
     28 
     29 // Following obtains the Following Collection for an actor with the
     30 // given id.
     31 //
     32 // If modified, the library will then call Update.
     33 //
     34 // The library makes this call only after acquiring a lock first.
     35 func (f *federatingDB) Following(ctx context.Context, actorIRI *url.URL) (following vocab.ActivityStreamsCollection, err error) {
     36 	acct, err := f.getAccountForIRI(ctx, actorIRI)
     37 	if err != nil {
     38 		return nil, err
     39 	}
     40 
     41 	follows, err := f.state.DB.GetAccountFollows(ctx, acct.ID)
     42 	if err != nil {
     43 		return nil, fmt.Errorf("Following: db error getting following for account id %s: %w", acct.ID, err)
     44 	}
     45 
     46 	iris := make([]*url.URL, 0, len(follows))
     47 	for _, follow := range follows {
     48 		if follow.TargetAccount == nil {
     49 			// Follow target account no longer exists,
     50 			// for some reason. Skip this one.
     51 			log.WithContext(ctx).WithField("follow", follow).Warnf("follow missing target account %s", follow.TargetAccountID)
     52 			continue
     53 		}
     54 
     55 		u, err := url.Parse(follow.TargetAccount.URI)
     56 		if err != nil {
     57 			return nil, err
     58 		}
     59 		iris = append(iris, u)
     60 	}
     61 
     62 	return f.collectIRIs(ctx, iris)
     63 }