Selly-Modules
/
appier
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update

This commit is contained in:
Minh Nguyen 2022-03-23 17:03:44 +07:00
parent 1de83ecede
commit 7356fea139
2 changed files with 44 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
constant.go
View File

@ -3,6 +3,13 @@ package appier
const ( const (
SubjectPullProductUpsert = "selly.pull.product.upsert" SubjectPullProductUpsert = "selly.pull.product.upsert"
SubjectPullBrandUpsert = "selly.pull.brand.upsert" SubjectPullBrandUpsert = "selly.pull.brand.upsert"
SubjectPullCategoryUpsert = "selly.pull.category.upsert"
SubjectPullSubCategoryUpsert = "selly.pull.subcategory.upsert"
SubjectPullInventoryUpsert = "selly.pull.inventory.upsert"
SubjectPullSupplierUpsert = "selly.pull.supplier.upsert"
SubjectPullPropertyUpsert = "selly.pull.property.upsert"
SubjectPullPropertyValueUpsert = "selly.pull.property_value.upsert"
SubjectPullSKUUpsert = "selly.pull.sku.upsert"
) )
const ( const (

35
pull.go
View File

@ -12,3 +12,38 @@ func (Pull) ProductUpsert(payload []byte) (bool, error) {
func (Pull) BrandUpsert(payload []byte) (bool, error) { func (Pull) BrandUpsert(payload []byte) (bool, error) {
return publishWithJetStream(JetStreamAppierService, SubjectPullBrandUpsert, payload) return publishWithJetStream(JetStreamAppierService, SubjectPullBrandUpsert, payload)
} }
// CategoryUpsert ...
func (Pull) CategoryUpsert(payload []byte) (bool, error) {
return publishWithJetStream(JetStreamAppierService, SubjectPullCategoryUpsert, payload)
}
// SubCategoryUpsert ...
func (Pull) SubCategoryUpsert(payload []byte) (bool, error) {
return publishWithJetStream(JetStreamAppierService, SubjectPullSubCategoryUpsert, payload)
}
// SupplierUpsert ...
func (Pull) SupplierUpsert(payload []byte) (bool, error) {
return publishWithJetStream(JetStreamAppierService, SubjectPullSupplierUpsert, payload)
}
// InventoryUpsert ...
func (Pull) InventoryUpsert(payload []byte) (bool, error) {
return publishWithJetStream(JetStreamAppierService, SubjectPullInventoryUpsert, payload)
}
// SKUUpsert ...
func (Pull) SKUUpsert(payload []byte) (bool, error) {
return publishWithJetStream(JetStreamAppierService, SubjectPullSKUUpsert, payload)
}
// PropertyUpsert ...
func (Pull) PropertyUpsert(payload []byte) (bool, error) {
return publishWithJetStream(JetStreamAppierService, SubjectPullPropertyUpsert, payload)
}
// PropertyValueUpsert ...
func (Pull) PropertyValueUpsert(payload []byte) (bool, error) {
return publishWithJetStream(JetStreamAppierService, SubjectPullPropertyValueUpsert, payload)
}