Compare commits
2 Commits
285d25223e
...
7aa400b936
| Author | SHA1 | Date | |
|---|---|---|---|
| 7aa400b936 | |||
| 1a82fbac12 |
@@ -20,48 +20,6 @@ sub get {
|
||||
return $promise;
|
||||
}
|
||||
|
||||
sub set {
|
||||
my ( $self, $key, $value ) = @_;
|
||||
my $promise = Mojo::Promise->new;
|
||||
$self->redis->set(
|
||||
$key => $value,
|
||||
sub {
|
||||
my ( $redis, $err, $result ) = @_;
|
||||
$err ? $promise->reject($err) : $promise->resolve($result);
|
||||
}
|
||||
);
|
||||
return $promise;
|
||||
}
|
||||
|
||||
sub incr {
|
||||
my ( $self, $key ) = @_;
|
||||
my $promise = Mojo::Promise->new;
|
||||
$self->redis->incr(
|
||||
$key => sub {
|
||||
my ( $redis, $err, $value ) = @_;
|
||||
$err ? $promise->reject($err) : $promise->resolve($value);
|
||||
}
|
||||
);
|
||||
return $promise;
|
||||
}
|
||||
|
||||
sub exists {
|
||||
my ( $self, $key ) = @_;
|
||||
my $promise = Mojo::Promise->new;
|
||||
$self->redis->exists(
|
||||
$key => sub {
|
||||
my ( $redis, $err, $exists ) = @_;
|
||||
if ($err) {
|
||||
$promise->reject($err);
|
||||
}
|
||||
else {
|
||||
$promise->resolve( $exists ? 1 : 0 );
|
||||
}
|
||||
}
|
||||
);
|
||||
return $promise;
|
||||
}
|
||||
|
||||
sub setnx {
|
||||
my ( $self, $key, $value ) = @_;
|
||||
my $promise = Mojo::Promise->new;
|
||||
@@ -81,7 +39,7 @@ sub setnx {
|
||||
}
|
||||
|
||||
sub ping {
|
||||
my $self = shift;
|
||||
my $self = shift;
|
||||
my $promise = Mojo::Promise->new;
|
||||
$self->redis->ping(
|
||||
sub {
|
||||
|
||||
30
t/03_db.t
30
t/03_db.t
@@ -61,36 +61,6 @@ subtest 'get' => sub {
|
||||
);
|
||||
};
|
||||
|
||||
subtest 'set' => sub {
|
||||
test_method(
|
||||
'set',
|
||||
'set',
|
||||
[ 'test_key', 'test_value' ],
|
||||
[ [ 'OK', undef, 'OK', 'returns success result' ] ],
|
||||
[ [ 'Write error', 'error is returned' ] ]
|
||||
);
|
||||
};
|
||||
|
||||
subtest 'incr' => sub {
|
||||
test_method(
|
||||
'incr', 'incr', ['test_key'],
|
||||
[ [ 42, undef, 42, 'returns correct value' ] ],
|
||||
[ [ 'Increment error', 'error is returned' ] ]
|
||||
);
|
||||
};
|
||||
|
||||
subtest 'exists' => sub {
|
||||
test_method(
|
||||
'exists', 'exists',
|
||||
['test_key'],
|
||||
[
|
||||
[ 1, undef, 1, 'returns 1 when key exists' ],
|
||||
[ 0, undef, 0, 'returns 0 when key does not exist' ],
|
||||
],
|
||||
[ [ 'Exists error', 'error is returned' ] ]
|
||||
);
|
||||
};
|
||||
|
||||
subtest 'setnx' => sub {
|
||||
test_method(
|
||||
'setnx', 'setnx',
|
||||
|
||||
Reference in New Issue
Block a user