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
|
#include "ds_blob.h"
#include "jx.h"
#include "jx_print.h"
#include "jx_parse.h"
#include "debug.h"
#include <stdlib.h>
#include <string.h>
#include <stdio.h>
struct ds_blob * ds_blob_create( const char *blobid, jx_int_t size, struct jx *meta)
{
struct ds_blob *b = malloc(sizeof(*b));
memset(b,0,sizeof(*b));
b->blobid = strdup(blobid);
b->state = DS_BLOB_RW;
b->size = size;
b->md5hash = 0;
b->meta = jx_copy(meta);
return b;
}
void ds_blob_delete( struct ds_blob *b )
{
if(!b) return;
if(b->meta) jx_delete(b->meta);
if(b->blobid) free(b->blobid);
if(b->md5hash) free(b->md5hash);
free(b);
}
struct ds_blob * ds_blob_create_from_jx( struct jx *jblob )
{
struct ds_blob *b = malloc(sizeof(*b));
memset(b,0,sizeof(*b));
b->blobid = jx_lookup_string_dup(jblob,"blobid");
b->state = jx_lookup_integer(jblob,"state");
b->size = jx_lookup_integer(jblob,"size");
b->md5hash = jx_lookup_string_dup(jblob,"md5hash");
b->meta = jx_lookup(jblob,"meta");
if(b->meta) b->meta = jx_copy(b->meta);
return b;
}
struct ds_blob * ds_blob_create_from_file( const char *filename )
{
FILE *file = fopen(filename,"r");
if(!file) return 0;
struct jx *jblob = jx_parse_stream(file);
if(!jblob) {
fclose(file);
return 0;
}
struct ds_blob *b = ds_blob_create_from_jx(jblob);
jx_delete(jblob);
fclose(file);
return b;
}
struct jx * ds_blob_to_jx( struct ds_blob *b )
{
struct jx *jblob = jx_object(0);
jx_insert_string(jblob,"blobid",b->blobid);
jx_insert_integer(jblob,"state",b->state);
jx_insert_integer(jblob,"size",b->size);
if(b->md5hash) jx_insert_string(jblob,"md5hash",b->md5hash);
if(b->meta) jx_insert(jblob,jx_string("meta"),jx_copy(b->meta));
return jblob;
}
int ds_blob_to_file( struct ds_blob *b, const char *filename )
{
struct jx *jblob = ds_blob_to_jx(b);
if(!jblob) return 0;
FILE *file = fopen(filename,"w");
if(!file) {
jx_delete(jblob);
return 0;
}
jx_print_stream(jblob,file);
jx_delete(jblob);
fclose(file);
return 1;
}
char *ds_blob_state_string( ds_blob_state_t state )
{
switch(state) {
case DS_BLOB_NEW: return "new";
case DS_BLOB_RW: return "rw";
case DS_BLOB_PUT: return "put";
case DS_BLOB_COPIED: return "copied";
case DS_BLOB_GET: return "get";
case DS_BLOB_DELETING: return "deleting";
case DS_BLOB_DELETED: return "deleted";
case DS_BLOB_ERROR: return "error";
default: return "unknown";
}
}
|