Compare commits
50 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
623060eef4 | ||
|
|
891ff0daef | ||
|
|
ae0e5fc379 | ||
|
|
914e49e9be | ||
|
|
43eed98f7c | ||
|
|
de552fc8d4 | ||
|
|
70d6955a63 | ||
|
|
a8646a6d52 | ||
|
|
3b1991970b | ||
|
|
dd69d72adb | ||
|
|
8bcd564447 | ||
|
|
043da741fa | ||
|
|
a2fdeafc3c | ||
|
|
5e2a2afd42 | ||
|
|
d7c5fd3b74 | ||
|
|
b586a3184c | ||
|
|
805491571c | ||
|
|
10a9427598 | ||
|
|
3816c67b95 | ||
|
|
c18376739b | ||
|
|
6d85149be8 | ||
|
|
cf4ad9642d | ||
|
|
e1adf8cf4f | ||
|
|
73195a090f | ||
|
|
db81f246bf | ||
|
|
9c7218f937 | ||
|
|
543935289f | ||
|
|
a4127264ef | ||
|
|
5a74c2bae8 | ||
|
|
d7f1571e09 | ||
|
|
f18e21f181 | ||
|
|
d56cf589da | ||
|
|
9e631a91b1 | ||
|
|
e575ff03a8 | ||
|
|
0ec82e6397 | ||
|
|
687a5df39f | ||
|
|
131af89f4f | ||
|
|
b93afeec2f | ||
|
|
bc56b4d16a | ||
|
|
b08b64f5b2 | ||
|
|
ad93704f41 | ||
|
|
b97ee3132b | ||
|
|
cfdde462f4 | ||
|
|
e039b583e2 | ||
|
|
26571a41fa | ||
|
|
559a100e90 | ||
|
|
6ff851823e | ||
|
|
db6e320b7f | ||
|
|
563e6baeda | ||
|
|
e1f7e99027 |
42
.github/workflows/release.yml
vendored
Normal file
42
.github/workflows/release.yml
vendored
Normal file
@@ -0,0 +1,42 @@
|
|||||||
|
name: Release
|
||||||
|
on:
|
||||||
|
push:
|
||||||
|
branches: [main]
|
||||||
|
|
||||||
|
permissions:
|
||||||
|
contents: write
|
||||||
|
issues: write
|
||||||
|
pull-requests: write
|
||||||
|
|
||||||
|
jobs:
|
||||||
|
release:
|
||||||
|
runs-on: fedora
|
||||||
|
steps:
|
||||||
|
- name: Checkout
|
||||||
|
uses: actions/checkout@v4
|
||||||
|
with:
|
||||||
|
fetch-depth: 0
|
||||||
|
|
||||||
|
- name: Setup Node.js
|
||||||
|
uses: actions/setup-node@v4
|
||||||
|
with:
|
||||||
|
node-version: 'lts/*'
|
||||||
|
|
||||||
|
- name: Install semantic-release
|
||||||
|
run: |
|
||||||
|
npm install -g semantic-release \
|
||||||
|
@semantic-release/commit-analyzer \
|
||||||
|
@semantic-release/release-notes-generator \
|
||||||
|
@semantic-release/changelog \
|
||||||
|
@saithodev/semantic-release-gitea \
|
||||||
|
@semantic-release/git
|
||||||
|
|
||||||
|
- name: Release
|
||||||
|
env:
|
||||||
|
# Use Gitea's automatic token (requires contents: write permission above)
|
||||||
|
GITEA_TOKEN: ${{ secrets.GITHUB_TOKEN }}
|
||||||
|
GIT_AUTHOR_NAME: gitea-actions[bot]
|
||||||
|
GIT_AUTHOR_EMAIL: gitea-actions[bot]@users.noreply.git.debyl.io
|
||||||
|
GIT_COMMITTER_NAME: gitea-actions[bot]
|
||||||
|
GIT_COMMITTER_EMAIL: gitea-actions[bot]@users.noreply.git.debyl.io
|
||||||
|
run: npx semantic-release
|
||||||
1
.gitignore
vendored
1
.gitignore
vendored
@@ -1,3 +1,4 @@
|
|||||||
*.json
|
*.json
|
||||||
|
!.releaserc.json
|
||||||
*.sum
|
*.sum
|
||||||
config/*
|
config/*
|
||||||
44
.releaserc.json
Normal file
44
.releaserc.json
Normal file
@@ -0,0 +1,44 @@
|
|||||||
|
{
|
||||||
|
"branches": ["main"],
|
||||||
|
"plugins": [
|
||||||
|
[
|
||||||
|
"@semantic-release/commit-analyzer",
|
||||||
|
{
|
||||||
|
"preset": "angular",
|
||||||
|
"releaseRules": [
|
||||||
|
{"message": "*#patch*", "release": "patch"},
|
||||||
|
{"message": "*#minor*", "release": "minor"},
|
||||||
|
{"message": "*#major*", "release": "major"},
|
||||||
|
{"type": "fix", "release": "patch"},
|
||||||
|
{"type": "feat", "release": "minor"},
|
||||||
|
{"type": "perf", "release": "patch"}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
],
|
||||||
|
[
|
||||||
|
"@semantic-release/release-notes-generator",
|
||||||
|
{
|
||||||
|
"preset": "angular"
|
||||||
|
}
|
||||||
|
],
|
||||||
|
[
|
||||||
|
"@semantic-release/changelog",
|
||||||
|
{
|
||||||
|
"changelogFile": "CHANGELOG.md"
|
||||||
|
}
|
||||||
|
],
|
||||||
|
[
|
||||||
|
"@saithodev/semantic-release-gitea",
|
||||||
|
{
|
||||||
|
"giteaUrl": "https://git.debyl.io"
|
||||||
|
}
|
||||||
|
],
|
||||||
|
[
|
||||||
|
"@semantic-release/git",
|
||||||
|
{
|
||||||
|
"assets": ["CHANGELOG.md"],
|
||||||
|
"message": "chore(release): ${nextRelease.version} [skip ci]\n\n${nextRelease.notes}"
|
||||||
|
}
|
||||||
|
]
|
||||||
|
]
|
||||||
|
}
|
||||||
28
CHANGELOG.md
Normal file
28
CHANGELOG.md
Normal file
@@ -0,0 +1,28 @@
|
|||||||
|
# [0.6.0](https://git.debyl.io/debyltech/go-snipcart/compare/v0.5.2...v0.6.0) (2026-01-23)
|
||||||
|
|
||||||
|
|
||||||
|
### Features
|
||||||
|
|
||||||
|
* add price, url, image, description, archived fields to Product struct ([ae0e5fc](https://git.debyl.io/debyltech/go-snipcart/commit/ae0e5fc37953b1645eb6bf75f6c9fb291dd0a223))
|
||||||
|
|
||||||
|
## [0.5.2](https://git.debyl.io/debyltech/go-snipcart/compare/v0.5.1...v0.5.2) (2026-01-04)
|
||||||
|
|
||||||
|
|
||||||
|
### Bug Fixes
|
||||||
|
|
||||||
|
* use fedora runner label for Gitea Actions ([de552fc](https://git.debyl.io/debyltech/go-snipcart/commit/de552fc8d4c37fb5af5e93ce4f4b8ae6e8e4bfcc))
|
||||||
|
|
||||||
|
## [0.5.1](https://git.debyl.io/debyltech/go-snipcart/compare/v0.5.0...v0.5.1) (2026-01-03)
|
||||||
|
|
||||||
|
|
||||||
|
### Bug Fixes
|
||||||
|
|
||||||
|
* migrate semantic-release from GitHub to Gitea ([3b19919](https://git.debyl.io/debyltech/go-snipcart/commit/3b1991970b64ac8c983006d4cf18bc6e080d6511))
|
||||||
|
* remove persist-credentials to allow semantic-release push ([a8646a6](https://git.debyl.io/debyltech/go-snipcart/commit/a8646a6d5258435b26a052ad57136032bb949ec7))
|
||||||
|
|
||||||
|
# [0.5.0](https://git.debyl.io/debyltech/go-snipcart/compare/v0.4.1...v0.5.0) (2026-01-02)
|
||||||
|
|
||||||
|
|
||||||
|
### Features
|
||||||
|
|
||||||
|
* add discount and savings fields to Order struct ([043da74](https://git.debyl.io/debyltech/go-snipcart/commit/043da741fafd24e3fb0bddbe06880c81c1b64b1f))
|
||||||
31
example_get_orders_by.go
Normal file
31
example_get_orders_by.go
Normal file
@@ -0,0 +1,31 @@
|
|||||||
|
package main
|
||||||
|
|
||||||
|
import (
|
||||||
|
"flag"
|
||||||
|
"log"
|
||||||
|
|
||||||
|
"github.com/debyltech/go-snipcart/snipcart"
|
||||||
|
)
|
||||||
|
|
||||||
|
func main() {
|
||||||
|
snipcartApiKey := flag.String("key", "", "Snipcart API Key")
|
||||||
|
flag.Parse()
|
||||||
|
|
||||||
|
if *snipcartApiKey == "" {
|
||||||
|
log.Fatal("missing -key flag")
|
||||||
|
}
|
||||||
|
|
||||||
|
Client := snipcart.NewClient(*snipcartApiKey)
|
||||||
|
|
||||||
|
response, err := Client.GetOrders(map[string]string{
|
||||||
|
"placedBy": "bastian@bdebyl.net",
|
||||||
|
})
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal(err)
|
||||||
|
}
|
||||||
|
log.Println("no errors continuing")
|
||||||
|
|
||||||
|
for k, v := range response.Items {
|
||||||
|
log.Printf("%v: %v\n", k, v)
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -18,10 +18,10 @@ func main() {
|
|||||||
Client := snipcart.NewClient(*snipcartApiKey)
|
Client := snipcart.NewClient(*snipcartApiKey)
|
||||||
|
|
||||||
updateOrder := snipcart.SnipcartOrderUpdate{
|
updateOrder := snipcart.SnipcartOrderUpdate{
|
||||||
Status: snipcart.Delivered,
|
ShippingRateId: "b1f5a5bca34d4e9ea7a55c011b22644f;5677a809435d46cbbb5dda2485295326",
|
||||||
}
|
}
|
||||||
|
|
||||||
response, err := Client.UpdateOrder("b35990df-c0ca-4014-94de-1caa7bd7bb51", &updateOrder)
|
response, err := Client.UpdateOrder("e6e72c95-31df-4594-b9a3-8603ce3914c8", &updateOrder)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatal(err)
|
log.Fatal(err)
|
||||||
}
|
}
|
||||||
|
|||||||
34
go.mod
34
go.mod
@@ -1,36 +1,8 @@
|
|||||||
module github.com/debyltech/go-snipcart
|
module git.debyl.io/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.1
|
||||||
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
|
|
||||||
)
|
|
||||||
|
|||||||
47
snipcart/common.go
Normal file
47
snipcart/common.go
Normal file
@@ -0,0 +1,47 @@
|
|||||||
|
package snipcart
|
||||||
|
|
||||||
|
const (
|
||||||
|
defaultLimit = 50
|
||||||
|
apiUri = "https://app.snipcart.com"
|
||||||
|
ordersPath = "/api/orders"
|
||||||
|
productsPath = "/api/products"
|
||||||
|
validationPath = "/api/requestvalidation/"
|
||||||
|
)
|
||||||
|
|
||||||
|
var (
|
||||||
|
orderUri = apiUri + ordersPath
|
||||||
|
productsUri = apiUri + productsPath
|
||||||
|
validationUri = apiUri + validationPath
|
||||||
|
|
||||||
|
orderNotificationPath = "notifications"
|
||||||
|
)
|
||||||
|
|
||||||
|
type Address 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"`
|
||||||
|
Province string `json:"province"`
|
||||||
|
Phone string `json:"phone"`
|
||||||
|
VatNumber string `json:"vatNumber,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type Client struct {
|
||||||
|
Key string
|
||||||
|
AuthBase64 string
|
||||||
|
Limit int
|
||||||
|
}
|
||||||
|
|
||||||
|
type CustomField struct {
|
||||||
|
Name string `json:"name"`
|
||||||
|
Value string `json:"value"`
|
||||||
|
Type string `json:"type,omitempty"`
|
||||||
|
Options string `json:"options,omitempty"`
|
||||||
|
Required bool `json:"required"`
|
||||||
|
}
|
||||||
21
snipcart/enums.go
Normal file
21
snipcart/enums.go
Normal file
@@ -0,0 +1,21 @@
|
|||||||
|
package snipcart
|
||||||
|
|
||||||
|
type OrderStatus string
|
||||||
|
type NotificationType string
|
||||||
|
|
||||||
|
const (
|
||||||
|
InProgress OrderStatus = "InProgress" // Open cart, not finalized
|
||||||
|
Pending OrderStatus = "Pending" // Waiting for payment/processing
|
||||||
|
Processed OrderStatus = "Processed" // Order completed
|
||||||
|
Disputed OrderStatus = "Disputed" // Order has dispute
|
||||||
|
Shipped OrderStatus = "Shipped" // Order shipped
|
||||||
|
Delivered OrderStatus = "Delivered" // Order delivered
|
||||||
|
Dispatched OrderStatus = "Dispatched" // Order dispatched
|
||||||
|
Cancelled OrderStatus = "Cancelled" // Order cancelled
|
||||||
|
|
||||||
|
Comment NotificationType = "Comment"
|
||||||
|
OrderStatusChanged NotificationType = "OrderStatusChanged"
|
||||||
|
OrderShipped NotificationType = "OrderShipped"
|
||||||
|
TrackingNumber NotificationType = "TrackingNumber"
|
||||||
|
Invoice NotificationType = "Invice"
|
||||||
|
)
|
||||||
@@ -1,13 +0,0 @@
|
|||||||
package snipcart
|
|
||||||
|
|
||||||
type OrderStatus string
|
|
||||||
|
|
||||||
const (
|
|
||||||
Processed OrderStatus = "Processed"
|
|
||||||
Disputed = "Disputed"
|
|
||||||
Shipped = "Shipped"
|
|
||||||
Delivered = "Delivered"
|
|
||||||
Pending = "Pending"
|
|
||||||
Cancelled = "Cancelled"
|
|
||||||
Dispatched = "Dispatched"
|
|
||||||
)
|
|
||||||
@@ -5,40 +5,20 @@ import (
|
|||||||
"encoding/json"
|
"encoding/json"
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
"time"
|
||||||
|
|
||||||
helper "github.com/debyltech/go-helpers/json"
|
helper "github.com/debyltech/go-helpers/json"
|
||||||
"github.com/skip2/go-qrcode"
|
"github.com/skip2/go-qrcode"
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
type Item struct {
|
||||||
defaultLimit = 50
|
|
||||||
apiUri = "https://app.snipcart.com"
|
|
||||||
ordersPath = "/api/orders"
|
|
||||||
)
|
|
||||||
|
|
||||||
var (
|
|
||||||
orderUri = apiUri + ordersPath
|
|
||||||
)
|
|
||||||
|
|
||||||
type Client struct {
|
|
||||||
SnipcartKey string
|
|
||||||
AuthBase64 string
|
|
||||||
Limit int
|
|
||||||
}
|
|
||||||
|
|
||||||
type SnipcartCustomField struct {
|
|
||||||
Name string `json:"name"`
|
|
||||||
Value string `json:"value"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type SnipcartItem struct {
|
|
||||||
UUID string `json:"uniqueId"`
|
UUID string `json:"uniqueId"`
|
||||||
ID string `json:"id"`
|
ID string `json:"id"`
|
||||||
Name string `json:"name"`
|
Name string `json:"name"`
|
||||||
Quantity int `json:"quantity"`
|
Quantity int `json:"quantity"`
|
||||||
TotalWeight float64 `json:"totalWeight,omitempty"`
|
TotalWeight float64 `json:"totalWeight,omitempty"`
|
||||||
TotalPrice float64 `json:"totalPrice,omitempty"`
|
TotalPrice float64 `json:"totalPrice,omitempty"`
|
||||||
CustomFields []SnipcartCustomField `json:"customFields"`
|
CustomFields []CustomField `json:"customFields"`
|
||||||
Length float64 `json:"length,omitempty"`
|
Length float64 `json:"length,omitempty"`
|
||||||
Width float64 `json:"width,omitempty"`
|
Width float64 `json:"width,omitempty"`
|
||||||
Height float64 `json:"height,omitempty"`
|
Height float64 `json:"height,omitempty"`
|
||||||
@@ -46,51 +26,182 @@ type SnipcartItem struct {
|
|||||||
Shippable bool `json:"shippable,omitempty"`
|
Shippable bool `json:"shippable,omitempty"`
|
||||||
}
|
}
|
||||||
|
|
||||||
type SnipcartOrder struct {
|
type Discount struct {
|
||||||
|
ID string `json:"id"`
|
||||||
|
DiscountID string `json:"discountId"`
|
||||||
|
Name string `json:"name"`
|
||||||
|
Code string `json:"code,omitempty"`
|
||||||
|
Trigger string `json:"trigger,omitempty"`
|
||||||
|
Type string `json:"type,omitempty"`
|
||||||
|
Rate float64 `json:"rate,omitempty"`
|
||||||
|
Amount float64 `json:"amount,omitempty"`
|
||||||
|
AmountSaved float64 `json:"amountSaved,omitempty"`
|
||||||
|
NormalizedRate float64 `json:"normalizedRate,omitempty"`
|
||||||
|
Combinable bool `json:"combinable"`
|
||||||
|
HasSavedAmount bool `json:"hasSavedAmount"`
|
||||||
|
MaxDiscountsPerItem *int `json:"maxDiscountsPerItem,omitempty"`
|
||||||
|
TotalToReach *float64 `json:"totalToReach,omitempty"`
|
||||||
|
ProductIds string `json:"productIds,omitempty"`
|
||||||
|
Categories string `json:"categories,omitempty"`
|
||||||
|
NumberOfUsages int `json:"numberOfUsages,omitempty"`
|
||||||
|
AppliesOnAllRecurring bool `json:"appliesOnAllRecurringOrders"`
|
||||||
|
CreationDate string `json:"creationDate,omitempty"`
|
||||||
|
ModificationDate string `json:"modificationDate,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type OrderTax struct {
|
||||||
|
Name string `json:"taxName"`
|
||||||
|
Rate float64 `json:"taxRate"`
|
||||||
|
Amount float64 `json:"amount"`
|
||||||
|
NumberForInvoice string `json:"numberForInvoice"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type OrderNotification struct {
|
||||||
|
Id string `json:"id"`
|
||||||
|
Created time.Time `json:"creationDate"`
|
||||||
|
Type NotificationType `json:"type"`
|
||||||
|
DeliveryMethod string `json:"deliveryMethod"`
|
||||||
|
Message string `json:"message,omitempty"`
|
||||||
|
SendDate time.Time `json:"sentOn,omitempty"`
|
||||||
|
Subject string `json:"subject,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type OrderNotifications struct {
|
||||||
|
TotalNotifications int `json:"totalItems"`
|
||||||
|
Offset int `json:"offset"`
|
||||||
|
Limit int `json:"limit"`
|
||||||
|
Notifications []OrderNotification `json:"items"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type Order struct {
|
||||||
Token string `json:"token"`
|
Token string `json:"token"`
|
||||||
|
Created time.Time `json:"creationDate"`
|
||||||
|
Modified time.Time `json:"modificationDate"`
|
||||||
|
Completed time.Time `json:"completionDate"`
|
||||||
Invoice string `json:"invoiceNumber"`
|
Invoice string `json:"invoiceNumber"`
|
||||||
Subtotal float64 `json:"subtotal,omitempty"`
|
Subtotal float64 `json:"subtotal,omitempty"`
|
||||||
Currency string `json:"currency,omitempty"`
|
Currency string `json:"currency,omitempty"`
|
||||||
Total float64 `json:"grandTotal,omitempty"`
|
Total float64 `json:"grandTotal,omitempty"`
|
||||||
|
TotalTaxable float64 `json:"taxableTotal,omitempty"`
|
||||||
|
TotalTaxes float64 `json:"taxesTotal,omitempty"`
|
||||||
Status string `json:"status"`
|
Status string `json:"status"`
|
||||||
TotalWeight float64 `json:"totalWeight"`
|
TotalWeight float64 `json:"totalWeight"`
|
||||||
Name string `json:"shippingAddressName"`
|
ShippingAddressSameAsBilling bool `json:"shippingAddressSameAsBilling,omitempty"`
|
||||||
Company string `json:"shippingAddressCompanyName"`
|
ShippingAddress Address `json:"shippingAddress,omitempty"`
|
||||||
Address1 string `json:"shippingAddressAddress1"`
|
Name string `json:"shippingAddressName,omitempty"`
|
||||||
Address2 string `json:"shippingAddressAddress2"`
|
Company string `json:"shippingAddressCompanyName,omitempty"`
|
||||||
City string `json:"shippingAddressCity"`
|
Address1 string `json:"shippingAddressAddress1,omitempty"`
|
||||||
Province string `json:"shippingAddressProvince"`
|
Address2 string `json:"shippingAddressAddress2,omitempty"`
|
||||||
Country string `json:"shippingAddressCountry"`
|
City string `json:"shippingAddressCity,omitempty"`
|
||||||
PostalCode string `json:"shippingAddressPostalCode"`
|
Province string `json:"shippingAddressProvince,omitempty"`
|
||||||
|
Country string `json:"shippingAddressCountry,omitempty"`
|
||||||
|
PostalCode string `json:"shippingAddressPostalCode,omitempty"`
|
||||||
Phone string `json:"shippingAddressPhone,omitempty"`
|
Phone string `json:"shippingAddressPhone,omitempty"`
|
||||||
Email string `json:"email,omitempty"`
|
Email string `json:"email,omitempty"`
|
||||||
TrackingNumber string `json:"trackingNumber"`
|
TrackingNumber string `json:"trackingNumber"`
|
||||||
TrackingUrl string `json:"trackingUrl"`
|
TrackingUrl string `json:"trackingUrl"`
|
||||||
ShippingCost float64 `json:"shippingFees"`
|
ShippingCost float64 `json:"shippingFees"`
|
||||||
Items []SnipcartItem `json:"items"`
|
ShippingProvider string `json:"shippingProvider,omitempty"`
|
||||||
|
ShippingMethod string `json:"shippingMethod,omitempty"`
|
||||||
|
ShippingRateId string `json:"shippingRateUserDefinedId,omitempty"`
|
||||||
|
Discounts []Discount `json:"discounts,omitempty"`
|
||||||
|
SavedAmount float64 `json:"savedAmount,omitempty"`
|
||||||
|
TotalRebateRate float64 `json:"totalRebateRate,omitempty"`
|
||||||
|
Items []Item `json:"items"`
|
||||||
|
Taxes []OrderTax `json:"taxes,omitempty"`
|
||||||
|
Metadata any `json:"metadata"`
|
||||||
}
|
}
|
||||||
|
|
||||||
type SnipcartOrderUpdate struct {
|
type OrderUpdate struct {
|
||||||
Status OrderStatus `json:"status"`
|
Status OrderStatus `json:"status"`
|
||||||
PaymentStatus string `json:"paymentStatus,omitempty"`
|
PaymentStatus string `json:"paymentStatus,omitempty"`
|
||||||
TrackingNumber string `json:"trackingNumber,omitempty"`
|
TrackingNumber string `json:"trackingNumber,omitempty"`
|
||||||
TrackingUrl string `json:"trackingUrl,omitempty"`
|
TrackingUrl string `json:"trackingUrl,omitempty"`
|
||||||
|
ShippingRateId string `json:"shippingRateUserDefinedId,omitempty"`
|
||||||
Metadata any `json:"metadata,omitempty"`
|
Metadata any `json:"metadata,omitempty"`
|
||||||
}
|
}
|
||||||
|
|
||||||
type SnipcartOrders struct {
|
type Orders struct {
|
||||||
TotalItems int
|
TotalItems int
|
||||||
Items []SnipcartOrder
|
Offest int
|
||||||
|
Limit int
|
||||||
|
Items []Order
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewClient(snipcartApiKey string) Client {
|
type Notification struct {
|
||||||
return Client{
|
Type NotificationType `json:"type"`
|
||||||
SnipcartKey: snipcartApiKey,
|
DeliveryMethod string `json:"deliveryMethod"`
|
||||||
|
Message string `json:"message,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type NotificationResponse struct {
|
||||||
|
Id string `json:"id"`
|
||||||
|
Created time.Time `json:"creationDate"`
|
||||||
|
Type NotificationType `json:"type"`
|
||||||
|
DeliveryMethod string `json:"deliveryMethod"`
|
||||||
|
Body string `json:"body"`
|
||||||
|
Message string `json:"message"`
|
||||||
|
Subject string `json:"subject"`
|
||||||
|
SentOn time.Time `json:"sentOn"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type ProductVariant struct {
|
||||||
|
Stock int `json:"stock"`
|
||||||
|
Variation []any `json:"variation"`
|
||||||
|
AllowBackorder bool `json:"allowOutOfStockPurchases"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type ProductCustomField struct {
|
||||||
|
Name string `json:"name"`
|
||||||
|
Placeholder string `json:"placeholder"`
|
||||||
|
DisplayValue string `json:"displayValue"`
|
||||||
|
Type string `json:"type"`
|
||||||
|
Options string `json:"options"`
|
||||||
|
Required bool `json:"required"`
|
||||||
|
Value string `json:"value"`
|
||||||
|
Operation float64 `json:"operation"`
|
||||||
|
OptionsArray []string `json:"optionsArray"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type Product struct {
|
||||||
|
Token string `json:"id"`
|
||||||
|
Id string `json:"userDefinedId"`
|
||||||
|
Name string `json:"name"`
|
||||||
|
Price float64 `json:"price"`
|
||||||
|
Url string `json:"url"`
|
||||||
|
Image string `json:"image"`
|
||||||
|
Description string `json:"description"`
|
||||||
|
Archived bool `json:"archived"`
|
||||||
|
Stock int `json:"stock"`
|
||||||
|
TotalStock int `json:"totalStock"`
|
||||||
|
AllowBackorder bool `json:"allowOutOfStockPurchases"`
|
||||||
|
CustomFields []ProductCustomField `json:"customFields"`
|
||||||
|
Variants []ProductVariant `json:"variants"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type ProductsResponse struct {
|
||||||
|
Keywords string `json:"keywords"`
|
||||||
|
UserDefinedId string `json:"userDefinedId"`
|
||||||
|
Archived bool `json:"archived"`
|
||||||
|
From time.Time `json:"from"`
|
||||||
|
To time.Time `json:"to"`
|
||||||
|
OrderBy string `json:"orderBy"`
|
||||||
|
Paginated bool `json:"hasMoreResults"`
|
||||||
|
TotalItems int `json:"totalItems"`
|
||||||
|
Offset int `json:"offset"`
|
||||||
|
Limit int `json:"limit"`
|
||||||
|
Sort []any `json:"sort"`
|
||||||
|
Items []Product `json:"items"`
|
||||||
|
}
|
||||||
|
|
||||||
|
func NewClient(snipcartApiKey string) *Client {
|
||||||
|
return &Client{
|
||||||
|
Key: snipcartApiKey,
|
||||||
AuthBase64: base64.StdEncoding.EncodeToString([]byte(snipcartApiKey + ":")),
|
AuthBase64: base64.StdEncoding.EncodeToString([]byte(snipcartApiKey + ":")),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *Client) GetOrder(token string) (*SnipcartOrder, error) {
|
func (s *Client) GetOrder(token string) (*Order, error) {
|
||||||
response, err := helper.Get(orderUri+"/"+token, "Basic", s.AuthBase64, nil)
|
response, err := helper.Get(orderUri+"/"+token, "Basic", s.AuthBase64, nil)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
@@ -101,7 +212,7 @@ func (s *Client) GetOrder(token string) (*SnipcartOrder, error) {
|
|||||||
|
|
||||||
defer response.Body.Close()
|
defer response.Body.Close()
|
||||||
|
|
||||||
var order SnipcartOrder
|
var order Order
|
||||||
err = json.NewDecoder(response.Body).Decode(&order)
|
err = json.NewDecoder(response.Body).Decode(&order)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
@@ -110,7 +221,27 @@ func (s *Client) GetOrder(token string) (*SnipcartOrder, error) {
|
|||||||
return &order, nil
|
return &order, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *Client) GetOrders(queries map[string]string) (*SnipcartOrders, error) {
|
func (s *Client) GetOrderNotifications(token string) (*OrderNotifications, error) {
|
||||||
|
response, err := helper.Get(orderUri+"/"+token+"/"+orderNotificationPath, "Basic", s.AuthBase64, nil)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
if response.StatusCode < 200 && response.StatusCode >= 300 {
|
||||||
|
return nil, fmt.Errorf("unexpected response received: %s", response.Status)
|
||||||
|
}
|
||||||
|
|
||||||
|
defer response.Body.Close()
|
||||||
|
|
||||||
|
var notifications OrderNotifications
|
||||||
|
err = json.NewDecoder(response.Body).Decode(¬ifications)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
return ¬ifications, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *Client) GetOrders(queries map[string]string) (*Orders, error) {
|
||||||
response, err := helper.Get(orderUri, "Basic", s.AuthBase64, queries)
|
response, err := helper.Get(orderUri, "Basic", s.AuthBase64, queries)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
@@ -121,7 +252,7 @@ func (s *Client) GetOrders(queries map[string]string) (*SnipcartOrders, error) {
|
|||||||
|
|
||||||
defer response.Body.Close()
|
defer response.Body.Close()
|
||||||
|
|
||||||
var orders SnipcartOrders
|
var orders Orders
|
||||||
err = json.NewDecoder(response.Body).Decode(&orders)
|
err = json.NewDecoder(response.Body).Decode(&orders)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
@@ -130,7 +261,7 @@ func (s *Client) GetOrders(queries map[string]string) (*SnipcartOrders, error) {
|
|||||||
return &orders, nil
|
return &orders, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *Client) GetOrdersByStatus(status OrderStatus) (*SnipcartOrders, error) {
|
func (s *Client) GetOrdersByStatus(status OrderStatus) (*Orders, error) {
|
||||||
if status == "" {
|
if status == "" {
|
||||||
return nil, errors.New("status is not set")
|
return nil, errors.New("status is not set")
|
||||||
}
|
}
|
||||||
@@ -138,7 +269,7 @@ func (s *Client) GetOrdersByStatus(status OrderStatus) (*SnipcartOrders, error)
|
|||||||
return s.GetOrders(map[string]string{"status": string(status)})
|
return s.GetOrders(map[string]string{"status": string(status)})
|
||||||
}
|
}
|
||||||
|
|
||||||
func (o *SnipcartOrder) TokenPNGBase64() (string, error) {
|
func (o *Order) TokenPNGBase64() (string, error) {
|
||||||
img, err := qrcode.Encode("order:"+o.Token, qrcode.Medium, 128)
|
img, err := qrcode.Encode("order:"+o.Token, qrcode.Medium, 128)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return "", err
|
return "", err
|
||||||
@@ -147,7 +278,7 @@ func (o *SnipcartOrder) TokenPNGBase64() (string, error) {
|
|||||||
return base64.StdEncoding.EncodeToString(img), nil
|
return base64.StdEncoding.EncodeToString(img), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *Client) UpdateOrder(token string, orderUpdate *SnipcartOrderUpdate) (*SnipcartOrder, error) {
|
func (s *Client) UpdateOrder(token string, orderUpdate *OrderUpdate) (*Order, error) {
|
||||||
response, err := helper.Put(orderUri+"/"+token, "Basic", s.AuthBase64, orderUpdate)
|
response, err := helper.Put(orderUri+"/"+token, "Basic", s.AuthBase64, orderUpdate)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
@@ -155,11 +286,10 @@ func (s *Client) UpdateOrder(token string, orderUpdate *SnipcartOrderUpdate) (*S
|
|||||||
if response.StatusCode < 200 && response.StatusCode >= 300 {
|
if response.StatusCode < 200 && response.StatusCode >= 300 {
|
||||||
return nil, fmt.Errorf("unexpected response received: %s", response.Status)
|
return nil, fmt.Errorf("unexpected response received: %s", response.Status)
|
||||||
}
|
}
|
||||||
fmt.Println(response.Status)
|
|
||||||
|
|
||||||
defer response.Body.Close()
|
defer response.Body.Close()
|
||||||
|
|
||||||
var responseOrder SnipcartOrder
|
var responseOrder Order
|
||||||
err = json.NewDecoder(response.Body).Decode(&responseOrder)
|
err = json.NewDecoder(response.Body).Decode(&responseOrder)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
@@ -167,3 +297,64 @@ func (s *Client) UpdateOrder(token string, orderUpdate *SnipcartOrderUpdate) (*S
|
|||||||
|
|
||||||
return &responseOrder, nil
|
return &responseOrder, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *Client) SendNotification(token string, notification *Notification) (*NotificationResponse, error) {
|
||||||
|
response, err := helper.Post(orderUri+"/"+token+"/notifications", "Basic", s.AuthBase64, notification)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
defer response.Body.Close()
|
||||||
|
|
||||||
|
var responseNotification NotificationResponse
|
||||||
|
err = json.NewDecoder(response.Body).Decode(&responseNotification)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
return &responseNotification, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *Client) GetProducts(queries map[string]string) (*ProductsResponse, error) {
|
||||||
|
response, err := helper.Get(productsUri, "Basic", s.AuthBase64, queries)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
if response.StatusCode < 200 && response.StatusCode >= 300 {
|
||||||
|
return nil, fmt.Errorf("unexpected response received: %s", response.Status)
|
||||||
|
}
|
||||||
|
|
||||||
|
defer response.Body.Close()
|
||||||
|
|
||||||
|
var products ProductsResponse
|
||||||
|
err = json.NewDecoder(response.Body).Decode(&products)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
return &products, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *Client) GetProductById(id string) (*Product, error) {
|
||||||
|
response, err := helper.Get(productsUri, "Basic", s.AuthBase64, map[string]string{"userDefinedId": id})
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
if response.StatusCode < 200 && response.StatusCode >= 300 {
|
||||||
|
return nil, fmt.Errorf("unexpected response received: %s", response.Status)
|
||||||
|
}
|
||||||
|
|
||||||
|
defer response.Body.Close()
|
||||||
|
|
||||||
|
var products ProductsResponse
|
||||||
|
err = json.NewDecoder(response.Body).Decode(&products)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
if len(products.Items) < 1 {
|
||||||
|
return nil, fmt.Errorf("no products with id '%s'", id)
|
||||||
|
}
|
||||||
|
|
||||||
|
return &products.Items[0], nil
|
||||||
|
}
|
||||||
|
|||||||
86
snipcart/webhook.go
Normal file
86
snipcart/webhook.go
Normal file
@@ -0,0 +1,86 @@
|
|||||||
|
package snipcart
|
||||||
|
|
||||||
|
import (
|
||||||
|
"encoding/base64"
|
||||||
|
"fmt"
|
||||||
|
"net/http"
|
||||||
|
)
|
||||||
|
|
||||||
|
type ShippingError struct {
|
||||||
|
Key string `json:"key"`
|
||||||
|
Message string `json:"message"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type ShippingErrors struct {
|
||||||
|
Errors []ShippingError `json:"errors"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type TaxShippingInfo struct {
|
||||||
|
Fees float64 `json:"fees"`
|
||||||
|
Method string `json:"method"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type TaxContent struct {
|
||||||
|
Created int `json:"creationDate"`
|
||||||
|
Modified int `json:"modificationDate"`
|
||||||
|
Token string `json:"token"`
|
||||||
|
Email string `json:"email"`
|
||||||
|
ShipToBillingAddress bool `json:"shipToBillingAddress"`
|
||||||
|
BillingAddress Address `json:"billingAddress"`
|
||||||
|
ShippingAddress Address `json:"shippingAddress"`
|
||||||
|
InvoiceNumber string `json:"invoiceNumber"`
|
||||||
|
ShippingInformation TaxShippingInfo `json:"shippingInformation"`
|
||||||
|
Items []Item `json:"items"`
|
||||||
|
Discounts []any `json:"discounts"`
|
||||||
|
CustomFields []CustomField `json:"customFields"`
|
||||||
|
Plans []any `json:"plans"`
|
||||||
|
Refunds []any `json:"refunds"`
|
||||||
|
Taxes []any `json:"taxes"`
|
||||||
|
Currency string `json:"currency"`
|
||||||
|
Total float64 `json:"total"`
|
||||||
|
DiscountsTotal float64 `json:"discountsTotal"`
|
||||||
|
ItemsTotal float64 `json:"itemsTotal"`
|
||||||
|
TaxesTotal float64 `json:"taxesTotal"`
|
||||||
|
PlansTotal float64 `json:"plansTotal"`
|
||||||
|
TaxProvider any `json:"taxProvider"`
|
||||||
|
Metadata any `json:"metadata"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type TaxWebhook struct {
|
||||||
|
Content TaxContent `json:"content"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type Tax struct {
|
||||||
|
Name string `json:"name"`
|
||||||
|
Amount float64 `json:"amount"`
|
||||||
|
NumberForInvoice string `json:"numberForInvoice"`
|
||||||
|
Rate float64 `json:"rate"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type TaxResponse struct {
|
||||||
|
Taxes []Tax `json:"taxes"`
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *Client) ValidateWebhook(token string) error {
|
||||||
|
validateRequest, err := http.NewRequest("GET", validationUri+token, nil)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
client := &http.Client{}
|
||||||
|
|
||||||
|
auth := base64.StdEncoding.EncodeToString([]byte(s.Key + ":"))
|
||||||
|
validateRequest.Header.Set("Authorization", fmt.Sprintf("Basic %s", auth))
|
||||||
|
validateRequest.Header.Set("Accept", "application/json")
|
||||||
|
|
||||||
|
validateResponse, err := client.Do(validateRequest)
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("error validating webhook: %s", err.Error())
|
||||||
|
}
|
||||||
|
|
||||||
|
if validateResponse.StatusCode < 200 || validateResponse.StatusCode >= 300 {
|
||||||
|
return fmt.Errorf("non-2XX status code for validating webhook: %d", validateResponse.StatusCode)
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil
|
||||||
|
}
|
||||||
@@ -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