From a63e224e24d345708f8d264b110be67c8e05db6c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=C5=81ukasz=20Magiera?= <magik6k@gmail.com>
Date: Sat, 10 Mar 2018 19:07:50 +0100
Subject: [PATCH] coreapi: dht interface
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

License: MIT
Signed-off-by: Łukasz Magiera <magik6k@gmail.com>
---
 core/coreapi/interface/dht.go         | 28 +++++++++++++++++++++++++
 core/coreapi/interface/options/dht.go | 30 +++++++++++++++++++++++++++
 2 files changed, 58 insertions(+)
 create mode 100644 core/coreapi/interface/dht.go
 create mode 100644 core/coreapi/interface/options/dht.go

diff --git a/core/coreapi/interface/dht.go b/core/coreapi/interface/dht.go
new file mode 100644
index 000000000..1c8e68bd1
--- /dev/null
+++ b/core/coreapi/interface/dht.go
@@ -0,0 +1,28 @@
+package iface
+
+import (
+	"context"
+
+	options "github.com/ipfs/go-ipfs/core/coreapi/interface/options"
+
+	ma "gx/ipfs/QmWWQ2Txc2c6tqjsBpzg5Ar652cHPGNsQQp2SejkNmkUMb/go-multiaddr"
+	peer "gx/ipfs/QmZoWKhxUmZ2seW4BzX6fJkNR8hh9PsGModr7q171yq2SS/go-libp2p-peer"
+)
+
+// DhtAPI specifies the interface to the DHT
+type DhtAPI interface {
+	// FindPeer queries the DHT for all of the multiaddresses associated with a
+	// Peer ID
+	FindPeer(context.Context, peer.ID) (<-chan ma.Multiaddr, error)
+
+	// FindProviders finds peers in the DHT who can provide a specific value
+	// given a key.
+	FindProviders(context.Context, Path) (<-chan peer.ID, error) //TODO: is path the right choice here?
+
+	// Provide announces to the network that you are providing given values
+	Provide(context.Context, Path, ...options.DhtProvideOption) error
+
+	// WithRecursive is an option for Provide which specifies whether to provide
+	// the given path recursively
+	WithRecursive(recursive bool) options.DhtProvideOption
+}
diff --git a/core/coreapi/interface/options/dht.go b/core/coreapi/interface/options/dht.go
new file mode 100644
index 000000000..92fd14f4a
--- /dev/null
+++ b/core/coreapi/interface/options/dht.go
@@ -0,0 +1,30 @@
+package options
+
+type DhtProvideSettings struct {
+	Recursive bool
+}
+
+type DhtProvideOption func(*DhtProvideSettings) error
+
+func DhtProvideOptions(opts ...DhtProvideOption) (*DhtProvideSettings, error) {
+	options := &DhtProvideSettings{
+		Recursive: false,
+	}
+
+	for _, opt := range opts {
+		err := opt(options)
+		if err != nil {
+			return nil, err
+		}
+	}
+	return options, nil
+}
+
+type DhtOptions struct{}
+
+func (api *DhtOptions) WithRecursive(recursive bool) DhtProvideOption {
+	return func(settings *DhtProvideSettings) error {
+		settings.Recursive = recursive
+		return nil
+	}
+}