1

#include "irc_chan.h"

     3

#include "log.h"

     4

     5

#include <stdlib.h>

     6

#include <assert.h>

     7

     8

const char* irc_chan_name (struct irc_chan *chan)

     9

{

    10

    return chan->info.channel;

    11

}

    12

    13

/**

    14

 * :nm JOIN <channel>

    15

 */ 

    16

static void irc_chan_on_JOIN (const struct irc_line *line, void *arg)

    17

{

    18

    struct irc_chan *chan = arg;

    19

    20

    // us?

    21

    if (irc_prefix_cmp_nick(line->prefix, chan->net->conn->nickname) == 0) {

    22

        // twiddle state

    23

        chan->state.joining = false;

    24

        chan->state.joined = true;

    25

    26

        log_info("joined channel: %s", chan->info.channel);

    27

    28

        // invoke callback

    29

        IRC_CHAN_INVOKE_CALLBACK(chan, on_self_join);

    30

    }

    31

}

    32

    33

/**

    34

 * :nm PRIVMSG <channel> <message>

    35

 */

    36

static void irc_chan_on_PRIVMSG (const struct irc_line *line, void *arg)

    37

{

    38

    struct irc_chan *chan = arg;

    39

    40

    // invoke callback (prefix, message)

    41

    IRC_CHAN_INVOKE_CALLBACK(chan, on_msg, line->prefix, line->args[1]);

    42

}

    43

    44

/**

    45

 * Core command handlers

    46

 */

    47

struct irc_cmd_handler _cmd_handlers[] = {

    48

    {   "JOIN",     &irc_chan_on_JOIN       },

    49

    {   "PRIVMSG",  &irc_chan_on_PRIVMSG    },

    50

    {   NULL,       NULL                    }

    51

};

    52

    53

err_t irc_chan_create (struct irc_chan **chan_ptr, struct irc_net *net, const struct irc_chan_info *info, struct error_info *err)

    54

{

    55

    struct irc_chan *chan;

    56

    57

    // allocate

    58

    if ((chan = calloc(1, sizeof(*chan))) == NULL)

    59

        return SET_ERROR(err, ERR_CALLOC);

    60

    61

    // store

    62

    chan->net = net;

    63

    chan->info = *info;

    64

    65

    // init

    66

    irc_cmd_init(&chan->handlers);

    67

    CHAIN_INIT(&chan->callbacks);

    68

    69

    // add handlers

    70

    if ((ERROR_CODE(err) = irc_cmd_add(&chan->handlers, _cmd_handlers, chan)))

    71

        goto error;

    72

    73

    // ok

    74

    *chan_ptr = chan;

    75

    76

    return SUCCESS;

    77

    78

error:

    79

    // cleanup

    80

    irc_chan_destroy(chan);

    81

    82

    return ERROR_CODE(err);

    83

}

    84

    85

void irc_chan_destroy (struct irc_chan *chan)

    86

{

    87

    // free command handlers

    88

    irc_cmd_free(&chan->handlers);

    89

    90

    // free callbacks

    91

    chain_free(&chan->callbacks);

    92

    93

    // free chan itself

    94

    free(chan);

    95

}

    96

    97

err_t irc_chan_add_callbacks (struct irc_chan *chan, const struct irc_chan_callbacks *callbacks, void *arg)

    98

{

    99

    return chain_add(&chan->callbacks, callbacks, arg);

   100

}

   101

   102

err_t irc_chan_join (struct irc_chan *chan)

   103

{

   104

    err_t err;

   105

   106

    // XXX: error instead?

   107

    assert(!chan->state.joining && !chan->state.joined);

   108

   109

    // send JOIN message on the appropriate connection

   110

    if ((err = irc_conn_JOIN(chan->net->conn, chan->info.channel)))

   111

        // XXX: error state?

   112

        return err;

   113

   114

    // ok

   115

    chan->state.joining = true;

   116

   117

    return SUCCESS;

   118

}

   119