OVE.rs/Bit.ASICmon-cpp
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Made simple work of UI, not works popup, shows online of device

Browse Source
This commit is contained in:
BitHeaven
2023-03-26 13:36:28 +05:00
parent 4f74b0a1b8
commit 743e823eb6
55 changed files with 9390 additions and 57 deletions
Download Patch File Download Diff File Expand all files Collapse all files

163
main.cpp
View File

@ -1,22 +1,11 @@
#include <iostream>
#include <string>
#include <cstdio>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <cstdlib>
#include <unistd.h>
#include <cstring>
#include <netdb.h>
#include <sys/uio.h>
#include <sys/time.h>
#include <sys/wait.h>
#include <sys/sendfile.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <fstream>
#include <iostream>
#include <netdb.h>
#include <regex>
#include <sys/sendfile.h>
#include <sys/stat.h>
#include "inc/args.hpp"
#include "inc/json.hpp"
@ -24,20 +13,21 @@
using namespace std;
using json = nlohmann::json;
int port = 9070;
json asictypes = json::parse(R"([
{"key": "A1066", "value": "Avalon 1066"}
])");
char* getFrom1066(char* ip, char* cmd) {
INFO("------ AVALON 1066 ------")
void tcpQuery(char* ip, int port, char* cmd, char* msg, int lenmsg) {
INFO("IP: ", ip)
INFO("Port: ", port)
INFO("Command: ", cmd)
int port = 4028;
int msglen = 1024*8;
char* msg = new char[msglen];
struct hostent* host = gethostbyname(ip);
sockaddr_in sendSockAddr;
bzero((char*)&sendSockAddr, sizeof(sendSockAddr));
@ -45,47 +35,87 @@ char* getFrom1066(char* ip, char* cmd) {
sendSockAddr.sin_addr.s_addr = inet_addr(inet_ntoa(*(struct in_addr*)*host->h_addr_list));
sendSockAddr.sin_port = htons(port);
int clientSd = socket(AF_INET, SOCK_STREAM, 0);
//try to connect...
int status = connect(clientSd, (sockaddr*) &sendSockAddr, sizeof(sendSockAddr));
if(status < 0) {
ERR("Error connecting to socket!")
return (char*)"";
return;
}
INFO("Connected to the server!")
memset(msg, 0, strlen(msg));
send(clientSd, cmd, sizeof(cmd), 0);
INFO("Awaiting server response...");
recv(clientSd, msg, msglen, MSG_WAITALL);
recv(clientSd, msg, lenmsg, MSG_WAITALL);
INFO("Server: ", msg)
close(clientSd);
INFO("-------------------------")
return msg;
}
char* httpGetURL(char line[], const char symbol[]) {
char *copy = (char*)malloc(strlen(line) + 1);
void getFrom1066(char* ip, char* cmd, char* msg, int lenmsg) {
INFO("------ AVALON 1066 ------")
int port = 4028;
tcpQuery(ip, port, cmd, msg, lenmsg);
}
void httpGetURL(char* url, char* line, const char* symbol) {
char *copy = new char[strlen(line) + 1];
strcpy(copy, line);
char *message;
char *token = strtok(copy, symbol);
char *token = new char[1024];
strcpy(token, strtok(copy, symbol));
int current = 0;
int run = 1;
while(token != nullptr) {
while(token != nullptr && run) {
token = strtok(nullptr, " ");
if(current == 0) {
message = token;
if (message == nullptr) {
message = (char *) "";
strcpy(url, token);
if (url == nullptr) {
strcpy(url, "");
}
return message;
run = 0;
}
current = current + 1;
}
free(copy);
free(token);
return message;
delete[] copy;
}
void parseUrl(char* url, char* res) {
res = strtok(url, "/");
while(res) {
INFO(res);
res = strtok(nullptr, "/");
}
}
void getStats(char* stats) {
ifstream f("asics.json");
json data = json::parse(f);
f.close();
json res;
if(data["mode"] == "manual") {
for (json::iterator it = data["asics"].begin(); it != data["asics"].end(); ++it) {
if(strcmp((*it)["type"].get<string>().c_str(), "A1066") == 0) {
int lenmsg = 1024*8;
char* msg = new char[lenmsg];
getFrom1066((char*)((*it)["address"].get<string>().c_str()), (char*)"summary", msg, lenmsg);
res["asics"][it.key()] = msg;
delete[] msg;
}
// INFO(it.key(), ": ", it.value())
}
}
else {
WARN("Not implemented!")
}
strcat(stats, res.dump().c_str());
data.clear();
res.clear();
}
void httpServer(int port) {
@ -119,7 +149,7 @@ void httpServer(int port) {
while(1) {
printf("\n+++++++ Waiting for new connection ++++++++\n\n");
if ((new_socket = accept(server_fd, (struct sockaddr *)&address, (socklen_t*)&addrlen)) < 0) {
if ((new_socket = accept(server_fd, (struct sockaddr*)&address, (socklen_t*)&addrlen)) < 0) {
CRIT("In accept")
exit(EXIT_FAILURE);
}
@ -131,13 +161,15 @@ void httpServer(int port) {
}
if(pid == 0) {
char buffer[30000] = {0};
read(new_socket , buffer, 30000);
char *url = httpGetURL(buffer, " ");
INFO(url)
char *url = new char[1024];
char *msg = new char[1024*64];
char *buffer = new char[30000];
char *copy_head = new char[strlen(http_header) + 200];
read(new_socket, buffer, 30000);
strcpy(copy_head, http_header);
httpGetURL(url, buffer, " ");
INFO(url)
if(strstr(url, "/api/"))
strcat(copy_head, "Content-Type: application/json\r\n\r\n");
@ -148,12 +180,13 @@ void httpServer(int port) {
write(new_socket, copy_head, strlen(copy_head));
if(strstr(url, ".js")) {
char file_path[512] = ".";
char *file_path = new char[512];
strcpy(file_path, ".");
strcat(file_path, url);
int file = open(file_path, O_RDONLY);
INFO(file);
if(file < 0){
WARN("Cannot Open file path : ", file_path, " with error ", file)
send(new_socket, R"({"error":"FILE_NOT_EXISTS"})", 27, MSG_DONTWAIT);
@ -162,18 +195,35 @@ void httpServer(int port) {
struct stat stat_buf;
fstat(file, &stat_buf);
sendfile(new_socket, file, nullptr, stat_buf.st_blksize);
delete[] file_path;
}
else if(strcmp(url, "/") == 0) {
char* msg = (char*)R"(<meta charset="UTF-8"><script defer src="/index.js"></script>)";
strcpy(msg, (char*)R"(<meta charset="UTF-8"><script defer src="/index.js"></script>)");
send(new_socket, msg, strlen(msg), MSG_DONTWAIT);
}
else if(strcmp(url, "/api/getstats") == 0) {
char *stats = new char[1024*64];
getStats(stats);
send(new_socket, stats, strlen(stats), MSG_DONTWAIT);
delete[] stats;
}
else if(strcmp(url, "/api/asictypes") == 0) {
strcpy(msg, asictypes.dump().c_str());
send(new_socket, msg, strlen(msg), MSG_DONTWAIT);
}
else {
char* msg = getFrom1066((char*)"128.128.128.56", (char*)"estats");
strcpy(msg, "");
send(new_socket, msg, strlen(msg), MSG_DONTWAIT);
}
delete[] msg;
delete[] url;
delete[] buffer;
delete[] copy_head;
close(new_socket);
free(copy_head);
exit(0);
}
else{
printf(">>>>>>>>>>Parent create child with pid: %d <<<<<<<<<", pid);
@ -201,16 +251,19 @@ int main(int argc, char **argv) {
else {
WARN("Port invalid using default: ", port)
}
delete[] aport;
}
getFrom1066((char*)"128.128.128.56", (char*)"version");
char* msg = getFrom1066((char*)"128.128.128.56", (char*)"estats");
// char* msg = getFrom1066((char*)"128.128.128.56", (char*)"estats");
// char* msg = getFrom1066((char*)"128.128.128.56", (char*)"summary");
regex re(R"(BOOTBY\[([\d\s\w.]+)\])");
cmatch m;
// regex re(R"(BOOTBY\[([\d\s\w.]+)\])");
// cmatch m;
regex_search(msg, m, re);
INFO(m[1])
// regex_search(msg, m, re);
// delete[] msg;
// INFO(m[1])
httpServer(port);