com_zerotierone_sdk_Node.cpp 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922
  1. /*
  2. * ZeroTier One - Network Virtualization Everywhere
  3. * Copyright (C) 2011-2015 ZeroTier, Inc.
  4. *
  5. * This program is free software: you can redistribute it and/or modify
  6. * it under the terms of the GNU General Public License as published by
  7. * the Free Software Foundation, either version 3 of the License, or
  8. * (at your option) any later version.
  9. *
  10. * This program is distributed in the hope that it will be useful,
  11. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  13. * GNU General Public License for more details.
  14. *
  15. * You should have received a copy of the GNU General Public License
  16. * along with this program. If not, see <http://www.gnu.org/licenses/>.
  17. *
  18. * --
  19. *
  20. * ZeroTier may be used and distributed under the terms of the GPLv3, which
  21. * are available at: http://www.gnu.org/licenses/gpl-3.0.html
  22. *
  23. * If you would like to embed ZeroTier into a commercial application or
  24. * redistribute it in a modified binary form, please contact ZeroTier Networks
  25. * LLC. Start here: http://www.zerotier.com/
  26. */
  27. #include "com_zerotierone_sdk_Node.h"
  28. #include "ZT1_jniutils.h"
  29. #include <ZeroTierOne.h>
  30. #include <map>
  31. #include <string>
  32. #include <assert.h>
  33. #include <string.h>
  34. #ifdef __cplusplus
  35. extern "C" {
  36. #endif
  37. namespace {
  38. struct JniRef
  39. {
  40. JniRef()
  41. : env(NULL)
  42. , node(NULL)
  43. , dataStoreGetListener(NULL)
  44. , dataStorePutListener(NULL)
  45. , packetSender(NULL)
  46. , frameListener(NULL)
  47. , configListener(NULL)
  48. {}
  49. uint64_t id;
  50. JNIEnv *env;
  51. ZT1_Node *node;
  52. jobject dataStoreGetListener;
  53. jobject dataStorePutListener;
  54. jobject packetSender;
  55. jobject frameListener;
  56. jobject configListener;
  57. };
  58. int VirtualNetworkConfigFunctionCallback(ZT1_Node *node,void *userData,uint64_t,enum ZT1_VirtualNetworkConfigOperation,const ZT1_VirtualNetworkConfig *)
  59. {
  60. JniRef *ref = (JniRef*)userData;
  61. assert(ref->node == node);
  62. JNIEnv *env = ref->env;
  63. return 0;
  64. }
  65. void VirtualNetworkFrameFunctionCallback(ZT1_Node *node,void *userData,uint64_t,uint64_t,uint64_t,unsigned int,unsigned int,const void *,unsigned int)
  66. {
  67. JniRef *ref = (JniRef*)userData;
  68. assert(ref->node == node);
  69. JNIEnv *env = ref->env;
  70. }
  71. void EventCallback(ZT1_Node *node,void *userData,enum ZT1_Event,const void *)
  72. {
  73. JniRef *ref = (JniRef*)userData;
  74. assert(ref->node == node);
  75. JNIEnv *env = ref->env;
  76. }
  77. long DataStoreGetFunction(ZT1_Node *node,void *userData,const char *,void *,unsigned long,unsigned long,unsigned long *)
  78. {
  79. JniRef *ref = (JniRef*)userData;
  80. assert(ref->node == node);
  81. JNIEnv *env = ref->env;
  82. return 0;
  83. }
  84. int DataStorePutFunction(ZT1_Node *node,void *userData,const char *,const void *,unsigned long,int)
  85. {
  86. JniRef *ref = (JniRef*)userData;
  87. assert(ref->node == node);
  88. JNIEnv *env = ref->env;
  89. return 0;
  90. }
  91. int WirePacketSendFunction(ZT1_Node *node,void *userData,const struct sockaddr_storage *,unsigned int,const void *,unsigned int)
  92. {
  93. JniRef *ref = (JniRef*)userData;
  94. assert(ref->node == node);
  95. JNIEnv *env = ref->env;
  96. return 0;
  97. }
  98. typedef std::map<uint64_t, JniRef*> NodeMap;
  99. static NodeMap nodeMap;
  100. ZT1_Node* findNode(uint64_t nodeId)
  101. {
  102. NodeMap::iterator found = nodeMap.find(nodeId);
  103. if(found != nodeMap.end())
  104. {
  105. JniRef *ref = found->second;
  106. return ref->node;
  107. }
  108. return NULL;
  109. }
  110. }
  111. /*
  112. * Class: com_zerotierone_sdk_Node
  113. * Method: node_init
  114. * Signature: (J)Lcom/zerotierone/sdk/ResultCode;
  115. */
  116. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_node_1init(
  117. JNIEnv *env, jobject obj, jlong now)
  118. {
  119. jobject resultObject = createResultObject(env, ZT1_RESULT_OK);
  120. ZT1_Node *node;
  121. JniRef *ref = new JniRef;
  122. ZT1_ResultCode rc = ZT1_Node_new(
  123. &node,
  124. ref,
  125. (uint64_t)now,
  126. &DataStoreGetFunction,
  127. &DataStorePutFunction,
  128. &WirePacketSendFunction,
  129. &VirtualNetworkFrameFunctionCallback,
  130. &VirtualNetworkConfigFunctionCallback,
  131. &EventCallback);
  132. if(rc != ZT1_RESULT_OK)
  133. {
  134. resultObject = createResultObject(env, rc);
  135. if(node)
  136. {
  137. ZT1_Node_delete(node);
  138. node = NULL;
  139. }
  140. delete ref;
  141. ref = NULL;
  142. return resultObject;
  143. }
  144. ref->id = (uint64_t)now;
  145. ref->env = env;
  146. ref->node = node;
  147. jclass cls = env->GetObjectClass(obj);
  148. jfieldID fid = env->GetFieldID(
  149. cls, "getListener", "Lcom/zerotierone/sdk/DataStoreGetListener;");
  150. if(fid == NULL)
  151. {
  152. return NULL; // exception already thrown
  153. }
  154. ref->dataStoreGetListener = env->GetObjectField(obj, fid);
  155. if(ref->dataStoreGetListener == NULL)
  156. {
  157. return NULL;
  158. }
  159. fid = env->GetFieldID(
  160. cls, "putListener", "Lcom/zerotierone/sdk/DataStorePutLisetner;");
  161. if(fid == NULL)
  162. {
  163. return NULL; // exception already thrown
  164. }
  165. ref->dataStorePutListener = env->GetObjectField(obj, fid);
  166. if(ref->dataStorePutListener == NULL)
  167. {
  168. return NULL;
  169. }
  170. fid = env->GetFieldID(
  171. cls, "sender", "Lcom/zerotierone/sdk/PacketSender;");
  172. if(fid == NULL)
  173. {
  174. return NULL; // exception already thrown
  175. }
  176. ref->packetSender = env->GetObjectField(obj, fid);
  177. if(ref->packetSender == NULL)
  178. {
  179. return NULL;
  180. }
  181. fid = env->GetFieldID(
  182. cls, "frameListener", "Lcom/zerotierone/sdk/VirtualNetworkFrameListener;");
  183. if(fid == NULL)
  184. {
  185. return NULL; // exception already thrown
  186. }
  187. ref->frameListener = env->GetObjectField(obj, fid);
  188. if(ref->frameListener = NULL)
  189. {
  190. return NULL;
  191. }
  192. fid = env->GetFieldID(
  193. cls, "configListener", "Lcom/zerotierone/sdk/VirtualNetworkConfigListener;");
  194. if(fid == NULL)
  195. {
  196. return NULL; // exception already thrown
  197. }
  198. ref->configListener = env->GetObjectField(obj, fid);
  199. if(ref->configListener == NULL)
  200. {
  201. return NULL;
  202. }
  203. nodeMap.insert(std::make_pair(ref->id, ref));
  204. return resultObject;
  205. }
  206. /*
  207. * Class: com_zerotierone_sdk_Node
  208. * Method: node_delete
  209. * Signature: (J)V
  210. */
  211. JNIEXPORT void JNICALL Java_com_zerotierone_sdk_Node_node_1delete(
  212. JNIEnv *env, jobject obj, jlong id)
  213. {
  214. uint64_t nodeId = (uint64_t)id;
  215. NodeMap::iterator found = nodeMap.find(nodeId);
  216. if(found != nodeMap.end())
  217. {
  218. JniRef *ref = found->second;
  219. nodeMap.erase(found);
  220. ZT1_Node_delete(ref->node);
  221. delete ref;
  222. ref = NULL;
  223. }
  224. }
  225. /*
  226. * Class: com_zerotierone_sdk_Node
  227. * Method: processVirtualNetworkFrame
  228. * Signature: (JJJJJII[B[J)Lcom/zerotierone/sdk/ResultCode;
  229. */
  230. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_processVirtualNetworkFrame(
  231. JNIEnv *env, jobject obj,
  232. jlong id,
  233. jlong in_now,
  234. jlong in_nwid,
  235. jlong in_sourceMac,
  236. jlong in_destMac,
  237. jint in_etherType,
  238. jint in_vlanId,
  239. jbyteArray in_frameData,
  240. jlongArray out_nextBackgroundTaskDeadline)
  241. {
  242. uint64_t nodeId = (uint64_t) id;
  243. ZT1_Node *node = findNode(nodeId);
  244. if(node == NULL)
  245. {
  246. // cannot find valid node. We should never get here.
  247. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  248. }
  249. unsigned int nbtd_len = env->GetArrayLength(out_nextBackgroundTaskDeadline);
  250. if(nbtd_len < 1)
  251. {
  252. // array for next background task length has 0 elements!
  253. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  254. }
  255. uint64_t now = (uint64_t)in_now;
  256. uint64_t nwid = (uint64_t)in_nwid;
  257. uint64_t sourceMac = (uint64_t)in_sourceMac;
  258. uint64_t destMac = (uint64_t)in_destMac;
  259. unsigned int etherType = (unsigned int)in_etherType;
  260. unsigned int vlanId = (unsigned int)in_vlanId;
  261. unsigned int frameLength = env->GetArrayLength(in_frameData);
  262. jbyte *frameData =env->GetByteArrayElements(in_frameData, NULL);
  263. uint64_t nextBackgroundTaskDeadline = 0;
  264. ZT1_ResultCode rc = ZT1_Node_processVirtualNetworkFrame(
  265. node,
  266. now,
  267. nwid,
  268. sourceMac,
  269. destMac,
  270. etherType,
  271. vlanId,
  272. (const void*)frameData,
  273. frameLength,
  274. &nextBackgroundTaskDeadline);
  275. jlong *outDeadline = env->GetLongArrayElements(out_nextBackgroundTaskDeadline, NULL);
  276. outDeadline[0] = (jlong)nextBackgroundTaskDeadline;
  277. env->ReleaseLongArrayElements(out_nextBackgroundTaskDeadline, outDeadline, 0);
  278. env->ReleaseByteArrayElements(in_frameData, frameData, 0);
  279. return createResultObject(env, rc);
  280. }
  281. /*
  282. * Class: com_zerotierone_sdk_Node
  283. * Method: processWirePacket
  284. * Signature: (JJLjava/net/InetAddress;I[B[J)Lcom/zerotierone/sdk/ResultCode;
  285. */
  286. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_processWirePacket(
  287. JNIEnv *env, jobject obj,
  288. jlong id,
  289. jlong in_now,
  290. jobject in_remoteAddress,
  291. jint in_linkDesparation,
  292. jbyteArray in_packetData,
  293. jlongArray out_nextBackgroundTaskDeadline)
  294. {
  295. uint64_t nodeId = (uint64_t) id;
  296. ZT1_Node *node = findNode(nodeId);
  297. if(node == NULL)
  298. {
  299. // cannot find valid node. We should never get here.
  300. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  301. }
  302. unsigned int nbtd_len = env->GetArrayLength(out_nextBackgroundTaskDeadline);
  303. if(nbtd_len < 1)
  304. {
  305. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  306. }
  307. uint64_t now = (uint64_t)in_now;
  308. unsigned int linkDesparation = (unsigned int)in_linkDesparation;
  309. // get the java.net.InetAddress class and getAddress() method
  310. jclass inetAddressClass = env->FindClass("java/net/InetAddress");
  311. if(inetAddressClass == NULL)
  312. {
  313. // can't find java.net.InetAddress
  314. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  315. }
  316. jmethodID getAddressMethod = env->GetMethodID(
  317. inetAddressClass, "getAddress", "()[B");
  318. if(getAddressMethod == NULL)
  319. {
  320. // cant find InetAddress.getAddres()
  321. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  322. }
  323. // Call InetAddress.getAddress()
  324. jbyteArray addressArray = (jbyteArray)env->CallObjectMethod(in_remoteAddress, getAddressMethod);
  325. if(addressArray == NULL)
  326. {
  327. // unable to call getAddress()
  328. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  329. }
  330. unsigned int addrSize = env->GetArrayLength(addressArray);
  331. // get the address bytes
  332. jbyte *addr = env->GetByteArrayElements(addressArray, NULL);
  333. sockaddr_storage remoteAddress = {};
  334. if(addrSize == 16)
  335. {
  336. // IPV6 address
  337. sockaddr_in6 ipv6 = {};
  338. ipv6.sin6_family = AF_INET6;
  339. memcpy(ipv6.sin6_addr.s6_addr, addr, 16);
  340. memcpy(&remoteAddress, &ipv6, sizeof(sockaddr_in6));
  341. }
  342. else if(addrSize = 4)
  343. {
  344. // IPV4 address
  345. sockaddr_in ipv4 = {};
  346. ipv4.sin_family = AF_INET;
  347. memcpy(&ipv4.sin_addr, addr, 4);
  348. memcpy(&remoteAddress, &ipv4, sizeof(sockaddr_in));
  349. }
  350. else
  351. {
  352. // unknown address type
  353. env->ReleaseByteArrayElements(addressArray, addr, 0);
  354. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  355. }
  356. unsigned int packetLength = env->GetArrayLength(in_packetData);
  357. jbyte *packetData = env->GetByteArrayElements(in_packetData, NULL);
  358. uint64_t nextBackgroundTaskDeadline = 0;
  359. ZT1_ResultCode rc = ZT1_Node_processWirePacket(
  360. node,
  361. now,
  362. &remoteAddress,
  363. linkDesparation,
  364. packetData,
  365. packetLength,
  366. &nextBackgroundTaskDeadline);
  367. jlong *outDeadline = env->GetLongArrayElements(out_nextBackgroundTaskDeadline, NULL);
  368. outDeadline[0] = (jlong)nextBackgroundTaskDeadline;
  369. env->ReleaseLongArrayElements(out_nextBackgroundTaskDeadline, outDeadline, 0);
  370. env->ReleaseByteArrayElements(addressArray, addr, 0);
  371. env->ReleaseByteArrayElements(in_packetData, packetData, 0);
  372. return createResultObject(env, ZT1_RESULT_OK);
  373. }
  374. /*
  375. * Class: com_zerotierone_sdk_Node
  376. * Method: processBackgroundTasks
  377. * Signature: (JJ[J)Lcom/zerotierone/sdk/ResultCode;
  378. */
  379. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_processBackgroundTasks(
  380. JNIEnv *env, jobject obj,
  381. jlong id,
  382. jlong in_now,
  383. jlongArray out_nextBackgroundTaskDeadline)
  384. {
  385. uint64_t nodeId = (uint64_t) id;
  386. ZT1_Node *node = findNode(nodeId);
  387. if(node == NULL)
  388. {
  389. // cannot find valid node. We should never get here.
  390. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  391. }
  392. unsigned int nbtd_len = env->GetArrayLength(out_nextBackgroundTaskDeadline);
  393. if(nbtd_len < 1)
  394. {
  395. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  396. }
  397. uint64_t now = (uint64_t)in_now;
  398. uint64_t nextBackgroundTaskDeadline = 0;
  399. ZT1_ResultCode rc = ZT1_Node_processBackgroundTasks(node, now, &nextBackgroundTaskDeadline);
  400. jlong *outDeadline = env->GetLongArrayElements(out_nextBackgroundTaskDeadline, NULL);
  401. outDeadline[0] = (jlong)nextBackgroundTaskDeadline;
  402. env->ReleaseLongArrayElements(out_nextBackgroundTaskDeadline, outDeadline, 0);
  403. return createResultObject(env, rc);
  404. }
  405. /*
  406. * Class: com_zerotierone_sdk_Node
  407. * Method: join
  408. * Signature: (JJ)Lcom/zerotierone/sdk/ResultCode;
  409. */
  410. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_join(
  411. JNIEnv *env, jobject obj, jlong id, jlong in_nwid)
  412. {
  413. uint64_t nodeId = (uint64_t) id;
  414. ZT1_Node *node = findNode(nodeId);
  415. if(node == NULL)
  416. {
  417. // cannot find valid node. We should never get here.
  418. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  419. }
  420. uint64_t nwid = (uint64_t)in_nwid;
  421. ZT1_ResultCode rc = ZT1_Node_join(node, nwid);
  422. return createResultObject(env, rc);
  423. }
  424. /*
  425. * Class: com_zerotierone_sdk_Node
  426. * Method: leave
  427. * Signature: (JJ)Lcom/zerotierone/sdk/ResultCode;
  428. */
  429. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_leave(
  430. JNIEnv *env, jobject obj, jlong id, jlong in_nwid)
  431. {
  432. uint64_t nodeId = (uint64_t) id;
  433. ZT1_Node *node = findNode(nodeId);
  434. if(node == NULL)
  435. {
  436. // cannot find valid node. We should never get here.
  437. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  438. }
  439. uint64_t nwid = (uint64_t)in_nwid;
  440. ZT1_ResultCode rc = ZT1_Node_leave(node, nwid);
  441. return createResultObject(env, rc);
  442. }
  443. /*
  444. * Class: com_zerotierone_sdk_Node
  445. * Method: multicastSubscribe
  446. * Signature: (JJJJ)Lcom/zerotierone/sdk/ResultCode;
  447. */
  448. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_multicastSubscribe(
  449. JNIEnv *env, jobject obj,
  450. jlong id,
  451. jlong in_nwid,
  452. jlong in_multicastGroup,
  453. jlong in_multicastAdi)
  454. {
  455. uint64_t nodeId = (uint64_t) id;
  456. ZT1_Node *node = findNode(nodeId);
  457. if(node == NULL)
  458. {
  459. // cannot find valid node. We should never get here.
  460. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  461. }
  462. uint64_t nwid = (uint64_t)in_nwid;
  463. uint64_t multicastGroup = (uint64_t)in_multicastGroup;
  464. uint64_t multicastAdi = (uint64_t)in_multicastAdi;
  465. ZT1_ResultCode rc = ZT1_Node_multicastSubscribe(
  466. node, nwid, multicastGroup, multicastAdi);
  467. return createResultObject(env, rc);
  468. }
  469. /*
  470. * Class: com_zerotierone_sdk_Node
  471. * Method: multicastUnsubscribe
  472. * Signature: (JJJJ)Lcom/zerotierone/sdk/ResultCode;
  473. */
  474. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_multicastUnsubscribe(
  475. JNIEnv *env, jobject obj,
  476. jlong id,
  477. jlong in_nwid,
  478. jlong in_multicastGroup,
  479. jlong in_multicastAdi)
  480. {
  481. uint64_t nodeId = (uint64_t) id;
  482. ZT1_Node *node = findNode(nodeId);
  483. if(node == NULL)
  484. {
  485. // cannot find valid node. We should never get here.
  486. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  487. }
  488. uint64_t nwid = (uint64_t)in_nwid;
  489. uint64_t multicastGroup = (uint64_t)in_multicastGroup;
  490. uint64_t multicastAdi = (uint64_t)in_multicastAdi;
  491. ZT1_ResultCode rc = ZT1_Node_multicastUnsubscribe(
  492. node, nwid, multicastGroup, multicastAdi);
  493. return createResultObject(env, rc);
  494. }
  495. /*
  496. * Class: com_zerotierone_sdk_Node
  497. * Method: address
  498. * Signature: (J)J
  499. */
  500. JNIEXPORT jlong JNICALL Java_com_zerotierone_sdk_Node_address(
  501. JNIEnv *env , jobject obj, jlong id)
  502. {
  503. uint64_t nodeId = (uint64_t) id;
  504. ZT1_Node *node = findNode(nodeId);
  505. if(node == NULL)
  506. {
  507. // cannot find valid node. We should never get here.
  508. return 0;
  509. }
  510. uint64_t address = ZT1_Node_address(node);
  511. return (jlong)address;
  512. }
  513. /*
  514. * Class: com_zerotierone_sdk_Node
  515. * Method: status
  516. * Signature: (J)Lcom/zerotierone/sdk/NodeStatus;
  517. */
  518. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_status
  519. (JNIEnv *env, jobject obj, jlong id)
  520. {
  521. uint64_t nodeId = (uint64_t) id;
  522. ZT1_Node *node = findNode(nodeId);
  523. if(node == NULL)
  524. {
  525. // cannot find valid node. We should never get here.
  526. return 0;
  527. }
  528. // static so we only have to look these up once
  529. static jclass nodeStatusClass = NULL;
  530. static jmethodID nodeStatusConstructor = NULL;
  531. // create a com.zerotierone.sdk.NodeStatus object
  532. if(nodeStatusClass == NULL)
  533. {
  534. nodeStatusClass = env->FindClass("com/zerotierone/sdk/NodeStatus");
  535. if(nodeStatusClass == NULL)
  536. {
  537. return NULL;
  538. }
  539. }
  540. if(nodeStatusConstructor == NULL)
  541. {
  542. nodeStatusConstructor = env->GetMethodID(
  543. nodeStatusClass, "<init>", "()V");
  544. if(nodeStatusConstructor == NULL)
  545. {
  546. return NULL;
  547. }
  548. }
  549. jobject nodeStatusObj = env->NewObject(nodeStatusClass, nodeStatusConstructor);
  550. if(nodeStatusObj == NULL)
  551. {
  552. return NULL;
  553. }
  554. ZT1_NodeStatus nodeStatus;
  555. ZT1_Node_status(node, &nodeStatus);
  556. static jfieldID addressField = NULL;
  557. static jfieldID publicIdentityField = NULL;
  558. static jfieldID secretIdentityField = NULL;
  559. static jfieldID onlineField = NULL;
  560. if(addressField == NULL)
  561. {
  562. addressField = env->GetFieldID(nodeStatusClass, "address", "J");
  563. if(addressField == NULL)
  564. {
  565. return NULL;
  566. }
  567. }
  568. if(publicIdentityField == NULL)
  569. {
  570. publicIdentityField = env->GetFieldID(nodeStatusClass, "publicIdentity", "Ljava/lang/String;");
  571. if(publicIdentityField == NULL)
  572. {
  573. return NULL;
  574. }
  575. }
  576. if(secretIdentityField == NULL)
  577. {
  578. secretIdentityField = env->GetFieldID(nodeStatusClass, "secretIdentity", "Ljava/lang/String;");
  579. if(secretIdentityField == NULL)
  580. {
  581. return NULL;
  582. }
  583. }
  584. if(onlineField == NULL)
  585. {
  586. onlineField = env->GetFieldID(nodeStatusClass, "online", "Z");
  587. if(onlineField == NULL)
  588. {
  589. return NULL;
  590. }
  591. }
  592. env->SetLongField(nodeStatusObj, addressField, nodeStatus.address);
  593. jstring pubIdentStr = env->NewStringUTF(nodeStatus.publicIdentity);
  594. if(pubIdentStr == NULL)
  595. {
  596. return NULL; // out of memory
  597. }
  598. env->SetObjectField(nodeStatusObj, publicIdentityField, pubIdentStr);
  599. jstring secIdentStr = env->NewStringUTF(nodeStatus.secretIdentity);
  600. if(secIdentStr == NULL)
  601. {
  602. return NULL; // out of memory
  603. }
  604. env->SetObjectField(nodeStatusObj, secretIdentityField, secIdentStr);
  605. env->SetBooleanField(nodeStatusObj, onlineField, nodeStatus.online);
  606. return nodeStatusObj;
  607. }
  608. /*
  609. * Class: com_zerotierone_sdk_Node
  610. * Method: networkConfig
  611. * Signature: (J)Lcom/zerotierone/sdk/VirtualNetworkConfig;
  612. */
  613. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_networkConfig(
  614. JNIEnv *env, jobject obj, jlong id, jlong nwid)
  615. {
  616. uint64_t nodeId = (uint64_t) id;
  617. ZT1_Node *node = findNode(nodeId);
  618. if(node == NULL)
  619. {
  620. // cannot find valid node. We should never get here.
  621. return 0;
  622. }
  623. ZT1_VirtualNetworkConfig *vnetConfig = ZT1_Node_networkConfig(node, nwid);
  624. jobject vnetConfigObject = newNetworkConfig(env, *vnetConfig);
  625. ZT1_Node_freeQueryResult(node, vnetConfig);
  626. return vnetConfigObject;
  627. }
  628. /*
  629. * Class: com_zerotierone_sdk_Node
  630. * Method: version
  631. * Signature: (J)Lcom/zerotierone/sdk/Version;
  632. */
  633. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_version(
  634. JNIEnv *env, jobject obj)
  635. {
  636. // create a com.zerotierone.sdk.Version object
  637. jclass versionClass = env->FindClass("com/zerotierone/sdk/Version");
  638. if(versionClass == NULL)
  639. {
  640. return NULL;
  641. }
  642. jmethodID versionConstructor = env->GetMethodID(
  643. versionClass, "<init>", "()V");
  644. if(versionConstructor == NULL)
  645. {
  646. return NULL;
  647. }
  648. jobject versionObj = env->NewObject(versionClass, versionConstructor);
  649. if(versionObj == NULL)
  650. {
  651. return NULL;
  652. }
  653. int major = 0;
  654. int minor = 0;
  655. int revision = 0;
  656. unsigned long featureFlags = 0;
  657. ZT1_version(&major, &minor, &revision, &featureFlags);
  658. // copy data to Version object
  659. static jfieldID majorField = NULL;
  660. static jfieldID minorField = NULL;
  661. static jfieldID revisionField = NULL;
  662. static jfieldID featureFlagsField = NULL;
  663. if(majorField == NULL)
  664. {
  665. majorField = env->GetFieldID(versionClass, "major", "I");
  666. if(majorField = NULL)
  667. {
  668. return NULL;
  669. }
  670. }
  671. if(minorField == NULL)
  672. {
  673. minorField = env->GetFieldID(versionClass, "minor", "I");
  674. if(minorField == NULL)
  675. {
  676. return NULL;
  677. }
  678. }
  679. if(revisionField == NULL)
  680. {
  681. revisionField = env->GetFieldID(versionClass, "revision", "I");
  682. if(revisionField == NULL)
  683. {
  684. return NULL;
  685. }
  686. }
  687. if(featureFlagsField == NULL)
  688. {
  689. featureFlagsField = env->GetFieldID(versionClass, "featureFlags", "J");
  690. if(featureFlagsField == NULL)
  691. {
  692. return NULL;
  693. }
  694. }
  695. env->SetIntField(versionObj, majorField, (jint)major);
  696. env->SetIntField(versionObj, minorField, (jint)minor);
  697. env->SetIntField(versionObj, revisionField, (jint)revision);
  698. env->SetLongField(versionObj, featureFlagsField, (jlong)featureFlags);
  699. return versionObj;
  700. }
  701. /*
  702. * Class: com_zerotierone_sdk_Node
  703. * Method: peers
  704. * Signature: (J)Ljava/util/ArrayList;
  705. */
  706. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_peers(
  707. JNIEnv *env, jobject obj, jlong id)
  708. {
  709. uint64_t nodeId = (uint64_t) id;
  710. ZT1_Node *node = findNode(nodeId);
  711. if(node == NULL)
  712. {
  713. // cannot find valid node. We should never get here.
  714. return 0;
  715. }
  716. ZT1_PeerList *peerList = ZT1_Node_peers(node);
  717. if(peerList == NULL)
  718. {
  719. return NULL;
  720. }
  721. jobject peerListObject = newArrayList(env);
  722. if(peerListObject == NULL)
  723. {
  724. ZT1_Node_freeQueryResult(node, peerList);
  725. return NULL;
  726. }
  727. for(unsigned int i = 0; i < peerList->peerCount; ++i)
  728. {
  729. jobject peerObj = newPeer(env, peerList->peers[i]);
  730. appendItemToArrayList(env, peerListObject, peerObj);
  731. }
  732. ZT1_Node_freeQueryResult(node, peerList);
  733. peerList = NULL;
  734. return peerListObject;
  735. }
  736. /*
  737. * Class: com_zerotierone_sdk_Node
  738. * Method: networks
  739. * Signature: (J)Ljava/util/ArrayList;
  740. */
  741. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_networks(
  742. JNIEnv *env, jobject obj, jlong id)
  743. {
  744. uint64_t nodeId = (uint64_t) id;
  745. ZT1_Node *node = findNode(nodeId);
  746. if(node == NULL)
  747. {
  748. // cannot find valid node. We should never get here.
  749. return 0;
  750. }
  751. ZT1_VirtualNetworkList *networkList = ZT1_Node_networks(node);
  752. if(networkList == NULL)
  753. {
  754. return NULL;
  755. }
  756. jobject networkListObject = newArrayList(env);
  757. if(networkListObject == NULL)
  758. {
  759. ZT1_Node_freeQueryResult(node, networkList);
  760. return NULL;
  761. }
  762. for(unsigned int i = 0; i < networkList->networkCount; ++i)
  763. {
  764. jobject networkObject = newNetworkConfig(env, networkList->networks[i]);
  765. appendItemToArrayList(env, networkListObject, networkObject);
  766. }
  767. ZT1_Node_freeQueryResult(node, networkList);
  768. return networkListObject;
  769. }
  770. #ifdef __cplusplus
  771. } // extern "C"
  772. #endif