status-im/go-waku
2
0
Fork 0
mirror of https://github.com/status-im/go-waku.git synced 2025-01-12 23:04:45 +00:00
Code Issues Projects Releases Wiki Activity

fix: use nanoseconds in c-bindings example

Browse Source
This commit is contained in:
Richard Ramos 2023-05-18 09:55:29 -04:00 committed by RichΛrd
parent 0c3803b5d8
commit 96c8980828
2 changed files with 39 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
examples/c-bindings/main.c
View File

@ -2,6 +2,8 @@
#include <stdio.h> #include <stdio.h>
#include <string.h> #include <string.h>
#include <unistd.h> #include <unistd.h>
#include <time.h>
#include <stdint.h>
#include "libgowaku.h" #include "libgowaku.h"
#include "nxjson.c" #include "nxjson.c"
@ -66,7 +68,7 @@ int main(int argc, char *argv[])
char *response; char *response;
waku_set_event_callback(callBack); waku_set_event_callback(callBack);
char *configJSON = "{\"host\": \"0.0.0.0\", \"port\": 60000, \"logLevel\":\"error\"}"; char *configJSON = "{\"host\": \"0.0.0.0\", \"port\": 60000, \"logLevel\":\"error\", \"store\":true}";
response = waku_new(configJSON); // configJSON can be NULL too to use defaults response = waku_new(configJSON); // configJSON can be NULL too to use defaults
if (isError(response)) if (isError(response))
return 1; return 1;
@ -84,7 +86,7 @@ int main(int argc, char *argv[])
response = waku_connect("/dns4/node-01.gc-us-central1-a.wakuv2.test.statusim.net/tcp/30303/p2p/16Uiu2HAmJb2e28qLXxT5kZxVUUoJt72EMzNGXB47Rxx5hw3q4YjS", 0); // Connect to a node response = waku_connect("/dns4/node-01.gc-us-central1-a.wakuv2.test.statusim.net/tcp/30303/p2p/16Uiu2HAmJb2e28qLXxT5kZxVUUoJt72EMzNGXB47Rxx5hw3q4YjS", 0); // Connect to a node
if (isError(response)) if (isError(response))
return 1; printf("Could not connect to node: %s\n", response);
/* /*
@ -118,7 +120,7 @@ int main(int argc, char *argv[])
char wakuMsg[1000]; char wakuMsg[1000];
char *msgPayload = waku_utils_base64_encode("Hello World!"); char *msgPayload = waku_utils_base64_encode("Hello World!");
char *contentTopic = waku_content_topic("example", 1, "default", "rfc26"); char *contentTopic = waku_content_topic("example", 1, "default", "rfc26");
sprintf(wakuMsg, "{\"payload\":\"%s\",\"contentTopic\":\"%s\",\"timestamp\":%d}", msgPayload, contentTopic, i); sprintf(wakuMsg, "{\"payload\":\"%s\",\"contentTopic\":\"%s\",\"timestamp\":%lu}", msgPayload, contentTopic, nowInNanosecs());
free(msgPayload); free(msgPayload);
free(contentTopic); free(contentTopic);
@ -134,6 +136,17 @@ int main(int argc, char *argv[])
sleep(1); sleep(1);
} }
// To retrieve messages from local store, set store:true in the node config, and use waku_store_local_query
/*
char query[1000];
sprintf(query, "{\"pubsubTopic\":\"%s\", \"pagingOptions\":{\"pageSize\": 40, \"forward\":false}}", waku_default_pubsub_topic());
response = waku_store_local_query(query);
if (isError(response))
return 1;
printf("%s\n",response);
*/
response = waku_stop(); response = waku_stop();
if (isError(response)) if (isError(response))
return 1; return 1;

23
examples/c-bindings/main.h
View File

@ -4,6 +4,29 @@
#include <stdbool.h> #include <stdbool.h>
#include "nxjson.c" #include "nxjson.c"
/// Convert seconds to nanoseconds
#define SEC_TO_NS(sec) ((sec)*1000000000)
uint64_t nowInNanosecs(){
uint64_t nanoseconds;
struct timespec ts;
int return_code = timespec_get(&ts, TIME_UTC);
if (return_code == 0)
{
printf("Failed to obtain timestamp.\n");
nanoseconds = UINT64_MAX; // use this to indicate error
}
else
{
// `ts` now contains your timestamp in seconds and nanoseconds! To
// convert the whole struct to nanoseconds, do this:
nanoseconds = SEC_TO_NS((uint64_t)ts.tv_sec) + (uint64_t)ts.tv_nsec;
}
return nanoseconds;
}
bool isError(char *input) bool isError(char *input)
{ {
char *jsonStr = malloc(strlen(input) + 1); char *jsonStr = malloc(strlen(input) + 1);