Added listFailedPushesAsString (#149)

* Added listFailedPushesAsString

* added a cehck to make sure i.links is not nil

mobile/client.go

@@ -194,6 +194,14 @@ func (c *Client) ListFailedPushes() (*LinkIterator, error) {
 	return &LinkIterator{links: links}, nil
 }
 
+func (c *Client) ListFailedPushesAsString() (*StringIterator, error) {
+	links, err := c.listFailedPushesAsString(context.TODO())
+	if err != nil {
+		return nil, err
+	}
+	return &StringIterator{links: links}, nil
+}
+
 // RetryFailedPushes retries pushing all links that failed to push.
 // The retry is disrupted as soon as a failure occurs.
 // See ListFailedPushes.

mobile/link_iter.go

@@ -27,3 +27,27 @@ func (i *LinkIterator) Next() ([]byte, error) {
 	}
 	return next.(cidlink.Link).Bytes(), nil
 }
+
+type StringIterator struct {
+	links  []string
+	offset int
+}
+
+func (i *StringIterator) HasNext() bool {
+	if i.links == nil {
+		return false
+	}
+	return i.offset < len(i.links)
+}
+
+func (i *StringIterator) Next() (string, error) {
+	if i.links == nil || !i.HasNext() {
+		return "", errors.New("no more items")
+	}
+	next := i.links[i.offset]
+	if next == "" {
+		return "", errors.New("no more items")
+	}
+	i.offset++
+	return next, nil
+}

mobile/store.go

@@ -49,3 +49,31 @@ func (c *Client) listFailedPushes(ctx context.Context) ([]ipld.Link, error) {
 	}
 	return links, nil
 }
+
+func (c *Client) listFailedPushesAsString(ctx context.Context) ([]string, error) {
+	q := query.Query{
+		KeysOnly: true,
+		Prefix:   failedPushKeyPrefix.String(),
+	}
+	results, err := c.ds.Query(ctx, q)
+	if err != nil {
+		return nil, err
+	}
+	defer results.Close()
+	var links []string
+	for r := range results.Next() {
+		if ctx.Err() != nil {
+			return nil, ctx.Err()
+		}
+		if r.Error != nil {
+			return nil, r.Error
+		}
+		key := datastore.RawKey(r.Key)
+		c, err := cid.Decode(key.BaseNamespace())
+		if err != nil {
+			return nil, err
+		}
+		links = append(links, c.String())
+	}
+	return links, nil
+}