newRssSourcesMsg Rss订阅源列表
(ctx *zero.Ctx, view []*domain.RssClientView)
| 56 | |
| 57 | // newRssSourcesMsg Rss订阅源列表 |
| 58 | func newRssSourcesMsg(ctx *zero.Ctx, view []*domain.RssClientView) (message.Message, error) { |
| 59 | var msgSlice []message.Message |
| 60 | // 生成消息 |
| 61 | for _, v := range view { |
| 62 | if v == nil { |
| 63 | continue |
| 64 | } |
| 65 | item, err := formatRssViewToMessagesSlice(v) |
| 66 | if err != nil { |
| 67 | return nil, err |
| 68 | } |
| 69 | msgSlice = append(msgSlice, item...) |
| 70 | } |
| 71 | // 伪造一个发送者为RssHub订阅姬的消息节点 |
| 72 | msg := make(message.Message, len(msgSlice)) |
| 73 | for i, item := range msgSlice { |
| 74 | msg[i] = fakeSenderForwardNode(ctx.Event.SelfID, item...) |
| 75 | } |
| 76 | return msg, nil |
| 77 | } |
| 78 | |
| 79 | // newRssDetailsMsg Rss订阅源详情(包含文章信息列表) |
| 80 | func newRssDetailsMsg(ctx *zero.Ctx, view *domain.RssClientView) (message.Message, error) { |
no test coverage detected