diff --git a/client/httpapi/api.go b/client/httpapi/api.go
index 3df45f38c..c2ec1ad67 100644
--- a/client/httpapi/api.go
+++ b/client/httpapi/api.go
@@ -138,7 +138,7 @@ func (api *HttpApi) Block() iface.BlockAPI {
 }
 
 func (api *HttpApi) Dag() iface.DagAPI {
-	return nil
+	return (*DagAPI)(api)
 }
 
 func (api *HttpApi) Name() iface.NameAPI {
diff --git a/client/httpapi/dag.go b/client/httpapi/dag.go
new file mode 100644
index 000000000..c3b29e7ee
--- /dev/null
+++ b/client/httpapi/dag.go
@@ -0,0 +1,69 @@
+package httpapi
+
+import (
+	"context"
+	"fmt"
+	"github.com/ipfs/go-cid"
+	"io"
+
+	"github.com/ipfs/go-ipfs/core/coreapi/interface"
+	"github.com/ipfs/go-ipfs/core/coreapi/interface/options"
+
+	caopts "github.com/ipfs/go-ipfs/core/coreapi/interface/options"
+	"github.com/ipfs/go-ipld-format"
+	mh "github.com/multiformats/go-multihash"
+)
+
+type DagAPI HttpApi
+
+func (api *DagAPI) Put(ctx context.Context, src io.Reader, opts ...options.DagPutOption) (iface.ResolvedPath, error) {
+	options, err := caopts.DagPutOptions(opts...)
+	if err != nil {
+		return nil, err
+	}
+
+	mht, ok := mh.Codes[options.MhType]
+	if !ok {
+		return nil, fmt.Errorf("unknowm mhType %d", options.MhType)
+	}
+
+	codec, ok := cid.CodecToStr[options.Codec]
+	if !ok {
+		return nil, fmt.Errorf("unknowm codec %d", options.MhType)
+	}
+
+	if options.MhLength != -1 {
+		return nil, fmt.Errorf("setting hash len is not supported yet")
+	}
+
+	var out struct{
+		Cid cid.Cid
+	}
+	err = api.core().request("dht/put").
+		Option("hash", mht).
+		Option("format", codec).
+		Option("input-enc", options.InputEnc).
+		FileBody(src).
+		Exec(ctx, &out)
+	if err != nil {
+		return nil, err
+	}
+
+	return iface.IpldPath(out.Cid), nil
+}
+
+func (api *DagAPI) Get(ctx context.Context, path iface.Path) (format.Node, error) {
+	panic("implement me")
+}
+
+func (api *DagAPI) Tree(ctx context.Context, path iface.Path, opts ...options.DagTreeOption) ([]iface.Path, error) {
+	panic("implement me")
+}
+
+func (api *DagAPI) Batch(ctx context.Context) iface.DagBatch {
+	panic("implement me")
+}
+
+func (api *DagAPI) core() *HttpApi {
+	return (*HttpApi)(api)
+}