summaryrefslogtreecommitdiffabout
path: root/src/eyefiservice.cc
authorMichael Krelin <hacker@klever.net>2012-01-21 13:49:46 (UTC)
committer Michael Krelin <hacker@klever.net>2012-01-21 13:57:59 (UTC)
commitf62b5898696f988a9c01f0de2d2a3d45c648beea (patch) (unidiff)
treeeb1ee7fb0e71271f4fb561f32cc86ac4a7c8b6bc /src/eyefiservice.cc
parent225ebc36b2eadcf04c7e41ff037b62fd16144cc7 (diff)
downloadiii-f62b5898696f988a9c01f0de2d2a3d45c648beea.zip
iii-f62b5898696f988a9c01f0de2d2a3d45c648beea.tar.gz
iii-f62b5898696f988a9c01f0de2d2a3d45c648beea.tar.bz2
older gsoap compatibility
Signed-off-by: Michael Krelin <hacker@klever.net>
Diffstat (limited to 'src/eyefiservice.cc') (more/less context) (ignore whitespace changes)
-rw-r--r--src/eyefiservice.cc2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/eyefiservice.cc b/src/eyefiservice.cc
index d9318ed..f8d5f31 100644
--- a/src/eyefiservice.cc
+++ b/src/eyefiservice.cc
@@ -1,229 +1,229 @@
1#include <cassert> 1#include <cassert>
2#include <iostream> 2#include <iostream>
3#include <fstream> 3#include <fstream>
4#include <stdexcept> 4#include <stdexcept>
5#include <iterator> 5#include <iterator>
6#include <algorithm> 6#include <algorithm>
7#include <syslog.h> 7#include <syslog.h>
8#include <sys/wait.h> 8#include <sys/wait.h>
9#include <autosprintf.h> 9#include <autosprintf.h>
10#include "eyekinfig.h" 10#include "eyekinfig.h"
11#include "eyetil.h" 11#include "eyetil.h"
12#include "soapeyefiService.h" 12#include "soapeyefiService.h"
13 13
14static binary_t session_nonce; 14static binary_t session_nonce;
15 15
16static bool detached_child() { 16static bool detached_child() {
17 pid_t p = fork(); 17 pid_t p = fork();
18 if(p<0) { 18 if(p<0) {
19 syslog(LOG_ERR,"Failed to fork away for hook execution"); 19 syslog(LOG_ERR,"Failed to fork away for hook execution");
20 _exit(-1); 20 _exit(-1);
21 } 21 }
22 if(!p) { 22 if(!p) {
23 setsid(); 23 setsid();
24 for(int i=getdtablesize();i>=0;--i) close(i); 24 for(int i=getdtablesize();i>=0;--i) close(i);
25 int i=open("/dev/null",O_RDWR); assert(i==0); 25 int i=open("/dev/null",O_RDWR); assert(i==0);
26 i = dup(i); assert(i==1); 26 i = dup(i); assert(i==1);
27 i = dup(i); assert(i==2); 27 i = dup(i); assert(i==2);
28 return true; 28 return true;
29 } 29 }
30 return false; 30 return false;
31} 31}
32 32
33static int E(eyefiService* efs,const char *c,const std::exception& e) { 33static int E(eyefiService* efs,const char *c,const std::exception& e) {
34 efs->keep_alive=0; 34 efs->keep_alive=0;
35 syslog(LOG_ERR,"error while processing %s: %s",c,e.what()); 35 syslog(LOG_ERR,"error while processing %s: %s",c,e.what());
36 return efs->soap_receiverfault(gnu::autosprintf("error processing %s",c),0); 36 return soap_sender_fault(efs,gnu::autosprintf("error processing %s",c),0);
37} 37}
38 38
39int eyefiService::StartSession( 39int eyefiService::StartSession(
40 std::string macaddress,std::string cnonce, 40 std::string macaddress,std::string cnonce,
41 int transfermode,long transfermodetimestamp, 41 int transfermode,long transfermodetimestamp,
42 struct rns__StartSessionResponse &r ) try { 42 struct rns__StartSessionResponse &r ) try {
43#ifndef NDEBUG 43#ifndef NDEBUG
44 syslog(LOG_DEBUG, 44 syslog(LOG_DEBUG,
45 "StartSession request from %s with cnonce=%s, transfermode=%d, transfermodetimestamp=%ld", 45 "StartSession request from %s with cnonce=%s, transfermode=%d, transfermodetimestamp=%ld",
46 macaddress.c_str(), cnonce.c_str(), transfermode, transfermodetimestamp ); 46 macaddress.c_str(), cnonce.c_str(), transfermode, transfermodetimestamp );
47#endif 47#endif
48 eyekinfig_t eyekinfig(macaddress); 48 eyekinfig_t eyekinfig(macaddress);
49 r.credential = binary_t(macaddress+cnonce+eyekinfig.get_upload_key()).md5().hex(); 49 r.credential = binary_t(macaddress+cnonce+eyekinfig.get_upload_key()).md5().hex();
50 50
51 r.snonce = session_nonce.make_nonce().hex(); 51 r.snonce = session_nonce.make_nonce().hex();
52 r.transfermode=transfermode; 52 r.transfermode=transfermode;
53 r.transfermodetimestamp=transfermodetimestamp; 53 r.transfermodetimestamp=transfermodetimestamp;
54 r.upsyncallowed=false; 54 r.upsyncallowed=false;
55 55
56 std::string cmd = eyekinfig.get_on_start_session(); 56 std::string cmd = eyekinfig.get_on_start_session();
57 if(!cmd.empty()) { 57 if(!cmd.empty()) {
58 if(detached_child()) { 58 if(detached_child()) {
59 putenv( gnu::autosprintf("EYEFI_MACADDRESS=%s",macaddress.c_str()) ); 59 putenv( gnu::autosprintf("EYEFI_MACADDRESS=%s",macaddress.c_str()) );
60 putenv( gnu::autosprintf("EYEFI_TRANSFERMODE=%d",transfermode) ); 60 putenv( gnu::autosprintf("EYEFI_TRANSFERMODE=%d",transfermode) );
61 putenv( gnu::autosprintf("EYEFI_TRANSFERMODETIMESTAMP=%ld",transfermodetimestamp) ); 61 putenv( gnu::autosprintf("EYEFI_TRANSFERMODETIMESTAMP=%ld",transfermodetimestamp) );
62 char *argv[] = { (char*)"/bin/sh", (char*)"-c", (char*)cmd.c_str(), 0 }; 62 char *argv[] = { (char*)"/bin/sh", (char*)"-c", (char*)cmd.c_str(), 0 };
63 execv("/bin/sh",argv); 63 execv("/bin/sh",argv);
64 syslog(LOG_ERR,"Failed to execute '%s'",cmd.c_str()); 64 syslog(LOG_ERR,"Failed to execute '%s'",cmd.c_str());
65 _exit(-1); 65 _exit(-1);
66 } 66 }
67 } 67 }
68 return SOAP_OK; 68 return SOAP_OK;
69}catch(const std::exception& e) { return E(this,"StartSession",e); } 69}catch(const std::exception& e) { return E(this,"StartSession",e); }
70 70
71int eyefiService::GetPhotoStatus( 71int eyefiService::GetPhotoStatus(
72 std::string credential, std::string macaddress, 72 std::string credential, std::string macaddress,
73 std::string filename, long filesize, std::string filesignature, 73 std::string filename, long filesize, std::string filesignature,
74 int flags, 74 int flags,
75 struct rns__GetPhotoStatusResponse &r ) try { 75 struct rns__GetPhotoStatusResponse &r ) try {
76#ifndef NDEBUG 76#ifndef NDEBUG
77 syslog(LOG_DEBUG, 77 syslog(LOG_DEBUG,
78 "GetPhotoStatus request from %s with credential=%s, filename=%s, filesize=%ld, filesignature=%s, flags=%d; session nonce=%s", 78 "GetPhotoStatus request from %s with credential=%s, filename=%s, filesize=%ld, filesignature=%s, flags=%d; session nonce=%s",
79 macaddress.c_str(), credential.c_str(), filename.c_str(), filesize, filesignature.c_str(), flags, 79 macaddress.c_str(), credential.c_str(), filename.c_str(), filesize, filesignature.c_str(), flags,
80 session_nonce.hex().c_str() ); 80 session_nonce.hex().c_str() );
81#endif 81#endif
82 82
83 std::string computed_credential = binary_t(macaddress+eyekinfig_t(macaddress).get_upload_key()+session_nonce.hex()).md5().hex(); 83 std::string computed_credential = binary_t(macaddress+eyekinfig_t(macaddress).get_upload_key()+session_nonce.hex()).md5().hex();
84 84
85#ifndef NDEBUG 85#ifndef NDEBUG
86 syslog(LOG_DEBUG, " computed credential=%s", computed_credential.c_str()); 86 syslog(LOG_DEBUG, " computed credential=%s", computed_credential.c_str());
87#endif 87#endif
88 88
89 if (credential != computed_credential) throw std::runtime_error("card authentication failed"); 89 if (credential != computed_credential) throw std::runtime_error("card authentication failed");
90 90
91 r.fileid = 1; r.offset = 0; 91 r.fileid = 1; r.offset = 0;
92 return SOAP_OK; 92 return SOAP_OK;
93}catch(const std::exception& e) { return E(this,"GetPhotoStatus",e); } 93}catch(const std::exception& e) { return E(this,"GetPhotoStatus",e); }
94 94
95int eyefiService::MarkLastPhotoInRoll( 95int eyefiService::MarkLastPhotoInRoll(
96 std::string macaddress, int mergedelta, 96 std::string macaddress, int mergedelta,
97 struct rns__MarkLastPhotoInRollResponse&/* r */ ) try { 97 struct rns__MarkLastPhotoInRollResponse&/* r */ ) try {
98#ifndef NDEBUG 98#ifndef NDEBUG
99 syslog(LOG_DEBUG, 99 syslog(LOG_DEBUG,
100 "MarkLastPhotoInRoll request from %s with mergedelta=%d", 100 "MarkLastPhotoInRoll request from %s with mergedelta=%d",
101 macaddress.c_str(), mergedelta ); 101 macaddress.c_str(), mergedelta );
102#endif 102#endif
103 std::string cmd = eyekinfig_t(macaddress).get_on_mark_last_photo_in_roll(); 103 std::string cmd = eyekinfig_t(macaddress).get_on_mark_last_photo_in_roll();
104 if(!cmd.empty()) { 104 if(!cmd.empty()) {
105 if(detached_child()) { 105 if(detached_child()) {
106 putenv( gnu::autosprintf("EYEFI_MACADDRESS=%s",macaddress.c_str()) ); 106 putenv( gnu::autosprintf("EYEFI_MACADDRESS=%s",macaddress.c_str()) );
107 putenv( gnu::autosprintf("EYEFI_MERGEDELTA=%d",mergedelta) ); 107 putenv( gnu::autosprintf("EYEFI_MERGEDELTA=%d",mergedelta) );
108 char *argv[] = { (char*)"/bin/sh", (char*)"-c", (char*)cmd.c_str(), 0 }; 108 char *argv[] = { (char*)"/bin/sh", (char*)"-c", (char*)cmd.c_str(), 0 };
109 execv("/bin/sh",argv); 109 execv("/bin/sh",argv);
110 syslog(LOG_ERR,"Failed to execute '%s'",cmd.c_str()); 110 syslog(LOG_ERR,"Failed to execute '%s'",cmd.c_str());
111 _exit(-1); 111 _exit(-1);
112 } 112 }
113 } 113 }
114 keep_alive = 0; 114 keep_alive = 0;
115 return SOAP_OK; 115 return SOAP_OK;
116}catch(const std::exception& e) { return E(this,"MarkLastPhotoInRoll",e); } 116}catch(const std::exception& e) { return E(this,"MarkLastPhotoInRoll",e); }
117 117
118int eyefiService::UploadPhoto( 118int eyefiService::UploadPhoto(
119 int fileid, std::string macaddress, 119 int fileid, std::string macaddress,
120 std::string filename, long filesize, std::string filesignature, 120 std::string filename, long filesize, std::string filesignature,
121 std::string encryption, int flags, 121 std::string encryption, int flags,
122 struct rns__UploadPhotoResponse& r ) try { 122 struct rns__UploadPhotoResponse& r ) try {
123#ifndef NDEBUG 123#ifndef NDEBUG
124 syslog(LOG_DEBUG, 124 syslog(LOG_DEBUG,
125 "UploadPhoto request from %s with fileid=%d, filename=%s, filesize=%ld," 125 "UploadPhoto request from %s with fileid=%d, filename=%s, filesize=%ld,"
126 " filesignature=%s, encryption=%s, flags=%04X", 126 " filesignature=%s, encryption=%s, flags=%04X",
127 macaddress.c_str(), fileid, filename.c_str(), filesize, 127 macaddress.c_str(), fileid, filename.c_str(), filesize,
128 filesignature.c_str(), encryption.c_str(), flags ); 128 filesignature.c_str(), encryption.c_str(), flags );
129#endif 129#endif
130 std::string::size_type fnl=filename.length(); 130 std::string::size_type fnl=filename.length();
131 if(fnl<sizeof(".tar") || strncmp(filename.c_str()+fnl-sizeof(".tar")+sizeof(""),".tar",sizeof(".tar"))) 131 if(fnl<sizeof(".tar") || strncmp(filename.c_str()+fnl-sizeof(".tar")+sizeof(""),".tar",sizeof(".tar")))
132 throw std::runtime_error(gnu::autosprintf("honestly, I expected the tarball coming here, not '%s'",filename.c_str())); 132 throw std::runtime_error(gnu::autosprintf("honestly, I expected the tarball coming here, not '%s'",filename.c_str()));
133 std::string the_file(filename,0,fnl-sizeof(".tar")+sizeof("")); 133 std::string the_file(filename,0,fnl-sizeof(".tar")+sizeof(""));
134 std::string the_log = the_file+".log"; 134 std::string the_log = the_file+".log";
135 135
136 eyekinfig_t eyekinfig(macaddress); 136 eyekinfig_t eyekinfig(macaddress);
137 137
138 umask(eyekinfig.get_umask()); 138 umask(eyekinfig.get_umask());
139 139
140 std::string td = eyekinfig.get_targetdir(); 140 std::string td = eyekinfig.get_targetdir();
141 tmpdir_t indir(td+"/.incoming.XXXXXX"); 141 tmpdir_t indir(td+"/.incoming.XXXXXX");
142 142
143 std::string tf,lf; 143 std::string tf,lf;
144 binary_t digest, idigest; 144 binary_t digest, idigest;
145 145
146 for(soap_multipart::iterator i=mime.begin(),ie=mime.end();i!=ie;++i) { 146 for(soap_multipart::iterator i=mime.begin(),ie=mime.end();i!=ie;++i) {
147#ifndef NDEBUG 147#ifndef NDEBUG
148 syslog(LOG_DEBUG, 148 syslog(LOG_DEBUG,
149 " MIME attachment with id=%s, type=%s, size=%ld", 149 " MIME attachment with id=%s, type=%s, size=%ld",
150 (*i).id, (*i).type, (long)(*i).size ); 150 (*i).id, (*i).type, (long)(*i).size );
151#endif 151#endif
152 152
153 if((*i).id && !strcmp((*i).id,"INTEGRITYDIGEST")) { 153 if((*i).id && !strcmp((*i).id,"INTEGRITYDIGEST")) {
154 std::string idigestr((*i).ptr,(*i).size); 154 std::string idigestr((*i).ptr,(*i).size);
155#ifndef NDEBUG 155#ifndef NDEBUG
156 syslog(LOG_DEBUG, " INTEGRITYDIGEST=%s", idigestr.c_str()); 156 syslog(LOG_DEBUG, " INTEGRITYDIGEST=%s", idigestr.c_str());
157#endif 157#endif
158 idigest.from_hex(idigestr); 158 idigest.from_hex(idigestr);
159 } 159 }
160 if( (*i).id && !strcmp((*i).id,"FILENAME") ) { 160 if( (*i).id && !strcmp((*i).id,"FILENAME") ) {
161 assert( (*i).type && !strcmp((*i).type,"application/x-tar") ); 161 assert( (*i).type && !strcmp((*i).type,"application/x-tar") );
162#ifdef III_SAVE_TARS 162#ifdef III_SAVE_TARS
163 std::string tarfile = indir.get_file(filename); 163 std::string tarfile = indir.get_file(filename);
164 { 164 {
165 std::ofstream(tarfile.c_str(),std::ios::out|std::ios::binary).write((*i).ptr,(*i).size); 165 std::ofstream(tarfile.c_str(),std::ios::out|std::ios::binary).write((*i).ptr,(*i).size);
166 } 166 }
167#endif 167#endif
168 168
169 if(!tf.empty()) throw std::runtime_error("already seen tarball"); 169 if(!tf.empty()) throw std::runtime_error("already seen tarball");
170 if(!digest.empty()) throw std::runtime_error("already have integrity digest"); 170 if(!digest.empty()) throw std::runtime_error("already have integrity digest");
171 digest = integrity_digest((*i).ptr,(*i).size,eyekinfig.get_upload_key()); 171 digest = integrity_digest((*i).ptr,(*i).size,eyekinfig.get_upload_key());
172#ifndef NDEBUG 172#ifndef NDEBUG
173 syslog(LOG_DEBUG," computed integrity digest=%s", digest.hex().c_str()); 173 syslog(LOG_DEBUG," computed integrity digest=%s", digest.hex().c_str());
174#endif 174#endif
175 175
176 tarchive_t a((*i).ptr,(*i).size); 176 tarchive_t a((*i).ptr,(*i).size);
177 while(a.read_next_header()) { 177 while(a.read_next_header()) {
178 std::string ep = a.entry_pathname(), f = indir.get_file(ep); 178 std::string ep = a.entry_pathname(), f = indir.get_file(ep);
179 if(ep==the_file) tf = f; 179 if(ep==the_file) tf = f;
180 else if(ep==the_log) lf = f; 180 else if(ep==the_log) lf = f;
181 else continue; 181 else continue;
182 int fd=open(f.c_str(),O_CREAT|O_WRONLY,0666); 182 int fd=open(f.c_str(),O_CREAT|O_WRONLY,0666);
183 if(fd<0) 183 if(fd<0)
184 throw std::runtime_error(gnu::autosprintf("failed to create output file '%s'",f.c_str())); 184 throw std::runtime_error(gnu::autosprintf("failed to create output file '%s'",f.c_str()));
185 if(!a.read_data_into_fd(fd)) 185 if(!a.read_data_into_fd(fd))
186 throw std::runtime_error(gnu::autosprintf("failed to untar file into '%s'",f.c_str())); 186 throw std::runtime_error(gnu::autosprintf("failed to untar file into '%s'",f.c_str()));
187 close(fd); 187 close(fd);
188 } 188 }
189 } 189 }
190 } 190 }
191 191
192 if(tf.empty()) throw std::runtime_error("haven't seen THE file"); 192 if(tf.empty()) throw std::runtime_error("haven't seen THE file");
193 if(digest!=idigest) throw std::runtime_error("integrity digest verification failed"); 193 if(digest!=idigest) throw std::runtime_error("integrity digest verification failed");
194 194
195 std::string::size_type ls = tf.rfind('/'); 195 std::string::size_type ls = tf.rfind('/');
196 // XXX: actually, lack of '/' signifies error here 196 // XXX: actually, lack of '/' signifies error here
197 std::string tbn = (ls==std::string::npos)?tf:tf.substr(ls+1); 197 std::string tbn = (ls==std::string::npos)?tf:tf.substr(ls+1);
198 ls = lf.rfind('/'); 198 ls = lf.rfind('/');
199 std::string lbn = (ls==std::string::npos)?lf:lf.substr(ls+1); 199 std::string lbn = (ls==std::string::npos)?lf:lf.substr(ls+1);
200 std::string ttf,tlf; 200 std::string ttf,tlf;
201 bool success = false; 201 bool success = false;
202 for(int i=0;i<32767;++i) { 202 for(int i=0;i<32767;++i) {
203 const char *fmt = i ? "%1$s/(%3$05d)%2$s" : "%1$s/%2$s"; 203 const char *fmt = i ? "%1$s/(%3$05d)%2$s" : "%1$s/%2$s";
204 ttf = (const char*)gnu::autosprintf(fmt,td.c_str(),tbn.c_str(),i); 204 ttf = (const char*)gnu::autosprintf(fmt,td.c_str(),tbn.c_str(),i);
205 if(!lf.empty()) tlf = (const char*)gnu::autosprintf(fmt,td.c_str(),lbn.c_str(),i); 205 if(!lf.empty()) tlf = (const char*)gnu::autosprintf(fmt,td.c_str(),lbn.c_str(),i);
206 if( (!link(tf.c_str(),ttf.c_str())) && (lf.empty() || !link(lf.c_str(),tlf.c_str())) ) { 206 if( (!link(tf.c_str(),ttf.c_str())) && (lf.empty() || !link(lf.c_str(),tlf.c_str())) ) {
207 unlink(tf.c_str()); 207 unlink(tf.c_str());
208 if(!lf.empty()) unlink(lf.c_str()); 208 if(!lf.empty()) unlink(lf.c_str());
209 success=true; 209 success=true;
210 break; 210 break;
211 } 211 }
212 } 212 }
213 std::string cmd = eyekinfig.get_on_upload_photo(); 213 std::string cmd = eyekinfig.get_on_upload_photo();
214 if(success && !cmd.empty()) { 214 if(success && !cmd.empty()) {
215 if(detached_child()) { 215 if(detached_child()) {
216 putenv( gnu::autosprintf("EYEFI_UPLOADED_ORIG=%s",tbn.c_str()) ); 216 putenv( gnu::autosprintf("EYEFI_UPLOADED_ORIG=%s",tbn.c_str()) );
217 putenv( gnu::autosprintf("EYEFI_MACADDRESS=%s",macaddress.c_str()) ); 217 putenv( gnu::autosprintf("EYEFI_MACADDRESS=%s",macaddress.c_str()) );
218 putenv( gnu::autosprintf("EYEFI_UPLOADED=%s",ttf.c_str()) ); 218 putenv( gnu::autosprintf("EYEFI_UPLOADED=%s",ttf.c_str()) );
219 if(!lf.empty()) putenv( gnu::autosprintf("EYEFI_LOG=%s",tlf.c_str()) ); 219 if(!lf.empty()) putenv( gnu::autosprintf("EYEFI_LOG=%s",tlf.c_str()) );
220 char *argv[] = { (char*)"/bin/sh", (char*)"-c", (char*)cmd.c_str(), 0 }; 220 char *argv[] = { (char*)"/bin/sh", (char*)"-c", (char*)cmd.c_str(), 0 };
221 execv("/bin/sh",argv); 221 execv("/bin/sh",argv);
222 syslog(LOG_ERR,"Failed to execute '%s'",cmd.c_str()); 222 syslog(LOG_ERR,"Failed to execute '%s'",cmd.c_str());
223 _exit(-1); 223 _exit(-1);
224 } 224 }
225 } 225 }
226 226
227 r.success = true; 227 r.success = true;
228 return SOAP_OK; 228 return SOAP_OK;
229}catch(const std::exception& e) { return E(this,"UploadPhoto",e); } 229}catch(const std::exception& e) { return E(this,"UploadPhoto",e); }