feature: implement the task mgr

Signed-off-by: Starnop <[email protected]>

apis/swagger.yml

@@ -562,6 +562,11 @@ definitions:
           downloads, if there is already a task a.b.com/fileA.
         items:
           type: "string"
+      peerID:
+        type: "string"
+        description: |
+          PeerID is used to uniquely identifies a peer which will be used to create a dfgetTask.
+          The value must be the value in the response after registering a peer.
 
   TaskCreateResponse:
     type: "object"
@@ -648,12 +653,6 @@ definitions:
           the same taskURL and taskID to download file, A and B will share the same peer network to distribute files.
           If user A additionally adds an identifier with taskURL, while user B still carries only taskURL, then A's
           generated taskID is different from B, and the result is that two users use different peer networks.
-      path:
-        type: "string"
-        description: |
-          path is used in one peer A for uploading functionality. When peer B hopes
-          to get piece C from peer A, B must provide a URL for piece C.
-          Then when creating a task in supernode, peer A must provide this URL in request.
       headers:
         type: "object"
         description: |

common/errors/errors.go

@@ -58,6 +58,9 @@ const (
 	codePeerWait
 	codeUnknowError
 	codePeerContinue
+	codeURLNotReachable
+	codeTaskIDDuplicate
+	codeAuthenticationRequired
 )
 
 // DfError represents a Dragonfly error.

common/errors/supernode_errors.go

@@ -36,6 +36,15 @@ var (
 
 	// PeerContinue represents the peer should wait.
 	PeerContinue = DfError{codePeerContinue, "peer continue"}
+
+	// ErrURLNotReachable represents the url is a not reachable.
+	ErrURLNotReachable = DfError{codeURLNotReachable, "url not reachable"}
+
+	// ErrTaskIDDuplicate represents the task id is in conflict.
+	ErrTaskIDDuplicate = DfError{codeTaskIDDuplicate, "taskId conflict"}
+
+	// ErrAuthenticationRequired represents the authentication is required.
+	ErrAuthenticationRequired = DfError{codeAuthenticationRequired, "authentication required"}
 )
 
 // IsSystemError check the error is a system error or not.
@@ -67,3 +76,18 @@ func IsUnknowError(err error) bool {
 func IsPeerContinue(err error) bool {
 	return checkError(err, codePeerContinue)
 }
+
+// IsURLNotReachable check the error is a url not reachable or not.
+func IsURLNotReachable(err error) bool {
+	return checkError(err, codeURLNotReachable)
+}
+
+// IsTaskIDDuplicate check the error is a TaskIDDuplicate error or not.
+func IsTaskIDDuplicate(err error) bool {
+	return checkError(err, codeTaskIDDuplicate)
+}
+
+// IsAuthenticationRequired check the error is a AuthenticationRequired error or not.
+func IsAuthenticationRequired(err error) bool {
+	return checkError(err, codeAuthenticationRequired)
+}