vbatts/ntfy
1
0
Fork 0
Code Pull requests Activity

More tests; enough!

Browse source
This commit is contained in:
Philipp Heckel 2022-02-03 22:26:22 -05:00
parent 4972407145
commit 3902599c52
4 changed files with 111 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

14
client/client.go
View file

@ -18,9 +18,10 @@ import (
// Event type constants
const (
MessageEvent = "message"
KeepaliveEvent = "keepalive"
OpenEvent = "open"
MessageEvent = "message"
KeepaliveEvent = "keepalive"
OpenEvent = "open"
PollRequestEvent = "poll_request"
)
const (
@ -251,6 +252,13 @@ func performSubscribeRequest(ctx context.Context, msgChan chan *Message, topicUR
return err
}
defer resp.Body.Close()
if resp.StatusCode != http.StatusOK {
b, err := io.ReadAll(io.LimitReader(resp.Body, maxResponseBytes))
if err != nil {
return err
}
return errors.New(strings.TrimSpace(string(b)))
}
scanner := bufio.NewScanner(resp.Body)
for scanner.Scan() {
m, err := toMessage(scanner.Text(), topicURL, subscriptionID)