-rw-r--r-- | src/eyefiservice.cc | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/eyefiservice.cc b/src/eyefiservice.cc index 5cbc396..fb2a90d 100644 --- a/src/eyefiservice.cc +++ b/src/eyefiservice.cc | |||
@@ -13,90 +13,92 @@ | |||
13 | 13 | ||
14 | static binary_t session_nonce; | 14 | static binary_t session_nonce; |
15 | 15 | ||
16 | static bool detached_child() { | 16 | static bool detached_child() { |
17 | pid_t p = fork(); | 17 | pid_t p = fork(); |
18 | if(p<0) throw std::runtime_error("failed to fork()"); | 18 | if(p<0) throw std::runtime_error("failed to fork()"); |
19 | if(!p) { | 19 | if(!p) { |
20 | p = fork(); | 20 | p = fork(); |
21 | if(p<0) { | 21 | if(p<0) { |
22 | syslog(LOG_ERR,"Failed to re-fork child process"); | 22 | syslog(LOG_ERR,"Failed to re-fork child process"); |
23 | _exit(-1); | 23 | _exit(-1); |
24 | } | 24 | } |
25 | if(!p) { | 25 | if(!p) { |
26 | setsid(); | 26 | setsid(); |
27 | for(int i=getdtablesize();i>=0;--i) close(i); | 27 | for(int i=getdtablesize();i>=0;--i) close(i); |
28 | int i=open("/dev/null",O_RDWR); assert(i==0); | 28 | int i=open("/dev/null",O_RDWR); assert(i==0); |
29 | i = dup(i); assert(i==1); | 29 | i = dup(i); assert(i==1); |
30 | i = dup(i); assert(i==2); | 30 | i = dup(i); assert(i==2); |
31 | return true; | 31 | return true; |
32 | } | 32 | } |
33 | _exit(0); | 33 | _exit(0); |
34 | } | 34 | } |
35 | int rc; | 35 | int rc; |
36 | if(waitpid(p,&rc,0)<0) throw std::runtime_error("failed to waitpid()"); | 36 | if(waitpid(p,&rc,0)<0) throw std::runtime_error("failed to waitpid()"); |
37 | if(!WIFEXITED(rc)) throw std::runtime_error("error in forked process"); | 37 | if(!WIFEXITED(rc)) throw std::runtime_error("error in forked process"); |
38 | if(WEXITSTATUS(rc)) throw std::runtime_error("forked process signalled error"); | 38 | if(WEXITSTATUS(rc)) throw std::runtime_error("forked process signalled error"); |
39 | return false; | 39 | return false; |
40 | } | 40 | } |
41 | 41 | ||
42 | int eyefiService::StartSession( | 42 | int eyefiService::StartSession( |
43 | std::string macaddress,std::string cnonce, | 43 | std::string macaddress,std::string cnonce, |
44 | int transfermode,long transfermodetimestamp, | 44 | int transfermode,long transfermodetimestamp, |
45 | struct rns__StartSessionResponse &r ) { | 45 | struct rns__StartSessionResponse &r ) try { |
46 | #ifndef NDEBUG | 46 | #ifndef NDEBUG |
47 | syslog(LOG_DEBUG, | 47 | syslog(LOG_DEBUG, |
48 | "StartSession request from %s with cnonce=%s, transfermode=%d, transfermodetimestamp=%ld", | 48 | "StartSession request from %s with cnonce=%s, transfermode=%d, transfermodetimestamp=%ld", |
49 | macaddress.c_str(), cnonce.c_str(), transfermode, transfermodetimestamp ); | 49 | macaddress.c_str(), cnonce.c_str(), transfermode, transfermodetimestamp ); |
50 | #endif | 50 | #endif |
51 | r.credential = binary_t(macaddress+cnonce+eyekinfig_t(macaddress).get_upload_key()).md5().hex(); | 51 | r.credential = binary_t(macaddress+cnonce+eyekinfig_t(macaddress).get_upload_key()).md5().hex(); |
52 | 52 | ||
53 | r.snonce = session_nonce.make_nonce().hex(); | 53 | r.snonce = session_nonce.make_nonce().hex(); |
54 | r.transfermode=transfermode; | 54 | r.transfermode=transfermode; |
55 | r.transfermodetimestamp=transfermodetimestamp; | 55 | r.transfermodetimestamp=transfermodetimestamp; |
56 | r.upsyncallowed=false; | 56 | r.upsyncallowed=false; |
57 | 57 | ||
58 | std::string cmd = eyekinfig_t(macaddress).get_on_start_session(); | 58 | std::string cmd = eyekinfig_t(macaddress).get_on_start_session(); |
59 | if(!cmd.empty()) { | 59 | if(!cmd.empty()) { |
60 | if(detached_child()) { | 60 | if(detached_child()) { |
61 | putenv( gnu::autosprintf("EYEFI_MACADDRESS=%s",macaddress.c_str()) ); | 61 | putenv( gnu::autosprintf("EYEFI_MACADDRESS=%s",macaddress.c_str()) ); |
62 | putenv( gnu::autosprintf("EYEFI_TRANSFERMODE=%d",transfermode) ); | 62 | putenv( gnu::autosprintf("EYEFI_TRANSFERMODE=%d",transfermode) ); |
63 | putenv( gnu::autosprintf("EYEFI_TRANSFERMODETIMESTAMP=%ld",transfermodetimestamp) ); | 63 | putenv( gnu::autosprintf("EYEFI_TRANSFERMODETIMESTAMP=%ld",transfermodetimestamp) ); |
64 | char *argv[] = { (char*)"/bin/sh", (char*)"-c", (char*)cmd.c_str(), 0 }; | 64 | char *argv[] = { (char*)"/bin/sh", (char*)"-c", (char*)cmd.c_str(), 0 }; |
65 | execv("/bin/sh",argv); | 65 | execv("/bin/sh",argv); |
66 | syslog(LOG_ERR,"Failed to execute '%s'",cmd.c_str()); | 66 | syslog(LOG_ERR,"Failed to execute '%s'",cmd.c_str()); |
67 | _exit(-1); | 67 | _exit(-1); |
68 | } | 68 | } |
69 | } | 69 | } |
70 | return SOAP_OK; | 70 | return SOAP_OK; |
71 | }catch(std::runtime_error& e) { | ||
72 | syslog(LOG_ERR,"error while processing StartSession: %s",e.what()); | ||
71 | } | 73 | } |
72 | 74 | ||
73 | int eyefiService::GetPhotoStatus( | 75 | int eyefiService::GetPhotoStatus( |
74 | std::string credential, std::string macaddress, | 76 | std::string credential, std::string macaddress, |
75 | std::string filename, long filesize, std::string filesignature, | 77 | std::string filename, long filesize, std::string filesignature, |
76 | int flags, | 78 | int flags, |
77 | struct rns__GetPhotoStatusResponse &r ) { | 79 | struct rns__GetPhotoStatusResponse &r ) { |
78 | #ifndef NDEBUG | 80 | #ifndef NDEBUG |
79 | syslog(LOG_DEBUG, | 81 | syslog(LOG_DEBUG, |
80 | "GetPhotoStatus request from %s with credential=%s, filename=%s, filesize=%ld, filesignature=%s, flags=%d; session nonce=%s", | 82 | "GetPhotoStatus request from %s with credential=%s, filename=%s, filesize=%ld, filesignature=%s, flags=%d; session nonce=%s", |
81 | macaddress.c_str(), credential.c_str(), filename.c_str(), filesize, filesignature.c_str(), flags, | 83 | macaddress.c_str(), credential.c_str(), filename.c_str(), filesize, filesignature.c_str(), flags, |
82 | session_nonce.hex().c_str() ); | 84 | session_nonce.hex().c_str() ); |
83 | #endif | 85 | #endif |
84 | 86 | ||
85 | std::string computed_credential = binary_t(macaddress+eyekinfig_t(macaddress).get_upload_key()+session_nonce.hex()).md5().hex(); | 87 | std::string computed_credential = binary_t(macaddress+eyekinfig_t(macaddress).get_upload_key()+session_nonce.hex()).md5().hex(); |
86 | 88 | ||
87 | #ifndef NDEBUG | 89 | #ifndef NDEBUG |
88 | syslog(LOG_DEBUG, " computed credential=%s", computed_credential.c_str()); | 90 | syslog(LOG_DEBUG, " computed credential=%s", computed_credential.c_str()); |
89 | #endif | 91 | #endif |
90 | 92 | ||
91 | if (credential != computed_credential) throw std::runtime_error("card authentication failed"); | 93 | if (credential != computed_credential) throw std::runtime_error("card authentication failed"); |
92 | 94 | ||
93 | r.fileid = 1; r.offset = 0; | 95 | r.fileid = 1; r.offset = 0; |
94 | return SOAP_OK; | 96 | return SOAP_OK; |
95 | } | 97 | } |
96 | 98 | ||
97 | int eyefiService::MarkLastPhotoInRoll( | 99 | int eyefiService::MarkLastPhotoInRoll( |
98 | std::string macaddress, int mergedelta, | 100 | std::string macaddress, int mergedelta, |
99 | struct rns__MarkLastPhotoInRollResponse &r ) { | 101 | struct rns__MarkLastPhotoInRollResponse &r ) { |
100 | #ifndef NDEBUG | 102 | #ifndef NDEBUG |
101 | syslog(LOG_DEBUG, | 103 | syslog(LOG_DEBUG, |
102 | "MarkLastPhotoInRoll request from %s with mergedelta=%d", | 104 | "MarkLastPhotoInRoll request from %s with mergedelta=%d", |