From e1f7e99027c88aaca19c603e8056fabdb11563c7 Mon Sep 17 00:00:00 2001 From: Bastian de Byl Date: Sun, 26 Feb 2023 21:23:37 -0500 Subject: [PATCH] moved webhook to go-snipcart-webhook repo --- example.go => examples/example.go | 0 .../example_get_order.go | 0 .../example_update_order.go | 0 go.mod | 29 +--- webhook.go | 162 ------------------ 5 files changed, 1 insertion(+), 190 deletions(-) rename example.go => examples/example.go (100%) rename example_get_order.go => examples/example_get_order.go (100%) rename example_update_order.go => examples/example_update_order.go (100%) delete mode 100644 webhook.go diff --git a/example.go b/examples/example.go similarity index 100% rename from example.go rename to examples/example.go diff --git a/example_get_order.go b/examples/example_get_order.go similarity index 100% rename from example_get_order.go rename to examples/example_get_order.go diff --git a/example_update_order.go b/examples/example_update_order.go similarity index 100% rename from example_update_order.go rename to examples/example_update_order.go diff --git a/go.mod b/go.mod index 38d1a69..726feca 100644 --- a/go.mod +++ b/go.mod @@ -1,36 +1,9 @@ module github.com/debyltech/go-snipcart -go 1.20 +go 1.19 require ( github.com/debyltech/go-helpers v1.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 ) - -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 -) diff --git a/webhook.go b/webhook.go deleted file mode 100644 index cd6371b..0000000 --- a/webhook.go +++ /dev/null @@ -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") -}