Method RunCommand

cmd/pk/searchnames.go:74–115

(args []string)

}

func (c *searchNamesSetCmd) RunCommand(args []string) error {
	if len(args) != 2 {
		return cmdmain.UsageError("expected 2 arguments")
	}
	named, substitute := args[0], args[1]

	cc := newClient("")
	uh := client.NewUploadHandleFromString(substitute)
	substpr, err := cc.Upload(ctxbg, uh)
	if err != nil {
		return err
	}
	var pn blob.Ref
	claims := []*schema.Builder{}
	gr, err := getNamedSearch(named)
	if err == nil {
		pn = gr.PermaRef
	} else {
		pnpr, err := cc.UploadAndSignBlob(ctxbg, schema.NewUnsignedPermanode())
		if err != nil {
			return err
		}
		pn = pnpr.BlobRef

		claims = append(claims, schema.NewSetAttributeClaim(pn, "camliNamedSearch", named))
		claims = append(claims, schema.NewSetAttributeClaim(pn, "title", fmt.Sprintf("named:%s", named)))
	}
	claims = append(claims, schema.NewSetAttributeClaim(pn, "camliContent", substpr.BlobRef.String()))
	for _, claimBuilder := range claims {
		_, err := cc.UploadAndSignBlob(ctxbg, claimBuilder)
		if err != nil {
			return err
		}
	}
	snr := setNamedResponse{PermaRef: pn, SubstRef: substpr.BlobRef}
	out, err := json.MarshalIndent(snr, "  ", "")
	if err != nil {
		return err
	}
	fmt.Fprintln(cmdmain.Stdout, string(out))
	return nil
}

type getNamedResponse struct {
	Named      string   `json:"named"`