1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
|
#ifndef __CSS3PROTOCOL_H__
#define __CSS3PROTOCOL_H__
/* Copyright (c) 2009 PrimeBase Technologies GmbH, Germany
*
* PrimeBase Media Stream for MySQL
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*
* Created by Barry Leslie on 10/02/09.
*
*/
#include "CSHTTPStream.h"
class S3ProtocolCon;
#define PUB_KEY_BIT ((uint8_t)1)
#define PRIV_KEY_BIT ((uint8_t)2)
#define SERVER_BIT ((uint8_t)4)
class CSS3Protocol: public CSRefObject {
private:
CSStringBuffer *s3_server;
CSString *s3_public_key;
CSString *s3_private_key;
uint8_t s3_ready; // A flag to indicate if the S3 protocol has been fully initialised.
uint32_t s3_maxRetrys;
CSString *s3_getSignature(const char *verb,
const char *md5,
const char *content_type,
const char *date,
const char *bucket,
const char *key,
CSString *headers = NULL
);
public:
CSS3Protocol();
~CSS3Protocol();
void s3_setServer(const char *server_arg)
{
s3_server->setLength(0);
if (server_arg && *server_arg) {
s3_ready |= SERVER_BIT;
s3_server->append(server_arg);
if (server_arg[strlen(server_arg)-1] != '/')
s3_server->append("/");
} else {
s3_ready ^= SERVER_BIT;
}
}
const char *s3_getServer() { return s3_server->getCString();}
void s3_setPublicKey(const char *key_arg)
{
s3_public_key->release();
s3_public_key = NULL;
if (key_arg && *key_arg) {
s3_ready |= PUB_KEY_BIT;
s3_public_key = CSString::newString(key_arg);
} else {
s3_ready ^= PUB_KEY_BIT;
}
}
const char *s3_getPublicKey() { return s3_public_key->getCString();}
void s3_setPrivateKey(const char *key_arg)
{
s3_private_key->release();
s3_private_key = NULL;
if (key_arg && *key_arg) {
s3_ready |= PRIV_KEY_BIT;
s3_private_key = CSString::newString(key_arg);
} else {
s3_ready ^= PRIV_KEY_BIT;
}
}
const char *s3_getPrivateKey() { return s3_private_key->getCString();}
bool s3_isReady() { return ((s3_ready & SERVER_BIT) && (s3_ready & PUB_KEY_BIT) && (s3_ready & PRIV_KEY_BIT));}
// s3_getAuthorization() returns the S3 Authorization sting and the time on which it was based.
CSString *s3_getAuthorization(const char *bucket, const char *key, const char *content_type, uint32_t *s3AuthorizationTime);
CSVector *s3_send(CSInputStream *input, const char *bucket, const char *key, off64_t size, const char *content_type = NULL, Md5Digest *digest = NULL, const char *s3Authorization = NULL, time_t s3AuthorizationTime = 0);
// s3_receive() returns false if the object was not found.
CSVector *s3_receive(CSOutputStream *output, const char *bucket, const char *key, bool *found);
// s3_delete() returns false if the object was not found.
bool s3_delete(const char *bucket, const char *key);
void s3_copy(const char *dest_server, const char *dest_bucket, const char *dest_key, const char *src_bucket, const char *src_key);
// s3_list() returns a CSString list if the keys in the bucket with the specified prefix.
// The list size returned can be limited with the 'max' parameter. The value 0 indicates no max.
CSVector *s3_list(const char *bucket, const char *key_prefix = NULL, uint32_t max = 0);
CSString *s3_getDataURL(const char *bucket, const char *key, uint32_t keep_alive);
};
#endif //__CSS3PROTOCOL_H__
|