开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > P2P编程 > 查看源码
servhs.cpp
资源名称：P2PSource-PeerCast.rar　[点击查看]
上传用户：chn_coc
上传日期：2007-12-20
资源大小：563k
文件大小：38k
源码类别：

P2P编程

开发平台：

Windows_Unix

servhs.cpp：源码内容
  1. // ------------------------------------------------ // File : servhs.cpp // Date: 4-apr-2002 // Author: giles // Desc:  // Servent handshaking, TODO: should be in its own class // // (c) 2002 peercast.org // ------------------------------------------------ // 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. // ------------------------------------------------ #include <stdlib.h> #include "servent.h" #include "servmgr.h" #include "html.h" #include "stats.h" #include "peercast.h" #include "pcp.h"
  2. #include "version2.h"
  3. // ----------------------------------- static void termArgs(char *str) { if (str) { int slen = strlen(str); for(int i=0; i<slen; i++) if (str[i]=='&') str[i] = 0; } } // ----------------------------------- char *nextCGIarg(char *cp, char *cmd, char *arg) { if (!*cp) return NULL; // fetch command while (*cp) { char c = *cp++; if (c == '=') break; else *cmd++ = c; } *cmd = 0; // fetch arg while (*cp) { char c = *cp++; if (c == '&') break; else *arg++ = c; } *arg = 0; return cp; } // ----------------------------------- bool getCGIargBOOL(char *a) { return (strcmp(a,"1")==0); } // ----------------------------------- int getCGIargINT(char *a) { return atoi(a); } // ----------------------------------- void Servent::handshakeHTTP(HTTP &http, bool isHTTP) { char *in = http.cmdLine; if (http.isRequest("GET /")) { char *fn = in+4; char *pt = strstr(fn,HTTP_PROTO1); if (pt) pt[-1] = 0; if (strncmp(fn,"/admin?",7)==0) { if (!isAllowed(ALLOW_HTML)) throw HTTPException(HTTP_SC_UNAVAILABLE,503);
  4. LOG_DEBUG("Admin client"); handshakeCMD(fn+7);
  6. }else if (strncmp(fn,"/http/",6)==0)
  7. {
  8. String dirName = fn+6;
  10. if (!isAllowed(ALLOW_HTML))
  11. throw HTTPException(HTTP_SC_UNAVAILABLE,503);
  13. if (!handshakeAuth(http,fn,false))
  14. throw HTTPException(HTTP_SC_UNAUTHORIZED,401);
  17. handshakeRemoteFile(dirName);
  20. }else if (strncmp(fn,"/html/",6)==0)
  21. {
  22. String dirName = fn+1;
  24. if (!isAllowed(ALLOW_HTML))
  25. throw HTTPException(HTTP_SC_UNAVAILABLE,503);
  27. if (handshakeAuth(http,fn,true))
  28. handshakeLocalFile(dirName);
  30. }else if (strncmp(fn,"/admin/?",8)==0) { if (!isAllowed(ALLOW_HTML)) throw HTTPException(HTTP_SC_UNAVAILABLE,503);
  31. LOG_DEBUG("Admin client"); handshakeCMD(fn+8); }else if (strncmp(fn,"/admin.cgi",10)==0) { if (!isAllowed(ALLOW_BROADCAST)) throw HTTPException(HTTP_SC_UNAVAILABLE,503);
  32. char *pwdArg = getCGIarg(fn,"pass="); char *songArg = getCGIarg(fn,"song="); char *mountArg = getCGIarg(fn,"mount="); char *urlArg = getCGIarg(fn,"url="); if (pwdArg && songArg) { int i; int slen = strlen(fn); for(i=0; i<slen; i++) if (fn[i]=='&') fn[i] = 0; Channel *c=chanMgr->channel; while (c) { if ((c->status == Channel::S_BROADCASTING) &&    (c->info.contentType == ChanInfo::T_MP3) ) { // if we have a mount point then check for it, otherwise update all channels. if (mountArg)
  33. { if (strcmp(c->mount,mountArg)==0)
  34. { ChanInfo newInfo = c->info; newInfo.track.title.set(songArg,String::T_ESC);
  35. newInfo.track.title.convertTo(String::T_UNICODE); if (urlArg) if (urlArg[0]) newInfo.track.contact.set(urlArg,String::T_ESC); LOG_CHANNEL("Channel Shoutcast update: %s",songArg); c->updateInfo(newInfo);
  36. } } }
  37. c=c->next; } } }else if (strncmp(fn,"/pls/",5)==0) {
  39. if (!sock->host.isLocalhost())
  40. if (!isAllowed(ALLOW_DIRECT) || !isFiltered(ServFilter::F_DIRECT))
  41. throw HTTPException(HTTP_SC_UNAVAILABLE,503);
  44. ChanInfo info;
  45. if (servMgr->getChannel(fn+5,info,isPrivate())) handshakePLS(info,false);
  46. else
  47. throw HTTPException(HTTP_SC_NOTFOUND,404);
  48. }else if (strncmp(fn,"/stream/",8)==0) {
  49. if (!sock->host.isLocalhost())
  50. if (!isAllowed(ALLOW_DIRECT) || !isFiltered(ServFilter::F_DIRECT))
  51. throw HTTPException(HTTP_SC_UNAVAILABLE,503);
  52. triggerChannel(fn+8,ChanInfo::SP_HTTP,isPrivate());
  53. }else if (strncmp(fn,"/channel/",9)==0) {
  54. if (!sock->host.isLocalhost())
  55. if (!isAllowed(ALLOW_NETWORK) || !isFiltered(ServFilter::F_NETWORK))
  56. throw HTTPException(HTTP_SC_UNAVAILABLE,503);
  57. triggerChannel(fn+9,ChanInfo::SP_PCP,false);
  58. }else 
  59. {
  60. while (http.nextHeader());
  61. http.writeLine(HTTP_SC_FOUND);
  62. http.writeLineF("Location: /%s/index.html",servMgr->htmlPath);
  63. http.writeLine("");
  64. } }else if (http.isRequest("GIV")) {
  65. HTTP http(*sock);
  67. while (http.nextHeader()) ;
  69. if (!isAllowed(ALLOW_NETWORK))
  70. throw HTTPException(HTTP_SC_UNAVAILABLE,503);
  72. GnuID id;
  73. id.clear();
  75. char *idstr = strstr(in,"/");
  76. if (idstr)
  77. id.fromStr(idstr+1);
  79. char ipstr[64];
  80. sock->host.toStr(ipstr);
  82. if (id.isSet())
  83. {
  84. // at the moment we don`t really care where the GIV came from, so just give to chan. no. if its waiting. Channel *ch = chanMgr->findChannelByID(id); if (!ch)
  85. throw HTTPException(HTTP_SC_NOTFOUND,404);
  87. if (!ch->acceptGIV(sock))
  88. throw HTTPException(HTTP_SC_UNAVAILABLE,503);
  91. LOG_DEBUG("Accepted GIV channel %s from: %s",idstr,ipstr);
  93. sock=NULL; // release this servent but dont close socket.
  94. }else 
  95. {
  97. if (!servMgr->acceptGIV(sock))
  98. throw HTTPException(HTTP_SC_UNAVAILABLE,503);
  100. LOG_DEBUG("Accepted GIV PCP from: %s",ipstr);
  101. sock=NULL; // release this servent but dont close socket.
  102. }
  103. }else if (http.isRequest(PCX_PCP_CONNECT))
  104. {
  106. if (!isAllowed(ALLOW_NETWORK) || !isFiltered(ServFilter::F_NETWORK))
  107. throw HTTPException(HTTP_SC_UNAVAILABLE,503);
  109. processIncomingPCP(true);
  110. }else if (http.isRequest("PEERCAST CONNECT"))
  111. { if (!isAllowed(ALLOW_NETWORK) || !isFiltered(ServFilter::F_NETWORK))
  112. throw HTTPException(HTTP_SC_UNAVAILABLE,503);
  113. LOG_DEBUG("PEERCAST client"); processServent(); }else if (http.isRequest("SOURCE")) { if (!isAllowed(ALLOW_BROADCAST))
  114. throw HTTPException(HTTP_SC_UNAVAILABLE,503);
  115. char *mount = NULL; char *ps; if (ps=strstr(in,"ICE/1.0")) { mount = in+7; *ps = 0; LOG_DEBUG("ICE 1.0 client to %s",mount?mount:"unknown"); }else{ mount = in+strlen(in); while (*--mount) if (*mount == '/') { mount[-1] = 0; // password preceeds break; } strcpy(loginPassword,in+7); LOG_DEBUG("ICY client: %s %s",loginPassword,mount?mount:"unknown"); } if (mount) strcpy(loginMount,mount); handshakeICY(Channel::SRC_ICECAST,isHTTP); sock = NULL; // socket is taken over by channel, so don`t close it }else if (http.isRequest(servMgr->password)) { if (!isAllowed(ALLOW_BROADCAST)) throw HTTPException(HTTP_SC_UNAVAILABLE,503);
  116. strcpy(loginPassword,servMgr->password); // pwd already checked sock->writeLine("OK2"); sock->writeLine("icy-caps:11"); sock->writeLine(""); LOG_DEBUG("ShoutCast client"); handshakeICY(Channel::SRC_SHOUTCAST,isHTTP); sock = NULL; // socket is taken over by channel, so don`t close it }else { throw HTTPException(HTTP_SC_BADREQUEST,400); } } // -----------------------------------
  117. bool Servent::canStream(Channel *ch)
  118. {
  119. if (ch==NULL)
  120. return false;
  122. if (servMgr->isDisabled)
  123. return false;
  125. if (!isPrivate())
  126. {
  127. if  (
  128. servMgr->bitrateFull(ch->getBitrate())
  129. || ((type == T_RELAY) && servMgr->relaysFull())
  130. || ((type == T_DIRECT) && servMgr->directFull())
  131. || !ch->isPlaying()
  132. || ch->isFull()
  133. )
  134. return false;
  135. }
  137. return true;
  138. }
  139. // ----------------------------------- void Servent::handshakeIncoming() { setStatus(S_HANDSHAKE); char buf[1024]; sock->readLine(buf,sizeof(buf)); char sb[64]; sock->host.toStr(sb); if (stristr(buf,RTSP_PROTO1)) { LOG_DEBUG("RTSP from %s '%s'",sb,buf); RTSP rtsp(*sock); rtsp.initRequest(buf); handshakeRTSP(rtsp); }else if (stristr(buf,HTTP_PROTO1)) { LOG_DEBUG("HTTP from %s '%s'",sb,buf); HTTP http(*sock); http.initRequest(buf); handshakeHTTP(http,true); }else { LOG_DEBUG("Connect from %s '%s'",sb,buf); HTTP http(*sock); http.initRequest(buf); handshakeHTTP(http,false); } } // ----------------------------------- void Servent::triggerChannel(char *str, ChanInfo::PROTOCOL proto,bool relay) {
  140. ChanInfo info;
  142. servMgr->getChannel(str,info,relay);
  144. if (proto == ChanInfo::SP_PCP)
  145. type = T_RELAY;
  146. else
  147. type = T_DIRECT;
  149. outputProtocol = proto;
  151. processStream(false,info);
  153. } // ----------------------------------- void writePLSHeader(Stream &s, PlayList::TYPE type) { s.writeLine(HTTP_SC_OK); s.writeLineF("%s %s",HTTP_HS_SERVER,PCX_AGENT); const char *content; switch(type) { case PlayList::T_PLS: content = MIME_XM3U; break; case PlayList::T_ASX: content = MIME_ASX; break; case PlayList::T_RAM:
  154. content = MIME_RAM;
  155. break;
  156. default: content = MIME_TEXT; break; } s.writeLineF("%s %s",HTTP_HS_CONTENT,content);     s.writeLine("Content-Disposition: inline");     s.writeLine("Cache-Control: private" ); s.writeLineF("%s %s",HTTP_HS_CONNECTION,"close"); s.writeLine(""); } // ----------------------------------- void Servent::handshakePLS(ChanInfo &info, bool doneHandshake) { char url[256]; char in[128]; if (!doneHandshake) while (sock->readLine(in,128));
  157. if (getLocalURL(url)) { PlayList::TYPE type; if ((info.contentType == ChanInfo::T_WMA) || (info.contentType == ChanInfo::T_WMV)) type = PlayList::T_ASX; else if (info.contentType == ChanInfo::T_OGM)
  158. type = PlayList::T_RAM;
  159. else type = PlayList::T_PLS; writePLSHeader(*sock,type); PlayList *pls; pls = new PlayList(type,1); pls->addChannel(url,info); pls->write(*sock); delete pls; } } // ----------------------------------- void Servent::handshakePLS(ChanHitList **cl, int num, bool doneHandshake) { char url[256]; char in[128]; if (!doneHandshake) while (sock->readLine(in,128)); if (getLocalURL(url)) { writePLSHeader(*sock,PlayList::T_SCPLS); PlayList *pls; pls = new PlayList(PlayList::T_SCPLS,num); for(int i=0; i<num; i++) pls->addChannel(url,cl[i]->info); pls->write(*sock); delete pls; } } // ----------------------------------- bool Servent::getLocalURL(char *str) { if (!sock) throw StreamException("Not connected"); char ipStr[64]; Host h; if (sock->host.localIP()) h = sock->getLocalHost(); else h = servMgr->serverHost; h.port = servMgr->serverHost.port; h.toStr(ipStr); sprintf(str,"http://%s",ipStr); return true; } // ----------------------------------- // Warning: testing RTSP/RTP stuff below. // .. moved over to seperate app now. // ----------------------------------- void Servent::handshakePOST() { char tmp[1024];     while (sock->readLine(tmp,sizeof(tmp))) LOG_DEBUG("POST: %s",tmp); throw HTTPException(HTTP_SC_BADREQUEST,400); } // ----------------------------------- void Servent::handshakeRTSP(RTSP &rtsp) { throw HTTPException(HTTP_SC_BADREQUEST,400); } // -----------------------------------
  160. bool Servent::handshakeAuth(HTTP &http,const char *args,bool local)
  161. {
  162. char user[64],pass[64];
  163. user[0] = pass[0] = 0;
  165. char *pwd  = getCGIarg(args, "pass=");
  167. if ((pwd) && strlen(servMgr->password))
  168. {
  169. String tmp = pwd;
  170. char *as = strstr(tmp.cstr(),"&");
  171. if (as) *as = 0;
  172. if (strcmp(tmp,servMgr->password)==0)
  173. {
  174.     while (http.nextHeader());
  175. return true;
  176. }
  177. }
  179. Cookie gotCookie;
  180. cookie.clear();
  182.     while (http.nextHeader())
  183. {
  184. char *arg = http.getArgStr();
  185. if (!arg)
  186. continue;
  188. switch (servMgr->authType)
  189. {
  190. case ServMgr::AUTH_HTTPBASIC:
  191. if (http.isHeader("Authorization"))
  192. http.getAuthUserPass(user,pass);
  193. break;
  194. case ServMgr::AUTH_COOKIE:
  195. if (http.isHeader("Cookie"))
  196. {
  197. LOG_DEBUG("Got cookie: %s",arg);
  198. char *idp=arg;
  199. while ((idp = strstr(idp,"id=")))
  200. {
  201. idp+=3;
  202. gotCookie.set(idp,sock->host.ip);
  203. if (servMgr->cookieList.contains(gotCookie))
  204. {
  205. LOG_DEBUG("Cookie found");
  206. cookie = gotCookie;
  207. break;
  208. }
  210. }
  211. }
  212. break;
  213. }
  214. }
  216. if (sock->host.isLocalhost())
  217. return true;
  220. switch (servMgr->authType)
  221. {
  222. case ServMgr::AUTH_HTTPBASIC:
  224. if ((strcmp(pass,servMgr->password)==0) && strlen(servMgr->password))
  225. return true;
  226. break;
  227. case ServMgr::AUTH_COOKIE:
  228. if (servMgr->cookieList.contains(cookie))
  229. return true;
  230. break;
  231. }
  235. if (servMgr->authType == ServMgr::AUTH_HTTPBASIC)
  236. {
  237. http.writeLine(HTTP_SC_UNAUTHORIZED);
  238. http.writeLine("WWW-Authenticate: Basic realm="PeerCast Admin"");
  239. }else if (servMgr->authType == ServMgr::AUTH_COOKIE)
  240. {
  241. String file = servMgr->htmlPath;
  242. file.append("/login.html");
  243. if (local)
  244. handshakeLocalFile(file);
  245. else
  246. handshakeRemoteFile(file);
  247. }
  250. return false;
  251. }
  253. // ----------------------------------- void Servent::handshakeCMD(char *cmd) { char result[256]; char arg[512]; char curr[256]; char jumpStr[128]; char *jumpArg=NULL; bool retHTML=true; strcpy(result,"OK"); HTTP http(*sock); HTML html("",*sock);
  255. if (!handshakeAuth(http,cmd,true))
  256. return; try { if (cmpCGIarg(cmd,"cmd=","redirect")) { char *j = getCGIarg(cmd,"url="); if (j) { termArgs(cmd); String url; url.set(j,String::T_ESC); url.convertTo(String::T_ASCII); if (!url.contains("http://")) url.prepend("http://"); html.setRefreshURL(url.cstr()); html.startHTML(); html.addHead(); html.startBody(); html.startTagEnd("h3","Please wait..."); html.end(); html.end(); } }else{ if (cmpCGIarg(cmd,"cmd=","viewxml")) { handshakeXML(); retHTML = false; }else if (cmpCGIarg(cmd,"cmd=","clearlog")) { sys->logBuf->clear(); sprintf(jumpStr,"/%s/viewlog.html",servMgr->htmlPath); jumpArg = jumpStr; }else if (cmpCGIarg(cmd,"cmd=","save")) { peercastInst->saveSettings(); sprintf(jumpStr,"/%s/settings.html",servMgr->htmlPath);
  257. jumpArg = jumpStr; }else if (cmpCGIarg(cmd,"cmd=","reg"))
  258. {
  259. char idstr[128];
  260. chanMgr->broadcastID.toStr(idstr);
  261. sprintf(jumpStr,"http://www.peercast.org/register/?id=%s",idstr);
  262. jumpArg = jumpStr;
  263. }else if (cmpCGIarg(cmd,"cmd=","edit_bcid"))
  264. {
  265. char *cp = cmd;
  266. GnuID id;
  267. BCID *bcid;
  268. while (cp=nextCGIarg(cp,curr,arg))
  269. {
  270. if (strcmp(curr,"id")==0)
  271. id.fromStr(arg);
  272. else if (strcmp(curr,"del")==0)
  273. servMgr->removeValidBCID(id);
  274. else if (strcmp(curr,"valid")==0)
  275. {
  276. bcid = servMgr->findValidBCID(id);
  277. if (bcid)
  278. bcid->valid = getCGIargBOOL(arg);
  279. }
  280. }
  281. peercastInst->saveSettings();
  282. sprintf(jumpStr,"/%s/bcid.html",servMgr->htmlPath);
  283. jumpArg = jumpStr;
  284. }else if (cmpCGIarg(cmd,"cmd=","add_bcid"))
  285. {
  286. BCID *bcid = new BCID();
  288. char *cp = cmd;
  289. bool result=false;
  290. while (cp=nextCGIarg(cp,curr,arg))
  291. {
  292. if (strcmp(curr,"id")==0)
  293. bcid->id.fromStr(arg);
  294. else if (strcmp(curr,"name")==0)
  295. bcid->name.set(arg);
  296. else if (strcmp(curr,"email")==0)
  297. bcid->email.set(arg);
  298. else if (strcmp(curr,"url")==0)
  299. bcid->url.set(arg);
  300. else if (strcmp(curr,"valid")==0)
  301. bcid->valid = getCGIargBOOL(arg);
  302. else if (strcmp(curr,"result")==0)
  303. result = true;
  305. }
  306. LOG_DEBUG("Adding BCID : %s",bcid->name.cstr());
  307. servMgr->addValidBCID(bcid);
  308. peercastInst->saveSettings();
  309. if (result) { http.writeLine(HTTP_SC_OK); http.writeLine("");
  310. http.writeString("OK");
  311. }else
  312. {
  313. sprintf(jumpStr,"/%s/bcid.html",servMgr->htmlPath);
  314. jumpArg = jumpStr;
  315. }
  318. }else if (cmpCGIarg(cmd,"cmd=","apply")) { servMgr->numFilters = 0; ServFilter *currFilter=servMgr->filters;
  319. bool brRoot=false;
  320. bool getUpd=false;
  321. int showLog=0;
  322. int allowServer1=0;
  323. int allowServer2=0;
  324. int newPort=servMgr->serverHost.port;
  325. char *cp = cmd; while (cp=nextCGIarg(cp,curr,arg)) { // server if (strcmp(curr,"serveractive")==0) servMgr->autoServe = getCGIargBOOL(arg); else if (strcmp(curr,"port")==0) newPort = getCGIargINT(arg); else if (strcmp(curr,"icymeta")==0) { int iv = getCGIargINT(arg); if (iv < 0) iv = 0; else if (iv > 16384) iv = 16384; chanMgr->icyMetaInterval = iv; }else if (strcmp(curr,"passnew")==0) strcpy(servMgr->password,arg); else if (strcmp(curr,"root")==0) servMgr->isRoot = getCGIargBOOL(arg); else if (strcmp(curr,"brroot")==0)
  326. brRoot = getCGIargBOOL(arg);
  327. else if (strcmp(curr,"getupd")==0)
  328. getUpd = getCGIargBOOL(arg);
  329. else if (strcmp(curr,"huint")==0)
  330. chanMgr->setUpdateInterval(getCGIargINT(arg));
  331. else if (strcmp(curr,"forceip")==0) servMgr->forceIP = arg; else if (strcmp(curr,"htmlPath")==0)
  332. {
  333. strcpy(servMgr->htmlPath,"html/");
  334. strcat(servMgr->htmlPath,arg);
  335. }else if (strcmp(curr,"djmsg")==0) { String msg; msg.set(arg,String::T_ESC); msg.convertTo(String::T_UNICODE); chanMgr->setBroadcastMsg(msg); } else if (strcmp(curr,"pcmsg")==0) { servMgr->rootMsg.set(arg,String::T_ESC); servMgr->rootMsg.convertTo(String::T_UNICODE); }else if (strcmp(curr,"minpgnu")==0)
  336. servMgr->minGnuIncoming = atoi(arg);
  337. else if (strcmp(curr,"maxpgnu")==0)
  338. servMgr->maxGnuIncoming = atoi(arg);
  339. // connections
  340. else if (strcmp(curr,"maxcin")==0)
  341. servMgr->maxControl = getCGIargINT(arg);
  342. else if (strcmp(curr,"maxup")==0) servMgr->maxBitrateOut = getCGIargINT(arg); else if (strcmp(curr,"maxrelays")==0) servMgr->setMaxRelays(getCGIargINT(arg)); else if (strcmp(curr,"maxdirect")==0)
  343. servMgr->maxDirect = getCGIargINT(arg);
  344. else if (strcmp(curr,"maxrelaypc")==0) chanMgr->maxRelaysPerChannel = getCGIargINT(arg); else if (strncmp(curr,"filt_",5)==0) { char *fs = curr+5; { if (strncmp(fs,"ip",2)==0) // ip must be first { currFilter = &servMgr->filters[servMgr->numFilters]; currFilter->init(); currFilter->host.fromStrIP(arg,DEFAULT_PORT); if ((currFilter->host.ip) && (servMgr->numFilters < (ServMgr::MAX_FILTERS-1))) { servMgr->numFilters++; servMgr->filters[servMgr->numFilters].init(); // clear new entry } }else if (strncmp(fs,"bn",2)==0) currFilter->flags |= ServFilter::F_BAN; else if (strncmp(fs,"pr",2)==0) currFilter->flags |= ServFilter::F_PRIVATE; else if (strncmp(fs,"nw",2)==0) currFilter->flags |= ServFilter::F_NETWORK; else if (strncmp(fs,"di",2)==0) currFilter->flags |= ServFilter::F_DIRECT; } } // client else if (strcmp(curr,"clientactive")==0) servMgr->autoConnect = getCGIargBOOL(arg); else if (strcmp(curr,"yp")==0) {
  345. if (!PCP_FORCE_YP)
  346. { String str(arg,String::T_ESC); str.convertTo(String::T_ASCII); servMgr->rootHost = str;
  347. }
  348. } else if (strcmp(curr,"deadhitage")==0) chanMgr->deadHitAge = getCGIargINT(arg); else if (strcmp(curr,"refresh")==0) servMgr->refreshHTML = getCGIargINT(arg); else if (strcmp(curr,"auth")==0) { if (strcmp(arg,"cookie")==0) servMgr->authType = ServMgr::AUTH_COOKIE; else if (strcmp(arg,"http")==0) servMgr->authType = ServMgr::AUTH_HTTPBASIC; }else if (strcmp(curr,"expire")==0) { if (strcmp(arg,"session")==0) servMgr->cookieList.neverExpire = false; else if (strcmp(arg,"never")==0) servMgr->cookieList.neverExpire = true; }
  350. else if (strcmp(curr,"logDebug")==0)
  351. showLog |= atoi(arg)?(1<<LogBuffer::T_DEBUG):0;
  352. else if (strcmp(curr,"logErrors")==0)
  353. showLog |= atoi(arg)?(1<<LogBuffer::T_ERROR):0;
  354. else if (strcmp(curr,"logNetwork")==0)
  355. showLog |= atoi(arg)?(1<<LogBuffer::T_NETWORK):0;
  356. else if (strcmp(curr,"logChannel")==0)
  357. showLog |= atoi(arg)?(1<<LogBuffer::T_CHANNEL):0;
  359. else if (strcmp(curr,"allowHTML1")==0)
  360. allowServer1 |= atoi(arg)?(ALLOW_HTML):0;
  361. else if (strcmp(curr,"allowNetwork1")==0)
  362. allowServer1 |= atoi(arg)?(ALLOW_NETWORK):0;
  363. else if (strcmp(curr,"allowBroadcast1")==0)
  364. allowServer1 |= atoi(arg)?(ALLOW_BROADCAST):0;
  365. else if (strcmp(curr,"allowDirect1")==0)
  366. allowServer1 |= atoi(arg)?(ALLOW_DIRECT):0;
  368. else if (strcmp(curr,"allowHTML2")==0)
  369. allowServer2 |= atoi(arg)?(ALLOW_HTML):0;
  370. else if (strcmp(curr,"allowBroadcast2")==0)
  371. allowServer2 |= atoi(arg)?(ALLOW_BROADCAST):0;
  372. } servMgr->showLog = showLog;
  373. servMgr->allowServer1 = allowServer1; servMgr->allowServer2 = allowServer2;
  375. if (servMgr->serverHost.port != newPort)
  376. {
  377. Host lh(ClientSocket::getIP(NULL),newPort);
  378. char ipstr[64];
  379. lh.toStr(ipstr);
  380. sprintf(jumpStr,"http://%s/%s/settings.html",ipstr,servMgr->htmlPath);
  382. servMgr->serverHost.port = newPort;
  383. servMgr->restartServer=true;
  384. //html.setRefresh(3);
  385. //html.setRefreshURL(jumpStr);
  386. //html.startHTML();
  387. //html.addHead();
  388. // html.startBody();
  389. // html.startTagEnd("h1","Please wait...");
  390. // html.end();
  391. //html.end();
  395. //char ipstr[64];
  396. //servMgr->serverHost.toStr(ipstr);
  397. //sprintf(jumpStr,"/%s/settings.html",ipstr,servMgr->htmlPath);
  398. jumpArg = jumpStr;
  400. }else
  401. {
  402. sprintf(jumpStr,"/%s/settings.html",servMgr->htmlPath);
  403. jumpArg = jumpStr;
  404. }
  405. peercastInst->saveSettings();
  406. peercastApp->updateSettings();
  407. if ((servMgr->isRoot) && (brRoot))
  408. servMgr->broadcastRootSettings(getUpd);
  410. }else if (cmpCGIarg(cmd,"cmd=","fetch")) { ChanInfo info; String curl; char *cp = cmd; while (cp=nextCGIarg(cp,curr,arg)) { if (strcmp(curr,"url")==0) { curl.set(arg,String::T_ESC); curl.convertTo(String::T_UNICODE); }else if (strcmp(curr,"name")==0) { info.name.set(arg,String::T_ESC); info.name.convertTo(String::T_UNICODE);
  411. }else if (strcmp(curr,"desc")==0) { info.desc.set(arg,String::T_ESC); info.desc.convertTo(String::T_UNICODE); }else if (strcmp(curr,"genre")==0) { info.genre.set(arg,String::T_ESC); info.genre.convertTo(String::T_UNICODE); }else if (strcmp(curr,"contact")==0) { info.url.set(arg,String::T_ESC); info.url.convertTo(String::T_UNICODE); }else if (strcmp(curr,"bitrate")==0) { info.bitrate = atoi(arg); }else if (strcmp(curr,"type")==0) { info.contentType = ChanInfo::getTypeFromStr(arg); } }
  412. info.bcID = chanMgr->broadcastID;
  413. Channel *c = chanMgr->createChannel(info,NULL); if (c) c->startURL(curl.cstr()); sprintf(jumpStr,"/%s/relays.html",servMgr->htmlPath);
  414. jumpArg = jumpStr; }else if (cmpCGIarg(cmd,"cmd=","stopserv")) { char *cp = cmd; while (cp=nextCGIarg(cp,curr,arg)) { if (strcmp(curr,"index")==0) { Servent *s = servMgr->findServentByIndex(atoi(arg)); if (s) s->abort(); } } sprintf(jumpStr,"/%s/connections.html",servMgr->htmlPath);
  415. jumpArg = jumpStr; }else if (cmpCGIarg(cmd,"cmd=","hitlist")) { bool stayConnected=hasCGIarg(cmd,"relay");
  416. int index = 0;
  417. ChanHitList *chl = chanMgr->hitlist; while (chl) { if (chl->isUsed()) { char tmp[64]; sprintf(tmp,"c%d=",index); if (cmpCGIarg(cmd,tmp,"1")) { Channel *c; if (!(c=chanMgr->findChannelByID(chl->info.id))) { c = chanMgr->createChannel(chl->info,NULL); if (!c) throw StreamException("out of channels"); c->stayConnected = stayConnected; c->startGet(); } } }
  418. chl = chl->next;
  419. index++; } char *findArg = getCGIarg(cmd,"keywords="); if (hasCGIarg(cmd,"relay")) { sys->sleep(500); sprintf(jumpStr,"/%s/relays.html",servMgr->htmlPath);
  420. jumpArg = jumpStr; } }else if (cmpCGIarg(cmd,"cmd=","clear")) { char *cp = cmd; while (cp=nextCGIarg(cp,curr,arg)) { if (strcmp(curr,"hostcache")==0) servMgr->clearHostCache(ServHost::T_SERVENT); else if (strcmp(curr,"hitlists")==0)
  421. chanMgr->clearHitLists();
  422. else if (strcmp(curr,"packets")==0) { stats.clearRange(Stats::PACKETSSTART,Stats::PACKETSEND); servMgr->numVersions = 0; } } sprintf(jumpStr,"/%s/index.html",servMgr->htmlPath);
  423. jumpArg = jumpStr; }else if (cmpCGIarg(cmd,"cmd=","upgrade")) { if (servMgr->downloadURL[0]) { sprintf(jumpStr,"/admin?cmd=redirect&url=%s",servMgr->downloadURL); jumpArg = jumpStr; } }else if (cmpCGIarg(cmd,"cmd=","connect")) { Servent *s = servMgr->servents; { char tmp[64]; sprintf(tmp,"c%d=",s->serventIndex); if (cmpCGIarg(cmd,tmp,"1")) { if (hasCGIarg(cmd,"stop")) s->thread.active = false; } s=s->next; } sprintf(jumpStr,"/%s/connections.html",servMgr->htmlPath);
  424. jumpArg = jumpStr; }else if (cmpCGIarg(cmd,"cmd=","shutdown")) { servMgr->shutdownTimer = 1; }else if (cmpCGIarg(cmd,"cmd=","stop")) { GnuID id; char *cp = cmd; while (cp=nextCGIarg(cp,curr,arg)) { if (strcmp(curr,"id")==0) id.fromStr(arg); } Channel *c = chanMgr->findChannelByID(id); if (c) c->thread.active = false; sys->sleep(500); sprintf(jumpStr,"/%s/relays.html",servMgr->htmlPath);
  425. jumpArg = jumpStr; }else if (cmpCGIarg(cmd,"cmd=","bump")) { GnuID id; char *cp = cmd; while (cp=nextCGIarg(cp,curr,arg)) { if (strcmp(curr,"id")==0) id.fromStr(arg); } Channel *c = chanMgr->findChannelByID(id); if (c) c->bump = true; sprintf(jumpStr,"/%s/relays.html",servMgr->htmlPath);
  426. jumpArg = jumpStr; }else if (cmpCGIarg(cmd,"cmd=","keep")) { GnuID id; char *cp = cmd; while (cp=nextCGIarg(cp,curr,arg)) { if (strcmp(curr,"id")==0) id.fromStr(arg); } Channel *c = chanMgr->findChannelByID(id); if (c) c->stayConnected = true; sprintf(jumpStr,"/%s/relays.html",servMgr->htmlPath);
  427. jumpArg = jumpStr; }else if (cmpCGIarg(cmd,"cmd=","relay")) {
  428. ChanInfo info; char *cp = cmd; while (cp=nextCGIarg(cp,curr,arg)) { if (strcmp(curr,"id")==0) info.id.fromStr(arg); } if (!chanMgr->findChannelByID(info.id)) { ChanHitList *chl = chanMgr->findHitList(info); if (!chl) throw StreamException("channel not found"); Channel *c = chanMgr->createChannel(chl->info,NULL); if (!c) throw StreamException("out of channels"); c->stayConnected = true; c->startGet(); } sprintf(jumpStr,"/%s/relays.html",servMgr->htmlPath);
  429. jumpArg = jumpStr; }else if (cmpCGIarg(cmd,"net=","add")) { GnuID id; id.clear(); while (cmd=nextCGIarg(cmd,curr,arg)) { if (strcmp(curr,"ip")==0) { Host h; h.fromStrIP(arg,DEFAULT_PORT); if (servMgr->addOutgoing(h,id,true)) LOG_NETWORK("Added connection: %s",arg); }else if (strcmp(curr,"id")==0) { id.fromStr(arg); } } }else if (cmpCGIarg(cmd,"cmd=","logout")) { jumpArg = "/"; servMgr->cookieList.remove(cookie); }else if (cmpCGIarg(cmd,"cmd=","login")) { GnuID id; char idstr[64]; id.generate(); id.toStr(idstr); cookie.set(idstr,sock->host.ip); servMgr->cookieList.add(cookie); http.writeLine(HTTP_SC_FOUND); if (servMgr->cookieList.neverExpire) http.writeLineF("%s id=%s; path=/; expires="Mon, 01-Jan-3000 00:00:00 GMT";",HTTP_HS_SETCOOKIE,idstr); else http.writeLineF("%s id=%s; path=/;",HTTP_HS_SETCOOKIE,idstr); http.writeLineF("Location: /%s/index.html",servMgr->htmlPath); http.writeLine("");
  430. }else{ sprintf(jumpStr,"/%s/index.html",servMgr->htmlPath);
  431. jumpArg = jumpStr;
  432. } } }catch(StreamException &e) { html.startTagEnd("h1","ERROR - %s",e.msg); LOG_ERROR("html: %s",e.msg); } if (retHTML) { if (jumpArg) { String jmp(jumpArg,String::T_HTML); jmp.convertTo(String::T_ASCII); html.locateTo(jmp.cstr()); } } } // ----------------------------------- static XML::Node *createChannelXML(Channel *c) { XML::Node *n = c->info.createChannelXML(); n->add(c->createRelayXML(true)); n->add(c->info.createTrackXML()); // n->add(c->info.createServentXML()); return n; } // ----------------------------------- static XML::Node *createChannelXML(ChanHitList *chl) { XML::Node *n = chl->info.createChannelXML(); n->add(chl->createXML()); n->add(chl->info.createTrackXML()); // n->add(chl->info.createServentXML()); return n; } // ----------------------------------- void Servent::handshakeXML() { int i; XML xml; XML::Node *rn = new XML::Node("peercast"); xml.setRoot(rn); rn->add(new XML::Node("servent uptime="%d"",servMgr->getUptime())); rn->add(new XML::Node("bandwidth out="%d" in="%d"",
  433. stats.getPerSecond(Stats::BYTESOUT)-stats.getPerSecond(Stats::LOCALBYTESOUT),
  434. stats.getPerSecond(Stats::BYTESIN)-stats.getPerSecond(Stats::LOCALBYTESIN)
  435. ));
  436. rn->add(new XML::Node("connections total="%d" relays="%d" direct="%d"",servMgr->totalConnected(),servMgr->numStreams(Servent::T_RELAY,true),servMgr->numStreams(Servent::T_DIRECT,true)));
  437. XML::Node *an = new XML::Node("channels_relayed total="%d"",chanMgr->numChannels());
  438. rn->add(an);
  440. Channel *c = chanMgr->channel;
  441. while (c)
  442. {
  443. if (c->isActive())
  444. an->add(createChannelXML(c));
  445. c=c->next;
  446. }
  447. // add public channels { XML::Node *fn = new XML::Node("channels_found total="%d"",chanMgr->numHitLists()); rn->add(fn);
  449. ChanHitList *chl = chanMgr->hitlist; while (chl)
  450. { if (chl->isUsed())
  451. if (!chl->info.isPrivate()) fn->add(createChannelXML(chl));
  452. chl = chl->next;
  453. }
  454. }
  456. if (servMgr->isRoot)
  457. {
  458. // add private channels
  459. {
  460. XML::Node *pn = new XML::Node("priv_channels");
  461. rn->add(pn);
  463. ChanHitList *chl = chanMgr->hitlist;
  464. while (chl)
  465. {
  466. if (chl->isUsed())
  467. if (chl->info.isPrivate())
  468. pn->add(createChannelXML(chl));
  469. chl = chl->next;
  470. }
  471. }
  472. }
  474. XML::Node *hc = new XML::Node("host_cache"); for(i=0; i<ServMgr::MAX_HOSTCACHE; i++) { ServHost *sh = &servMgr->hostCache[i]; if (sh->type != ServHost::T_NONE) { char ipstr[64]; sh->host.toStr(ipstr); hc->add(new XML::Node("host ip="%s" type="%s" time="%d"",ipstr,ServHost::getTypeStr(sh->type),sh->time)); } }
  475. rn->add(hc);
  478.     sock->writeLine(HTTP_SC_OK);
  479. sock->writeLineF("%s %s",HTTP_HS_SERVER,PCX_AGENT);
  480.     sock->writeLineF("%s %s",HTTP_HS_CONTENT,MIME_XML);
  481. sock->writeLine("Connection: close");
  483.     sock->writeLine("");
  485. xml.write(*sock);
  487. } // ----------------------------------- void Servent::readICYHeader(HTTP &http, ChanInfo &info, char *pwd) { char *arg = http.getArgStr(); if (!arg) return; if (http.isHeader("x-audiocast-name") || http.isHeader("icy-name") || http.isHeader("ice-name"))
  488. { info.name.set(arg,String::T_ASCII);
  489. info.name.convertTo(String::T_UNICODE);
  490. }else if (http.isHeader("x-audiocast-url") || http.isHeader("icy-url") || http.isHeader("ice-url"))
  491. info.url.set(arg,String::T_ASCII); else if (http.isHeader("x-audiocast-bitrate") || (http.isHeader("icy-br")) || http.isHeader("ice-bitrate") || http.isHeader("icy-bitrate")) info.bitrate = atoi(arg); else if (http.isHeader("x-audiocast-genre") || http.isHeader("ice-genre") || http.isHeader("icy-genre"))
  492. { info.genre.set(arg,String::T_ASCII);
  493. info.genre.convertTo(String::T_UNICODE);
  494. }else if (http.isHeader("x-audiocast-description") || http.isHeader("ice-description"))
  495. { info.desc.set(arg,String::T_ASCII);
  496. info.desc.convertTo(String::T_UNICODE);
  497. }else if (http.isHeader("Authorization")) http.getAuthUserPass(NULL,pwd); else if (http.isHeader(PCX_HS_CHANNELID)) info.id.fromStr(arg);
  498. else if (http.isHeader("ice-password")) { if (pwd) if (strlen(arg) < 64) strcpy(pwd,arg); }else if (http.isHeader("content-type")) { if (stristr(arg,MIME_OGG)) info.contentType = ChanInfo::T_OGG; else if (stristr(arg,MIME_XOGG)) info.contentType = ChanInfo::T_OGG; else if (stristr(arg,MIME_MP3)) info.contentType = ChanInfo::T_MP3; else if (stristr(arg,MIME_XMP3)) info.contentType = ChanInfo::T_MP3; else if (stristr(arg,MIME_WMA)) info.contentType = ChanInfo::T_WMA; else if (stristr(arg,MIME_WMV)) info.contentType = ChanInfo::T_WMV; else if (stristr(arg,MIME_ASX)) info.contentType = ChanInfo::T_ASX; else if (stristr(arg,MIME_NSV)) info.contentType = ChanInfo::T_NSV; else if (stristr(arg,MIME_RAW)) info.contentType = ChanInfo::T_RAW;
  499. else if (stristr(arg,MIME_MMS)) info.srcProtocol = ChanInfo::SP_MMS;
  500. else if (stristr(arg,MIME_XPCP))
  501. info.srcProtocol = ChanInfo::SP_PCP;
  502. else if (stristr(arg,MIME_XPEERCAST))
  503. info.srcProtocol = ChanInfo::SP_PEERCAST;
  504. else if (stristr(arg,MIME_XSCPLS)) info.contentType = ChanInfo::T_PLS; else if (stristr(arg,MIME_PLS)) info.contentType = ChanInfo::T_PLS; else if (stristr(arg,MIME_XPLS)) info.contentType = ChanInfo::T_PLS; else if (stristr(arg,MIME_M3U)) info.contentType = ChanInfo::T_PLS; else if (stristr(arg,MIME_MPEGURL))
  505. info.contentType = ChanInfo::T_PLS;
  506. else if (stristr(arg,MIME_TEXT)) info.contentType = ChanInfo::T_PLS; } } // ----------------------------------- void Servent::handshakeICY(Channel::SRC_TYPE type, bool isHTTP) { ChanInfo info; HTTP http(*sock); // default to mp3 for shoutcast DSP (doesn`t send content-type) if (type == Channel::SRC_SHOUTCAST) info.contentType = ChanInfo::T_MP3; while (http.nextHeader()) { LOG_DEBUG("ICY %s",http.cmdLine); readICYHeader(http,info,loginPassword); } // check password before anything else, if needed if (strcmp(servMgr->password,loginPassword)!=0)
  507. {
  508. if (!sock->host.isLocalhost() || strlen(loginPassword))
  509. throw HTTPException(HTTP_SC_UNAUTHORIZED,401);
  510. }
  512. // we need a valid IP address before we start
  513. servMgr->checkFirewall();
  514. // attach channel ID to name, channel ID is also encoded with IP address  // to help prevent channel hijacking.  info.id = chanMgr->broadcastID;
  515. info.id.encode(NULL,info.name.cstr(),loginMount,info.bitrate); LOG_DEBUG("Incoming source: %s : %s",info.name.cstr(),ChanInfo::getTypeStr(info.contentType)); if (isHTTP) sock->writeStringF("%snn",HTTP_SC_OK); else sock->writeLine("OK");
  516. Channel *c = chanMgr->findChannelByID(info.id); if (c)
  517. {
  518. LOG_CHANNEL("ICY channel already active, closing old one");
  519. c->thread.shutdown();
  520. }
  521. info.comment = chanMgr->broadcastMsg; info.bcID = chanMgr->broadcastID;
  522. c = chanMgr->createChannel(info,loginMount); if (!c) throw HTTPException(HTTP_SC_UNAVAILABLE,503);
  523. c->startICY(sock,type); }
  525. // -----------------------------------
  526. void Servent::handshakeLocalFile(const char *fn)
  527. {
  528. HTTP http(*sock);
  529. String fileName;
  531. fileName = peercastApp->getPath();
  533. fileName.append(fn);
  535. LOG_DEBUG("Writing HTML file: %s",fileName.cstr());
  537. HTML html("",*sock);
  539. char *args = strstr(fileName.cstr(),"?");
  540. if (args)
  541. *args++=0;
  543. if (fileName.contains(".htm"))
  544. {
  545. html.writeOK(MIME_HTML);
  546. html.writeTemplate(fileName.cstr(),args);
  548. }else if (fileName.contains(".css"))
  549. {
  550. html.writeOK(MIME_CSS);
  551. html.writeRawFile(fileName.cstr());
  552. }else if (fileName.contains(".jpg"))
  553. {
  554. html.writeOK(MIME_JPEG);
  555. html.writeRawFile(fileName.cstr());
  556. }else if (fileName.contains(".gif"))
  557. {
  558. html.writeOK(MIME_GIF);
  559. html.writeRawFile(fileName.cstr());
  560. }else if (fileName.contains(".png"))
  561. {
  562. html.writeOK(MIME_PNG);
  563. html.writeRawFile(fileName.cstr());
  564. }
  565. }
  567. // -----------------------------------
  568. void Servent::handshakeRemoteFile(const char *dirName)
  569. {
  570. ClientSocket *rsock = sys->createSocket();
  571. if (!rsock)
  572. throw HTTPException(HTTP_SC_UNAVAILABLE,503);
  575. const char *hostName = "www.peercast.org"; // hardwired for "security"
  577. Host host;
  578. host.fromStrName(hostName,80);
  581. rsock->open(host);
  582. rsock->connect();
  584. HTTP rhttp(*rsock);
  586. rhttp.writeLineF("GET /%s HTTP/1.0",dirName);
  587. rhttp.writeLineF("%s %s",HTTP_HS_HOST,hostName);
  588. rhttp.writeLineF("%s %s",HTTP_HS_CONNECTION,"close");
  589. rhttp.writeLineF("%s %s",HTTP_HS_ACCEPT,"*/*");
  590. rhttp.writeLine("");
  592. String contentType;
  593. bool isTemplate = false;
  594. while (rhttp.nextHeader())
  595. {
  596. char *arg = rhttp.getArgStr();
  597. if (arg) 
  598. {
  599. if (rhttp.isHeader("content-type"))
  600. contentType = arg;
  601. }
  602. }
  604. MemoryStream mem(100*1024);
  605. while (!rsock->eof())
  606. {
  607. int len=0;
  608. char buf[4096];
  609. len = rsock->readUpto(buf,sizeof(buf));
  610. if (len==0)
  611. break;
  612. else
  613. mem.write(buf,len);
  615. }
  616. rsock->close();
  618. int fileLen = mem.getPosition();
  619. mem.len = fileLen;
  620. mem.rewind();
  623. if (contentType.contains(MIME_HTML))
  624. isTemplate = true;
  626. sock->writeLine(HTTP_SC_OK);
  627. sock->writeLineF("%s %s",HTTP_HS_SERVER,PCX_AGENT);
  628. sock->writeLineF("%s %s",HTTP_HS_CACHE,"no-cache");
  629. sock->writeLineF("%s %s",HTTP_HS_CONNECTION,"close");
  630. sock->writeLineF("%s %s",HTTP_HS_CONTENT,contentType.cstr());
  632. sock->writeLine("");
  634. if (isTemplate)
  635. {
  636. HTML html("",*sock);
  637. html.readTemplate(mem,sock,0);
  638. }else
  639. sock->write(mem.buf,fileLen);
  641. mem.free();
  642. }