Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
6ff851823e | ||
|
|
db6e320b7f | ||
|
|
563e6baeda | ||
|
|
e1f7e99027 |
29
go.mod
29
go.mod
@@ -1,36 +1,9 @@
|
|||||||
module github.com/debyltech/go-snipcart
|
module github.com/debyltech/go-snipcart
|
||||||
|
|
||||||
go 1.20
|
go 1.19
|
||||||
|
|
||||||
require (
|
require (
|
||||||
github.com/debyltech/go-helpers v1.1.0
|
github.com/debyltech/go-helpers v1.1.0
|
||||||
github.com/debyltech/go-shippr v0.1.0
|
github.com/debyltech/go-shippr v0.1.0
|
||||||
github.com/gin-gonic/gin v1.9.0
|
|
||||||
github.com/skip2/go-qrcode v0.0.0-20200617195104-da1b6568686e
|
github.com/skip2/go-qrcode v0.0.0-20200617195104-da1b6568686e
|
||||||
)
|
)
|
||||||
|
|
||||||
require (
|
|
||||||
github.com/bytedance/sonic v1.8.0 // indirect
|
|
||||||
github.com/chenzhuoyu/base64x v0.0.0-20221115062448-fe3a3abad311 // indirect
|
|
||||||
github.com/gin-contrib/sse v0.1.0 // indirect
|
|
||||||
github.com/go-playground/locales v0.14.1 // indirect
|
|
||||||
github.com/go-playground/universal-translator v0.18.1 // indirect
|
|
||||||
github.com/go-playground/validator/v10 v10.11.2 // indirect
|
|
||||||
github.com/goccy/go-json v0.10.0 // indirect
|
|
||||||
github.com/json-iterator/go v1.1.12 // indirect
|
|
||||||
github.com/klauspost/cpuid/v2 v2.0.9 // indirect
|
|
||||||
github.com/leodido/go-urn v1.2.1 // indirect
|
|
||||||
github.com/mattn/go-isatty v0.0.17 // indirect
|
|
||||||
github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421 // indirect
|
|
||||||
github.com/modern-go/reflect2 v1.0.2 // indirect
|
|
||||||
github.com/pelletier/go-toml/v2 v2.0.6 // indirect
|
|
||||||
github.com/twitchyliquid64/golang-asm v0.15.1 // indirect
|
|
||||||
github.com/ugorji/go/codec v1.2.9 // indirect
|
|
||||||
golang.org/x/arch v0.0.0-20210923205945-b76863e36670 // indirect
|
|
||||||
golang.org/x/crypto v0.5.0 // indirect
|
|
||||||
golang.org/x/net v0.7.0 // indirect
|
|
||||||
golang.org/x/sys v0.5.0 // indirect
|
|
||||||
golang.org/x/text v0.7.0 // indirect
|
|
||||||
google.golang.org/protobuf v1.28.1 // indirect
|
|
||||||
gopkg.in/yaml.v3 v3.0.1 // indirect
|
|
||||||
)
|
|
||||||
|
|||||||
@@ -68,6 +68,7 @@ type SnipcartOrder struct {
|
|||||||
TrackingUrl string `json:"trackingUrl"`
|
TrackingUrl string `json:"trackingUrl"`
|
||||||
ShippingCost float64 `json:"shippingFees"`
|
ShippingCost float64 `json:"shippingFees"`
|
||||||
Items []SnipcartItem `json:"items"`
|
Items []SnipcartItem `json:"items"`
|
||||||
|
Metadata any `json:"metadata"`
|
||||||
}
|
}
|
||||||
|
|
||||||
type SnipcartOrderUpdate struct {
|
type SnipcartOrderUpdate struct {
|
||||||
|
|||||||
27
snipcart/webhook.go
Normal file
27
snipcart/webhook.go
Normal file
@@ -0,0 +1,27 @@
|
|||||||
|
package snipcart
|
||||||
|
|
||||||
|
type SnipcartShippingAddress struct {
|
||||||
|
FullName string `json:"fullName"`
|
||||||
|
FirstName string `json:"firstName"`
|
||||||
|
Name string `json:"name"`
|
||||||
|
Company string `json:"company"`
|
||||||
|
Address1 string `json:"address1"`
|
||||||
|
Address2 string `json:"address2"`
|
||||||
|
FullAddress string `json:"fullAddress"`
|
||||||
|
City string `json:"city"`
|
||||||
|
Country string `json:"country"`
|
||||||
|
PostalCode string `json:"postalCode"`
|
||||||
|
State string `json:"province"`
|
||||||
|
Phone string `json:"phone"`
|
||||||
|
VatNumber string `json:"vatNumber,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type SnipcartOrderEventContent struct {
|
||||||
|
Token string `json:"token"`
|
||||||
|
Status string `json:"status"`
|
||||||
|
PaymentStatus string `json:"paymentStatus"`
|
||||||
|
Email string `json:"email"`
|
||||||
|
Curreny string `json:"currency"`
|
||||||
|
Items []SnipcartItem `json:"items"`
|
||||||
|
ShippingAddress SnipcartShippingAddress `json:"shippingAddress"`
|
||||||
|
}
|
||||||
@@ -1,33 +0,0 @@
|
|||||||
package webhook
|
|
||||||
|
|
||||||
import (
|
|
||||||
"bytes"
|
|
||||||
"encoding/json"
|
|
||||||
"io/ioutil"
|
|
||||||
|
|
||||||
"github.com/debyltech/go-shippr/shippo"
|
|
||||||
)
|
|
||||||
|
|
||||||
type Config struct {
|
|
||||||
ShippoApiKey string `json:"shippo_api_key"`
|
|
||||||
WeightUnit string `json:"weight_unit"`
|
|
||||||
DimensionUnit string `json:"dimension_unit"`
|
|
||||||
ManufactureCountry string `json:"manufacture_country"`
|
|
||||||
SenderAddress shippo.Address `json:"sender_address"`
|
|
||||||
DefaultParcel shippo.Parcel `json:"default_parcel"`
|
|
||||||
}
|
|
||||||
|
|
||||||
func NewConfigFromFile(filePath string) (*Config, error) {
|
|
||||||
configBytes, err := ioutil.ReadFile(filePath)
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
|
|
||||||
var config Config
|
|
||||||
err = json.NewDecoder(bytes.NewBuffer(configBytes)).Decode(&config)
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
|
|
||||||
return &config, nil
|
|
||||||
}
|
|
||||||
162
webhook.go
162
webhook.go
@@ -1,162 +0,0 @@
|
|||||||
package main
|
|
||||||
|
|
||||||
import (
|
|
||||||
"encoding/json"
|
|
||||||
"errors"
|
|
||||||
"flag"
|
|
||||||
"fmt"
|
|
||||||
"log"
|
|
||||||
"net/http"
|
|
||||||
"strconv"
|
|
||||||
"time"
|
|
||||||
|
|
||||||
"github.com/debyltech/go-shippr/shippo"
|
|
||||||
"github.com/debyltech/go-snipcart/snipcart"
|
|
||||||
"github.com/debyltech/go-snipcart/snipcart/webhook"
|
|
||||||
"github.com/gin-gonic/gin"
|
|
||||||
)
|
|
||||||
|
|
||||||
const (
|
|
||||||
ValidateUrl string = "https://app.snipcart.com/api/requestvalidation/"
|
|
||||||
)
|
|
||||||
|
|
||||||
type ShippingWebhookEvent struct {
|
|
||||||
EventName string `json:"eventName"`
|
|
||||||
CreatedOn time.Time `json:"createdOn"`
|
|
||||||
Order snipcart.SnipcartOrder `json:"content"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type ShippingRatesResponse struct {
|
|
||||||
Cost float64 `json:"cost"`
|
|
||||||
Description string `json:"description"`
|
|
||||||
DeliveryDays int `json:"guaranteedDaysToDelivery"`
|
|
||||||
}
|
|
||||||
|
|
||||||
func ValidateWebhook(token string) error {
|
|
||||||
validateRequest, err := http.Get(ValidateUrl + token)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
if validateRequest.StatusCode < 200 || validateRequest.StatusCode >= 300 {
|
|
||||||
return errors.New("non-2XX response received")
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func HandleShippingRates(config *webhook.Config, shippoClient *shippo.Client) gin.HandlerFunc {
|
|
||||||
fn := func(c *gin.Context) {
|
|
||||||
err := ValidateWebhook(c.GetHeader("X-Snipcart-RequestToken"))
|
|
||||||
if err != nil {
|
|
||||||
c.AbortWithError(http.StatusBadRequest, err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
var event ShippingWebhookEvent
|
|
||||||
err = json.NewDecoder(c.Request.Body).Decode(&event)
|
|
||||||
if err != nil {
|
|
||||||
c.AbortWithError(http.StatusInternalServerError, err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
defer c.Request.Body.Close()
|
|
||||||
|
|
||||||
var lineItems []shippo.LineItem
|
|
||||||
for _, v := range event.Order.Items {
|
|
||||||
lineItems = append(lineItems, shippo.LineItem{
|
|
||||||
Quantity: v.Quantity,
|
|
||||||
TotalPrice: fmt.Sprintf("%.2f", v.TotalPrice),
|
|
||||||
Currency: event.Order.Currency,
|
|
||||||
Weight: fmt.Sprintf("%.2f", v.Weight),
|
|
||||||
WeightUnit: config.WeightUnit,
|
|
||||||
Title: v.Name,
|
|
||||||
ManufactureCountry: config.ManufactureCountry,
|
|
||||||
Sku: v.ID,
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
parcel := config.DefaultParcel
|
|
||||||
parcel.WeightUnit = config.WeightUnit
|
|
||||||
parcel.DistanceUnit = config.DimensionUnit
|
|
||||||
parcel.Weight = fmt.Sprintf("%.2f", event.Order.TotalWeight)
|
|
||||||
|
|
||||||
rateRequest := shippo.RateRequest{
|
|
||||||
AddressFrom: shippo.Address{
|
|
||||||
Name: config.SenderAddress.Name,
|
|
||||||
Address1: config.SenderAddress.Address1,
|
|
||||||
Address2: config.SenderAddress.Address2,
|
|
||||||
City: config.SenderAddress.City,
|
|
||||||
State: config.SenderAddress.State,
|
|
||||||
Country: config.SenderAddress.Country,
|
|
||||||
PostalCode: config.SenderAddress.PostalCode,
|
|
||||||
},
|
|
||||||
AddressTo: shippo.Address{
|
|
||||||
Name: event.Order.Name,
|
|
||||||
Company: event.Order.Company,
|
|
||||||
Address1: event.Order.Address1,
|
|
||||||
Address2: event.Order.Address2,
|
|
||||||
City: event.Order.City,
|
|
||||||
Country: event.Order.Country,
|
|
||||||
State: event.Order.Province,
|
|
||||||
PostalCode: event.Order.PostalCode,
|
|
||||||
Phone: event.Order.Phone,
|
|
||||||
Email: event.Order.Email,
|
|
||||||
},
|
|
||||||
LineItems: lineItems,
|
|
||||||
Parcel: parcel,
|
|
||||||
}
|
|
||||||
|
|
||||||
rateResponse, err := shippoClient.GenerateRates(rateRequest)
|
|
||||||
if err != nil {
|
|
||||||
c.AbortWithError(http.StatusBadRequest, err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
var rates []ShippingRatesResponse
|
|
||||||
for _, v := range rateResponse.Rates {
|
|
||||||
cost, err := strconv.ParseFloat(v.Amount, 64)
|
|
||||||
if err != nil {
|
|
||||||
c.AbortWithError(http.StatusInternalServerError, err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
rates = append(rates, ShippingRatesResponse{
|
|
||||||
Cost: cost,
|
|
||||||
Description: v.Title,
|
|
||||||
DeliveryDays: v.EstimatedDays,
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
c.JSON(http.StatusOK, rates)
|
|
||||||
}
|
|
||||||
|
|
||||||
return fn
|
|
||||||
}
|
|
||||||
|
|
||||||
func main() {
|
|
||||||
configPath := flag.String("config", "", "path to config.json")
|
|
||||||
flag.Parse()
|
|
||||||
|
|
||||||
if *configPath == "" {
|
|
||||||
log.Fatal("config path not defined")
|
|
||||||
}
|
|
||||||
|
|
||||||
config, err := webhook.NewConfigFromFile(*configPath)
|
|
||||||
if err != nil {
|
|
||||||
log.Fatal(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
shippoClient := shippo.NewClient(config.ShippoApiKey)
|
|
||||||
|
|
||||||
r := gin.Default()
|
|
||||||
|
|
||||||
api := r.Group("/api")
|
|
||||||
{
|
|
||||||
v1 := api.Group("/v1")
|
|
||||||
{
|
|
||||||
v1.POST("/shipping", HandleShippingRates(config, &shippoClient))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
r.Run("localhost:8081")
|
|
||||||
}
|
|
||||||
Reference in New Issue
Block a user