hwelltech block chain cpp sdk

Dependencies:   EthernetInterface SDFileSystem mbed-rtos mbed uniqueCPUID

Fork of bcsdk by Webb Xu

bcsdk 是 block chain sdk 的简写。它是由江苏恒为信息科技有限公司开发的 BlockChain 的 基于 mbed os 的 C++ 版本SDK,它能帮助开发者快速的在支持 mbed os 的芯片上开发 BlockChain 的应用。 bcsdk 的demo文件中包含了BlockChain中的 Key、Account、Asset、Transaction等方面的示例。其中: (1) Key 加密私钥是区块链上的主要授权机制。他们控制资产单位的发行和转让。 资产或帐户将定义发行或转移所需的单个密钥。 在 Key_test.cpp 中,我们实现了: 创建HSM密钥 键入密钥别名的名称(例如'gold','silver','bronze'),密钥别名是用于区分密钥的标签。

(2) Asset 资产是一种可以在区块链上发布的值类型。资产的所有单位均可互换,可以在各方之间直接交易,无需发行人参与。 在 Asset_test.cpp 中,我们实现了: 创建资产 键入资产别名的名称(例如'gold','silver','bronze'),资产别名是用于区分资产的标签。 选择“Key”键以使用现有的HSM密键,此密钥将用于此帐户中资产单位的发放和转移。

(3) Account 加帐户是恒为区块链核心平台中的一个对象,通过创建和跟踪控制程序来跟踪区块链上的资产的所有权。创建帐户时,您提供一个或多个“root”密钥和仲裁。 在 Account_test.cpp 中,我们实现了: 创建帐户 1 输入帐户别名的名称(例如'alice','bob'),帐户别名是用于区分帐户的标签。 2 键入名称以生成新的HSM密钥(例如'alice key','bob key'),此密钥将用于此帐户中资产单位的发放和转移。

(4) Transaction 交易包含一个或多个输入,以及一个或多个输出。恒为区块链核心平台的API允许您使用操作(包括发出,支出和返还)构建交易。 在 Transaction_test.cpp 中,我们实现了: 资产的交易 1 添加“账户支出”操作 2 为资产别名选择“Asset” 3 输入“100”作为金额 4 添加“使用帐户控制”操作 5 为帐户别名选择“Account” 6 为资产别名选择“Asset” 7 输入“100”作为金额 8 “提交”

Revision:
8:f2a567ee3a46
Child:
10:aabd720e632c
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/Client.cpp	Thu Sep 21 02:09:04 2017 +0000
@@ -0,0 +1,182 @@
+#include "Client.h"
+//#include <WINSOCK2.H>  
+#include "mbed.h"
+#include "EthernetInterface.h"
+//#include "BlockChain.h"
+
+
+Client::Client()
+{
+	m_strIP = "101.201.199.150";
+	m_sPort = 80;
+	m_url = "/info";
+	m_host = "testbc.hwelltech.com";
+	m_token = "962cd39d-6496-4b23-a2c5-85e445069a78";
+}
+
+Client::Client(string ip,short port)
+{
+	this->m_strIP = ip;
+	this->m_sPort = port;
+
+	m_url = "/info";
+	m_host = "testbc.hwelltech.com";
+	m_token = "962cd39d-6496-4b23-a2c5-85e445069a78";
+}
+
+Client::~Client()
+{
+
+}
+
+bool Client::build_post_raw(const string & url,const string & content, string & post_raw)
+{
+	return build_post_raw(url,m_host,m_token,content,post_raw);
+}
+
+bool Client::build_post_raw(const string & url, const string & host, const string & token, const string & content, string & post_raw)
+{
+	bool ret = true;
+
+	post_raw = "";
+	post_raw.append("POST "+ url + " HTTP/1.1\r\n");
+	post_raw.append("Host: " + host + "\r\n");
+	post_raw.append("Connection: keep-alive\r\n");
+	post_raw.append("accept: application/json\r\n");
+	post_raw.append("content-type: application/json\r\n");
+	string authorization = "Basic YmxvY2tnZW5lcmF0b3I6MTM3NzQzMDJlNTcyYmU4MWMxZmRmZjg2NGZiODA2Yjc2NjcxMzg5NzMwZjBjMDYwZDNlODExNTQ4OGRjNjQ2Mg==";
+	//if(!token.empty())
+	//	authorization = Base64Encode(token)
+	post_raw.append("authorization: " + authorization + "\r\n");
+
+	char pLen[16] = {0};
+	//sprintf_s(pLen, sizeof(pLen), "%d", content.length());
+	sprintf(pLen, "%d", content.length());
+	string strLen = pLen;
+
+	post_raw.append("Content-Length: " + strLen + "\r\n");
+	post_raw.append("\r\n");
+	post_raw.append(content);
+	post_raw.append("\r\n\r\n");
+
+	return ret;
+}
+
+int Client::http_post(const string & url,const string & content,string & strOut)
+{
+	string post_raw = "";
+	build_post_raw(url,content,post_raw);
+	return http_post_raw(post_raw,strOut);
+}
+
+int Client::http_post_raw(const string &strIn,string &strOut)
+{
+	string strReq;
+	string strRep;
+	strReq = strIn;
+
+	//SOCKET sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);  
+	TCPSocketConnection sClient;
+/*
+	if(sClient == INVALID_SOCKET)  
+	{  
+		printf("invalid socket!");  
+		return 0;  
+	} 
+*/ 
+#ifdef WIN32
+	// windows下是这样设置超时时间
+	int recvTimeout = 3 * 1000;   //30s
+	int sendTimeout = 3 * 1000;  //30s
+	setsockopt(sClient, SOL_SOCKET, SO_RCVTIMEO, (char *)&recvTimeout ,sizeof(int));
+	setsockopt(sClient, SOL_SOCKET, SO_SNDTIMEO, (char *)&sendTimeout ,sizeof(int));
+#elif __LINUX__
+	// linux下是这样设置超时时间
+	struct timeval timeout = {3,0};    
+	setsockopt(sClient, SOL_SOCKET, SO_RCVTIMEO, (char *)&timeout,sizeof(struct timeval));
+	setsockopt(sClient, SOL_SOCKET, SO_SNDTIMEO, (char *)&timeout,sizeof(struct timeval));
+#else 
+	unsigned int timeout = 1500;
+	sClient.set_blocking(false, timeout); // Timeout after (1.5)s
+#endif
+
+
+/*
+	sockaddr_in serAddr;  
+	serAddr.sin_family = AF_INET;  
+	serAddr.sin_port = htons(m_sPort);  
+	serAddr.sin_addr.S_un.S_addr = inet_addr(m_strIP.c_str());  
+	if(connect(sClient, (sockaddr *)&serAddr, sizeof(serAddr)) == SOCKET_ERROR)  
+	{  
+		printf("connect error !");  
+		closesocket(sClient);  
+		return SOCKET_ERROR;  
+	}  
+*/	
+	while (sClient.connect(m_strIP.c_str(), m_sPort) < 0) {
+        printf("Unable to connect to (%s) on port (%d)\n", m_strIP.c_str(), m_sPort);
+        wait(1);
+    }
+    printf("Connected to Server at %s\n", m_strIP.c_str());
+    
+	int ret = 0;
+
+/*	
+	int left = strReq.length();
+	unsigned int pos = 0;
+	ret = send(sClient, strReq.c_str(), strReq.length(), 0);  
+	while (ret < left )
+	{
+		pos = pos + ret;
+		ret = send(sClient, strReq.c_str() + pos, strReq.length() - pos, 0);  
+		ret = sClient.send(strReq.c_str() + pos, strReq.length() - pos);
+		if (ret < 0)
+		{
+			return SOCKET_ERROR;
+		}
+	}
+*/	
+	ret = sClient.send_all((char *)strReq.c_str(), strReq.length());
+	if (ret < 0)
+	{
+		//get last error
+		//get errno
+		return ret;
+	}
+
+#ifdef DEBUG_LOG
+	cout<< ">>>>>>>>>>HTTP Request (Length = "<< strReq.length() << "):\n" << strReq << endl;
+#endif
+
+
+	char recData[BUFSIZE+1] = {0};  
+
+	ret = 0;
+	//ret = recv(sClient, recData, BUFSIZE, 0);  
+	ret = sClient.receive(recData, BUFSIZE);
+	strRep.append(recData);
+
+	// 第一次收数据可能没有收完全,所以一直收到没有数据为止,这里会堵塞
+	while (ret > 0)
+	{
+		memset(recData,0,BUFSIZE);
+		//ret = recv(sClient, recData, BUFSIZE, 0); 
+		ret = sClient.receive(recData, BUFSIZE);
+
+		if (ret > 0)
+		{
+			strRep.append(recData);
+		}
+	}
+
+	strOut = strRep;
+
+#ifdef DEBUG_LOG
+	cout<< ">>>>>>>>>>HTTP Response (Length = "<< strRep.length() << "):\n" << strRep << endl;
+#endif
+
+	// Clean up
+	//closesocket(sClient); 
+    sClient.close();
+	return 0;
+}