restful_client.c 1.46 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18
/*
 * Copyright (c) 2014 Cesanta Software Limited
 * All rights reserved
 */

#include "mongoose.h"

/* RESTful server host and request URI */
static const char *s_target_address = "ajax.googleapis.com:80";
static const char *s_request = "/ajax/services/search/web?v=1.0&q=cesanta";

static int s_exit_flag = 0;

static void ev_handler(struct mg_connection *nc, int ev, void *ev_data) {
  struct http_message *hm = (struct http_message *) ev_data;
  int connect_status;

  switch (ev) {
19
    case MG_EV_CONNECT:
20 21 22 23 24 25 26 27 28 29 30
      connect_status = * (int *) ev_data;
      if (connect_status == 0) {
        printf("Connected to %s, sending request...\n", s_target_address);
        mg_printf(nc, "GET %s HTTP/1.0\r\nHost: %s\r\n\r\n",
                  s_request, s_target_address);
      } else {
        printf("Error connecting to %s: %s\n",
               s_target_address, strerror(connect_status));
        s_exit_flag = 1;
      }
      break;
31
    case MG_EV_HTTP_REPLY:
32
      printf("Got reply:\n%.*s\n", (int) hm->body.len, hm->body.p);
33
      nc->flags |= MG_F_SEND_AND_CLOSE;
34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56
      s_exit_flag = 1;
      break;
    default:
      break;
  }
}

int main(void) {
  struct mg_mgr mgr;
  struct mg_connection *nc;

  mg_mgr_init(&mgr, NULL);
  nc = mg_connect(&mgr, s_target_address, ev_handler);
  mg_set_protocol_http_websocket(nc);

  printf("Starting RESTful client against %s\n", s_target_address);
  while (s_exit_flag == 0) {
    mg_mgr_poll(&mgr, 1000);
  }
  mg_mgr_free(&mgr);

  return 0;
}