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

Remove all the pin support for now.

Browse Source
This commit is contained in:
Ian Gulliver
2015-06-07 14:45:21 -07:00
parent 3995a4d0d9
commit e24794b229
1 changed files with 1 additions and 86 deletions
Download Patch File Download Diff File Expand all files Collapse all files

87
clients/c/cosmopolite.c
View File

@@ -166,81 +166,10 @@ 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);
} else if (strcmp(event_type, "pin") == 0) {
cosmo_handle_pin(instance, event);
} 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);
} }
@@ -424,7 +353,7 @@ void cosmo_subscribe(cosmo *instance, json_t *subject, const json_int_t messages
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) {
json_array_append_new(instance->subscriptions, json_pack("{sOs[]s[]}", "subject", subject, "messages", "pins")); json_array_append_new(instance->subscriptions, json_pack("{sOs[]}", "subject", subject, "messages"));
} }
assert(!pthread_mutex_unlock(&instance->lock)); assert(!pthread_mutex_unlock(&instance->lock));
@@ -488,20 +417,6 @@ json_t *cosmo_get_last_message(cosmo *instance, json_t *subject) {
return ret; return ret;
} }
json_t *cosmo_get_pins(cosmo *instance, json_t *subject) {
assert(!pthread_mutex_lock(&instance->lock));
json_t *subscription = cosmo_find_subscription(instance, subject);
if (!subscription) {
assert(!pthread_mutex_unlock(&instance->lock));
return NULL;
}
json_t *pins = json_object_get(subscription, "pins");
json_t *ret = json_deep_copy(pins);
assert(!pthread_mutex_unlock(&instance->lock));
return ret;
}
cosmo *cosmo_create(const char *base_url, const char *client_id) { cosmo *cosmo_create(const char *base_url, const char *client_id) {
curl_global_init(CURL_GLOBAL_DEFAULT); curl_global_init(CURL_GLOBAL_DEFAULT);
srandomdev(); srandomdev();