From a37db546527958dddae1b3a5f43d65a40e3fb69e Mon Sep 17 00:00:00 2001
From: miker <miker@9efc2488-bf62-4759-914b-345cdb29e865>
Date: Thu, 24 Feb 2005 16:34:33 +0000
Subject: [PATCH] added .slot.set_expire interface for
 setting/removing/updating the expire time of a slot

git-svn-id: svn://svn.open-ils.org/OpenSRF/trunk@103 9efc2488-bf62-4759-914b-345cdb29e865
---
 src/perlmods/OpenSRF/Application/Persist.pm | 40 +++++++++++++++++----
 1 file changed, 33 insertions(+), 7 deletions(-)

diff --git a/src/perlmods/OpenSRF/Application/Persist.pm b/src/perlmods/OpenSRF/Application/Persist.pm
index aca73d9..90f3251 100644
--- a/src/perlmods/OpenSRF/Application/Persist.pm
+++ b/src/perlmods/OpenSRF/Application/Persist.pm
@@ -95,6 +95,7 @@ sub create_store {
 		$dbh->do("UPDATE store_name SET name = '$name' WHERE id = '$last_id';");
 	}
 
+	_flush_by_name($name);
 	return $name;
 }
 __PACKAGE__->register_method(
@@ -119,11 +120,7 @@ sub create_expirable_store {
 		}
 	};
 
-	my $name_id = _get_name_id($name);
-	my $atime = time;
-	my $etime = interval_to_seconds($time);
-
-	$dbh->do('INSERT INTO store_expire (id, atime, expire_interval) VALUES (?,?,?);',{},$name_id,$atime,$etime);
+	$self->method_lookup('opensrf.persist.slot.set_expire')->run($name, $time);
 
 	return $name;
 }
@@ -138,6 +135,28 @@ sub _update_expire_atime {
 	$dbh->do('UPDATE store_expire SET atime = ? WHERE id = ?', {}, time(), $id);
 }
 
+sub set_expire_interval {
+	my $self = shift;
+	my $client = shift;
+	my $slot = shift;
+	my $new_interval = shift;
+
+	my $etime = interval_to_seconds($new_interval);
+	my $sid = _get_name_id($slot);
+
+	$dbh->do('DELETE FROM store_expire where id = ?', {}, $sid);
+	return $slot if ($etime == 0);
+
+	$dbh->do('INSERT INTO store_expire (id, atime, expire_interval) VALUES (?,?,?);',{},$sid,time(),$etime);
+	return $slot;
+}
+__PACKAGE__->register_method(
+	api_name => 'opensrf.persist.slot.set_expire',
+	method => 'set_expire_interval',
+	argc => 2,
+);
+
+
 sub _sweep_expired_slots {
 	return if (shift());
 
@@ -170,6 +189,8 @@ sub add_item {
 
 	$dbh->do('INSERT INTO storage (name_id,value) VALUES (?,?);', {}, $name_id, JSON->perl2JSON($value));
 
+	_flush_by_name($name);
+
 	return 0 if ($dbh->err);
 	return $name;
 }
@@ -240,11 +261,15 @@ __PACKAGE__->register_method(
 sub _flush_by_name {
 	my $name = shift;
 	my $no_sweep = shift;
+ 
+	my $name_id = _get_name_id($name);
 
-	_sweep_expired_slots() unless ($no_sweep);
+	unless ($no_sweep) {
+ 		_update_expire_atime($name);
+		_sweep_expired_slots();
+	}
 	
 	if ($name =~ /^AUTOGENERATED!!/) {
-		my $name_id = _get_name_id($name);
 		my $count = $dbh->selectcol_arrayref("SELECT COUNT(*) FROM storage WHERE name_id = ?;", {}, $name_id);
 		if (!ref($count) || $$count[0] == 0) {
 			$dbh->do("DELETE FROM store_name WHERE name = ?;", {}, $name);
@@ -296,6 +321,7 @@ sub peek_slot {
 
 	$client->respond( JSON->JSON2perl( $_->[0] ) ) for (@$values);
 
+	_flush_by_name($name);
 	return undef;
 }
 __PACKAGE__->register_method(
-- 
2.43.2