Compare commits
2 Commits
285d25223e
...
7aa400b936
| Author | SHA1 | Date | |
|---|---|---|---|
| 7aa400b936 | |||
| 1a82fbac12 |
@@ -20,48 +20,6 @@ sub get {
|
|||||||
return $promise;
|
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 {
|
sub setnx {
|
||||||
my ( $self, $key, $value ) = @_;
|
my ( $self, $key, $value ) = @_;
|
||||||
my $promise = Mojo::Promise->new;
|
my $promise = Mojo::Promise->new;
|
||||||
@@ -81,7 +39,7 @@ sub setnx {
|
|||||||
}
|
}
|
||||||
|
|
||||||
sub ping {
|
sub ping {
|
||||||
my $self = shift;
|
my $self = shift;
|
||||||
my $promise = Mojo::Promise->new;
|
my $promise = Mojo::Promise->new;
|
||||||
$self->redis->ping(
|
$self->redis->ping(
|
||||||
sub {
|
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 {
|
subtest 'setnx' => sub {
|
||||||
test_method(
|
test_method(
|
||||||
'setnx', 'setnx',
|
'setnx', 'setnx',
|
||||||
|
|||||||
Reference in New Issue
Block a user