misc/cosmopolite
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

onpin support, but onunpin never fires, so mostly useless right now.

Browse Source
This commit is contained in:
Ian Gulliver
2015-06-07 10:14:15 -07:00
parent 3f40ddb037
commit 190e1eb182
2 changed files with 78 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

77
clients/c/cosmopolite.c
View File

@@ -144,7 +144,7 @@ static void cosmo_handle_message(cosmo *instance, json_t *event) {
assert(!pthread_mutex_lock(&instance->lock)); assert(!pthread_mutex_lock(&instance->lock));
json_t *subscription = cosmo_find_subscription(instance, subject); json_t *subscription = cosmo_find_subscription(instance, subject);
if (!subscription) { if (!subscription) {
// Normal to sometimes get events after unsubscribe. fprintf(stderr, "message from unknown subject\n");
assert(!pthread_mutex_unlock(&instance->lock)); assert(!pthread_mutex_unlock(&instance->lock));
return; return;
} }
@@ -166,10 +166,85 @@ static void cosmo_handle_message(cosmo *instance, json_t *event) {
assert(!pthread_mutex_unlock(&instance->lock)); assert(!pthread_mutex_unlock(&instance->lock));
} }
static void cosmo_handle_pin(cosmo *instance, json_t *event) {
json_t *subject = json_object_get(event, "subject");
if (!subject) {
fprintf(stderr, "pin event without subject\n");
return;
}
json_t *id = json_object_get(event, "id");
if (!id) {
fprintf(stderr, "pin event without id\n");
return;
}
assert(!pthread_mutex_lock(&instance->lock));
json_t *subscription = cosmo_find_subscription(instance, subject);
if (!subscription) {
fprintf(stderr, "pin from unknown subject\n");
assert(!pthread_mutex_unlock(&instance->lock));
return;
}
json_t *pins = json_object_get(subscription, "pins");
size_t index;
json_t *pin;
json_array_foreach(pins, index, pin) {
if (json_equal(id, json_object_get(pin, "id"))) {
assert(!pthread_mutex_unlock(&instance->lock));
return;
}
}
printf("new pin: %s\n", json_string_value(id));
json_array_append(pins, event);
assert(!pthread_mutex_unlock(&instance->lock));
}
static void cosmo_handle_unpin(cosmo *instance, json_t *event) {
fprintf(stderr, "unpin event\n");
json_t *subject = json_object_get(event, "subject");
if (!subject) {
fprintf(stderr, "unpin event without subject\n");
return;
}
json_t *id = json_object_get(event, "id");
if (!id) {
fprintf(stderr, "unpin event without id\n");
return;
}
assert(!pthread_mutex_lock(&instance->lock));
json_t *subscription = cosmo_find_subscription(instance, subject);
if (!subscription) {
fprintf(stderr, "unpin from unknown subject\n");
assert(!pthread_mutex_unlock(&instance->lock));
return;
}
json_t *pins = json_object_get(subscription, "pins");
size_t index;
json_t *pin;
json_array_foreach(pins, index, pin) {
if (json_equal(id, json_object_get(pin, "id"))) {
printf("deleted pin: %s\n", json_string_value(id));
json_array_remove(pins, index);
break;
}
}
assert(!pthread_mutex_unlock(&instance->lock));
}
static void cosmo_handle_event(cosmo *instance, json_t *event) { static void cosmo_handle_event(cosmo *instance, json_t *event) {
const char *event_type = json_string_value(json_object_get(event, "event_type")); const char *event_type = json_string_value(json_object_get(event, "event_type"));
if (strcmp(event_type, "message") == 0) { if (strcmp(event_type, "message") == 0) {
cosmo_handle_message(instance, event); cosmo_handle_message(instance, event);
/*
// This can all come back once we have channel support.
} else if (strcmp(event_type, "pin") == 0) {
cosmo_handle_pin(instance, event);
// unpin never fires when we're just polling
} else if (strcmp(event_type, "unpin") == 0) {
cosmo_handle_unpin(instance, event);
*/
} else { } else {
fprintf(stderr, "unknown event type: %s\n", event_type); fprintf(stderr, "unknown event type: %s\n", event_type);
} }

4
clients/c/cosmopolite.h
View File

@@ -38,9 +38,9 @@ void cosmo_send_message(cosmo *instance, json_t *subject, json_t *message);
json_t *cosmo_get_messages(cosmo *instance, json_t *subject); json_t *cosmo_get_messages(cosmo *instance, json_t *subject);
json_t *cosmo_get_last_message(cosmo *instance, json_t *subject); json_t *cosmo_get_last_message(cosmo *instance, json_t *subject);
json_t *cosmo_get_pins(cosmo *instance, json_t *subject);
// Hard TODO // TODO
json_t *cosmo_get_pins(cosmo *instance, json_t *subject);
void cosmo_pin(cosmo *instance, json_t *subject, json_t *message); void cosmo_pin(cosmo *instance, json_t *subject, json_t *message);
void cosmo_unpin(cosmo *instance, json_t *subject, json_t *message); void cosmo_unpin(cosmo *instance, json_t *subject, json_t *message);