kvs-php.git

1) <?php
2) require('config.php');

3) header("Content-Type: text/plain");

4) try {
5)     $db = new PDO('sqlite:store.db');

6)     $db->exec('create table if not exists keys(k varchar(80) primary key, 
7)                v varchar(140), created integer, updated integer, origin varchar(16));');

8) } catch(PDOException $e) {
9)     echo 'Exception : '.$e->getMessage();
10)     exit(0);
11) }
12) 
13) if (isset($_GET['k'])) {

14)     // This is a request to get one specific value.

15)     $keys = array_map(array($db, 'quote'), explode(',', $_GET['k']));

16)     $result = $db->query('SELECT v FROM keys WHERE k IN ('.implode(',', $keys).') 
17)                           ORDER BY updated DESC LIMIT 1;', PDO::FETCH_ASSOC);

18)     foreach($result as $row) {

19)         echo $row['v'];

20)     }
21)     exit(0);
22) } elseif (isset($_POST['auth'])) {
23)     if ($_POST['auth'] != $authorization) {

24)         echo "Not authorized.\n";

25)         exit(0);
26)     }

27) 

28)     // We have an authorized request to insert or replace a key/value pair.
29)     $stmt = $db->prepare(
30)         'INSERT OR REPLACE INTO keys
31)          VALUES (:k, :v,
32)                  COALESCE((SELECT created FROM keys WHERE k = :k), :rtime),
33)                  :rtime, :raddr);');
34)     $stmt->bindParam(':rtime', $_SERVER['REQUEST_TIME'], PDO::PARAM_INT);
35)     $stmt->bindParam(':raddr', $_SERVER['REMOTE_ADDR'], PDO::PARAM_STR);
36) 
37)     foreach($_POST as $key => $value) {

38)         if ($key == 'auth') {
39)             continue;
40)         }

41)         $stmt->bindParam(':k', $key, PDO::PARAM_STR);
42)         $stmt->bindParam(':v', $value, PDO::PARAM_STR);

43)         $stmt->execute();
44)         if ($db->errorCode() != '00000') {
45)             echo "Error:", $db->errorInfo()[2], "\n";
46)         } else {

47)             echo "OK\n";

48)         }

49)     }
50)     exit(0);
51) }

52) $headers = array("key          ","value         ","created     ","updated     ","origin      ");

53) echo implode("\t", $headers)."\n";

54) $headers = array("-------------","--------------","------------","------------","------------");

55) echo implode("\t", $headers)."\n";

56) $result = $db->query('SELECT * FROM keys ORDER BY updated DESC', PDO::FETCH_ASSOC);