summaryrefslogtreecommitdiffabout
Unidiff
Diffstat (more/less context) (show whitespace changes)
-rw-r--r--src/eyefiservice.cc3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/eyefiservice.cc b/src/eyefiservice.cc
index 9350386..5c4e308 100644
--- a/src/eyefiservice.cc
+++ b/src/eyefiservice.cc
@@ -76,152 +76,153 @@ int eyefiService::GetPhotoStatus(
76 session_nonce.hex().c_str() ); 76 session_nonce.hex().c_str() );
77#endif 77#endif
78 78
79 std::string computed_credential = binary_t(macaddress+eyekinfig_t(macaddress).get_upload_key()+session_nonce.hex()).md5().hex(); 79 std::string computed_credential = binary_t(macaddress+eyekinfig_t(macaddress).get_upload_key()+session_nonce.hex()).md5().hex();
80 80
81#ifndef NDEBUG 81#ifndef NDEBUG
82 syslog(LOG_DEBUG, " computed credential=%s", computed_credential.c_str()); 82 syslog(LOG_DEBUG, " computed credential=%s", computed_credential.c_str());
83#endif 83#endif
84 84
85 if (credential != computed_credential) throw std::runtime_error("card authentication failed"); 85 if (credential != computed_credential) throw std::runtime_error("card authentication failed");
86 86
87 r.fileid = 1; r.offset = 0; 87 r.fileid = 1; r.offset = 0;
88 return SOAP_OK; 88 return SOAP_OK;
89} 89}
90 90
91int eyefiService::MarkLastPhotoInRoll( 91int eyefiService::MarkLastPhotoInRoll(
92 std::string macaddress, int mergedelta, 92 std::string macaddress, int mergedelta,
93 struct rns__MarkLastPhotoInRollResponse &r ) { 93 struct rns__MarkLastPhotoInRollResponse &r ) {
94#ifndef NDEBUG 94#ifndef NDEBUG
95 syslog(LOG_DEBUG, 95 syslog(LOG_DEBUG,
96 "MarkLastPhotoInRoll request from %s with mergedelta=%d", 96 "MarkLastPhotoInRoll request from %s with mergedelta=%d",
97 macaddress.c_str(), mergedelta ); 97 macaddress.c_str(), mergedelta );
98#endif 98#endif
99 std::string cmd = eyekinfig_t(macaddress).get_on_mark_last_photo_in_roll(); 99 std::string cmd = eyekinfig_t(macaddress).get_on_mark_last_photo_in_roll();
100 if(!cmd.empty()) { 100 if(!cmd.empty()) {
101 if(detached_child()) { 101 if(detached_child()) {
102 putenv( gnu::autosprintf("EYEFI_MACADDRESS=%s",macaddress.c_str()) ); 102 putenv( gnu::autosprintf("EYEFI_MACADDRESS=%s",macaddress.c_str()) );
103 putenv( gnu::autosprintf("EYEFI_MERGEDELTA=%d",mergedelta) ); 103 putenv( gnu::autosprintf("EYEFI_MERGEDELTA=%d",mergedelta) );
104 char *argv[] = { (char*)"/bin/sh", (char*)"-c", (char*)cmd.c_str(), 0 }; 104 char *argv[] = { (char*)"/bin/sh", (char*)"-c", (char*)cmd.c_str(), 0 };
105 execv("/bin/sh",argv); 105 execv("/bin/sh",argv);
106 syslog(LOG_ERR,"Failed to execute '%s'",cmd.c_str()); 106 syslog(LOG_ERR,"Failed to execute '%s'",cmd.c_str());
107 _exit(-1); 107 _exit(-1);
108 } 108 }
109 } 109 }
110 keep_alive = 0; 110 keep_alive = 0;
111 return SOAP_OK; 111 return SOAP_OK;
112} 112}
113 113
114int eyefiService::UploadPhoto( 114int eyefiService::UploadPhoto(
115 int fileid, std::string macaddress, 115 int fileid, std::string macaddress,
116 std::string filename, long filesize, std::string filesignature, 116 std::string filename, long filesize, std::string filesignature,
117 std::string encryption, int flags, 117 std::string encryption, int flags,
118 struct rns__UploadPhotoResponse& r ) { 118 struct rns__UploadPhotoResponse& r ) {
119#ifndef NDEBUG 119#ifndef NDEBUG
120 syslog(LOG_DEBUG, 120 syslog(LOG_DEBUG,
121 "UploadPhoto request from %s with fileid=%d, filename=%s, filesize=%ld," 121 "UploadPhoto request from %s with fileid=%d, filename=%s, filesize=%ld,"
122 " filesignature=%s, encryption=%s, flags=%04X", 122 " filesignature=%s, encryption=%s, flags=%04X",
123 macaddress.c_str(), fileid, filename.c_str(), filesize, 123 macaddress.c_str(), fileid, filename.c_str(), filesize,
124 filesignature.c_str(), encryption.c_str(), flags ); 124 filesignature.c_str(), encryption.c_str(), flags );
125#endif 125#endif
126 eyekinfig_t eyekinfig(macaddress); 126 eyekinfig_t eyekinfig(macaddress);
127 127
128 umask(eyekinfig.get_umask()); 128 umask(eyekinfig.get_umask());
129 129
130 std::string td = eyekinfig.get_targetdir(); 130 std::string td = eyekinfig.get_targetdir();
131 tmpdir_t indir(td+"/.incoming.XXXXXX"); 131 tmpdir_t indir(td+"/.incoming.XXXXXX");
132 132
133 std::string tf,lf; 133 std::string tf,lf;
134 binary_t digest, idigest; 134 binary_t digest, idigest;
135 135
136 for(soap_multipart::iterator i=mime.begin(),ie=mime.end();i!=ie;++i) { 136 for(soap_multipart::iterator i=mime.begin(),ie=mime.end();i!=ie;++i) {
137#ifndef NDEBUG 137#ifndef NDEBUG
138 syslog(LOG_DEBUG, 138 syslog(LOG_DEBUG,
139 " MIME attachment with id=%s, type=%s, size=%ld", 139 " MIME attachment with id=%s, type=%s, size=%ld",
140 (*i).id, (*i).type, (long)(*i).size ); 140 (*i).id, (*i).type, (long)(*i).size );
141#endif 141#endif
142 142
143 if((*i).id && !strcmp((*i).id,"INTEGRITYDIGEST")) { 143 if((*i).id && !strcmp((*i).id,"INTEGRITYDIGEST")) {
144 std::string idigestr((*i).ptr,(*i).size); 144 std::string idigestr((*i).ptr,(*i).size);
145#ifndef NDEBUG 145#ifndef NDEBUG
146 syslog(LOG_DEBUG, " INTEGRITYDIGEST=%s", idigestr.c_str()); 146 syslog(LOG_DEBUG, " INTEGRITYDIGEST=%s", idigestr.c_str());
147#endif 147#endif
148 idigest.from_hex(idigestr); 148 idigest.from_hex(idigestr);
149 } 149 }
150 if( (*i).id && !strcmp((*i).id,"FILENAME") ) { 150 if( (*i).id && !strcmp((*i).id,"FILENAME") ) {
151 assert( (*i).type && !strcmp((*i).type,"application/x-tar") ); 151 assert( (*i).type && !strcmp((*i).type,"application/x-tar") );
152#ifdef III_SAVE_TARS 152#ifdef III_SAVE_TARS
153 std::string tarfile = indir.get_file(filename); 153 std::string tarfile = indir.get_file(filename);
154 { 154 {
155 std::ofstream(tarfile.c_str(),std::ios::out|std::ios::binary).write((*i).ptr,(*i).size); 155 std::ofstream(tarfile.c_str(),std::ios::out|std::ios::binary).write((*i).ptr,(*i).size);
156 } 156 }
157#endif 157#endif
158 158
159 if(!tf.empty()) throw std::runtime_error("already seen tarball"); 159 if(!tf.empty()) throw std::runtime_error("already seen tarball");
160 if(!digest.empty()) throw std::runtime_error("already have integrity digest"); 160 if(!digest.empty()) throw std::runtime_error("already have integrity digest");
161 digest = integrity_digest((*i).ptr,(*i).size,eyekinfig.get_upload_key()); 161 digest = integrity_digest((*i).ptr,(*i).size,eyekinfig.get_upload_key());
162#ifndef NDEBUG 162#ifndef NDEBUG
163 syslog(LOG_DEBUG," computed integrity digest=%s", digest.hex().c_str()); 163 syslog(LOG_DEBUG," computed integrity digest=%s", digest.hex().c_str());
164#endif 164#endif
165 165
166 tarchive_t a((*i).ptr,(*i).size); 166 tarchive_t a((*i).ptr,(*i).size);
167 while(a.read_next_header()) { 167 while(a.read_next_header()) {
168 std::string f = indir.get_file(a.entry_pathname()); 168 std::string f = indir.get_file(a.entry_pathname());
169 std::string::size_type fl = f.length(); 169 std::string::size_type fl = f.length();
170 if(fl<4) continue; 170 if(fl<4) continue;
171 const char *s = f.c_str()+fl-4; 171 const char *s = f.c_str()+fl-4;
172 static const char *suffixes[] = { ".JPG",".AVI",".MP4",".NEF",".RAW",".TIF",".DNG",".CRW", ".RW2" }; 172 static const char *suffixes[] = { ".JPG",".AVI",".MP4",".NEF",".RAW",".TIF",".DNG",".CRW",
173 ".RW2",".CR2" };
173 if(std::find_if(suffixes,suffixes+sizeof(suffixes)/sizeof(*suffixes), 174 if(std::find_if(suffixes,suffixes+sizeof(suffixes)/sizeof(*suffixes),
174 std::not1(std::bind1st(std::ptr_fun(strcasecmp),s))) 175 std::not1(std::bind1st(std::ptr_fun(strcasecmp),s)))
175 != suffixes+sizeof(suffixes)/sizeof(*suffixes)) 176 != suffixes+sizeof(suffixes)/sizeof(*suffixes))
176 tf = f; 177 tf = f;
177 else if(!strcasecmp(s,".log")) 178 else if(!strcasecmp(s,".log"))
178 lf = f; 179 lf = f;
179 else continue; 180 else continue;
180 int fd=open(f.c_str(),O_CREAT|O_WRONLY,0666); 181 int fd=open(f.c_str(),O_CREAT|O_WRONLY,0666);
181 if(fd<0) 182 if(fd<0)
182 throw std::runtime_error(gnu::autosprintf("failed to create output file '%s'",f.c_str())); 183 throw std::runtime_error(gnu::autosprintf("failed to create output file '%s'",f.c_str()));
183 if(!a.read_data_into_fd(fd)) 184 if(!a.read_data_into_fd(fd))
184 throw std::runtime_error(gnu::autosprintf("failed to untar file into '%s'",f.c_str())); 185 throw std::runtime_error(gnu::autosprintf("failed to untar file into '%s'",f.c_str()));
185 close(fd); 186 close(fd);
186 } 187 }
187 } 188 }
188 } 189 }
189 190
190 if(tf.empty()) throw std::runtime_error("haven't seen THE file"); 191 if(tf.empty()) throw std::runtime_error("haven't seen THE file");
191 if(digest!=idigest) throw std::runtime_error("integrity digest verification failed"); 192 if(digest!=idigest) throw std::runtime_error("integrity digest verification failed");
192 193
193 std::string::size_type ls = tf.rfind('/'); 194 std::string::size_type ls = tf.rfind('/');
194 // XXX: actually, lack of '/' signifies error here 195 // XXX: actually, lack of '/' signifies error here
195 std::string tbn = (ls==std::string::npos)?tf:tf.substr(ls+1); 196 std::string tbn = (ls==std::string::npos)?tf:tf.substr(ls+1);
196 ls = lf.rfind('/'); 197 ls = lf.rfind('/');
197 std::string lbn = (ls==std::string::npos)?lf:lf.substr(ls+1); 198 std::string lbn = (ls==std::string::npos)?lf:lf.substr(ls+1);
198 std::string ttf,tlf; 199 std::string ttf,tlf;
199 bool success = false; 200 bool success = false;
200 for(int i=0;i<32767;++i) { 201 for(int i=0;i<32767;++i) {
201 const char *fmt = i ? "%1$s/(%3$05d)%2$s" : "%1$s/%2$s"; 202 const char *fmt = i ? "%1$s/(%3$05d)%2$s" : "%1$s/%2$s";
202 ttf = (const char*)gnu::autosprintf(fmt,td.c_str(),tbn.c_str(),i); 203 ttf = (const char*)gnu::autosprintf(fmt,td.c_str(),tbn.c_str(),i);
203 if(!lf.empty()) tlf = (const char*)gnu::autosprintf(fmt,td.c_str(),lbn.c_str(),i); 204 if(!lf.empty()) tlf = (const char*)gnu::autosprintf(fmt,td.c_str(),lbn.c_str(),i);
204 if( (!link(tf.c_str(),ttf.c_str())) && (lf.empty()) || !link(lf.c_str(),tlf.c_str()) ) { 205 if( (!link(tf.c_str(),ttf.c_str())) && (lf.empty()) || !link(lf.c_str(),tlf.c_str()) ) {
205 unlink(tf.c_str()); 206 unlink(tf.c_str());
206 if(!lf.empty()) unlink(lf.c_str()); 207 if(!lf.empty()) unlink(lf.c_str());
207 success=true; 208 success=true;
208 break; 209 break;
209 } 210 }
210 } 211 }
211 std::string cmd = eyekinfig.get_on_upload_photo(); 212 std::string cmd = eyekinfig.get_on_upload_photo();
212 if(success && !cmd.empty()) { 213 if(success && !cmd.empty()) {
213 if(detached_child()) { 214 if(detached_child()) {
214 putenv( gnu::autosprintf("EYEFI_UPLOADED_ORIG=%s",tbn.c_str()) ); 215 putenv( gnu::autosprintf("EYEFI_UPLOADED_ORIG=%s",tbn.c_str()) );
215 putenv( gnu::autosprintf("EYEFI_MACADDRESS=%s",macaddress.c_str()) ); 216 putenv( gnu::autosprintf("EYEFI_MACADDRESS=%s",macaddress.c_str()) );
216 putenv( gnu::autosprintf("EYEFI_UPLOADED=%s",ttf.c_str()) ); 217 putenv( gnu::autosprintf("EYEFI_UPLOADED=%s",ttf.c_str()) );
217 if(!lf.empty()) putenv( gnu::autosprintf("EYEFI_LOG=%s",tlf.c_str()) ); 218 if(!lf.empty()) putenv( gnu::autosprintf("EYEFI_LOG=%s",tlf.c_str()) );
218 char *argv[] = { (char*)"/bin/sh", (char*)"-c", (char*)cmd.c_str(), 0 }; 219 char *argv[] = { (char*)"/bin/sh", (char*)"-c", (char*)cmd.c_str(), 0 };
219 execv("/bin/sh",argv); 220 execv("/bin/sh",argv);
220 syslog(LOG_ERR,"Failed to execute '%s'",cmd.c_str()); 221 syslog(LOG_ERR,"Failed to execute '%s'",cmd.c_str());
221 _exit(-1); 222 _exit(-1);
222 } 223 }
223 } 224 }
224 225
225 r.success = true; 226 r.success = true;
226 return SOAP_OK; 227 return SOAP_OK;
227} 228}