98 lines
2.2 KiB
Perl
98 lines
2.2 KiB
Perl
package IpfsUpload::Model::Users;
|
|
use strict;
|
|
use warnings FATAL => 'all';
|
|
use experimental q/signatures/;
|
|
use Crypt::Random qw( makerandom_octet );
|
|
|
|
use Mojo::Base -base, -signatures;
|
|
|
|
has 'sql';
|
|
|
|
sub token_info($self, $token) {
|
|
return $self->sql->db->select('access_token', ['uid', 'app_name'], { token => $token })->hash;
|
|
}
|
|
|
|
sub token_info_p($self, $token) {
|
|
return $self->sql->db->select_p('access_token', ['uid', 'app_name', 'id'], {
|
|
token => $token,
|
|
})->then(sub ($res) {
|
|
return $res->hash;
|
|
});
|
|
}
|
|
|
|
sub gen_token($self, $uid, $app_name) {
|
|
my $size = 512;
|
|
my $r = makerandom_octet(Size => $size, Strength => 0);
|
|
my $s = unpack "H*", pack "B*", '0' x ( $size%8 ? 8-$size % 8 : 0 ).
|
|
unpack "b$size", $r;
|
|
|
|
return $self->sql->db->insert_p(
|
|
'access_token',
|
|
{
|
|
uid => $uid,
|
|
app_name => $app_name,
|
|
token => $s,
|
|
},
|
|
{returning => ['token']}
|
|
)->then(sub ($res) {
|
|
return $res->hash->{token};
|
|
});
|
|
}
|
|
|
|
sub del_token($self, $uid, $id) {
|
|
return $self->sql->db->delete_p(
|
|
'access_token',
|
|
{
|
|
uid => $uid,
|
|
id => $id,
|
|
}
|
|
);
|
|
}
|
|
|
|
sub list_tokens($self, $uid) {
|
|
return $self->sql->db->select_p('access_token', ['uid', 'app_name', 'id'], {
|
|
uid => $uid,
|
|
})->then(sub ($res) {
|
|
return $res->hashes;
|
|
});
|
|
}
|
|
|
|
sub get_or_make($self, $username) {
|
|
return $self->sql->db->select_p('users', ['uid'], {username => $username})->then(sub ($res) {
|
|
my $val = $res->hash;
|
|
if (defined $val) {
|
|
return $val->{uid};
|
|
}
|
|
return $self->sql->db->insert_p('users', {username => $username}, {returning => 'uid'})->then(sub ($n) {
|
|
return $n->hash->{uid};
|
|
});
|
|
});
|
|
}
|
|
|
|
sub get($self, $username) {
|
|
return $self->sql->db->select_p('users', ['uid'], {username => $username})->then(sub ($res) {
|
|
my $val = $res->hash;
|
|
if (defined $val) {
|
|
return $val->{uid};
|
|
}
|
|
return undef;
|
|
});
|
|
}
|
|
|
|
sub get_pass_hash($self, $uid) {
|
|
return $self->sql->db->select_p('users', ['pass'], {uid => $uid})->then(sub ($res) {
|
|
return $res->hash->{pass};
|
|
});
|
|
}
|
|
|
|
sub make_with_pass($self, $username, $hash) {
|
|
return $self->sql->db->insert_p('users', {username => $username, pass => $hash}, {returning => 'uid'})->then(sub ($n) {
|
|
return $n->hash->{uid};
|
|
});
|
|
}
|
|
|
|
sub set_pass_hash($self, $uid, $hash) {
|
|
return $self->sql->db->update_p('users', { pass => $hash }, { uid => $uid });
|
|
}
|
|
1;
|