Alter Rust bindings to make investigation easier, reproduce issue 63

This patch introduces a PHP script in DEBUG-sfalvo where I am able to reproduce
the OP's issue.  To do this, I needed to make a small adjustment to the Rust
binding code.

After speaking with Khosrow, he recommended adding a few utility methods to the
Expiration class ("We probably need a few methods in there, including
neverExpire() -> bool, serverDefault() -> bool in addition to inSeconds()
(in seconds should be an i64 that can be negative for the two above values.)).

For now, this is just a research branch; DO NOT merge into main.

Author: sfalvo-aerospike

DEBUG-sfalvo/put.php

@@ -0,0 +1,97 @@
+<?php
+
+namespace Aerospike;
+
+////////////////////////////////////////////////////////////////////////////////
+//
+//	Creating Client, persisting in permanent storage, retriving from there
+//
+////////////////////////////////////////////////////////////////////////////////
+
+$socket = "/tmp/asld_grpc.sock";
+
+$client = Client::connect($socket);
+
+////////////////////////////////////////////////////////////////////////////////
+//
+// Key object
+//
+////////////////////////////////////////////////////////////////////////////////
+
+$key = new Key("test", "test", 1);
+
+////////////////////////////////////////////////////////////////////////////////
+//
+// client->truncate
+//
+////////////////////////////////////////////////////////////////////////////////
+
+// $ip = new InfoPolicy();
+// $client->truncate($ip, "test", "test");
+
+////////////////////////////////////////////////////////////////////////////////
+//
+// client->put
+//
+////////////////////////////////////////////////////////////////////////////////
+
+echo "============= PUT ===============\n";
+
+$wp = new WritePolicy();
+$wp->setExpiration(Expiration::Seconds(10));
+
+$bin1 = new Bin("bin1", 111);
+
+for ($x = 0; $x < 10; $x++) {
+	$key = new Key("test", "test", $x);
+	$bin1 = new Bin("bin1", $x);
+	echo "/";
+	$client->put($wp, $key, [$bin1]);
+}
+echo "\n";
+
+////////////////////////////////////////////////////////////////////////////////
+//
+// client->get
+//
+////////////////////////////////////////////////////////////////////////////////
+
+echo "============= GET ===============\n";
+
+$rp = new ReadPolicy();
+
+$rp->setMaxRetries(3);
+$timeInMillis = 3000;
+$rp->timeout = $timeInMillis;
+
+var_dump($rp);
+
+for ($x = 0; $x <= 10; $x++) {
+	sleep(1);
+	$record = $client->get($rp, $key, ["bin1"]);
+	if ($record) {
+		echo "RECORD " . $x . " TTL = " . ($record->getTtl()) . "\n";
+		echo "RECORD " . $x . " EXP = " . ($record->getExpiration()->inSeconds()) . "\n";
+	}
+	else {
+		echo "Record " . $x . " expired.\n";
+	}
+}
+
+$record = $client->get($rp, $key);
+var_dump($record->bins);
+var_dump($record->generation);
+var_dump($record->key);
+
+////////////////////////////////////////////////////////////////////////////////
+//
+// $client->delete
+//
+////////////////////////////////////////////////////////////////////////////////
+
+$deleted = $client->delete($wp, $key);
+var_dump($deleted);
+
+$exists = $client->exists($rp, $key);
+var_dump($exists);
+

src/lib.rs

@@ -1657,6 +1657,12 @@ impl Expiration {
             _as: _Expiration::DontUpdate,
         }
     }
+
+	/// Answers with the expiration's configured value in units of seconds.
+	#[getter]
+	pub fn in_seconds(&self) -> u32 {
+		self.into()
+	}
 }
 
 impl From<&Expiration> for u32 {
@@ -9744,6 +9750,7 @@ impl Client {
     /// Write record bin(s). The policy specifies the transaction timeout, record expiration and
     /// how the transaction is handled when the record already exists.
     pub fn put(&self, policy: &WritePolicy, key: &Key, bins: Vec<&Bin>) -> PhpResult<()> {
+		eprintln!("LBPUT001 put() entered");
         let bins: Vec<proto::Bin> = bins.into_iter().map(|b| b.into()).collect();
 
         let request = tonic::Request::new(proto::AerospikePutRequest {
@@ -9761,6 +9768,7 @@ impl Client {
             } => Ok(()),
             pe => {
                 let error: AerospikeException = pe.into();
+				eprintln!("LBPUT002 Error detected: {:?}", error);
                 throw_object(error.into_zval(true)?)?;
                 Ok(())
             }