d0s3t3ch/wownero-puddle
1
0
Fork 0
mirror of https://git.wownero.com/wownero/wownero-puddle.git synced 2024-08-15 01:03:20 +00:00
Code Issues Projects Releases Wiki Activity

move web stats to json api

Browse source
This commit is contained in:
Jethro Grassie 2019-03-03 15:26:11 -05:00
parent 17998481bf
commit 6a0c5475a1
No known key found for this signature in database
GPG key ID: DE8ED755616565BB
2 changed files with 108 additions and 113 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

71
src/webui-embed.html
View file

@ -20,22 +20,67 @@
<body> <body>
<header>THE Monero Mining Pool</header> <header>THE Monero Mining Pool</header>
<table> <table>
<tr><td>Pool HR: </td><td>{{POOL_HASHRATE}}</td></tr> <tr><td>Pool HR: </td><td id="pool_hashrate"></td></tr>
<tr><td>Network HR: </td><td>{{NETWORK_HASHRATE}}</td></tr> <tr><td>Network HR: </td><td id="network_hashrate"></td></tr>
<tr><td>Blocks found: </td><td>{{POOL_BLOCKS_FOUND}}</td></tr> <tr><td>Blocks found: </td><td id="pool_blocks_found"></td></tr>
<tr><td>Last block found: </td><td>{{LAST_BLOCK_FOUND}}</td></tr> <tr><td>Last block found: </td><td id="last_block_found"></td></tr>
<tr><td>Payment threshold: </td><td>{{PAYMENT_THRESHOLD}}</td></tr> <tr><td>Payment threshold: </td><td id="payment_threshold"></td></tr>
<tr><td>Pool fee: </td><td>{{POOL_FEE}}</td></tr> <tr><td>Pool fee: </td><td id="pool_fee"></td></tr>
<tr><td>Pool port: </td><td>{{POOL_PORT}}</td></tr> <tr><td>Pool port: </td><td id="pool_port"></td></tr>
<tr><td>Miners connected: </td><td>{{MINERS_CONNECTED}}</td></tr> <tr><td>Miners connected: </td><td id="connected_miners"></td></tr>
<tr class="wallet"><td>Your HR: </td><td>{{MINER_HASHRATE}}</td></tr> <tr class="wallet"><td>Your HR: </td><td id="miner_hashrate"></td></tr>
<tr class="wallet"><td>Balance due: </td><td>{{MINER_BALANCE_DUE}}</td></tr> <tr class="wallet"><td>Balance due: </td><td id="miner_balance"></td></tr>
</table> </table>
<form> <form>
Your wallet address: <input type="text" id="wa" name="address" /> Your wallet address: <input type="text" id="wa" name="address" />
<input type="submit" value="Submit" /> <input type="submit" value="Submit" />
</form> </form>
<script> <script>
function format_last_block(last)
{
var now = new Date().getTime() / 1000;
var diff = now - last;
if (last == 0)
return "None yet";
else if (diff < 60)
return parseInt(diff) + " seconds ago";
else if (diff < 3600)
return parseInt(diff/60) + " minutes ago";
else if (diff < 86400)
return parseInt(diff/3600) + " hours ago";
else
return parseInt(diff/86400) + " days ago";
}
function format_hashrate(hr)
{
if (hr < 1000)
return parseInt(hr) + " H/s";
else if (hr < 1000000)
return parseFloat(hr/1000).toFixed(2) + " KH/s";
else if (hr < 1000000000000)
return parseFloat(hr/1000000).toFixed(2) + " MH/s";
else
return parseFloat(hr/1000000000000).toFixed(2) + " GH/s";
}
var xhr = new XMLHttpRequest();
xhr.open("POST", "/stats");
xhr.onload = function()
{
var stats = JSON.parse(xhr.responseText);
for (var e in stats)
{
var el = document.querySelector("#"+e);
if (e == "last_block_found")
el.innerHTML = format_last_block(stats[e]);
else if (/hashrate/.test(e))
el.innerHTML = format_hashrate(stats[e]);
else
el.innerHTML = stats[e];
}
};
var f = document.querySelector("form"); var f = document.querySelector("form");
var wa = document.querySelector("#wa"); var wa = document.querySelector("#wa");
f.onsubmit = function(e) f.onsubmit = function(e)
@ -49,6 +94,7 @@
}; };
window.onload = function() window.onload = function()
{ {
xhr.send(null);
if (/wa=[0-9a-fA-F]+/.test(document.cookie)) if (/wa=[0-9a-fA-F]+/.test(document.cookie))
{ {
var wh = document.querySelectorAll(".wallet"); var wh = document.querySelectorAll(".wallet");
@ -59,9 +105,10 @@
var c = document.cookie.split("="); var c = document.cookie.split("=");
wa.value = c[1]; wa.value = c[1];
} }
setTimeout(function() setInterval(function()
{ {
window.location.reload(1); xhr.open("POST", "/stats");
xhr.send(null);
}, 30000); }, 30000);
}; };
</script> </script>

150
src/webui.c
View file

@ -30,6 +30,9 @@
Parts of the project are originally copyright (c) 2012-2013 The Cryptonote developers Parts of the project are originally copyright (c) 2012-2013 The Cryptonote developers
*/ */
#define __STDC_FORMAT_MACROS
#include <inttypes.h>
#include <assert.h> #include <assert.h>
#include <unistd.h> #include <unistd.h>
#include <string.h> #include <string.h>
@ -51,35 +54,53 @@
#define TAG_MAX 17 #define TAG_MAX 17
#define PAGE_MAX 4096 #define PAGE_MAX 4096
#define JSON_MAX 512
extern unsigned char webui_html[]; extern unsigned char webui_html[];
extern unsigned int webui_html_len; extern unsigned int webui_html_len;
static struct MHD_Daemon *mhd_daemon; static struct MHD_Daemon *mhd_daemon;
static char page_buffer[PAGE_MAX];
static char MINERS_CONNECTED[] = "{{MINERS_CONNECTED}}";
static char LAST_BLOCK_FOUND[] = "{{LAST_BLOCK_FOUND}}";
static char NETWORK_HASHRATE[] = "{{NETWORK_HASHRATE}}";
static char POOL_HASHRATE[] = "{{POOL_HASHRATE}}";
static char MINER_HASHRATE[] = "{{MINER_HASHRATE}}";
static char POOL_BLOCKS_FOUND[] = "{{POOL_BLOCKS_FOUND}}";
static char PAYMENT_THRESHOLD[] = "{{PAYMENT_THRESHOLD}}";
static char POOL_FEE[] = "{{POOL_FEE}}";
static char POOL_PORT[] = "{{POOL_PORT}}";
static char MINER_BALANCE_DUE[] = "{{MINER_BALANCE_DUE}}";
int
static void send_json_stats (void *cls, struct MHD_Connection *connection)
format_hashrate(uint64_t hashrate, char* output, size_t len)
{ {
if (hashrate < 1000) struct MHD_Response *response;
snprintf(output, len, "%d H/s", (int) hashrate); int ret;
else if (hashrate < 1000000) wui_context_t *context = (wui_context_t*) cls;
snprintf(output, len, "%.2f KH/s", (double) hashrate / 1000.0); char json[JSON_MAX];
else if (hashrate < 1000000000000) uint64_t ph = context->pool_stats->pool_hashrate;
snprintf(output, len, "%.2f MH/s", (double) hashrate / 1000000.0); uint64_t nh = context->pool_stats->network_hashrate;
else uint64_t lbf = context->pool_stats->last_block_found;
snprintf(output, len, "%.2f GH/s", (double) hashrate / 1000000000000.0); uint32_t pbf = context->pool_stats->pool_blocks_found;
uint64_t mh = 0;
double mb = 0.0;
const char *wa = MHD_lookup_connection_value(connection, MHD_COOKIE_KIND, "wa");
if (wa != NULL)
{
mh = miner_hr(wa);
uint64_t balance = miner_balance(wa);
mb = (double) balance / 1000000000000.0;
}
snprintf(json, JSON_MAX, "{"
"\"pool_hashrate\":%"PRIu64","
"\"network_hashrate\":%"PRIu64","
"\"last_block_found\":%"PRIu64","
"\"pool_blocks_found\":%d,"
"\"payment_threshold\":%.2f,"
"\"pool_fee\":%.2f,"
"\"pool_port\":%d,"
"\"connected_miners\":%d,"
"\"miner_hashrate\":%"PRIu64","
"\"miner_balance\":%.8f"
"}", ph, nh, lbf, pbf,
context->payment_threshold, context->pool_fee,
context->pool_port, context->pool_stats->connected_miners,
mh, mb);
response = MHD_create_response_from_buffer(strlen(json),
(void*) json, MHD_RESPMEM_MUST_COPY);
ret = MHD_queue_response(connection, MHD_HTTP_OK, response);
MHD_destroy_response(response);
return ret;
} }
int int
@ -89,86 +110,13 @@ answer_to_connection (void *cls, struct MHD_Connection *connection,
const char *upload_data, const char *upload_data,
size_t *upload_data_size, void **con_cls) size_t *upload_data_size, void **con_cls)
{ {
static char temp[TAG_MAX]; if (strstr(url, "/stats") != NULL)
return send_json_stats(cls, connection);
struct MHD_Response *response; struct MHD_Response *response;
int ret; response = MHD_create_response_from_buffer(webui_html_len,
wui_context_t *context = (wui_context_t*) cls; (void*) webui_html, MHD_RESPMEM_PERSISTENT);
int ret = MHD_queue_response(connection, MHD_HTTP_OK, response);
memset(page_buffer, 0, PAGE_MAX);
memcpy(page_buffer, webui_html, webui_html_len);
char *p = strstr(page_buffer, MINERS_CONNECTED);
memset(p, ' ', strlen(MINERS_CONNECTED));
sprintf(temp, "%d", context->pool_stats->connected_miners);
memcpy(p, temp, strlen(temp));
time_t now = time(NULL);
double diff = difftime(now, context->pool_stats->last_block_found);
if (context->pool_stats->last_block_found == 0)
snprintf(temp, TAG_MAX, "None yet");
else if (diff < 60)
snprintf(temp, TAG_MAX, "%d seconds ago", (int) diff);
else if (diff < 3600)
snprintf(temp, TAG_MAX, "%d minutes ago", (int) diff / 60);
else if (diff < 86400)
snprintf(temp, TAG_MAX, "%d hours ago", (int) diff / 3600);
else
snprintf(temp, TAG_MAX, "%d days ago", (int) diff / 86400);
p = strstr(page_buffer, LAST_BLOCK_FOUND);
memset(p, ' ', strlen(LAST_BLOCK_FOUND));
memcpy(p, temp, strlen(temp));
uint64_t nh = context->pool_stats->network_hashrate;
format_hashrate(nh, temp, TAG_MAX);
p = strstr(page_buffer, NETWORK_HASHRATE);
memset(p, ' ', strlen(NETWORK_HASHRATE));
memcpy(p, temp, strlen(temp));
uint64_t ph = context->pool_stats->pool_hashrate;
format_hashrate(ph, temp, TAG_MAX);
p = strstr(page_buffer, POOL_HASHRATE);
memset(p, ' ', strlen(POOL_HASHRATE));
memcpy(p, temp, strlen(temp));
sprintf(temp, "%d", context->pool_stats->pool_blocks_found);
p = strstr(page_buffer, POOL_BLOCKS_FOUND);
memset(p, ' ', strlen(POOL_BLOCKS_FOUND));
memcpy(p, temp, strlen(temp));
p = strstr(page_buffer, PAYMENT_THRESHOLD);
memset(p, ' ', strlen(PAYMENT_THRESHOLD));
sprintf(temp, "%.2f", context->payment_threshold);
memcpy(p, temp, strlen(temp));
p = strstr(page_buffer, POOL_FEE);
memset(p, ' ', strlen(POOL_FEE));
sprintf(temp, "%.2f", context->pool_fee);
memcpy(p, temp, strlen(temp));
sprintf(temp, "%d", context->pool_port);
p = strstr(page_buffer, POOL_PORT);
memset(p, ' ', strlen(POOL_PORT));
memcpy(p, temp, strlen(temp));
const char *wa = MHD_lookup_connection_value(connection, MHD_COOKIE_KIND, "wa");
if (wa != NULL)
{
uint64_t mh = miner_hr(wa);
format_hashrate(mh, temp, TAG_MAX);
p = strstr(page_buffer, MINER_HASHRATE);
memset(p, ' ', strlen(MINER_HASHRATE));
memcpy(p, temp, strlen(temp));
uint64_t balance = miner_balance(wa);
p = strstr(page_buffer, MINER_BALANCE_DUE);
memset(p, ' ', strlen(MINER_BALANCE_DUE));
sprintf(temp, "%.8f", (double) balance / 1000000000000.0);
memcpy(p, temp, strlen(temp));
}
response = MHD_create_response_from_buffer(strlen(page_buffer),
(void*) page_buffer, MHD_RESPMEM_PERSISTENT);
ret = MHD_queue_response(connection, MHD_HTTP_OK, response);
MHD_destroy_response(response); MHD_destroy_response(response);
return ret; return ret;
} }