(message string)
| 217 | } |
| 218 | |
| 219 | func parseMessage(message string) (*anaconda.Tweet, error) { |
| 220 | var tweet anaconda.Tweet |
| 221 | if err := json.Unmarshal([]byte(message), &tweet); err != nil { |
| 222 | return nil, err |
| 223 | } |
| 224 | |
| 225 | if tweet.IdStr == "" { |
| 226 | return nil, errNotATweet |
| 227 | } |
| 228 | |
| 229 | return &tweet, nil |
| 230 | } |
| 231 | |
| 232 | func tweetToJSON(writer io.Writer, tweet *anaconda.Tweet) error { |
| 233 | createdAt, err := time.Parse(cTimeFormat, tweet.CreatedAt) |
no test coverage detected