ccnet-server/net/common/processors/getpubinfo-proc.c

/* -*- Mode: C; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */

#include "common.h"

#include "peer.h"
#include "getpubinfo-proc.h"

#define DEBUG_FLAG CCNET_DEBUG_CONNECTION
#include "log.h"


/*
 * get peer's public info
 */

static int get_pubinfo_start (CcnetProcessor *processor, 
                                int argc, char **argv);
static void handle_response (CcnetProcessor *processor,
                             char *code, char *code_msg,
                             char *content, int clen);


G_DEFINE_TYPE (CcnetGetpubinfoProc, ccnet_getpubinfo_proc, CCNET_TYPE_PROCESSOR)

static void
ccnet_getpubinfo_proc_class_init (CcnetGetpubinfoProcClass *klass)
{
    CcnetProcessorClass *proc_class = CCNET_PROCESSOR_CLASS (klass);
    /* GObjectClass *gobject_class = G_OBJECT_CLASS (klass); */

    proc_class->name = "getpubinfo-proc";
    proc_class->start = get_pubinfo_start;
    proc_class->handle_response = handle_response;
}

static void
ccnet_getpubinfo_proc_init (CcnetGetpubinfoProc *processor)
{
}


static int get_pubinfo_start (CcnetProcessor *processor, 
                              int argc, char **argv)
{
    ccnet_processor_send_request (processor, "put-pubinfo");

    return 0;
}


static void parse_pubinfo (CcnetProcessor *processor,
                            char *content,
                            int clen)
{
    g_return_if_fail (content[clen-1] == '\0');
    ccnet_peer_update_from_string (processor->peer, content);
}

static void handle_response (CcnetProcessor *processor, 
                             char *code, char *code_msg,
                             char *content, int clen)
{
    if (code[0] != '2') {
        ccnet_warning ("[Getpubinfo] Receive bad response %s: %s\n",
                       code, code_msg);
        ccnet_processor_done (processor, FALSE);
        return;
    }

    parse_pubinfo (processor, content, clen);
    ccnet_processor_done (processor, TRUE);
}