-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'main' into 146-stripe-integration-for-111-nft
- Loading branch information
Showing
42 changed files
with
1,030 additions
and
179 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,14 @@ | ||
| package claim | ||
|
|
||
| import ( | ||
| "github.com/gin-gonic/gin" | ||
| ) | ||
|
|
||
| // ApplyRoutes applies router to gin Router | ||
| func ApplyRoutes(r *gin.RouterGroup) { | ||
| g := r.Group("/claim") | ||
| { | ||
| g.POST("start", startClaimDomain) | ||
| g.POST("finish", finishClaimDomain) | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,118 @@ | ||
| package claim | ||
|
|
||
| import ( | ||
| "errors" | ||
| "fmt" | ||
| "net" | ||
| "net/http" | ||
|
|
||
| "github.com/NetSepio/gateway/api/middleware/auth/paseto" | ||
| "github.com/NetSepio/gateway/config/dbconfig" | ||
| "github.com/NetSepio/gateway/models" | ||
| "github.com/NetSepio/gateway/util/pkg/logwrapper" | ||
| "github.com/TheLazarusNetwork/go-helpers/httpo" | ||
| "github.com/gin-gonic/gin" | ||
| "gorm.io/gorm" | ||
| ) | ||
|
|
||
| // finish claim, check if txt record in dns matches the domain name, if matches then add current user to admin | ||
| // verify txt using dig +short gmail.com txt check above code for refereance | ||
| func finishClaimDomain(c *gin.Context) { | ||
| db := dbconfig.GetDb() | ||
| var request FinishClaimDomainRequest | ||
| err := c.BindJSON(&request) | ||
| if err != nil { | ||
| httpo.NewErrorResponse(http.StatusBadRequest, fmt.Sprintf("payload is invalid %s", err)).SendD(c) | ||
| return | ||
| } | ||
|
|
||
| // fetch domainData from db | ||
| var domainData models.Domain | ||
| err = db.Model(&domainData).Where("id = ?", request.DomainId).First(&domainData).Error | ||
| if err != nil { | ||
| if errors.Is(err, gorm.ErrRecordNotFound) { | ||
| httpo.NewErrorResponse(http.StatusNotFound, "domain not found").SendD(c) | ||
| return | ||
| } | ||
| httpo.NewErrorResponse(http.StatusInternalServerError, "internal server error").SendD(c) | ||
| return | ||
| } | ||
| userId := c.GetString(paseto.CTX_USER_ID) | ||
| var claimTxt models.DomainClaim | ||
| err = db.Where("domain_id = ? and admin_id = ?", request.DomainId, userId).First(&claimTxt).Error | ||
| if err != nil { | ||
| httpo.NewErrorResponse(http.StatusForbidden, "claim record not found").SendD(c) | ||
| return | ||
| } | ||
|
|
||
| var domainAdmin models.DomainAdmin | ||
| err = db.Where("domain_id = ?", request.DomainId).First(&domainAdmin).Error | ||
| if err == nil { | ||
| httpo.NewErrorResponse(http.StatusForbidden, "domain is already claimed").SendD(c) | ||
| return | ||
| } | ||
| if err != gorm.ErrRecordNotFound { | ||
| logwrapper.Errorf("failed to query domain admin: %s", err) | ||
| httpo.NewErrorResponse(http.StatusNotFound, "domain admin not found").SendD(c) | ||
| return | ||
| } | ||
|
|
||
| txts, err := net.LookupTXT(domainData.DomainName) | ||
| if err != nil { | ||
| var dnsError *net.DNSError | ||
| if errors.As(err, &dnsError) { | ||
| if dnsError.IsNotFound { | ||
| httpo.NewErrorResponse(http.StatusNotFound, "record not found in dns").SendD(c) | ||
| return | ||
| } | ||
| } | ||
| logwrapper.Errorf("failed to lookup domain: %s", err) | ||
| httpo.NewErrorResponse(http.StatusInternalServerError, "internal server error").SendD(c) | ||
| return | ||
| } | ||
| if len(txts) == 0 { | ||
| httpo.NewErrorResponse(http.StatusNotFound, "txt records are empty").SendD(c) | ||
| return | ||
| } | ||
|
|
||
| validTxtFound := false | ||
| for _, txt := range txts { | ||
| if txt == *domainData.TxtValue { | ||
| validTxtFound = true | ||
| break | ||
| } | ||
| } | ||
| if !validTxtFound { | ||
| httpo.NewErrorResponse(400, "no valid txt record found").SendD(c) | ||
| return | ||
| } | ||
|
|
||
| // Add current user to admin | ||
| newDomainAdmin := models.DomainAdmin{ | ||
| DomainId: request.DomainId, | ||
| AdminId: userId, | ||
| UpdatedById: userId, | ||
| } | ||
|
|
||
| // Insert into db | ||
| err = db.Transaction(func(tx *gorm.DB) error { | ||
| if err := tx.Create(&newDomainAdmin).Error; err != nil { | ||
| return fmt.Errorf("failed to create domain admin: %s", err) | ||
| } | ||
|
|
||
| // update domain set verified to true | ||
| if err := tx.Model(&domainData).Where("id = ?", request.DomainId).Update("verified", true).Update("claimable", false).Error; err != nil { | ||
| return fmt.Errorf("failed to update domain: %s", err) | ||
| } | ||
|
|
||
| return nil | ||
| }) | ||
|
|
||
| if err != nil { | ||
| logwrapper.Errorf("failed to complete transaction: %s", err) | ||
| httpo.NewErrorResponse(http.StatusInternalServerError, "internal server error").SendD(c) | ||
| return | ||
| } | ||
|
|
||
| httpo.NewSuccessResponse(200, "domain claim completed").SendD(c) | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,72 @@ | ||
| package claim | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "net/http" | ||
|
|
||
| "github.com/NetSepio/gateway/api/middleware/auth/paseto" | ||
| "github.com/NetSepio/gateway/config/dbconfig" | ||
| "github.com/NetSepio/gateway/models" | ||
| "github.com/NetSepio/gateway/util/pkg/logwrapper" | ||
| "github.com/TheLazarusNetwork/go-helpers/httpo" | ||
| "github.com/gin-gonic/gin" | ||
| "github.com/google/uuid" | ||
| "gorm.io/gorm" | ||
| ) | ||
|
|
||
| func startClaimDomain(c *gin.Context) { | ||
| db := dbconfig.GetDb() | ||
| var request ClaimDomainRequest | ||
| err := c.BindJSON(&request) | ||
| if err != nil { | ||
| httpo.NewErrorResponse(http.StatusBadRequest, fmt.Sprintf("payload is invalid %s", err)).SendD(c) | ||
| return | ||
| } | ||
|
|
||
| var domain models.Domain | ||
| err = db.Where("id = ?", request.DomainId).First(&domain).Error | ||
| if err != nil { | ||
| httpo.NewErrorResponse(http.StatusNotFound, "domain not found").SendD(c) | ||
| return | ||
| } | ||
|
|
||
| if !domain.Claimable { | ||
| httpo.NewErrorResponse(http.StatusForbidden, "domain is not claimable").SendD(c) | ||
| return | ||
| } | ||
|
|
||
| txtValue := fmt.Sprintf("netsepio_verification=%s", uuid.NewString()) | ||
| userId := c.GetString(paseto.CTX_USER_ID) | ||
| err = db.Transaction(func(tx *gorm.DB) error { | ||
| // insert txt record in new model | ||
| newClaimTxt := models.DomainClaim{ | ||
| ID: uuid.NewString(), | ||
| DomainID: request.DomainId, | ||
| Txt: txtValue, | ||
| AdminId: userId, | ||
| } | ||
|
|
||
| //remove all txt claim records for this domain and current user as admin | ||
| if err := tx.Where("domain_id = ? and admin_id = ?", request.DomainId, userId).Delete(&models.DomainClaim{}).Error; err != nil { | ||
| return fmt.Errorf("failed to delete claim txt: %s", err) | ||
| } | ||
| // insert into db | ||
| if err := tx.Create(&newClaimTxt).Error; err != nil { | ||
| return fmt.Errorf("failed to create claim txt: %s", err) | ||
| } | ||
|
|
||
| return nil | ||
| }) | ||
|
|
||
| if err != nil { | ||
| logwrapper.Errorf("failed to create claim txt: %s", err) | ||
| httpo.NewErrorResponse(http.StatusInternalServerError, "internal server error").SendD(c) | ||
| return | ||
| } | ||
| //return txt record | ||
| payload := ClaimDomainResponse{ | ||
| TxtValue: txtValue, | ||
| } | ||
| httpo.NewSuccessResponseP(200, "domain claimed", payload).SendD(c) | ||
|
|
||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,13 @@ | ||
| package claim | ||
|
|
||
| type ClaimDomainRequest struct { | ||
| DomainId string `json:"domainId" binding:"required"` | ||
| } | ||
|
|
||
| type ClaimDomainResponse struct { | ||
| TxtValue string `json:"txtValue"` | ||
| } | ||
|
|
||
| type FinishClaimDomainRequest struct { | ||
| DomainId string `json:"domainId" binding:"required"` | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.