Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
24 changes: 14 additions & 10 deletions code/go/0chain.net/blobbercore/handler/auth_ticket.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@ package handler

import (
"context"
"fmt"
"github.com/0chain/blobber/code/go/0chain.net/core/node"
"github.com/0chain/common/core/common"
"net/http"
Expand All @@ -19,24 +20,27 @@ type AuthTicketResponse struct {
//
// parameters:
//
// +name: Zbox-Signature
// in: header
// type: string
// description: Digital signature to verify that the sender is 0box service.
// +name: client_id
// type: string
// in: query
// description: Client ID is used as a payload to the token generated. The token represents a signed version of this string by the blobber's private key.
// +name: Zbox-Signature
// in: header
// type: string
// description: Digital signature to verify that the sender is 0box service.
// +name: client_id
// type: string
// in: query
// description: Client ID is used as a payload to the token generated. The token represents a signed version of this string by the blobber's private key.
//
// responses:
// 200: AuthTicketResponse
//
// 200: AuthTicketResponse
func GenerateAuthTicket(ctx context.Context, r *http.Request) (interface{}, error) {
clientID := r.URL.Query().Get("client_id")
if clientID == "" {
return nil, common.NewError("missing_client_id", "client_id is required")
}

signature, err := node.Self.Sign(clientID)
round := r.URL.Query().Get("round")

signature, err := node.Self.Sign(fmt.Sprintf("%s_%s", clientID, round))
if err != nil {
return nil, common.NewError("signature_failed", "signature failed")
}
Expand Down
Loading