appier.go

@@ -12,6 +12,7 @@ type Client struct {
 	Config        Config
 	natsServer    natsio.Server
 	natsJetStream natsio.JetStream
+	Pull          Pull
 }
 
 var (

constant.go

@@ -1,7 +1,8 @@
 package appier
 
 const (
-	SubjectRequestProductUpsert = "selly.request.product.upsert"
+	SubjectPingPullService   = "selly.pull.ping"
+	SubjectPullProductUpsert = "selly.pull.product.upsert"
 )
 
 const (

pull.go

@@ -5,5 +5,10 @@ type Pull struct{}
 
 // ProductUpsert ...
 func (Pull) ProductUpsert(payload Payload) (bool, error) {
-	return publishWithJetStream(JetStreamAppierService, SubjectRequestProductUpsert, toBytes(payload))
+	return publishWithJetStream(JetStreamAppierService, SubjectPullProductUpsert, payload.Data)
+}
+
+// PingService ...
+func (Pull) PingService(payload Payload) (bool, error) {
+	return publishWithJetStream(JetStreamAppierService, SubjectPingPullService, payload.Data)
 }