summaryrefslogtreecommitdiff
path: root/lib/Travelynx/Model
diff options
context:
space:
mode:
Diffstat (limited to 'lib/Travelynx/Model')
-rw-r--r--lib/Travelynx/Model/Users.pm145
1 files changed, 131 insertions, 14 deletions
diff --git a/lib/Travelynx/Model/Users.pm b/lib/Travelynx/Model/Users.pm
index 4444dc9..fbd53fd 100644
--- a/lib/Travelynx/Model/Users.pm
+++ b/lib/Travelynx/Model/Users.pm
@@ -103,7 +103,6 @@ sub verify_registration_token {
my $db = $opt{db} // $self->{pg}->db;
my $tx;
-
if ( not $opt{in_transaction} ) {
$tx = $db->begin;
}
@@ -120,7 +119,7 @@ sub verify_registration_token {
if ( $res->hash->{count} ) {
$db->update( 'users', { status => 1 }, { id => $uid } );
$db->delete( 'pending_registrations', { user_id => $uid } );
- if ( not $opt{in_transaction} ) {
+ if ($tx) {
$tx->commit;
}
return 1;
@@ -179,8 +178,11 @@ sub get_privacy_by {
$where{id} = $opt{uid};
}
- my $res = $db->select( 'users', [ 'id', 'public_level' ],
- { %where, status => 1 } );
+ my $res = $db->select(
+ 'users',
+ [ 'id', 'public_level', 'accept_follows' ],
+ { %where, status => 1 }
+ );
if ( my $user = $res->hash ) {
return {
@@ -189,10 +191,12 @@ sub get_privacy_by {
default_visibility => $user->{public_level} & 0x7f,
default_visibility_str =>
$visibility_itoa{ $user->{public_level} & 0x7f },
- comments_visible => $user->{public_level} & 0x80 ? 1 : 0,
- past_visible => ( $user->{public_level} & 0x300 ) >> 8,
- past_all => $user->{public_level} & 0x400 ? 1 : 0,
- past_status => $user->{public_level} & 0x800 ? 1 : 0,
+ comments_visible => $user->{public_level} & 0x80 ? 1 : 0,
+ past_visible => ( $user->{public_level} & 0x300 ) >> 8,
+ past_all => $user->{public_level} & 0x400 ? 1 : 0,
+ past_status => $user->{public_level} & 0x800 ? 1 : 0,
+ accept_follows => $user->{accept_follows} == 2 ? 1 : 0,
+ accept_follow_requests => $user->{accept_follows} == 1 ? 1 : 0,
};
}
return;
@@ -215,6 +219,27 @@ sub set_privacy {
$db->update( 'users', { public_level => $public_level }, { id => $uid } );
}
+sub set_social {
+ my ( $self, %opt ) = @_;
+ my $db = $opt{db} // $self->{pg}->db;
+ my $uid = $opt{uid};
+
+ my $accept_follows = 0;
+
+ if ( $opt{accept_follows} ) {
+ $accept_follows = 2;
+ }
+ elsif ( $opt{accept_follow_requests} ) {
+ $accept_follows = 1;
+ }
+
+ $db->update(
+ 'users',
+ { accept_follows => $accept_follows },
+ { id => $uid }
+ );
+}
+
sub mark_for_password_reset {
my ( $self, %opt ) = @_;
my $db = $opt{db} // $self->{pg}->db;
@@ -373,7 +398,8 @@ sub get {
my $user = $db->select(
'users',
- 'id, name, status, public_level, email, external_services, '
+ 'id, name, status, public_level, email, '
+ . 'external_services, accept_follows, notifications, '
. 'extract(epoch from registered_at) as registered_at_ts, '
. 'extract(epoch from last_seen) as last_seen_ts, '
. 'extract(epoch from deletion_requested) as deletion_requested_ts',
@@ -384,6 +410,9 @@ sub get {
id => $user->{id},
name => $user->{name},
status => $user->{status},
+ notifications => $user->{notifications},
+ accept_follows => $user->{accept_follows} == 2 ? 1 : 0,
+ accept_follow_requests => $user->{accept_follows} == 1 ? 1 : 0,
is_public => $user->{public_level},
default_visibility => $user->{public_level} & 0x7f,
default_visibility_str =>
@@ -512,7 +541,6 @@ sub delete {
my $db = $opt{db} // $self->{pg}->db;
my $uid = $opt{uid};
my $tx;
-
if ( not $opt{in_transaction} ) {
$tx = $db->begin;
}
@@ -537,7 +565,7 @@ sub delete {
die("Deleted $res{users} rows from users, expected 1. Rolling back.\n");
}
- if ( not $opt{in_transaction} ) {
+ if ($tx) {
$tx->commit;
}
@@ -722,8 +750,6 @@ sub update_webhook_status {
);
}
-# TODO irgendwo muss auch noch ne einstellung rein, um follows / follow requests global zu deaktivieren
-
sub get_relation {
my ( $self, %opt ) = @_;
@@ -749,6 +775,31 @@ sub get_relation {
# { subject_id => [$uid, $target], object_id => [$target, $target] } )->hash;
}
+sub update_notifications {
+ my ( $self, %opt ) = @_;
+
+ # must be called inside a transaction, so $opt{db} is mandatory.
+ my $db = $opt{db};
+ my $uid = $opt{uid};
+
+ my $has_follow_requests = $opt{has_follow_requests}
+ // $self->has_follow_requests(
+ db => $db,
+ uid => $uid
+ );
+
+ my $notifications
+ = $db->select( 'users', ['notifications'], { id => $uid } )
+ ->hash->{notifications};
+ if ($has_follow_requests) {
+ $notifications |= 0x01;
+ }
+ else {
+ $notifications &= ~0x01;
+ }
+ $db->update( 'users', { notifications => $notifications }, { id => $uid } );
+}
+
sub request_follow {
my ( $self, %opt ) = @_;
@@ -756,14 +807,29 @@ sub request_follow {
my $uid = $opt{uid};
my $target = $opt{target};
+ my $tx;
+ if ( not $opt{in_transaction} ) {
+ $tx = $db->begin;
+ }
+
$db->insert(
'relations',
{
subject_id => $uid,
predicate => $predicate_atoi{requests_follow},
object_id => $target,
+ ts => DateTime->now( time_zone => 'Europe/Berlin' ),
}
);
+ $self->update_notifications(
+ db => $db,
+ uid => $target,
+ has_follow_requests => 1,
+ );
+
+ if ($tx) {
+ $tx->commit;
+ }
}
sub accept_follow_request {
@@ -773,10 +839,16 @@ sub accept_follow_request {
my $uid = $opt{uid};
my $applicant = $opt{applicant};
+ my $tx;
+ if ( not $opt{in_transaction} ) {
+ $tx = $db->begin;
+ }
+
$db->update(
'relations',
{
predicate => $predicate_atoi{follows},
+ ts => DateTime->now( time_zone => 'Europe/Berlin' ),
},
{
subject_id => $applicant,
@@ -784,6 +856,14 @@ sub accept_follow_request {
object_id => $uid
}
);
+ $self->update_notifications(
+ db => $db,
+ uid => $uid
+ );
+
+ if ($tx) {
+ $tx->commit;
+ }
}
sub reject_follow_request {
@@ -793,6 +873,11 @@ sub reject_follow_request {
my $uid = $opt{uid};
my $applicant = $opt{applicant};
+ my $tx;
+ if ( not $opt{in_transaction} ) {
+ $tx = $db->begin;
+ }
+
$db->delete(
'relations',
{
@@ -801,6 +886,14 @@ sub reject_follow_request {
object_id => $uid
}
);
+ $self->update_notifications(
+ db => $db,
+ uid => $uid
+ );
+
+ if ($tx) {
+ $tx->commit;
+ }
}
sub unfollow {
@@ -837,18 +930,32 @@ sub block {
my $uid = $opt{uid};
my $target = $opt{target};
+ my $tx;
+ if ( not $opt{in_transaction} ) {
+ $tx = $db->begin;
+ }
+
$db->insert(
'relations',
{
subject_id => $target,
predicate => $predicate_atoi{is_blocked_by},
- object_id => $uid
+ object_id => $uid,
+ ts => DateTime->now( time_zone => 'Europe/Berlin' ),
},
{
on_conflict => \
'(subject_id, object_id) do update set predicate = EXCLUDED.predicate'
},
);
+ $self->update_notifications(
+ db => $db,
+ uid => $uid
+ );
+
+ if ($tx) {
+ $tx->commit;
+ }
}
sub unblock {
@@ -891,6 +998,16 @@ sub get_follow_requests {
return $res->hashes->each;
}
+sub has_follow_requests {
+ my ( $self, %opt ) = @_;
+
+ my $db = $opt{db} // $self->{pg}->db;
+ my $uid = $opt{uid};
+
+ return $db->select( 'follow_requests', 'count(*) as count',
+ { self_id => $uid } )->hash->{count};
+}
+
sub get_followees {
my ( $self, %opt ) = @_;
generated by cgit v1.2.3 (git 2.39.1) at 2024-11-01 08:57:49 +0000