C# Requires Chilkat v11.5.0+

Box: Poll User Events and Save a Checkpoint

See more Box Examples

Poll the authenticated user event stream in bounded batches. The local JSON checkpoint keeps processed event IDs and the next stream position. This single-process demonstration logs events; a production worker should commit its business action, deduplication record, and cursor transactionally and prune old IDs.

See the Box API guide for setup and the complete workflow.

C#

bool success = false;

//  Requires Chilkat 11.5.0 or later and a previously unlocked Chilkat bundle.
//  See Global Unlock Sample.
//  Guide: Box API Guide.

success = false;

//  Supply an unexpired token obtained with one of the Box authentication examples.
//  A token represents a particular user or service account. IDs must be accessible to it.
Chilkat.HttpCurl curl = new Chilkat.HttpCurl();
curl.SetVar("access_token","BOX_ACCESS_TOKEN");

Chilkat.JsonObject state = new Chilkat.JsonObject();
Chilkat.FileAccess files = new Chilkat.FileAccess();
string statePath = "qa_data/box_events_state.json";
if (files.FileExists(statePath) == true) {
    success = state.LoadFile(statePath);
    if (success != true) {
        Debug.WriteLine(state.LastErrorText);
        return;
    }

    if (state.HasMember("position") != true) {
        Debug.WriteLine("Invalid checkpoint: position missing.");
        return;
    }

}
else {
    //  "now" starts a new subscription. It deliberately skips historical events.
    state.UpdateString("position","now");
}

curl.SetVar("position",state.StringOf("position"));
Chilkat.JsonObject page = new Chilkat.JsonObject();
Chilkat.StringBuilder seenPath = new Chilkat.StringBuilder();
string eventId;
string nextPosition;
int batch = 0;
int i;
int count;
bool more = true;
while ((more == true) && (batch < 20)) {
    curl.ClearTargetOutput("*");
    Chilkat.StringBuilder authorizedCommand1 = new Chilkat.StringBuilder();
    authorizedCommand1.SetString("curl -X GET \"https://api.box.com/2.0/events?stream_type=all&stream_position={{position}}&limit=100\" -H \"Authorization: Bearer {{access_token}}\"");
    int headerReplacement1 = authorizedCommand1.Replace("{{access_token}}",curl.GetVar("access_token"));
    success = curl.DoYourThing(authorizedCommand1.GetAsString());
    if ((success != true) || (curl.StatusCode != 200)) {
        Debug.WriteLine("Box request failed. HTTP status: " + Convert.ToString(curl.StatusCode));
        Debug.WriteLine("Failure reason: " + Convert.ToString(curl.FailReason));
        Debug.WriteLine(curl.ResponseBodyStr);
        return;
    }

    success = curl.GetResponseJson(page);
    if (success != true) {
        Debug.WriteLine(curl.LastErrorText);
        return;
    }

    count = page.SizeOfArray("entries");
    i = 0;
    while (i < count) {
        page.I = i;
        eventId = page.StringOf("entries[i].event_id");
        if (eventId == "") {
            Debug.WriteLine("Event without an event_id; checkpoint not advanced.");
            return;
        }

        seenPath.Clear();
        seenPath.Append("seen.");
        seenPath.Append(eventId);
        if (state.HasMember(seenPath.GetAsString()) == false) {
            //  Replace this logging with your idempotent business operation.
            //  Record success only after that operation succeeds.
            Debug.WriteLine(eventId + " " + page.StringOf("entries[i].event_type") + " " + page.StringOf("entries[i].source.id"));
            state.UpdateBool(seenPath.GetAsString(),true);
        }

        i = i + 1;
    }

    nextPosition = page.StringOf("next_stream_position");
    if (nextPosition == "") {
        Debug.WriteLine("Missing next_stream_position; checkpoint not advanced.");
        return;
    }

    more = (count > 0) && (nextPosition != curl.GetVar("position"));
    state.UpdateString("position",nextPosition);
    success = state.WriteFile(statePath);
    if (success != true) {
        Debug.WriteLine(state.LastErrorText);
        return;
    }

    curl.SetVar("position",nextPosition);
    batch = batch + 1;
}

Debug.WriteLine("Checkpoint saved. Run again later to continue polling.");