-
Notifications
You must be signed in to change notification settings - Fork 57
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
* removed state param from subscribe * state taken if exists from pubnub context * set state with heartbeat implementation * add basic test for set_state_ex * set state with heartbeat examples
- Loading branch information
1 parent
af81bfd
commit 7af9fba
Showing
28 changed files
with
557 additions
and
138 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,125 @@ | ||
| #include "pbcc_set_state.h" | ||
| #include "pubnub_internal.h" | ||
| #include "pubnub_log.h" | ||
| #include <string.h> | ||
| #include <stdlib.h> | ||
|
|
||
| static int json_kvp_builder(char* jsonbuilder, int pos, char* key, char* val) | ||
| { | ||
| int dq_len = strlen("\""); | ||
| int co_len = strlen(":"); | ||
| int key_len = strlen(key); | ||
| int val_len = strlen(val); | ||
|
|
||
| memcpy(jsonbuilder + pos, "\"", dq_len); | ||
| pos += dq_len; | ||
| memcpy(jsonbuilder + pos, key, key_len); | ||
| pos += key_len; | ||
| memcpy(jsonbuilder + pos, "\"", dq_len); | ||
| pos += dq_len; | ||
| memcpy(jsonbuilder + pos, ":", co_len); | ||
| pos += co_len; | ||
| memcpy(jsonbuilder + pos, val, val_len); | ||
| pos += val_len; | ||
| return pos; | ||
| } | ||
|
|
||
|
|
||
| void pbcc_adjust_state(pubnub_t* pb, | ||
| char const* channel, | ||
| char const* channel_group, | ||
| char const* state) | ||
| { | ||
| int ch_cnt = 0, cg_cnt = 0, tot_ch = 0, tot_cg = 0; | ||
| if (channel){ | ||
| tot_ch = 1; | ||
| for (int i=0; i < (int)strlen(channel); i++) { tot_ch = (channel[i] == ',') ? tot_ch + 1 : tot_ch; } | ||
| } | ||
| if (channel_group){ | ||
| tot_cg = 1; | ||
| for (int i=0; i < (int)strlen(channel_group); i++) { tot_cg = (channel_group[i] == ',') ? tot_cg + 1 : tot_cg; } | ||
| } | ||
|
|
||
| int buff_size = ((tot_ch + tot_cg) * strlen(state)) + (channel ? strlen(channel) : 1) + (channel_group ? strlen(channel_group) : 1) + 20; | ||
| char * json_state = (char*)malloc(buff_size); | ||
| if (pb->core.state != NULL && buff_size != sizeof(pb->core.state)){ | ||
| pb->core.state = (char*)realloc((char*)pb->core.state, buff_size); | ||
| } | ||
| else if (pb->core.state == NULL){ | ||
| pb->core.state = (char*)malloc(buff_size); | ||
| } | ||
| int mem_len = 0; | ||
| if (json_state != NULL && pb->core.state != NULL){ | ||
| mem_len = strlen("{"); | ||
| memcpy(json_state, "{", mem_len); | ||
| int cm_len = strlen(","); | ||
| if (channel && strncmp(channel, (char*)",", 1) != 0) { | ||
| char* str_ch = (char*)channel; | ||
| char* ch_temp; | ||
| size_t ch_len; | ||
| bool end = false; | ||
| do{ | ||
| ch_temp = strchr(str_ch,','); | ||
| if (ch_cnt > 0) { | ||
| memcpy(json_state + mem_len, ",", cm_len); | ||
| mem_len += cm_len; | ||
| } | ||
| if (ch_temp == NULL) { end = true; ch_len = strlen(str_ch); } | ||
| else { ch_len = ch_temp - str_ch; } | ||
|
|
||
| if (ch_len == 0) { continue; } | ||
|
|
||
| char* curr_ch = (char*)malloc(ch_len + 1); | ||
| strncpy(curr_ch, str_ch, ch_len); | ||
| curr_ch[ch_len] = '\0'; | ||
|
|
||
| mem_len = json_kvp_builder(json_state, mem_len, curr_ch, (char*)state); | ||
|
|
||
| ch_cnt++; | ||
| str_ch = ch_temp + 1; | ||
| free(curr_ch); | ||
| } while (false == end); | ||
| } | ||
|
|
||
| if (channel_group) { | ||
| char* str_cg = (char*)channel_group; | ||
| char* cg_temp; | ||
| int cg_len; | ||
| bool end = false; | ||
| do{ | ||
| cg_temp = strchr(str_cg,','); | ||
| if (ch_cnt > 0 || cg_cnt > 0) { | ||
| memcpy(json_state + mem_len, ",", cm_len); | ||
| mem_len += cm_len; | ||
| } | ||
| if (cg_temp == NULL) { end = true; cg_len = strlen(str_cg); } | ||
| else { cg_len = cg_temp - str_cg; } | ||
|
|
||
| if (cg_len == 0) { continue; } | ||
|
|
||
| char* curr_cg = (char*)malloc(cg_len + 1); | ||
| strncpy(curr_cg, str_cg, cg_len); | ||
| curr_cg[cg_len] = '\0'; | ||
|
|
||
| mem_len = json_kvp_builder(json_state, mem_len, curr_cg, (char*)state); | ||
|
|
||
| cg_cnt++; | ||
| str_cg = cg_temp + 1; | ||
| free(curr_cg); | ||
| } while (false == end); | ||
| } | ||
|
|
||
| int cb_len = strlen("}"); | ||
| memcpy(json_state + mem_len, "}", cb_len); | ||
| mem_len += cb_len; | ||
| json_state[mem_len] = '\0'; | ||
| PUBNUB_LOG_DEBUG("formatted state is %s\n", json_state); | ||
|
|
||
| strcpy((char*)pb->core.state, (const char*)json_state); | ||
| free(json_state); | ||
| json_state = NULL; | ||
| } | ||
|
|
||
| } | ||
|
|
||
|
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,14 @@ | ||
| /* -*- c-file-style:"stroustrup"; indent-tabs-mode: nil -*- */ | ||
| #if !defined INC_PBCC_SET_STATE | ||
| #define INC_PBCC_SET_STATE | ||
|
|
||
| #include "pubnub_api_types.h" | ||
|
|
||
| /** Adjusting the @pb presence state for pubnub usage | ||
| */ | ||
| void pbcc_adjust_state(pubnub_t* pb, | ||
| char const* channel, | ||
| char const* channel_group, | ||
| char const* state); | ||
|
|
||
| #endif // INC_PBCC_SET_STATE |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.