New Structure:
"); char tbuffer[83]; -#ifdef WITH_EMU - char keyBuffer[1024]; -#endif int jsondelimiter = 0; while((item = ll_iter_next(&itr))) { -#ifdef WITH_EMU - if(item->isKey) - { - tpl_addVar(vars, TPLADD, "ENTSTARTDATE", ""); - tpl_addVar(vars, TPLADD, "ENTENDDATE", ""); - cs_hexdump(0, item->key, item->keyLength, keyBuffer, sizeof(keyBuffer)); - tpl_addVar(vars, TPLADD, "ENTEXPIERED", "e_valid"); - tpl_printf(vars, TPLADD, "ENTCAID", "%04X", item->caid); - tpl_printf(vars, TPLADD, "ENTPROVID", "%08X", item->provid); - tpl_addVar(vars, TPLADD, "ENTID", item->name); - tpl_addVar(vars, TPLADD, "ENTCLASS", keyBuffer); - if(item->isData) { tpl_addVar(vars, TPLADD, "ENTTYPE", "data"); } - else { tpl_addVar(vars, TPLADD, "ENTTYPE", "key"); } - tpl_addVar(vars, TPLADD, "ENTRESNAME", ""); - - if((strcmp(getParam(params, "hideexpired"), "1") != 0) || (item->end > now)) - { tpl_addVar(vars, TPLAPPEND, "READERENTENTRY", tpl_getTpl(vars, "ENTITLEMENTITEMBIT")); } - - continue; - } -#endif - localtime_r(&item->start, &start_t); localtime_r(&item->end, &end_t); @@ -5970,9 +5855,6 @@ static char *send_oscam_status(struct templatevars * vars, struct uriparams * pa filtered = (type == cl->typ) || (type == 'x' && (cl->typ == 'p' || cl->typ == 'r') && (cl->reader && cl->reader->cacheex.mode)); #else filtered = (type == cl->typ); -#endif -#ifdef WITH_EMU - if(type == 'e' && cl->typ == 'r' && cl->reader->typ == R_EMU) filtered = 1; #endif } } @@ -7564,9 +7446,6 @@ static char *send_oscam_files(struct templatevars * vars, struct uriparams * par { "stats.info", MNU_GBX_FSTAINF, FTYPE_GBOX }, // id 27 { "expired.info", MNU_GBX_FEXPINF, FTYPE_GBOX }, // id 28 { "info.log", MNU_GBX_INFOLOG, FTYPE_GBOX }, // id 29 -#endif -#ifdef WITH_EMU - { "SoftCam.Key", MNU_CFG_FSOFTCAMKEY,FTYPE_CONFIG }, // id 30 #endif { NULL, 0, 0 }, }; @@ -8039,11 +7918,7 @@ static char *send_oscam_EMM_running(struct templatevars * vars, struct uriparams else if(!proxy && rdr->csystem_active) // local active reader { csystem = rdr->csystem; - - if(rdr->typ != R_EMU) - { - caid = rdr->caid; - } + caid = rdr->caid; } if(csystem) @@ -8325,8 +8200,9 @@ static char *send_oscam_cacheex(struct templatevars * vars, struct uriparams * p tpl_addVar(vars, TPLADD, "CLIENTDESCRIPTION", ""); } } - - { tpl_addVar(vars, TPLADD, "IP", ""); } + + + { tpl_addVar(vars, TPLADD, "IP", ""); } // --- NODEID changer detection (persistent, based on cxnodeid_changer_detected) --- @@ -8348,7 +8224,20 @@ else webif_last_nodeid[idx] = current_node; // --- end detection --- - + if(IP_ISSET(cl->ip)) + { tpl_addVar(vars, TPLADD, "IP", cs_inet_ntoa(cl->ip)); } + else if(cl->login > cl->logout) + { tpl_addVar(vars, TPLADD, "IP", "camd.socket"); } + else + { tpl_addVar(vars, TPLADD, "IP", ""); } + tpl_printf(vars, TPLADD, "NODE", "%" PRIu64 "X", get_cacheex_node(cl)); + tpl_addVar(vars, TPLADD, "LEVEL", level[cl->account->cacheex.mode]); + tpl_printf(vars, TPLADD, "PUSH", "%d", cl->account->cwcacheexpush); + tpl_printf(vars, TPLADD, "GOT", "%d", cl->account->cwcacheexgot); + tpl_printf(vars, TPLADD, "CWCINFO", "%d", cl->account->cwc_info); + tpl_printf(vars, TPLADD, "HIT", "%d", cl->account->cwcacheexhit); + tpl_printf(vars, TPLADD, "ERR", "%d", cl->account->cwcacheexerr); + tpl_printf(vars, TPLADD, "ERRCW", "%d", cl->account->cwcacheexerrcw); #ifdef CS_CACHEEX_AIO tpl_printf(vars, TPLADD, "GOTLG", "%d", cl->account->cwcacheexgotlg); tpl_printf(vars, TPLADD, "PUSHLG", "%d", cl->account->cwcacheexpushlg); @@ -9356,11 +9245,7 @@ static int32_t readRequest(FILE * f, IN_ADDR_T in, char **result, int8_t forcePl memcpy(*result + bufsize, buf2, n); bufsize += n; -#ifdef WITH_EMU - if(bufsize > 204800) // max request size 200kb -#else if(bufsize > 102400) // max request size 100kb -#endif { cs_log("error: too much data received from %s", cs_inet_ntoa(in)); NULLFREE(*result); diff --git a/module-webif.c.bak b/module-webif.c.bak new file mode 100644 index 0000000..f6f7f89 --- /dev/null +++ b/module-webif.c.bak @@ -0,0 +1,10260 @@ +#define MODULE_LOG_PREFIX "webif" + +#include "globals.h" + +#ifdef WEBIF +// +// OSCam HTTP server module +// +#include
protocol version: %d", proto, dvbapi_get_client_name(), dvbapi_get_client_proto_version()); + else + tpl_printf(vars, TPLADD, "CLIENTPROTO", "%s (client: %s, protocol version: %d)", proto, dvbapi_get_client_name(), dvbapi_get_client_proto_version()); + tpl_printf(vars, TPLADD, "CLIENTPROTOSORT", "%s", proto); + return; + } +#endif + tpl_addVar(vars, TPLADDONCE, "CLIENTPROTO", (char *)proto); + tpl_addVar(vars, TPLADDONCE, "CLIENTPROTOSORT", (char *)proto); + if(cfg.http_showpicons) + { + char picon_name[32]; + snprintf(picon_name, sizeof(picon_name) / sizeof(char) - 1, "%s", proto); + if(picon_exists(picon_name)) + { + if (!apicall) + { + tpl_addVar(vars, TPLADD, "OTHER", (char *)proto); + tpl_addVar(vars, TPLADD, "CLIENTPROTO", tpl_getTpl(vars, "PROTOOTHERPIC")); + } + else + { + tpl_printf(vars, TPLADDONCE, "PROTOICON", "%s",(char *)proto); + } + } + else + { + tpl_printf(vars, TPLADD, "CLIENTPROTOTITLE", "missing icon: IC_%s.tpl", proto); + } + } +} + +static void kill_account_thread(struct s_auth *account) +{ + struct s_client *cl; + for(cl = first_client->next; cl ; cl = cl->next) + { + if(cl->account == account) + { + if(get_module(cl)->type & MOD_CONN_NET) + { + kill_thread(cl); + } + else + { + cl->account = first_client->account; + } + } + } +} + +static char *send_oscam_user_config(struct templatevars *vars, struct uriparams *params, int32_t apicall) +{ + struct s_auth *account; + struct s_client *cl; + char *user = getParam(params, "user"); + int32_t found = 0; + uint8_t md5tmp[MD5_DIGEST_LENGTH]; + + if(!apicall) + { + setActiveMenu(vars, MNU_USERS); + } + if(strcmp(getParam(params, "action"), "reinit") == 0) + { + if(!cfg.http_readonly) + { refresh_oscam(REFR_ACCOUNTS); } + } + if(strcmp(getParam(params, "action"), "delete") == 0) + { + if(cfg.http_readonly) + { + tpl_addMsg(vars, "WebIf is in readonly mode. No deletion will be made!"); + } + else + { + struct s_auth *account_prev = NULL; + + for(account = cfg.account; (account); account = account->next) + { + if(strcmp(account->usr, user) == 0) + { + if(account_prev == NULL) + { cfg.account = account->next; } + else + { account_prev->next = account->next; } + ll_clear(account->aureader_list); + kill_account_thread(account); + add_garbage(account); + found = 1; + break; + } + account_prev = account; + } + if(found > 0) + { + if(write_userdb() != 0) { tpl_addMsg(vars, "Write Config failed!"); } + } + else { tpl_addMsg(vars, "Sorry but the specified user doesn't exist. No deletion will be made!"); } + } + } + + if((strcmp(getParam(params, "action"), "disable") == 0) || (strcmp(getParam(params, "action"), "enable") == 0)) + { + account = get_account_by_name(getParam(params, "user")); + if(account) + { + if(strcmp(getParam(params, "action"), "disable") == 0) + { + account->disabled = 1; + kill_account_thread(account); + } + else + { account->disabled = 0; } + if(write_userdb() != 0) { tpl_addMsg(vars, "Write Config failed!"); } + } + else + { + tpl_addMsg(vars, "Sorry but the specified user doesn't exist. No deletion will be made!"); + } + } + + if(strcmp(getParam(params, "action"), "resetstats") == 0) + { + account = get_account_by_name(getParam(params, "user")); + if(account) { clear_account_stats(account); } + } + + if(strcmp(getParam(params, "action"), "resetuserstats") == 0) + { + clear_info_clients_stats(); + } + + if(strcmp(getParam(params, "action"), "resetreaderstats") == 0) + { + clear_info_readers_stats(); + } + + if(strcmp(getParam(params, "action"), "resetalluserstats") == 0) + { + clear_all_account_stats(); + } + + if((strcmp(getParam(params, "part"), "adduser") == 0) && (!cfg.http_readonly)) + { + tpl_addVar(vars, TPLAPPEND, "NEWUSERFORM", tpl_getTpl(vars, "ADDNEWUSER")); + } + + /* List accounts*/ + char *status, *expired, *classname, *lastchan; + time_t now = time((time_t *)0); + int32_t isec = 0, chsec = 0; + + char *filter = NULL; + int32_t clientcount = 0; + if(apicall) + { + filter = getParam(params, "label"); + } + int8_t grp_set = 0; + int8_t expdate_set = 0; + int32_t total_users = 0; + int32_t disabled_users = 0; + int32_t expired_users = 0; + int32_t expired_or_disabled_users = 0; + int32_t connected_users = 0; + int32_t online_users = 0; + int32_t casc_users = 0; + int32_t casc_users2 = 0; + int32_t n_request = 0; + int existing_insert = 0; + + for(account = cfg.account; (account); account = account->next) + { + if(account->expirationdate){ + expdate_set = 1; + } + + if(account->next){ + if(account->grp != account->next->grp){ + grp_set = 1; + } + } + if(expdate_set && grp_set) + break; + } + + for(account = cfg.account; (account); account = account->next) + { + //clear for next client + total_users++; + isactive = 1; + + status = "offline"; + classname = "offline"; + isec = 0; + chsec = 0; + + //reset caid/srevid template variables + tpl_addVar(vars, TPLADD, "CLIENTCAID", ""); + tpl_addVar(vars, TPLADD, "CLIENTPROVID", ""); + tpl_addVar(vars, TPLADD, "CLIENTSRVID", ""); + tpl_addVar(vars, TPLADD, "LASTCHANNEL", ""); + tpl_addVar(vars, TPLADD, "LASTCHANNELSORT", ""); + tpl_addVar(vars, TPLADD, "USERMD5", ""); + tpl_addVar(vars, TPLADD, "CWLASTRESPONSET", ""); + tpl_addVar(vars, TPLADD, "CWLASTRESPONSETMS", ""); + tpl_addVar(vars, TPLADD, "CLIENTIP", ""); + tpl_addVar(vars, TPLADD, "LASTCHANNELTITLE", ""); + tpl_addVar(vars, TPLADD, "LASTCHANNELSORT", ""); + tpl_addVar(vars, TPLADD, "CLIENTTIMEONCHANNELAPI", ""); + tpl_addVar(vars, TPLADD, "CLIENTTIMEONCHANNEL", ""); + tpl_addVar(vars, TPLADD, "CLIENTTIMETOSLEEP", ""); + tpl_addVar(vars, TPLADD, "CLIENTTIMETOSLEEPAPI", ""); + tpl_addVar(vars, TPLADD, "IDLESECS", ""); + tpl_addVar(vars, TPLADD, "UNOTIFY", ""); + + if(account->expirationdate && account->expirationdate < now) + { + expired = " (expired)"; + classname = "expired"; + expired_users++; + isactive = 0; + } + else + { + expired = ""; + } + + if(account->disabled != 0) + { + expired = " (disabled)"; + classname = "disabled"; + tpl_addVar(vars, TPLADD, "SWITCHICO", "image?i=ICENA"); + tpl_addVar(vars, TPLADD, "SWITCHTITLE", "Enable"); + tpl_addVar(vars, TPLADD, "SWITCH", "enable"); + disabled_users++; + isactive = 0; + } + else + { + tpl_addVar(vars, TPLADD, "SWITCHICO", "image?i=ICDIS"); + tpl_addVar(vars, TPLADD, "SWITCHTITLE", "Disable"); + tpl_addVar(vars, TPLADD, "SWITCH", "disable"); + } + if((account->expirationdate && account->expirationdate < now)||account->disabled != 0) + { + expired_or_disabled_users++; + } + + int32_t lastresponsetm = 0, latestactivity = 0; + const char *proto = ""; + double cwrate = 0.0, cwrate2 = 0.0; + + //search account in active clients + isactive = 0; + int16_t nrclients = 0; + struct s_client *latestclient = NULL; + for(cl = first_client->next; cl ; cl = cl->next) + { + if(cl->account && !strcmp(cl->account->usr, account->usr)) + { + if(cl->lastecm > latestactivity || cl->login > latestactivity) + { + if(cl->lastecm > cl->login) { latestactivity = cl->lastecm; } + else { latestactivity = cl->login; } + latestclient = cl; + } + nrclients++; + } + } + if(account->cwfound + account->cwnot + account->cwcache > 0) + { + cwrate = now - account->firstlogin; + cwrate /= (account->cwfound + account->cwnot + account->cwcache); + } + + casc_users = 0; + casc_users2 = 0; + int8_t conn = 0; + if(latestclient != NULL) + { + char channame[CS_SERVICENAME_SIZE]; + status = (!apicall) ? "connected" : "connected"; + if(account->expirationdate && account->expirationdate < now) { classname = "expired"; } + else { classname = "connected";conn = 1; } + + proto = client_get_proto(latestclient); + int clientcaid = latestclient->last_caid; + int clientsrvid = latestclient->last_srvid; + int clientprovid = latestclient->last_provid; + tpl_printf(vars, TPLADD, "CLIENTCAID", "%04X", clientcaid); + tpl_printf(vars, TPLADD, "CLIENTPROVID", "%06X", clientprovid); + tpl_printf(vars, TPLADD, "CLIENTSRVID", "%04X", clientsrvid); + + if(clientsrvid != NO_SRVID_VALUE || clientcaid != NO_CAID_VALUE) + { + lastchan = xml_encode(vars, get_servicename(latestclient, clientsrvid, clientprovid, clientcaid, channame, sizeof(channame))); + tpl_addVar(vars, TPLADD, "LASTCHANNELSORT", lastchan); + } + else + { + lastchan = ""; + tpl_addVar(vars, TPLADD, "LASTCHANNELSORT", "~~~~~"); + } + + tpl_addVar(vars, TPLADDONCE, "LASTCHANNEL", lastchan); + tpl_addVar(vars, TPLADD, "LASTCHANNELTITLE", lastchan); + + if(cfg.http_showpicons ) + { + char picon_name[128]; + char picon_channame[128]; + int8_t picon_ok = 0; + + get_picon_servicename_or_null(latestclient, clientsrvid, clientprovid, clientcaid, picon_channame, sizeof(picon_channame)); + if(picon_channame[0]) + { + snprintf(picon_name, sizeof(picon_name) / sizeof(char), "%s", picon_channame); + picon_ok = picon_exists(picon_name); + + if(!picon_ok && picon_servicename_remve_hd(picon_channame, sizeof(picon_channame))) + { + snprintf(picon_name, sizeof(picon_name) / sizeof(char), "%s", picon_channame); + picon_ok = picon_exists(picon_name); + } + } + if(!picon_ok) + { + snprintf(picon_name, sizeof(picon_name) / sizeof(char), "%04X_%06X_%04X", clientcaid, clientprovid, clientsrvid); + picon_ok = picon_exists(picon_name); + } + if(!picon_ok) + { + snprintf(picon_name, sizeof(picon_name) / sizeof(char), "%04X_%04X", clientcaid, clientsrvid); + picon_ok = picon_exists(picon_name); + } + if(!picon_ok) + { + snprintf(picon_name, sizeof(picon_name) / sizeof(char), "0000_%04X", clientsrvid); + picon_ok = picon_exists(picon_name); + } + if(picon_ok) + { + tpl_addVar(vars, TPLADDONCE, "LCA", picon_name); + tpl_addVar(vars, TPLADDONCE, "LCB", lastchan); + if(!apicall) + { + tpl_addVar(vars, TPLADDONCE, "LASTCHANNEL", tpl_getTpl(vars, "USERCONFIGLASTCHANEL")); + } + } + else + { + tpl_printf(vars, TPLADD, "LASTCHANNELTITLE", "missing icon: IC_%s.tpl", picon_name); + } + } + + lastresponsetm = latestclient->cwlastresptime; + if(IP_ISSET(latestclient->ip)) + { tpl_addVar(vars, TPLADD, "CLIENTIP", cs_inet_ntoa(latestclient->ip)); } + else if(latestclient->login > latestclient->logout) + { tpl_addVar(vars, TPLADD, "CLIENTIP", "camd.socket"); } + else + { tpl_addVar(vars, TPLADD, "CLIENTIP", ""); } + connected_users++; + casc_users = ll_count(latestclient->cascadeusers); + LL_ITER it = ll_iter_create(latestclient->cascadeusers); + struct s_cascadeuser *cu; + while((cu = ll_iter_next(&it))) + { + if(cu->cwrate > 0) + { casc_users2++; } + } + if(latestactivity > 0) + { + isec = now - latestactivity; + chsec = latestclient->lastswitch ? now - latestclient->lastswitch : 0; + if(isec < cfg.hideclient_to) + { + isactive = 1; + status = (!apicall) ? "online" : "online"; + if(account->expirationdate && account->expirationdate < now) { classname = "expired"; } + else { classname = "online"; } + if(latestclient->cwfound + latestclient->cwnot + latestclient->cwcache > 0) + { + cwrate2 = now - latestclient->login; + cwrate2 /= (latestclient->cwfound + latestclient->cwnot + latestclient->cwcache); + tpl_printf(vars, TPLADDONCE, "CWRATE2", " (%.2f)", cwrate2); + online_users++; + } + } + } + } + + n_request = 0; + if(latestclient != NULL){ + n_request = latestclient->n_request[0]; + } + + tpl_addVar(vars, TPLADD, "EXPIREVIEW", expdate_set ? "" : "exp"); + tpl_addVar(vars, TPLADD, "GRPVIEW", grp_set ? "" : "grp"); +#ifdef CS_ANTICASC + tpl_addVar(vars, TPLADD, "ANTICASCVIEW", cfg.ac_enabled ? "" : "acas"); +#endif + tpl_printf(vars, TPLADD, "CWOK", PRINTF_LOCAL_D, account->cwfound); + tpl_printf(vars, TPLADD, "CWNOK", PRINTF_LOCAL_D, account->cwnot); + tpl_printf(vars, TPLADD, "CWIGN", PRINTF_LOCAL_D, account->cwignored); + tpl_printf(vars, TPLADD, "CWTOUT", PRINTF_LOCAL_D, account->cwtout); +#ifdef CW_CYCLE_CHECK + tpl_addVar(vars, TPLADD, "CWCCYCVIEW", cfg.cwcycle_check_enable ? "" : "cwc"); + tpl_printf(vars, TPLADD, "CWCYCLECHECKED", "%d", account->cwcycledchecked); + tpl_printf(vars, TPLADD, "CWCYCLEOK", "%d", account->cwcycledok); + tpl_printf(vars, TPLADD, "CWCYCLENOK", "%d", account->cwcyclednok); + tpl_printf(vars, TPLADD, "CWCYCLEIGN", "%d", account->cwcycledign); +#endif + tpl_printf(vars, TPLADD, "CWCACHE", PRINTF_LOCAL_D, account->cwcache); + tpl_printf(vars, TPLADD, "CWTUN", PRINTF_LOCAL_D, account->cwtun); + tpl_printf(vars, TPLADD, "EMMOK", PRINTF_LOCAL_D, account->emmok); + tpl_printf(vars, TPLADD, "EMMNOK", PRINTF_LOCAL_D, account->emmnok); + tpl_printf(vars, TPLADD, "CWRATE", "%.2f", cwrate); + tpl_printf(vars, TPLADD, "CASCUSERS", "%d", casc_users); + tpl_printf(vars, TPLADD, "CASCUSERS2", "%d", casc_users2); + tpl_printf(vars, TPLADD, "CASCUSERSCOMB", "%d/%d", casc_users, casc_users2); + tpl_printf(vars, TPLADD, "N_REQUEST_MIN", "%d", n_request); + + if(isactive > 0 || conn > 0) + { + if(casc_users+casc_users2>0) + { + tpl_printf(vars, TPLADD, "CWLASTRESPONSET", "%d", lastresponsetm); + tpl_printf(vars, TPLADD, "CWLASTRESPONSETMS", PRINTF_LOCAL_D " ms", lastresponsetm); + } + tpl_addVar(vars, TPLADD, "IDLESECS", sec2timeformat(vars, isec)); + } + + if(isactive > 0) + { + tpl_printf(vars, TPLADD, "CLIENTTIMEONCHANNELAPI", "%d", chsec); + tpl_addVar(vars, TPLADD, "CLIENTTIMEONCHANNEL", sec2timeformat(vars, chsec)); + + if(account->tosleep) + { + if(account->tosleep >0){ + tpl_printf(vars, TPLADD, "CLIENTTIMETOSLEEP", "Sleeping in %d minutes", account->tosleep - (chsec / 60)); + } else { + tpl_addVar(vars, TPLADD, "CLIENTTIMETOSLEEP", "Sleeping"); + } + tpl_printf(vars, TPLADD, "CLIENTTIMETOSLEEPAPI", "%d", account->tosleep - (chsec / 60)); + } else { + tpl_addVar(vars, TPLADD, "CLIENTTIMETOSLEEPAPI", "undefined"); + } + } +#ifdef CS_CACHEEX_AIO +#if defined(MODULE_CAMD35) || defined (MODULE_CAMD35_TCP) + if(latestclient != NULL && (latestclient->account->cacheex.feature_bitfield || latestclient->c35_extmode > 1)) +#else + if(latestclient != NULL && (latestclient->account->cacheex.feature_bitfield)) +#endif + { + const char *aio_suffix = " (cx-aio)"; + char *new_proto; + if(cs_malloc(&new_proto, cs_strlen(proto)+cs_strlen(aio_suffix)+1)) { + if (!cs_strncat(new_proto, (char *)proto, cs_strlen(proto)+cs_strlen(aio_suffix)+1)) { + cs_log("FIXME!"); + } + if (cs_strncat(new_proto, (char *)aio_suffix, cs_strlen(proto)+cs_strlen(aio_suffix)+1)) { + webif_add_client_proto(vars, latestclient, (const char *)new_proto, apicall); + } else { + cs_log("FIXME!"); + } + free(new_proto); + } + } else { +#endif + webif_add_client_proto(vars, latestclient, proto, apicall); +#ifdef CS_CACHEEX_AIO + } +#endif + + tpl_addVar(vars, TPLADD, "CLASSNAME", classname); + MD5((uint8_t *)account->usr, cs_strlen(account->usr), md5tmp); + int z; + tpl_addVar(vars, TPLADD, "USERMD5","id_"); + for (z = 0; z < MD5_DIGEST_LENGTH; z++) + { + tpl_printf(vars, TPLAPPEND, "USERMD5", "%02x", md5tmp[z]); + } + tpl_addVar(vars, TPLADD, "USERNAME", xml_encode(vars, account->usr)); + tpl_addVar(vars, TPLADD, "USERNAMEENC", urlencode(vars, account->usr)); + if(!existing_insert) + { + tpl_printf(vars, TPLADD, "EXISTING_INS", "'%s'", urlencode(vars, account->usr)); + existing_insert++; + }else + { + tpl_printf(vars, TPLAPPEND, "EXISTING_INS", ",'%s'", urlencode(vars, account->usr)); + } + + if(account->description) + tpl_printf(vars, TPLADD, "DESCRIPTION","%s(%s)",!apicall?" ":"",xml_encode(vars, account->description)); + else + tpl_addVar(vars, TPLADD, "DESCRIPTION", ""); + + if(cfg.http_showpicons && !apicall) + tpl_addVar(vars, TPLADD, "USERBIT", tpl_getTpl(vars, picon_exists(xml_encode(vars, account->usr)) ? "USERICON" : "USERNOICON")); + else + tpl_addVar(vars, TPLADD, "USERBIT", tpl_getTpl(vars, "USERLABEL")); + + char *value = mk_t_group(account->grp); + tpl_addVar(vars, TPLADD, "GROUPS", value); + free_mk_t(value); + tpl_addVar(vars, TPLADD, "STATUS", status); + tpl_addVar(vars, TPLAPPEND, "STATUS", expired); + + if(nrclients > 1) + { + tpl_printf(vars, TPLADD, "UNOTIFY", "%d", nrclients); + tpl_addVar(vars, TPLADDONCE, "CLIENTCOUNTNOTIFIER", tpl_getTpl(vars, "CLIENTCOUNTNOTIFIERBIT")); + } + + //Expirationdate + struct tm timeinfo; + cs_gmtime_r(&account->expirationdate, &timeinfo); + char buf [80]; + strftime(buf, 80, "%Y-%m-%d", &timeinfo); + if(strcmp(buf, "1970-01-01")) { tpl_addVar(vars, TPLADD, "EXPDATE", buf); } + else { tpl_addVar(vars, TPLADD, "EXPDATE", ""); } + + // append row to table template + if(!apicall) + { tpl_addVar(vars, TPLAPPEND, "USERCONFIGS", tpl_getTpl(vars, "USERCONFIGLISTBIT")); } + else if(!filter || strcmp(filter, account->usr) == 0 || strcmp(filter, "all") == 0 || cs_strlen(filter) == 0) + { + if(apicall == 1){ + tpl_addVar(vars, TPLAPPEND, "APIUSERCONFIGS", tpl_getTpl(vars, "APIUSERCONFIGLISTBIT")); + } else if (apicall == 2){ + tpl_printf(vars, TPLADD, "JSONDELIMITER", "%s", (total_users > 1)?",":""); + tpl_addVar(vars, TPLAPPEND, "APIUSERCONFIGS", tpl_getTpl(vars, "JSONUSERBIT")); + } + ++clientcount; + } + } + + tpl_printf(vars, TPLADD, "TOTAL_USERS", "%d", total_users); + tpl_printf(vars, TPLADD, "TOTAL_DISABLED", "%d", disabled_users); + tpl_printf(vars, TPLADD, "TOTAL_EXPIRED", "%d", expired_users); + tpl_printf(vars, TPLADD, "TOTAL_ACTIVE", "%d", total_users - expired_or_disabled_users); + tpl_printf(vars, TPLADD, "TOTAL_CONNECTED", "%d", connected_users); + tpl_printf(vars, TPLADD, "TOTAL_ONLINE", "%d", online_users); + + //CM info + tpl_addVar(vars, TPLADD, "DISPLAYREADERINFO", "hidden"); // no readerinfo in users + set_ecm_info(vars); + + if(!apicall) + { return tpl_getTpl(vars, "USERCONFIGLIST"); } + else + { + if(!filter || clientcount > 0) + { + return tpl_getTpl(vars, (apicall==1)?"APIUSERCONFIGLIST":"JSONUSER"); + } + else + { + tpl_printf(vars, TPLADD, "APIERRORMESSAGE", "Invalid client %s", xml_encode(vars, filter)); + return tpl_getTpl(vars, "APIERROR"); + } + } + +} + +#define ENTITLEMENT_PAGE_SIZE 500 + +#ifdef MODULE_CCCAM +static void print_cards(struct templatevars *vars, struct uriparams *params, struct cc_card **cardarray, int32_t cardsize, + int8_t show_global_list, struct s_reader *rdr, int32_t offset, int32_t apicall) +{ + if(cardarray) + { + uint8_t serbuf[8]; + int32_t i, count = 0; + char provname[83]; + struct cc_card *card; + int32_t cardcount = 0; + int32_t providercount = 0; + int32_t nodecount = 0; + + char *provider = ""; + + // @todo alno: sort by click, 0=ascending, 1=descending (maybe two buttons or reverse on second click) + for(i = offset; i < cardsize; ++i) + { + card = cardarray[i]; + if(count == ENTITLEMENT_PAGE_SIZE) + { break; } + count++; + + if(!apicall) + { + if(show_global_list) + { rdr = card->origin_reader; } + if(rdr) + { tpl_printf(vars, TPLADD, "HOST", "%s:%d", xml_encode(vars, rdr->device), rdr->r_port); } + tpl_printf(vars, TPLADD, "CAID", "%04X", card->caid); + tpl_printf(vars, TPLADD, "CARDTYPE", "%02X", card->card_type); + } + else + { + tpl_printf(vars, TPLADD, "APICARDNUMBER", "%d", cardcount); + tpl_printf(vars, TPLADD, "APICAID", "%04X", card->caid); + tpl_printf(vars, TPLADD, "APICARDTYPE", "%02X", card->card_type); + } + + if(cc_UA_valid(card->hexserial)) //Add UA: + { + cc_UA_cccam2oscam(card->hexserial, serbuf, card->caid); + char tmp[20]; + tpl_printf(vars, TPLAPPEND, "HOST", "
\nUA_OSCam:%s", cs_hexdump(0, serbuf, 8, tmp, 20)); + tpl_printf(vars, TPLAPPEND, "HOST", "
\nUA_CCcam:%s", cs_hexdump(0, card->hexserial, 8, tmp, 20)); + } + if(!apicall) + { + int32_t n; + char channame[CS_SERVICENAME_SIZE]; + int8_t sidname = 0; + LL_ITER its = ll_iter_create(card->goodsids); + struct cc_srvid *srv; + n = 0; + if(strcmp(getParam(params, "button"), "Show detail list") == 0) + { sidname = 1; } + + tpl_addVar(vars, TPLADD, "SERVICESGOOD", ""); + while((srv = ll_iter_next(&its))) + { + if(sidname) + { + tpl_printf(vars, TPLAPPEND, "SERVICESGOOD", "%04X - %s
", srv->sid, xml_encode(vars, get_servicename(cur_client(), srv->sid, 0, card->caid, channame, sizeof(channame)))); + } else { + tpl_printf(vars, TPLAPPEND, "SERVICESGOOD", "%04X%s", srv->sid, ++n % 10 == 0 ? "
\n" : " "); + } + } + + its = ll_iter_create(card->badsids); + n = 0; + tpl_addVar(vars, TPLADD, "SERVICESBAD", ""); + while((srv = ll_iter_next(&its))) + { + if(sidname) + { + tpl_printf(vars, TPLAPPEND, "SERVICESBAD", "%04X - %s
", srv->sid, xml_encode(vars, get_servicename(cur_client(), srv->sid, 0, card->caid, channame, sizeof(channame)))); + } else { + tpl_printf(vars, TPLAPPEND, "SERVICESBAD", "%04X%s", srv->sid, ++n % 10 == 0 ? "
\n" : " "); + } + } + } + + tpl_addVar(vars, TPLADD, "SYSTEM", get_cardsystem_desc_by_caid(card->caid)); + + tpl_printf(vars, TPLADD, "SHAREID", "%08X", card->id); + tpl_printf(vars, TPLADD, "REMOTEID", "%08X", card->remote_id); + tpl_printf(vars, TPLADD, "UPHOPS", "%d", card->hop); + tpl_printf(vars, TPLADD, "MAXDOWN", "%d", card->reshare); + + LL_ITER pit = ll_iter_create(card->providers); + struct cc_provider *prov; + + providercount = 0; + + if(!apicall) + { tpl_addVar(vars, TPLADD, "PROVIDERS", ""); } + else + { tpl_addVar(vars, TPLADD, "PROVIDERLIST", ""); } + + while((prov = ll_iter_next(&pit))) + { + provider = xml_encode(vars, get_provider(prov->prov, card->caid, provname, sizeof(provname))); + + if(!apicall) + { + if(prov->sa[0] || prov->sa[1] || prov->sa[2] || prov->sa[3]) + { + tpl_printf(vars, TPLAPPEND, "PROVIDERS", "%s SA:%02X%02X%02X%02X
\n", provider, prov->sa[0], prov->sa[1], prov->sa[2], prov->sa[3]); + } + else + { + tpl_printf(vars, TPLAPPEND, "PROVIDERS", "%s
\n", provider); + } + } + else + { + if(prov->sa[0] || prov->sa[1] || prov->sa[2] || prov->sa[3]) + { tpl_printf(vars, TPLADD, "APIPROVIDERSA", "%02X%02X%02X%02X", prov->sa[0], prov->sa[1], prov->sa[2], prov->sa[3]); } + else + { tpl_addVar(vars, TPLADD, "APIPROVIDERSA", ""); } + tpl_printf(vars, TPLADD, "APIPROVIDERCAID", "%04X", card->caid); + tpl_printf(vars, TPLADD, "APIPROVIDERPROVID", "%06X", prov->prov); + tpl_printf(vars, TPLADD, "APIPROVIDERNUMBER", "%d", providercount); + tpl_addVar(vars, TPLADD, "APIPROVIDERNAME", xml_encode(vars, provider)); + tpl_addVar(vars, TPLAPPEND, "PROVIDERLIST", tpl_getTpl(vars, "APICCCAMCARDPROVIDERBIT")); + + } + providercount++; + tpl_printf(vars, TPLADD, "APITOTALPROVIDERS", "%d", providercount); + } + + LL_ITER nit = ll_iter_create(card->remote_nodes); + uint8_t *node; + + nodecount = 0; + if(!apicall) { tpl_addVar(vars, TPLADD, "NODES", ""); } + else { tpl_addVar(vars, TPLADD, "NODELIST", ""); } + + while((node = ll_iter_next(&nit))) + { + + if(!apicall) + { + tpl_printf(vars, TPLAPPEND, "NODES", "%02X%02X%02X%02X%02X%02X%02X%02X
\n", + node[0], node[1], node[2], node[3], node[4], node[5], node[6], node[7]); + } + else + { + tpl_printf(vars, TPLADD, "APINODE", "%02X%02X%02X%02X%02X%02X%02X%02X", node[0], node[1], node[2], node[3], node[4], node[5], node[6], node[7]); + tpl_printf(vars, TPLADD, "APINODENUMBER", "%d", nodecount); + tpl_addVar(vars, TPLAPPEND, "NODELIST", tpl_getTpl(vars, "APICCCAMCARDNODEBIT")); + } + nodecount++; + tpl_printf(vars, TPLADD, "APITOTALNODES", "%d", nodecount); + } + + if(!apicall) + { tpl_addVar(vars, TPLAPPEND, "CCCAMSTATSENTRY", tpl_getTpl(vars, "ENTITLEMENTCCCAMENTRYBIT")); } + else + { tpl_addVar(vars, TPLAPPEND, "CARDLIST", tpl_getTpl(vars, "APICCCAMCARDBIT")); } + + cardcount++; + } + // set previous Link if needed + if(offset >= ENTITLEMENT_PAGE_SIZE) + { + tpl_printf(vars, TPLAPPEND, "CONTROLS", " << PREVIOUS < ", + offset - ENTITLEMENT_PAGE_SIZE, + getParam(params, "globallist"), + urlencode(vars, getParam(params, "label"))); + } + + // set next link if needed + if(cardsize > count && offset < cardsize) + { + tpl_printf(vars, TPLAPPEND, "CONTROLS", " > NEXT >> ", + offset + ENTITLEMENT_PAGE_SIZE, + getParam(params, "globallist"), + urlencode(vars, getParam(params, "label"))); + } + + if(!apicall) + { + tpl_printf(vars, TPLADD, "TOTALS", "card count=%d", cardsize); + tpl_addVar(vars, TPLADD, "ENTITLEMENTCONTENT", tpl_getTpl(vars, "ENTITLEMENTCCCAMBIT")); + } + else + { + tpl_printf(vars, TPLADD, "APITOTALCARDS", "%d", cardsize); + } + + } + else + { + if(!apicall) + { + tpl_addVar(vars, TPLADD, "ENTITLEMENTCONTENT", tpl_getTpl(vars, "ENTITLEMENTGENERICBIT")); + tpl_addVar(vars, TPLADD, "LOGHISTORY", "no cards found
\n"); + } + else + { + tpl_printf(vars, TPLADD, "APITOTALCARDS", "%d", 0); + } + } + +} +#endif + +static char *send_oscam_entitlement(struct templatevars *vars, struct uriparams *params, int32_t apicall) +{ + if(!apicall) { setActiveMenu(vars, MNU_READERS); } + char *reader_ = getParam(params, "label"); +#ifdef MODULE_CCCAM +#ifdef MODULE_CCCSHARE + char *sharelist_ = getParam(params, "globallist"); + int32_t show_global_list = sharelist_ && sharelist_[0] == '1'; +#else + int32_t show_global_list = 0; +#endif + + struct s_reader *rdr = get_reader_by_label(getParam(params, "label")); + if(show_global_list || cs_strlen(reader_) || (rdr && rdr->typ == R_CCCAM)) + { + + if(show_global_list || (rdr && rdr->typ == R_CCCAM && rdr->enable)) + { + + if(show_global_list) + { + tpl_addVar(vars, TPLADD, "READERNAME", "GLOBAL"); + tpl_addVar(vars, TPLADD, "APIHOST", "GLOBAL"); + tpl_addVar(vars, TPLADD, "APIHOSTPORT", "GLOBAL"); + } + else + { + tpl_addVar(vars, TPLADD, "READERNAME", xml_encode(vars, rdr->label)); + tpl_addVar(vars, TPLADD, "APIHOST", xml_encode(vars, rdr->device)); + tpl_printf(vars, TPLADD, "APIHOSTPORT", "%d", rdr->r_port); + } + + int32_t offset = atoi(getParam(params, "offset")); //should be 0 if parameter is missed on very first call + int32_t cardsize; +#ifdef MODULE_CCCSHARE + if(show_global_list) + { + int32_t i; + LLIST **sharelist = get_and_lock_sharelist(); + LLIST *sharelist2 = ll_create("web-sharelist"); + for(i = 0; i < CAID_KEY; i++) + { + if(sharelist[i]) + { ll_putall(sharelist2, sharelist[i]); } + } + unlock_sharelist(); + struct cc_card **cardarray = get_sorted_card_copy(sharelist2, 0, &cardsize); + ll_destroy(&sharelist2); + print_cards(vars, params, cardarray, cardsize, 1, NULL, offset, apicall); + NULLFREE(cardarray); + } + else +#endif + { + struct s_client *rc = rdr->client; + struct cc_data *rcc = (rc) ? rc->cc : NULL; + if(rcc && rcc->cards) + { + struct cc_card **cardarray = get_sorted_card_copy(rcc->cards, 0, &cardsize); + print_cards(vars, params, cardarray, cardsize, 0, rdr, offset, apicall); + NULLFREE(cardarray); + } + } + + } + else + { +#else + if(cs_strlen(reader_)) + { + { + struct s_reader *rdr; +#endif + tpl_addVar(vars, TPLADD, "LOGHISTORY", "->"); + // normal non-cccam reader + + rdr = get_reader_by_label(reader_); + + if(rdr) + { + struct s_client *cl = rdr->client; + if(rdr->ll_entitlements) + { + + time_t now = time((time_t *)0); + + struct tm start_t, end_t; + LL_ITER itr = ll_iter_create(rdr->ll_entitlements); + S_ENTITLEMENT *item; + + tpl_addVar(vars, TPLAPPEND, "LOGHISTORY", "
New Structure:
"); + char tbuffer[83]; + int jsondelimiter = 0; + while((item = ll_iter_next(&itr))) + { + localtime_r(&item->start, &start_t); + localtime_r(&item->end, &end_t); + + if(!apicall) + { strftime(tbuffer, 30, "%Y-%m-%d", &start_t); } + else + { strftime(tbuffer, 30, "%Y-%m-%dT%H:%M:%S%z", &start_t); } + tpl_addVar(vars, TPLADD, "ENTSTARTDATE", tbuffer); + + if(!apicall) + { strftime(tbuffer, 30, "%Y-%m-%d", &end_t); } + else + { strftime(tbuffer, 30, "%Y-%m-%dT%H:%M:%S%z", &end_t); } + tpl_addVar(vars, TPLADD, "ENTENDDATE", tbuffer); + + tpl_addVar(vars, TPLADD, "ENTEXPIERED", item->end > now ? "e_valid" : "e_expired"); + tpl_printf(vars, TPLADD, "ENTCAID", "%04X", item->caid); + tpl_printf(vars, TPLADD, "ENTPROVID", "%06X", item->provid); + tpl_printf(vars, TPLADD, "ENTID", "%08X%08X", (uint32_t)(item->id >> 32), (uint32_t)item->id); + tpl_printf(vars, TPLADD, "ENTCLASS", "%08X", item->class); + tpl_addVar(vars, TPLADD, "ENTTYPE", entitlement_type[item->type]); + + char *entresname; + entresname = xml_encode(vars, get_tiername((uint16_t)(item->id & 0xFFFF), item->caid, tbuffer)); + if(!tbuffer[0]) + { entresname = xml_encode(vars, get_provider(item->provid, item->caid, tbuffer, sizeof(tbuffer))); } + tpl_addVar(vars, TPLADD, "ENTRESNAME", entresname); + + if((strcmp(getParam(params, "hideexpired"), "1") != 0) || (item->end > now)) + { tpl_addVar(vars, TPLAPPEND, "READERENTENTRY", tpl_getTpl(vars, "ENTITLEMENTITEMBIT")); } + + if(apicall==2) + { + tpl_printf(vars, TPLAPPEND, "APIENTITLEMENTLIST","%s%s",jsondelimiter?",":"", tpl_getTpl(vars, "JSONENTITLEMENTBIT")); + jsondelimiter++; + } + } + } + + if(cl && cl->typ) + { tpl_printf(vars, TPLADD, "READERTYPE", "%c", cl->typ); } + else + { tpl_addVar(vars, TPLADD, "READERTYPE", "null"); } + tpl_addVar(vars, TPLADD, "READERNAME", xml_encode(vars, rdr->label)); + + int8_t i, j; + for(i = 0; i < 15; i++) { tpl_printf(vars, TPLAPPEND, "READERROM", "%c", rdr->rom[i]); } + if(rdr->hexserial[0] || rdr->hexserial[1]) { i = 0; } + else { i = 2; } + if(rdr->hexserial[6] || rdr->hexserial[7]) { j = 8; } + else { j = 6; } + for(; i < j; i++) { tpl_printf(vars, TPLAPPEND, "READERSERIAL", "%02X%s", rdr->hexserial[i], i < j - 1 ? " " : ""); } + for(i = 0; i < rdr->nprov; i++) + { + for(j = 0; j < 4; j++) { tpl_printf(vars, TPLAPPEND, "READERPROVIDS", "%02X ", rdr->prid[i][j]); } + tpl_addVar(vars, TPLAPPEND, "READERPROVIDS", i == 0 ? "(sysid)
\n" : "
\n"); + } + +#ifdef READER_VIDEOGUARD + //CountryCode Vg card + char add_nds_line = 0; + if(rdr->VgCountryC[0]) + { + for(i = 0; i < 3; i++) { tpl_printf(vars, TPLAPPEND, "READERCOUNTRYC", "%c", rdr->VgCountryC[i]); } + add_nds_line = 1; + } + else + { + tpl_addVar(vars, TPLADD, "READERCOUNTRYC", "n/a"); + } + + //regional code for Vg card + if(rdr->VgRegionC[0]) + { + for(i = 0; i < 8; i++) { tpl_printf(vars, TPLAPPEND, "READER_RCODE", "%c", rdr->VgRegionC[i]); } + add_nds_line = 1; + } + else + { + tpl_addVar(vars, TPLADD, "READER_RCODE", "n/a"); + } + + //Pin Vg card + if(rdr->VgPin) + { + tpl_printf(vars, TPLAPPEND, "READERPIN", "%04i", rdr->VgPin); + add_nds_line = 1; + } + else + { + tpl_addVar(vars, TPLADD, "READERPIN", "n/a"); + } + + //Fuse Vg card + if(rdr->VgFuse) + { + tpl_printf(vars, TPLAPPEND, "READERFUSE", "%02X", rdr->VgFuse); + add_nds_line = 1; + } + + if(caid_is_videoguard(rdr->caid)) + { + tpl_printf(vars, TPLAPPEND, "READERPAYLOAD", "%02X %02X %02X %02X %02X %02X", rdr->VgLastPayload[0], + rdr->VgLastPayload[1], rdr->VgLastPayload[2], rdr->VgLastPayload[3], rdr->VgLastPayload[4], rdr->VgLastPayload[5]); + add_nds_line = 1; + } + + //credit on Vg card + if(rdr->VgCredit) + { + tpl_printf(vars, TPLAPPEND, "READERCREDIT", "%i", rdr->VgCredit); + add_nds_line = 1; + } + else + { + tpl_addVar(vars, TPLADD, "READERCREDIT", "n/a"); + } +#endif + + if(rdr->card_valid_to) + { + struct tm vto_t; + char vtobuffer[30]; + localtime_r(&rdr->card_valid_to, &vto_t); + strftime(vtobuffer, 30, "%Y-%m-%d", &vto_t); + tpl_addVar(vars, TPLADD, "READERCARDVALIDTO", vtobuffer); + } + else + { + tpl_addVar(vars, TPLADD, "READERCARDVALIDTO", "n/a"); + } + + if(rdr->irdId[0]) + { + for(i = 0; i < 4; i++) { tpl_printf(vars, TPLAPPEND, "READERIRDID", "%02X ", rdr->irdId[i]); } + } + else + { + tpl_addVar(vars, TPLADD, "READERIRDID", "n/a"); + } + + if(rdr->card_atr_length) + for(i = 0; i < rdr->card_atr_length; i++) { tpl_printf(vars, TPLAPPEND, "READERATR", "%02X ", rdr->card_atr[i]); } + + if(caid_is_seca(rdr->caid) || caid_is_viaccess(rdr->caid)) + { + if(rdr->maturity == 0xF) + { + tpl_printf(vars, TPLAPPEND, "READERMATURITY", "%s ", "no limit"); + } + else + { + tpl_printf(vars, TPLAPPEND, "READERMATURITY", "%d+", rdr->maturity); + } + } + else + { + tpl_printf(vars, TPLAPPEND, "READERMATURITY", "%s ", "n/a"); + } + + if (rdr->csystem) + tpl_addVar(vars, TPLADD, "READERCSYSTEM", rdr->csystem->desc); + +#ifdef READER_VIDEOGUARD + if(add_nds_line) + { + tpl_addVar(vars, TPLADD, "ENTITLEMENTCONTENTNDS", tpl_getTpl(vars, "ENTITLEMENTBITNDS")); + } +#endif + tpl_addVar(vars, TPLADD, "ENTITLEMENTCONTENT", tpl_getTpl(vars, "ENTITLEMENTBIT")); + } + else + { + tpl_addMsg(vars, "Reader does not exist or is not started!"); + } + } + + } + else + { + tpl_addVar(vars, TPLADD, "ENTITLEMENTCONTENT", tpl_getTpl(vars, "ENTITLEMENTGENERICBIT")); + } + + if(!apicall) + { return tpl_getTpl(vars, "ENTITLEMENTS"); } + else + { + if(apicall==1) + { return tpl_getTpl(vars, "APICCCAMCARDLIST"); } + else + { return tpl_getTpl(vars, "JSONENTITLEMENTS"); } + } +} + +#ifdef WEBIF_LIVELOG +static char *send_oscam_logpoll(struct templatevars * vars, struct uriparams * params) +{ + + uint64_t lastid = 0; + +#ifdef WITH_DEBUG + tpl_addVar(vars, TPLADD, "LOG_DEBUGMENU", tpl_getTpl(vars, "LOGDEBUGMENU")); +#endif + tpl_addVar(vars, TPLADD, "LOG_SIZEMENU", tpl_getTpl(vars, "LOGSIZEMENU")); + tpl_addVar(vars, TPLADD, "TITLEADD1", "Move mouse over log-window to stop scroll"); + + if(strcmp(getParam(params, "lastid"), "start") == 0){ + setActiveMenu(vars, MNU_LIVELOG); + return tpl_getTpl(vars, "LOGPAGE"); + } + else + { + lastid = strtoull(getParam(params, "lastid"), NULL, 10); + } + + char *dot = ""; //Delimiter + +#ifdef WITH_DEBUG + char *debuglvl = getParam(params, "debug"); + if(cs_strlen(debuglvl) > 0) { + int32_t dblvl = atoi(debuglvl); + if(cs_dblevel != dblvl) { + if(dblvl >= 0 && dblvl <= 65535) { cs_dblevel = dblvl; } + cs_log("%s debug_level=%d", "all", cs_dblevel); + } + } + tpl_printf(vars, TPLAPPEND, "DATA","%s\"debug\":\"%d\"", dot, cs_dblevel); + dot = ","; + tpl_printf(vars, TPLAPPEND, "DATA","%s\"maxdebug\":\"%d\"",dot, MAX_DEBUG_LEVELS); +#endif + + if(cfg.loghistorylines == 0){ + tpl_printf(vars, TPLAPPEND, "DATA","%s\"logdisabled\":\"1\"",dot); + return tpl_getTpl(vars, "POLL"); + } + + if(log_history) + { + LL_ITER it = ll_iter_create(log_history); + struct s_log_history *hist; + + tpl_printf(vars, TPLAPPEND, "DATA", "%s\"lines\":[", dot); + + dot = ""; + + while((hist = (struct s_log_history*)ll_iter_next(&it))) + { + char p_usr[32]; + size_t pos1 = strcspn(hist->txt, "\t") + 1; + cs_strncpy(p_usr, hist->txt , pos1 > sizeof(p_usr) ? sizeof(p_usr) : pos1); + + char *p_txt = hist->txt + pos1; + + pos1 = strcspn(p_txt, "\n") + 1; + char str_out[pos1]; + cs_strncpy(str_out, p_txt, pos1); + uint64_t id = hist->counter; + + size_t b64_str_in = cs_strlen(xml_encode(vars, str_out)); + size_t b64_str_out = 32 + BASE64_LENGTH(b64_str_in); + char *b64_str_out_buf; + if(!cs_malloc(&b64_str_out_buf, b64_str_out)) + { continue; } + base64_encode(xml_encode(vars, str_out), b64_str_in, b64_str_out_buf, b64_str_out); + + if(id > lastid){ + tpl_printf(vars, TPLAPPEND, "DATA","%s{\"id\":\"%" PRIu64 "\",\"usr\":\"%s\",\"line\":\"%s\"}", + dot, + id, + urlencode(vars, xml_encode(vars, p_usr)), + b64_str_out_buf); + dot = ","; // next in Array with leading delimiter + } + NULLFREE(b64_str_out_buf); + } + } + + tpl_addVar(vars, TPLAPPEND, "DATA", "]"); + return tpl_getTpl(vars, "POLL"); +} +#endif + +static char *send_oscam_status(struct templatevars * vars, struct uriparams * params, int32_t apicall) +{ + const char *usr; + int32_t lsec, isec, chsec, con, cau = 0; + time_t now = time((time_t *)0); + struct tm lt; + int delimiter=0; + + if(!apicall) + { + setActiveMenu(vars, MNU_STATUS); + if (config_enabled(WITH_LB)) + tpl_addVar(vars, TPLADD, "STATUSCOL14HEAD","LB Value/"); + } + if(strcmp(getParam(params, "action"), "kill") == 0) + { + char *cptr = getParam(params, "threadid"); + struct s_client *cl = NULL; + if(cs_strlen(cptr) > 1) + { sscanf(cptr, "%p", (void **)(void *)&cl); } + + if(cl && is_valid_client(cl)) + { + if(is_dvbapi_usr(cl->account->usr)) + { + cs_log("WebIF from %s requests to kill dvbapi client %s -> ignoring!", cs_inet_ntoa(GET_IP()), cl->account->usr); + } + else + { + kill_thread(cl); + cs_log("Client %s killed by WebIF from %s", cl->account->usr, cs_inet_ntoa(GET_IP())); + } + } + } + + if(strcmp(getParam(params, "action"), "resetuserstats") == 0) + { + clear_info_clients_stats(); + } + if(strcmp(getParam(params, "action"), "resetreaderstats") == 0) + { + clear_info_readers_stats(); + } + if(strcmp(getParam(params, "action"), "restart") == 0) + { + struct s_reader *rdr = get_reader_by_label(getParam(params, "label")); + if(rdr) + { + if(rdr->typ != R_GBOX) + { + add_job(rdr->client, ACTION_READER_RESTART, NULL, 0); + } +#ifdef MODULE_GBOX + else + { + restart_gbox_peer(rdr->label, 0, 0); + } +#endif + cs_log("Reader %s restarted by WebIF from %s", rdr->label, cs_inet_ntoa(GET_IP())); + } + } + + char *debuglvl = getParam(params, "debug"); + if(cs_strlen(debuglvl) > 0) + { +#ifndef WITH_DEBUG + cs_log("*** Warning: Debug Support not compiled in ***"); +#else + int32_t dblvl = atoi(debuglvl); + if(dblvl >= 0 && dblvl <= 65535) { cs_dblevel = dblvl; } + cs_log("%s debug_level=%d", "all", cs_dblevel); +#endif + } + + char *hide = getParam(params, "hide"); + if(cs_strlen(hide) > 0) + { + struct s_client *hideidx = NULL; + sscanf(hide, "%p", (void **)(void *)&hideidx); + + if(hideidx && is_valid_client(hideidx)) + { hideidx->wihidden = 1; } + } + + char *hideidle = getParam(params, "hideidle"); + if(cs_strlen(hideidle) > 0) + { + if(atoi(hideidle) == 2) + { + struct s_client *cl; + for(cl = first_client; cl ; cl = cl->next) + { + if(cl->typ == 's' || cl->typ == 'h' || cl->typ == 'm'){ + cl->wihidden = 0; + } + } + } + else if(atoi(hideidle) == 3) + { + struct s_client *cl; + for(cl = first_client; cl ; cl = cl->next) + { + if(cl->typ == 'r'){ + cl->wihidden = 0; + } + } + } + else if(atoi(hideidle) == 4) + { + struct s_client *cl; + for(cl = first_client; cl ; cl = cl->next) + { + if(cl->typ == 'p'){ + cl->wihidden = 0; + } + } + } + else if(atoi(hideidle) == 5) + { + struct s_client *cl; + for(cl = first_client; cl ; cl = cl->next) + { + if(cl->typ == 'c'){ + cl->wihidden = 0; + } + } + } + else + { + int32_t oldval = cfg.http_hide_idle_clients; + config_set("webif", "httphideidleclients", hideidle); + if(oldval != cfg.http_hide_idle_clients) + { + refresh_oscam(REFR_SERVER); + } + } + } + + if(cfg.http_hide_idle_clients > 0) { tpl_addVar(vars, TPLADD, "HIDEIDLECLIENTSSELECTED1", "selected"); } + else { tpl_addVar(vars, TPLADD, "HIDEIDLECLIENTSSELECTED0", "selected"); } + + tpl_addVar(vars, TPLADD, "SRVIDFILE", use_srvid2 ? "oscam.srvid2" : "oscam.srvid"); + + int32_t user_count_all = 0, user_count_shown = 0, user_count_active = 0; + int32_t reader_count_all = 0, reader_count_conn = 0, reader_count_off = 0; + int32_t proxy_count_all = 0, proxy_count_conn = 0, proxy_count_off = 0; + int32_t server_count_all = 0, server_count_shown = 0, server_count_hidden = 0; + int32_t monitor_count_all = 0, monitor_count_shown = 0; + int32_t shown; + + int32_t total_readers = 0; + int32_t active_readers = 0; + int32_t disabled_readers = 0; + int32_t connected_readers = 0; + + struct s_client *cl; + int8_t filtered; + + cs_readlock(__func__, &readerlist_lock); + cs_readlock(__func__, &clientlist_lock); + for(cl = first_client; cl ; cl = cl->next) + { +#ifdef CS_CACHEEX_AIO +#if defined(MODULE_CCCAM) && defined(CS_CACHEEX) + struct cc_data *cc = cl->cc; +#endif +#endif + if(cl->kill) { continue; } +#ifdef CS_CACHEEX + if(get_module(cl)->listenertype != LIS_CSPUDP) + { +#endif + + // Reset template variables + tpl_addVar(vars, TPLADD, "LBLRPSTRVALUE", ""); + tpl_addVar(vars, TPLADD, "CLIENTLBVALUE", ""); + tpl_addVar(vars, TPLADD, "LASTREADER", ""); + tpl_addVar(vars, TPLADD, "CLIENTPROTO", ""); + tpl_addVar(vars, TPLADD, "CLIENTDESCRIPTION", ""); + tpl_addVar(vars, TPLADD, "CLIENTLASTRESPONSETIME", ""); + tpl_addVar(vars, TPLADD, "CLIENTLASTRESPONSETIMEHIST", ""); + tpl_addVar(vars, TPLADD, "UPICMISSING" , ""); + tpl_addVar(vars, TPLADD, "ENTITLEMENTS", ""); + + if(cl->typ == 'c') + { user_count_all++; } + else if(cl->typ == 'p') + { + proxy_count_all++; + if((cl->reader->typ == R_GBOX && cl->reader->card_status != CARD_INSERTED && cl->reader->card_status != NO_CARD) || + (cl->reader->typ != R_GBOX && cl->reader->card_status != CARD_INSERTED)) + { proxy_count_off++; } + } + else if(cl->typ == 'r') + { reader_count_all++; if(cl->reader->card_status != CARD_INSERTED) { reader_count_off++; } } + else if(cl->typ == 's' || cl->typ == 'h') + { server_count_all++; if(cl->wihidden) {server_count_hidden++;} } + else if(cl->typ == 'm') + { monitor_count_all++; } + + shown = 0; + if(cl->wihidden != 1) + { + filtered = !(cfg.http_hide_idle_clients != 1 || cl->typ != 'c' || (now - cl->lastecm) <= cfg.hideclient_to); + if(!filtered && cfg.http_hide_type) + { + char *p = cfg.http_hide_type; + while(*p && !filtered) + { + char type = *p++; +#ifdef CS_CACHEEX + filtered = (type == cl->typ) || (type == 'x' && (cl->typ == 'p' || cl->typ == 'r') && (cl->reader && cl->reader->cacheex.mode)); +#else + filtered = (type == cl->typ); +#endif + } + } + + if(!filtered) + { + if(cl->typ == 'c') + { + user_count_shown++; + if(cfg.http_hide_idle_clients != 1 && cfg.hideclient_to > 0 && (now - cl->lastecm) <= cfg.hideclient_to) + { + user_count_active++; + } + } + else if(cl->typ == 's' || cl->typ == 'h') + { + server_count_shown++; + } + else if(cl->typ == 'm') + { + monitor_count_shown++; + } + else if(cl->typ == 'r') + { + reader_count_conn++; + } + else if(cl->typ == 'p') + { + proxy_count_conn++; + } + + if(cl->typ == 'c' || cl->typ == 'r' || cl->typ == 'p') + { + if(cl->lastecm >= cl->login && cl->lastecm >= cl->logout) { isec = now - cl->lastecm; } + else if(cl->logout >= cl->login) { isec = now - cl->logout; } + else { isec = now - cl->login; } + } + else { isec = now - cl->last; } + + shown = 1; + lsec = now - cl->login; + chsec = now - cl->lastswitch; + usr = username(cl); + + if((cl->typ == 'r') || (cl->typ == 'p')) { usr = cl->reader->label; } + + if(cl->dup) { con = 2; } + else if((cl->tosleep) && (now - cl->lastswitch > cl->tosleep)) { con = 1; } + else { con = 0; } + + // no AU reader == 0 / AU ok == 1 / Last EMM > aulow == -1 + if(cl->typ == 'c' || cl->typ == 'p' || cl->typ == 'r') + { + if((cl->typ == 'c' && ll_count(cl->aureader_list) == 0) || ((cl->typ == 'p' || cl->typ == 'r') && cl->reader->audisabled)) { cau = 0; } + else if((now - cl->lastemm) / 60 > cfg.aulow) { cau = -1; } + else { cau = 1; } + + if(cau == 0) + { + tpl_addVar(vars, TPLADD, "CLIENTCAUHTTP", "OFF"); + } + else + { + if(cau == -1) + { tpl_addVar(vars, TPLADD, "CLIENTCAUHTTP", !apicall?"ON":""); } + else + { tpl_addVar(vars, TPLADD, "CLIENTCAUHTTP", !apicall?"ACTIVE":""); } + tpl_addVar(vars, TPLAPPEND, "CLIENTCAUHTTP", !apicall?"":""); + if(cl->typ == 'c') + { + struct s_reader *rdr; + LL_ITER itr = ll_iter_create(cl->aureader_list); + while((rdr = ll_iter_next(&itr))) + { + if(rdr->audisabled) + { tpl_printf(vars, TPLAPPEND, "CLIENTCAUHTTP", "(%s)
", xml_encode(vars, rdr->label)); } + else + { tpl_printf(vars, TPLAPPEND, "CLIENTCAUHTTP", "%s
", xml_encode(vars, rdr->label)); } + } + } + else { tpl_addVar(vars, TPLAPPEND, "CLIENTCAUHTTP", xml_encode(vars, cl->reader->label)); } + tpl_addVar(vars, TPLAPPEND, "CLIENTCAUHTTP", !apicall?"":""); + } + } + else + { + cau = 0; + tpl_addVar(vars, TPLADD, "CLIENTCAUHTTP", ""); + } + localtime_r(&cl->login, <); + + if(cl->typ == 'c' || cl->typ == 'm') + { + if(cl->account && cl->account->description) + tpl_printf(vars, TPLADD, "CLIENTDESCRIPTION","%s(%s)",!apicall?" ":"",xml_encode(vars, cl->account->description)); + else + tpl_addVar(vars, TPLADD, "CLIENTDESCRIPTION", ""); + } + else if(cl->typ == 'p' || cl->typ == 'r') + { + if(cl->reader && cl->reader->description) + tpl_printf(vars, TPLADD, "CLIENTDESCRIPTION","%s(%s)",!apicall?" ":"",xml_encode(vars, cl->reader->description)); + else + tpl_addVar(vars, TPLADD, "CLIENTDESCRIPTION", ""); + } + if(!apicall) + { + tpl_addVar(vars, TPLADD, "LBL", xml_encode(vars, usr)); + tpl_printf(vars, TPLADD, "CID", "%p", cl); + if(cl->typ == 'c' || cl->typ == 'm') + { + tpl_addVar(vars, TPLADD, "TARGET", "User"); + tpl_addVar(vars, TPLADD, "CSIDX", tpl_getTpl(vars, "STATUSKBUTTON")); + } + else if(cl->typ == 'p') + { + tpl_addVar(vars, TPLADD, "TARGET", "Proxy"); + tpl_addVar(vars, TPLADD, "LBLENC", urlencode(vars, usr)); + tpl_addVar(vars, TPLADD, "CSIDX", tpl_getTpl(vars, "STATUSRBUTTON")); + } + else if(cl->typ == 'r') + { + tpl_addVar(vars, TPLADD, "TARGET", "Reader"); + tpl_addVar(vars, TPLADD, "LBLENC", urlencode(vars, usr)); + tpl_addVar(vars, TPLADD, "CSIDX", tpl_getTpl(vars, "STATUSRBUTTON")); + } + else if (cl->typ == 'h' || cl->typ == 's') + { + tpl_addVar(vars, TPLADD, "TARGET", "Server"); + tpl_addVar(vars, TPLADD, "CSIDX", ""); + } + tpl_addVar(vars, TPLADD, "HIDEIDX", tpl_getTpl(vars, "STATUSHBUTTON")); + tpl_printf(vars, TPLADD, "CSIDXPLAIN", "id_%p", cl); + } + else + { + tpl_printf(vars, TPLADD, "HIDEIDX", "%p", cl); + tpl_printf(vars, TPLADD, "CSIDX", "id_%p", cl); + } + tpl_printf(vars, TPLADD, "CLIENTTYPE", "%c", cl->typ); + tpl_printf(vars, TPLADD, "CLIENTCNR", "%d", get_threadnum(cl)); + tpl_addVar(vars, TPLADD, "CLIENTUSER", xml_encode(vars, usr)); + + tpl_addVar(vars, TPLADD, "STATUSUSERICON", xml_encode(vars, usr)); + if (cl->typ == 'c' || cl->typ == 'm') + { + tpl_addVar(vars, TPLADD, "USERNAME", xml_encode(vars, usr)); + tpl_addVar(vars, TPLADD, "USERENC", urlencode(vars, usr)); + } + else if (cl->typ == 'p' || cl->typ == 'r') + { + tpl_addVar(vars, TPLADD, "READERNAME", xml_encode(vars, usr)); + tpl_addVar(vars, TPLADD, "READERNAMEENC", urlencode(vars, usr)); + } + + bool picon_shown = false; + const char *status_user_icon_tpl = NULL; + + char picon_name[32]; + if(cfg.http_showpicons) + { + if(picon_exists(xml_encode(vars, usr))) + { + switch (cl->typ) + { + case 'm': // Fall through + case 'c': status_user_icon_tpl = "SUSERICON"; picon_shown = true; break; + case 'p': // Fall through + case 'r': status_user_icon_tpl = "SREADERICON"; picon_shown = true; break; + } + } + else + tpl_printf(vars, TPLADD, "UPICMISSING", "%smissing icon: IC_%s.tpl",!apicall?" ":"",xml_encode(vars, usr)); + } + + if (!picon_shown) + { + switch (cl->typ) + { + case 'm': // Fall through + case 'c': status_user_icon_tpl = "SUSER"; break; + case 'p': // Fall through + case 'r': status_user_icon_tpl = "SREADER"; break; + } + } + + if (status_user_icon_tpl) + tpl_addVar(vars, TPLADD, "STATUSUSERICON", tpl_getTpl(vars, status_user_icon_tpl)); + + tpl_printf(vars, TPLADD, "CLIENTCAU", "%d", cau); + if(!apicall) + { + if(cl->typ == 'c' || cl->typ == 'p' || cl->typ == 'r') + { + if(cl->crypted) { tpl_addVar(vars, TPLADD, "CLIENTCRYPTED", "ON"); } + else { tpl_addVar(vars, TPLADD, "CLIENTCRYPTED", "OFF"); } + } + else { tpl_addVar(vars, TPLADD, "CLIENTCRYPTED", ""); } + } + else { tpl_printf(vars, TPLADD, "CLIENTCRYPTED", "%d", cl->crypted); } + + if(cl->typ == 'r' && cl->reader && !is_network_reader(cl->reader)) + { tpl_addVar(vars, TPLADD, "CLIENTIP", "local"); } + else if(IP_ISSET(cl->ip)) + { tpl_addVar(vars, TPLADD, "CLIENTIP", cs_inet_ntoa(cl->ip)); } + else if((cl->typ == 'p' || cl->typ == 'r') && cl->reader && cl->reader->tcp_connected) + { tpl_addVar(vars, TPLADD, "CLIENTIP", "camd.socket"); } + else if(cl->typ == 'c' && cl->login > cl->logout) + { tpl_addVar(vars, TPLADD, "CLIENTIP", "camd.socket"); } + else + { tpl_addVar(vars, TPLADD, "CLIENTIP", ""); } + + tpl_printf(vars, TPLADD, "CLIENTPORT", "%d", cl->port); + const char *proto = client_get_proto(cl); +#ifdef CS_CACHEEX_AIO + if(cl && + ( (cl->typ == 'c' && cl->account && cl->account->cacheex.feature_bitfield) +#if defined(MODULE_CAMD35) || defined (MODULE_CAMD35_TCP) + || (cl->c35_extmode > 1) +#endif +#ifdef MODULE_CCCAM + || (cc && cc->extended_lg_flagged_cws) +#endif + || (cl->typ == 'p' && cl->reader && cl->reader->cacheex.feature_bitfield)) + ) + { + const char *aio_suffix = " (cx-aio)"; + char *new_proto; + if(cs_malloc(&new_proto, cs_strlen(proto)+cs_strlen(aio_suffix)+1)) { + new_proto[0] = '\0'; + if (!cs_strncat(new_proto, (char *)proto, cs_strlen(proto)+cs_strlen(aio_suffix)+1)) { + cs_log("FIXME!"); + } + if (cs_strncat(new_proto, (char *)aio_suffix, cs_strlen(proto)+cs_strlen(aio_suffix)+1)) { + webif_add_client_proto(vars, cl, (const char*)new_proto, apicall); + } else { + cs_log("FIXME!"); + } + free(new_proto); + } + } else { +#endif + webif_add_client_proto(vars, cl, proto, apicall); +#ifdef CS_CACHEEX_AIO + } +#endif + if(!apicall) + { + if((cl->typ != 'p' && cl->typ != 'r') || cl->reader->card_status == CARD_INSERTED) + { + tpl_printf(vars, TPLADD, "CLIENTLOGINDATE", "%02d.%02d.%02d
%02d:%02d:%02d", lt.tm_mday, lt.tm_mon + 1, lt.tm_year % 100, lt.tm_hour, lt.tm_min, lt.tm_sec); + tpl_addVar(vars, TPLADD, "CLIENTLOGINSECS", sec2timeformat(vars, lsec)); + } + else + { + tpl_addVar(vars, TPLADD, "CLIENTLOGINDATE", ""); + tpl_addVar(vars, TPLADD, "CLIENTLOGINSECS", ""); + } + } + else + { + tpl_printf(vars, TPLADD, "CLIENTLOGINDATEFMT", "%02d.%02d.%02d %02d:%02d:%02d", lt.tm_mday, lt.tm_mon + 1, lt.tm_year % 100, lt.tm_hour, lt.tm_min, lt.tm_sec); + char tbuffer [30]; + strftime(tbuffer, 30, "%Y-%m-%dT%H:%M:%S%z", <); + tpl_addVar(vars, TPLADD, "CLIENTLOGINDATE", tbuffer); + tpl_printf(vars, TPLADD, "CLIENTLOGINSECS", "%d", lsec); + } + + //load historical values from ringbuffer + char *value = get_ecm_historystring(cl); + tpl_addVar(vars, TPLADD, "CLIENTLASTRESPONSETIMEHIST", value); + free_mk_t(value); + + if((isec < cfg.hideclient_to || cfg.hideclient_to == 0 || is_dvbapi_usr(cl->account->usr)) && (cl->typ == 'c' || cl->typ == 'p' || cl->typ == 'r')) + { + if(((cl->typ == 'c')) && (cl->lastreader[0])) + { + tpl_printf(vars, TPLADD, "MSVALUE", PRINTF_LOCAL_D, cl->cwlastresptime); + if(apicall) + { + tpl_addVar(vars, TPLADD, "LASTREADER", (cl->last_caid == NO_CAID_VALUE || isec > cfg.hideclient_to ) ? "" : cl->lastreader); + tpl_addVar(vars, TPLADD, "READERNAMEENC", urlencode(vars, cl->lastreader)); + } + else + { +#ifdef WITH_LB + tpl_addVar(vars, TPLADD, "LBLVALUE", xml_encode(vars, cl->lastreader)); + if(strstr(cl->lastreader, " (cache)")) + { + char lastreader_tmp[cs_strlen(cl->lastreader) - 8]; + tpl_addVar(vars, TPLADD, "CLIENTLBVALUE", tpl_getVar(vars, "LBLRPSTRVALUE")); + cs_strncpy(lastreader_tmp, cl->lastreader, sizeof(lastreader_tmp)); + tpl_addVar(vars, TPLADD, "LBLVALUEENC", urlencode(vars, lastreader_tmp)); + tpl_addVar(vars, TPLADD, "LBLVALUETITLE", xml_encode(vars, lastreader_tmp)); + } + else + { + tpl_addVar(vars, TPLADD, "LBLVALUEENC", urlencode(vars, cl->lastreader)); + tpl_addVar(vars, TPLADD, "LBLVALUETITLE", xml_encode(vars, cl->lastreader)); + } + tpl_addVar(vars, TPLAPPEND, "CLIENTLBVALUE", tpl_getTpl(vars, "CLIENTLBLVALUEBIT")); +#else + tpl_printf(vars, TPLAPPEND, "CLIENTLBVALUE", "%s (%'d ms)", xml_encode(vars, cl->lastreader), cl->cwlastresptime); +#endif + } + if(cl->last_caid == NO_CAID_VALUE || isec > cfg.hideclient_to) tpl_addVar(vars, TPLADD, "CLIENTLBVALUE", ""); + } + if(cl->last_caid != NO_CAID_VALUE || cl->last_srvid != NO_SRVID_VALUE) + { + char channame[CS_SERVICENAME_SIZE]; + const char *lastprovidername; + + get_servicename_or_null(cl, cl->last_srvid, cl->last_provid, cl->last_caid, channame, sizeof(channame)); + if(channame[0] == '\0') + { + cs_strncpy(channame, "unknown", sizeof(channame)); + } + + lastprovidername = get_cl_lastprovidername(cl); + + tpl_printf(vars, TPLADD, "CLIENTCAID", "%04X", cl->last_caid); + tpl_printf(vars, TPLADD, "CLIENTPROVID", "%06X", cl->last_provid); + tpl_printf(vars, TPLADD, "CLIENTSRVID", "%04X", cl->last_srvid); + tpl_printf(vars, TPLADD, "CLIENTSRVPROVIDER", "%s%s%s", (lastprovidername[0] != '\0' && strcmp(lastprovidername, " ")) ? " [" : "", xml_encode(vars, lastprovidername), (lastprovidername[0] != '\0' && strcmp(lastprovidername, " ")) ? "]" : ""); + tpl_addVar(vars, TPLADD, "CLIENTSRVNAME", xml_encode(vars, channame)); + tpl_printf(vars, TPLADD, "CLIENTLASTRESPONSETIME", "%d", cl->cwlastresptime ? cl->cwlastresptime : 1); + tpl_addVar(vars, TPLADD, "CLIENTSRVTYPE", cl->last_srvidptr && cl->last_srvidptr->type ? xml_encode(vars, cl->last_srvidptr->type) : ""); + tpl_addVar(vars, TPLADD, "CLIENTSRVDESCRIPTION", cl->last_srvidptr && cl->last_srvidptr->desc ? xml_encode(vars, cl->last_srvidptr->desc) : ""); + tpl_addVar(vars, TPLADD, "CLIENTTIMEONCHANNEL", sec2timeformat(vars, chsec)); + if(cfg.http_showpicons && cl->last_srvid) + { + char picon_channame[30]; + int8_t picon_ok = 0; + + get_picon_servicename_or_null(cl, cl->last_srvid, cl->last_provid, cl->last_caid, picon_channame, sizeof(picon_channame)); + if(picon_channame[0]) + { + snprintf(picon_name, sizeof(picon_name) / sizeof(char) - 1, "%s", picon_channame); + picon_ok = picon_exists(picon_name); + if(picon_ok) tpl_addVar(vars, TPLADD, "PICONNAME", picon_name); + + if(!picon_ok && picon_servicename_remve_hd(picon_channame, sizeof(picon_channame))) + { + snprintf(picon_name, sizeof(picon_name) / sizeof(char) - 1, "%s", picon_channame); + picon_ok = picon_exists(picon_name); + if(picon_ok) tpl_addVar(vars, TPLADD, "PICONNAME", picon_name); + } + } + if(!picon_ok) + { + snprintf(picon_name, sizeof(picon_name) / sizeof(char) - 1, "%04X_%06X_%04X", cl->last_caid, cl->last_provid, cl->last_srvid); + tpl_addVar(vars, TPLADD, "PICONNAME", picon_name); + picon_ok = picon_exists(picon_name); + } + if(!picon_ok) + { + snprintf(picon_name, sizeof(picon_name) / sizeof(char) - 1, "%04X_%04X", cl->last_caid, cl->last_srvid); + picon_ok = picon_exists(picon_name); + if(picon_ok) tpl_addVar(vars, TPLADD, "PICONNAME", picon_name); + } + if(!picon_ok) + { + snprintf(picon_name, sizeof(picon_name) / sizeof(char) - 1, "0000_%04X", cl->last_srvid); + picon_ok = picon_exists(picon_name); + if(picon_ok) tpl_addVar(vars, TPLADD, "PICONNAME", picon_name); + } + if(picon_ok) + { + tpl_addVar(vars, TPLADDONCE, "CURRENTPICON", tpl_getTpl(vars, "CLIENTCURRENTCHANNELPIC")); + } + else + { + tpl_addVar(vars, TPLADDONCE, "CURRENTPICON", tpl_getTpl(vars, "CLIENTCURRENTCHANNEL")); + tpl_addVar(vars, TPLADD, "PICONNAME", ""); + } + } + else + { + tpl_addVar(vars, TPLADDONCE, "CURRENTPICON", tpl_getTpl(vars, "CLIENTCURRENTCHANNELBIT")); + tpl_addVar(vars, TPLADD, "PICONNAME", "0000_0000"); + } + } + else + { + tpl_addVar(vars, TPLADD, "CLIENTCAID", "0000"); + tpl_addVar(vars, TPLADD, "CLIENTPROVID", "000000"); + tpl_printf(vars, TPLADD, "CLIENTSRVID", "0000"); + } + } + else + { + tpl_addVar(vars, TPLADD, "CLIENTCAID", "0000"); + tpl_addVar(vars, TPLADD, "CLIENTPROVID", "000000"); + tpl_addVar(vars, TPLADD, "CLIENTSRVID", "0000"); + tpl_addVar(vars, TPLADD, "CURRENTPICON", ""); + tpl_addVar(vars, TPLADD, "CLIENTSRVPROVIDER", ""); + tpl_addVar(vars, TPLADD, "CLIENTSRVNAME", ""); + tpl_addVar(vars, TPLADD, "CLIENTSRVTYPE", ""); + tpl_addVar(vars, TPLADD, "CLIENTSRVDESCRIPTION", ""); + tpl_addVar(vars, TPLADD, "CLIENTLBVALUE", ""); + tpl_addVar(vars, TPLADD, "CLIENTTIMEONCHANNEL", ""); + } + + if(!apicall) + { + tpl_addVar(vars, TPLADD, "CLIENTIDLESECS", sec2timeformat(vars, isec)); + + if((cl->typ != 'p' && cl->typ != 'r') || cl->reader->card_status == CARD_INSERTED) + { tpl_addVar(vars, TPLADD, "CLIENTIDLESECSCLASS", "idlesec_normal"); } + else + { tpl_addVar(vars, TPLADD, "CLIENTIDLESECSCLASS", "idlesec_alert"); } + } + else + { + tpl_printf(vars, TPLADD, "CLIENTIDLESECS", "%d", isec); + } + + if(con == 2) { tpl_addVar(vars, TPLADD, "CLIENTCON", "Duplicate"); } + else if(con == 1) { tpl_addVar(vars, TPLADD, "CLIENTCON", "Sleep"); } + else + { + struct s_reader *rdr = cl->reader; + char *txt = "OK"; + if(!rdr && (cl->typ == 'r' || cl->typ == 'p')) { txt = "UNKNOWN"; } + + else if(cl->typ == 'r' || cl->typ == 'p') //reader or proxy + { +#ifdef WITH_LB + if(rdr->lbvalue) + { + tpl_printf(vars, TPLADD, "LBLRPSTRVALUE", "%d", rdr->lbvalue); + } + else + { + tpl_addVar(vars, TPLADD, "LBLRPSTRVALUE", "no data"); + } + tpl_addVar(vars, TPLADD, "LBLRPVALUE", rdr->label); + tpl_addVar(vars, TPLADD, "LBLRPVALUEENC", urlencode(vars, rdr->label)); + tpl_addVar(vars, TPLADD, "CLIENTLBVALUE", tpl_getTpl(vars, "CLIENTLBLVALUERP")); +#else + tpl_addVar(vars, TPLADD, "CLIENTLBVALUE", tpl_getVar(vars, "LBLRPSTRVALUE")); +#endif + switch(rdr->card_status) + { + case NO_CARD: + if(rdr->typ == R_GBOX) + { txt = "ONL"; } + else + { txt = "OFF"; } + break; + case UNKNOWN: + txt = "UNKNOWN"; + break; + case READER_DEVICE_ERROR: + txt = "READER DEVICE ERROR"; + break; + case CARD_NEED_INIT: + if(rdr->typ == R_GBOX) + { txt = "OFFLINE"; } +#ifdef CS_CACHEEX + else if (cl->reader->cacheex.mode > 0) + { txt = "CCcam CacheEX"; } +#endif + else + { txt = "NEEDINIT"; } + break; + case CARD_INSERTED: + if(cl->typ == 'p') + { + if(rdr->typ == R_GBOX) + { txt = "ONL"; } + else + { txt = "CONNECTED"; } + } + else + { txt = "CARDOK"; } + break; + case CARD_FAILURE: + txt = "ERROR"; + break; + default: + txt = "UNDEF"; + } +#ifdef MODULE_GBOX + if(rdr->typ == R_GBOX) + { + struct gbox_peer *peer = cl->gbox; + char gbx_txt[45]; + memset(gbx_txt, 0, sizeof(gbx_txt)); + if(!strcmp(txt, "OFFLINE")) + { + snprintf(gbx_txt, sizeof(gbx_txt), "%s | ID: %04X", txt, peer->gbox.id); + } + else + { + snprintf(gbx_txt, sizeof(gbx_txt), "%s | crd: %d | ID: %04X", txt, gbox_count_peer_cards(peer->gbox.id), peer->gbox.id); + } + txt = gbx_txt; + } +#endif + } + + tpl_addVar(vars, TPLADD, "CLIENTCON", txt); + + if(rdr && (cl->typ == 'r')) //reader + { + if(rdr->ll_entitlements) + { + LL_ITER itr = ll_iter_create(rdr->ll_entitlements); + S_ENTITLEMENT *ent; + uint16_t total_ent = 0; + uint16_t active_ent = 0; + struct tm end_t; + tpl_addVar(vars, TPLADD, "TMPSPAN", ""); + while((ent = ll_iter_next(&itr))) + { + total_ent++; + if((ent->end > now) && (ent->type != 7)) + { + if(active_ent) {tpl_addVar(vars, TPLAPPEND, "TMPSPAN", "
");} + active_ent++; + localtime_r(&ent->end, &end_t); + tpl_printf(vars, TPLAPPEND, "TMPSPAN", "%04X@%06X
exp:%04d/%02d/%02d", + ent->caid, ent->provid, + end_t.tm_year + 1900, end_t.tm_mon + 1, end_t.tm_mday); + tpl_printf(vars, TPLAPPEND, "ENTITLEMENTS", "%s{\"caid\":\"%04X\",\"provid\":\"%06X\",\"exp\":\"%04d/%02d/%02d\"}", + active_ent > 1 ? ",": "", + ent->caid, ent->provid, + end_t.tm_year + 1900, end_t.tm_mon + 1, end_t.tm_mday); + } + } + tpl_printf(vars, TPLADD, "TOTENTITLEMENTS", "%d", total_ent); + if(((total_ent) && (active_ent == 0)) || (total_ent == 0)) + { + tpl_addVar(vars, TPLAPPEND, "TMPSPAN", "No active entitlements found"); + } + tpl_addVar(vars, TPLAPPEND, "TMPSPAN", ""); + if(active_ent) + { + tpl_printf(vars, TPLADD, "TMP", "(%d entitlement%s)", active_ent, (active_ent != 1) ? "s" : ""); + } + else + { + tpl_addVar(vars, TPLADD, "TMP", "(no entitlements)"); + } + tpl_addVar(vars, TPLADD, "ENTLABEL", urlencode(vars, cl->reader->label)); + tpl_addVar(vars, TPLADD, "ENTVALUE", active_ent > 0 ? "" : "1"); + if (!apicall) tpl_addVar(vars, TPLAPPEND, "CLIENTCON", tpl_getTpl(vars, "FOUNDENTITLEMENTS")); + } + else + { + tpl_addVar(vars, TPLADD, "ENTLABEL", urlencode(vars, cl->reader->label)); + if (!apicall) tpl_addVar(vars, TPLAPPEND, "CLIENTCON", tpl_getTpl(vars, "NOENTITLEMENTS")); + } + } +#ifdef MODULE_CCCAM + if(!apicall || apicall == 2) + { + if(rdr && (cl->typ == 'r' || cl->typ == 'p') && strncmp(proto, "cccam", 5) == 0 && rdr->tcp_connected && rdr->card_status != CARD_FAILURE) + { + struct cc_data *rcc = cl->cc; + if(rcc) + { + LLIST *cards = rcc->cards; + if(cards) + { + int32_t cnt = ll_count(cards); + int32_t locals = rcc->num_hop1; + if(!apicall) + { + tpl_printf(vars, TPLADD, "TMP", "(%d of %d card%s)", locals, cnt, (cnt > 1) ? "s" : ""); + tpl_printf(vars, TPLADD, "CCCOUNT", "%d", cnt); + tpl_printf(vars, TPLADD, "CCCHOP1", "%d", rcc->num_hop1); + tpl_printf(vars, TPLADD, "CCCHOP2", "%d", rcc->num_hop2); + tpl_printf(vars, TPLADD, "CCCHOPX", "%d", rcc->num_hopx); + tpl_printf(vars, TPLADD, "CCCCURR", "%d", cl->reader->currenthops); + tpl_printf(vars, TPLADD, "CCCRES0", "%d", rcc->num_reshare0); + tpl_printf(vars, TPLADD, "CCCRES1", "%d", rcc->num_reshare1); + tpl_printf(vars, TPLADD, "CCCRES2", "%d", rcc->num_reshare2); + tpl_printf(vars, TPLADD, "CCCRESX", "%d", rcc->num_resharex); + tpl_addVar(vars, TPLADD, "TMPSPAN", tpl_getTpl(vars, "CCENTITLEMENTS")); + tpl_addVar(vars, TPLADD, "CCCLABEL", urlencode(vars, cl->reader->label)); + tpl_addVar(vars, TPLADD, "CCCRESHARE", rcc->num_reshare0 > 0 ? "1" : ""); + tpl_addVar(vars, TPLADD, "CCCTMP", tpl_getVar(vars, "TMP")); + tpl_addVar(vars, TPLADD, "CCCTMPSPAN", tpl_getVar(vars, "TMPSPAN")); + tpl_addVar(vars, TPLAPPEND, "CLIENTCON", tpl_getTpl(vars, "CCENTITLETOOLTIP")); + } + if (apicall == 2) + { + tpl_addVar(vars, TPLADD, "READERNAMEENC", urlencode(vars, cl->reader->label)); + tpl_printf(vars, TPLADD, "ENTITLEMENTS", "{\"locals\":\"%d\",\"cccount\":\"%d\",\"ccchop1\":\"%d\",\"ccchop2\":\"%d\",\"ccchopx\":\"%d\",\"ccccurr\":\"%d\",\"cccres0\":\"%d\",\"cccres1\":\"%d\",\"cccres2\":\"%d\",\"cccresx\":\"%d\",\"cccreshare\":\"%s\"}", + locals, cnt, rcc->num_hop1, rcc->num_hop2, rcc->num_hopx, cl->reader->currenthops, + rcc->num_reshare0, rcc->num_reshare1, rcc->num_reshare2, rcc->num_resharex, + rcc->num_reshare0 > 0 ? "1" : ""); + } + cs_log_dbg(D_TRACE, "Reader %s has total %d local%s hop1 %d hopx %d from total of %d card%s", cl->reader->label, locals, (locals > 1) ? "s" : "", rcc->num_hop2, rcc->num_hopx, cnt, (cnt > 1) ? "s" : ""); + } + } + } + } +#endif + } + } + } + if(!apicall) + { + // select right suborder + if(cl->typ == 'c') + { + if(shown) { tpl_addVar(vars, TPLAPPEND, "CLIENTSTATUS", tpl_getTpl(vars, "CLIENTSTATUSBIT")); } + if(cfg.http_hide_idle_clients != 1 && cfg.hideclient_to > 0) + { + tpl_printf(vars, TPLADD, "UCAC", "%d", user_count_active); + tpl_printf(vars, TPLADD, "CFGH", "%d", cfg.hideclient_to); + tpl_addVar(vars, TPLADD, "CHEADADD", tpl_getTpl(vars, "CLIENTHEADLINEADD")); + } + + tpl_printf(vars, TPLADD, "UCS", "%d", user_count_shown); + tpl_printf(vars, TPLADD, "UCA", "%d", user_count_all); + tpl_addVar(vars, TPLADD, "HIDEIDLE", "5"); + tpl_addVar(vars, TPLADD, "SHOWHIDDEN", "User"); + tpl_addVar(vars, TPLADD, "XHEAD", tpl_getTpl(vars, "CLIENTHEADLINE")); + tpl_addVar(vars, TPLADD, "CLIENTOPTIONADD", tpl_getTpl(vars, "CLIENTHEADLINEBIT")); + tpl_addVar(vars, TPLADD, "CLIENTHEADLINE", tpl_getTpl(vars, "STATUSHEADLINE")); + tpl_addVar(vars, TPLADD, "CLIENTOPTIONADD", ""); + } + else if(cl->typ == 'r') + { + if(shown) + { + tpl_addVar(vars, TPLAPPEND, "READERSTATUS", tpl_getTpl(vars, "CLIENTSTATUSBIT")); + } + + tpl_printf(vars, TPLADD, "RCC", "%d", reader_count_conn); + tpl_printf(vars, TPLADD, "RCA", "%d", reader_count_all); + + if(reader_count_off) + { + tpl_printf(vars, TPLADD, "RCO", "%d", reader_count_all-reader_count_off); + tpl_addVar(vars, TPLADD, "RHEADADD", tpl_getTpl(vars, "CLIENTRHEADLINEADD")); + } + + tpl_addVar(vars, TPLADD, "HIDEIDLE", "3"); + tpl_addVar(vars, TPLADD, "SHOWHIDDEN", "Reader"); + tpl_addVar(vars, TPLADD, "XHEAD", tpl_getTpl(vars, "CLIENTRHEADLINE")); + tpl_addVar(vars, TPLADD, "READERHEADLINE", tpl_getTpl(vars, "STATUSHEADLINE")); + } + else if(cl->typ == 'p') + { + if(shown) + { + tpl_addVar(vars, TPLAPPEND, "PROXYSTATUS", tpl_getTpl(vars, "CLIENTSTATUSBIT")); + } + + tpl_printf(vars, TPLADD, "PCC", "%d", proxy_count_conn); + tpl_printf(vars, TPLADD, "PCA", "%d", proxy_count_all); + + if(proxy_count_off) + { + tpl_printf(vars, TPLADD, "PCO", "%d", proxy_count_all-proxy_count_off); + tpl_addVar(vars, TPLADD, "PHEADADD", tpl_getTpl(vars, "CLIENTPHEADLINEADD")); + } + + tpl_addVar(vars, TPLADD, "HIDEIDLE", "4"); + tpl_addVar(vars, TPLADD, "SHOWHIDDEN", "Proxy"); + tpl_addVar(vars, TPLADD, "XHEAD", tpl_getTpl(vars, "CLIENTPHEADLINE")); + tpl_addVar(vars, TPLADD, "PROXYHEADLINE", tpl_getTpl(vars, "STATUSHEADLINE")); + } + else if(cl->typ == 'm' || cl->typ == 's' || cl->typ == 'h') + { + if(shown) + { + tpl_addVar(vars, TPLAPPEND, "SERVERSTATUS", tpl_getTpl(vars, "CLIENTSTATUSBIT")); + } + + tpl_addVar(vars, TPLADD, "HIDEIDLE", "2"); + tpl_addVar(vars, TPLADD, "SHOWHIDDEN", "Server"); + + if(cl->typ == 's' || cl->typ == 'h') + { + tpl_printf(vars, TPLADD, "SCS", "%d", server_count_shown); + tpl_printf(vars, TPLADD, "SCA", "%d", server_count_all); + tpl_addVar(vars, TPLADD, "XHEAD", tpl_getTpl(vars, "CLIENTSHEADLINE")); + + if(shown || cl->wihidden) + { + tpl_addVar(vars, TPLADD, "SERVERHEADLINE", tpl_getTpl(vars, "STATUSHEADLINE")); + } + } + else + { + tpl_addVar(vars, TPLADD, "SHOWHIDDENADD", " & Monitors"); + tpl_printf(vars, TPLADD, "MCS", "%d", monitor_count_shown); + tpl_printf(vars, TPLADD, "MCA", "%d", monitor_count_all); + tpl_addVar(vars, TPLADD, "MHEADADD", tpl_getTpl(vars, "CLIENTMHEADLINE")); + tpl_addVar(vars, TPLADD, "XHEAD", tpl_getTpl(vars, "CLIENTSHEADLINE")); + tpl_addVar(vars, TPLADD, "SERVERHEADLINE", tpl_getTpl(vars, "STATUSHEADLINE")); + tpl_addVar(vars, TPLADD, "SHOWHIDDENADD", ""); + } + } + } + else + { + if(shown) + { + if(apicall == 1) + { + tpl_addVar(vars, TPLAPPEND, "APISTATUSBITS", tpl_getTpl(vars, "APISTATUSBIT")); + } + + if(apicall == 2) + { + tpl_addVar(vars, TPLADD, "JSONARRAYDELIMITER", delimiter?",":""); + tpl_addVar(vars, TPLAPPEND, "JSONSTATUSBITS", tpl_getTpl(vars, "JSONSTATUSBIT")); + delimiter++; + } + } + } + +#ifdef CS_CACHEEX + } +#endif + + } + + LL_ITER itr = ll_iter_create(configured_readers); + struct s_reader *rdrr; + while((rdrr = ll_iter_next(&itr))) + { + if(rdrr->label[0] && rdrr->typ) + { + total_readers += 1; + + if(rdrr->enable) { active_readers += 1; } + else { disabled_readers += 1; } + + if(rdrr->tcp_connected) { connected_readers += 1; } + } + } + + cs_readunlock(__func__, &clientlist_lock); + cs_readunlock(__func__, &readerlist_lock); + + if(cfg.http_status_log || (apicall == 1 && strcmp(getParam(params, "appendlog"), "1") == 0)) + { + if(cfg.loghistorylines && log_history) + { + LL_ITER it = ll_iter_create(log_history); + struct s_log_history *hist; + + while((hist = (struct s_log_history*)ll_iter_next(&it))) + { + char p_usr[32]; + size_t pos1 = strcspn(hist->txt, "\t") + 1; + cs_strncpy(p_usr, hist->txt , pos1 > sizeof(p_usr) ? sizeof(p_usr) : pos1); + + char *p_txt = hist->txt + pos1; + + if(!apicall) + { + if(p_txt[0]) tpl_printf(vars, TPLAPPEND, "LOGHISTORY","\t\t%s\t\t
\n", xml_encode(vars, p_usr), xml_encode(vars, p_txt)); + } + else + { + tpl_addVar(vars, TPLAPPEND, "LOGHISTORY", p_txt); + } + } + } + else + { + tpl_addVar(vars, TPLADD, "LOGHISTORY", "loghistorylines is set to 0 in your configuration"); + } + } + +#ifdef CS_CACHEEX + char *getting = "
", sidtab->srvid[i], + xml_encode(vars, get_servicename(cur_client(), sidtab->srvid[i], sidtab->num_provid ? sidtab->provid[0] : 0, + sidtab->num_caid ? sidtab->caid[0] : 0, channame, sizeof(channame)))); + } + } + else + { + tpl_addVar(vars, TPLADD, "SIDCLASS", ""); + tpl_printf(vars, TPLADD, "SID", "Show Services", urlencode(vars, sidtab->label)); + } + tpl_addVar(vars, TPLADD, "LABELENC", urlencode(vars, sidtab->label)); + tpl_addVar(vars, TPLADD, "LABEL", xml_encode(vars, sidtab->label)); + tpl_addVar(vars, TPLADD, "SIDLIST", tpl_getTpl(vars, "SERVICECONFIGSIDBIT")); + + tpl_addVar(vars, TPLAPPEND, "SERVICETABS", tpl_getTpl(vars, "SERVICECONFIGLISTBIT")); + sidtab = sidtab->next; + counter++; + } + if(counter >= MAX_SIDBITS) + { + tpl_addVar(vars, TPLADD, "BTNDISABLED", "DISABLED"); + tpl_addMsg(vars, "Maximum Number of Services is reached"); + } + return tpl_getTpl(vars, "SERVICECONFIGLIST"); +} + +static char *send_oscam_savetpls(struct templatevars * vars) +{ + if(cfg.http_tpl) + { + tpl_printf(vars, TPLADD, "CNT", "%d", tpl_saveIncludedTpls(cfg.http_tpl)); + tpl_addVar(vars, TPLADD, "PATH", cfg.http_tpl); + } + else { tpl_addVar(vars, TPLADD, "CNT", "0"); } + return tpl_getTpl(vars, "SAVETEMPLATES"); +} + +static char *send_oscam_shutdown(struct templatevars * vars, FILE * f, struct uriparams * params, int8_t apicall, int8_t *keepalive, char *extraheader) +{ + if(!apicall) { setActiveMenu(vars, MNU_SHUTDOWN); } + if(strcmp(strtolower(getParam(params, "action")), "shutdown") == 0) + { + *keepalive = 0; + if(!apicall) + { + char *CSS = tpl_getUnparsedTpl("CSS", 1, ""); + tpl_addVar(vars, TPLADD, "STYLESHEET", CSS); + NULLFREE(CSS); + tpl_printf(vars, TPLADD, "REFRESHTIME", "%d", SHUTDOWNREFRESH); + tpl_addVar(vars, TPLADD, "REFRESH", tpl_getTpl(vars, "REFRESH")); + tpl_printf(vars, TPLADD, "SECONDS", "%d", SHUTDOWNREFRESH); + char *result = tpl_getTpl(vars, "SHUTDOWN"); + send_headers(f, 200, "OK", extraheader, "text/html", 0, cs_strlen(result), NULL, 0); + webif_write(result, f); + cs_log("Shutdown requested by WebIF from %s", cs_inet_ntoa(GET_IP())); + } + else + { + tpl_addVar(vars, TPLADD, "APICONFIRMMESSAGE", "shutdown"); + cs_log("Shutdown requested by XMLApi from %s", cs_inet_ntoa(GET_IP())); + } + cs_exit_oscam(); + + if(!apicall) + { return "1"; } + else + { return tpl_getTpl(vars, "APICONFIRMATION"); } + + } + else if(strcmp(strtolower(getParam(params, "action")), "restart") == 0) + { + *keepalive = 0; + if(!apicall) + { + char *CSS = tpl_getUnparsedTpl("CSS", 1, ""); + tpl_addVar(vars, TPLADD, "STYLESHEET", CSS); + NULLFREE(CSS); + tpl_addVar(vars, TPLADD, "REFRESHTIME", "5"); + tpl_addVar(vars, TPLADD, "REFRESH", tpl_getTpl(vars, "REFRESH")); + tpl_addVar(vars, TPLADD, "SECONDS", "5"); + char *result = tpl_getTpl(vars, "SHUTDOWN"); + send_headers(f, 200, "OK", extraheader, "text/html", 0, cs_strlen(result), NULL, 0); + webif_write(result, f); + cs_log("Restart requested by WebIF from %s", cs_inet_ntoa(GET_IP())); + } + else + { + tpl_addVar(vars, TPLADD, "APICONFIRMMESSAGE", "restart"); + cs_log("Restart requested by XMLApi from %s", cs_inet_ntoa(GET_IP())); + } + cs_restart_oscam(); + + if(!apicall) + { return "1"; } + else + { return tpl_getTpl(vars, "APICONFIRMATION"); } + + } + else + { + return tpl_getTpl(vars, "PRESHUTDOWN"); + } +} + +static char *send_oscam_script(struct templatevars * vars, struct uriparams * params) +{ + setActiveMenu(vars, MNU_SCRIPT); + tpl_printf(vars, TPLADD, "SCRIPTOPTIONS", "\n"); + + if(!cfg.http_readonly && cfg.http_script) + { + struct dirent **namelist; + int count, i; + count = scandir(cfg.http_script, &namelist, 0, alphasort ); + if( count >= 0 ) + { + for( i = 0 ; i < count; i++ ) + { + if(is_ext(namelist[i]->d_name, ".script") || is_ext(namelist[i]->d_name, ".sh")) + { + tpl_printf(vars, TPLAPPEND, "SCRIPTOPTIONS", "\n",namelist[i]->d_name,namelist[i]->d_name); + } + free( namelist[i] ); + } + free(namelist); + } + + char *scriptname = getParam(params, "scriptname"); + char *scriptparam = getParam(params, "scriptparam"); + char system_str[256]; + struct stat s; + snprintf(system_str, sizeof(system_str), "%s/%s", cfg.http_script, scriptname); + + if(!stat(system_str,&s)) + { + if(s.st_mode & S_IFREG) + { + if(s.st_mode & S_IXUSR) + { + int32_t rc = -1; + FILE *fp; + char buf[256]; + + if((scriptparam != NULL) && (sizeof(scriptparam) > 0)) + { + cs_strncat(system_str, " ", sizeof(system_str)); + cs_strncat(system_str, scriptparam, sizeof(system_str)); + } + + fp = popen(system_str, "r"); + if (fp) + { + while (fgets(buf, sizeof(buf), fp) != NULL) + { + tpl_addVar(vars, TPLAPPEND, "SCRIPTRESULTOUT", buf); + } + rc = pclose(fp)/256; + } + + tpl_printf(vars, TPLAPPEND, "CODE", "returncode: %d", rc); + tpl_printf(vars, TPLADD, "SCRIPTNAME", "scriptname: %s", scriptname); + } + else + { + tpl_printf(vars, TPLADD, "SCRIPTRESULTOUT", "[Error]: Script \"%s\" not executable!", scriptname); + } + } + } + else + { + tpl_printf(vars, TPLADD, "SCRIPTRESULTOUT", "[Error]: Script \"%s\" not found!", scriptname); + } + + } + return tpl_getTpl(vars, "SCRIPT"); +} + +static char *send_oscam_scanusb(struct templatevars * vars) +{ + setActiveMenu(vars, MNU_READERS); +#if !defined(__CYGWIN__) + FILE *fp; + char line[100]; + uint8_t i; + char header[11], txt[13], entry[10], bit[8], scan[12], error[120]; + +// key tool package match command + char *elems[] = { "USB", "lsusb", "usbutils", "Bus ", "lsusb -v | egrep '^Bus|^ *iSerial|^ *iProduct'" + , "UDEV", "/dev/serial/by-id", "udev", "<-", "find /dev/serial/by-id -type l -exec readlink -fn {} ';' -exec echo ' <- {}' \\;" +#ifdef CARDREADER_PCSC + , "PCSC", "pcsc_scan", "pcsc-tools", ":", "pcsc_scan -r" +#endif + }; + + for (i = 0; i < (sizeof(elems) / sizeof(elems[0])); i+=5) + { + snprintf(header, sizeof(header), "%sHEADER", elems[i]); //key + snprintf(txt, sizeof(txt), "%s Devices", elems[i]); //key + snprintf(entry, sizeof(entry), "%sENTRY", elems[i]); //key + snprintf(bit, sizeof(bit), "%sBIT", elems[i]); //key + snprintf(scan, sizeof(scan), "SCAN%sBIT", elems[i]); //key + snprintf(error, sizeof(error), "%s: Failed to run or %s package not installed!", elems[i + 1], elems[i + 2]); //tool + package + + tpl_addVar(vars, TPLADD, header, txt); + fp = popen(elems[i + 4], "r"); //command + if(!fp || !fgets(line, sizeof(line) - 1, fp)) + { + tpl_addVar(vars, TPLADD, entry, error); + tpl_addVar(vars, TPLADD, bit, tpl_getTpl(vars, scan)); + } + else + { + do{ + tpl_addVar(vars, TPLADD, "USBENTRYCLASS", ""); + if(strstr(line, elems[i + 3])) //match + { + tpl_addVar(vars, TPLADD, entry, line); + tpl_addVar(vars, TPLADD, "USBENTRYCLASS", "CLASS=\"scanusbsubhead\""); + } + else + { + tpl_printf(vars, TPLADD, entry, " %s", line); + } + tpl_addVar(vars, TPLAPPEND, bit, tpl_getTpl(vars, scan)); + } + while(fgets(line, sizeof(line) - 1, fp) != NULL); + pclose(fp); + } + } +#else + tpl_addMsg(vars, "Function not supported in CYGWIN environment"); +#endif + return tpl_getTpl(vars, "SCANUSB"); +} + +static void webif_process_logfile(struct templatevars * vars, struct uriparams * params, char *targetfile, size_t targetfile_len) +{ + snprintf(targetfile, targetfile_len, "%s", cfg.logfile); + if(strcmp(getParam(params, "clear"), "logfile") == 0) + { + if(cs_strlen(targetfile) > 0) + { + FILE *file = fopen(targetfile, "w"); + if (file != NULL) + { + fclose(file); + } + } + } +#ifdef WITH_DEBUG + // Debuglevel Selector + int32_t i, lvl; + for(i = 0; i < MAX_DEBUG_LEVELS; i++) + { + lvl = 1 << i; + tpl_printf(vars, TPLADD, "TMPC", "DCLASS%d", lvl); + tpl_printf(vars, TPLADD, "TMPV", "DEBUGVAL%d", lvl); + if(cs_dblevel & lvl) + { + tpl_addVar(vars, TPLADD, tpl_getVar(vars, "TMPC"), "debugls"); + tpl_printf(vars, TPLADD, tpl_getVar(vars, "TMPV"), "%d", cs_dblevel - lvl); + } + else + { + tpl_addVar(vars, TPLADD, tpl_getVar(vars, "TMPC"), "debugl"); + tpl_printf(vars, TPLADD, tpl_getVar(vars, "TMPV"), "%d", cs_dblevel + lvl); + } + } + if(cs_dblevel == D_ALL_DUMP) + { tpl_addVar(vars, TPLADD, "DCLASS65535", "debugls"); } + else + { tpl_addVar(vars, TPLADD, "DCLASS65535", "debugl"); } + tpl_addVar(vars, TPLADD, "CUSTOMPARAM", "&file=logfile"); + tpl_printf(vars, TPLADD, "ACTDEBUG", "%d", cs_dblevel); +#ifdef CS_CACHEEX_AIO + tpl_addVar(vars, TPLADD, "SDEBUG", tpl_getTpl(vars, "DEBUGSELECTAIO")); +#else + tpl_addVar(vars, TPLADD, "SDEBUG", tpl_getTpl(vars, "DEBUGSELECT")); +#endif + tpl_addVar(vars, TPLADD, "NEXTPAGE", "files.html"); +#endif + if(!cfg.disablelog) + { + tpl_printf(vars, TPLADD, "SWITCH", "%d", 1); + tpl_addVar(vars, TPLADD, "TEXT", "Stop Log"); + tpl_addVar(vars, TPLADD, "LOGMENU", tpl_getTpl(vars, "LOGMENUDISABLELOG")); + + } + else + { + tpl_printf(vars, TPLADD, "SWITCH", "%d", 0); + tpl_addVar(vars, TPLADD, "TEXT", "Start Log"); + tpl_addVar(vars, TPLADD, "LOGMENU", tpl_getTpl(vars, "LOGMENUDISABLELOG")); + } + tpl_addVar(vars, TPLAPPEND, "LOGMENU", tpl_getTpl(vars, "CLEARLOG")); + return; +} + +static void webif_process_userfile(struct templatevars * vars, struct uriparams * params, char *targetfile, size_t targetfile_len) +{ + snprintf(targetfile, targetfile_len, "%s", cfg.usrfile); + if(strcmp(getParam(params, "clear"), "usrfile") == 0) + { + if(cs_strlen(targetfile) > 0) + { + FILE *file = fopen(targetfile, "w"); + if (file) + { + fclose(file); + } + } + } + if(!cfg.disableuserfile) + { + tpl_printf(vars, TPLADD, "SWITCH", "%d", 1); + tpl_addVar(vars, TPLADD, "TEXT", "Stop Log"); + tpl_addVar(vars, TPLADD, "LOGMENU", tpl_getTpl(vars, "LOGMENUONOFF")); + } + else + { + tpl_printf(vars, TPLADD, "SWITCH", "%d", 0); + tpl_addVar(vars, TPLADD, "TEXT", "Start Log"); + tpl_addVar(vars, TPLADD, "LOGMENU", tpl_getTpl(vars, "LOGMENUONOFF")); + } + tpl_addVar(vars, TPLAPPEND, "LOGMENU", tpl_getTpl(vars, "CLEARUSERLOG")); + tpl_addVar(vars, TPLADD, "FFVAL", "all"); + tpl_addVar(vars, TPLADD, "FILTERFORMOPTIONS", tpl_getTpl(vars, "LOGMENUFILTERFORM")); + struct s_auth *account; + for(account = cfg.account; account; account = account->next) + { + tpl_addVar(vars, TPLADD, "FFVAL", xml_encode(vars, account->usr)); + tpl_addVar(vars, TPLADD, "FFSEL", strcmp(getParam(params, "filter"), account->usr) ? "" : "selected"); + tpl_addVar(vars, TPLAPPEND, "FILTERFORMOPTIONS", tpl_getTpl(vars, "LOGMENUFILTERFORM")); + } + tpl_addVar(vars, TPLADD, "FILTERFORM", tpl_getTpl(vars, "FILTERFORM")); +} + +enum file_types { FTYPE_CONFIG, FTYPE_VERSION, FTYPE_ANTICASC, FTYPE_LOGFILE, FTYPE_USERFILE , FTYPE_GBOX }; + +struct files +{ + char *file; + int menu_id; + enum file_types type; +}; + +static char *send_oscam_files(struct templatevars * vars, struct uriparams * params, int8_t apicall) +{ + bool writable = false; + const struct files *entry; + static struct files config_files[] = + { + // id are used + // new entry after last entry before first ifdef entry + // ifdef must be add to end + { "oscam.version", MNU_CFG_FVERSION, FTYPE_VERSION }, // id 0 + { "oscam.conf", MNU_CFG_FCONF, FTYPE_CONFIG }, // id 1 + { "oscam.user", MNU_CFG_FUSER, FTYPE_CONFIG }, // id 2 + { "oscam.server", MNU_CFG_FSERVER, FTYPE_CONFIG }, // id 3 + { "oscam.srvid", MNU_CFG_FSRVID, FTYPE_CONFIG }, // id 4 + { "oscam.srvid2", MNU_CFG_FSRVID2, FTYPE_CONFIG }, // id 5 + { "logfile", MNU_CFG_FLOGFILE, FTYPE_LOGFILE }, // id 6 + { "userfile", MNU_CFG_FUSERFILE, FTYPE_USERFILE }, // id 7 + { "css_file_name", MNU_CFG_FCSS, FTYPE_CONFIG }, // id 8 + { "oscam.services", MNU_CFG_FSERVICES, FTYPE_CONFIG }, // id 9 + { "oscam.provid", MNU_CFG_FPROVID, FTYPE_CONFIG }, // id 10 + { "oscam.tiers", MNU_CFG_FTIERS, FTYPE_CONFIG }, // id 11 + { "oscam.ratelimit", MNU_CFG_FRATELIMIT,FTYPE_CONFIG }, // id 12 + { "oscam.whitelist", MNU_CFG_FWHITELIST,FTYPE_CONFIG }, // id 13 +#ifdef HAVE_DVBAPI + { "oscam.dvbapi", MNU_CFG_FDVBAPI, FTYPE_CONFIG }, // id 14 +#endif +#ifdef CS_CACHEEX + { "oscam.fakecws", MNU_CFG_FFAKECWS, FTYPE_CONFIG }, // id 15 +#endif +#ifdef CS_ANTICASC + { "anticasc", MNU_CFG_FACLOG, FTYPE_ANTICASC }, // id 16 +#endif +#ifdef MODULE_SERIAL + { "oscam.twin", MNU_CFG_FTWIN, FTYPE_CONFIG }, // id 17 +#endif +#ifdef MODULE_CONSTCW + { "constant.cw", MNU_CFG_FKEYCW, FTYPE_CONFIG }, // id 18 +#endif +#ifdef MODULE_GBOX + { "sc.info", MNU_GBX_FSCINF, FTYPE_GBOX }, // id 19 + { "share.info", MNU_GBX_FSHRINF, FTYPE_GBOX }, // id 20 + { "share.onl", MNU_GBX_FSHRONL, FTYPE_GBOX }, // id 21 + { "gbox.ver", MNU_GBX_FVERS, FTYPE_GBOX }, // id 22 + { "attack.txt", MNU_GBX_FATTACK, FTYPE_GBOX }, // id 23 + { "gsms.log", MNU_GBX_FSMSLOG, FTYPE_GBOX }, // id 24 + { "gsms.ack", MNU_GBX_FSMSACK, FTYPE_GBOX }, // id 25 + { "gsms.nack", MNU_GBX_FSMSNACK, FTYPE_GBOX }, // id 26 + { "stats.info", MNU_GBX_FSTAINF, FTYPE_GBOX }, // id 27 + { "expired.info", MNU_GBX_FEXPINF, FTYPE_GBOX }, // id 28 + { "info.log", MNU_GBX_INFOLOG, FTYPE_GBOX }, // id 29 +#endif + { NULL, 0, 0 }, + }; + + if(use_srvid2) + { + config_files[4].menu_id = MNU_CFG_FSRVID2; + config_files[5].menu_id = MNU_CFG_FSRVID; + } + + if(cfg.http_css) + { + if(strchr(cfg.http_css,'/')) + config_files[8].file = strrchr(cfg.http_css, '/')+1; + else if(strchr(cfg.http_css,'\\')) + config_files[8].file = strrchr(cfg.http_css, '\\')+1; + else + config_files[8].file = cfg.http_css; + tpl_addVar(vars, TPLADD, "FILE_USER_CSS", xml_encode(vars, config_files[8].file)); + } + + if(!apicall) { setActiveMenu(vars, MNU_FILES); } + + tpl_addVar(vars, TPLADD, "APIFILENAME", "null"); + tpl_addVar(vars, TPLADD, "APIWRITABLE", "0"); + + if(use_srvid2) + { + tpl_printf(vars, TPLADD, "SRVID", "%s", "oscam.srvid2"); + tpl_printf(vars, TPLADD, "SRVIDSUB", "%s", "oscam.srvid"); + } + else + { + tpl_printf(vars, TPLADD, "SRVID", "%s", "oscam.srvid"); + tpl_printf(vars, TPLADD, "SRVIDSUB", "%s", "oscam.srvid2"); + } + + char *stoplog = getParam(params, "stoplog"); + if(cs_strlen(stoplog) > 0) + { cs_disable_log(atoi(stoplog)); } + + char *stopusrlog = getParam(params, "stopusrlog"); + if(cs_strlen(stopusrlog) > 0) + { cfg.disableuserfile = atoi(stopusrlog); } + + char *debuglvl = getParam(params, "debug"); + if(cs_strlen(debuglvl) > 0) + { +#ifndef WITH_DEBUG + cs_log("*** Warning: Debug Support not compiled in ***"); +#else + int32_t dblvl = atoi(debuglvl); + if(dblvl >= 0 && dblvl <= 65535) { cs_dblevel = dblvl; } + cs_log("%s debug_level=%d", "all", cs_dblevel); +#endif + } + // Process config files + char *file = getParam(params, "file"); + char targetfile[256] = { 0 }; + int menu_id = 0; + for(entry = config_files; entry->file; entry++) + { + if(streq(file, entry->file)) + { + if(!apicall) { setActiveSubMenu(vars, entry->menu_id); } + menu_id = entry->menu_id; + tpl_addVar(vars, TPLADD, "APIWRITABLE", writable ? "1" : "0"); + switch(entry->type) + { + case FTYPE_CONFIG: + writable = 1; + get_config_filename(targetfile, sizeof(targetfile), entry->file); + break; + case FTYPE_VERSION: + get_tmp_dir_filename(targetfile, sizeof(targetfile), entry->file); + break; + case FTYPE_ANTICASC: +#ifdef CS_ANTICASC + if(!apicall) { snprintf(targetfile, sizeof(targetfile), "%s", ESTR(cfg.ac_logfile)); } +#endif + break; + case FTYPE_LOGFILE: + if(!apicall) { webif_process_logfile(vars, params, targetfile, sizeof(targetfile)); } + break; + case FTYPE_USERFILE: + if(!apicall) { webif_process_userfile(vars, params, targetfile, sizeof(targetfile)); } + break; + case FTYPE_GBOX: +#ifdef MODULE_GBOX + get_gbox_filename(targetfile, sizeof(targetfile), entry->file); +#endif + break; + } + tpl_addVar(vars, TPLADD, "APIFILENAME", entry->file); + break; + } + } + + if(cfg.http_css) + { + tpl_addVar(vars, TPLADD, "VIEW_FILEMENUCSS", tpl_getTpl(vars, "FILEMENUCSS")); + } + + if(!strstr(targetfile, "/dev/")) + { + if(strcmp(getParam(params, "action"), "Save") == 0) + { + if((cs_strlen(targetfile) > 0) /*&& (file_exists(targetfile) == 1)*/) + { + FILE *fpsave; + char *fcontent = getParam(params, "filecontent"); + if((fpsave = fopen(targetfile, "w"))) + { + int32_t i, lastpos = 0, len = cs_strlen(fcontent) + 1; + //write submitted file line by line to disk and remove windows linebreaks + for(i = 0; i < len; ++i) + { + char tmp = fcontent[i]; + if(tmp == '\r' || tmp == '\n' || tmp == 0) + { + fcontent[i] = 0; + fprintf(fpsave, "%s%s", fcontent + lastpos, tmp == 0 ? "" : "\n"); + if(tmp == '\r' && fcontent[i + 1] == '\n') { ++i; } + lastpos = i + 1; + } + } + fclose(fpsave); + tpl_addVar(vars, TPLAPPEND, "APIFILENAME", " saved!"); + // Reinit on save + switch(menu_id) + { + case MNU_CFG_FSRVID: + case MNU_CFG_FSRVID2: + init_srvid(); + break; + case MNU_CFG_FPROVID: + init_provid(); + break; + case MNU_CFG_FUSER: + cs_accounts_chk(); + break; + case MNU_CFG_FDVBAPI: + dvbapi_read_priority(); + break; + case MNU_CFG_FWHITELIST: + global_whitelist_read(); + break; + case MNU_CFG_FFAKECWS: + init_fakecws(); + break; + default: + break; + } + } + } + } + + if((cs_strlen(targetfile) > 0) && (file_exists(targetfile) == 1)) + { + FILE *fp; + char buffer[256]; + + if((fp = fopen(targetfile, "r")) == NULL) { return "0"; } + while(fgets(buffer, sizeof(buffer), fp) != NULL) + if(!strcmp(getParam(params, "filter"), "all")) + { tpl_addVar(vars, TPLAPPEND, "FILECONTENT", buffer); } + else if(strstr(buffer, getParam(params, "filter"))) + { tpl_addVar(vars, TPLAPPEND, "FILECONTENT", buffer); } + fclose(fp); + } + else + { + tpl_addVar(vars, TPLAPPEND, "FILECONTENT", "File does not exist or no file selected!"); + } + } + else + { + tpl_addVar(vars, TPLAPPEND, "FILECONTENT", "File not valid!"); + } + + tpl_addVar(vars, TPLADD, "PART", file); + + if(!writable) + { + tpl_addVar(vars, TPLADD, "WRITEPROTECTION", tpl_getTpl(vars, "WRITEPROTECTION")); + tpl_addVar(vars, TPLADD, "BTNDISABLED", "DISABLED"); + } + + if(!apicall) + { return tpl_getTpl(vars, "FILE"); } + else + { return tpl_getTpl(vars, "APIFILE"); } +} + +static char *send_oscam_failban(struct templatevars * vars, struct uriparams * params, int8_t apicall) +{ + IN_ADDR_T ip2delete; + set_null_ip(&ip2delete); + LL_ITER itr = ll_iter_create(cfg.v_list); + V_BAN *v_ban_entry; + //int8_t apicall = 0; //remove before flight + + if(!apicall) { setActiveMenu(vars, MNU_FAILBAN); } + + if(strcmp(getParam(params, "action"), "delete") == 0) + { + if(strcmp(getParam(params, "intip"), "all") == 0) + { + // clear whole list + while(ll_iter_next(&itr)) + { + ll_iter_remove_data(&itr); + } + } + else + { + //we have a single IP + cs_inet_addr(getParam(params, "intip"), &ip2delete); + while((v_ban_entry = ll_iter_next(&itr))) + { + if(IP_EQUAL(v_ban_entry->v_ip, ip2delete)) + { + ll_iter_remove_data(&itr); + break; + } + } + } + } + ll_iter_reset(&itr); + + struct timeb now; + cs_ftime(&now); + + while((v_ban_entry = ll_iter_next(&itr))) + { + tpl_printf(vars, TPLADD, "IPADDRESS", "%s@%d", cs_inet_ntoa(v_ban_entry->v_ip), v_ban_entry->v_port); + tpl_addVar(vars, TPLADD, "VIOLATIONUSER", v_ban_entry->info ? v_ban_entry->info : "unknown"); + struct tm st ; + localtime_r(&v_ban_entry->v_time.time, &st); // fix me, we need walltime! + if(!apicall) + { + tpl_printf(vars, TPLADD, "VIOLATIONDATE", "%02d.%02d.%02d %02d:%02d:%02d", + st.tm_mday, st.tm_mon + 1, + st.tm_year % 100, st.tm_hour, + st.tm_min, st.tm_sec); + } + else + { + char tbuffer [30]; + strftime(tbuffer, 30, "%Y-%m-%dT%H:%M:%S%z", &st); + tpl_addVar(vars, TPLADD, "VIOLATIONDATE", tbuffer); + } + + tpl_printf(vars, TPLADD, "VIOLATIONCOUNT", "%d", v_ban_entry->v_count); + + int64_t gone = comp_timeb(&now, &v_ban_entry->v_time); + if(!apicall) + { + if(!v_ban_entry->acosc_entry) + { tpl_addVar(vars, TPLADD, "LEFTTIME", sec2timeformat(vars, (cfg.failbantime * 60) - (gone / 1000))); } + else + { tpl_addVar(vars, TPLADD, "LEFTTIME", sec2timeformat(vars, v_ban_entry->acosc_penalty_dur - (gone / 1000))); } + } + else + { + if(!v_ban_entry->acosc_entry) + { tpl_printf(vars, TPLADD, "LEFTTIME", "%"PRId64"", (cfg.failbantime * 60) - (gone / 1000)); } + else + { tpl_printf(vars, TPLADD, "LEFTTIME", "%"PRId64"", v_ban_entry->acosc_penalty_dur - (gone / 1000)); } + } + + tpl_addVar(vars, TPLADD, "INTIP", cs_inet_ntoa(v_ban_entry->v_ip)); + + if(!apicall) + { tpl_addVar(vars, TPLAPPEND, "FAILBANROW", tpl_getTpl(vars, "FAILBANBIT")); } + else + { tpl_addVar(vars, TPLAPPEND, "APIFAILBANROW", tpl_getTpl(vars, "APIFAILBANBIT")); } + } + if(!apicall) + { return tpl_getTpl(vars, "FAILBAN"); } + else + { return tpl_getTpl(vars, "APIFAILBAN"); } +} + +static bool send_EMM(struct s_reader * rdr, uint16_t caid, const struct s_cardsystem *csystem, const uint8_t *emmhex, uint32_t len) +{ + if(NULL != rdr && NULL != emmhex && 0 != len) + { + EMM_PACKET *emm_pack = NULL; + + if(cs_malloc(&emm_pack, sizeof(EMM_PACKET))) + { + struct s_client *webif_client = cur_client(); + webif_client->grp = 0xFF; /* to access to all readers */ + + memset(emm_pack, '\0', sizeof(EMM_PACKET)); + emm_pack->client = webif_client; + emm_pack->emmlen = len; + memcpy(emm_pack->emm, emmhex, len); + + emm_pack->caid[0] = (caid >> 8) & 0xFF; + emm_pack->caid[1] = caid & 0xFF; + + if(csystem && csystem->get_emm_type) + { + if(!csystem->get_emm_type(emm_pack, rdr)) + { + rdr_log_dbg(rdr, D_EMM, "get_emm_type() returns error"); + } + } + + cs_log_dbg(D_EMM, "emm is being sent to reader %s.", rdr->label); + add_job(rdr->client, ACTION_READER_EMM, emm_pack, sizeof(EMM_PACKET)); + return true; + } + } + + return false; +} + +static bool process_single_emm(struct templatevars * vars, struct s_reader * rdr, uint16_t caid, const struct s_cardsystem *csystem, const char *ep) +{ + + if(NULL != vars && NULL != rdr && NULL != ep) + { + char emmdata[1025] = {'\0'}; /*1024 + '\0'*/ + uint8_t emmhex[513] = {'\0'}; + char buff[7] = {'\0'}; + uint16_t len = 0; + cs_strncpy(emmdata, ep, sizeof(emmdata)); + remove_white_chars(emmdata); + + if('\0' != emmdata[0]) + { + len = cs_strlen(emmdata); + tpl_addVar(vars, TPLADD, "EP", strtoupper(emmdata)); + if(key_atob_l(emmdata, emmhex, len)) + { + tpl_addMsg(vars, "Single EMM has not been sent due to wrong value!"); + } + else + { + len /= 2; + snprintf(buff, sizeof(buff), "0x%02X", len); + tpl_addVar(vars, TPLADD, "EP", strtoupper(emmdata)); + tpl_addVar(vars, TPLADD, "SIZE", buff); + + if(send_EMM(rdr, caid, csystem, emmhex, len)) + { + tpl_addMsg(vars, "Single EMM has been sent."); + return true; + } + } + } + } + tpl_addVar(vars, TPLADD, "SIZE", "0x00"); + return false; +} + +static bool process_emm_file(struct templatevars * vars, struct s_reader * rdr, uint16_t caid, const struct s_cardsystem *csystem, const char *sFilePath) +{ + + bool bret = false; + uint32_t fsize = 0; + uint32_t rlines = 0; + uint32_t wemms = 0; + uint32_t errsize = 0; + char numerrl[256] = {'\0'}; + char buff[20] = {'\0'}; + + if(NULL != rdr && NULL != sFilePath && '\0' != sFilePath[0]) + { + char sMessage[128] = {0}; + if(true == file_exists(sFilePath)) + { + FILE *fp; + if((fp = fopen(sFilePath, "r"))) + { + char line[2048] = {'\0'}; + uint8_t emmhex[513] = {'\0'}; + uint32_t len = 0; + + tpl_addMsg(vars, "EMM file has been processed."); + while(fgets(line, sizeof(line), fp)) + { + ++rlines; + len = cs_strlen(remove_white_chars(line)); + + // wrong emm + if(len > (sizeof(emmhex) * 2) || + key_atob_l(line, emmhex, len)) + { + errsize += snprintf(numerrl + errsize, sizeof(numerrl) - errsize, "%d, ", rlines); + continue; + } + len /= 2; + if(send_EMM(rdr, caid, csystem, emmhex, len)) + { + ++wemms; + int32_t jcount = ll_count(rdr->client->joblist); + if (jcount > 200) + { + /* Give more time to process EMMs */ + cs_sleepms(1000); + } + rdr_log_dbg(rdr, D_READER, "pending emm jobs: %i, processed emms: %i", jcount, wemms); + } + } + fsize = ftell(fp); + fclose(fp); + } + else + { + snprintf(sMessage, sizeof(sMessage), "Cannot open file '%s' (errno=%d: %s)\n", sFilePath, errno, strerror(errno)); + tpl_addMsg(vars, sMessage); + } + } + else + { + snprintf(sMessage, sizeof(sMessage), "FILE \"%s\" not found!", sFilePath); + tpl_addMsg(vars, sMessage); + } + bret = true; + } + + snprintf(buff, sizeof(buff), "%d bytes", fsize); + tpl_addVar(vars, TPLADD, "FSIZE", buff); + snprintf(buff, sizeof(buff), "%d", rlines); + tpl_addVar(vars, TPLADD, "NUMRLINE", buff); + snprintf(buff, sizeof(buff), "%d", wemms); + tpl_addVar(vars, TPLADD, "NUMWEMM", buff); + tpl_addVar(vars, TPLADD, "ERRLINE", numerrl); + + return bret; +} + +static char *send_oscam_EMM_running(struct templatevars * vars, struct uriparams * params) +{ + + struct s_reader *rdr = NULL; + + setActiveMenu(vars, MNU_READERS); + tpl_addVar(vars, TPLADD, "READER", getParam(params, "label")); + tpl_addVar(vars, TPLADD, "FNAME", getParam(params, "emmfile")); + + rdr = get_reader_by_label(getParam(params, "label")); + if(rdr) + { + int32_t tcaid = dyn_word_atob(getParam(params, "emmcaid")); + uint16_t caid = (-1 != tcaid) ? (uint16_t)tcaid : 0; + char buff[7] = ""; + const struct s_cardsystem *csystem = NULL; + int32_t proxy = is_cascading_reader(rdr); + + if((proxy || !rdr->csystem_active) && caid) // network reader (R_CAMD35 R_NEWCAMD R_CS378X R_CCCAM) + { + if(proxy && !rdr->ph.c_send_emm) + { + tpl_addMsg(vars, "The reader does not support EMM's!"); + return tpl_getTpl(vars, "EMM_RUNNING"); + } + + csystem = get_cardsystem_by_caid(caid); + if(!csystem) + { + rdr_log_dbg(rdr, D_EMM, "unable to find cardsystem for caid %04X", caid); + caid = 0; + } + } + else if(!proxy && rdr->csystem_active) // local active reader + { + csystem = rdr->csystem; + caid = rdr->caid; + } + + if(csystem) + { + tpl_addVar(vars, TPLADD, "SYSTEM", csystem->desc); + } + else + { + tpl_addVar(vars, TPLADD, "SYSTEM", "unknown"); + } + if(caid) + { + snprintf(buff, sizeof(buff), "0x%04X", caid); + tpl_addVar(vars, TPLADD, "CAID", buff); + } + else + { + tpl_addVar(vars, TPLADD, "CAID", "unknown"); + } + + process_single_emm(vars, rdr, caid, csystem, getParam(params, "ep")); + process_emm_file(vars, rdr, caid, csystem, getParam(params, "emmfile")); + } + else + { + char sMessage[128] = {0}; + snprintf(sMessage, sizeof(sMessage), "READER \"%s\" not found!", getParam(params, "label")); + tpl_addMsg(vars, sMessage); + tpl_addVar(vars, TPLADD, "READER", "reader not found"); + } + + return tpl_getTpl(vars, "EMM_RUNNING"); +} + +static char *send_oscam_EMM(struct templatevars * vars, struct uriparams * params) +{ + + setActiveMenu(vars, MNU_READERS); + tpl_addVar(vars, TPLADD, "READER", getParam(params, "label")); + + struct s_reader *rdr = NULL; + rdr = get_reader_by_label(getParam(params, "label")); + if(rdr && rdr->caid) + { + char buff[5] = ""; + snprintf(buff, sizeof(buff), "%04X", rdr->caid); + tpl_addVar(vars, TPLADD, "CAID", buff); + if(!is_cascading_reader(rdr)) + { + tpl_addVar(vars, TPLADD, "READONLY", "readonly=\"readonly\""); + } + } + + FILE *fp; + struct stat sb; + char buffer[1024]; + char emm_hex[1024]; + char filename[128]; + char targetfile[256]; + char tmpstr[20]; + char emm_txt[32]; + char emm_title[32]; + char *emm_path; + char *emm_types[] = { "unique_emm", "shared_emm", "global_emm" }; + char *emm_names[] = { "RDREMMUNIQUE", "RDREMMSHARED", "RDREMMGLOBAL" }; + char *emm_cfg_names[] = { "httpemmuclean", "httpemmsclean", "httpemmgclean" }; + int32_t emm_max_size[] = { cfg.http_emmu_clean, cfg.http_emms_clean, cfg.http_emmg_clean }; + int num_emm_types = 3; + int i; + + emm_path = cfg.emmlogdir ? cfg.emmlogdir : cs_confdir; + + for( i = 0 ; i < num_emm_types; i++ ) + { + snprintf(filename, sizeof(filename), "%s%s%s%s", getParam(params, "label"), "_", emm_types[i], ".log"); + snprintf(targetfile, sizeof(targetfile), "%s%s%s", emm_path, emm_path[cs_strlen(emm_path) - 1] == '/' ? "" : "/", filename); + snprintf(emm_txt, sizeof(emm_txt), "%s_TXT", emm_names[i]); + tpl_addVar(vars, TPLADD, emm_txt, filename); + + if((fp = fopen(targetfile, "r")) != NULL) + { + stat(targetfile, &sb); + tpl_printf(vars, TPLAPPEND, emm_txt, " (Size: %'.2f kB)", (double)sb.st_size/1024); + + if(emm_max_size[i]>=0) + { + snprintf(emm_title, sizeof(emm_title), "%s_TITLE", emm_names[i]); + tpl_addVar(vars, TPLADD, emm_title, "title=\"Click Line to Copy EMM in Single EMM Write Field\""); + } + + if(emm_max_size[i]>0) + { + uint32_t emms=0, emm_d, emmrs=0; + char *ptr, *saveptr1 = NULL; + + while(fgets(buffer, sizeof(buffer), fp) != NULL) + { + emms++; + snprintf(tmpstr, sizeof(tmpstr), "LINE_%d", emms); + tpl_addVar(vars, TPLADD, tmpstr, buffer); + } + + for(emm_d=emms;emm_d>0;--emm_d) + { + snprintf(tmpstr, sizeof(tmpstr), "LINE_%d", emm_d); + if(sscanf(tpl_getVar(vars, tmpstr), "%*s %*s %*s %s", &emm_hex[0])==1) + { + if(strstr(tpl_getVar(vars, "EMM_TMP"),emm_hex)==0) + { tpl_addVar(vars, TPLAPPEND, "EMM_TMP", tpl_getVar(vars, tmpstr)); } + tpl_addVar(vars, TPLADD, tmpstr, ""); + } + } + + for(ptr = strtok_r(tpl_getVar(vars, "EMM_TMP"),"\n", &saveptr1); ptr; ptr = strtok_r(NULL,"\n", &saveptr1)) + { + emmrs++; + snprintf(tmpstr, sizeof(tmpstr), "LINE_%d", emmrs); + tpl_addVar(vars, TPLADD, tmpstr, ptr); + } + tpl_addVar(vars, TPLADD, "EMM_TMP", ""); + + tpl_printf(vars, TPLAPPEND, emm_txt, ": %'d different EMM's from a total of %'d Entries", emmrs,emms); + for(emm_d=emmrs;emm_d>0;--emm_d) + { + snprintf(tmpstr, sizeof(tmpstr), "LINE_%d", emm_d); + tpl_printf(vars, TPLAPPEND, emm_names[i], "%s\n", tpl_getVar(vars, tmpstr)); + if(sb.st_size>emm_max_size[i]*1024) { tpl_printf(vars, TPLAPPEND, "EMM_TMP", "%s\n", tpl_getVar(vars, tmpstr)); } + tpl_addVar(vars, TPLADD, tmpstr, ""); + } + + if(sb.st_size>emm_max_size[i]*1024) + { + char orgfile[268]; + int f=0; + do { + snprintf(orgfile, sizeof(orgfile), "%s.%d", targetfile, f); + f++; + } while(access(orgfile, F_OK) != -1); + + if(rename(targetfile, orgfile) == 0) + { + FILE *fs = fopen(targetfile, "w"); + if (fs) + { + fprintf(fs, "%s", tpl_getVar(vars, "EMM_TMP")); + fclose(fs); + } + tpl_printf(vars, TPLAPPEND, emm_txt, "
New reduced File created! Size of Original File is higher as %d kB, saved to %s", emm_max_size[i], orgfile); + } + } + tpl_addVar(vars, TPLADD, "EMM_TMP", ""); + } + else if (emm_max_size[i]==0) + { + while(fgets(buffer, sizeof(buffer), fp) != NULL) + { + tpl_printf(vars, TPLAPPEND, emm_names[i], "%s", buffer); + } + } + else + { + tpl_printf(vars, TPLADD, emm_names[i],"Viewing of EMM File deactivated.
Set %s in Config Webif to 0 or higher for viewing or filtering EMM File.", emm_cfg_names[i]); + } + fclose(fp); + } + if(strcmp(tpl_getVar(vars, emm_names[i]),"")==0) { tpl_addVar(vars, TPLADD, emm_names[i],"no saved EMM's"); } + } + + return tpl_getTpl(vars, "ASKEMM"); +} + +#ifdef CS_CACHEEX +static uint64_t get_cacheex_node(struct s_client * cl) +{ + uint64_t node = 0x00; +#if defined(MODULE_CCCAM) || defined(MODULE_CAMD35) || defined(MODULE_CAMD35_TCP) + struct s_module *module = (cl->reader ? &cl->reader->ph : get_module(cl)); +#endif +#ifdef MODULE_CCCAM + if(module->num == R_CCCAM && cl->cc) + { + struct cc_data *cc = cl->cc; + memcpy(&node, cc->peer_node_id, 8); + } + else +#endif +#ifdef MODULE_CAMD35 + if(module->num == R_CAMD35) + { + memcpy(&node, cl->ncd_skey, 8); + } + else +#endif +#ifdef MODULE_CAMD35_TCP + if(module->num == R_CS378X) + { + memcpy(&node, cl->ncd_skey, 8); + } + else +#endif + {} + return node; +} + + +static char *send_oscam_cacheex(struct templatevars * vars, struct uriparams * params, int8_t apicall) +{ + + if(!apicall) { setActiveMenu(vars, MNU_CACHEEX); } + + if(strcmp(getParam(params, "x"), "x") == 0) + { + // avoid compilerwarning unused vars + } + char *level[] = {"NONE", "CACHE PULL", "CACHE PUSH", "REVERSE CACHE PUSH"}; + char *getting = "
Format: caid[&mask][@provid][$servid]:mode:timediff_old_cw[,n]
s after known ECM requests are dropped
Format: caid[&mask][@provid][$servid]:mode:counter[,n]
Format: caid:time[,n]
| Edit Global Config | |||||||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| Serverip: | |||||||||||||||||
| Nice: | |||||||||||||||||
| Net prio: | ++ + | +||||||||||||||||
| Bind wait: | s | ||||||||||||||||
| Resolver: | ++ + | +||||||||||||||||
| Prefer local cards: | |||||||||||||||||
| SIGHUP reload: | +
+
|
+ ||||||||||||||||
| Simple block: | +
+
|
+ ||||||||||||||||
| Drop duplicate users: | ++ + | +||||||||||||||||
| Skip CWs checksum test: | ++ + | +||||||||||||||||
| Skip CWs checksum test only for: | + | +||||||||||||||||
| Logging | |||||||||||||||||
| Usr file: | +
+
|
+ ||||||||||||||||
| Mail file: | +
+
|
+ ||||||||||||||||
| Log file / max size: | +
+
|
+ ||||||||||||||||
| Log duplicated lines: | |||||||||||||||||
| Initial debug level: | |||||||||||||||||
| Pid file: | |||||||||||||||||
| CW log dir: | |||||||||||||||||
| EMM log dir: | |||||||||||||||||
| ECM log format: | |||||||||||||||||
| Loghistory Lines: | |||||||||||||||||
| Syslog server: | |||||||||||||||||
| Syslog port: | |||||||||||||||||
| Failban | |||||||||||||||||
| Failban time: | min blocking IP based | ||||||||||||||||
| Failban count: | chances with wrong credentials | ||||||||||||||||
| Timeouts / Times | |||||||||||||||||
| Client timeout: | ms to give up and return timeout | ||||||||||||||||
| Fallback timeout: | ms to switch to fallback reader | ||||||||||||||||
| Fallback timeout per caid: | |||||||||||||||||
| Client max idle: | s to disconnect idle clients | ||||||||||||||||
| Global sleep: | min to switch a client in sleepmode | ||||||||||||||||
| Reader restart seconds: | s waittime to restart a reader | ||||||||||||||||
| Doublecheck | |||||||||||||||||
| ECM Doublecheck: | |||||||||||||||||
| Doublecheck caids: | |||||||||||||||||
| Source Stream Password: | |||||||||||||||||
| Relay Buffer Time: | |||||||||||||||||
| Relay Reconnect Count: | |||||||||||||||||
| Relay Client Display Options: |
| ||||||||||||||||