Add additional publish function for more fine grained control of IPNS record publishing

ipns.go

@@ -1,10 +1,18 @@
 package shell
 
 import (
+	"bytes"
 	"context"
 	"encoding/json"
+	"strconv"
+	"time"
 )
 
+type PublishResponse struct {
+	Name  string `json:"name"`
+	Value string `json:"value"`
+}
+
 // Publish updates a mutable name to point to a given value
 func (s *Shell) Publish(node string, value string) error {
 	args := []string{value}
@@ -25,6 +33,32 @@ func (s *Shell) Publish(node string, value string) error {
 	return nil
 }
 
+// PublishWithDetails is used for fine grained control over record publishing
+func (s *Shell) PublishWithDetails(contentHash, key string, lifetime, ttl time.Duration, resolve bool) (*PublishResponse, error) {
+	var pubResp PublishResponse
+	args := []string{contentHash}
+	req := s.newRequest(context.Background(), "name/publish", args...)
+	if key == "" {
+		key = "self"
+	}
+	req.Opts["key"] = key
+	req.Opts["lifetime"] = lifetime.String()
+	req.Opts["ttl"] = ttl.String()
+	req.Opts["resolve"] = strconv.FormatBool(resolve)
+	resp, err := req.Send(s.httpcli)
+	if err != nil {
+		return nil, err
+	}
+	defer resp.Close()
+	if resp.Error != nil {
+		return nil, resp.Error
+	}
+	buf := new(bytes.Buffer)
+	buf.ReadFrom(resp.Output)
+	json.Unmarshal(buf.Bytes(), &pubResp)
+	return &pubResp, nil
+}
+
 // Resolve gets resolves the string provided to an /ipfs/[hash]. If asked to
 // resolve an empty string, resolve instead resolves the node's own /ipns value.
 func (s *Shell) Resolve(id string) (string, error) {

ipns_test.go

@@ -0,0 +1,37 @@
+package shell_test
+
+import (
+	"fmt"
+	"testing"
+	"time"
+
+	ipfsapi "github.com/RTradeLtd/go-ipfs-api"
+)
+
+var examplesHash = "/ipfs/Qmbu7x6gJbsKDcseQv66pSbUcAA3Au6f7MfTYVXwvBxN2K"
+
+func TestPublishDetailsWithKey(t *testing.T) {
+	shell := ipfsapi.NewShell("localhost:5001")
+
+	resp, err := shell.PublishWithDetails(examplesHash, "key1", time.Hour, time.Hour, false)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	if resp.Value != examplesHash {
+		t.Fatalf(fmt.Sprintf("Expected to receive %s but got %s", examplesHash, resp.Value))
+	}
+}
+
+func TestPublishDetailsWithoutKey(t *testing.T) {
+	shell := ipfsapi.NewShell("localhost:5001")
+
+	resp, err := shell.PublishWithDetails(examplesHash, "", time.Hour, time.Hour, false)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	if resp.Value != examplesHash {
+		t.Fatalf(fmt.Sprintf("Expected to receive %s but got %s", examplesHash, resp.Value))
+	}
+}

request.go

@@ -74,7 +74,6 @@ func (e *Error) Error() string {
 
 func (r *Request) Send(c *http.Client) (*Response, error) {
 	url := r.getURL()
-
 	req, err := http.NewRequest("POST", url, r.Body)
 	if err != nil {
 		return nil, err