Какой тип канала ставить?

Question

[Muxauko]

Стоит задача сделать пост запрос на сервер, декодировать ответ и отправить в канал. С другой стороны горутина вытаскивает из канала и обрабатывает.
Вообщем тип канала поставил, но мне надо не полностью events передавать, элемент списка из него. Проблема в том, что не знаю как это делать. Ругается и все, если передаю events.Events[0] что не того типа, который нужен каналу.
Вот код https://play.golang.org/p/SPp8wP1ZkEL

вот скрин того, что сервер может прислать несколько обновлений, поэтому надо вытаскивать из списка


требуется отправить в канал не events а events.Events[0]

а вот скрин одного из элемента того списка...вот в таком мне и надо передавать в канал, а не полность,как выше...

Answer 1

[Евгений Мамонов]

Должно быть немного иначе, первое что нужно изменить - это объявление самой структуры, оно должно быть таким

type Event struct {
        EventID int    `json:"eventId"`
        Type    string `json:"type"`
        ....
}

Судя по комментарию "//Делаем longpoll запрос на обновления" - логика должна быть немного иной, вы должны сделать один запрос и потом постоянно декодировать (по одному) пришедшие порции данных.
Если я понял верно - тогда делать нужно вот так

// канал создаёте вот так, т.к. вы хотите по одному событию передавать данные, а не целыми слайсами сразу
EventsCh = make(chan Event, 100)
go mailing(EventsCh)

// делаете HTTP запрос
response, responseErr := http.PostForm(...)

// создаёте decoder
decoder := json.NewDecoder(response.Body)

for {
    event := Event{}
    decoderErr := decoder.Decode(&event) // если данных нет - тут выполнение программы блокируется
    if decodeErr != nil { // тут может быть ошибка io.EOF (просто данные закончились, сервер корректно закрыл соединение)
       break
    }
    EventsCh <- event  // отправляете данные в канал, из которого их читает горутина
}

Функция mailing должна быть такой

func mailing(eventsCh chan Event){									//Получает события из канала
    for{
        event, ok := <- eventsChan
        if !ok {
            // канал закрыт
            break
        }
        log.Print("Получено ", event)
    }
}

Comments

[Muxauko]

Структуру не получится. Это и есть та структура, в которой приходит json ответ от сервера.
Решение проблемы будет если в канал я буду отправлять не весь events, а именно ту часть что мне и нужна, а именно events.Events[0] но не знаю как правильно под это канал настроить.

[Muxauko]

{
  "events": [
    {
      "eventId": 1,
      "type": "newMessage",
      "payload": {
        "msgId": "57883346846815032",
        "chat": {
          "chatId": "[e-mail]",
          "type": "channel",
          "title": "The best channel"
        },
        "from": {
          "userId": "1234567890",
          "firstName": "Name",
          "lastName": "SurName"
        },
        "timestamp": 1546290000,
        "text": "Hello!",
        "parts": [
          null
        ]
      }
    }
  ]
}

вот структура ответа, поэтому изменить events не выйдет...наверное

[Евгений Мамонов]

такая стркутура приходит каждый раз при новом ответе longpoll?
или таки нужно в цикле постоянно делать запросы и декодить ответы?

[Евгений Мамонов]

В любом случае структуру нужно делать по другому, точнее вам нужно чтобы у вас был тип Event, иначе вы не прокините его через канал, а тип канала должен быть Event (как эта структура)

type Event struct {
        EventID int    `json:"eventId"`
        Type    string `json:"type"`
        Payload struct {
            MsgID string `json:"msgId"`
            Chat  struct {
                ChatID string `json:"chatId"`
                Type   string `json:"type"`
                Title  string `json:"title"`
            } `json:"chat"`
            From struct {
                UserID    string `json:"userId"`
                FirstName string `json:"firstName"`
                LastName  string `json:"lastName"`
            } `json:"from"`
            Timestamp int           `json:"timestamp"`
            Text      string        `json:"text"`
            Parts     []interface{} `json:"parts"`
        } `json:"payload"`
}

type EventsList struct {
     Events []Event `json:"events"`
}

И тогда декодите уже EventsList, канал у вас будет с типом Event, а данные в канал вы можете записывать тогда уже вот так
EventsCh <- eventsList.Events[0] или в цикле писать в канал

[Евгений Мамонов]

Получилось?

[Muxauko]

А вот это уже подходит. Спасибо за отзывчивость.)

[Евгений Мамонов]

Рад помочь :)