list share

Author: boddumanohar

code/go/0chain.net/blobbercore/handler/handler.go

@@ -194,6 +194,11 @@ func setupHandlers(r *mux.Router) {
 RateLimitByGeneralRL(common.ToJSONResponse(WithConnection(RevokeShare)))).
 Methods(http.MethodOptions, http.MethodDelete)
 
+// list files shared in this allocation
+r.HandleFunc("/v1/marketplace/shareinfo/{allocation}",
+RateLimitByGeneralRL(common.ToJSONResponse(WithConnection(ListShare)))).
+Methods(http.MethodOptions, http.MethodGet)
+
 // lightweight http handler without heavy postgres transaction to improve performance
 
 r.HandleFunc("/v1/writemarker/lock/{allocation}",
@@ -648,7 +653,43 @@ func InsertShare(ctx context.Context, r *http.Request) (interface{}, error) {
 return map[string]interface{}{"message": "Share info added successfully"}, nil
 }
 
-//PrintCSS - print the common css elements
+// ListShare a list of files that clientID has shared
+func ListShare(ctx context.Context, r *http.Request) (interface{}, error) {
+
+ctx = setupHandlerContext(ctx, r)
+
+var (
+allocationID = ctx.Value(constants.ContextKeyAllocation).(string)
+clientID = ctx.Value(constants.ContextKeyClient).(string)
+)
+
+allocationObj, err := storageHandler.verifyAllocation(ctx, allocationID, true)
+if err != nil {
+return nil, common.NewError("invalid_parameters", "Invalid allocation id passed."+err.Error())
+}
+
+sign := r.Header.Get(common.ClientSignatureHeader)
+
+valid, err := verifySignatureFromRequest(allocationID, sign, allocationObj.OwnerPublicKey)
+if !valid || err != nil {
+return nil, common.NewError("invalid_signature", "Invalid signature")
+}
+
+if clientID != allocationObj.OwnerID {
+return nil, common.NewError("invalid_client", "Client has no access to share file")
+}
+
+shares, err := reference.ListShareInfoClientID(ctx, clientID)
+if err != nil {
+Logger.Error("failed_to_list_share", zap.Error(err))
+return nil, common.NewError("failed_to_list_share", "failed to list file share")
+}
+
+// get the files shared in that allocation
+return shares, nil
+}
+
+// PrintCSS - print the common css elements
 func PrintCSS(w http.ResponseWriter) {
 fmt.Fprintf(w, "<style>\n")
 fmt.Fprintf(w, ".number { text-align: right; }\n")

code/go/0chain.net/blobbercore/handler/handler_share_test.go

@@ -31,6 +31,7 @@ import (
 const (
 insertShare = "InsertShare"
 revokeShare = "RevokeShare"
+listShare = "ListShare"
 )
 
 func setupShareHandlers() (*mux.Router, map[string]string) {
@@ -45,10 +46,15 @@ func setupShareHandlers() (*mux.Router, map[string]string) {
 common.ToJSONResponse(
 WithReadOnlyConnection(RevokeShare))).Name(revokeShare).Methods(http.MethodDelete)
 
+router.HandleFunc(sharePath,
+common.ToJSONResponse(
+WithReadOnlyConnection(ListShare))).Name(revokeShare).Methods(http.MethodGet)
+
 return router,
 map[string]string{
 insertShare: http.MethodPost,
 revokeShare: http.MethodDelete,
+listShare: http.MethodGet,
 }
 }
 

code/go/0chain.net/blobbercore/reference/shareinfo.go

@@ -30,6 +30,20 @@ func AddShareInfo(ctx context.Context, shareInfo *ShareInfo) error {
 return db.Model(&ShareInfo{}).Create(shareInfo).Error
 }
 
+// ListShareInfo returns list of files I shared?? or list of files shared with??
+func ListShareInfoOwnerID(ctx context.Context, ownerID string) error {
+db := datastore.GetStore().GetTransaction(ctx)
+return db.Model(&ShareInfo{}).Where("owner_id=?", ownerID).Error // todo: fix
+}
+
+// ListShareInfo returns list of files I shared?? or list of files shared with??
+func ListShareInfoClientID(ctx context.Context, clientID string) ([]ShareInfo, error) {
+db := datastore.GetStore().GetTransaction(ctx)
+var shares []ShareInfo
+err := db.Where("client_id <> ?", clientID).Find(&shares).Error
+return shares, err
+}
+
 func DeleteShareInfo(ctx context.Context, shareInfo *ShareInfo) error {
 db := datastore.GetStore().GetTransaction(ctx)