type rosterClient struct {

	rosterChan <-chan []RosterItem

	rosterUpdate chan<- RosterItem

}

var (

	rosterClients = make(map[string] rosterClient)

)

// that information. This is called once from a fairly deep call stack

// as part of XMPP negotiation.

func fetchRoster(client *Client) os.Error {

	rosterUpdate := rosterClients[client.Uid].rosterUpdate

	iq := &Iq{From: client.Jid.String(), Id: <- Id, Type: "get",

		defer close(ch)

		for _, item := range(rq.Item) {

			rosterUpdate <- item

	client.HandleStanza(iq.Id, f)

	client.Out <- iq

// roster, but it lets the relevant stanzas through. This also starts

// the roster feeder, which is the goroutine that provides data on

// client.Roster.

func startRosterFilter(client *Client) {

	in := client.AddFilter(out)

			maybeUpdateRoster(client, st)

	rosterCh := make(chan []RosterItem)

	rosterUpdate := make(chan RosterItem)

	rosterClients[client.Uid] = rosterClient{rosterChan: rosterCh,

		rosterUpdate: rosterUpdate}

	go feedRoster(rosterCh, rosterUpdate)

func maybeUpdateRoster(client *Client, st Stanza) {

	rosterUpdate := rosterClients[client.Uid].rosterUpdate

		for _, item := range(rq.Item) {

			rosterUpdate <- item

func feedRoster(rosterCh chan<- []RosterItem, rosterUpdate <-chan RosterItem) {

	roster := make(map[string] RosterItem)

	snapshot := []RosterItem{}

	for {

		select {

		case newIt := <-rosterUpdate:

			if newIt.Subscription == "remove" {

				roster[newIt.Jid] = RosterItem{}, false

			} else {

				roster[newIt.Jid] = newIt

			}

		case rosterCh <- snapshot:

		}

		snapshot = make([]RosterItem, 0, len(roster))

		for _, v := range(roster) {

			snapshot = append(snapshot, v)

		}

	}

}

// Retrieve a snapshot of the roster for the given Client.

func Roster(client *Client) []RosterItem {

	rosterChan := rosterClients[client.Uid].rosterChan

	return <- rosterChan

}